?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
rename AC3_MAX_FRAME_SIZE to AC3_FRAME_BUFFER_SIZE and increase the size
[ffmpeg-lucabe.git] / ffserver.c
blob08b89a885f178e2853617bb321a6d465b6807a0e
1 /*
2 * Multiple format streaming server
3 * Copyright (c) 2000, 2001, 2002 Fabrice Bellard
4 *
5 * This file is part of FFmpeg.
6 *
7 * FFmpeg is free software; you can redistribute it and/or
8 * modify it under the terms of the GNU Lesser General Public
9 * License as published by the Free Software Foundation; either
10 * version 2.1 of the License, or (at your option) any later version.
11 *
12 * FFmpeg is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * Lesser General Public License for more details.
16 *
17 * You should have received a copy of the GNU Lesser General Public
18 * License along with FFmpeg; if not, write to the Free Software
19 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
20 */
21
22 #define _XOPEN_SOURCE 600
23
24 #include "config.h"
25 #ifndef HAVE_CLOSESOCKET
26 #define closesocket close
27 #endif
28 #include <string.h>
29 #include <strings.h>
30 #include <stdlib.h>
31 #include "libavutil/random.h"
32 #include "libavutil/avstring.h"
33 #include "libavformat/avformat.h"
34 #include "libavformat/network.h"
35 #include "libavformat/os_support.h"
36 #include "libavformat/rtp.h"
37 #include "libavformat/rtsp.h"
38 #include "libavcodec/opt.h"
39 #include <stdarg.h>
40 #include <unistd.h>
41 #include <fcntl.h>
42 #include <sys/ioctl.h>
43 #ifdef HAVE_POLL_H
44 #include <poll.h>
45 #endif
46 #include <errno.h>
47 #include <sys/time.h>
48 #undef time //needed because HAVE_AV_CONFIG_H is defined on top
49 #include <time.h>
50 #include <sys/wait.h>
51 #include <signal.h>
52 #ifdef HAVE_DLFCN_H
53 #include <dlfcn.h>
54 #endif
55
56 #include "cmdutils.h"
57
58 #undef exit
59
60 const char program_name[] = "FFserver";
61 const int program_birth_year = 2000;
62
63 static const OptionDef options[];
64
65 /* maximum number of simultaneous HTTP connections */
66 #define HTTP_MAX_CONNECTIONS 2000
67
68 enum HTTPState {
69 HTTPSTATE_WAIT_REQUEST,
70 HTTPSTATE_SEND_HEADER,
71 HTTPSTATE_SEND_DATA_HEADER,
72 HTTPSTATE_SEND_DATA, /* sending TCP or UDP data */
73 HTTPSTATE_SEND_DATA_TRAILER,
74 HTTPSTATE_RECEIVE_DATA,
75 HTTPSTATE_WAIT_FEED, /* wait for data from the feed */
76 HTTPSTATE_READY,
77
78 RTSPSTATE_WAIT_REQUEST,
79 RTSPSTATE_SEND_REPLY,
80 RTSPSTATE_SEND_PACKET,
81 };
82
83 static const char *http_state[] = {
84 "HTTP_WAIT_REQUEST",
85 "HTTP_SEND_HEADER",
86
87 "SEND_DATA_HEADER",
88 "SEND_DATA",
89 "SEND_DATA_TRAILER",
90 "RECEIVE_DATA",
91 "WAIT_FEED",
92 "READY",
93
94 "RTSP_WAIT_REQUEST",
95 "RTSP_SEND_REPLY",
96 "RTSP_SEND_PACKET",
97 };
98
99 #define IOBUFFER_INIT_SIZE 8192
100
101 /* timeouts are in ms */
102 #define HTTP_REQUEST_TIMEOUT (15 * 1000)
103 #define RTSP_REQUEST_TIMEOUT (3600 * 24 * 1000)
104
105 #define SYNC_TIMEOUT (10 * 1000)
106
107 typedef struct {
108 int64_t count1, count2;
109 int64_t time1, time2;
110 } DataRateData;
111
112 /* context associated with one connection */
113 typedef struct HTTPContext {
114 enum HTTPState state;
115 int fd; /* socket file descriptor */
116 struct sockaddr_in from_addr; /* origin */
117 struct pollfd *poll_entry; /* used when polling */
118 int64_t timeout;
119 uint8_t *buffer_ptr, *buffer_end;
120 int http_error;
121 int post;
122 struct HTTPContext *next;
123 int got_key_frame; /* stream 0 => 1, stream 1 => 2, stream 2=> 4 */
124 int64_t data_count;
125 /* feed input */
126 int feed_fd;
127 /* input format handling */
128 AVFormatContext *fmt_in;
129 int64_t start_time; /* In milliseconds - this wraps fairly often */
130 int64_t first_pts; /* initial pts value */
131 int64_t cur_pts; /* current pts value from the stream in us */
132 int64_t cur_frame_duration; /* duration of the current frame in us */
133 int cur_frame_bytes; /* output frame size, needed to compute
134 the time at which we send each
135 packet */
136 int pts_stream_index; /* stream we choose as clock reference */
137 int64_t cur_clock; /* current clock reference value in us */
138 /* output format handling */
139 struct FFStream *stream;
140 /* -1 is invalid stream */
141 int feed_streams[MAX_STREAMS]; /* index of streams in the feed */
142 int switch_feed_streams[MAX_STREAMS]; /* index of streams in the feed */
143 int switch_pending;
144 AVFormatContext fmt_ctx; /* instance of FFStream for one user */
145 int last_packet_sent; /* true if last data packet was sent */
146 int suppress_log;
147 DataRateData datarate;
148 int wmp_client_id;
149 char protocol[16];
150 char method[16];
151 char url[128];
152 int buffer_size;
153 uint8_t *buffer;
154 int is_packetized; /* if true, the stream is packetized */
155 int packet_stream_index; /* current stream for output in state machine */
156
157 /* RTSP state specific */
158 uint8_t *pb_buffer; /* XXX: use that in all the code */
159 ByteIOContext *pb;
160 int seq; /* RTSP sequence number */
161
162 /* RTP state specific */
163 enum RTSPProtocol rtp_protocol;
164 char session_id[32]; /* session id */
165 AVFormatContext *rtp_ctx[MAX_STREAMS];
166
167 /* RTP/UDP specific */
168 URLContext *rtp_handles[MAX_STREAMS];
169
170 /* RTP/TCP specific */
171 struct HTTPContext *rtsp_c;
172 uint8_t *packet_buffer, *packet_buffer_ptr, *packet_buffer_end;
173 } HTTPContext;
174
175 /* each generated stream is described here */
176 enum StreamType {
177 STREAM_TYPE_LIVE,
178 STREAM_TYPE_STATUS,
179 STREAM_TYPE_REDIRECT,
180 };
181
182 enum IPAddressAction {
183 IP_ALLOW = 1,
184 IP_DENY,
185 };
186
187 typedef struct IPAddressACL {
188 struct IPAddressACL *next;
189 enum IPAddressAction action;
190 /* These are in host order */
191 struct in_addr first;
192 struct in_addr last;
193 } IPAddressACL;
194
195 /* description of each stream of the ffserver.conf file */
196 typedef struct FFStream {
197 enum StreamType stream_type;
198 char filename[1024]; /* stream filename */
199 struct FFStream *feed; /* feed we are using (can be null if
200 coming from file) */
201 AVFormatParameters *ap_in; /* input parameters */
202 AVInputFormat *ifmt; /* if non NULL, force input format */
203 AVOutputFormat *fmt;
204 IPAddressACL *acl;
205 int nb_streams;
206 int prebuffer; /* Number of millseconds early to start */
207 int64_t max_time; /* Number of milliseconds to run */
208 int send_on_key;
209 AVStream *streams[MAX_STREAMS];
210 int feed_streams[MAX_STREAMS]; /* index of streams in the feed */
211 char feed_filename[1024]; /* file name of the feed storage, or
212 input file name for a stream */
213 char author[512];
214 char title[512];
215 char copyright[512];
216 char comment[512];
217 pid_t pid; /* Of ffmpeg process */
218 time_t pid_start; /* Of ffmpeg process */
219 char **child_argv;
220 struct FFStream *next;
221 unsigned bandwidth; /* bandwidth, in kbits/s */
222 /* RTSP options */
223 char *rtsp_option;
224 /* multicast specific */
225 int is_multicast;
226 struct in_addr multicast_ip;
227 int multicast_port; /* first port used for multicast */
228 int multicast_ttl;
229 int loop; /* if true, send the stream in loops (only meaningful if file) */
230
231 /* feed specific */
232 int feed_opened; /* true if someone is writing to the feed */
233 int is_feed; /* true if it is a feed */
234 int readonly; /* True if writing is prohibited to the file */
235 int conns_served;
236 int64_t bytes_served;
237 int64_t feed_max_size; /* maximum storage size, zero means unlimited */
238 int64_t feed_write_index; /* current write position in feed (it wraps around) */
239 int64_t feed_size; /* current size of feed */
240 struct FFStream *next_feed;
241 } FFStream;
242
243 typedef struct FeedData {
244 long long data_count;
245 float avg_frame_size; /* frame size averaged over last frames with exponential mean */
246 } FeedData;
247
248 static struct sockaddr_in my_http_addr;
249 static struct sockaddr_in my_rtsp_addr;
250
251 static char logfilename[1024];
252 static HTTPContext *first_http_ctx;
253 static FFStream *first_feed; /* contains only feeds */
254 static FFStream *first_stream; /* contains all streams, including feeds */
255
256 static void new_connection(int server_fd, int is_rtsp);
257 static void close_connection(HTTPContext *c);
258
259 /* HTTP handling */
260 static int handle_connection(HTTPContext *c);
261 static int http_parse_request(HTTPContext *c);
262 static int http_send_data(HTTPContext *c);
263 static void compute_status(HTTPContext *c);
264 static int open_input_stream(HTTPContext *c, const char *info);
265 static int http_start_receive_data(HTTPContext *c);
266 static int http_receive_data(HTTPContext *c);
267
268 /* RTSP handling */
269 static int rtsp_parse_request(HTTPContext *c);
270 static void rtsp_cmd_describe(HTTPContext *c, const char *url);
271 static void rtsp_cmd_options(HTTPContext *c, const char *url);
272 static void rtsp_cmd_setup(HTTPContext *c, const char *url, RTSPHeader *h);
273 static void rtsp_cmd_play(HTTPContext *c, const char *url, RTSPHeader *h);
274 static void rtsp_cmd_pause(HTTPContext *c, const char *url, RTSPHeader *h);
275 static void rtsp_cmd_teardown(HTTPContext *c, const char *url, RTSPHeader *h);
276
277 /* SDP handling */
278 static int prepare_sdp_description(FFStream *stream, uint8_t **pbuffer,
279 struct in_addr my_ip);
280
281 /* RTP handling */
282 static HTTPContext *rtp_new_connection(struct sockaddr_in *from_addr,
283 FFStream *stream, const char *session_id,
284 enum RTSPProtocol rtp_protocol);
285 static int rtp_new_av_stream(HTTPContext *c,
286 int stream_index, struct sockaddr_in *dest_addr,
287 HTTPContext *rtsp_c);
288
289 static const char *my_program_name;
290 static const char *my_program_dir;
291
292 static const char *config_filename;
293 static int ffserver_debug;
294 static int ffserver_daemon;
295 static int no_launch;
296 static int need_to_start_children;
297
298 static int nb_max_connections = 5;
299 static int nb_connections;
300
301 static uint64_t max_bandwidth = 1000;
302 static uint64_t current_bandwidth;
303
304 static int64_t cur_time; // Making this global saves on passing it around everywhere
305
306 static AVRandomState random_state;
307
308 static FILE *logfile = NULL;
309
310 static char *ctime1(char *buf2)
311 {
312 time_t ti;
313 char *p;
314
315 ti = time(NULL);
316 p = ctime(&ti);
317 strcpy(buf2, p);
318 p = buf2 + strlen(p) - 1;
319 if (*p == '\n')
320 *p = '\0';
321 return buf2;
322 }
323
324 static void http_vlog(const char *fmt, va_list vargs)
325 {
326 static int print_prefix = 1;
327 if (logfile) {
328 if (print_prefix) {
329 char buf[32];
330 ctime1(buf);
331 fprintf(logfile, "%s ", buf);
332 }
333 print_prefix = strstr(fmt, "\n") != NULL;
334 vfprintf(logfile, fmt, vargs);
335 fflush(logfile);
336 }
337 }
338
339 void __attribute__ ((format (printf, 1, 2))) http_log(const char *fmt, ...)
340 {
341 va_list vargs;
342 va_start(vargs, fmt);
343 http_vlog(fmt, vargs);
344 va_end(vargs);
345 }
346
347 static void http_av_log(void *ptr, int level, const char *fmt, va_list vargs)
348 {
349 static int print_prefix = 1;
350 AVClass *avc = ptr ? *(AVClass**)ptr : NULL;
351 if (level > av_log_level)
352 return;
353 if (print_prefix && avc)
354 http_log("[%s @ %p]", avc->item_name(ptr), ptr);
355 print_prefix = strstr(fmt, "\n") != NULL;
356 http_vlog(fmt, vargs);
357 }
358
359 static void log_connection(HTTPContext *c)
360 {
361 if (c->suppress_log)
362 return;
363
364 http_log("%s - - [%s] \"%s %s\" %d %"PRId64"\n",
365 inet_ntoa(c->from_addr.sin_addr), c->method, c->url,
366 c->protocol, (c->http_error ? c->http_error : 200), c->data_count);
367 }
368
369 static void update_datarate(DataRateData *drd, int64_t count)
370 {
371 if (!drd->time1 && !drd->count1) {
372 drd->time1 = drd->time2 = cur_time;
373 drd->count1 = drd->count2 = count;
374 } else if (cur_time - drd->time2 > 5000) {
375 drd->time1 = drd->time2;
376 drd->count1 = drd->count2;
377 drd->time2 = cur_time;
378 drd->count2 = count;
379 }
380 }
381
382 /* In bytes per second */
383 static int compute_datarate(DataRateData *drd, int64_t count)
384 {
385 if (cur_time == drd->time1)
386 return 0;
387
388 return ((count - drd->count1) * 1000) / (cur_time - drd->time1);
389 }
390
391
392 static void start_children(FFStream *feed)
393 {
394 if (no_launch)
395 return;
396
397 for (; feed; feed = feed->next) {
398 if (feed->child_argv && !feed->pid) {
399 feed->pid_start = time(0);
400
401 feed->pid = fork();
402
403 if (feed->pid < 0) {
404 http_log("Unable to create children\n");
405 exit(1);
406 }
407 if (!feed->pid) {
408 /* In child */
409 char pathname[1024];
410 char *slash;
411 int i;
412
413 av_strlcpy(pathname, my_program_name, sizeof(pathname));
414
415 slash = strrchr(pathname, '/');
416 if (!slash)
417 slash = pathname;
418 else
419 slash++;
420 strcpy(slash, "ffmpeg");
421
422 http_log("Launch commandline: ");
423 http_log("%s ", pathname);
424 for (i = 1; feed->child_argv[i] && feed->child_argv[i][0]; i++)
425 http_log("%s ", feed->child_argv[i]);
426 http_log("\n");
427
428 for (i = 3; i < 256; i++)
429 close(i);
430
431 if (!ffserver_debug) {
432 i = open("/dev/null", O_RDWR);
433 if (i != -1) {
434 dup2(i, 0);
435 dup2(i, 1);
436 dup2(i, 2);
437 close(i);
438 }
439 }
440
441 /* This is needed to make relative pathnames work */
442 chdir(my_program_dir);
443
444 signal(SIGPIPE, SIG_DFL);
445
446 execvp(pathname, feed->child_argv);
447
448 _exit(1);
449 }
450 }
451 }
452 }
453
454 /* open a listening socket */
455 static int socket_open_listen(struct sockaddr_in *my_addr)
456 {
457 int server_fd, tmp;
458
459 server_fd = socket(AF_INET,SOCK_STREAM,0);
460 if (server_fd < 0) {
461 perror ("socket");
462 return -1;
463 }
464
465 tmp = 1;
466 setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR, &tmp, sizeof(tmp));
467
468 if (bind (server_fd, (struct sockaddr *) my_addr, sizeof (*my_addr)) < 0) {
469 char bindmsg[32];
470 snprintf(bindmsg, sizeof(bindmsg), "bind(port %d)", ntohs(my_addr->sin_port));
471 perror (bindmsg);
472 closesocket(server_fd);
473 return -1;
474 }
475
476 if (listen (server_fd, 5) < 0) {
477 perror ("listen");
478 closesocket(server_fd);
479 return -1;
480 }
481 ff_socket_nonblock(server_fd, 1);
482
483 return server_fd;
484 }
485
486 /* start all multicast streams */
487 static void start_multicast(void)
488 {
489 FFStream *stream;
490 char session_id[32];
491 HTTPContext *rtp_c;
492 struct sockaddr_in dest_addr;
493 int default_port, stream_index;
494
495 default_port = 6000;
496 for(stream = first_stream; stream != NULL; stream = stream->next) {
497 if (stream->is_multicast) {
498 /* open the RTP connection */
499 snprintf(session_id, sizeof(session_id), "%08x%08x",
500 av_random(&random_state), av_random(&random_state));
501
502 /* choose a port if none given */
503 if (stream->multicast_port == 0) {
504 stream->multicast_port = default_port;
505 default_port += 100;
506 }
507
508 dest_addr.sin_family = AF_INET;
509 dest_addr.sin_addr = stream->multicast_ip;
510 dest_addr.sin_port = htons(stream->multicast_port);
511
512 rtp_c = rtp_new_connection(&dest_addr, stream, session_id,
513 RTSP_PROTOCOL_RTP_UDP_MULTICAST);
514 if (!rtp_c)
515 continue;
516
517 if (open_input_stream(rtp_c, "") < 0) {
518 http_log("Could not open input stream for stream '%s'\n",
519 stream->filename);
520 continue;
521 }
522
523 /* open each RTP stream */
524 for(stream_index = 0; stream_index < stream->nb_streams;
525 stream_index++) {
526 dest_addr.sin_port = htons(stream->multicast_port +
527 2 * stream_index);
528 if (rtp_new_av_stream(rtp_c, stream_index, &dest_addr, NULL) < 0) {
529 http_log("Could not open output stream '%s/streamid=%d'\n",
530 stream->filename, stream_index);
531 exit(1);
532 }
533 }
534
535 /* change state to send data */
536 rtp_c->state = HTTPSTATE_SEND_DATA;
537 }
538 }
539 }
540
541 /* main loop of the http server */
542 static int http_server(void)
543 {
544 int server_fd = 0, rtsp_server_fd = 0;
545 int ret, delay, delay1;
546 struct pollfd poll_table[HTTP_MAX_CONNECTIONS + 2], *poll_entry;
547 HTTPContext *c, *c_next;
548
549 if (my_http_addr.sin_port) {
550 server_fd = socket_open_listen(&my_http_addr);
551 if (server_fd < 0)
552 return -1;
553 }
554
555 if (my_rtsp_addr.sin_port) {
556 rtsp_server_fd = socket_open_listen(&my_rtsp_addr);
557 if (rtsp_server_fd < 0)
558 return -1;
559 }
560
561 if (!rtsp_server_fd && !server_fd) {
562 http_log("HTTP and RTSP disabled.\n");
563 return -1;
564 }
565
566 http_log("ffserver started.\n");
567
568 start_children(first_feed);
569
570 start_multicast();
571
572 for(;;) {
573 poll_entry = poll_table;
574 if (server_fd) {
575 poll_entry->fd = server_fd;
576 poll_entry->events = POLLIN;
577 poll_entry++;
578 }
579 if (rtsp_server_fd) {
580 poll_entry->fd = rtsp_server_fd;
581 poll_entry->events = POLLIN;
582 poll_entry++;
583 }
584
585 /* wait for events on each HTTP handle */
586 c = first_http_ctx;
587 delay = 1000;
588 while (c != NULL) {
589 int fd;
590 fd = c->fd;
591 switch(c->state) {
592 case HTTPSTATE_SEND_HEADER:
593 case RTSPSTATE_SEND_REPLY:
594 case RTSPSTATE_SEND_PACKET:
595 c->poll_entry = poll_entry;
596 poll_entry->fd = fd;
597 poll_entry->events = POLLOUT;
598 poll_entry++;
599 break;
600 case HTTPSTATE_SEND_DATA_HEADER:
601 case HTTPSTATE_SEND_DATA:
602 case HTTPSTATE_SEND_DATA_TRAILER:
603 if (!c->is_packetized) {
604 /* for TCP, we output as much as we can (may need to put a limit) */
605 c->poll_entry = poll_entry;
606 poll_entry->fd = fd;
607 poll_entry->events = POLLOUT;
608 poll_entry++;
609 } else {
610 /* when ffserver is doing the timing, we work by
611 looking at which packet need to be sent every
612 10 ms */
613 delay1 = 10; /* one tick wait XXX: 10 ms assumed */
614 if (delay1 < delay)
615 delay = delay1;
616 }
617 break;
618 case HTTPSTATE_WAIT_REQUEST:
619 case HTTPSTATE_RECEIVE_DATA:
620 case HTTPSTATE_WAIT_FEED:
621 case RTSPSTATE_WAIT_REQUEST:
622 /* need to catch errors */
623 c->poll_entry = poll_entry;
624 poll_entry->fd = fd;
625 poll_entry->events = POLLIN;/* Maybe this will work */
626 poll_entry++;
627 break;
628 default:
629 c->poll_entry = NULL;
630 break;
631 }
632 c = c->next;
633 }
634
635 /* wait for an event on one connection. We poll at least every
636 second to handle timeouts */
637 do {
638 ret = poll(poll_table, poll_entry - poll_table, delay);
639 if (ret < 0 && ff_neterrno() != FF_NETERROR(EAGAIN) &&
640 ff_neterrno() != FF_NETERROR(EINTR))
641 return -1;
642 } while (ret < 0);
643
644 cur_time = av_gettime() / 1000;
645
646 if (need_to_start_children) {
647 need_to_start_children = 0;
648 start_children(first_feed);
649 }
650
651 /* now handle the events */
652 for(c = first_http_ctx; c != NULL; c = c_next) {
653 c_next = c->next;
654 if (handle_connection(c) < 0) {
655 /* close and free the connection */
656 log_connection(c);
657 close_connection(c);
658 }
659 }
660
661 poll_entry = poll_table;
662 if (server_fd) {
663 /* new HTTP connection request ? */
664 if (poll_entry->revents & POLLIN)
665 new_connection(server_fd, 0);
666 poll_entry++;
667 }
668 if (rtsp_server_fd) {
669 /* new RTSP connection request ? */
670 if (poll_entry->revents & POLLIN)
671 new_connection(rtsp_server_fd, 1);
672 }
673 }
674 }
675
676 /* start waiting for a new HTTP/RTSP request */
677 static void start_wait_request(HTTPContext *c, int is_rtsp)
678 {
679 c->buffer_ptr = c->buffer;
680 c->buffer_end = c->buffer + c->buffer_size - 1; /* leave room for '\0' */
681
682 if (is_rtsp) {
683 c->timeout = cur_time + RTSP_REQUEST_TIMEOUT;
684 c->state = RTSPSTATE_WAIT_REQUEST;
685 } else {
686 c->timeout = cur_time + HTTP_REQUEST_TIMEOUT;
687 c->state = HTTPSTATE_WAIT_REQUEST;
688 }
689 }
690
691 static void new_connection(int server_fd, int is_rtsp)
692 {
693 struct sockaddr_in from_addr;
694 int fd, len;
695 HTTPContext *c = NULL;
696
697 len = sizeof(from_addr);
698 fd = accept(server_fd, (struct sockaddr *)&from_addr,
699 &len);
700 if (fd < 0) {
701 http_log("error during accept %s\n", strerror(errno));
702 return;
703 }
704 ff_socket_nonblock(fd, 1);
705
706 /* XXX: should output a warning page when coming
707 close to the connection limit */
708 if (nb_connections >= nb_max_connections)
709 goto fail;
710
711 /* add a new connection */
712 c = av_mallocz(sizeof(HTTPContext));
713 if (!c)
714 goto fail;
715
716 c->fd = fd;
717 c->poll_entry = NULL;
718 c->from_addr = from_addr;
719 c->buffer_size = IOBUFFER_INIT_SIZE;
720 c->buffer = av_malloc(c->buffer_size);
721 if (!c->buffer)
722 goto fail;
723
724 c->next = first_http_ctx;
725 first_http_ctx = c;
726 nb_connections++;
727
728 start_wait_request(c, is_rtsp);
729
730 return;
731
732 fail:
733 if (c) {
734 av_free(c->buffer);
735 av_free(c);
736 }
737 closesocket(fd);
738 }
739
740 static void close_connection(HTTPContext *c)
741 {
742 HTTPContext **cp, *c1;
743 int i, nb_streams;
744 AVFormatContext *ctx;
745 URLContext *h;
746 AVStream *st;
747
748 /* remove connection from list */
749 cp = &first_http_ctx;
750 while ((*cp) != NULL) {
751 c1 = *cp;
752 if (c1 == c)
753 *cp = c->next;
754 else
755 cp = &c1->next;
756 }
757
758 /* remove references, if any (XXX: do it faster) */
759 for(c1 = first_http_ctx; c1 != NULL; c1 = c1->next) {
760 if (c1->rtsp_c == c)
761 c1->rtsp_c = NULL;
762 }
763
764 /* remove connection associated resources */
765 if (c->fd >= 0)
766 closesocket(c->fd);
767 if (c->fmt_in) {
768 /* close each frame parser */
769 for(i=0;i<c->fmt_in->nb_streams;i++) {
770 st = c->fmt_in->streams[i];
771 if (st->codec->codec)
772 avcodec_close(st->codec);
773 }
774 av_close_input_file(c->fmt_in);
775 }
776
777 /* free RTP output streams if any */
778 nb_streams = 0;
779 if (c->stream)
780 nb_streams = c->stream->nb_streams;
781
782 for(i=0;i<nb_streams;i++) {
783 ctx = c->rtp_ctx[i];
784 if (ctx) {
785 av_write_trailer(ctx);
786 av_free(ctx);
787 }
788 h = c->rtp_handles[i];
789 if (h)
790 url_close(h);
791 }
792
793 ctx = &c->fmt_ctx;
794
795 if (!c->last_packet_sent) {
796 if (ctx->oformat) {
797 /* prepare header */
798 if (url_open_dyn_buf(&ctx->pb) >= 0) {
799 av_write_trailer(ctx);
800 av_freep(&c->pb_buffer);
801 url_close_dyn_buf(ctx->pb, &c->pb_buffer);
802 }
803 }
804 }
805
806 for(i=0; i<ctx->nb_streams; i++)
807 av_free(ctx->streams[i]);
808
809 if (c->stream && !c->post && c->stream->stream_type == STREAM_TYPE_LIVE)
810 current_bandwidth -= c->stream->bandwidth;
811
812 /* signal that there is no feed if we are the feeder socket */
813 if (c->state == HTTPSTATE_RECEIVE_DATA && c->stream) {
814 c->stream->feed_opened = 0;
815 close(c->feed_fd);
816 }
817
818 av_freep(&c->pb_buffer);
819 av_freep(&c->packet_buffer);
820 av_free(c->buffer);
821 av_free(c);
822 nb_connections--;
823 }
824
825 static int handle_connection(HTTPContext *c)
826 {
827 int len, ret;
828
829 switch(c->state) {
830 case HTTPSTATE_WAIT_REQUEST:
831 case RTSPSTATE_WAIT_REQUEST:
832 /* timeout ? */
833 if ((c->timeout - cur_time) < 0)
834 return -1;
835 if (c->poll_entry->revents & (POLLERR | POLLHUP))
836 return -1;
837
838 /* no need to read if no events */
839 if (!(c->poll_entry->revents & POLLIN))
840 return 0;
841 /* read the data */
842 read_loop:
843 len = recv(c->fd, c->buffer_ptr, 1, 0);
844 if (len < 0) {
845 if (ff_neterrno() != FF_NETERROR(EAGAIN) &&
846 ff_neterrno() != FF_NETERROR(EINTR))
847 return -1;
848 } else if (len == 0) {
849 return -1;
850 } else {
851 /* search for end of request. */
852 uint8_t *ptr;
853 c->buffer_ptr += len;
854 ptr = c->buffer_ptr;
855 if ((ptr >= c->buffer + 2 && !memcmp(ptr-2, "\n\n", 2)) ||
856 (ptr >= c->buffer + 4 && !memcmp(ptr-4, "\r\n\r\n", 4))) {
857 /* request found : parse it and reply */
858 if (c->state == HTTPSTATE_WAIT_REQUEST) {
859 ret = http_parse_request(c);
860 } else {
861 ret = rtsp_parse_request(c);
862 }
863 if (ret < 0)
864 return -1;
865 } else if (ptr >= c->buffer_end) {
866 /* request too long: cannot do anything */
867 return -1;
868 } else goto read_loop;
869 }
870 break;
871
872 case HTTPSTATE_SEND_HEADER:
873 if (c->poll_entry->revents & (POLLERR | POLLHUP))
874 return -1;
875
876 /* no need to write if no events */
877 if (!(c->poll_entry->revents & POLLOUT))
878 return 0;
879 len = send(c->fd, c->buffer_ptr, c->buffer_end - c->buffer_ptr, 0);
880 if (len < 0) {
881 if (ff_neterrno() != FF_NETERROR(EAGAIN) &&
882 ff_neterrno() != FF_NETERROR(EINTR)) {
883 /* error : close connection */
884 av_freep(&c->pb_buffer);
885 return -1;
886 }
887 } else {
888 c->buffer_ptr += len;
889 if (c->stream)
890 c->stream->bytes_served += len;
891 c->data_count += len;
892 if (c->buffer_ptr >= c->buffer_end) {
893 av_freep(&c->pb_buffer);
894 /* if error, exit */
895 if (c->http_error)
896 return -1;
897 /* all the buffer was sent : synchronize to the incoming stream */
898 c->state = HTTPSTATE_SEND_DATA_HEADER;
899 c->buffer_ptr = c->buffer_end = c->buffer;
900 }
901 }
902 break;
903
904 case HTTPSTATE_SEND_DATA:
905 case HTTPSTATE_SEND_DATA_HEADER:
906 case HTTPSTATE_SEND_DATA_TRAILER:
907 /* for packetized output, we consider we can always write (the
908 input streams sets the speed). It may be better to verify
909 that we do not rely too much on the kernel queues */
910 if (!c->is_packetized) {
911 if (c->poll_entry->revents & (POLLERR | POLLHUP))
912 return -1;
913
914 /* no need to read if no events */
915 if (!(c->poll_entry->revents & POLLOUT))
916 return 0;
917 }
918 if (http_send_data(c) < 0)
919 return -1;
920 /* close connection if trailer sent */
921 if (c->state == HTTPSTATE_SEND_DATA_TRAILER)
922 return -1;
923 break;
924 case HTTPSTATE_RECEIVE_DATA:
925 /* no need to read if no events */
926 if (c->poll_entry->revents & (POLLERR | POLLHUP))
927 return -1;
928 if (!(c->poll_entry->revents & POLLIN))
929 return 0;
930 if (http_receive_data(c) < 0)
931 return -1;
932 break;
933 case HTTPSTATE_WAIT_FEED:
934 /* no need to read if no events */
935 if (c->poll_entry->revents & (POLLIN | POLLERR | POLLHUP))
936 return -1;
937
938 /* nothing to do, we'll be waken up by incoming feed packets */
939 break;
940
941 case RTSPSTATE_SEND_REPLY:
942 if (c->poll_entry->revents & (POLLERR | POLLHUP)) {
943 av_freep(&c->pb_buffer);
944 return -1;
945 }
946 /* no need to write if no events */
947 if (!(c->poll_entry->revents & POLLOUT))
948 return 0;
949 len = send(c->fd, c->buffer_ptr, c->buffer_end - c->buffer_ptr, 0);
950 if (len < 0) {
951 if (ff_neterrno() != FF_NETERROR(EAGAIN) &&
952 ff_neterrno() != FF_NETERROR(EINTR)) {
953 /* error : close connection */
954 av_freep(&c->pb_buffer);
955 return -1;
956 }
957 } else {
958 c->buffer_ptr += len;
959 c->data_count += len;
960 if (c->buffer_ptr >= c->buffer_end) {
961 /* all the buffer was sent : wait for a new request */
962 av_freep(&c->pb_buffer);
963 start_wait_request(c, 1);
964 }
965 }
966 break;
967 case RTSPSTATE_SEND_PACKET:
968 if (c->poll_entry->revents & (POLLERR | POLLHUP)) {
969 av_freep(&c->packet_buffer);
970 return -1;
971 }
972 /* no need to write if no events */
973 if (!(c->poll_entry->revents & POLLOUT))
974 return 0;
975 len = send(c->fd, c->packet_buffer_ptr,
976 c->packet_buffer_end - c->packet_buffer_ptr, 0);
977 if (len < 0) {
978 if (ff_neterrno() != FF_NETERROR(EAGAIN) &&
979 ff_neterrno() != FF_NETERROR(EINTR)) {
980 /* error : close connection */
981 av_freep(&c->packet_buffer);
982 return -1;
983 }
984 } else {
985 c->packet_buffer_ptr += len;
986 if (c->packet_buffer_ptr >= c->packet_buffer_end) {
987 /* all the buffer was sent : wait for a new request */
988 av_freep(&c->packet_buffer);
989 c->state = RTSPSTATE_WAIT_REQUEST;
990 }
991 }
992 break;
993 case HTTPSTATE_READY:
994 /* nothing to do */
995 break;
996 default:
997 return -1;
998 }
999 return 0;
1000 }
1001
1002 static int extract_rates(char *rates, int ratelen, const char *request)
1003 {
1004 const char *p;
1005
1006 for (p = request; *p && *p != '\r' && *p != '\n'; ) {
1007 if (strncasecmp(p, "Pragma:", 7) == 0) {
1008 const char *q = p + 7;
1009
1010 while (*q && *q != '\n' && isspace(*q))
1011 q++;
1012
1013 if (strncasecmp(q, "stream-switch-entry=", 20) == 0) {
1014 int stream_no;
1015 int rate_no;
1016
1017 q += 20;
1018
1019 memset(rates, 0xff, ratelen);
1020
1021 while (1) {
1022 while (*q && *q != '\n' && *q != ':')
1023 q++;
1024
1025 if (sscanf(q, ":%d:%d", &stream_no, &rate_no) != 2)
1026 break;
1027
1028 stream_no--;
1029 if (stream_no < ratelen && stream_no >= 0)
1030 rates[stream_no] = rate_no;
1031
1032 while (*q && *q != '\n' && !isspace(*q))
1033 q++;
1034 }
1035
1036 return 1;
1037 }
1038 }
1039 p = strchr(p, '\n');
1040 if (!p)
1041 break;
1042
1043 p++;
1044 }
1045
1046 return 0;
1047 }
1048
1049 static int find_stream_in_feed(FFStream *feed, AVCodecContext *codec, int bit_rate)
1050 {
1051 int i;
1052 int best_bitrate = 100000000;
1053 int best = -1;
1054
1055 for (i = 0; i < feed->nb_streams; i++) {
1056 AVCodecContext *feed_codec = feed->streams[i]->codec;
1057
1058 if (feed_codec->codec_id != codec->codec_id ||
1059 feed_codec->sample_rate != codec->sample_rate ||
1060 feed_codec->width != codec->width ||
1061 feed_codec->height != codec->height)
1062 continue;
1063
1064 /* Potential stream */
1065
1066 /* We want the fastest stream less than bit_rate, or the slowest
1067 * faster than bit_rate
1068 */
1069
1070 if (feed_codec->bit_rate <= bit_rate) {
1071 if (best_bitrate > bit_rate || feed_codec->bit_rate > best_bitrate) {
1072 best_bitrate = feed_codec->bit_rate;
1073 best = i;
1074 }
1075 } else {
1076 if (feed_codec->bit_rate < best_bitrate) {
1077 best_bitrate = feed_codec->bit_rate;
1078 best = i;
1079 }
1080 }
1081 }
1082
1083 return best;
1084 }
1085
1086 static int modify_current_stream(HTTPContext *c, char *rates)
1087 {
1088 int i;
1089 FFStream *req = c->stream;
1090 int action_required = 0;
1091
1092 /* Not much we can do for a feed */
1093 if (!req->feed)
1094 return 0;
1095
1096 for (i = 0; i < req->nb_streams; i++) {
1097 AVCodecContext *codec = req->streams[i]->codec;
1098
1099 switch(rates[i]) {
1100 case 0:
1101 c->switch_feed_streams[i] = req->feed_streams[i];
1102 break;
1103 case 1:
1104 c->switch_feed_streams[i] = find_stream_in_feed(req->feed, codec, codec->bit_rate / 2);
1105 break;
1106 case 2:
1107 /* Wants off or slow */
1108 c->switch_feed_streams[i] = find_stream_in_feed(req->feed, codec, codec->bit_rate / 4);
1109 #ifdef WANTS_OFF
1110 /* This doesn't work well when it turns off the only stream! */
1111 c->switch_feed_streams[i] = -2;
1112 c->feed_streams[i] = -2;
1113 #endif
1114 break;
1115 }
1116
1117 if (c->switch_feed_streams[i] >= 0 && c->switch_feed_streams[i] != c->feed_streams[i])
1118 action_required = 1;
1119 }
1120
1121 return action_required;
1122 }
1123
1124
1125 static void do_switch_stream(HTTPContext *c, int i)
1126 {
1127 if (c->switch_feed_streams[i] >= 0) {
1128 #ifdef PHILIP
1129 c->feed_streams[i] = c->switch_feed_streams[i];
1130 #endif
1131
1132 /* Now update the stream */
1133 }
1134 c->switch_feed_streams[i] = -1;
1135 }
1136
1137 /* XXX: factorize in utils.c ? */
1138 /* XXX: take care with different space meaning */
1139 static void skip_spaces(const char **pp)
1140 {
1141 const char *p;
1142 p = *pp;
1143 while (*p == ' ' || *p == '\t')
1144 p++;
1145 *pp = p;
1146 }
1147
1148 static void get_word(char *buf, int buf_size, const char **pp)
1149 {
1150 const char *p;
1151 char *q;
1152
1153 p = *pp;
1154 skip_spaces(&p);
1155 q = buf;
1156 while (!isspace(*p) && *p != '\0') {
1157 if ((q - buf) < buf_size - 1)
1158 *q++ = *p;
1159 p++;
1160 }
1161 if (buf_size > 0)
1162 *q = '\0';
1163 *pp = p;
1164 }
1165
1166 static int validate_acl(FFStream *stream, HTTPContext *c)
1167 {
1168 enum IPAddressAction last_action = IP_DENY;
1169 IPAddressACL *acl;
1170 struct in_addr *src = &c->from_addr.sin_addr;
1171 unsigned long src_addr = src->s_addr;
1172
1173 for (acl = stream->acl; acl; acl = acl->next) {
1174 if (src_addr >= acl->first.s_addr && src_addr <= acl->last.s_addr)
1175 return (acl->action == IP_ALLOW) ? 1 : 0;
1176 last_action = acl->action;
1177 }
1178
1179 /* Nothing matched, so return not the last action */
1180 return (last_action == IP_DENY) ? 1 : 0;
1181 }
1182
1183 /* compute the real filename of a file by matching it without its
1184 extensions to all the stream filenames */
1185 static void compute_real_filename(char *filename, int max_size)
1186 {
1187 char file1[1024];
1188 char file2[1024];
1189 char *p;
1190 FFStream *stream;
1191
1192 /* compute filename by matching without the file extensions */
1193 av_strlcpy(file1, filename, sizeof(file1));
1194 p = strrchr(file1, '.');
1195 if (p)
1196 *p = '\0';
1197 for(stream = first_stream; stream != NULL; stream = stream->next) {
1198 av_strlcpy(file2, stream->filename, sizeof(file2));
1199 p = strrchr(file2, '.');
1200 if (p)
1201 *p = '\0';
1202 if (!strcmp(file1, file2)) {
1203 av_strlcpy(filename, stream->filename, max_size);
1204 break;
1205 }
1206 }
1207 }
1208
1209 enum RedirType {
1210 REDIR_NONE,
1211 REDIR_ASX,
1212 REDIR_RAM,
1213 REDIR_ASF,
1214 REDIR_RTSP,
1215 REDIR_SDP,
1216 };
1217
1218 /* parse http request and prepare header */
1219 static int http_parse_request(HTTPContext *c)
1220 {
1221 char *p;
1222 enum RedirType redir_type;
1223 char cmd[32];
1224 char info[1024], filename[1024];
1225 char url[1024], *q;
1226 char protocol[32];
1227 char msg[1024];
1228 const char *mime_type;
1229 FFStream *stream;
1230 int i;
1231 char ratebuf[32];
1232 char *useragent = 0;
1233
1234 p = c->buffer;
1235 get_word(cmd, sizeof(cmd), (const char **)&p);
1236 av_strlcpy(c->method, cmd, sizeof(c->method));
1237
1238 if (!strcmp(cmd, "GET"))
1239 c->post = 0;
1240 else if (!strcmp(cmd, "POST"))
1241 c->post = 1;
1242 else
1243 return -1;
1244
1245 get_word(url, sizeof(url), (const char **)&p);
1246 av_strlcpy(c->url, url, sizeof(c->url));
1247
1248 get_word(protocol, sizeof(protocol), (const char **)&p);
1249 if (strcmp(protocol, "HTTP/1.0") && strcmp(protocol, "HTTP/1.1"))
1250 return -1;
1251
1252 av_strlcpy(c->protocol, protocol, sizeof(c->protocol));
1253
1254 if (ffserver_debug)
1255 http_log("New connection: %s %s\n", cmd, url);
1256
1257 /* find the filename and the optional info string in the request */
1258 p = strchr(url, '?');
1259 if (p) {
1260 av_strlcpy(info, p, sizeof(info));
1261 *p = '\0';
1262 } else
1263 info[0] = '\0';
1264
1265 av_strlcpy(filename, url + ((*url == '/') ? 1 : 0), sizeof(filename)-1);
1266
1267 for (p = c->buffer; *p && *p != '\r' && *p != '\n'; ) {
1268 if (strncasecmp(p, "User-Agent:", 11) == 0) {
1269 useragent = p + 11;
1270 if (*useragent && *useragent != '\n' && isspace(*useragent))
1271 useragent++;
1272 break;
1273 }
1274 p = strchr(p, '\n');
1275 if (!p)
1276 break;
1277
1278 p++;
1279 }
1280
1281 redir_type = REDIR_NONE;
1282 if (match_ext(filename, "asx")) {
1283 redir_type = REDIR_ASX;
1284 filename[strlen(filename)-1] = 'f';
1285 } else if (match_ext(filename, "asf") &&
1286 (!useragent || strncasecmp(useragent, "NSPlayer", 8) != 0)) {
1287 /* if this isn't WMP or lookalike, return the redirector file */
1288 redir_type = REDIR_ASF;
1289 } else if (match_ext(filename, "rpm,ram")) {
1290 redir_type = REDIR_RAM;
1291 strcpy(filename + strlen(filename)-2, "m");
1292 } else if (match_ext(filename, "rtsp")) {
1293 redir_type = REDIR_RTSP;
1294 compute_real_filename(filename, sizeof(filename) - 1);
1295 } else if (match_ext(filename, "sdp")) {
1296 redir_type = REDIR_SDP;
1297 compute_real_filename(filename, sizeof(filename) - 1);
1298 }
1299
1300 // "redirect" / request to index.html
1301 if (!strlen(filename))
1302 av_strlcpy(filename, "index.html", sizeof(filename) - 1);
1303
1304 stream = first_stream;
1305 while (stream != NULL) {
1306 if (!strcmp(stream->filename, filename) && validate_acl(stream, c))
1307 break;
1308 stream = stream->next;
1309 }
1310 if (stream == NULL) {
1311 snprintf(msg, sizeof(msg), "File '%s' not found", url);
1312 goto send_error;
1313 }
1314
1315 c->stream = stream;
1316 memcpy(c->feed_streams, stream->feed_streams, sizeof(c->feed_streams));
1317 memset(c->switch_feed_streams, -1, sizeof(c->switch_feed_streams));
1318
1319 if (stream->stream_type == STREAM_TYPE_REDIRECT) {
1320 c->http_error = 301;
1321 q = c->buffer;
1322 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "HTTP/1.0 301 Moved\r\n");
1323 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "Location: %s\r\n", stream->feed_filename);
1324 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "Content-type: text/html\r\n");
1325 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "\r\n");
1326 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "<html><head><title>Moved</title></head><body>\r\n");
1327 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "You should be <a href=\"%s\">redirected</a>.\r\n", stream->feed_filename);
1328 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "</body></html>\r\n");
1329
1330 /* prepare output buffer */
1331 c->buffer_ptr = c->buffer;
1332 c->buffer_end = q;
1333 c->state = HTTPSTATE_SEND_HEADER;
1334 return 0;
1335 }
1336
1337 /* If this is WMP, get the rate information */
1338 if (extract_rates(ratebuf, sizeof(ratebuf), c->buffer)) {
1339 if (modify_current_stream(c, ratebuf)) {
1340 for (i = 0; i < sizeof(c->feed_streams) / sizeof(c->feed_streams[0]); i++) {
1341 if (c->switch_feed_streams[i] >= 0)
1342 do_switch_stream(c, i);
1343 }
1344 }
1345 }
1346
1347 /* If already streaming this feed, do not let start another feeder. */
1348 if (stream->feed_opened) {
1349 snprintf(msg, sizeof(msg), "This feed is already being received.");
1350 http_log("feed %s already being received\n", stream->feed_filename);
1351 goto send_error;
1352 }
1353
1354 if (c->post == 0 && stream->stream_type == STREAM_TYPE_LIVE)
1355 current_bandwidth += stream->bandwidth;
1356
1357 if (c->post == 0 && max_bandwidth < current_bandwidth) {
1358 c->http_error = 200;
1359 q = c->buffer;
1360 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "HTTP/1.0 200 Server too busy\r\n");
1361 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "Content-type: text/html\r\n");
1362 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "\r\n");
1363 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "<html><head><title>Too busy</title></head><body>\r\n");
1364 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "<p>The server is too busy to serve your request at this time.</p>\r\n");
1365 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "<p>The bandwidth being served (including your stream) is %lldkbit/sec, and this exceeds the limit of %lldkbit/sec.</p>\r\n",
1366 current_bandwidth, max_bandwidth);
1367 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "</body></html>\r\n");
1368
1369 /* prepare output buffer */
1370 c->buffer_ptr = c->buffer;
1371 c->buffer_end = q;
1372 c->state = HTTPSTATE_SEND_HEADER;
1373 return 0;
1374 }
1375
1376 if (redir_type != REDIR_NONE) {
1377 char *hostinfo = 0;
1378
1379 for (p = c->buffer; *p && *p != '\r' && *p != '\n'; ) {
1380 if (strncasecmp(p, "Host:", 5) == 0) {
1381 hostinfo = p + 5;
1382 break;
1383 }
1384 p = strchr(p, '\n');
1385 if (!p)
1386 break;
1387
1388 p++;
1389 }
1390
1391 if (hostinfo) {
1392 char *eoh;
1393 char hostbuf[260];
1394
1395 while (isspace(*hostinfo))
1396 hostinfo++;
1397
1398 eoh = strchr(hostinfo, '\n');
1399 if (eoh) {
1400 if (eoh[-1] == '\r')
1401 eoh--;
1402
1403 if (eoh - hostinfo < sizeof(hostbuf) - 1) {
1404 memcpy(hostbuf, hostinfo, eoh - hostinfo);
1405 hostbuf[eoh - hostinfo] = 0;
1406
1407 c->http_error = 200;
1408 q = c->buffer;
1409 switch(redir_type) {
1410 case REDIR_ASX:
1411 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "HTTP/1.0 200 ASX Follows\r\n");
1412 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "Content-type: video/x-ms-asf\r\n");
1413 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "\r\n");
1414 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "<ASX Version=\"3\">\r\n");
1415 //q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "<!-- Autogenerated by ffserver -->\r\n");
1416 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "<ENTRY><REF HREF=\"http://%s/%s%s\"/></ENTRY>\r\n",
1417 hostbuf, filename, info);
1418 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "</ASX>\r\n");
1419 break;
1420 case REDIR_RAM:
1421 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "HTTP/1.0 200 RAM Follows\r\n");
1422 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "Content-type: audio/x-pn-realaudio\r\n");
1423 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "\r\n");
1424 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "# Autogenerated by ffserver\r\n");
1425 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "http://%s/%s%s\r\n",
1426 hostbuf, filename, info);
1427 break;
1428 case REDIR_ASF:
1429 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "HTTP/1.0 200 ASF Redirect follows\r\n");
1430 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "Content-type: video/x-ms-asf\r\n");
1431 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "\r\n");
1432 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "[Reference]\r\n");
1433 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "Ref1=http://%s/%s%s\r\n",
1434 hostbuf, filename, info);
1435 break;
1436 case REDIR_RTSP:
1437 {
1438 char hostname[256], *p;
1439 /* extract only hostname */
1440 av_strlcpy(hostname, hostbuf, sizeof(hostname));
1441 p = strrchr(hostname, ':');
1442 if (p)
1443 *p = '\0';
1444 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "HTTP/1.0 200 RTSP Redirect follows\r\n");
1445 /* XXX: incorrect mime type ? */
1446 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "Content-type: application/x-rtsp\r\n");
1447 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "\r\n");
1448 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "rtsp://%s:%d/%s\r\n",
1449 hostname, ntohs(my_rtsp_addr.sin_port),
1450 filename);
1451 }
1452 break;
1453 case REDIR_SDP:
1454 {
1455 uint8_t *sdp_data;
1456 int sdp_data_size, len;
1457 struct sockaddr_in my_addr;
1458
1459 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "HTTP/1.0 200 OK\r\n");
1460 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "Content-type: application/sdp\r\n");
1461 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "\r\n");
1462
1463 len = sizeof(my_addr);
1464 getsockname(c->fd, (struct sockaddr *)&my_addr, &len);
1465
1466 /* XXX: should use a dynamic buffer */
1467 sdp_data_size = prepare_sdp_description(stream,
1468 &sdp_data,
1469 my_addr.sin_addr);
1470 if (sdp_data_size > 0) {
1471 memcpy(q, sdp_data, sdp_data_size);
1472 q += sdp_data_size;
1473 *q = '\0';
1474 av_free(sdp_data);
1475 }
1476 }
1477 break;
1478 default:
1479 abort();
1480 break;
1481 }
1482
1483 /* prepare output buffer */
1484 c->buffer_ptr = c->buffer;
1485 c->buffer_end = q;
1486 c->state = HTTPSTATE_SEND_HEADER;
1487 return 0;
1488 }
1489 }
1490 }
1491
1492 snprintf(msg, sizeof(msg), "ASX/RAM file not handled");
1493 goto send_error;
1494 }
1495
1496 stream->conns_served++;
1497
1498 /* XXX: add there authenticate and IP match */
1499
1500 if (c->post) {
1501 /* if post, it means a feed is being sent */
1502 if (!stream->is_feed) {
1503 /* However it might be a status report from WMP! Let us log the
1504 * data as it might come in handy one day. */
1505 char *logline = 0;
1506 int client_id = 0;
1507
1508 for (p = c->buffer; *p && *p != '\r' && *p != '\n'; ) {
1509 if (strncasecmp(p, "Pragma: log-line=", 17) == 0) {
1510 logline = p;
1511 break;
1512 }
1513 if (strncasecmp(p, "Pragma: client-id=", 18) == 0)
1514 client_id = strtol(p + 18, 0, 10);
1515 p = strchr(p, '\n');
1516 if (!p)
1517 break;
1518
1519 p++;
1520 }
1521
1522 if (logline) {
1523 char *eol = strchr(logline, '\n');
1524
1525 logline += 17;
1526
1527 if (eol) {
1528 if (eol[-1] == '\r')
1529 eol--;
1530 http_log("%.*s\n", (int) (eol - logline), logline);
1531 c->suppress_log = 1;
1532 }
1533 }
1534
1535 #ifdef DEBUG_WMP
1536 http_log("\nGot request:\n%s\n", c->buffer);
1537 #endif
1538
1539 if (client_id && extract_rates(ratebuf, sizeof(ratebuf), c->buffer)) {
1540 HTTPContext *wmpc;
1541
1542 /* Now we have to find the client_id */
1543 for (wmpc = first_http_ctx; wmpc; wmpc = wmpc->next) {
1544 if (wmpc->wmp_client_id == client_id)
1545 break;
1546 }
1547
1548 if (wmpc && modify_current_stream(wmpc, ratebuf))
1549 wmpc->switch_pending = 1;
1550 }
1551
1552 snprintf(msg, sizeof(msg), "POST command not handled");
1553 c->stream = 0;
1554 goto send_error;
1555 }
1556 if (http_start_receive_data(c) < 0) {
1557 snprintf(msg, sizeof(msg), "could not open feed");
1558 goto send_error;
1559 }
1560 c->http_error = 0;
1561 c->state = HTTPSTATE_RECEIVE_DATA;
1562 return 0;
1563 }
1564
1565 #ifdef DEBUG_WMP
1566 if (strcmp(stream->filename + strlen(stream->filename) - 4, ".asf") == 0)
1567 http_log("\nGot request:\n%s\n", c->buffer);
1568 #endif
1569
1570 if (c->stream->stream_type == STREAM_TYPE_STATUS)
1571 goto send_status;
1572
1573 /* open input stream */
1574 if (open_input_stream(c, info) < 0) {
1575 snprintf(msg, sizeof(msg), "Input stream corresponding to '%s' not found", url);
1576 goto send_error;
1577 }
1578
1579 /* prepare http header */
1580 q = c->buffer;
1581 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "HTTP/1.0 200 OK\r\n");
1582 mime_type = c->stream->fmt->mime_type;
1583 if (!mime_type)
1584 mime_type = "application/x-octet-stream";
1585 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "Pragma: no-cache\r\n");
1586
1587 /* for asf, we need extra headers */
1588 if (!strcmp(c->stream->fmt->name,"asf_stream")) {
1589 /* Need to allocate a client id */
1590
1591 c->wmp_client_id = av_random(&random_state) & 0x7fffffff;
1592
1593 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "Server: Cougar 4.1.0.3923\r\nCache-Control: no-cache\r\nPragma: client-id=%d\r\nPragma: features=\"broadcast\"\r\n", c->wmp_client_id);
1594 }
1595 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "Content-Type: %s\r\n", mime_type);
1596 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "\r\n");
1597
1598 /* prepare output buffer */
1599 c->http_error = 0;
1600 c->buffer_ptr = c->buffer;
1601 c->buffer_end = q;
1602 c->state = HTTPSTATE_SEND_HEADER;
1603 return 0;
1604 send_error:
1605 c->http_error = 404;
1606 q = c->buffer;
1607 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "HTTP/1.0 404 Not Found\r\n");
1608 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "Content-type: %s\r\n", "text/html");
1609 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "\r\n");
1610 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "<HTML>\n");
1611 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "<HEAD><TITLE>404 Not Found</TITLE></HEAD>\n");
1612 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "<BODY>%s</BODY>\n", msg);
1613 q += snprintf(q, q - (char *) c->buffer + c->buffer_size, "</HTML>\n");
1614
1615 /* prepare output buffer */
1616 c->buffer_ptr = c->buffer;
1617 c->buffer_end = q;
1618 c->state = HTTPSTATE_SEND_HEADER;
1619 return 0;
1620 send_status:
1621 compute_status(c);
1622 c->http_error = 200; /* horrible : we use this value to avoid
1623 going to the send data state */
1624 c->state = HTTPSTATE_SEND_HEADER;
1625 return 0;
1626 }
1627
1628 static void fmt_bytecount(ByteIOContext *pb, int64_t count)
1629 {
1630 static const char *suffix = " kMGTP";
1631 const char *s;
1632
1633 for (s = suffix; count >= 100000 && s[1]; count /= 1000, s++);
1634
1635 url_fprintf(pb, "%"PRId64"%c", count, *s);
1636 }
1637
1638 static void compute_status(HTTPContext *c)
1639 {
1640 HTTPContext *c1;
1641 FFStream *stream;
1642 char *p;
1643 time_t ti;
1644 int i, len;
1645 ByteIOContext *pb;
1646
1647 if (url_open_dyn_buf(&pb) < 0) {
1648 /* XXX: return an error ? */
1649 c->buffer_ptr = c->buffer;
1650 c->buffer_end = c->buffer;
1651 return;
1652 }
1653
1654 url_fprintf(pb, "HTTP/1.0 200 OK\r\n");
1655 url_fprintf(pb, "Content-type: %s\r\n", "text/html");
1656 url_fprintf(pb, "Pragma: no-cache\r\n");
1657 url_fprintf(pb, "\r\n");
1658
1659 url_fprintf(pb, "<HEAD><TITLE>%s Status</TITLE>\n", program_name);
1660 if (c->stream->feed_filename[0])
1661 url_fprintf(pb, "<link rel=\"shortcut icon\" href=\"%s\">\n", c->stream->feed_filename);
1662 url_fprintf(pb, "</HEAD>\n<BODY>");
1663 url_fprintf(pb, "<H1>%s Status</H1>\n", program_name);
1664 /* format status */
1665 url_fprintf(pb, "<H2>Available Streams</H2>\n");
1666 url_fprintf(pb, "<TABLE cellspacing=0 cellpadding=4>\n");
1667 url_fprintf(pb, "<TR><Th valign=top>Path<th align=left>Served<br>Conns<Th><br>bytes<Th valign=top>Format<Th>Bit rate<br>kbits/s<Th align=left>Video<br>kbits/s<th><br>Codec<Th align=left>Audio<br>kbits/s<th><br>Codec<Th align=left valign=top>Feed\n");
1668 stream = first_stream;
1669 while (stream != NULL) {
1670 char sfilename[1024];
1671 char *eosf;
1672
1673 if (stream->feed != stream) {
1674 av_strlcpy(sfilename, stream->filename, sizeof(sfilename) - 10);
1675 eosf = sfilename + strlen(sfilename);
1676 if (eosf - sfilename >= 4) {
1677 if (strcmp(eosf - 4, ".asf") == 0)
1678 strcpy(eosf - 4, ".asx");
1679 else if (strcmp(eosf - 3, ".rm") == 0)
1680 strcpy(eosf - 3, ".ram");
1681 else if (stream->fmt && !strcmp(stream->fmt->name, "rtp")) {
1682 /* generate a sample RTSP director if
1683 unicast. Generate an SDP redirector if
1684 multicast */
1685 eosf = strrchr(sfilename, '.');
1686 if (!eosf)
1687 eosf = sfilename + strlen(sfilename);
1688 if (stream->is_multicast)
1689 strcpy(eosf, ".sdp");
1690 else
1691 strcpy(eosf, ".rtsp");
1692 }
1693 }
1694
1695 url_fprintf(pb, "<TR><TD><A HREF=\"/%s\">%s</A> ",
1696 sfilename, stream->filename);
1697 url_fprintf(pb, "<td align=right> %d <td align=right> ",
1698 stream->conns_served);
1699 fmt_bytecount(pb, stream->bytes_served);
1700 switch(stream->stream_type) {
1701 case STREAM_TYPE_LIVE: {
1702 int audio_bit_rate = 0;
1703 int video_bit_rate = 0;
1704 const char *audio_codec_name = "";
1705 const char *video_codec_name = "";
1706 const char *audio_codec_name_extra = "";
1707 const char *video_codec_name_extra = "";
1708
1709 for(i=0;i<stream->nb_streams;i++) {
1710 AVStream *st = stream->streams[i];
1711 AVCodec *codec = avcodec_find_encoder(st->codec->codec_id);
1712 switch(st->codec->codec_type) {
1713 case CODEC_TYPE_AUDIO:
1714 audio_bit_rate += st->codec->bit_rate;
1715 if (codec) {
1716 if (*audio_codec_name)
1717 audio_codec_name_extra = "...";
1718 audio_codec_name = codec->name;
1719 }
1720 break;
1721 case CODEC_TYPE_VIDEO:
1722 video_bit_rate += st->codec->bit_rate;
1723 if (codec) {
1724 if (*video_codec_name)
1725 video_codec_name_extra = "...";
1726 video_codec_name = codec->name;
1727 }
1728 break;
1729 case CODEC_TYPE_DATA:
1730 video_bit_rate += st->codec->bit_rate;
1731 break;
1732 default:
1733 abort();
1734 }
1735 }
1736 url_fprintf(pb, "<TD align=center> %s <TD align=right> %d <TD align=right> %d <TD> %s %s <TD align=right> %d <TD> %s %s",
1737 stream->fmt->name,
1738 stream->bandwidth,
1739 video_bit_rate / 1000, video_codec_name, video_codec_name_extra,
1740 audio_bit_rate / 1000, audio_codec_name, audio_codec_name_extra);
1741 if (stream->feed)
1742 url_fprintf(pb, "<TD>%s", stream->feed->filename);
1743 else
1744 url_fprintf(pb, "<TD>%s", stream->feed_filename);
1745 url_fprintf(pb, "\n");
1746 }
1747 break;
1748 default:
1749 url_fprintf(pb, "<TD align=center> - <TD align=right> - <TD align=right> - <td><td align=right> - <TD>\n");
1750 break;
1751 }
1752 }
1753 stream = stream->next;
1754 }
1755 url_fprintf(pb, "</TABLE>\n");
1756
1757 stream = first_stream;
1758 while (stream != NULL) {
1759 if (stream->feed == stream) {
1760 url_fprintf(pb, "<h2>Feed %s</h2>", stream->filename);
1761 if (stream->pid) {
1762 url_fprintf(pb, "Running as pid %d.\n", stream->pid);
1763
1764 #if defined(linux) && !defined(CONFIG_NOCUTILS)
1765 {
1766 FILE *pid_stat;
1767 char ps_cmd[64];
1768
1769 /* This is somewhat linux specific I guess */
1770 snprintf(ps_cmd, sizeof(ps_cmd),
1771 "ps -o \"%%cpu,cputime\" --no-headers %d",
1772 stream->pid);
1773
1774 pid_stat = popen(ps_cmd, "r");
1775 if (pid_stat) {
1776 char cpuperc[10];
1777 char cpuused[64];
1778
1779 if (fscanf(pid_stat, "%10s %64s", cpuperc,
1780 cpuused) == 2) {
1781 url_fprintf(pb, "Currently using %s%% of the cpu. Total time used %s.\n",
1782 cpuperc, cpuused);
1783 }
1784 fclose(pid_stat);
1785 }
1786 }
1787 #endif
1788
1789 url_fprintf(pb, "<p>");
1790 }
1791 url_fprintf(pb, "<table cellspacing=0 cellpadding=4><tr><th>Stream<th>type<th>kbits/s<th align=left>codec<th align=left>Parameters\n");
1792
1793 for (i = 0; i < stream->nb_streams; i++) {
1794 AVStream *st = stream->streams[i];
1795 AVCodec *codec = avcodec_find_encoder(st->codec->codec_id);
1796 const char *type = "unknown";
1797 char parameters[64];
1798
1799 parameters[0] = 0;
1800
1801 switch(st->codec->codec_type) {
1802 case CODEC_TYPE_AUDIO:
1803 type = "audio";
1804 snprintf(parameters, sizeof(parameters), "%d channel(s), %d Hz", st->codec->channels, st->codec->sample_rate);
1805 break;
1806 case CODEC_TYPE_VIDEO:
1807 type = "video";
1808 snprintf(parameters, sizeof(parameters), "%dx%d, q=%d-%d, fps=%d", st->codec->width, st->codec->height,
1809 st->codec->qmin, st->codec->qmax, st->codec->time_base.den / st->codec->time_base.num);
1810 break;
1811 default:
1812 abort();
1813 }
1814 url_fprintf(pb, "<tr><td align=right>%d<td>%s<td align=right>%d<td>%s<td>%s\n",
1815 i, type, st->codec->bit_rate/1000, codec ? codec->name : "", parameters);
1816 }
1817 url_fprintf(pb, "</table>\n");
1818
1819 }
1820 stream = stream->next;
1821 }
1822
1823 #if 0
1824 {
1825 float avg;
1826 AVCodecContext *enc;
1827 char buf[1024];
1828
1829 /* feed status */
1830 stream = first_feed;
1831 while (stream != NULL) {
1832 url_fprintf(pb, "<H1>Feed '%s'</H1>\n", stream->filename);
1833 url_fprintf(pb, "<TABLE>\n");
1834 url_fprintf(pb, "<TR><TD>Parameters<TD>Frame count<TD>Size<TD>Avg bitrate (kbits/s)\n");
1835 for(i=0;i<stream->nb_streams;i++) {
1836 AVStream *st = stream->streams[i];
1837 FeedData *fdata = st->priv_data;
1838 enc = st->codec;
1839
1840 avcodec_string(buf, sizeof(buf), enc);
1841 avg = fdata->avg_frame_size * (float)enc->rate * 8.0;
1842 if (enc->codec->type == CODEC_TYPE_AUDIO && enc->frame_size > 0)
1843 avg /= enc->frame_size;
1844 url_fprintf(pb, "<TR><TD>%s <TD> %d <TD> %"PRId64" <TD> %0.1f\n",
1845 buf, enc->frame_number, fdata->data_count, avg / 1000.0);
1846 }
1847 url_fprintf(pb, "</TABLE>\n");
1848 stream = stream->next_feed;
1849 }
1850 }
1851 #endif
1852
1853 /* connection status */
1854 url_fprintf(pb, "<H2>Connection Status</H2>\n");
1855
1856 url_fprintf(pb, "Number of connections: %d / %d<BR>\n",
1857 nb_connections, nb_max_connections);
1858
1859 url_fprintf(pb, "Bandwidth in use: %lldk / %lldk<BR>\n",
1860 current_bandwidth, max_bandwidth);
1861
1862 url_fprintf(pb, "<TABLE>\n");
1863 url_fprintf(pb, "<TR><th>#<th>File<th>IP<th>Proto<th>State<th>Target bits/sec<th>Actual bits/sec<th>Bytes transferred\n");
1864 c1 = first_http_ctx;
1865 i = 0;
1866 while (c1 != NULL) {
1867 int bitrate;
1868 int j;
1869
1870 bitrate = 0;
1871 if (c1->stream) {
1872 for (j = 0; j < c1->stream->nb_streams; j++) {
1873 if (!c1->stream->feed)
1874 bitrate += c1->stream->streams[j]->codec->bit_rate;
1875 else if (c1->feed_streams[j] >= 0)
1876 bitrate += c1->stream->feed->streams[c1->feed_streams[j]]->codec->bit_rate;
1877 }
1878 }
1879
1880 i++;
1881 p = inet_ntoa(c1->from_addr.sin_addr);
1882 url_fprintf(pb, "<TR><TD><B>%d</B><TD>%s%s<TD>%s<TD>%s<TD>%s<td align=right>",
1883 i,
1884 c1->stream ? c1->stream->filename : "",
1885 c1->state == HTTPSTATE_RECEIVE_DATA ? "(input)" : "",
1886 p,
1887 c1->protocol,
1888 http_state[c1->state]);
1889 fmt_bytecount(pb, bitrate);
1890 url_fprintf(pb, "<td align=right>");
1891 fmt_bytecount(pb, compute_datarate(&c1->datarate, c1->data_count) * 8);
1892 url_fprintf(pb, "<td align=right>");
1893 fmt_bytecount(pb, c1->data_count);
1894 url_fprintf(pb, "\n");
1895 c1 = c1->next;
1896 }
1897 url_fprintf(pb, "</TABLE>\n");
1898
1899 /* date */
1900 ti = time(NULL);
1901 p = ctime(&ti);
1902 url_fprintf(pb, "<HR size=1 noshade>Generated at %s", p);
1903 url_fprintf(pb, "</BODY>\n</HTML>\n");
1904
1905 len = url_close_dyn_buf(pb, &c->pb_buffer);
1906 c->buffer_ptr = c->pb_buffer;
1907 c->buffer_end = c->pb_buffer + len;
1908 }
1909
1910 /* check if the parser needs to be opened for stream i */
1911 static void open_parser(AVFormatContext *s, int i)
1912 {
1913 AVStream *st = s->streams[i];
1914 AVCodec *codec;
1915
1916 if (!st->codec->codec) {
1917 codec = avcodec_find_decoder(st->codec->codec_id);
1918 if (codec && (codec->capabilities & CODEC_CAP_PARSE_ONLY)) {
1919 st->codec->parse_only = 1;
1920 if (avcodec_open(st->codec, codec) < 0)
1921 st->codec->parse_only = 0;
1922 }
1923 }
1924 }
1925
1926 static int open_input_stream(HTTPContext *c, const char *info)
1927 {
1928 char buf[128];
1929 char input_filename[1024];
1930 AVFormatContext *s;
1931 int buf_size, i, ret;
1932 int64_t stream_pos;
1933
1934 /* find file name */
1935 if (c->stream->feed) {
1936 strcpy(input_filename, c->stream->feed->feed_filename);
1937 buf_size = FFM_PACKET_SIZE;
1938 /* compute position (absolute time) */
1939 if (find_info_tag(buf, sizeof(buf), "date", info)) {
1940 stream_pos = parse_date(buf, 0);
1941 if (stream_pos == INT64_MIN)
1942 return -1;
1943 } else if (find_info_tag(buf, sizeof(buf), "buffer", info)) {
1944 int prebuffer = strtol(buf, 0, 10);
1945 stream_pos = av_gettime() - prebuffer * (int64_t)1000000;
1946 } else
1947 stream_pos = av_gettime() - c->stream->prebuffer * (int64_t)1000;
1948 } else {
1949 strcpy(input_filename, c->stream->feed_filename);
1950 buf_size = 0;
1951 /* compute position (relative time) */
1952 if (find_info_tag(buf, sizeof(buf), "date", info)) {
1953 stream_pos = parse_date(buf, 1);
1954 if (stream_pos == INT64_MIN)
1955 return -1;
1956 } else
1957 stream_pos = 0;
1958 }
1959 if (input_filename[0] == '\0')
1960 return -1;
1961
1962 #if 0
1963 { time_t when = stream_pos / 1000000;
1964 http_log("Stream pos = %"PRId64", time=%s", stream_pos, ctime(&when));
1965 }
1966 #endif
1967
1968 /* open stream */
1969 if ((ret = av_open_input_file(&s, input_filename, c->stream->ifmt,
1970 buf_size, c->stream->ap_in)) < 0) {
1971 http_log("could not open %s: %d\n", input_filename, ret);
1972 return -1;
1973 }
1974 s->flags |= AVFMT_FLAG_GENPTS;
1975 c->fmt_in = s;
1976 av_find_stream_info(c->fmt_in);
1977
1978 /* open each parser */
1979 for(i=0;i<s->nb_streams;i++)
1980 open_parser(s, i);
1981
1982 /* choose stream as clock source (we favorize video stream if
1983 present) for packet sending */
1984 c->pts_stream_index = 0;
1985 for(i=0;i<c->stream->nb_streams;i++) {
1986 if (c->pts_stream_index == 0 &&
1987 c->stream->streams[i]->codec->codec_type == CODEC_TYPE_VIDEO) {
1988 c->pts_stream_index = i;
1989 }
1990 }
1991
1992 #if 1
1993 if (c->fmt_in->iformat->read_seek)
1994 av_seek_frame(c->fmt_in, -1, stream_pos, 0);
1995 #endif
1996 /* set the start time (needed for maxtime and RTP packet timing) */
1997 c->start_time = cur_time;
1998 c->first_pts = AV_NOPTS_VALUE;
1999 return 0;
2000 }
2001
2002 /* return the server clock (in us) */
2003 static int64_t get_server_clock(HTTPContext *c)
2004 {
2005 /* compute current pts value from system time */
2006 return (cur_time - c->start_time) * 1000;
2007 }
2008
2009 /* return the estimated time at which the current packet must be sent
2010 (in us) */
2011 static int64_t get_packet_send_clock(HTTPContext *c)
2012 {
2013 int bytes_left, bytes_sent, frame_bytes;
2014
2015 frame_bytes = c->cur_frame_bytes;
2016 if (frame_bytes <= 0)
2017 return c->cur_pts;
2018 else {
2019 bytes_left = c->buffer_end - c->buffer_ptr;
2020 bytes_sent = frame_bytes - bytes_left;
2021 return c->cur_pts + (c->cur_frame_duration * bytes_sent) / frame_bytes;
2022 }
2023 }
2024
2025
2026 static int http_prepare_data(HTTPContext *c)
2027 {
2028 int i, len, ret;
2029 AVFormatContext *ctx;
2030
2031 av_freep(&c->pb_buffer);
2032 switch(c->state) {
2033 case HTTPSTATE_SEND_DATA_HEADER:
2034 memset(&c->fmt_ctx, 0, sizeof(c->fmt_ctx));
2035 av_strlcpy(c->fmt_ctx.author, c->stream->author,
2036 sizeof(c->fmt_ctx.author));
2037 av_strlcpy(c->fmt_ctx.comment, c->stream->comment,
2038 sizeof(c->fmt_ctx.comment));
2039 av_strlcpy(c->fmt_ctx.copyright, c->stream->copyright,
2040 sizeof(c->fmt_ctx.copyright));
2041 av_strlcpy(c->fmt_ctx.title, c->stream->title,
2042 sizeof(c->fmt_ctx.title));
2043
2044 for(i=0;i<c->stream->nb_streams;i++) {
2045 AVStream *st;
2046 AVStream *src;
2047 st = av_mallocz(sizeof(AVStream));
2048 c->fmt_ctx.streams[i] = st;
2049 /* if file or feed, then just take streams from FFStream struct */
2050 if (!c->stream->feed ||
2051 c->stream->feed == c->stream)
2052 src = c->stream->streams[i];
2053 else
2054 src = c->stream->feed->streams[c->stream->feed_streams[i]];
2055
2056 *st = *src;
2057 st->priv_data = 0;
2058 st->codec->frame_number = 0; /* XXX: should be done in
2059 AVStream, not in codec */
2060 }
2061 /* set output format parameters */
2062 c->fmt_ctx.oformat = c->stream->fmt;
2063 c->fmt_ctx.nb_streams = c->stream->nb_streams;
2064
2065 c->got_key_frame = 0;
2066
2067 /* prepare header and save header data in a stream */
2068 if (url_open_dyn_buf(&c->fmt_ctx.pb) < 0) {
2069 /* XXX: potential leak */
2070 return -1;
2071 }
2072 c->fmt_ctx.pb->is_streamed = 1;
2073
2074 /*
2075 * HACK to avoid mpeg ps muxer to spit many underflow errors
2076 * Default value from FFmpeg
2077 * Try to set it use configuration option
2078 */
2079 c->fmt_ctx.preload = (int)(0.5*AV_TIME_BASE);
2080 c->fmt_ctx.max_delay = (int)(0.7*AV_TIME_BASE);
2081
2082 av_set_parameters(&c->fmt_ctx, NULL);
2083 if (av_write_header(&c->fmt_ctx) < 0) {
2084 http_log("Error writing output header\n");
2085 return -1;
2086 }
2087
2088 len = url_close_dyn_buf(c->fmt_ctx.pb, &c->pb_buffer);
2089 c->buffer_ptr = c->pb_buffer;
2090 c->buffer_end = c->pb_buffer + len;
2091
2092 c->state = HTTPSTATE_SEND_DATA;
2093 c->last_packet_sent = 0;
2094 break;
2095 case HTTPSTATE_SEND_DATA:
2096 /* find a new packet */
2097 /* read a packet from the input stream */
2098 if (c->stream->feed)
2099 ffm_set_write_index(c->fmt_in,
2100 c->stream->feed->feed_write_index,
2101 c->stream->feed->feed_size);
2102
2103 if (c->stream->max_time &&
2104 c->stream->max_time + c->start_time - cur_time < 0)
2105 /* We have timed out */
2106 c->state = HTTPSTATE_SEND_DATA_TRAILER;
2107 else {
2108 AVPacket pkt;
2109 redo:
2110 if (av_read_frame(c->fmt_in, &pkt) < 0) {
2111 if (c->stream->feed && c->stream->feed->feed_opened) {
2112 /* if coming from feed, it means we reached the end of the
2113 ffm file, so must wait for more data */
2114 c->state = HTTPSTATE_WAIT_FEED;
2115 return 1; /* state changed */
2116 } else {
2117 if (c->stream->loop) {
2118 av_close_input_file(c->fmt_in);
2119 c->fmt_in = NULL;
2120 if (open_input_stream(c, "") < 0)
2121 goto no_loop;
2122 goto redo;
2123 } else {
2124 no_loop:
2125 /* must send trailer now because eof or error */
2126 c->state = HTTPSTATE_SEND_DATA_TRAILER;
2127 }
2128 }
2129 } else {
2130 int source_index = pkt.stream_index;
2131 /* update first pts if needed */
2132 if (c->first_pts == AV_NOPTS_VALUE) {
2133 c->first_pts = av_rescale_q(pkt.dts, c->fmt_in->streams[pkt.stream_index]->time_base, AV_TIME_BASE_Q);
2134 c->start_time = cur_time;
2135 }
2136 /* send it to the appropriate stream */
2137 if (c->stream->feed) {
2138 /* if coming from a feed, select the right stream */
2139 if (c->switch_pending) {
2140 c->switch_pending = 0;
2141 for(i=0;i<c->stream->nb_streams;i++) {
2142 if (c->switch_feed_streams[i] == pkt.stream_index)
2143 if (pkt.flags & PKT_FLAG_KEY)
2144 do_switch_stream(c, i);
2145 if (c->switch_feed_streams[i] >= 0)
2146 c->switch_pending = 1;
2147 }
2148 }
2149 for(i=0;i<c->stream->nb_streams;i++) {
2150 if (c->feed_streams[i] == pkt.stream_index) {
2151 AVStream *st = c->fmt_in->streams[source_index];
2152 pkt.stream_index = i;
2153 if (pkt.flags & PKT_FLAG_KEY &&
2154 (st->codec->codec_type == CODEC_TYPE_VIDEO ||
2155 c->stream->nb_streams == 1))
2156 c->got_key_frame = 1;
2157 if (!c->stream->send_on_key || c->got_key_frame)
2158 goto send_it;
2159 }
2160 }
2161 } else {
2162 AVCodecContext *codec;
2163 AVStream *ist, *ost;
2164 send_it:
2165 ist = c->fmt_in->streams[source_index];
2166 /* specific handling for RTP: we use several
2167 output stream (one for each RTP
2168 connection). XXX: need more abstract handling */
2169 if (c->is_packetized) {
2170 /* compute send time and duration */
2171 c->cur_pts = av_rescale_q(pkt.dts, ist->time_base, AV_TIME_BASE_Q);
2172 if (ist->start_time != AV_NOPTS_VALUE)
2173 c->cur_pts -= av_rescale_q(ist->start_time, ist->time_base, AV_TIME_BASE_Q);
2174 c->cur_frame_duration = av_rescale_q(pkt.duration, ist->time_base, AV_TIME_BASE_Q);
2175 #if 0
2176 printf("index=%d pts=%0.3f duration=%0.6f\n",
2177 pkt.stream_index,
2178 (double)c->cur_pts /
2179 AV_TIME_BASE,
2180 (double)c->cur_frame_duration /
2181 AV_TIME_BASE);
2182 #endif
2183 /* find RTP context */
2184 c->packet_stream_index = pkt.stream_index;
2185 ctx = c->rtp_ctx[c->packet_stream_index];
2186 if(!ctx) {
2187 av_free_packet(&pkt);
2188 break;
2189 }
2190 codec = ctx->streams[0]->codec;
2191 /* only one stream per RTP connection */
2192 pkt.stream_index = 0;
2193 } else {
2194 ctx = &c->fmt_ctx;
2195 /* Fudge here */
2196 codec = ctx->streams[pkt.stream_index]->codec;
2197 }
2198
2199 if (c->is_packetized) {
2200 int max_packet_size;
2201 if (c->rtp_protocol == RTSP_PROTOCOL_RTP_TCP)
2202 max_packet_size = RTSP_TCP_MAX_PACKET_SIZE;
2203 else
2204 max_packet_size = url_get_max_packet_size(c->rtp_handles[c->packet_stream_index]);
2205 ret = url_open_dyn_packet_buf(&ctx->pb, max_packet_size);
2206 } else {
2207 ret = url_open_dyn_buf(&ctx->pb);
2208 }
2209 if (ret < 0) {
2210 /* XXX: potential leak */
2211 return -1;
2212 }
2213 ost = ctx->streams[pkt.stream_index];
2214
2215 ctx->pb->is_streamed = 1;
2216 if (pkt.dts != AV_NOPTS_VALUE)
2217 pkt.dts = av_rescale_q(pkt.dts, ist->time_base, ost->time_base);
2218 if (pkt.pts != AV_NOPTS_VALUE)
2219 pkt.pts = av_rescale_q(pkt.pts, ist->time_base, ost->time_base);
2220 pkt.duration = av_rescale_q(pkt.duration, ist->time_base, ost->time_base);
2221 if (av_write_frame(ctx, &pkt) < 0) {
2222 http_log("Error writing frame to output\n");
2223 c->state = HTTPSTATE_SEND_DATA_TRAILER;
2224 }
2225
2226 len = url_close_dyn_buf(ctx->pb, &c->pb_buffer);
2227 c->cur_frame_bytes = len;
2228 c->buffer_ptr = c->pb_buffer;
2229 c->buffer_end = c->pb_buffer + len;
2230
2231 codec->frame_number++;
2232 if (len == 0) {
2233 av_free_packet(&pkt);
2234 goto redo;
2235 }
2236 }
2237 av_free_packet(&pkt);
2238 }
2239 }
2240 break;
2241 default:
2242 case HTTPSTATE_SEND_DATA_TRAILER:
2243 /* last packet test ? */
2244 if (c->last_packet_sent || c->is_packetized)
2245 return -1;
2246 ctx = &c->fmt_ctx;
2247 /* prepare header */
2248 if (url_open_dyn_buf(&ctx->pb) < 0) {
2249 /* XXX: potential leak */
2250 return -1;
2251 }
2252 c->fmt_ctx.pb->is_streamed = 1;
2253 av_write_trailer(ctx);
2254 len = url_close_dyn_buf(ctx->pb, &c->pb_buffer);
2255 c->buffer_ptr = c->pb_buffer;
2256 c->buffer_end = c->pb_buffer + len;
2257
2258 c->last_packet_sent = 1;
2259 break;
2260 }
2261 return 0;
2262 }
2263
2264 /* should convert the format at the same time */
2265 /* send data starting at c->buffer_ptr to the output connection
2266 (either UDP or TCP connection) */
2267 static int http_send_data(HTTPContext *c)
2268 {
2269 int len, ret;
2270
2271 for(;;) {
2272 if (c->buffer_ptr >= c->buffer_end) {
2273 ret = http_prepare_data(c);
2274 if (ret < 0)
2275 return -1;
2276 else if (ret != 0)
2277 /* state change requested */
2278 break;
2279 } else {
2280 if (c->is_packetized) {
2281 /* RTP data output */
2282 len = c->buffer_end - c->buffer_ptr;
2283 if (len < 4) {
2284 /* fail safe - should never happen */
2285 fail1:
2286 c->buffer_ptr = c->buffer_end;
2287 return 0;
2288 }
2289 len = (c->buffer_ptr[0] << 24) |
2290 (c->buffer_ptr[1] << 16) |
2291 (c->buffer_ptr[2] << 8) |
2292 (c->buffer_ptr[3]);
2293 if (len > (c->buffer_end - c->buffer_ptr))
2294 goto fail1;
2295 if ((get_packet_send_clock(c) - get_server_clock(c)) > 0) {
2296 /* nothing to send yet: we can wait */
2297 return 0;
2298 }
2299
2300 c->data_count += len;
2301 update_datarate(&c->datarate, c->data_count);
2302 if (c->stream)
2303 c->stream->bytes_served += len;
2304
2305 if (c->rtp_protocol == RTSP_PROTOCOL_RTP_TCP) {
2306 /* RTP packets are sent inside the RTSP TCP connection */
2307 ByteIOContext *pb;
2308 int interleaved_index, size;
2309 uint8_t header[4];
2310 HTTPContext *rtsp_c;
2311
2312 rtsp_c = c->rtsp_c;
2313 /* if no RTSP connection left, error */
2314 if (!rtsp_c)
2315 return -1;
2316 /* if already sending something, then wait. */
2317 if (rtsp_c->state != RTSPSTATE_WAIT_REQUEST)
2318 break;
2319 if (url_open_dyn_buf(&pb) < 0)
2320 goto fail1;
2321 interleaved_index = c->packet_stream_index * 2;
2322 /* RTCP packets are sent at odd indexes */
2323 if (c->buffer_ptr[1] == 200)
2324 interleaved_index++;
2325 /* write RTSP TCP header */
2326 header[0] = '$';
2327 header[1] = interleaved_index;
2328 header[2] = len >> 8;
2329 header[3] = len;
2330 put_buffer(pb, header, 4);
2331 /* write RTP packet data */
2332 c->buffer_ptr += 4;
2333 put_buffer(pb, c->buffer_ptr, len);
2334 size = url_close_dyn_buf(pb, &c->packet_buffer);
2335 /* prepare asynchronous TCP sending */
2336 rtsp_c->packet_buffer_ptr = c->packet_buffer;
2337 rtsp_c->packet_buffer_end = c->packet_buffer + size;
2338 c->buffer_ptr += len;
2339
2340 /* send everything we can NOW */
2341 len = send(rtsp_c->fd, rtsp_c->packet_buffer_ptr,
2342 rtsp_c->packet_buffer_end - rtsp_c->packet_buffer_ptr, 0);
2343 if (len > 0)
2344 rtsp_c->packet_buffer_ptr += len;
2345 if (rtsp_c->packet_buffer_ptr < rtsp_c->packet_buffer_end) {
2346 /* if we could not send all the data, we will
2347 send it later, so a new state is needed to
2348 "lock" the RTSP TCP connection */
2349 rtsp_c->state = RTSPSTATE_SEND_PACKET;
2350 break;
2351 } else
2352 /* all data has been sent */
2353 av_freep(&c->packet_buffer);
2354 } else {
2355 /* send RTP packet directly in UDP */
2356 c->buffer_ptr += 4;
2357 url_write(c->rtp_handles[c->packet_stream_index],
2358 c->buffer_ptr, len);
2359 c->buffer_ptr += len;
2360 /* here we continue as we can send several packets per 10 ms slot */
2361 }
2362 } else {
2363 /* TCP data output */
2364 len = send(c->fd, c->buffer_ptr, c->buffer_end - c->buffer_ptr, 0);
2365 if (len < 0) {
2366 if (ff_neterrno() != FF_NETERROR(EAGAIN) &&
2367 ff_neterrno() != FF_NETERROR(EINTR))
2368 /* error : close connection */
2369 return -1;
2370 else
2371 return 0;
2372 } else
2373 c->buffer_ptr += len;
2374
2375 c->data_count += len;
2376 update_datarate(&c->datarate, c->data_count);
2377 if (c->stream)
2378 c->stream->bytes_served += len;
2379 break;
2380 }
2381 }
2382 } /* for(;;) */
2383 return 0;
2384 }
2385
2386 static int http_start_receive_data(HTTPContext *c)
2387 {
2388 int fd;
2389
2390 if (c->stream->feed_opened)
2391 return -1;
2392
2393 /* Don't permit writing to this one */
2394 if (c->stream->readonly)
2395 return -1;
2396
2397 /* open feed */
2398 fd = open(c->stream->feed_filename, O_RDWR);
2399 if (fd < 0) {
2400 http_log("Error opening feeder file: %s\n", strerror(errno));
2401 return -1;
2402 }
2403 c->feed_fd = fd;
2404
2405 c->stream->feed_write_index = ffm_read_write_index(fd);
2406 c->stream->feed_size = lseek(fd, 0, SEEK_END);
2407 lseek(fd, 0, SEEK_SET);
2408
2409 /* init buffer input */
2410 c->buffer_ptr = c->buffer;
2411 c->buffer_end = c->buffer + FFM_PACKET_SIZE;
2412 c->stream->feed_opened = 1;
2413 return 0;
2414 }
2415
2416 static int http_receive_data(HTTPContext *c)
2417 {
2418 HTTPContext *c1;
2419
2420 if (c->buffer_end > c->buffer_ptr) {
2421 int len;
2422
2423 len = recv(c->fd, c->buffer_ptr, c->buffer_end - c->buffer_ptr, 0);
2424 if (len < 0) {
2425 if (ff_neterrno() != FF_NETERROR(EAGAIN) &&
2426 ff_neterrno() != FF_NETERROR(EINTR))
2427 /* error : close connection */
2428 goto fail;
2429 } else if (len == 0)
2430 /* end of connection : close it */
2431 goto fail;
2432 else {
2433 c->buffer_ptr += len;
2434 c->data_count += len;
2435 update_datarate(&c->datarate, c->data_count);
2436 }
2437 }
2438
2439 if (c->buffer_ptr - c->buffer >= 2 && c->data_count > FFM_PACKET_SIZE) {
2440 if (c->buffer[0] != 'f' ||
2441 c->buffer[1] != 'm') {
2442 http_log("Feed stream has become desynchronized -- disconnecting\n");
2443 goto fail;
2444 }
2445 }
2446
2447 if (c->buffer_ptr >= c->buffer_end) {
2448 FFStream *feed = c->stream;
2449 /* a packet has been received : write it in the store, except
2450 if header */
2451 if (c->data_count > FFM_PACKET_SIZE) {
2452
2453 // printf("writing pos=0x%"PRIx64" size=0x%"PRIx64"\n", feed->feed_write_index, feed->feed_size);
2454 /* XXX: use llseek or url_seek */
2455 lseek(c->feed_fd, feed->feed_write_index, SEEK_SET);
2456 if (write(c->feed_fd, c->buffer, FFM_PACKET_SIZE) < 0) {
2457 http_log("Error writing to feed file: %s\n", strerror(errno));
2458 goto fail;
2459 }
2460
2461 feed->feed_write_index += FFM_PACKET_SIZE;
2462 /* update file size */
2463 if (feed->feed_write_index > c->stream->feed_size)
2464 feed->feed_size = feed->feed_write_index;
2465
2466 /* handle wrap around if max file size reached */
2467 if (c->stream->feed_max_size && feed->feed_write_index >= c->stream->feed_max_size)
2468 feed->feed_write_index = FFM_PACKET_SIZE;
2469
2470 /* write index */
2471 ffm_write_write_index(c->feed_fd, feed->feed_write_index);
2472
2473 /* wake up any waiting connections */
2474 for(c1 = first_http_ctx; c1 != NULL; c1 = c1->next) {
2475 if (c1->state == HTTPSTATE_WAIT_FEED &&
2476 c1->stream->feed == c->stream->feed)
2477 c1->state = HTTPSTATE_SEND_DATA;
2478 }
2479 } else {
2480 /* We have a header in our hands that contains useful data */
2481 AVFormatContext *s = NULL;
2482 ByteIOContext *pb;
2483 AVInputFormat *fmt_in;
2484 int i;
2485
2486 /* use feed output format name to find corresponding input format */
2487 fmt_in = av_find_input_format(feed->fmt->name);
2488 if (!fmt_in)
2489 goto fail;
2490
2491 url_open_buf(&pb, c->buffer, c->buffer_end - c->buffer, URL_RDONLY);
2492 pb->is_streamed = 1;
2493
2494 if (av_open_input_stream(&s, pb, c->stream->feed_filename, fmt_in, NULL) < 0) {
2495 av_free(pb);
2496 goto fail;
2497 }
2498
2499 /* Now we have the actual streams */
2500 if (s->nb_streams != feed->nb_streams) {
2501 av_close_input_stream(s);
2502 av_free(pb);
2503 goto fail;
2504 }
2505
2506 for (i = 0; i < s->nb_streams; i++) {
2507 AVStream *fst = feed->streams[i];
2508 AVStream *st = s->streams[i];
2509 memcpy(fst->codec, st->codec, sizeof(AVCodecContext));
2510 if (fst->codec->extradata_size) {
2511 fst->codec->extradata = av_malloc(fst->codec->extradata_size);
2512 if (!fst->codec->extradata)
2513 goto fail;
2514 memcpy(fst->codec->extradata, st->codec->extradata,
2515 fst->codec->extradata_size);
2516 }
2517 }
2518
2519 av_close_input_stream(s);
2520 av_free(pb);
2521 }
2522 c->buffer_ptr = c->buffer;
2523 }
2524
2525 return 0;
2526 fail:
2527 c->stream->feed_opened = 0;
2528 close(c->feed_fd);
2529 /* wake up any waiting connections to stop waiting for feed */
2530 for(c1 = first_http_ctx; c1 != NULL; c1 = c1->next) {
2531 if (c1->state == HTTPSTATE_WAIT_FEED &&
2532 c1->stream->feed == c->stream->feed)
2533 c1->state = HTTPSTATE_SEND_DATA_TRAILER;
2534 }
2535 return -1;
2536 }
2537
2538 /********************************************************************/
2539 /* RTSP handling */
2540
2541 static void rtsp_reply_header(HTTPContext *c, enum RTSPStatusCode error_number)
2542 {
2543 const char *str;
2544 time_t ti;
2545 char *p;
2546 char buf2[32];
2547
2548 switch(error_number) {
2549 case RTSP_STATUS_OK:
2550 str = "OK";
2551 break;
2552 case RTSP_STATUS_METHOD:
2553 str = "Method Not Allowed";
2554 break;
2555 case RTSP_STATUS_BANDWIDTH:
2556 str = "Not Enough Bandwidth";
2557 break;
2558 case RTSP_STATUS_SESSION:
2559 str = "Session Not Found";
2560 break;
2561 case RTSP_STATUS_STATE:
2562 str = "Method Not Valid in This State";
2563 break;
2564 case RTSP_STATUS_AGGREGATE:
2565 str = "Aggregate operation not allowed";
2566 break;
2567 case RTSP_STATUS_ONLY_AGGREGATE:
2568 str = "Only aggregate operation allowed";
2569 break;
2570 case RTSP_STATUS_TRANSPORT:
2571 str = "Unsupported transport";
2572 break;
2573 case RTSP_STATUS_INTERNAL:
2574 str = "Internal Server Error";
2575 break;
2576 case RTSP_STATUS_SERVICE:
2577 str = "Service Unavailable";
2578 break;
2579 case RTSP_STATUS_VERSION:
2580 str = "RTSP Version not supported";
2581 break;
2582 default:
2583 str = "Unknown Error";
2584 break;
2585 }
2586
2587 url_fprintf(c->pb, "RTSP/1.0 %d %s\r\n", error_number, str);
2588 url_fprintf(c->pb, "CSeq: %d\r\n", c->seq);
2589
2590 /* output GMT time */
2591 ti = time(NULL);
2592 p = ctime(&ti);
2593 strcpy(buf2, p);
2594 p = buf2 + strlen(p) - 1;
2595 if (*p == '\n')
2596 *p = '\0';
2597 url_fprintf(c->pb, "Date: %s GMT\r\n", buf2);
2598 }
2599
2600 static void rtsp_reply_error(HTTPContext *c, enum RTSPStatusCode error_number)
2601 {
2602 rtsp_reply_header(c, error_number);
2603 url_fprintf(c->pb, "\r\n");
2604 }
2605
2606 static int rtsp_parse_request(HTTPContext *c)
2607 {
2608 const char *p, *p1, *p2;
2609 char cmd[32];
2610 char url[1024];
2611 char protocol[32];
2612 char line[1024];
2613 int len;
2614 RTSPHeader header1, *header = &header1;
2615
2616 c->buffer_ptr[0] = '\0';
2617 p = c->buffer;
2618
2619 get_word(cmd, sizeof(cmd), &p);
2620 get_word(url, sizeof(url), &p);
2621 get_word(protocol, sizeof(protocol), &p);
2622
2623 av_strlcpy(c->method, cmd, sizeof(c->method));
2624 av_strlcpy(c->url, url, sizeof(c->url));
2625 av_strlcpy(c->protocol, protocol, sizeof(c->protocol));
2626
2627 if (url_open_dyn_buf(&c->pb) < 0) {
2628 /* XXX: cannot do more */
2629 c->pb = NULL; /* safety */
2630 return -1;
2631 }
2632
2633 /* check version name */
2634 if (strcmp(protocol, "RTSP/1.0") != 0) {
2635 rtsp_reply_error(c, RTSP_STATUS_VERSION);
2636 goto the_end;
2637 }
2638
2639 /* parse each header line */
2640 memset(header, 0, sizeof(RTSPHeader));
2641 /* skip to next line */
2642 while (*p != '\n' && *p != '\0')
2643 p++;
2644 if (*p == '\n')
2645 p++;
2646 while (*p != '\0') {
2647 p1 = strchr(p, '\n');
2648 if (!p1)
2649 break;
2650 p2 = p1;
2651 if (p2 > p && p2[-1] == '\r')
2652 p2--;
2653 /* skip empty line */
2654 if (p2 == p)
2655 break;
2656 len = p2 - p;
2657 if (len > sizeof(line) - 1)
2658 len = sizeof(line) - 1;
2659 memcpy(line, p, len);
2660 line[len] = '\0';
2661 rtsp_parse_line(header, line);
2662 p = p1 + 1;
2663 }
2664
2665 /* handle sequence number */
2666 c->seq = header->seq;
2667
2668 if (!strcmp(cmd, "DESCRIBE"))
2669 rtsp_cmd_describe(c, url);
2670 else if (!strcmp(cmd, "OPTIONS"))
2671 rtsp_cmd_options(c, url);
2672 else if (!strcmp(cmd, "SETUP"))
2673 rtsp_cmd_setup(c, url, header);
2674 else if (!strcmp(cmd, "PLAY"))
2675 rtsp_cmd_play(c, url, header);
2676 else if (!strcmp(cmd, "PAUSE"))
2677 rtsp_cmd_pause(c, url, header);
2678 else if (!strcmp(cmd, "TEARDOWN"))
2679 rtsp_cmd_teardown(c, url, header);
2680 else
2681 rtsp_reply_error(c, RTSP_STATUS_METHOD);
2682
2683 the_end:
2684 len = url_close_dyn_buf(c->pb, &c->pb_buffer);
2685 c->pb = NULL; /* safety */
2686 if (len < 0) {
2687 /* XXX: cannot do more */
2688 return -1;
2689 }
2690 c->buffer_ptr = c->pb_buffer;
2691 c->buffer_end = c->pb_buffer + len;
2692 c->state = RTSPSTATE_SEND_REPLY;
2693 return 0;
2694 }
2695
2696 static int prepare_sdp_description(FFStream *stream, uint8_t **pbuffer,
2697 struct in_addr my_ip)
2698 {
2699 AVFormatContext *avc;
2700 AVStream avs[MAX_STREAMS];
2701 int i;
2702
2703 avc = av_alloc_format_context();
2704 if (avc == NULL) {
2705 return -1;
2706 }
2707 if (stream->title[0] != 0) {
2708 av_strlcpy(avc->title, stream->title, sizeof(avc->title));
2709 } else {
2710 av_strlcpy(avc->title, "No Title", sizeof(avc->title));
2711 }
2712 avc->nb_streams = stream->nb_streams;
2713 if (stream->is_multicast) {
2714 snprintf(avc->filename, 1024, "rtp://%s:%d?multicast=1?ttl=%d",
2715 inet_ntoa(stream->multicast_ip),
2716 stream->multicast_port, stream->multicast_ttl);
2717 }
2718
2719 for(i = 0; i < stream->nb_streams; i++) {
2720 avc->streams[i] = &avs[i];
2721 avc->streams[i]->codec = stream->streams[i]->codec;
2722 }
2723 *pbuffer = av_mallocz(2048);
2724 avf_sdp_create(&avc, 1, *pbuffer, 2048);
2725 av_free(avc);
2726
2727 return strlen(*pbuffer);
2728 }
2729
2730 static void rtsp_cmd_options(HTTPContext *c, const char *url)
2731 {
2732 // rtsp_reply_header(c, RTSP_STATUS_OK);
2733 url_fprintf(c->pb, "RTSP/1.0 %d %s\r\n", RTSP_STATUS_OK, "OK");
2734 url_fprintf(c->pb, "CSeq: %d\r\n", c->seq);
2735 url_fprintf(c->pb, "Public: %s\r\n", "OPTIONS, DESCRIBE, SETUP, TEARDOWN, PLAY, PAUSE");
2736 url_fprintf(c->pb, "\r\n");
2737 }
2738
2739 static void rtsp_cmd_describe(HTTPContext *c, const char *url)
2740 {
2741 FFStream *stream;
2742 char path1[1024];
2743 const char *path;
2744 uint8_t *content;
2745 int content_length, len;
2746 struct sockaddr_in my_addr;
2747
2748 /* find which url is asked */
2749 url_split(NULL, 0, NULL, 0, NULL, 0, NULL, path1, sizeof(path1), url);
2750 path = path1;
2751 if (*path == '/')
2752 path++;
2753
2754 for(stream = first_stream; stream != NULL; stream = stream->next) {
2755 if (!stream->is_feed &&
2756 stream->fmt && !strcmp(stream->fmt->name, "rtp") &&
2757 !strcmp(path, stream->filename)) {
2758 goto found;
2759 }
2760 }
2761 /* no stream found */
2762 rtsp_reply_error(c, RTSP_STATUS_SERVICE); /* XXX: right error ? */
2763 return;
2764
2765 found:
2766 /* prepare the media description in sdp format */
2767
2768 /* get the host IP */
2769 len = sizeof(my_addr);
2770 getsockname(c->fd, (struct sockaddr *)&my_addr, &len);
2771 content_length = prepare_sdp_description(stream, &content, my_addr.sin_addr);
2772 if (content_length < 0) {
2773 rtsp_reply_error(c, RTSP_STATUS_INTERNAL);
2774 return;
2775 }
2776 rtsp_reply_header(c, RTSP_STATUS_OK);
2777 url_fprintf(c->pb, "Content-Type: application/sdp\r\n");
2778 url_fprintf(c->pb, "Content-Length: %d\r\n", content_length);
2779 url_fprintf(c->pb, "\r\n");
2780 put_buffer(c->pb, content, content_length);
2781 }
2782
2783 static HTTPContext *find_rtp_session(const char *session_id)
2784 {
2785 HTTPContext *c;
2786
2787 if (session_id[0] == '\0')
2788 return NULL;
2789
2790 for(c = first_http_ctx; c != NULL; c = c->next) {
2791 if (!strcmp(c->session_id, session_id))
2792 return c;
2793 }
2794 return NULL;
2795 }
2796
2797 static RTSPTransportField *find_transport(RTSPHeader *h, enum RTSPProtocol protocol)
2798 {
2799 RTSPTransportField *th;
2800 int i;
2801
2802 for(i=0;i<h->nb_transports;i++) {
2803 th = &h->transports[i];
2804 if (th->protocol == protocol)
2805 return th;
2806 }
2807 return NULL;
2808 }
2809
2810 static void rtsp_cmd_setup(HTTPContext *c, const char *url,
2811 RTSPHeader *h)
2812 {
2813 FFStream *stream;
2814 int stream_index, port;
2815 char buf[1024];
2816 char path1[1024];
2817 const char *path;
2818 HTTPContext *rtp_c;
2819 RTSPTransportField *th;
2820 struct sockaddr_in dest_addr;
2821 RTSPActionServerSetup setup;
2822
2823 /* find which url is asked */
2824 url_split(NULL, 0, NULL, 0, NULL, 0, NULL, path1, sizeof(path1), url);
2825 path = path1;
2826 if (*path == '/')
2827 path++;
2828
2829 /* now check each stream */
2830 for(stream = first_stream; stream != NULL; stream = stream->next) {
2831 if (!stream->is_feed &&
2832 stream->fmt && !strcmp(stream->fmt->name, "rtp")) {
2833 /* accept aggregate filenames only if single stream */
2834 if (!strcmp(path, stream->filename)) {
2835 if (stream->nb_streams != 1) {
2836 rtsp_reply_error(c, RTSP_STATUS_AGGREGATE);
2837 return;
2838 }
2839 stream_index = 0;
2840 goto found;
2841 }
2842
2843 for(stream_index = 0; stream_index < stream->nb_streams;
2844 stream_index++) {
2845 snprintf(buf, sizeof(buf), "%s/streamid=%d",
2846 stream->filename, stream_index);
2847 if (!strcmp(path, buf))
2848 goto found;
2849 }
2850 }
2851 }
2852 /* no stream found */
2853 rtsp_reply_error(c, RTSP_STATUS_SERVICE); /* XXX: right error ? */
2854 return;
2855 found:
2856
2857 /* generate session id if needed */
2858 if (h->session_id[0] == '\0')
2859 snprintf(h->session_id, sizeof(h->session_id), "%08x%08x",
2860 av_random(&random_state), av_random(&random_state));
2861
2862 /* find rtp session, and create it if none found */
2863 rtp_c = find_rtp_session(h->session_id);
2864 if (!rtp_c) {
2865 /* always prefer UDP */
2866 th = find_transport(h, RTSP_PROTOCOL_RTP_UDP);
2867 if (!th) {
2868 th = find_transport(h, RTSP_PROTOCOL_RTP_TCP);
2869 if (!th) {
2870 rtsp_reply_error(c, RTSP_STATUS_TRANSPORT);
2871 return;
2872 }
2873 }
2874
2875 rtp_c = rtp_new_connection(&c->from_addr, stream, h->session_id,
2876 th->protocol);
2877 if (!rtp_c) {
2878 rtsp_reply_error(c, RTSP_STATUS_BANDWIDTH);
2879 return;
2880 }
2881
2882 /* open input stream */
2883 if (open_input_stream(rtp_c, "") < 0) {
2884 rtsp_reply_error(c, RTSP_STATUS_INTERNAL);
2885 return;
2886 }
2887 }
2888
2889 /* test if stream is OK (test needed because several SETUP needs
2890 to be done for a given file) */
2891 if (rtp_c->stream != stream) {
2892 rtsp_reply_error(c, RTSP_STATUS_SERVICE);
2893 return;
2894 }
2895
2896 /* test if stream is already set up */
2897 if (rtp_c->rtp_ctx[stream_index]) {
2898 rtsp_reply_error(c, RTSP_STATUS_STATE);
2899 return;
2900 }
2901
2902 /* check transport */
2903 th = find_transport(h, rtp_c->rtp_protocol);
2904 if (!th || (th->protocol == RTSP_PROTOCOL_RTP_UDP &&
2905 th->client_port_min <= 0)) {
2906 rtsp_reply_error(c, RTSP_STATUS_TRANSPORT);
2907 return;
2908 }
2909
2910 /* setup default options */
2911 setup.transport_option[0] = '\0';
2912 dest_addr = rtp_c->from_addr;
2913 dest_addr.sin_port = htons(th->client_port_min);
2914
2915 /* setup stream */
2916 if (rtp_new_av_stream(rtp_c, stream_index, &dest_addr, c) < 0) {
2917 rtsp_reply_error(c, RTSP_STATUS_TRANSPORT);
2918 return;
2919 }
2920
2921 /* now everything is OK, so we can send the connection parameters */
2922 rtsp_reply_header(c, RTSP_STATUS_OK);
2923 /* session ID */
2924 url_fprintf(c->pb, "Session: %s\r\n", rtp_c->session_id);
2925
2926 switch(rtp_c->rtp_protocol) {
2927 case RTSP_PROTOCOL_RTP_UDP:
2928 port = rtp_get_local_port(rtp_c->rtp_handles[stream_index]);
2929 url_fprintf(c->pb, "Transport: RTP/AVP/UDP;unicast;"
2930 "client_port=%d-%d;server_port=%d-%d",
2931 th->client_port_min, th->client_port_min + 1,
2932 port, port + 1);
2933 break;
2934 case RTSP_PROTOCOL_RTP_TCP:
2935 url_fprintf(c->pb, "Transport: RTP/AVP/TCP;interleaved=%d-%d",
2936 stream_index * 2, stream_index * 2 + 1);
2937 break;
2938 default:
2939 break;
2940 }
2941 if (setup.transport_option[0] != '\0')
2942 url_fprintf(c->pb, ";%s", setup.transport_option);
2943 url_fprintf(c->pb, "\r\n");
2944
2945
2946 url_fprintf(c->pb, "\r\n");
2947 }
2948
2949
2950 /* find an rtp connection by using the session ID. Check consistency
2951 with filename */
2952 static HTTPContext *find_rtp_session_with_url(const char *url,
2953 const char *session_id)
2954 {
2955 HTTPContext *rtp_c;
2956 char path1[1024];
2957 const char *path;
2958 char buf[1024];
2959 int s;
2960
2961 rtp_c = find_rtp_session(session_id);
2962 if (!rtp_c)
2963 return NULL;
2964
2965 /* find which url is asked */
2966 url_split(NULL, 0, NULL, 0, NULL, 0, NULL, path1, sizeof(path1), url);
2967 path = path1;
2968 if (*path == '/')
2969 path++;
2970 if(!strcmp(path, rtp_c->stream->filename)) return rtp_c;
2971 for(s=0; s<rtp_c->stream->nb_streams; ++s) {
2972 snprintf(buf, sizeof(buf), "%s/streamid=%d",
2973 rtp_c->stream->filename, s);
2974 if(!strncmp(path, buf, sizeof(buf))) {
2975 // XXX: Should we reply with RTSP_STATUS_ONLY_AGGREGATE if nb_streams>1?
2976 return rtp_c;
2977 }
2978 }
2979 return NULL;
2980 }
2981
2982 static void rtsp_cmd_play(HTTPContext *c, const char *url, RTSPHeader *h)
2983 {
2984 HTTPContext *rtp_c;
2985
2986 rtp_c = find_rtp_session_with_url(url, h->session_id);
2987 if (!rtp_c) {
2988 rtsp_reply_error(c, RTSP_STATUS_SESSION);
2989 return;
2990 }
2991
2992 if (rtp_c->state != HTTPSTATE_SEND_DATA &&
2993 rtp_c->state != HTTPSTATE_WAIT_FEED &&
2994 rtp_c->state != HTTPSTATE_READY) {
2995 rtsp_reply_error(c, RTSP_STATUS_STATE);
2996 return;
2997 }
2998
2999 #if 0
3000 /* XXX: seek in stream */
3001 if (h->range_start != AV_NOPTS_VALUE) {
3002 printf("range_start=%0.3f\n", (double)h->range_start / AV_TIME_BASE);
3003 av_seek_frame(rtp_c->fmt_in, -1, h->range_start);
3004 }
3005 #endif
3006
3007 rtp_c->state = HTTPSTATE_SEND_DATA;
3008
3009 /* now everything is OK, so we can send the connection parameters */
3010 rtsp_reply_header(c, RTSP_STATUS_OK);
3011 /* session ID */
3012 url_fprintf(c->pb, "Session: %s\r\n", rtp_c->session_id);
3013 url_fprintf(c->pb, "\r\n");
3014 }
3015
3016 static void rtsp_cmd_pause(HTTPContext *c, const char *url, RTSPHeader *h)
3017 {
3018 HTTPContext *rtp_c;
3019
3020 rtp_c = find_rtp_session_with_url(url, h->session_id);
3021 if (!rtp_c) {
3022 rtsp_reply_error(c, RTSP_STATUS_SESSION);
3023 return;
3024 }
3025
3026 if (rtp_c->state != HTTPSTATE_SEND_DATA &&
3027 rtp_c->state != HTTPSTATE_WAIT_FEED) {
3028 rtsp_reply_error(c, RTSP_STATUS_STATE);
3029 return;
3030 }
3031
3032 rtp_c->state = HTTPSTATE_READY;
3033 rtp_c->first_pts = AV_NOPTS_VALUE;
3034 /* now everything is OK, so we can send the connection parameters */
3035 rtsp_reply_header(c, RTSP_STATUS_OK);
3036 /* session ID */
3037 url_fprintf(c->pb, "Session: %s\r\n", rtp_c->session_id);
3038 url_fprintf(c->pb, "\r\n");
3039 }
3040
3041 static void rtsp_cmd_teardown(HTTPContext *c, const char *url, RTSPHeader *h)
3042 {
3043 HTTPContext *rtp_c;
3044 char session_id[32];
3045
3046 rtp_c = find_rtp_session_with_url(url, h->session_id);
3047 if (!rtp_c) {
3048 rtsp_reply_error(c, RTSP_STATUS_SESSION);
3049 return;
3050 }
3051
3052 av_strlcpy(session_id, rtp_c->session_id, sizeof(session_id));
3053
3054 /* abort the session */
3055 close_connection(rtp_c);
3056
3057 /* now everything is OK, so we can send the connection parameters */
3058 rtsp_reply_header(c, RTSP_STATUS_OK);
3059 /* session ID */
3060 url_fprintf(c->pb, "Session: %s\r\n", session_id);
3061 url_fprintf(c->pb, "\r\n");
3062 }
3063
3064
3065 /********************************************************************/
3066 /* RTP handling */
3067
3068 static HTTPContext *rtp_new_connection(struct sockaddr_in *from_addr,
3069 FFStream *stream, const char *session_id,
3070 enum RTSPProtocol rtp_protocol)
3071 {
3072 HTTPContext *c = NULL;
3073 const char *proto_str;
3074
3075 /* XXX: should output a warning page when coming
3076 close to the connection limit */
3077 if (nb_connections >= nb_max_connections)
3078 goto fail;
3079
3080 /* add a new connection */
3081 c = av_mallocz(sizeof(HTTPContext));
3082 if (!c)
3083 goto fail;
3084
3085 c->fd = -1;
3086 c->poll_entry = NULL;
3087 c->from_addr = *from_addr;
3088 c->buffer_size = IOBUFFER_INIT_SIZE;
3089 c->buffer = av_malloc(c->buffer_size);
3090 if (!c->buffer)
3091 goto fail;
3092 nb_connections++;
3093 c->stream = stream;
3094 av_strlcpy(c->session_id, session_id, sizeof(c->session_id));
3095 c->state = HTTPSTATE_READY;
3096 c->is_packetized = 1;
3097 c->rtp_protocol = rtp_protocol;
3098
3099 /* protocol is shown in statistics */
3100 switch(c->rtp_protocol) {
3101 case RTSP_PROTOCOL_RTP_UDP_MULTICAST:
3102 proto_str = "MCAST";
3103 break;
3104 case RTSP_PROTOCOL_RTP_UDP:
3105 proto_str = "UDP";
3106 break;
3107 case RTSP_PROTOCOL_RTP_TCP:
3108 proto_str = "TCP";
3109 break;
3110 default:
3111 proto_str = "???";
3112 break;
3113 }
3114 av_strlcpy(c->protocol, "RTP/", sizeof(c->protocol));
3115 av_strlcat(c->protocol, proto_str, sizeof(c->protocol));
3116
3117 current_bandwidth += stream->bandwidth;
3118
3119 c->next = first_http_ctx;
3120 first_http_ctx = c;
3121 return c;
3122
3123 fail:
3124 if (c) {
3125 av_free(c->buffer);
3126 av_free(c);
3127 }
3128 return NULL;
3129 }
3130
3131 /* add a new RTP stream in an RTP connection (used in RTSP SETUP
3132 command). If RTP/TCP protocol is used, TCP connection 'rtsp_c' is
3133 used. */
3134 static int rtp_new_av_stream(HTTPContext *c,
3135 int stream_index, struct sockaddr_in *dest_addr,
3136 HTTPContext *rtsp_c)
3137 {
3138 AVFormatContext *ctx;
3139 AVStream *st;
3140 char *ipaddr;
3141 URLContext *h = NULL;
3142 uint8_t *dummy_buf;
3143 int max_packet_size;
3144
3145 /* now we can open the relevant output stream */
3146 ctx = av_alloc_format_context();
3147 if (!ctx)
3148 return -1;
3149 ctx->oformat = guess_format("rtp", NULL, NULL);
3150
3151 st = av_mallocz(sizeof(AVStream));
3152 if (!st)
3153 goto fail;
3154 st->codec= avcodec_alloc_context();
3155 ctx->nb_streams = 1;
3156 ctx->streams[0] = st;
3157
3158 if (!c->stream->feed ||
3159 c->stream->feed == c->stream)
3160 memcpy(st, c->stream->streams[stream_index], sizeof(AVStream));
3161 else
3162 memcpy(st,
3163 c->stream->feed->streams[c->stream->feed_streams[stream_index]],
3164 sizeof(AVStream));
3165 st->priv_data = NULL;
3166
3167 /* build destination RTP address */
3168 ipaddr = inet_ntoa(dest_addr->sin_addr);
3169
3170 switch(c->rtp_protocol) {
3171 case RTSP_PROTOCOL_RTP_UDP:
3172 case RTSP_PROTOCOL_RTP_UDP_MULTICAST:
3173 /* RTP/UDP case */
3174
3175 /* XXX: also pass as parameter to function ? */
3176 if (c->stream->is_multicast) {
3177 int ttl;
3178 ttl = c->stream->multicast_ttl;
3179 if (!ttl)
3180 ttl = 16;
3181 snprintf(ctx->filename, sizeof(ctx->filename),
3182 "rtp://%s:%d?multicast=1&ttl=%d",
3183 ipaddr, ntohs(dest_addr->sin_port), ttl);
3184 } else {
3185 snprintf(ctx->filename, sizeof(ctx->filename),
3186 "rtp://%s:%d", ipaddr, ntohs(dest_addr->sin_port));
3187 }
3188
3189 if (url_open(&h, ctx->filename, URL_WRONLY) < 0)
3190 goto fail;
3191 c->rtp_handles[stream_index] = h;
3192 max_packet_size = url_get_max_packet_size(h);
3193 break;
3194 case RTSP_PROTOCOL_RTP_TCP:
3195 /* RTP/TCP case */
3196 c->rtsp_c = rtsp_c;
3197 max_packet_size = RTSP_TCP_MAX_PACKET_SIZE;
3198 break;
3199 default:
3200 goto fail;
3201 }
3202
3203 http_log("%s:%d - - \"PLAY %s/streamid=%d %s\"\n",
3204 ipaddr, ntohs(dest_addr->sin_port),
3205 c->stream->filename, stream_index, c->protocol);
3206
3207 /* normally, no packets should be output here, but the packet size may be checked */
3208 if (url_open_dyn_packet_buf(&ctx->pb, max_packet_size) < 0) {
3209 /* XXX: close stream */
3210 goto fail;
3211 }
3212 av_set_parameters(ctx, NULL);
3213 if (av_write_header(ctx) < 0) {
3214 fail:
3215 if (h)
3216 url_close(h);
3217 av_free(ctx);
3218 return -1;
3219 }
3220 url_close_dyn_buf(ctx->pb, &dummy_buf);
3221 av_free(dummy_buf);
3222
3223 c->rtp_ctx[stream_index] = ctx;
3224 return 0;
3225 }
3226
3227 /********************************************************************/
3228 /* ffserver initialization */
3229
3230 static AVStream *add_av_stream1(FFStream *stream, AVCodecContext *codec)
3231 {
3232 AVStream *fst;
3233
3234 fst = av_mallocz(sizeof(AVStream));
3235 if (!fst)
3236 return NULL;
3237 fst->codec= avcodec_alloc_context();
3238 fst->priv_data = av_mallocz(sizeof(FeedData));
3239 memcpy(fst->codec, codec, sizeof(AVCodecContext));
3240 fst->index = stream->nb_streams;
3241 av_set_pts_info(fst, 33, 1, 90000);
3242 stream->streams[stream->nb_streams++] = fst;
3243 return fst;
3244 }
3245
3246 /* return the stream number in the feed */
3247 static int add_av_stream(FFStream *feed, AVStream *st)
3248 {
3249 AVStream *fst;
3250 AVCodecContext *av, *av1;
3251 int i;
3252
3253 av = st->codec;
3254 for(i=0;i<feed->nb_streams;i++) {
3255 st = feed->streams[i];
3256 av1 = st->codec;
3257 if (av1->codec_id == av->codec_id &&
3258 av1->codec_type == av->codec_type &&
3259 av1->bit_rate == av->bit_rate) {
3260
3261 switch(av->codec_type) {
3262 case CODEC_TYPE_AUDIO:
3263 if (av1->channels == av->channels &&
3264 av1->sample_rate == av->sample_rate)
3265 goto found;
3266 break;
3267 case CODEC_TYPE_VIDEO:
3268 if (av1->width == av->width &&
3269 av1->height == av->height &&
3270 av1->time_base.den == av->time_base.den &&
3271 av1->time_base.num == av->time_base.num &&
3272 av1->gop_size == av->gop_size)
3273 goto found;
3274 break;
3275 default:
3276 abort();
3277 }
3278 }
3279 }
3280
3281 fst = add_av_stream1(feed, av);
3282 if (!fst)
3283 return -1;
3284 return feed->nb_streams - 1;
3285 found:
3286 return i;
3287 }
3288
3289 static void remove_stream(FFStream *stream)
3290 {
3291 FFStream **ps;
3292 ps = &first_stream;
3293 while (*ps != NULL) {
3294 if (*ps == stream)
3295 *ps = (*ps)->next;
3296 else
3297 ps = &(*ps)->next;
3298 }
3299 }
3300
3301 /* specific mpeg4 handling : we extract the raw parameters */
3302 static void extract_mpeg4_header(AVFormatContext *infile)
3303 {
3304 int mpeg4_count, i, size;
3305 AVPacket pkt;
3306 AVStream *st;
3307 const uint8_t *p;
3308
3309 mpeg4_count = 0;
3310 for(i=0;i<infile->nb_streams;i++) {
3311 st = infile->streams[i];
3312 if (st->codec->codec_id == CODEC_ID_MPEG4 &&
3313 st->codec->extradata_size == 0) {
3314 mpeg4_count++;
3315 }
3316 }
3317 if (!mpeg4_count)
3318 return;
3319
3320 printf("MPEG4 without extra data: trying to find header in %s\n", infile->filename);
3321 while (mpeg4_count > 0) {
3322 if (av_read_packet(infile, &pkt) < 0)
3323 break;
3324 st = infile->streams[pkt.stream_index];
3325 if (st->codec->codec_id == CODEC_ID_MPEG4 &&
3326 st->codec->extradata_size == 0) {
3327 av_freep(&st->codec->extradata);
3328 /* fill extradata with the header */
3329 /* XXX: we make hard suppositions here ! */
3330 p = pkt.data;
3331 while (p < pkt.data + pkt.size - 4) {
3332 /* stop when vop header is found */
3333 if (p[0] == 0x00 && p[1] == 0x00 &&
3334 p[2] == 0x01 && p[3] == 0xb6) {
3335 size = p - pkt.data;
3336 // av_hex_dump_log(infile, AV_LOG_DEBUG, pkt.data, size);
3337 st->codec->extradata = av_malloc(size);
3338 st->codec->extradata_size = size;
3339 memcpy(st->codec->extradata, pkt.data, size);
3340 break;
3341 }
3342 p++;
3343 }
3344 mpeg4_count--;
3345 }
3346 av_free_packet(&pkt);
3347 }
3348 }
3349
3350 /* compute the needed AVStream for each file */
3351 static void build_file_streams(void)
3352 {
3353 FFStream *stream, *stream_next;
3354 AVFormatContext *infile;
3355 int i, ret;
3356
3357 /* gather all streams */
3358 for(stream = first_stream; stream != NULL; stream = stream_next) {
3359 stream_next = stream->next;
3360 if (stream->stream_type == STREAM_TYPE_LIVE &&
3361 !stream->feed) {
3362 /* the stream comes from a file */
3363 /* try to open the file */
3364 /* open stream */
3365 stream->ap_in = av_mallocz(sizeof(AVFormatParameters));
3366 if (stream->fmt && !strcmp(stream->fmt->name, "rtp")) {
3367 /* specific case : if transport stream output to RTP,
3368 we use a raw transport stream reader */
3369 stream->ap_in->mpeg2ts_raw = 1;
3370 stream->ap_in->mpeg2ts_compute_pcr = 1;
3371 }
3372
3373 if ((ret = av_open_input_file(&infile, stream->feed_filename,
3374 stream->ifmt, 0, stream->ap_in)) < 0) {
3375 http_log("could not open %s: %d\n", stream->feed_filename, ret);
3376 /* remove stream (no need to spend more time on it) */
3377 fail:
3378 remove_stream(stream);
3379 } else {
3380 /* find all the AVStreams inside and reference them in
3381 'stream' */
3382 if (av_find_stream_info(infile) < 0) {
3383 http_log("Could not find codec parameters from '%s'\n",
3384 stream->feed_filename);
3385 av_close_input_file(infile);
3386 goto fail;
3387 }
3388 extract_mpeg4_header(infile);
3389
3390 for(i=0;i<infile->nb_streams;i++)
3391 add_av_stream1(stream, infile->streams[i]->codec);
3392
3393 av_close_input_file(infile);
3394 }
3395 }
3396 }
3397 }
3398
3399 /* compute the needed AVStream for each feed */
3400 static void build_feed_streams(void)
3401 {
3402 FFStream *stream, *feed;
3403 int i;
3404
3405 /* gather all streams */
3406 for(stream = first_stream; stream != NULL; stream = stream->next) {
3407 feed = stream->feed;
3408 if (feed) {
3409 if (!stream->is_feed) {
3410 /* we handle a stream coming from a feed */
3411 for(i=0;i<stream->nb_streams;i++)
3412 stream->feed_streams[i] = add_av_stream(feed, stream->streams[i]);
3413 }
3414 }
3415 }
3416
3417 /* gather all streams */
3418 for(stream = first_stream; stream != NULL; stream = stream->next) {
3419 feed = stream->feed;
3420 if (feed) {
3421 if (stream->is_feed) {
3422 for(i=0;i<stream->nb_streams;i++)
3423 stream->feed_streams[i] = i;
3424 }
3425 }
3426 }
3427
3428 /* create feed files if needed */
3429 for(feed = first_feed; feed != NULL; feed = feed->next_feed) {
3430 int fd;
3431
3432 if (url_exist(feed->feed_filename)) {
3433 /* See if it matches */
3434 AVFormatContext *s;
3435 int matches = 0;
3436
3437 if (av_open_input_file(&s, feed->feed_filename, NULL, FFM_PACKET_SIZE, NULL) >= 0) {
3438 /* Now see if it matches */
3439 if (s->nb_streams == feed->nb_streams) {
3440 matches = 1;
3441 for(i=0;i<s->nb_streams;i++) {
3442 AVStream *sf, *ss;
3443 sf = feed->streams[i];
3444 ss = s->streams[i];
3445
3446 if (sf->index != ss->index ||
3447 sf->id != ss->id) {
3448 http_log("Index & Id do not match for stream %d (%s)\n",
3449 i, feed->feed_filename);
3450 matches = 0;
3451 } else {
3452 AVCodecContext *ccf, *ccs;
3453
3454 ccf = sf->codec;
3455 ccs = ss->codec;
3456 #define CHECK_CODEC(x) (ccf->x != ccs->x)
3457
3458 if (CHECK_CODEC(codec) || CHECK_CODEC(codec_type)) {
3459 http_log("Codecs do not match for stream %d\n", i);
3460 matches = 0;
3461 } else if (CHECK_CODEC(bit_rate) || CHECK_CODEC(flags)) {
3462 http_log("Codec bitrates do not match for stream %d\n", i);
3463 matches = 0;
3464 } else if (ccf->codec_type == CODEC_TYPE_VIDEO) {
3465 if (CHECK_CODEC(time_base.den) ||
3466 CHECK_CODEC(time_base.num) ||
3467 CHECK_CODEC(width) ||
3468 CHECK_CODEC(height)) {
3469 http_log("Codec width, height and framerate do not match for stream %d\n", i);
3470 matches = 0;
3471 }
3472 } else if (ccf->codec_type == CODEC_TYPE_AUDIO) {
3473 if (CHECK_CODEC(sample_rate) ||
3474 CHECK_CODEC(channels) ||
3475 CHECK_CODEC(frame_size)) {
3476 http_log("Codec sample_rate, channels, frame_size do not match for stream %d\n", i);
3477 matches = 0;
3478 }
3479 } else {
3480 http_log("Unknown codec type\n");
3481 matches = 0;
3482 }
3483 }
3484 if (!matches)
3485 break;
3486 }
3487 } else
3488 http_log("Deleting feed file '%s' as stream counts differ (%d != %d)\n",
3489 feed->feed_filename, s->nb_streams, feed->nb_streams);
3490
3491 av_close_input_file(s);
3492 } else
3493 http_log("Deleting feed file '%s' as it appears to be corrupt\n",
3494 feed->feed_filename);
3495
3496 if (!matches) {
3497 if (feed->readonly) {
3498 http_log("Unable to delete feed file '%s' as it is marked readonly\n",
3499 feed->feed_filename);
3500 exit(1);
3501 }
3502 unlink(feed->feed_filename);
3503 }
3504 }
3505 if (!url_exist(feed->feed_filename)) {
3506 AVFormatContext s1, *s = &s1;
3507
3508 if (feed->readonly) {
3509 http_log("Unable to create feed file '%s' as it is marked readonly\n",
3510 feed->feed_filename);
3511 exit(1);
3512 }
3513
3514 /* only write the header of the ffm file */
3515 if (url_fopen(&s->pb, feed->feed_filename, URL_WRONLY) < 0) {
3516 http_log("Could not open output feed file '%s'\n",
3517 feed->feed_filename);
3518 exit(1);
3519 }
3520 s->oformat = feed->fmt;
3521 s->nb_streams = feed->nb_streams;
3522 for(i=0;i<s->nb_streams;i++) {
3523 AVStream *st;
3524 st = feed->streams[i];
3525 s->streams[i] = st;
3526 }
3527 av_set_parameters(s, NULL);
3528 if (av_write_header(s) < 0) {
3529 http_log("Container doesn't supports the required parameters\n");
3530 exit(1);
3531 }
3532 /* XXX: need better api */
3533 av_freep(&s->priv_data);
3534 url_fclose(s->pb);
3535 }
3536 /* get feed size and write index */
3537 fd = open(feed->feed_filename, O_RDONLY);
3538 if (fd < 0) {
3539 http_log("Could not open output feed file '%s'\n",
3540 feed->feed_filename);
3541 exit(1);
3542 }
3543
3544 feed->feed_write_index = ffm_read_write_index(fd);
3545 feed->feed_size = lseek(fd, 0, SEEK_END);
3546 /* ensure that we do not wrap before the end of file */
3547 if (feed->feed_max_size && feed->feed_max_size < feed->feed_size)
3548 feed->feed_max_size = feed->feed_size;
3549
3550 close(fd);
3551 }
3552 }
3553
3554 /* compute the bandwidth used by each stream */
3555 static void compute_bandwidth(void)
3556 {
3557 unsigned bandwidth;
3558 int i;
3559 FFStream *stream;
3560
3561 for(stream = first_stream; stream != NULL; stream = stream->next) {
3562 bandwidth = 0;
3563 for(i=0;i<stream->nb_streams;i++) {
3564 AVStream *st = stream->streams[i];
3565 switch(st->codec->codec_type) {
3566 case CODEC_TYPE_AUDIO:
3567 case CODEC_TYPE_VIDEO:
3568 bandwidth += st->codec->bit_rate;
3569 break;
3570 default:
3571 break;
3572 }
3573 }
3574 stream->bandwidth = (bandwidth + 999) / 1000;
3575 }
3576 }
3577
3578 static void get_arg(char *buf, int buf_size, const char **pp)
3579 {
3580 const char *p;
3581 char *q;
3582 int quote;
3583
3584 p = *pp;
3585 while (isspace(*p)) p++;
3586 q = buf;
3587 quote = 0;
3588 if (*p == '\"' || *p == '\'')
3589 quote = *p++;
3590 for(;;) {
3591 if (quote) {
3592 if (*p == quote)
3593 break;
3594 } else {
3595 if (isspace(*p))
3596 break;
3597 }
3598 if (*p == '\0')
3599 break;
3600 if ((q - buf) < buf_size - 1)
3601 *q++ = *p;
3602 p++;
3603 }
3604 *q = '\0';
3605 if (quote && *p == quote)
3606 p++;
3607 *pp = p;
3608 }
3609
3610 /* add a codec and set the default parameters */
3611 static void add_codec(FFStream *stream, AVCodecContext *av)
3612 {
3613 AVStream *st;
3614
3615 /* compute default parameters */
3616 switch(av->codec_type) {
3617 case CODEC_TYPE_AUDIO:
3618 if (av->bit_rate == 0)
3619 av->bit_rate = 64000;
3620 if (av->sample_rate == 0)
3621 av->sample_rate = 22050;
3622 if (av->channels == 0)
3623 av->channels = 1;
3624 break;
3625 case CODEC_TYPE_VIDEO:
3626 if (av->bit_rate == 0)
3627 av->bit_rate = 64000;
3628 if (av->time_base.num == 0){
3629 av->time_base.den = 5;
3630 av->time_base.num = 1;
3631 }
3632 if (av->width == 0 || av->height == 0) {
3633 av->width = 160;
3634 av->height = 128;
3635 }
3636 /* Bitrate tolerance is less for streaming */
3637 if (av->bit_rate_tolerance == 0)
3638 av->bit_rate_tolerance = FFMAX(av->bit_rate / 4,
3639 (int64_t)av->bit_rate*av->time_base.num/av->time_base.den);
3640 if (av->qmin == 0)
3641 av->qmin = 3;
3642 if (av->qmax == 0)
3643 av->qmax = 31;
3644 if (av->max_qdiff == 0)
3645 av->max_qdiff = 3;
3646 av->qcompress = 0.5;
3647 av->qblur = 0.5;
3648
3649 if (!av->nsse_weight)
3650 av->nsse_weight = 8;
3651
3652 av->frame_skip_cmp = FF_CMP_DCTMAX;
3653 av->me_method = ME_EPZS;
3654 av->rc_buffer_aggressivity = 1.0;
3655
3656 if (!av->rc_eq)
3657 av->rc_eq = "tex^qComp";
3658 if (!av->i_quant_factor)
3659 av->i_quant_factor = -0.8;
3660 if (!av->b_quant_factor)
3661 av->b_quant_factor = 1.25;
3662 if (!av->b_quant_offset)
3663 av->b_quant_offset = 1.25;
3664 if (!av->rc_max_rate)
3665 av->rc_max_rate = av->bit_rate * 2;
3666
3667 if (av->rc_max_rate && !av->rc_buffer_size) {
3668 av->rc_buffer_size = av->rc_max_rate;
3669 }
3670
3671
3672 break;
3673 default:
3674 abort();
3675 }
3676
3677 st = av_mallocz(sizeof(AVStream));
3678 if (!st)
3679 return;
3680 st->codec = avcodec_alloc_context();
3681 stream->streams[stream->nb_streams++] = st;
3682 memcpy(st->codec, av, sizeof(AVCodecContext));
3683 }
3684
3685 static int opt_audio_codec(const char *arg)
3686 {
3687 AVCodec *p= avcodec_find_encoder_by_name(arg);
3688
3689 if (p == NULL || p->type != CODEC_TYPE_AUDIO)
3690 return CODEC_ID_NONE;
3691
3692 return p->id;
3693 }
3694
3695 static int opt_video_codec(const char *arg)
3696 {
3697 AVCodec *p= avcodec_find_encoder_by_name(arg);
3698
3699 if (p == NULL || p->type != CODEC_TYPE_VIDEO)
3700 return CODEC_ID_NONE;
3701
3702 return p->id;
3703 }
3704
3705 /* simplistic plugin support */
3706
3707 #ifdef HAVE_DLOPEN
3708 static void load_module(const char *filename)
3709 {
3710 void *dll;
3711 void (*init_func)(void);
3712 dll = dlopen(filename, RTLD_NOW);
3713 if (!dll) {
3714 fprintf(stderr, "Could not load module '%s' - %s\n",
3715 filename, dlerror());
3716 return;
3717 }
3718
3719 init_func = dlsym(dll, "ffserver_module_init");
3720 if (!init_func) {
3721 fprintf(stderr,
3722 "%s: init function 'ffserver_module_init()' not found\n",
3723 filename);
3724 dlclose(dll);
3725 }
3726
3727 init_func();
3728 }
3729 #endif
3730
3731 static int opt_default(const char *opt, const char *arg,
3732 AVCodecContext *avctx, int type)
3733 {
3734 const AVOption *o = NULL;
3735 const AVOption *o2 = av_find_opt(avctx, opt, NULL, type, type);
3736 if(o2)
3737 o = av_set_string2(avctx, opt, arg, 1);
3738 if(!o)
3739 return -1;
3740 return 0;
3741 }
3742
3743 static int parse_ffconfig(const char *filename)
3744 {
3745 FILE *f;
3746 char line[1024];
3747 char cmd[64];
3748 char arg[1024];
3749 const char *p;
3750 int val, errors, line_num;
3751 FFStream **last_stream, *stream, *redirect;
3752 FFStream **last_feed, *feed;
3753 AVCodecContext audio_enc, video_enc;
3754 int audio_id, video_id;
3755
3756 f = fopen(filename, "r");
3757 if (!f) {
3758 perror(filename);
3759 return -1;
3760 }
3761
3762 errors = 0;
3763 line_num = 0;
3764 first_stream = NULL;
3765 last_stream = &first_stream;
3766 first_feed = NULL;
3767 last_feed = &first_feed;
3768 stream = NULL;
3769 feed = NULL;
3770 redirect = NULL;
3771 audio_id = CODEC_ID_NONE;
3772 video_id = CODEC_ID_NONE;
3773 for(;;) {
3774 if (fgets(line, sizeof(line), f) == NULL)
3775 break;
3776 line_num++;
3777 p = line;
3778 while (isspace(*p))
3779 p++;
3780 if (*p == '\0' || *p == '#')
3781 continue;
3782
3783 get_arg(cmd, sizeof(cmd), &p);
3784
3785 if (!strcasecmp(cmd, "Port")) {
3786 get_arg(arg, sizeof(arg), &p);
3787 val = atoi(arg);
3788 if (val < 1 || val > 65536) {
3789 fprintf(stderr, "%s:%d: Invalid port: %s\n",
3790 filename, line_num, arg);
3791 errors++;
3792 }
3793 my_http_addr.sin_port = htons(val);
3794 } else if (!strcasecmp(cmd, "BindAddress")) {
3795 get_arg(arg, sizeof(arg), &p);
3796 if (resolve_host(&my_http_addr.sin_addr, arg) != 0) {
3797 fprintf(stderr, "%s:%d: Invalid host/IP address: %s\n",
3798 filename, line_num, arg);
3799 errors++;
3800 }
3801 } else if (!strcasecmp(cmd, "NoDaemon")) {
3802 ffserver_daemon = 0;
3803 } else if (!strcasecmp(cmd, "RTSPPort")) {
3804 get_arg(arg, sizeof(arg), &p);
3805 val = atoi(arg);
3806 if (val < 1 || val > 65536) {
3807 fprintf(stderr, "%s:%d: Invalid port: %s\n",
3808 filename, line_num, arg);
3809 errors++;
3810 }
3811 my_rtsp_addr.sin_port = htons(atoi(arg));
3812 } else if (!strcasecmp(cmd, "RTSPBindAddress")) {
3813 get_arg(arg, sizeof(arg), &p);
3814 if (resolve_host(&my_rtsp_addr.sin_addr, arg) != 0) {
3815 fprintf(stderr, "%s:%d: Invalid host/IP address: %s\n",
3816 filename, line_num, arg);
3817 errors++;
3818 }
3819 } else if (!strcasecmp(cmd, "MaxClients")) {
3820 get_arg(arg, sizeof(arg), &p);
3821 val = atoi(arg);
3822 if (val < 1 || val > HTTP_MAX_CONNECTIONS) {
3823 fprintf(stderr, "%s:%d: Invalid MaxClients: %s\n",
3824 filename, line_num, arg);
3825 errors++;
3826 } else {
3827 nb_max_connections = val;
3828 }
3829 } else if (!strcasecmp(cmd, "MaxBandwidth")) {
3830 int64_t llval;
3831 get_arg(arg, sizeof(arg), &p);
3832 llval = atoll(arg);
3833 if (llval < 10 || llval > 10000000) {
3834 fprintf(stderr, "%s:%d: Invalid MaxBandwidth: %s\n",
3835 filename, line_num, arg);
3836 errors++;
3837 } else
3838 max_bandwidth = llval;
3839 } else if (!strcasecmp(cmd, "CustomLog")) {
3840 if (!ffserver_debug)
3841 get_arg(logfilename, sizeof(logfilename), &p);
3842 } else if (!strcasecmp(cmd, "<Feed")) {
3843 /*********************************************/
3844 /* Feed related options */
3845 char *q;
3846 if (stream || feed) {
3847 fprintf(stderr, "%s:%d: Already in a tag\n",
3848 filename, line_num);
3849 } else {
3850 feed = av_mallocz(sizeof(FFStream));
3851 /* add in stream list */
3852 *last_stream = feed;
3853 last_stream = &feed->next;
3854 /* add in feed list */
3855 *last_feed = feed;
3856 last_feed = &feed->next_feed;
3857
3858 get_arg(feed->filename, sizeof(feed->filename), &p);
3859 q = strrchr(feed->filename, '>');
3860 if (*q)
3861 *q = '\0';
3862 feed->fmt = guess_format("ffm", NULL, NULL);
3863 /* defaut feed file */
3864 snprintf(feed->feed_filename, sizeof(feed->feed_filename),
3865 "/tmp/%s.ffm", feed->filename);
3866 feed->feed_max_size = 5 * 1024 * 1024;
3867 feed->is_feed = 1;
3868 feed->feed = feed; /* self feeding :-) */
3869 }
3870 } else if (!strcasecmp(cmd, "Launch")) {
3871 if (feed) {
3872 int i;
3873
3874 feed->child_argv = av_mallocz(64 * sizeof(char *));
3875
3876 for (i = 0; i < 62; i++) {
3877 get_arg(arg, sizeof(arg), &p);
3878 if (!arg[0])
3879 break;
3880
3881 feed->child_argv[i] = av_strdup(arg);
3882 }
3883
3884 feed->child_argv[i] = av_malloc(30 + strlen(feed->filename));
3885
3886 snprintf(feed->child_argv[i], 30+strlen(feed->filename),
3887 "http://%s:%d/%s",
3888 (my_http_addr.sin_addr.s_addr == INADDR_ANY) ? "127.0.0.1" :
3889 inet_ntoa(my_http_addr.sin_addr),
3890 ntohs(my_http_addr.sin_port), feed->filename);
3891 }
3892 } else if (!strcasecmp(cmd, "ReadOnlyFile")) {
3893 if (feed) {
3894 get_arg(feed->feed_filename, sizeof(feed->feed_filename), &p);
3895 feed->readonly = 1;
3896 } else if (stream) {
3897 get_arg(stream->feed_filename, sizeof(stream->feed_filename), &p);
3898 }
3899 } else if (!strcasecmp(cmd, "File")) {
3900 if (feed) {
3901 get_arg(feed->feed_filename, sizeof(feed->feed_filename), &p);
3902 } else if (stream)
3903 get_arg(stream->feed_filename, sizeof(stream->feed_filename), &p);
3904 } else if (!strcasecmp(cmd, "FileMaxSize")) {
3905 if (feed) {
3906 char *p1;
3907 double fsize;
3908
3909 get_arg(arg, sizeof(arg), &p);
3910 p1 = arg;
3911 fsize = strtod(p1, &p1);
3912 switch(toupper(*p1)) {
3913 case 'K':
3914 fsize *= 1024;
3915 break;
3916 case 'M':
3917 fsize *= 1024 * 1024;
3918 break;
3919 case 'G':
3920 fsize *= 1024 * 1024 * 1024;
3921 break;
3922 }
3923 feed->feed_max_size = (int64_t)fsize;
3924 }
3925 } else if (!strcasecmp(cmd, "</Feed>")) {
3926 if (!feed) {
3927 fprintf(stderr, "%s:%d: No corresponding <Feed> for </Feed>\n",
3928 filename, line_num);
3929 errors++;
3930 }
3931 feed = NULL;
3932 } else if (!strcasecmp(cmd, "<Stream")) {
3933 /*********************************************/
3934 /* Stream related options */
3935 char *q;
3936 if (stream || feed) {
3937 fprintf(stderr, "%s:%d: Already in a tag\n",
3938 filename, line_num);
3939 } else {
3940 const AVClass *class;
3941 stream = av_mallocz(sizeof(FFStream));
3942 *last_stream = stream;
3943 last_stream = &stream->next;
3944
3945 get_arg(stream->filename, sizeof(stream->filename), &p);
3946 q = strrchr(stream->filename, '>');
3947 if (*q)
3948 *q = '\0';
3949 stream->fmt = guess_stream_format(NULL, stream->filename, NULL);
3950 /* fetch avclass so AVOption works
3951 * FIXME try to use avcodec_get_context_defaults2
3952 * without changing defaults too much */
3953 avcodec_get_context_defaults(&video_enc);
3954 class = video_enc.av_class;
3955 memset(&audio_enc, 0, sizeof(AVCodecContext));
3956 memset(&video_enc, 0, sizeof(AVCodecContext));
3957 audio_enc.av_class = class;
3958 video_enc.av_class = class;
3959 audio_id = CODEC_ID_NONE;
3960 video_id = CODEC_ID_NONE;
3961 if (stream->fmt) {
3962 audio_id = stream->fmt->audio_codec;
3963 video_id = stream->fmt->video_codec;
3964 }
3965 }
3966 } else if (!strcasecmp(cmd, "Feed")) {
3967 get_arg(arg, sizeof(arg), &p);
3968 if (stream) {
3969 FFStream *sfeed;
3970
3971 sfeed = first_feed;
3972 while (sfeed != NULL) {
3973 if (!strcmp(sfeed->filename, arg))
3974 break;
3975 sfeed = sfeed->next_feed;
3976 }
3977 if (!sfeed)
3978 fprintf(stderr, "%s:%d: feed '%s' not defined\n",
3979 filename, line_num, arg);
3980 else
3981 stream->feed = sfeed;
3982 }
3983 } else if (!strcasecmp(cmd, "Format")) {
3984 get_arg(arg, sizeof(arg), &p);
3985 if (stream) {
3986 if (!strcmp(arg, "status")) {
3987 stream->stream_type = STREAM_TYPE_STATUS;
3988 stream->fmt = NULL;
3989 } else {
3990 stream->stream_type = STREAM_TYPE_LIVE;
3991 /* jpeg cannot be used here, so use single frame jpeg */
3992 if (!strcmp(arg, "jpeg"))
3993 strcpy(arg, "mjpeg");
3994 stream->fmt = guess_stream_format(arg, NULL, NULL);
3995 if (!stream->fmt) {
3996 fprintf(stderr, "%s:%d: Unknown Format: %s\n",
3997 filename, line_num, arg);
3998 errors++;
3999 }
4000 }
4001 if (stream->fmt) {
4002 audio_id = stream->fmt->audio_codec;
4003 video_id = stream->fmt->video_codec;
4004 }
4005 }
4006 } else if (!strcasecmp(cmd, "InputFormat")) {
4007 get_arg(arg, sizeof(arg), &p);
4008 stream->ifmt = av_find_input_format(arg);
4009 if (!stream->ifmt) {
4010 fprintf(stderr, "%s:%d: Unknown input format: %s\n",
4011 filename, line_num, arg);
4012 }
4013 } else if (!strcasecmp(cmd, "FaviconURL")) {
4014 if (stream && stream->stream_type == STREAM_TYPE_STATUS) {
4015 get_arg(stream->feed_filename, sizeof(stream->feed_filename), &p);
4016 } else {
4017 fprintf(stderr, "%s:%d: FaviconURL only permitted for status streams\n",
4018 filename, line_num);
4019 errors++;
4020 }
4021 } else if (!strcasecmp(cmd, "Author")) {
4022 if (stream)
4023 get_arg(stream->author, sizeof(stream->author), &p);
4024 } else if (!strcasecmp(cmd, "Comment")) {
4025 if (stream)
4026 get_arg(stream->comment, sizeof(stream->comment), &p);
4027 } else if (!strcasecmp(cmd, "Copyright")) {
4028 if (stream)
4029 get_arg(stream->copyright, sizeof(stream->copyright), &p);
4030 } else if (!strcasecmp(cmd, "Title")) {
4031 if (stream)
4032 get_arg(stream->title, sizeof(stream->title), &p);
4033 } else if (!strcasecmp(cmd, "Preroll")) {
4034 get_arg(arg, sizeof(arg), &p);
4035 if (stream)
4036 stream->prebuffer = atof(arg) * 1000;
4037 } else if (!strcasecmp(cmd, "StartSendOnKey")) {
4038 if (stream)
4039 stream->send_on_key = 1;
4040 } else if (!strcasecmp(cmd, "AudioCodec")) {
4041 get_arg(arg, sizeof(arg), &p);
4042 audio_id = opt_audio_codec(arg);
4043 if (audio_id == CODEC_ID_NONE) {
4044 fprintf(stderr, "%s:%d: Unknown AudioCodec: %s\n",
4045 filename, line_num, arg);
4046 errors++;
4047 }
4048 } else if (!strcasecmp(cmd, "VideoCodec")) {
4049 get_arg(arg, sizeof(arg), &p);
4050 video_id = opt_video_codec(arg);
4051 if (video_id == CODEC_ID_NONE) {
4052 fprintf(stderr, "%s:%d: Unknown VideoCodec: %s\n",
4053 filename, line_num, arg);
4054 errors++;
4055 }
4056 } else if (!strcasecmp(cmd, "MaxTime")) {
4057 get_arg(arg, sizeof(arg), &p);
4058 if (stream)
4059 stream->max_time = atof(arg) * 1000;
4060 } else if (!strcasecmp(cmd, "AudioBitRate")) {
4061 get_arg(arg, sizeof(arg), &p);
4062 if (stream)
4063 audio_enc.bit_rate = atoi(arg) * 1000;
4064 } else if (!strcasecmp(cmd, "AudioChannels")) {
4065 get_arg(arg, sizeof(arg), &p);
4066 if (stream)
4067 audio_enc.channels = atoi(arg);
4068 } else if (!strcasecmp(cmd, "AudioSampleRate")) {
4069 get_arg(arg, sizeof(arg), &p);
4070 if (stream)
4071 audio_enc.sample_rate = atoi(arg);
4072 } else if (!strcasecmp(cmd, "AudioQuality")) {
4073 get_arg(arg, sizeof(arg), &p);
4074 if (stream) {
4075 // audio_enc.quality = atof(arg) * 1000;
4076 }
4077 } else if (!strcasecmp(cmd, "VideoBitRateRange")) {
4078 if (stream) {
4079 int minrate, maxrate;
4080
4081 get_arg(arg, sizeof(arg), &p);
4082
4083 if (sscanf(arg, "%d-%d", &minrate, &maxrate) == 2) {
4084 video_enc.rc_min_rate = minrate * 1000;
4085 video_enc.rc_max_rate = maxrate * 1000;
4086 } else {
4087 fprintf(stderr, "%s:%d: Incorrect format for VideoBitRateRange -- should be <min>-<max>: %s\n",
4088 filename, line_num, arg);
4089 errors++;
4090 }
4091 }
4092 } else if (!strcasecmp(cmd, "Debug")) {
4093 if (stream) {
4094 get_arg(arg, sizeof(arg), &p);
4095 video_enc.debug = strtol(arg,0,0);
4096 }
4097 } else if (!strcasecmp(cmd, "Strict")) {
4098 if (stream) {
4099 get_arg(arg, sizeof(arg), &p);
4100 video_enc.strict_std_compliance = atoi(arg);
4101 }
4102 } else if (!strcasecmp(cmd, "VideoBufferSize")) {
4103 if (stream) {
4104 get_arg(arg, sizeof(arg), &p);
4105 video_enc.rc_buffer_size = atoi(arg) * 8*1024;
4106 }
4107 } else if (!strcasecmp(cmd, "VideoBitRateTolerance")) {
4108 if (stream) {
4109 get_arg(arg, sizeof(arg), &p);
4110 video_enc.bit_rate_tolerance = atoi(arg) * 1000;
4111 }
4112 } else if (!strcasecmp(cmd, "VideoBitRate")) {
4113 get_arg(arg, sizeof(arg), &p);
4114 if (stream) {
4115 video_enc.bit_rate = atoi(arg) * 1000;
4116 }
4117 } else if (!strcasecmp(cmd, "VideoSize")) {
4118 get_arg(arg, sizeof(arg), &p);
4119 if (stream) {
4120 av_parse_video_frame_size(&video_enc.width, &video_enc.height, arg);
4121 if ((video_enc.width % 16) != 0 ||
4122 (video_enc.height % 16) != 0) {
4123 fprintf(stderr, "%s:%d: Image size must be a multiple of 16\n",
4124 filename, line_num);
4125 errors++;
4126 }
4127 }
4128 } else if (!strcasecmp(cmd, "VideoFrameRate")) {
4129 get_arg(arg, sizeof(arg), &p);
4130 if (stream) {
4131 AVRational frame_rate;
4132 if (av_parse_video_frame_rate(&frame_rate, arg) < 0) {
4133 fprintf(stderr, "Incorrect frame rate\n");
4134 errors++;
4135 } else {
4136 video_enc.time_base.num = frame_rate.den;
4137 video_enc.time_base.den = frame_rate.num;
4138 }
4139 }
4140 } else if (!strcasecmp(cmd, "VideoGopSize")) {
4141 get_arg(arg, sizeof(arg), &p);
4142 if (stream)
4143 video_enc.gop_size = atoi(arg);
4144 } else if (!strcasecmp(cmd, "VideoIntraOnly")) {
4145 if (stream)
4146 video_enc.gop_size = 1;
4147 } else if (!strcasecmp(cmd, "VideoHighQuality")) {
4148 if (stream)
4149 video_enc.mb_decision = FF_MB_DECISION_BITS;
4150 } else if (!strcasecmp(cmd, "Video4MotionVector")) {
4151 if (stream) {
4152 video_enc.mb_decision = FF_MB_DECISION_BITS; //FIXME remove
4153 video_enc.flags |= CODEC_FLAG_4MV;
4154 }
4155 } else if (!strcasecmp(cmd, "AVOptionVideo") ||
4156 !strcasecmp(cmd, "AVOptionAudio")) {
4157 char arg2[1024];
4158 AVCodecContext *avctx;
4159 int type;
4160 get_arg(arg, sizeof(arg), &p);
4161 get_arg(arg2, sizeof(arg2), &p);
4162 if (!strcasecmp(cmd, "AVOptionVideo")) {
4163 avctx = &video_enc;
4164 type = AV_OPT_FLAG_VIDEO_PARAM;
4165 } else {
4166 avctx = &audio_enc;
4167 type = AV_OPT_FLAG_AUDIO_PARAM;
4168 }
4169 if (opt_default(arg, arg2, avctx, type|AV_OPT_FLAG_ENCODING_PARAM)) {
4170 fprintf(stderr, "AVOption error: %s %s\n", arg, arg2);
4171 errors++;
4172 }
4173 } else if (!strcasecmp(cmd, "VideoTag")) {
4174 get_arg(arg, sizeof(arg), &p);
4175 if ((strlen(arg) == 4) && stream)
4176 video_enc.codec_tag = ff_get_fourcc(arg);
4177 } else if (!strcasecmp(cmd, "BitExact")) {
4178 if (stream)
4179 video_enc.flags |= CODEC_FLAG_BITEXACT;
4180 } else if (!strcasecmp(cmd, "DctFastint")) {
4181 if (stream)
4182 video_enc.dct_algo = FF_DCT_FASTINT;
4183 } else if (!strcasecmp(cmd, "IdctSimple")) {
4184 if (stream)
4185 video_enc.idct_algo = FF_IDCT_SIMPLE;
4186 } else if (!strcasecmp(cmd, "Qscale")) {
4187 get_arg(arg, sizeof(arg), &p);
4188 if (stream) {
4189 video_enc.flags |= CODEC_FLAG_QSCALE;
4190 video_enc.global_quality = FF_QP2LAMBDA * atoi(arg);
4191 }
4192 } else if (!strcasecmp(cmd, "VideoQDiff")) {
4193 get_arg(arg, sizeof(arg), &p);
4194 if (stream) {
4195 video_enc.max_qdiff = atoi(arg);
4196 if (video_enc.max_qdiff < 1 || video_enc.max_qdiff > 31) {
4197 fprintf(stderr, "%s:%d: VideoQDiff out of range\n",
4198 filename, line_num);
4199 errors++;
4200 }
4201 }
4202 } else if (!strcasecmp(cmd, "VideoQMax")) {
4203 get_arg(arg, sizeof(arg), &p);
4204 if (stream) {
4205 video_enc.qmax = atoi(arg);
4206 if (video_enc.qmax < 1 || video_enc.qmax > 31) {
4207 fprintf(stderr, "%s:%d: VideoQMax out of range\n",
4208 filename, line_num);
4209 errors++;
4210 }
4211 }
4212 } else if (!strcasecmp(cmd, "VideoQMin")) {
4213 get_arg(arg, sizeof(arg), &p);
4214 if (stream) {
4215 video_enc.qmin = atoi(arg);
4216 if (video_enc.qmin < 1 || video_enc.qmin > 31) {
4217 fprintf(stderr, "%s:%d: VideoQMin out of range\n",
4218 filename, line_num);
4219 errors++;
4220 }
4221 }
4222 } else if (!strcasecmp(cmd, "LumaElim")) {
4223 get_arg(arg, sizeof(arg), &p);
4224 if (stream)
4225 video_enc.luma_elim_threshold = atoi(arg);
4226 } else if (!strcasecmp(cmd, "ChromaElim")) {
4227 get_arg(arg, sizeof(arg), &p);
4228 if (stream)
4229 video_enc.chroma_elim_threshold = atoi(arg);
4230 } else if (!strcasecmp(cmd, "LumiMask")) {
4231 get_arg(arg, sizeof(arg), &p);
4232 if (stream)
4233 video_enc.lumi_masking = atof(arg);
4234 } else if (!strcasecmp(cmd, "DarkMask")) {
4235 get_arg(arg, sizeof(arg), &p);
4236 if (stream)
4237 video_enc.dark_masking = atof(arg);
4238 } else if (!strcasecmp(cmd, "NoVideo")) {
4239 video_id = CODEC_ID_NONE;
4240 } else if (!strcasecmp(cmd, "NoAudio")) {
4241 audio_id = CODEC_ID_NONE;
4242 } else if (!strcasecmp(cmd, "ACL")) {
4243 IPAddressACL acl;
4244
4245 get_arg(arg, sizeof(arg), &p);
4246 if (strcasecmp(arg, "allow") == 0)
4247 acl.action = IP_ALLOW;
4248 else if (strcasecmp(arg, "deny") == 0)
4249 acl.action = IP_DENY;
4250 else {
4251 fprintf(stderr, "%s:%d: ACL action '%s' is not ALLOW or DENY\n",
4252 filename, line_num, arg);
4253 errors++;
4254 }
4255
4256 get_arg(arg, sizeof(arg), &p);
4257
4258 if (resolve_host(&acl.first, arg) != 0) {
4259 fprintf(stderr, "%s:%d: ACL refers to invalid host or ip address '%s'\n",
4260 filename, line_num, arg);
4261 errors++;
4262 } else
4263 acl.last = acl.first;
4264
4265 get_arg(arg, sizeof(arg), &p);
4266
4267 if (arg[0]) {
4268 if (resolve_host(&acl.last, arg) != 0) {
4269 fprintf(stderr, "%s:%d: ACL refers to invalid host or ip address '%s'\n",
4270 filename, line_num, arg);
4271 errors++;
4272 }
4273 }
4274
4275 if (!errors) {
4276 IPAddressACL *nacl = av_mallocz(sizeof(*nacl));
4277 IPAddressACL **naclp = 0;
4278
4279 acl.next = 0;
4280 *nacl = acl;
4281
4282 if (stream)
4283 naclp = &stream->acl;
4284 else if (feed)
4285 naclp = &feed->acl;
4286 else {
4287 fprintf(stderr, "%s:%d: ACL found not in <stream> or <feed>\n",
4288 filename, line_num);
4289 errors++;
4290 }
4291
4292 if (naclp) {
4293 while (*naclp)
4294 naclp = &(*naclp)->next;
4295
4296 *naclp = nacl;
4297 }
4298 }
4299 } else if (!strcasecmp(cmd, "RTSPOption")) {
4300 get_arg(arg, sizeof(arg), &p);
4301 if (stream) {
4302 av_freep(&stream->rtsp_option);
4303 stream->rtsp_option = av_strdup(arg);
4304 }
4305 } else if (!strcasecmp(cmd, "MulticastAddress")) {
4306 get_arg(arg, sizeof(arg), &p);
4307 if (stream) {
4308 if (resolve_host(&stream->multicast_ip, arg) != 0) {
4309 fprintf(stderr, "%s:%d: Invalid host/IP address: %s\n",
4310 filename, line_num, arg);
4311 errors++;
4312 }
4313 stream->is_multicast = 1;
4314 stream->loop = 1; /* default is looping */
4315 }
4316 } else if (!strcasecmp(cmd, "MulticastPort")) {
4317 get_arg(arg, sizeof(arg), &p);
4318 if (stream)
4319 stream->multicast_port = atoi(arg);
4320 } else if (!strcasecmp(cmd, "MulticastTTL")) {
4321 get_arg(arg, sizeof(arg), &p);
4322 if (stream)
4323 stream->multicast_ttl = atoi(arg);
4324 } else if (!strcasecmp(cmd, "NoLoop")) {
4325 if (stream)
4326 stream->loop = 0;
4327 } else if (!strcasecmp(cmd, "</Stream>")) {
4328 if (!stream) {
4329 fprintf(stderr, "%s:%d: No corresponding <Stream> for </Stream>\n",
4330 filename, line_num);
4331 errors++;
4332 } else {
4333 if (stream->feed && stream->fmt && strcmp(stream->fmt->name, "ffm") != 0) {
4334 if (audio_id != CODEC_ID_NONE) {
4335 audio_enc.codec_type = CODEC_TYPE_AUDIO;
4336 audio_enc.codec_id = audio_id;
4337 add_codec(stream, &audio_enc);
4338 }
4339 if (video_id != CODEC_ID_NONE) {
4340 video_enc.codec_type = CODEC_TYPE_VIDEO;
4341 video_enc.codec_id = video_id;
4342 add_codec(stream, &video_enc);
4343 }
4344 }
4345 stream = NULL;
4346 }
4347 } else if (!strcasecmp(cmd, "<Redirect")) {
4348 /*********************************************/
4349 char *q;
4350 if (stream || feed || redirect) {
4351 fprintf(stderr, "%s:%d: Already in a tag\n",
4352 filename, line_num);
4353 errors++;
4354 } else {
4355 redirect = av_mallocz(sizeof(FFStream));
4356 *last_stream = redirect;
4357 last_stream = &redirect->next;
4358
4359 get_arg(redirect->filename, sizeof(redirect->filename), &p);
4360 q = strrchr(redirect->filename, '>');
4361 if (*q)
4362 *q = '\0';
4363 redirect->stream_type = STREAM_TYPE_REDIRECT;
4364 }
4365 } else if (!strcasecmp(cmd, "URL")) {
4366 if (redirect)
4367 get_arg(redirect->feed_filename, sizeof(redirect->feed_filename), &p);
4368 } else if (!strcasecmp(cmd, "</Redirect>")) {
4369 if (!redirect) {
4370 fprintf(stderr, "%s:%d: No corresponding <Redirect> for </Redirect>\n",
4371 filename, line_num);
4372 errors++;
4373 } else {
4374 if (!redirect->feed_filename[0]) {
4375 fprintf(stderr, "%s:%d: No URL found for <Redirect>\n",
4376 filename, line_num);
4377 errors++;
4378 }
4379 redirect = NULL;
4380 }
4381 } else if (!strcasecmp(cmd, "LoadModule")) {
4382 get_arg(arg, sizeof(arg), &p);
4383 #ifdef HAVE_DLOPEN
4384 load_module(arg);
4385 #else
4386 fprintf(stderr, "%s:%d: Module support not compiled into this version: '%s'\n",
4387 filename, line_num, arg);
4388 errors++;
4389 #endif
4390 } else {
4391 fprintf(stderr, "%s:%d: Incorrect keyword: '%s'\n",
4392 filename, line_num, cmd);
4393 errors++;
4394 }
4395 }
4396
4397 fclose(f);
4398 if (errors)
4399 return -1;
4400 else
4401 return 0;
4402 }
4403
4404 static void handle_child_exit(int sig)
4405 {
4406 pid_t pid;
4407 int status;
4408
4409 while ((pid = waitpid(-1, &status, WNOHANG)) > 0) {
4410 FFStream *feed;
4411
4412 for (feed = first_feed; feed; feed = feed->next) {
4413 if (feed->pid == pid) {
4414 int uptime = time(0) - feed->pid_start;
4415
4416 feed->pid = 0;
4417 fprintf(stderr, "%s: Pid %d exited with status %d after %d seconds\n", feed->filename, pid, status, uptime);
4418
4419 if (uptime < 30)
4420 /* Turn off any more restarts */
4421 feed->child_argv = 0;
4422 }
4423 }
4424 }
4425
4426 need_to_start_children = 1;
4427 }
4428
4429 static void opt_debug()
4430 {
4431 ffserver_debug = 1;
4432 ffserver_daemon = 0;
4433 logfilename[0] = '-';
4434 }
4435
4436 static void opt_show_help(void)
4437 {
4438 printf("usage: ffserver [options]\n"
4439 "Hyper fast multi format Audio/Video streaming server\n");
4440 printf("\n");
4441 show_help_options(options, "Main options:\n", 0, 0);
4442 }
4443
4444 static const OptionDef options[] = {
4445 { "h", OPT_EXIT, {(void*)opt_show_help}, "show help" },
4446 { "version", OPT_EXIT, {(void*)show_version}, "show version" },
4447 { "L", OPT_EXIT, {(void*)show_license}, "show license" },
4448 { "formats", OPT_EXIT, {(void*)show_formats}, "show available formats, codecs, protocols, ..." },
4449 { "n", OPT_BOOL, {(void *)&no_launch }, "enable no-launch mode" },
4450 { "d", 0, {(void*)opt_debug}, "enable debug mode" },
4451 { "f", HAS_ARG | OPT_STRING, {(void*)&config_filename }, "use configfile instead of /etc/ffserver.conf", "configfile" },
4452 { NULL },
4453 };
4454
4455 int main(int argc, char **argv)
4456 {
4457 struct sigaction sigact;
4458
4459 av_register_all();
4460
4461 show_banner();
4462
4463 config_filename = "/etc/ffserver.conf";
4464
4465 my_program_name = argv[0];
4466 my_program_dir = getcwd(0, 0);
4467 ffserver_daemon = 1;
4468
4469 parse_options(argc, argv, options, NULL);
4470
4471 unsetenv("http_proxy"); /* Kill the http_proxy */
4472
4473 av_init_random(av_gettime() + (getpid() << 16), &random_state);
4474
4475 memset(&sigact, 0, sizeof(sigact));
4476 sigact.sa_handler = handle_child_exit;
4477 sigact.sa_flags = SA_NOCLDSTOP | SA_RESTART;
4478 sigaction(SIGCHLD, &sigact, 0);
4479
4480 if (parse_ffconfig(config_filename) < 0) {
4481 fprintf(stderr, "Incorrect config file - exiting.\n");
4482 exit(1);
4483 }
4484
4485 /* open log file if needed */
4486 if (logfilename[0] != '\0') {
4487 if (!strcmp(logfilename, "-"))
4488 logfile = stdout;
4489 else
4490 logfile = fopen(logfilename, "a");
4491 av_log_set_callback(http_av_log);
4492 }
4493
4494 build_file_streams();
4495
4496 build_feed_streams();
4497
4498 compute_bandwidth();
4499
4500 /* put the process in background and detach it from its TTY */
4501 if (ffserver_daemon) {
4502 int pid;
4503
4504 pid = fork();
4505 if (pid < 0) {
4506 perror("fork");
4507 exit(1);
4508 } else if (pid > 0) {
4509 /* parent : exit */
4510 exit(0);
4511 } else {
4512 /* child */
4513 setsid();
4514 close(0);
4515 open("/dev/null", O_RDWR);
4516 if (strcmp(logfilename, "-") != 0) {
4517 close(1);
4518 dup(0);
4519 }
4520 close(2);
4521 dup(0);
4522 }
4523 }
4524
4525 /* signal init */
4526 signal(SIGPIPE, SIG_IGN);
4527
4528 if (ffserver_daemon)
4529 chdir("/");
4530
4531 if (http_server() < 0) {
4532 http_log("Could not start server\n");
4533 exit(1);
4534 }
4535
4536 return 0;
4537 }
lucabe's unfinished and experimental patches for ffmpeg