2 * Copyright (c) 2000, 2001, 2002 Fabrice Bellard
4 * This file is part of FFmpeg.
6 * FFmpeg is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation; either
9 * version 2.1 of the License, or (at your option) any later version.
11 * FFmpeg is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
16 * You should have received a copy of the GNU Lesser General Public
17 * License along with FFmpeg; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
23 * multiple format streaming server based on the FFmpeg libraries
28 #define closesocket close
32 #include "libavformat/avformat.h"
33 // FIXME those are internal headers, ffserver _really_ shouldn't use them
34 #include "libavformat/ffm.h"
35 #include "libavformat/network.h"
36 #include "libavformat/os_support.h"
37 #include "libavformat/rtpdec.h"
38 #include "libavformat/rtsp.h"
39 #include "libavformat/avio_internal.h"
40 #include "libavformat/internal.h"
41 #include "libavformat/url.h"
43 #include "libavutil/avassert.h"
44 #include "libavutil/avstring.h"
45 #include "libavutil/lfg.h"
46 #include "libavutil/dict.h"
47 #include "libavutil/mathematics.h"
48 #include "libavutil/random_seed.h"
49 #include "libavutil/parseutils.h"
50 #include "libavutil/opt.h"
54 #include <sys/ioctl.h>
68 const char program_name[] = "ffserver";
69 const int program_birth_year = 2000;
71 static const OptionDef options[];
74 HTTPSTATE_WAIT_REQUEST,
75 HTTPSTATE_SEND_HEADER,
76 HTTPSTATE_SEND_DATA_HEADER,
77 HTTPSTATE_SEND_DATA, /* sending TCP or UDP data */
78 HTTPSTATE_SEND_DATA_TRAILER,
79 HTTPSTATE_RECEIVE_DATA,
80 HTTPSTATE_WAIT_FEED, /* wait for data from the feed */
83 RTSPSTATE_WAIT_REQUEST,
85 RTSPSTATE_SEND_PACKET,
88 static const char *http_state[] = {
104 #define MAX_STREAMS 20
106 #define IOBUFFER_INIT_SIZE 8192
108 /* timeouts are in ms */
109 #define HTTP_REQUEST_TIMEOUT (15 * 1000)
110 #define RTSP_REQUEST_TIMEOUT (3600 * 24 * 1000)
112 #define SYNC_TIMEOUT (10 * 1000)
114 typedef struct RTSPActionServerSetup {
116 char transport_option[512];
117 } RTSPActionServerSetup;
120 int64_t count1, count2;
121 int64_t time1, time2;
124 /* context associated with one connection */
125 typedef struct HTTPContext {
126 enum HTTPState state;
127 int fd; /* socket file descriptor */
128 struct sockaddr_in from_addr; /* origin */
129 struct pollfd *poll_entry; /* used when polling */
131 uint8_t *buffer_ptr, *buffer_end;
134 int chunked_encoding;
135 int chunk_size; /* 0 if it needs to be read */
136 struct HTTPContext *next;
137 int got_key_frame; /* stream 0 => 1, stream 1 => 2, stream 2=> 4 */
141 /* input format handling */
142 AVFormatContext *fmt_in;
143 int64_t start_time; /* In milliseconds - this wraps fairly often */
144 int64_t first_pts; /* initial pts value */
145 int64_t cur_pts; /* current pts value from the stream in us */
146 int64_t cur_frame_duration; /* duration of the current frame in us */
147 int cur_frame_bytes; /* output frame size, needed to compute
148 the time at which we send each
150 int pts_stream_index; /* stream we choose as clock reference */
151 int64_t cur_clock; /* current clock reference value in us */
152 /* output format handling */
153 struct FFStream *stream;
154 /* -1 is invalid stream */
155 int feed_streams[MAX_STREAMS]; /* index of streams in the feed */
156 int switch_feed_streams[MAX_STREAMS]; /* index of streams in the feed */
158 AVFormatContext fmt_ctx; /* instance of FFStream for one user */
159 int last_packet_sent; /* true if last data packet was sent */
161 DataRateData datarate;
168 int is_packetized; /* if true, the stream is packetized */
169 int packet_stream_index; /* current stream for output in state machine */
171 /* RTSP state specific */
172 uint8_t *pb_buffer; /* XXX: use that in all the code */
174 int seq; /* RTSP sequence number */
176 /* RTP state specific */
177 enum RTSPLowerTransport rtp_protocol;
178 char session_id[32]; /* session id */
179 AVFormatContext *rtp_ctx[MAX_STREAMS];
181 /* RTP/UDP specific */
182 URLContext *rtp_handles[MAX_STREAMS];
184 /* RTP/TCP specific */
185 struct HTTPContext *rtsp_c;
186 uint8_t *packet_buffer, *packet_buffer_ptr, *packet_buffer_end;
189 /* each generated stream is described here */
193 STREAM_TYPE_REDIRECT,
196 enum IPAddressAction {
201 typedef struct IPAddressACL {
202 struct IPAddressACL *next;
203 enum IPAddressAction action;
204 /* These are in host order */
205 struct in_addr first;
209 /* description of each stream of the ffserver.conf file */
210 typedef struct FFStream {
211 enum StreamType stream_type;
212 char filename[1024]; /* stream filename */
213 struct FFStream *feed; /* feed we are using (can be null if
215 AVDictionary *in_opts; /* input parameters */
216 AVInputFormat *ifmt; /* if non NULL, force input format */
219 char dynamic_acl[1024];
221 int prebuffer; /* Number of millseconds early to start */
222 int64_t max_time; /* Number of milliseconds to run */
224 AVStream *streams[MAX_STREAMS];
225 int feed_streams[MAX_STREAMS]; /* index of streams in the feed */
226 char feed_filename[1024]; /* file name of the feed storage, or
227 input file name for a stream */
232 pid_t pid; /* Of ffmpeg process */
233 time_t pid_start; /* Of ffmpeg process */
235 struct FFStream *next;
236 unsigned bandwidth; /* bandwidth, in kbits/s */
239 /* multicast specific */
241 struct in_addr multicast_ip;
242 int multicast_port; /* first port used for multicast */
244 int loop; /* if true, send the stream in loops (only meaningful if file) */
247 int feed_opened; /* true if someone is writing to the feed */
248 int is_feed; /* true if it is a feed */
249 int readonly; /* True if writing is prohibited to the file */
250 int truncate; /* True if feeder connection truncate the feed file */
252 int64_t bytes_served;
253 int64_t feed_max_size; /* maximum storage size, zero means unlimited */
254 int64_t feed_write_index; /* current write position in feed (it wraps around) */
255 int64_t feed_size; /* current size of feed */
256 struct FFStream *next_feed;
259 typedef struct FeedData {
260 long long data_count;
261 float avg_frame_size; /* frame size averaged over last frames with exponential mean */
264 static struct sockaddr_in my_http_addr;
265 static struct sockaddr_in my_rtsp_addr;
267 static char logfilename[1024];
268 static HTTPContext *first_http_ctx;
269 static FFStream *first_feed; /* contains only feeds */
270 static FFStream *first_stream; /* contains all streams, including feeds */
272 static void new_connection(int server_fd, int is_rtsp);
273 static void close_connection(HTTPContext *c);
276 static int handle_connection(HTTPContext *c);
277 static int http_parse_request(HTTPContext *c);
278 static int http_send_data(HTTPContext *c);
279 static void compute_status(HTTPContext *c);
280 static int open_input_stream(HTTPContext *c, const char *info);
281 static int http_start_receive_data(HTTPContext *c);
282 static int http_receive_data(HTTPContext *c);
285 static int rtsp_parse_request(HTTPContext *c);
286 static void rtsp_cmd_describe(HTTPContext *c, const char *url);
287 static void rtsp_cmd_options(HTTPContext *c, const char *url);
288 static void rtsp_cmd_setup(HTTPContext *c, const char *url, RTSPMessageHeader *h);
289 static void rtsp_cmd_play(HTTPContext *c, const char *url, RTSPMessageHeader *h);
290 static void rtsp_cmd_pause(HTTPContext *c, const char *url, RTSPMessageHeader *h);
291 static void rtsp_cmd_teardown(HTTPContext *c, const char *url, RTSPMessageHeader *h);
294 static int prepare_sdp_description(FFStream *stream, uint8_t **pbuffer,
295 struct in_addr my_ip);
298 static HTTPContext *rtp_new_connection(struct sockaddr_in *from_addr,
299 FFStream *stream, const char *session_id,
300 enum RTSPLowerTransport rtp_protocol);
301 static int rtp_new_av_stream(HTTPContext *c,
302 int stream_index, struct sockaddr_in *dest_addr,
303 HTTPContext *rtsp_c);
305 static const char *my_program_name;
306 static const char *my_program_dir;
308 static const char *config_filename = "/etc/ffserver.conf";
310 static int ffserver_debug;
311 static int ffserver_daemon;
312 static int no_launch;
313 static int need_to_start_children;
315 /* maximum number of simultaneous HTTP connections */
316 static unsigned int nb_max_http_connections = 2000;
317 static unsigned int nb_max_connections = 5;
318 static unsigned int nb_connections;
320 static uint64_t max_bandwidth = 1000;
321 static uint64_t current_bandwidth;
323 static int64_t cur_time; // Making this global saves on passing it around everywhere
325 static AVLFG random_state;
327 static FILE *logfile = NULL;
329 /* FIXME: make ffserver work with IPv6 */
330 void av_noreturn exit_program(int ret)
335 /* resolve host with also IP address parsing */
336 static int resolve_host(struct in_addr *sin_addr, const char *hostname)
339 if (!ff_inet_aton(hostname, sin_addr)) {
341 struct addrinfo *ai, *cur;
342 struct addrinfo hints = { 0 };
343 hints.ai_family = AF_INET;
344 if (getaddrinfo(hostname, NULL, &hints, &ai))
346 /* getaddrinfo returns a linked list of addrinfo structs.
347 * Even if we set ai_family = AF_INET above, make sure
348 * that the returned one actually is of the correct type. */
349 for (cur = ai; cur; cur = cur->ai_next) {
350 if (cur->ai_family == AF_INET) {
351 *sin_addr = ((struct sockaddr_in *)cur->ai_addr)->sin_addr;
360 hp = gethostbyname(hostname);
363 memcpy(sin_addr, hp->h_addr_list[0], sizeof(struct in_addr));
369 static char *ctime1(char *buf2)
377 p = buf2 + strlen(p) - 1;
383 static void http_vlog(const char *fmt, va_list vargs)
385 static int print_prefix = 1;
390 fprintf(logfile, "%s ", buf);
392 print_prefix = strstr(fmt, "\n") != NULL;
393 vfprintf(logfile, fmt, vargs);
399 __attribute__ ((format (printf, 1, 2)))
401 static void http_log(const char *fmt, ...)
404 va_start(vargs, fmt);
405 http_vlog(fmt, vargs);
409 static void http_av_log(void *ptr, int level, const char *fmt, va_list vargs)
411 static int print_prefix = 1;
412 AVClass *avc = ptr ? *(AVClass**)ptr : NULL;
413 if (level > av_log_get_level())
415 if (print_prefix && avc)
416 http_log("[%s @ %p]", avc->item_name(ptr), ptr);
417 print_prefix = strstr(fmt, "\n") != NULL;
418 http_vlog(fmt, vargs);
421 static void log_connection(HTTPContext *c)
426 http_log("%s - - [%s] \"%s %s\" %d %"PRId64"\n",
427 inet_ntoa(c->from_addr.sin_addr), c->method, c->url,
428 c->protocol, (c->http_error ? c->http_error : 200), c->data_count);
431 static void update_datarate(DataRateData *drd, int64_t count)
433 if (!drd->time1 && !drd->count1) {
434 drd->time1 = drd->time2 = cur_time;
435 drd->count1 = drd->count2 = count;
436 } else if (cur_time - drd->time2 > 5000) {
437 drd->time1 = drd->time2;
438 drd->count1 = drd->count2;
439 drd->time2 = cur_time;
444 /* In bytes per second */
445 static int compute_datarate(DataRateData *drd, int64_t count)
447 if (cur_time == drd->time1)
450 return ((count - drd->count1) * 1000) / (cur_time - drd->time1);
454 static void start_children(FFStream *feed)
459 for (; feed; feed = feed->next) {
460 if (feed->child_argv && !feed->pid) {
461 feed->pid_start = time(0);
466 http_log("Unable to create children\n");
475 av_strlcpy(pathname, my_program_name, sizeof(pathname));
477 slash = strrchr(pathname, '/');
482 strcpy(slash, "ffmpeg");
484 http_log("Launch command line: ");
485 http_log("%s ", pathname);
486 for (i = 1; feed->child_argv[i] && feed->child_argv[i][0]; i++)
487 http_log("%s ", feed->child_argv[i]);
490 for (i = 3; i < 256; i++)
493 if (!ffserver_debug) {
494 i = open("/dev/null", O_RDWR);
503 /* This is needed to make relative pathnames work */
504 if (chdir(my_program_dir) < 0) {
505 http_log("chdir failed\n");
509 signal(SIGPIPE, SIG_DFL);
511 execvp(pathname, feed->child_argv);
519 /* open a listening socket */
520 static int socket_open_listen(struct sockaddr_in *my_addr)
524 server_fd = socket(AF_INET,SOCK_STREAM,0);
531 setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR, &tmp, sizeof(tmp));
533 my_addr->sin_family = AF_INET;
534 if (bind (server_fd, (struct sockaddr *) my_addr, sizeof (*my_addr)) < 0) {
536 snprintf(bindmsg, sizeof(bindmsg), "bind(port %d)", ntohs(my_addr->sin_port));
538 closesocket(server_fd);
542 if (listen (server_fd, 5) < 0) {
544 closesocket(server_fd);
547 ff_socket_nonblock(server_fd, 1);
552 /* start all multicast streams */
553 static void start_multicast(void)
558 struct sockaddr_in dest_addr;
559 int default_port, stream_index;
562 for(stream = first_stream; stream != NULL; stream = stream->next) {
563 if (stream->is_multicast) {
564 unsigned random0 = av_lfg_get(&random_state);
565 unsigned random1 = av_lfg_get(&random_state);
566 /* open the RTP connection */
567 snprintf(session_id, sizeof(session_id), "%08x%08x",
570 /* choose a port if none given */
571 if (stream->multicast_port == 0) {
572 stream->multicast_port = default_port;
576 dest_addr.sin_family = AF_INET;
577 dest_addr.sin_addr = stream->multicast_ip;
578 dest_addr.sin_port = htons(stream->multicast_port);
580 rtp_c = rtp_new_connection(&dest_addr, stream, session_id,
581 RTSP_LOWER_TRANSPORT_UDP_MULTICAST);
585 if (open_input_stream(rtp_c, "") < 0) {
586 http_log("Could not open input stream for stream '%s'\n",
591 /* open each RTP stream */
592 for(stream_index = 0; stream_index < stream->nb_streams;
594 dest_addr.sin_port = htons(stream->multicast_port +
596 if (rtp_new_av_stream(rtp_c, stream_index, &dest_addr, NULL) < 0) {
597 http_log("Could not open output stream '%s/streamid=%d'\n",
598 stream->filename, stream_index);
603 /* change state to send data */
604 rtp_c->state = HTTPSTATE_SEND_DATA;
609 /* main loop of the http server */
610 static int http_server(void)
612 int server_fd = 0, rtsp_server_fd = 0;
613 int ret, delay, delay1;
614 struct pollfd *poll_table, *poll_entry;
615 HTTPContext *c, *c_next;
617 if(!(poll_table = av_mallocz((nb_max_http_connections + 2)*sizeof(*poll_table)))) {
618 http_log("Impossible to allocate a poll table handling %d connections.\n", nb_max_http_connections);
622 if (my_http_addr.sin_port) {
623 server_fd = socket_open_listen(&my_http_addr);
628 if (my_rtsp_addr.sin_port) {
629 rtsp_server_fd = socket_open_listen(&my_rtsp_addr);
630 if (rtsp_server_fd < 0)
634 if (!rtsp_server_fd && !server_fd) {
635 http_log("HTTP and RTSP disabled.\n");
639 http_log("FFserver started.\n");
641 start_children(first_feed);
646 poll_entry = poll_table;
648 poll_entry->fd = server_fd;
649 poll_entry->events = POLLIN;
652 if (rtsp_server_fd) {
653 poll_entry->fd = rtsp_server_fd;
654 poll_entry->events = POLLIN;
658 /* wait for events on each HTTP handle */
665 case HTTPSTATE_SEND_HEADER:
666 case RTSPSTATE_SEND_REPLY:
667 case RTSPSTATE_SEND_PACKET:
668 c->poll_entry = poll_entry;
670 poll_entry->events = POLLOUT;
673 case HTTPSTATE_SEND_DATA_HEADER:
674 case HTTPSTATE_SEND_DATA:
675 case HTTPSTATE_SEND_DATA_TRAILER:
676 if (!c->is_packetized) {
677 /* for TCP, we output as much as we can (may need to put a limit) */
678 c->poll_entry = poll_entry;
680 poll_entry->events = POLLOUT;
683 /* when ffserver is doing the timing, we work by
684 looking at which packet need to be sent every
686 delay1 = 10; /* one tick wait XXX: 10 ms assumed */
691 case HTTPSTATE_WAIT_REQUEST:
692 case HTTPSTATE_RECEIVE_DATA:
693 case HTTPSTATE_WAIT_FEED:
694 case RTSPSTATE_WAIT_REQUEST:
695 /* need to catch errors */
696 c->poll_entry = poll_entry;
698 poll_entry->events = POLLIN;/* Maybe this will work */
702 c->poll_entry = NULL;
708 /* wait for an event on one connection. We poll at least every
709 second to handle timeouts */
711 ret = poll(poll_table, poll_entry - poll_table, delay);
712 if (ret < 0 && ff_neterrno() != AVERROR(EAGAIN) &&
713 ff_neterrno() != AVERROR(EINTR))
717 cur_time = av_gettime() / 1000;
719 if (need_to_start_children) {
720 need_to_start_children = 0;
721 start_children(first_feed);
724 /* now handle the events */
725 for(c = first_http_ctx; c != NULL; c = c_next) {
727 if (handle_connection(c) < 0) {
728 /* close and free the connection */
734 poll_entry = poll_table;
736 /* new HTTP connection request ? */
737 if (poll_entry->revents & POLLIN)
738 new_connection(server_fd, 0);
741 if (rtsp_server_fd) {
742 /* new RTSP connection request ? */
743 if (poll_entry->revents & POLLIN)
744 new_connection(rtsp_server_fd, 1);
749 /* start waiting for a new HTTP/RTSP request */
750 static void start_wait_request(HTTPContext *c, int is_rtsp)
752 c->buffer_ptr = c->buffer;
753 c->buffer_end = c->buffer + c->buffer_size - 1; /* leave room for '\0' */
756 c->timeout = cur_time + RTSP_REQUEST_TIMEOUT;
757 c->state = RTSPSTATE_WAIT_REQUEST;
759 c->timeout = cur_time + HTTP_REQUEST_TIMEOUT;
760 c->state = HTTPSTATE_WAIT_REQUEST;
764 static void http_send_too_busy_reply(int fd)
767 int len = snprintf(buffer, sizeof(buffer),
768 "HTTP/1.0 503 Server too busy\r\n"
769 "Content-type: text/html\r\n"
771 "<html><head><title>Too busy</title></head><body>\r\n"
772 "<p>The server is too busy to serve your request at this time.</p>\r\n"
773 "<p>The number of current connections is %d, and this exceeds the limit of %d.</p>\r\n"
774 "</body></html>\r\n",
775 nb_connections, nb_max_connections);
776 av_assert0(len < sizeof(buffer));
777 send(fd, buffer, len, 0);
781 static void new_connection(int server_fd, int is_rtsp)
783 struct sockaddr_in from_addr;
785 HTTPContext *c = NULL;
787 len = sizeof(from_addr);
788 fd = accept(server_fd, (struct sockaddr *)&from_addr,
791 http_log("error during accept %s\n", strerror(errno));
794 ff_socket_nonblock(fd, 1);
796 if (nb_connections >= nb_max_connections) {
797 http_send_too_busy_reply(fd);
801 /* add a new connection */
802 c = av_mallocz(sizeof(HTTPContext));
807 c->poll_entry = NULL;
808 c->from_addr = from_addr;
809 c->buffer_size = IOBUFFER_INIT_SIZE;
810 c->buffer = av_malloc(c->buffer_size);
814 c->next = first_http_ctx;
818 start_wait_request(c, is_rtsp);
830 static void close_connection(HTTPContext *c)
832 HTTPContext **cp, *c1;
834 AVFormatContext *ctx;
838 /* remove connection from list */
839 cp = &first_http_ctx;
840 while ((*cp) != NULL) {
848 /* remove references, if any (XXX: do it faster) */
849 for(c1 = first_http_ctx; c1 != NULL; c1 = c1->next) {
854 /* remove connection associated resources */
858 /* close each frame parser */
859 for(i=0;i<c->fmt_in->nb_streams;i++) {
860 st = c->fmt_in->streams[i];
861 if (st->codec->codec)
862 avcodec_close(st->codec);
864 avformat_close_input(&c->fmt_in);
867 /* free RTP output streams if any */
870 nb_streams = c->stream->nb_streams;
872 for(i=0;i<nb_streams;i++) {
875 av_write_trailer(ctx);
876 av_dict_free(&ctx->metadata);
877 av_free(ctx->streams[0]);
880 h = c->rtp_handles[i];
887 if (!c->last_packet_sent && c->state == HTTPSTATE_SEND_DATA_TRAILER) {
890 if (avio_open_dyn_buf(&ctx->pb) >= 0) {
891 av_write_trailer(ctx);
892 av_freep(&c->pb_buffer);
893 avio_close_dyn_buf(ctx->pb, &c->pb_buffer);
898 for(i=0; i<ctx->nb_streams; i++)
899 av_free(ctx->streams[i]);
901 if (c->stream && !c->post && c->stream->stream_type == STREAM_TYPE_LIVE)
902 current_bandwidth -= c->stream->bandwidth;
904 /* signal that there is no feed if we are the feeder socket */
905 if (c->state == HTTPSTATE_RECEIVE_DATA && c->stream) {
906 c->stream->feed_opened = 0;
910 av_freep(&c->pb_buffer);
911 av_freep(&c->packet_buffer);
917 static int handle_connection(HTTPContext *c)
922 case HTTPSTATE_WAIT_REQUEST:
923 case RTSPSTATE_WAIT_REQUEST:
925 if ((c->timeout - cur_time) < 0)
927 if (c->poll_entry->revents & (POLLERR | POLLHUP))
930 /* no need to read if no events */
931 if (!(c->poll_entry->revents & POLLIN))
935 len = recv(c->fd, c->buffer_ptr, 1, 0);
937 if (ff_neterrno() != AVERROR(EAGAIN) &&
938 ff_neterrno() != AVERROR(EINTR))
940 } else if (len == 0) {
943 /* search for end of request. */
945 c->buffer_ptr += len;
947 if ((ptr >= c->buffer + 2 && !memcmp(ptr-2, "\n\n", 2)) ||
948 (ptr >= c->buffer + 4 && !memcmp(ptr-4, "\r\n\r\n", 4))) {
949 /* request found : parse it and reply */
950 if (c->state == HTTPSTATE_WAIT_REQUEST) {
951 ret = http_parse_request(c);
953 ret = rtsp_parse_request(c);
957 } else if (ptr >= c->buffer_end) {
958 /* request too long: cannot do anything */
960 } else goto read_loop;
964 case HTTPSTATE_SEND_HEADER:
965 if (c->poll_entry->revents & (POLLERR | POLLHUP))
968 /* no need to write if no events */
969 if (!(c->poll_entry->revents & POLLOUT))
971 len = send(c->fd, c->buffer_ptr, c->buffer_end - c->buffer_ptr, 0);
973 if (ff_neterrno() != AVERROR(EAGAIN) &&
974 ff_neterrno() != AVERROR(EINTR)) {
975 /* error : close connection */
976 av_freep(&c->pb_buffer);
980 c->buffer_ptr += len;
982 c->stream->bytes_served += len;
983 c->data_count += len;
984 if (c->buffer_ptr >= c->buffer_end) {
985 av_freep(&c->pb_buffer);
989 /* all the buffer was sent : synchronize to the incoming stream */
990 c->state = HTTPSTATE_SEND_DATA_HEADER;
991 c->buffer_ptr = c->buffer_end = c->buffer;
996 case HTTPSTATE_SEND_DATA:
997 case HTTPSTATE_SEND_DATA_HEADER:
998 case HTTPSTATE_SEND_DATA_TRAILER:
999 /* for packetized output, we consider we can always write (the
1000 input streams sets the speed). It may be better to verify
1001 that we do not rely too much on the kernel queues */
1002 if (!c->is_packetized) {
1003 if (c->poll_entry->revents & (POLLERR | POLLHUP))
1006 /* no need to read if no events */
1007 if (!(c->poll_entry->revents & POLLOUT))
1010 if (http_send_data(c) < 0)
1012 /* close connection if trailer sent */
1013 if (c->state == HTTPSTATE_SEND_DATA_TRAILER)
1016 case HTTPSTATE_RECEIVE_DATA:
1017 /* no need to read if no events */
1018 if (c->poll_entry->revents & (POLLERR | POLLHUP))
1020 if (!(c->poll_entry->revents & POLLIN))
1022 if (http_receive_data(c) < 0)
1025 case HTTPSTATE_WAIT_FEED:
1026 /* no need to read if no events */
1027 if (c->poll_entry->revents & (POLLIN | POLLERR | POLLHUP))
1030 /* nothing to do, we'll be waken up by incoming feed packets */
1033 case RTSPSTATE_SEND_REPLY:
1034 if (c->poll_entry->revents & (POLLERR | POLLHUP)) {
1035 av_freep(&c->pb_buffer);
1038 /* no need to write if no events */
1039 if (!(c->poll_entry->revents & POLLOUT))
1041 len = send(c->fd, c->buffer_ptr, c->buffer_end - c->buffer_ptr, 0);
1043 if (ff_neterrno() != AVERROR(EAGAIN) &&
1044 ff_neterrno() != AVERROR(EINTR)) {
1045 /* error : close connection */
1046 av_freep(&c->pb_buffer);
1050 c->buffer_ptr += len;
1051 c->data_count += len;
1052 if (c->buffer_ptr >= c->buffer_end) {
1053 /* all the buffer was sent : wait for a new request */
1054 av_freep(&c->pb_buffer);
1055 start_wait_request(c, 1);
1059 case RTSPSTATE_SEND_PACKET:
1060 if (c->poll_entry->revents & (POLLERR | POLLHUP)) {
1061 av_freep(&c->packet_buffer);
1064 /* no need to write if no events */
1065 if (!(c->poll_entry->revents & POLLOUT))
1067 len = send(c->fd, c->packet_buffer_ptr,
1068 c->packet_buffer_end - c->packet_buffer_ptr, 0);
1070 if (ff_neterrno() != AVERROR(EAGAIN) &&
1071 ff_neterrno() != AVERROR(EINTR)) {
1072 /* error : close connection */
1073 av_freep(&c->packet_buffer);
1077 c->packet_buffer_ptr += len;
1078 if (c->packet_buffer_ptr >= c->packet_buffer_end) {
1079 /* all the buffer was sent : wait for a new request */
1080 av_freep(&c->packet_buffer);
1081 c->state = RTSPSTATE_WAIT_REQUEST;
1085 case HTTPSTATE_READY:
1094 static int extract_rates(char *rates, int ratelen, const char *request)
1098 for (p = request; *p && *p != '\r' && *p != '\n'; ) {
1099 if (av_strncasecmp(p, "Pragma:", 7) == 0) {
1100 const char *q = p + 7;
1102 while (*q && *q != '\n' && isspace(*q))
1105 if (av_strncasecmp(q, "stream-switch-entry=", 20) == 0) {
1111 memset(rates, 0xff, ratelen);
1114 while (*q && *q != '\n' && *q != ':')
1117 if (sscanf(q, ":%d:%d", &stream_no, &rate_no) != 2)
1121 if (stream_no < ratelen && stream_no >= 0)
1122 rates[stream_no] = rate_no;
1124 while (*q && *q != '\n' && !isspace(*q))
1131 p = strchr(p, '\n');
1141 static int find_stream_in_feed(FFStream *feed, AVCodecContext *codec, int bit_rate)
1144 int best_bitrate = 100000000;
1147 for (i = 0; i < feed->nb_streams; i++) {
1148 AVCodecContext *feed_codec = feed->streams[i]->codec;
1150 if (feed_codec->codec_id != codec->codec_id ||
1151 feed_codec->sample_rate != codec->sample_rate ||
1152 feed_codec->width != codec->width ||
1153 feed_codec->height != codec->height)
1156 /* Potential stream */
1158 /* We want the fastest stream less than bit_rate, or the slowest
1159 * faster than bit_rate
1162 if (feed_codec->bit_rate <= bit_rate) {
1163 if (best_bitrate > bit_rate || feed_codec->bit_rate > best_bitrate) {
1164 best_bitrate = feed_codec->bit_rate;
1168 if (feed_codec->bit_rate < best_bitrate) {
1169 best_bitrate = feed_codec->bit_rate;
1178 static int modify_current_stream(HTTPContext *c, char *rates)
1181 FFStream *req = c->stream;
1182 int action_required = 0;
1184 /* Not much we can do for a feed */
1188 for (i = 0; i < req->nb_streams; i++) {
1189 AVCodecContext *codec = req->streams[i]->codec;
1193 c->switch_feed_streams[i] = req->feed_streams[i];
1196 c->switch_feed_streams[i] = find_stream_in_feed(req->feed, codec, codec->bit_rate / 2);
1199 /* Wants off or slow */
1200 c->switch_feed_streams[i] = find_stream_in_feed(req->feed, codec, codec->bit_rate / 4);
1202 /* This doesn't work well when it turns off the only stream! */
1203 c->switch_feed_streams[i] = -2;
1204 c->feed_streams[i] = -2;
1209 if (c->switch_feed_streams[i] >= 0 && c->switch_feed_streams[i] != c->feed_streams[i])
1210 action_required = 1;
1213 return action_required;
1216 /* XXX: factorize in utils.c ? */
1217 /* XXX: take care with different space meaning */
1218 static void skip_spaces(const char **pp)
1222 while (*p == ' ' || *p == '\t')
1227 static void get_word(char *buf, int buf_size, const char **pp)
1235 while (!isspace(*p) && *p != '\0') {
1236 if ((q - buf) < buf_size - 1)
1245 static void get_arg(char *buf, int buf_size, const char **pp)
1252 while (isspace(*p)) p++;
1255 if (*p == '\"' || *p == '\'')
1267 if ((q - buf) < buf_size - 1)
1272 if (quote && *p == quote)
1277 static void parse_acl_row(FFStream *stream, FFStream* feed, IPAddressACL *ext_acl,
1278 const char *p, const char *filename, int line_num)
1284 get_arg(arg, sizeof(arg), &p);
1285 if (av_strcasecmp(arg, "allow") == 0)
1286 acl.action = IP_ALLOW;
1287 else if (av_strcasecmp(arg, "deny") == 0)
1288 acl.action = IP_DENY;
1290 fprintf(stderr, "%s:%d: ACL action '%s' is not ALLOW or DENY\n",
1291 filename, line_num, arg);
1295 get_arg(arg, sizeof(arg), &p);
1297 if (resolve_host(&acl.first, arg) != 0) {
1298 fprintf(stderr, "%s:%d: ACL refers to invalid host or ip address '%s'\n",
1299 filename, line_num, arg);
1302 acl.last = acl.first;
1304 get_arg(arg, sizeof(arg), &p);
1307 if (resolve_host(&acl.last, arg) != 0) {
1308 fprintf(stderr, "%s:%d: ACL refers to invalid host or ip address '%s'\n",
1309 filename, line_num, arg);
1315 IPAddressACL *nacl = av_mallocz(sizeof(*nacl));
1316 IPAddressACL **naclp = 0;
1322 naclp = &stream->acl;
1328 fprintf(stderr, "%s:%d: ACL found not in <stream> or <feed>\n",
1329 filename, line_num);
1335 naclp = &(*naclp)->next;
1343 static IPAddressACL* parse_dynamic_acl(FFStream *stream, HTTPContext *c)
1348 IPAddressACL *acl = NULL;
1352 f = fopen(stream->dynamic_acl, "r");
1354 perror(stream->dynamic_acl);
1358 acl = av_mallocz(sizeof(IPAddressACL));
1362 if (fgets(line, sizeof(line), f) == NULL)
1368 if (*p == '\0' || *p == '#')
1370 get_arg(cmd, sizeof(cmd), &p);
1372 if (!av_strcasecmp(cmd, "ACL"))
1373 parse_acl_row(NULL, NULL, acl, p, stream->dynamic_acl, line_num);
1380 static void free_acl_list(IPAddressACL *in_acl)
1382 IPAddressACL *pacl,*pacl2;
1392 static int validate_acl_list(IPAddressACL *in_acl, HTTPContext *c)
1394 enum IPAddressAction last_action = IP_DENY;
1396 struct in_addr *src = &c->from_addr.sin_addr;
1397 unsigned long src_addr = src->s_addr;
1399 for (acl = in_acl; acl; acl = acl->next) {
1400 if (src_addr >= acl->first.s_addr && src_addr <= acl->last.s_addr)
1401 return (acl->action == IP_ALLOW) ? 1 : 0;
1402 last_action = acl->action;
1405 /* Nothing matched, so return not the last action */
1406 return (last_action == IP_DENY) ? 1 : 0;
1409 static int validate_acl(FFStream *stream, HTTPContext *c)
1415 /* if stream->acl is null validate_acl_list will return 1 */
1416 ret = validate_acl_list(stream->acl, c);
1418 if (stream->dynamic_acl[0]) {
1419 acl = parse_dynamic_acl(stream, c);
1421 ret = validate_acl_list(acl, c);
1429 /* compute the real filename of a file by matching it without its
1430 extensions to all the stream filenames */
1431 static void compute_real_filename(char *filename, int max_size)
1438 /* compute filename by matching without the file extensions */
1439 av_strlcpy(file1, filename, sizeof(file1));
1440 p = strrchr(file1, '.');
1443 for(stream = first_stream; stream != NULL; stream = stream->next) {
1444 av_strlcpy(file2, stream->filename, sizeof(file2));
1445 p = strrchr(file2, '.');
1448 if (!strcmp(file1, file2)) {
1449 av_strlcpy(filename, stream->filename, max_size);
1464 /* parse http request and prepare header */
1465 static int http_parse_request(HTTPContext *c)
1468 enum RedirType redir_type;
1470 char info[1024], filename[1024];
1474 const char *mime_type;
1478 char *useragent = 0;
1481 get_word(cmd, sizeof(cmd), (const char **)&p);
1482 av_strlcpy(c->method, cmd, sizeof(c->method));
1484 if (!strcmp(cmd, "GET"))
1486 else if (!strcmp(cmd, "POST"))
1491 get_word(url, sizeof(url), (const char **)&p);
1492 av_strlcpy(c->url, url, sizeof(c->url));
1494 get_word(protocol, sizeof(protocol), (const char **)&p);
1495 if (strcmp(protocol, "HTTP/1.0") && strcmp(protocol, "HTTP/1.1"))
1498 av_strlcpy(c->protocol, protocol, sizeof(c->protocol));
1501 http_log("%s - - New connection: %s %s\n", inet_ntoa(c->from_addr.sin_addr), cmd, url);
1503 /* find the filename and the optional info string in the request */
1504 p = strchr(url, '?');
1506 av_strlcpy(info, p, sizeof(info));
1511 av_strlcpy(filename, url + ((*url == '/') ? 1 : 0), sizeof(filename)-1);
1513 for (p = c->buffer; *p && *p != '\r' && *p != '\n'; ) {
1514 if (av_strncasecmp(p, "User-Agent:", 11) == 0) {
1516 if (*useragent && *useragent != '\n' && isspace(*useragent))
1520 p = strchr(p, '\n');
1527 redir_type = REDIR_NONE;
1528 if (av_match_ext(filename, "asx")) {
1529 redir_type = REDIR_ASX;
1530 filename[strlen(filename)-1] = 'f';
1531 } else if (av_match_ext(filename, "asf") &&
1532 (!useragent || av_strncasecmp(useragent, "NSPlayer", 8) != 0)) {
1533 /* if this isn't WMP or lookalike, return the redirector file */
1534 redir_type = REDIR_ASF;
1535 } else if (av_match_ext(filename, "rpm,ram")) {
1536 redir_type = REDIR_RAM;
1537 strcpy(filename + strlen(filename)-2, "m");
1538 } else if (av_match_ext(filename, "rtsp")) {
1539 redir_type = REDIR_RTSP;
1540 compute_real_filename(filename, sizeof(filename) - 1);
1541 } else if (av_match_ext(filename, "sdp")) {
1542 redir_type = REDIR_SDP;
1543 compute_real_filename(filename, sizeof(filename) - 1);
1546 // "redirect" / request to index.html
1547 if (!strlen(filename))
1548 av_strlcpy(filename, "index.html", sizeof(filename) - 1);
1550 stream = first_stream;
1551 while (stream != NULL) {
1552 if (!strcmp(stream->filename, filename) && validate_acl(stream, c))
1554 stream = stream->next;
1556 if (stream == NULL) {
1557 snprintf(msg, sizeof(msg), "File '%s' not found", url);
1558 http_log("File '%s' not found\n", url);
1563 memcpy(c->feed_streams, stream->feed_streams, sizeof(c->feed_streams));
1564 memset(c->switch_feed_streams, -1, sizeof(c->switch_feed_streams));
1566 if (stream->stream_type == STREAM_TYPE_REDIRECT) {
1567 c->http_error = 301;
1569 snprintf(q, c->buffer_size,
1570 "HTTP/1.0 301 Moved\r\n"
1572 "Content-type: text/html\r\n"
1574 "<html><head><title>Moved</title></head><body>\r\n"
1575 "You should be <a href=\"%s\">redirected</a>.\r\n"
1576 "</body></html>\r\n", stream->feed_filename, stream->feed_filename);
1578 /* prepare output buffer */
1579 c->buffer_ptr = c->buffer;
1581 c->state = HTTPSTATE_SEND_HEADER;
1585 /* If this is WMP, get the rate information */
1586 if (extract_rates(ratebuf, sizeof(ratebuf), c->buffer)) {
1587 if (modify_current_stream(c, ratebuf)) {
1588 for (i = 0; i < FF_ARRAY_ELEMS(c->feed_streams); i++) {
1589 if (c->switch_feed_streams[i] >= 0)
1590 c->switch_feed_streams[i] = -1;
1595 if (c->post == 0 && stream->stream_type == STREAM_TYPE_LIVE)
1596 current_bandwidth += stream->bandwidth;
1598 /* If already streaming this feed, do not let start another feeder. */
1599 if (stream->feed_opened) {
1600 snprintf(msg, sizeof(msg), "This feed is already being received.");
1601 http_log("Feed '%s' already being received\n", stream->feed_filename);
1605 if (c->post == 0 && max_bandwidth < current_bandwidth) {
1606 c->http_error = 503;
1608 snprintf(q, c->buffer_size,
1609 "HTTP/1.0 503 Server too busy\r\n"
1610 "Content-type: text/html\r\n"
1612 "<html><head><title>Too busy</title></head><body>\r\n"
1613 "<p>The server is too busy to serve your request at this time.</p>\r\n"
1614 "<p>The bandwidth being served (including your stream) is %"PRIu64"kbit/sec, "
1615 "and this exceeds the limit of %"PRIu64"kbit/sec.</p>\r\n"
1616 "</body></html>\r\n", current_bandwidth, max_bandwidth);
1618 /* prepare output buffer */
1619 c->buffer_ptr = c->buffer;
1621 c->state = HTTPSTATE_SEND_HEADER;
1625 if (redir_type != REDIR_NONE) {
1628 for (p = c->buffer; *p && *p != '\r' && *p != '\n'; ) {
1629 if (av_strncasecmp(p, "Host:", 5) == 0) {
1633 p = strchr(p, '\n');
1644 while (isspace(*hostinfo))
1647 eoh = strchr(hostinfo, '\n');
1649 if (eoh[-1] == '\r')
1652 if (eoh - hostinfo < sizeof(hostbuf) - 1) {
1653 memcpy(hostbuf, hostinfo, eoh - hostinfo);
1654 hostbuf[eoh - hostinfo] = 0;
1656 c->http_error = 200;
1658 switch(redir_type) {
1660 snprintf(q, c->buffer_size,
1661 "HTTP/1.0 200 ASX Follows\r\n"
1662 "Content-type: video/x-ms-asf\r\n"
1664 "<ASX Version=\"3\">\r\n"
1665 //"<!-- Autogenerated by ffserver -->\r\n"
1666 "<ENTRY><REF HREF=\"http://%s/%s%s\"/></ENTRY>\r\n"
1667 "</ASX>\r\n", hostbuf, filename, info);
1671 snprintf(q, c->buffer_size,
1672 "HTTP/1.0 200 RAM Follows\r\n"
1673 "Content-type: audio/x-pn-realaudio\r\n"
1675 "# Autogenerated by ffserver\r\n"
1676 "http://%s/%s%s\r\n", hostbuf, filename, info);
1680 snprintf(q, c->buffer_size,
1681 "HTTP/1.0 200 ASF Redirect follows\r\n"
1682 "Content-type: video/x-ms-asf\r\n"
1685 "Ref1=http://%s/%s%s\r\n", hostbuf, filename, info);
1690 char hostname[256], *p;
1691 /* extract only hostname */
1692 av_strlcpy(hostname, hostbuf, sizeof(hostname));
1693 p = strrchr(hostname, ':');
1696 snprintf(q, c->buffer_size,
1697 "HTTP/1.0 200 RTSP Redirect follows\r\n"
1698 /* XXX: incorrect mime type ? */
1699 "Content-type: application/x-rtsp\r\n"
1701 "rtsp://%s:%d/%s\r\n", hostname, ntohs(my_rtsp_addr.sin_port), filename);
1708 int sdp_data_size, len;
1709 struct sockaddr_in my_addr;
1711 snprintf(q, c->buffer_size,
1712 "HTTP/1.0 200 OK\r\n"
1713 "Content-type: application/sdp\r\n"
1717 len = sizeof(my_addr);
1718 getsockname(c->fd, (struct sockaddr *)&my_addr, &len);
1720 /* XXX: should use a dynamic buffer */
1721 sdp_data_size = prepare_sdp_description(stream,
1724 if (sdp_data_size > 0) {
1725 memcpy(q, sdp_data, sdp_data_size);
1737 /* prepare output buffer */
1738 c->buffer_ptr = c->buffer;
1740 c->state = HTTPSTATE_SEND_HEADER;
1746 snprintf(msg, sizeof(msg), "ASX/RAM file not handled");
1750 stream->conns_served++;
1752 /* XXX: add there authenticate and IP match */
1755 /* if post, it means a feed is being sent */
1756 if (!stream->is_feed) {
1757 /* However it might be a status report from WMP! Let us log the
1758 * data as it might come in handy one day. */
1762 for (p = c->buffer; *p && *p != '\r' && *p != '\n'; ) {
1763 if (av_strncasecmp(p, "Pragma: log-line=", 17) == 0) {
1767 if (av_strncasecmp(p, "Pragma: client-id=", 18) == 0)
1768 client_id = strtol(p + 18, 0, 10);
1769 p = strchr(p, '\n');
1777 char *eol = strchr(logline, '\n');
1782 if (eol[-1] == '\r')
1784 http_log("%.*s\n", (int) (eol - logline), logline);
1785 c->suppress_log = 1;
1790 http_log("\nGot request:\n%s\n", c->buffer);
1793 if (client_id && extract_rates(ratebuf, sizeof(ratebuf), c->buffer)) {
1796 /* Now we have to find the client_id */
1797 for (wmpc = first_http_ctx; wmpc; wmpc = wmpc->next) {
1798 if (wmpc->wmp_client_id == client_id)
1802 if (wmpc && modify_current_stream(wmpc, ratebuf))
1803 wmpc->switch_pending = 1;
1806 snprintf(msg, sizeof(msg), "POST command not handled");
1810 if (http_start_receive_data(c) < 0) {
1811 snprintf(msg, sizeof(msg), "could not open feed");
1815 c->state = HTTPSTATE_RECEIVE_DATA;
1820 if (strcmp(stream->filename + strlen(stream->filename) - 4, ".asf") == 0)
1821 http_log("\nGot request:\n%s\n", c->buffer);
1824 if (c->stream->stream_type == STREAM_TYPE_STATUS)
1827 /* open input stream */
1828 if (open_input_stream(c, info) < 0) {
1829 snprintf(msg, sizeof(msg), "Input stream corresponding to '%s' not found", url);
1833 /* prepare http header */
1835 av_strlcatf(c->buffer, c->buffer_size, "HTTP/1.0 200 OK\r\n");
1836 mime_type = c->stream->fmt->mime_type;
1838 mime_type = "application/x-octet-stream";
1839 av_strlcatf(c->buffer, c->buffer_size, "Pragma: no-cache\r\n");
1841 /* for asf, we need extra headers */
1842 if (!strcmp(c->stream->fmt->name,"asf_stream")) {
1843 /* Need to allocate a client id */
1845 c->wmp_client_id = av_lfg_get(&random_state);
1847 av_strlcatf(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);
1849 av_strlcatf(c->buffer, c->buffer_size, "Content-Type: %s\r\n", mime_type);
1850 av_strlcatf(c->buffer, c->buffer_size, "\r\n");
1851 q = c->buffer + strlen(c->buffer);
1853 /* prepare output buffer */
1855 c->buffer_ptr = c->buffer;
1857 c->state = HTTPSTATE_SEND_HEADER;
1860 c->http_error = 404;
1862 snprintf(q, c->buffer_size,
1863 "HTTP/1.0 404 Not Found\r\n"
1864 "Content-type: text/html\r\n"
1867 "<head><title>404 Not Found</title></head>\n"
1871 /* prepare output buffer */
1872 c->buffer_ptr = c->buffer;
1874 c->state = HTTPSTATE_SEND_HEADER;
1878 c->http_error = 200; /* horrible : we use this value to avoid
1879 going to the send data state */
1880 c->state = HTTPSTATE_SEND_HEADER;
1884 static void fmt_bytecount(AVIOContext *pb, int64_t count)
1886 static const char suffix[] = " kMGTP";
1889 for (s = suffix; count >= 100000 && s[1]; count /= 1000, s++);
1891 avio_printf(pb, "%"PRId64"%c", count, *s);
1894 static void compute_status(HTTPContext *c)
1903 if (avio_open_dyn_buf(&pb) < 0) {
1904 /* XXX: return an error ? */
1905 c->buffer_ptr = c->buffer;
1906 c->buffer_end = c->buffer;
1910 avio_printf(pb, "HTTP/1.0 200 OK\r\n");
1911 avio_printf(pb, "Content-type: %s\r\n", "text/html");
1912 avio_printf(pb, "Pragma: no-cache\r\n");
1913 avio_printf(pb, "\r\n");
1915 avio_printf(pb, "<html><head><title>%s Status</title>\n", program_name);
1916 if (c->stream->feed_filename[0])
1917 avio_printf(pb, "<link rel=\"shortcut icon\" href=\"%s\">\n", c->stream->feed_filename);
1918 avio_printf(pb, "</head>\n<body>");
1919 avio_printf(pb, "<h1>%s Status</h1>\n", program_name);
1921 avio_printf(pb, "<h2>Available Streams</h2>\n");
1922 avio_printf(pb, "<table cellspacing=0 cellpadding=4>\n");
1923 avio_printf(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");
1924 stream = first_stream;
1925 while (stream != NULL) {
1926 char sfilename[1024];
1929 if (stream->feed != stream) {
1930 av_strlcpy(sfilename, stream->filename, sizeof(sfilename) - 10);
1931 eosf = sfilename + strlen(sfilename);
1932 if (eosf - sfilename >= 4) {
1933 if (strcmp(eosf - 4, ".asf") == 0)
1934 strcpy(eosf - 4, ".asx");
1935 else if (strcmp(eosf - 3, ".rm") == 0)
1936 strcpy(eosf - 3, ".ram");
1937 else if (stream->fmt && !strcmp(stream->fmt->name, "rtp")) {
1938 /* generate a sample RTSP director if
1939 unicast. Generate an SDP redirector if
1941 eosf = strrchr(sfilename, '.');
1943 eosf = sfilename + strlen(sfilename);
1944 if (stream->is_multicast)
1945 strcpy(eosf, ".sdp");
1947 strcpy(eosf, ".rtsp");
1951 avio_printf(pb, "<tr><td><a href=\"/%s\">%s</a> ",
1952 sfilename, stream->filename);
1953 avio_printf(pb, "<td align=right> %d <td align=right> ",
1954 stream->conns_served);
1955 fmt_bytecount(pb, stream->bytes_served);
1956 switch(stream->stream_type) {
1957 case STREAM_TYPE_LIVE: {
1958 int audio_bit_rate = 0;
1959 int video_bit_rate = 0;
1960 const char *audio_codec_name = "";
1961 const char *video_codec_name = "";
1962 const char *audio_codec_name_extra = "";
1963 const char *video_codec_name_extra = "";
1965 for(i=0;i<stream->nb_streams;i++) {
1966 AVStream *st = stream->streams[i];
1967 AVCodec *codec = avcodec_find_encoder(st->codec->codec_id);
1968 switch(st->codec->codec_type) {
1969 case AVMEDIA_TYPE_AUDIO:
1970 audio_bit_rate += st->codec->bit_rate;
1972 if (*audio_codec_name)
1973 audio_codec_name_extra = "...";
1974 audio_codec_name = codec->name;
1977 case AVMEDIA_TYPE_VIDEO:
1978 video_bit_rate += st->codec->bit_rate;
1980 if (*video_codec_name)
1981 video_codec_name_extra = "...";
1982 video_codec_name = codec->name;
1985 case AVMEDIA_TYPE_DATA:
1986 video_bit_rate += st->codec->bit_rate;
1992 avio_printf(pb, "<td align=center> %s <td align=right> %d <td align=right> %d <td> %s %s <td align=right> %d <td> %s %s",
1995 video_bit_rate / 1000, video_codec_name, video_codec_name_extra,
1996 audio_bit_rate / 1000, audio_codec_name, audio_codec_name_extra);
1998 avio_printf(pb, "<td>%s", stream->feed->filename);
2000 avio_printf(pb, "<td>%s", stream->feed_filename);
2001 avio_printf(pb, "\n");
2005 avio_printf(pb, "<td align=center> - <td align=right> - <td align=right> - <td><td align=right> - <td>\n");
2009 stream = stream->next;
2011 avio_printf(pb, "</table>\n");
2013 stream = first_stream;
2014 while (stream != NULL) {
2015 if (stream->feed == stream) {
2016 avio_printf(pb, "<h2>Feed %s</h2>", stream->filename);
2018 avio_printf(pb, "Running as pid %d.\n", stream->pid);
2020 #if defined(linux) && !defined(CONFIG_NOCUTILS)
2025 /* This is somewhat linux specific I guess */
2026 snprintf(ps_cmd, sizeof(ps_cmd),
2027 "ps -o \"%%cpu,cputime\" --no-headers %d",
2030 pid_stat = popen(ps_cmd, "r");
2035 if (fscanf(pid_stat, "%10s %64s", cpuperc,
2037 avio_printf(pb, "Currently using %s%% of the cpu. Total time used %s.\n",
2045 avio_printf(pb, "<p>");
2047 avio_printf(pb, "<table cellspacing=0 cellpadding=4><tr><th>Stream<th>type<th>kbits/s<th align=left>codec<th align=left>Parameters\n");
2049 for (i = 0; i < stream->nb_streams; i++) {
2050 AVStream *st = stream->streams[i];
2051 AVCodec *codec = avcodec_find_encoder(st->codec->codec_id);
2052 const char *type = "unknown";
2053 char parameters[64];
2057 switch(st->codec->codec_type) {
2058 case AVMEDIA_TYPE_AUDIO:
2060 snprintf(parameters, sizeof(parameters), "%d channel(s), %d Hz", st->codec->channels, st->codec->sample_rate);
2062 case AVMEDIA_TYPE_VIDEO:
2064 snprintf(parameters, sizeof(parameters), "%dx%d, q=%d-%d, fps=%d", st->codec->width, st->codec->height,
2065 st->codec->qmin, st->codec->qmax, st->codec->time_base.den / st->codec->time_base.num);
2070 avio_printf(pb, "<tr><td align=right>%d<td>%s<td align=right>%d<td>%s<td>%s\n",
2071 i, type, st->codec->bit_rate/1000, codec ? codec->name : "", parameters);
2073 avio_printf(pb, "</table>\n");
2076 stream = stream->next;
2079 /* connection status */
2080 avio_printf(pb, "<h2>Connection Status</h2>\n");
2082 avio_printf(pb, "Number of connections: %d / %d<br>\n",
2083 nb_connections, nb_max_connections);
2085 avio_printf(pb, "Bandwidth in use: %"PRIu64"k / %"PRIu64"k<br>\n",
2086 current_bandwidth, max_bandwidth);
2088 avio_printf(pb, "<table>\n");
2089 avio_printf(pb, "<tr><th>#<th>File<th>IP<th>Proto<th>State<th>Target bits/sec<th>Actual bits/sec<th>Bytes transferred\n");
2090 c1 = first_http_ctx;
2092 while (c1 != NULL) {
2098 for (j = 0; j < c1->stream->nb_streams; j++) {
2099 if (!c1->stream->feed)
2100 bitrate += c1->stream->streams[j]->codec->bit_rate;
2101 else if (c1->feed_streams[j] >= 0)
2102 bitrate += c1->stream->feed->streams[c1->feed_streams[j]]->codec->bit_rate;
2107 p = inet_ntoa(c1->from_addr.sin_addr);
2108 avio_printf(pb, "<tr><td><b>%d</b><td>%s%s<td>%s<td>%s<td>%s<td align=right>",
2110 c1->stream ? c1->stream->filename : "",
2111 c1->state == HTTPSTATE_RECEIVE_DATA ? "(input)" : "",
2114 http_state[c1->state]);
2115 fmt_bytecount(pb, bitrate);
2116 avio_printf(pb, "<td align=right>");
2117 fmt_bytecount(pb, compute_datarate(&c1->datarate, c1->data_count) * 8);
2118 avio_printf(pb, "<td align=right>");
2119 fmt_bytecount(pb, c1->data_count);
2120 avio_printf(pb, "\n");
2123 avio_printf(pb, "</table>\n");
2128 avio_printf(pb, "<hr size=1 noshade>Generated at %s", p);
2129 avio_printf(pb, "</body>\n</html>\n");
2131 len = avio_close_dyn_buf(pb, &c->pb_buffer);
2132 c->buffer_ptr = c->pb_buffer;
2133 c->buffer_end = c->pb_buffer + len;
2136 static int open_input_stream(HTTPContext *c, const char *info)
2139 char input_filename[1024];
2140 AVFormatContext *s = NULL;
2141 int buf_size, i, ret;
2144 /* find file name */
2145 if (c->stream->feed) {
2146 strcpy(input_filename, c->stream->feed->feed_filename);
2147 buf_size = FFM_PACKET_SIZE;
2148 /* compute position (absolute time) */
2149 if (av_find_info_tag(buf, sizeof(buf), "date", info)) {
2150 if ((ret = av_parse_time(&stream_pos, buf, 0)) < 0)
2152 } else if (av_find_info_tag(buf, sizeof(buf), "buffer", info)) {
2153 int prebuffer = strtol(buf, 0, 10);
2154 stream_pos = av_gettime() - prebuffer * (int64_t)1000000;
2156 stream_pos = av_gettime() - c->stream->prebuffer * (int64_t)1000;
2158 strcpy(input_filename, c->stream->feed_filename);
2160 /* compute position (relative time) */
2161 if (av_find_info_tag(buf, sizeof(buf), "date", info)) {
2162 if ((ret = av_parse_time(&stream_pos, buf, 1)) < 0)
2167 if (input_filename[0] == '\0')
2171 if ((ret = avformat_open_input(&s, input_filename, c->stream->ifmt, &c->stream->in_opts)) < 0) {
2172 http_log("could not open %s: %d\n", input_filename, ret);
2176 /* set buffer size */
2177 if (buf_size > 0) ffio_set_buf_size(s->pb, buf_size);
2179 s->flags |= AVFMT_FLAG_GENPTS;
2181 if (strcmp(s->iformat->name, "ffm") && avformat_find_stream_info(c->fmt_in, NULL) < 0) {
2182 http_log("Could not find stream info '%s'\n", input_filename);
2183 avformat_close_input(&s);
2187 /* choose stream as clock source (we favorize video stream if
2188 present) for packet sending */
2189 c->pts_stream_index = 0;
2190 for(i=0;i<c->stream->nb_streams;i++) {
2191 if (c->pts_stream_index == 0 &&
2192 c->stream->streams[i]->codec->codec_type == AVMEDIA_TYPE_VIDEO) {
2193 c->pts_stream_index = i;
2197 if (c->fmt_in->iformat->read_seek)
2198 av_seek_frame(c->fmt_in, -1, stream_pos, 0);
2199 /* set the start time (needed for maxtime and RTP packet timing) */
2200 c->start_time = cur_time;
2201 c->first_pts = AV_NOPTS_VALUE;
2205 /* return the server clock (in us) */
2206 static int64_t get_server_clock(HTTPContext *c)
2208 /* compute current pts value from system time */
2209 return (cur_time - c->start_time) * 1000;
2212 /* return the estimated time at which the current packet must be sent
2214 static int64_t get_packet_send_clock(HTTPContext *c)
2216 int bytes_left, bytes_sent, frame_bytes;
2218 frame_bytes = c->cur_frame_bytes;
2219 if (frame_bytes <= 0)
2222 bytes_left = c->buffer_end - c->buffer_ptr;
2223 bytes_sent = frame_bytes - bytes_left;
2224 return c->cur_pts + (c->cur_frame_duration * bytes_sent) / frame_bytes;
2229 static int http_prepare_data(HTTPContext *c)
2232 AVFormatContext *ctx;
2234 av_freep(&c->pb_buffer);
2236 case HTTPSTATE_SEND_DATA_HEADER:
2237 memset(&c->fmt_ctx, 0, sizeof(c->fmt_ctx));
2238 av_dict_set(&c->fmt_ctx.metadata, "author" , c->stream->author , 0);
2239 av_dict_set(&c->fmt_ctx.metadata, "comment" , c->stream->comment , 0);
2240 av_dict_set(&c->fmt_ctx.metadata, "copyright", c->stream->copyright, 0);
2241 av_dict_set(&c->fmt_ctx.metadata, "title" , c->stream->title , 0);
2243 c->fmt_ctx.streams = av_mallocz(sizeof(AVStream *) * c->stream->nb_streams);
2245 for(i=0;i<c->stream->nb_streams;i++) {
2247 c->fmt_ctx.streams[i] = av_mallocz(sizeof(AVStream));
2248 /* if file or feed, then just take streams from FFStream struct */
2249 if (!c->stream->feed ||
2250 c->stream->feed == c->stream)
2251 src = c->stream->streams[i];
2253 src = c->stream->feed->streams[c->stream->feed_streams[i]];
2255 *(c->fmt_ctx.streams[i]) = *src;
2256 c->fmt_ctx.streams[i]->priv_data = 0;
2257 c->fmt_ctx.streams[i]->codec->frame_number = 0; /* XXX: should be done in
2258 AVStream, not in codec */
2260 /* set output format parameters */
2261 c->fmt_ctx.oformat = c->stream->fmt;
2262 c->fmt_ctx.nb_streams = c->stream->nb_streams;
2264 c->got_key_frame = 0;
2266 /* prepare header and save header data in a stream */
2267 if (avio_open_dyn_buf(&c->fmt_ctx.pb) < 0) {
2268 /* XXX: potential leak */
2271 c->fmt_ctx.pb->seekable = 0;
2274 * HACK to avoid mpeg ps muxer to spit many underflow errors
2275 * Default value from FFmpeg
2276 * Try to set it use configuration option
2278 c->fmt_ctx.max_delay = (int)(0.7*AV_TIME_BASE);
2280 if (avformat_write_header(&c->fmt_ctx, NULL) < 0) {
2281 http_log("Error writing output header\n");
2284 av_dict_free(&c->fmt_ctx.metadata);
2286 len = avio_close_dyn_buf(c->fmt_ctx.pb, &c->pb_buffer);
2287 c->buffer_ptr = c->pb_buffer;
2288 c->buffer_end = c->pb_buffer + len;
2290 c->state = HTTPSTATE_SEND_DATA;
2291 c->last_packet_sent = 0;
2293 case HTTPSTATE_SEND_DATA:
2294 /* find a new packet */
2295 /* read a packet from the input stream */
2296 if (c->stream->feed)
2297 ffm_set_write_index(c->fmt_in,
2298 c->stream->feed->feed_write_index,
2299 c->stream->feed->feed_size);
2301 if (c->stream->max_time &&
2302 c->stream->max_time + c->start_time - cur_time < 0)
2303 /* We have timed out */
2304 c->state = HTTPSTATE_SEND_DATA_TRAILER;
2308 ret = av_read_frame(c->fmt_in, &pkt);
2310 if (c->stream->feed) {
2311 /* if coming from feed, it means we reached the end of the
2312 ffm file, so must wait for more data */
2313 c->state = HTTPSTATE_WAIT_FEED;
2314 return 1; /* state changed */
2315 } else if (ret == AVERROR(EAGAIN)) {
2316 /* input not ready, come back later */
2319 if (c->stream->loop) {
2320 avformat_close_input(&c->fmt_in);
2321 if (open_input_stream(c, "") < 0)
2326 /* must send trailer now because eof or error */
2327 c->state = HTTPSTATE_SEND_DATA_TRAILER;
2331 int source_index = pkt.stream_index;
2332 /* update first pts if needed */
2333 if (c->first_pts == AV_NOPTS_VALUE) {
2334 c->first_pts = av_rescale_q(pkt.dts, c->fmt_in->streams[pkt.stream_index]->time_base, AV_TIME_BASE_Q);
2335 c->start_time = cur_time;
2337 /* send it to the appropriate stream */
2338 if (c->stream->feed) {
2339 /* if coming from a feed, select the right stream */
2340 if (c->switch_pending) {
2341 c->switch_pending = 0;
2342 for(i=0;i<c->stream->nb_streams;i++) {
2343 if (c->switch_feed_streams[i] == pkt.stream_index)
2344 if (pkt.flags & AV_PKT_FLAG_KEY)
2345 c->switch_feed_streams[i] = -1;
2346 if (c->switch_feed_streams[i] >= 0)
2347 c->switch_pending = 1;
2350 for(i=0;i<c->stream->nb_streams;i++) {
2351 if (c->stream->feed_streams[i] == pkt.stream_index) {
2352 AVStream *st = c->fmt_in->streams[source_index];
2353 pkt.stream_index = i;
2354 if (pkt.flags & AV_PKT_FLAG_KEY &&
2355 (st->codec->codec_type == AVMEDIA_TYPE_VIDEO ||
2356 c->stream->nb_streams == 1))
2357 c->got_key_frame = 1;
2358 if (!c->stream->send_on_key || c->got_key_frame)
2363 AVCodecContext *codec;
2364 AVStream *ist, *ost;
2366 ist = c->fmt_in->streams[source_index];
2367 /* specific handling for RTP: we use several
2368 output stream (one for each RTP
2369 connection). XXX: need more abstract handling */
2370 if (c->is_packetized) {
2371 /* compute send time and duration */
2372 c->cur_pts = av_rescale_q(pkt.dts, ist->time_base, AV_TIME_BASE_Q);
2373 c->cur_pts -= c->first_pts;
2374 c->cur_frame_duration = av_rescale_q(pkt.duration, ist->time_base, AV_TIME_BASE_Q);
2375 /* find RTP context */
2376 c->packet_stream_index = pkt.stream_index;
2377 ctx = c->rtp_ctx[c->packet_stream_index];
2379 av_free_packet(&pkt);
2382 codec = ctx->streams[0]->codec;
2383 /* only one stream per RTP connection */
2384 pkt.stream_index = 0;
2388 codec = ctx->streams[pkt.stream_index]->codec;
2391 if (c->is_packetized) {
2392 int max_packet_size;
2393 if (c->rtp_protocol == RTSP_LOWER_TRANSPORT_TCP)
2394 max_packet_size = RTSP_TCP_MAX_PACKET_SIZE;
2396 max_packet_size = c->rtp_handles[c->packet_stream_index]->max_packet_size;
2397 ret = ffio_open_dyn_packet_buf(&ctx->pb, max_packet_size);
2399 ret = avio_open_dyn_buf(&ctx->pb);
2402 /* XXX: potential leak */
2405 ost = ctx->streams[pkt.stream_index];
2407 ctx->pb->seekable = 0;
2408 if (pkt.dts != AV_NOPTS_VALUE)
2409 pkt.dts = av_rescale_q(pkt.dts, ist->time_base, ost->time_base);
2410 if (pkt.pts != AV_NOPTS_VALUE)
2411 pkt.pts = av_rescale_q(pkt.pts, ist->time_base, ost->time_base);
2412 pkt.duration = av_rescale_q(pkt.duration, ist->time_base, ost->time_base);
2413 if (av_write_frame(ctx, &pkt) < 0) {
2414 http_log("Error writing frame to output\n");
2415 c->state = HTTPSTATE_SEND_DATA_TRAILER;
2418 len = avio_close_dyn_buf(ctx->pb, &c->pb_buffer);
2419 c->cur_frame_bytes = len;
2420 c->buffer_ptr = c->pb_buffer;
2421 c->buffer_end = c->pb_buffer + len;
2423 codec->frame_number++;
2425 av_free_packet(&pkt);
2429 av_free_packet(&pkt);
2434 case HTTPSTATE_SEND_DATA_TRAILER:
2435 /* last packet test ? */
2436 if (c->last_packet_sent || c->is_packetized)
2439 /* prepare header */
2440 if (avio_open_dyn_buf(&ctx->pb) < 0) {
2441 /* XXX: potential leak */
2444 c->fmt_ctx.pb->seekable = 0;
2445 av_write_trailer(ctx);
2446 len = avio_close_dyn_buf(ctx->pb, &c->pb_buffer);
2447 c->buffer_ptr = c->pb_buffer;
2448 c->buffer_end = c->pb_buffer + len;
2450 c->last_packet_sent = 1;
2456 /* should convert the format at the same time */
2457 /* send data starting at c->buffer_ptr to the output connection
2458 (either UDP or TCP connection) */
2459 static int http_send_data(HTTPContext *c)
2464 if (c->buffer_ptr >= c->buffer_end) {
2465 ret = http_prepare_data(c);
2469 /* state change requested */
2472 if (c->is_packetized) {
2473 /* RTP data output */
2474 len = c->buffer_end - c->buffer_ptr;
2476 /* fail safe - should never happen */
2478 c->buffer_ptr = c->buffer_end;
2481 len = (c->buffer_ptr[0] << 24) |
2482 (c->buffer_ptr[1] << 16) |
2483 (c->buffer_ptr[2] << 8) |
2485 if (len > (c->buffer_end - c->buffer_ptr))
2487 if ((get_packet_send_clock(c) - get_server_clock(c)) > 0) {
2488 /* nothing to send yet: we can wait */
2492 c->data_count += len;
2493 update_datarate(&c->datarate, c->data_count);
2495 c->stream->bytes_served += len;
2497 if (c->rtp_protocol == RTSP_LOWER_TRANSPORT_TCP) {
2498 /* RTP packets are sent inside the RTSP TCP connection */
2500 int interleaved_index, size;
2502 HTTPContext *rtsp_c;
2505 /* if no RTSP connection left, error */
2508 /* if already sending something, then wait. */
2509 if (rtsp_c->state != RTSPSTATE_WAIT_REQUEST)
2511 if (avio_open_dyn_buf(&pb) < 0)
2513 interleaved_index = c->packet_stream_index * 2;
2514 /* RTCP packets are sent at odd indexes */
2515 if (c->buffer_ptr[1] == 200)
2516 interleaved_index++;
2517 /* write RTSP TCP header */
2519 header[1] = interleaved_index;
2520 header[2] = len >> 8;
2522 avio_write(pb, header, 4);
2523 /* write RTP packet data */
2525 avio_write(pb, c->buffer_ptr, len);
2526 size = avio_close_dyn_buf(pb, &c->packet_buffer);
2527 /* prepare asynchronous TCP sending */
2528 rtsp_c->packet_buffer_ptr = c->packet_buffer;
2529 rtsp_c->packet_buffer_end = c->packet_buffer + size;
2530 c->buffer_ptr += len;
2532 /* send everything we can NOW */
2533 len = send(rtsp_c->fd, rtsp_c->packet_buffer_ptr,
2534 rtsp_c->packet_buffer_end - rtsp_c->packet_buffer_ptr, 0);
2536 rtsp_c->packet_buffer_ptr += len;
2537 if (rtsp_c->packet_buffer_ptr < rtsp_c->packet_buffer_end) {
2538 /* if we could not send all the data, we will
2539 send it later, so a new state is needed to
2540 "lock" the RTSP TCP connection */
2541 rtsp_c->state = RTSPSTATE_SEND_PACKET;
2544 /* all data has been sent */
2545 av_freep(&c->packet_buffer);
2547 /* send RTP packet directly in UDP */
2549 ffurl_write(c->rtp_handles[c->packet_stream_index],
2550 c->buffer_ptr, len);
2551 c->buffer_ptr += len;
2552 /* here we continue as we can send several packets per 10 ms slot */
2555 /* TCP data output */
2556 len = send(c->fd, c->buffer_ptr, c->buffer_end - c->buffer_ptr, 0);
2558 if (ff_neterrno() != AVERROR(EAGAIN) &&
2559 ff_neterrno() != AVERROR(EINTR))
2560 /* error : close connection */
2565 c->buffer_ptr += len;
2567 c->data_count += len;
2568 update_datarate(&c->datarate, c->data_count);
2570 c->stream->bytes_served += len;
2578 static int http_start_receive_data(HTTPContext *c)
2582 if (c->stream->feed_opened)
2585 /* Don't permit writing to this one */
2586 if (c->stream->readonly)
2590 fd = open(c->stream->feed_filename, O_RDWR);
2592 http_log("Error opening feeder file: %s\n", strerror(errno));
2597 if (c->stream->truncate) {
2598 /* truncate feed file */
2599 ffm_write_write_index(c->feed_fd, FFM_PACKET_SIZE);
2600 http_log("Truncating feed file '%s'\n", c->stream->feed_filename);
2601 if (ftruncate(c->feed_fd, FFM_PACKET_SIZE) < 0) {
2602 http_log("Error truncating feed file: %s\n", strerror(errno));
2606 if ((c->stream->feed_write_index = ffm_read_write_index(fd)) < 0) {
2607 http_log("Error reading write index from feed file: %s\n", strerror(errno));
2612 c->stream->feed_write_index = FFMAX(ffm_read_write_index(fd), FFM_PACKET_SIZE);
2613 c->stream->feed_size = lseek(fd, 0, SEEK_END);
2614 lseek(fd, 0, SEEK_SET);
2616 /* init buffer input */
2617 c->buffer_ptr = c->buffer;
2618 c->buffer_end = c->buffer + FFM_PACKET_SIZE;
2619 c->stream->feed_opened = 1;
2620 c->chunked_encoding = !!av_stristr(c->buffer, "Transfer-Encoding: chunked");
2624 static int http_receive_data(HTTPContext *c)
2627 int len, loop_run = 0;
2629 while (c->chunked_encoding && !c->chunk_size &&
2630 c->buffer_end > c->buffer_ptr) {
2631 /* read chunk header, if present */
2632 len = recv(c->fd, c->buffer_ptr, 1, 0);
2635 if (ff_neterrno() != AVERROR(EAGAIN) &&
2636 ff_neterrno() != AVERROR(EINTR))
2637 /* error : close connection */
2640 } else if (len == 0) {
2641 /* end of connection : close it */
2643 } else if (c->buffer_ptr - c->buffer >= 2 &&
2644 !memcmp(c->buffer_ptr - 1, "\r\n", 2)) {
2645 c->chunk_size = strtol(c->buffer, 0, 16);
2646 if (c->chunk_size == 0) // end of stream
2648 c->buffer_ptr = c->buffer;
2650 } else if (++loop_run > 10) {
2651 /* no chunk header, abort */
2658 if (c->buffer_end > c->buffer_ptr) {
2659 len = recv(c->fd, c->buffer_ptr,
2660 FFMIN(c->chunk_size, c->buffer_end - c->buffer_ptr), 0);
2662 if (ff_neterrno() != AVERROR(EAGAIN) &&
2663 ff_neterrno() != AVERROR(EINTR))
2664 /* error : close connection */
2666 } else if (len == 0)
2667 /* end of connection : close it */
2670 c->chunk_size -= len;
2671 c->buffer_ptr += len;
2672 c->data_count += len;
2673 update_datarate(&c->datarate, c->data_count);
2677 if (c->buffer_ptr - c->buffer >= 2 && c->data_count > FFM_PACKET_SIZE) {
2678 if (c->buffer[0] != 'f' ||
2679 c->buffer[1] != 'm') {
2680 http_log("Feed stream has become desynchronized -- disconnecting\n");
2685 if (c->buffer_ptr >= c->buffer_end) {
2686 FFStream *feed = c->stream;
2687 /* a packet has been received : write it in the store, except
2689 if (c->data_count > FFM_PACKET_SIZE) {
2691 // printf("writing pos=0x%"PRIx64" size=0x%"PRIx64"\n", feed->feed_write_index, feed->feed_size);
2692 /* XXX: use llseek or url_seek */
2693 lseek(c->feed_fd, feed->feed_write_index, SEEK_SET);
2694 if (write(c->feed_fd, c->buffer, FFM_PACKET_SIZE) < 0) {
2695 http_log("Error writing to feed file: %s\n", strerror(errno));
2699 feed->feed_write_index += FFM_PACKET_SIZE;
2700 /* update file size */
2701 if (feed->feed_write_index > c->stream->feed_size)
2702 feed->feed_size = feed->feed_write_index;
2704 /* handle wrap around if max file size reached */
2705 if (c->stream->feed_max_size && feed->feed_write_index >= c->stream->feed_max_size)
2706 feed->feed_write_index = FFM_PACKET_SIZE;
2709 if (ffm_write_write_index(c->feed_fd, feed->feed_write_index) < 0) {
2710 http_log("Error writing index to feed file: %s\n", strerror(errno));
2714 /* wake up any waiting connections */
2715 for(c1 = first_http_ctx; c1 != NULL; c1 = c1->next) {
2716 if (c1->state == HTTPSTATE_WAIT_FEED &&
2717 c1->stream->feed == c->stream->feed)
2718 c1->state = HTTPSTATE_SEND_DATA;
2721 /* We have a header in our hands that contains useful data */
2722 AVFormatContext *s = avformat_alloc_context();
2724 AVInputFormat *fmt_in;
2730 /* use feed output format name to find corresponding input format */
2731 fmt_in = av_find_input_format(feed->fmt->name);
2735 pb = avio_alloc_context(c->buffer, c->buffer_end - c->buffer,
2736 0, NULL, NULL, NULL, NULL);
2740 if (avformat_open_input(&s, c->stream->feed_filename, fmt_in, NULL) < 0) {
2745 /* Now we have the actual streams */
2746 if (s->nb_streams != feed->nb_streams) {
2747 avformat_close_input(&s);
2749 http_log("Feed '%s' stream number does not match registered feed\n",
2750 c->stream->feed_filename);
2754 for (i = 0; i < s->nb_streams; i++) {
2755 AVStream *fst = feed->streams[i];
2756 AVStream *st = s->streams[i];
2757 avcodec_copy_context(fst->codec, st->codec);
2760 avformat_close_input(&s);
2763 c->buffer_ptr = c->buffer;
2768 c->stream->feed_opened = 0;
2770 /* wake up any waiting connections to stop waiting for feed */
2771 for(c1 = first_http_ctx; c1 != NULL; c1 = c1->next) {
2772 if (c1->state == HTTPSTATE_WAIT_FEED &&
2773 c1->stream->feed == c->stream->feed)
2774 c1->state = HTTPSTATE_SEND_DATA_TRAILER;
2779 /********************************************************************/
2782 static void rtsp_reply_header(HTTPContext *c, enum RTSPStatusCode error_number)
2789 switch(error_number) {
2790 case RTSP_STATUS_OK:
2793 case RTSP_STATUS_METHOD:
2794 str = "Method Not Allowed";
2796 case RTSP_STATUS_BANDWIDTH:
2797 str = "Not Enough Bandwidth";
2799 case RTSP_STATUS_SESSION:
2800 str = "Session Not Found";
2802 case RTSP_STATUS_STATE:
2803 str = "Method Not Valid in This State";
2805 case RTSP_STATUS_AGGREGATE:
2806 str = "Aggregate operation not allowed";
2808 case RTSP_STATUS_ONLY_AGGREGATE:
2809 str = "Only aggregate operation allowed";
2811 case RTSP_STATUS_TRANSPORT:
2812 str = "Unsupported transport";
2814 case RTSP_STATUS_INTERNAL:
2815 str = "Internal Server Error";
2817 case RTSP_STATUS_SERVICE:
2818 str = "Service Unavailable";
2820 case RTSP_STATUS_VERSION:
2821 str = "RTSP Version not supported";
2824 str = "Unknown Error";
2828 avio_printf(c->pb, "RTSP/1.0 %d %s\r\n", error_number, str);
2829 avio_printf(c->pb, "CSeq: %d\r\n", c->seq);
2831 /* output GMT time */
2834 strftime(buf2, sizeof(buf2), "%a, %d %b %Y %H:%M:%S", tm);
2835 avio_printf(c->pb, "Date: %s GMT\r\n", buf2);
2838 static void rtsp_reply_error(HTTPContext *c, enum RTSPStatusCode error_number)
2840 rtsp_reply_header(c, error_number);
2841 avio_printf(c->pb, "\r\n");
2844 static int rtsp_parse_request(HTTPContext *c)
2846 const char *p, *p1, *p2;
2852 RTSPMessageHeader header1 = { 0 }, *header = &header1;
2854 c->buffer_ptr[0] = '\0';
2857 get_word(cmd, sizeof(cmd), &p);
2858 get_word(url, sizeof(url), &p);
2859 get_word(protocol, sizeof(protocol), &p);
2861 av_strlcpy(c->method, cmd, sizeof(c->method));
2862 av_strlcpy(c->url, url, sizeof(c->url));
2863 av_strlcpy(c->protocol, protocol, sizeof(c->protocol));
2865 if (avio_open_dyn_buf(&c->pb) < 0) {
2866 /* XXX: cannot do more */
2867 c->pb = NULL; /* safety */
2871 /* check version name */
2872 if (strcmp(protocol, "RTSP/1.0") != 0) {
2873 rtsp_reply_error(c, RTSP_STATUS_VERSION);
2877 /* parse each header line */
2878 /* skip to next line */
2879 while (*p != '\n' && *p != '\0')
2883 while (*p != '\0') {
2884 p1 = memchr(p, '\n', (char *)c->buffer_ptr - p);
2888 if (p2 > p && p2[-1] == '\r')
2890 /* skip empty line */
2894 if (len > sizeof(line) - 1)
2895 len = sizeof(line) - 1;
2896 memcpy(line, p, len);
2898 ff_rtsp_parse_line(header, line, NULL, NULL);
2902 /* handle sequence number */
2903 c->seq = header->seq;
2905 if (!strcmp(cmd, "DESCRIBE"))
2906 rtsp_cmd_describe(c, url);
2907 else if (!strcmp(cmd, "OPTIONS"))
2908 rtsp_cmd_options(c, url);
2909 else if (!strcmp(cmd, "SETUP"))
2910 rtsp_cmd_setup(c, url, header);
2911 else if (!strcmp(cmd, "PLAY"))
2912 rtsp_cmd_play(c, url, header);
2913 else if (!strcmp(cmd, "PAUSE"))
2914 rtsp_cmd_pause(c, url, header);
2915 else if (!strcmp(cmd, "TEARDOWN"))
2916 rtsp_cmd_teardown(c, url, header);
2918 rtsp_reply_error(c, RTSP_STATUS_METHOD);
2921 len = avio_close_dyn_buf(c->pb, &c->pb_buffer);
2922 c->pb = NULL; /* safety */
2924 /* XXX: cannot do more */
2927 c->buffer_ptr = c->pb_buffer;
2928 c->buffer_end = c->pb_buffer + len;
2929 c->state = RTSPSTATE_SEND_REPLY;
2933 static int prepare_sdp_description(FFStream *stream, uint8_t **pbuffer,
2934 struct in_addr my_ip)
2936 AVFormatContext *avc;
2937 AVStream *avs = NULL;
2940 avc = avformat_alloc_context();
2944 av_dict_set(&avc->metadata, "title",
2945 stream->title[0] ? stream->title : "No Title", 0);
2946 avc->nb_streams = stream->nb_streams;
2947 if (stream->is_multicast) {
2948 snprintf(avc->filename, 1024, "rtp://%s:%d?multicast=1?ttl=%d",
2949 inet_ntoa(stream->multicast_ip),
2950 stream->multicast_port, stream->multicast_ttl);
2952 snprintf(avc->filename, 1024, "rtp://0.0.0.0");
2955 if (avc->nb_streams >= INT_MAX/sizeof(*avc->streams) ||
2956 !(avc->streams = av_malloc(avc->nb_streams * sizeof(*avc->streams))))
2958 if (avc->nb_streams >= INT_MAX/sizeof(*avs) ||
2959 !(avs = av_malloc(avc->nb_streams * sizeof(*avs))))
2962 for(i = 0; i < stream->nb_streams; i++) {
2963 avc->streams[i] = &avs[i];
2964 avc->streams[i]->codec = stream->streams[i]->codec;
2966 *pbuffer = av_mallocz(2048);
2967 av_sdp_create(&avc, 1, *pbuffer, 2048);
2970 av_free(avc->streams);
2971 av_dict_free(&avc->metadata);
2975 return strlen(*pbuffer);
2978 static void rtsp_cmd_options(HTTPContext *c, const char *url)
2980 // rtsp_reply_header(c, RTSP_STATUS_OK);
2981 avio_printf(c->pb, "RTSP/1.0 %d %s\r\n", RTSP_STATUS_OK, "OK");
2982 avio_printf(c->pb, "CSeq: %d\r\n", c->seq);
2983 avio_printf(c->pb, "Public: %s\r\n", "OPTIONS, DESCRIBE, SETUP, TEARDOWN, PLAY, PAUSE");
2984 avio_printf(c->pb, "\r\n");
2987 static void rtsp_cmd_describe(HTTPContext *c, const char *url)
2993 int content_length, len;
2994 struct sockaddr_in my_addr;
2996 /* find which url is asked */
2997 av_url_split(NULL, 0, NULL, 0, NULL, 0, NULL, path1, sizeof(path1), url);
3002 for(stream = first_stream; stream != NULL; stream = stream->next) {
3003 if (!stream->is_feed &&
3004 stream->fmt && !strcmp(stream->fmt->name, "rtp") &&
3005 !strcmp(path, stream->filename)) {
3009 /* no stream found */
3010 rtsp_reply_error(c, RTSP_STATUS_SERVICE); /* XXX: right error ? */
3014 /* prepare the media description in sdp format */
3016 /* get the host IP */
3017 len = sizeof(my_addr);
3018 getsockname(c->fd, (struct sockaddr *)&my_addr, &len);
3019 content_length = prepare_sdp_description(stream, &content, my_addr.sin_addr);
3020 if (content_length < 0) {
3021 rtsp_reply_error(c, RTSP_STATUS_INTERNAL);
3024 rtsp_reply_header(c, RTSP_STATUS_OK);
3025 avio_printf(c->pb, "Content-Base: %s/\r\n", url);
3026 avio_printf(c->pb, "Content-Type: application/sdp\r\n");
3027 avio_printf(c->pb, "Content-Length: %d\r\n", content_length);
3028 avio_printf(c->pb, "\r\n");
3029 avio_write(c->pb, content, content_length);
3033 static HTTPContext *find_rtp_session(const char *session_id)
3037 if (session_id[0] == '\0')
3040 for(c = first_http_ctx; c != NULL; c = c->next) {
3041 if (!strcmp(c->session_id, session_id))
3047 static RTSPTransportField *find_transport(RTSPMessageHeader *h, enum RTSPLowerTransport lower_transport)
3049 RTSPTransportField *th;
3052 for(i=0;i<h->nb_transports;i++) {
3053 th = &h->transports[i];
3054 if (th->lower_transport == lower_transport)
3060 static void rtsp_cmd_setup(HTTPContext *c, const char *url,
3061 RTSPMessageHeader *h)
3064 int stream_index, rtp_port, rtcp_port;
3069 RTSPTransportField *th;
3070 struct sockaddr_in dest_addr;
3071 RTSPActionServerSetup setup;
3073 /* find which url is asked */
3074 av_url_split(NULL, 0, NULL, 0, NULL, 0, NULL, path1, sizeof(path1), url);
3079 /* now check each stream */
3080 for(stream = first_stream; stream != NULL; stream = stream->next) {
3081 if (!stream->is_feed &&
3082 stream->fmt && !strcmp(stream->fmt->name, "rtp")) {
3083 /* accept aggregate filenames only if single stream */
3084 if (!strcmp(path, stream->filename)) {
3085 if (stream->nb_streams != 1) {
3086 rtsp_reply_error(c, RTSP_STATUS_AGGREGATE);
3093 for(stream_index = 0; stream_index < stream->nb_streams;
3095 snprintf(buf, sizeof(buf), "%s/streamid=%d",
3096 stream->filename, stream_index);
3097 if (!strcmp(path, buf))
3102 /* no stream found */
3103 rtsp_reply_error(c, RTSP_STATUS_SERVICE); /* XXX: right error ? */
3107 /* generate session id if needed */
3108 if (h->session_id[0] == '\0') {
3109 unsigned random0 = av_lfg_get(&random_state);
3110 unsigned random1 = av_lfg_get(&random_state);
3111 snprintf(h->session_id, sizeof(h->session_id), "%08x%08x",
3115 /* find rtp session, and create it if none found */
3116 rtp_c = find_rtp_session(h->session_id);
3118 /* always prefer UDP */
3119 th = find_transport(h, RTSP_LOWER_TRANSPORT_UDP);
3121 th = find_transport(h, RTSP_LOWER_TRANSPORT_TCP);
3123 rtsp_reply_error(c, RTSP_STATUS_TRANSPORT);
3128 rtp_c = rtp_new_connection(&c->from_addr, stream, h->session_id,
3129 th->lower_transport);
3131 rtsp_reply_error(c, RTSP_STATUS_BANDWIDTH);
3135 /* open input stream */
3136 if (open_input_stream(rtp_c, "") < 0) {
3137 rtsp_reply_error(c, RTSP_STATUS_INTERNAL);
3142 /* test if stream is OK (test needed because several SETUP needs
3143 to be done for a given file) */
3144 if (rtp_c->stream != stream) {
3145 rtsp_reply_error(c, RTSP_STATUS_SERVICE);
3149 /* test if stream is already set up */
3150 if (rtp_c->rtp_ctx[stream_index]) {
3151 rtsp_reply_error(c, RTSP_STATUS_STATE);
3155 /* check transport */
3156 th = find_transport(h, rtp_c->rtp_protocol);
3157 if (!th || (th->lower_transport == RTSP_LOWER_TRANSPORT_UDP &&
3158 th->client_port_min <= 0)) {
3159 rtsp_reply_error(c, RTSP_STATUS_TRANSPORT);
3163 /* setup default options */
3164 setup.transport_option[0] = '\0';
3165 dest_addr = rtp_c->from_addr;
3166 dest_addr.sin_port = htons(th->client_port_min);
3169 if (rtp_new_av_stream(rtp_c, stream_index, &dest_addr, c) < 0) {
3170 rtsp_reply_error(c, RTSP_STATUS_TRANSPORT);
3174 /* now everything is OK, so we can send the connection parameters */
3175 rtsp_reply_header(c, RTSP_STATUS_OK);
3177 avio_printf(c->pb, "Session: %s\r\n", rtp_c->session_id);
3179 switch(rtp_c->rtp_protocol) {
3180 case RTSP_LOWER_TRANSPORT_UDP:
3181 rtp_port = ff_rtp_get_local_rtp_port(rtp_c->rtp_handles[stream_index]);
3182 rtcp_port = ff_rtp_get_local_rtcp_port(rtp_c->rtp_handles[stream_index]);
3183 avio_printf(c->pb, "Transport: RTP/AVP/UDP;unicast;"
3184 "client_port=%d-%d;server_port=%d-%d",
3185 th->client_port_min, th->client_port_max,
3186 rtp_port, rtcp_port);
3188 case RTSP_LOWER_TRANSPORT_TCP:
3189 avio_printf(c->pb, "Transport: RTP/AVP/TCP;interleaved=%d-%d",
3190 stream_index * 2, stream_index * 2 + 1);
3195 if (setup.transport_option[0] != '\0')
3196 avio_printf(c->pb, ";%s", setup.transport_option);
3197 avio_printf(c->pb, "\r\n");
3200 avio_printf(c->pb, "\r\n");
3204 /* find an rtp connection by using the session ID. Check consistency
3206 static HTTPContext *find_rtp_session_with_url(const char *url,
3207 const char *session_id)
3215 rtp_c = find_rtp_session(session_id);
3219 /* find which url is asked */
3220 av_url_split(NULL, 0, NULL, 0, NULL, 0, NULL, path1, sizeof(path1), url);
3224 if(!strcmp(path, rtp_c->stream->filename)) return rtp_c;
3225 for(s=0; s<rtp_c->stream->nb_streams; ++s) {
3226 snprintf(buf, sizeof(buf), "%s/streamid=%d",
3227 rtp_c->stream->filename, s);
3228 if(!strncmp(path, buf, sizeof(buf))) {
3229 // XXX: Should we reply with RTSP_STATUS_ONLY_AGGREGATE if nb_streams>1?
3234 if (len > 0 && path[len - 1] == '/' &&
3235 !strncmp(path, rtp_c->stream->filename, len - 1))
3240 static void rtsp_cmd_play(HTTPContext *c, const char *url, RTSPMessageHeader *h)
3244 rtp_c = find_rtp_session_with_url(url, h->session_id);
3246 rtsp_reply_error(c, RTSP_STATUS_SESSION);
3250 if (rtp_c->state != HTTPSTATE_SEND_DATA &&
3251 rtp_c->state != HTTPSTATE_WAIT_FEED &&
3252 rtp_c->state != HTTPSTATE_READY) {
3253 rtsp_reply_error(c, RTSP_STATUS_STATE);
3257 rtp_c->state = HTTPSTATE_SEND_DATA;
3259 /* now everything is OK, so we can send the connection parameters */
3260 rtsp_reply_header(c, RTSP_STATUS_OK);
3262 avio_printf(c->pb, "Session: %s\r\n", rtp_c->session_id);
3263 avio_printf(c->pb, "\r\n");
3266 static void rtsp_cmd_pause(HTTPContext *c, const char *url, RTSPMessageHeader *h)
3270 rtp_c = find_rtp_session_with_url(url, h->session_id);
3272 rtsp_reply_error(c, RTSP_STATUS_SESSION);
3276 if (rtp_c->state != HTTPSTATE_SEND_DATA &&
3277 rtp_c->state != HTTPSTATE_WAIT_FEED) {
3278 rtsp_reply_error(c, RTSP_STATUS_STATE);
3282 rtp_c->state = HTTPSTATE_READY;
3283 rtp_c->first_pts = AV_NOPTS_VALUE;
3284 /* now everything is OK, so we can send the connection parameters */
3285 rtsp_reply_header(c, RTSP_STATUS_OK);
3287 avio_printf(c->pb, "Session: %s\r\n", rtp_c->session_id);
3288 avio_printf(c->pb, "\r\n");
3291 static void rtsp_cmd_teardown(HTTPContext *c, const char *url, RTSPMessageHeader *h)
3295 rtp_c = find_rtp_session_with_url(url, h->session_id);
3297 rtsp_reply_error(c, RTSP_STATUS_SESSION);
3301 /* now everything is OK, so we can send the connection parameters */
3302 rtsp_reply_header(c, RTSP_STATUS_OK);
3304 avio_printf(c->pb, "Session: %s\r\n", rtp_c->session_id);
3305 avio_printf(c->pb, "\r\n");
3307 /* abort the session */
3308 close_connection(rtp_c);
3312 /********************************************************************/
3315 static HTTPContext *rtp_new_connection(struct sockaddr_in *from_addr,
3316 FFStream *stream, const char *session_id,
3317 enum RTSPLowerTransport rtp_protocol)
3319 HTTPContext *c = NULL;
3320 const char *proto_str;
3322 /* XXX: should output a warning page when coming
3323 close to the connection limit */
3324 if (nb_connections >= nb_max_connections)
3327 /* add a new connection */
3328 c = av_mallocz(sizeof(HTTPContext));
3333 c->poll_entry = NULL;
3334 c->from_addr = *from_addr;
3335 c->buffer_size = IOBUFFER_INIT_SIZE;
3336 c->buffer = av_malloc(c->buffer_size);
3341 av_strlcpy(c->session_id, session_id, sizeof(c->session_id));
3342 c->state = HTTPSTATE_READY;
3343 c->is_packetized = 1;
3344 c->rtp_protocol = rtp_protocol;
3346 /* protocol is shown in statistics */
3347 switch(c->rtp_protocol) {
3348 case RTSP_LOWER_TRANSPORT_UDP_MULTICAST:
3349 proto_str = "MCAST";
3351 case RTSP_LOWER_TRANSPORT_UDP:
3354 case RTSP_LOWER_TRANSPORT_TCP:
3361 av_strlcpy(c->protocol, "RTP/", sizeof(c->protocol));
3362 av_strlcat(c->protocol, proto_str, sizeof(c->protocol));
3364 current_bandwidth += stream->bandwidth;
3366 c->next = first_http_ctx;
3378 /* add a new RTP stream in an RTP connection (used in RTSP SETUP
3379 command). If RTP/TCP protocol is used, TCP connection 'rtsp_c' is
3381 static int rtp_new_av_stream(HTTPContext *c,
3382 int stream_index, struct sockaddr_in *dest_addr,
3383 HTTPContext *rtsp_c)
3385 AVFormatContext *ctx;
3388 URLContext *h = NULL;
3390 int max_packet_size;
3392 /* now we can open the relevant output stream */
3393 ctx = avformat_alloc_context();
3396 ctx->oformat = av_guess_format("rtp", NULL, NULL);
3398 st = av_mallocz(sizeof(AVStream));
3401 ctx->nb_streams = 1;
3402 ctx->streams = av_mallocz(sizeof(AVStream *) * ctx->nb_streams);
3405 ctx->streams[0] = st;
3407 if (!c->stream->feed ||
3408 c->stream->feed == c->stream)
3409 memcpy(st, c->stream->streams[stream_index], sizeof(AVStream));
3412 c->stream->feed->streams[c->stream->feed_streams[stream_index]],
3414 st->priv_data = NULL;
3416 /* build destination RTP address */
3417 ipaddr = inet_ntoa(dest_addr->sin_addr);
3419 switch(c->rtp_protocol) {
3420 case RTSP_LOWER_TRANSPORT_UDP:
3421 case RTSP_LOWER_TRANSPORT_UDP_MULTICAST:
3424 /* XXX: also pass as parameter to function ? */
3425 if (c->stream->is_multicast) {
3427 ttl = c->stream->multicast_ttl;
3430 snprintf(ctx->filename, sizeof(ctx->filename),
3431 "rtp://%s:%d?multicast=1&ttl=%d",
3432 ipaddr, ntohs(dest_addr->sin_port), ttl);
3434 snprintf(ctx->filename, sizeof(ctx->filename),
3435 "rtp://%s:%d", ipaddr, ntohs(dest_addr->sin_port));
3438 if (ffurl_open(&h, ctx->filename, AVIO_FLAG_WRITE, NULL, NULL) < 0)
3440 c->rtp_handles[stream_index] = h;
3441 max_packet_size = h->max_packet_size;
3443 case RTSP_LOWER_TRANSPORT_TCP:
3446 max_packet_size = RTSP_TCP_MAX_PACKET_SIZE;
3452 http_log("%s:%d - - \"PLAY %s/streamid=%d %s\"\n",
3453 ipaddr, ntohs(dest_addr->sin_port),
3454 c->stream->filename, stream_index, c->protocol);
3456 /* normally, no packets should be output here, but the packet size may be checked */
3457 if (ffio_open_dyn_packet_buf(&ctx->pb, max_packet_size) < 0) {
3458 /* XXX: close stream */
3461 if (avformat_write_header(ctx, NULL) < 0) {
3468 avio_close_dyn_buf(ctx->pb, &dummy_buf);
3471 c->rtp_ctx[stream_index] = ctx;
3475 /********************************************************************/
3476 /* ffserver initialization */
3478 static AVStream *add_av_stream1(FFStream *stream, AVCodecContext *codec, int copy)
3482 fst = av_mallocz(sizeof(AVStream));
3486 fst->codec = avcodec_alloc_context3(NULL);
3487 memcpy(fst->codec, codec, sizeof(AVCodecContext));
3488 if (codec->extradata_size) {
3489 fst->codec->extradata = av_malloc(codec->extradata_size);
3490 memcpy(fst->codec->extradata, codec->extradata,
3491 codec->extradata_size);
3494 /* live streams must use the actual feed's codec since it may be
3495 * updated later to carry extradata needed by the streams.
3499 fst->priv_data = av_mallocz(sizeof(FeedData));
3500 fst->index = stream->nb_streams;
3501 avpriv_set_pts_info(fst, 33, 1, 90000);
3502 fst->sample_aspect_ratio = codec->sample_aspect_ratio;
3503 stream->streams[stream->nb_streams++] = fst;
3507 /* return the stream number in the feed */
3508 static int add_av_stream(FFStream *feed, AVStream *st)
3511 AVCodecContext *av, *av1;
3515 for(i=0;i<feed->nb_streams;i++) {
3516 st = feed->streams[i];
3518 if (av1->codec_id == av->codec_id &&
3519 av1->codec_type == av->codec_type &&
3520 av1->bit_rate == av->bit_rate) {
3522 switch(av->codec_type) {
3523 case AVMEDIA_TYPE_AUDIO:
3524 if (av1->channels == av->channels &&
3525 av1->sample_rate == av->sample_rate)
3528 case AVMEDIA_TYPE_VIDEO:
3529 if (av1->width == av->width &&
3530 av1->height == av->height &&
3531 av1->time_base.den == av->time_base.den &&
3532 av1->time_base.num == av->time_base.num &&
3533 av1->gop_size == av->gop_size)
3542 fst = add_av_stream1(feed, av, 0);
3545 return feed->nb_streams - 1;
3548 static void remove_stream(FFStream *stream)
3552 while (*ps != NULL) {
3560 /* specific mpeg4 handling : we extract the raw parameters */
3561 static void extract_mpeg4_header(AVFormatContext *infile)
3563 int mpeg4_count, i, size;
3569 for(i=0;i<infile->nb_streams;i++) {
3570 st = infile->streams[i];
3571 if (st->codec->codec_id == AV_CODEC_ID_MPEG4 &&
3572 st->codec->extradata_size == 0) {
3579 printf("MPEG4 without extra data: trying to find header in %s\n", infile->filename);
3580 while (mpeg4_count > 0) {
3581 if (av_read_packet(infile, &pkt) < 0)
3583 st = infile->streams[pkt.stream_index];
3584 if (st->codec->codec_id == AV_CODEC_ID_MPEG4 &&
3585 st->codec->extradata_size == 0) {
3586 av_freep(&st->codec->extradata);
3587 /* fill extradata with the header */
3588 /* XXX: we make hard suppositions here ! */
3590 while (p < pkt.data + pkt.size - 4) {
3591 /* stop when vop header is found */
3592 if (p[0] == 0x00 && p[1] == 0x00 &&
3593 p[2] == 0x01 && p[3] == 0xb6) {
3594 size = p - pkt.data;
3595 // av_hex_dump_log(infile, AV_LOG_DEBUG, pkt.data, size);
3596 st->codec->extradata = av_malloc(size);
3597 st->codec->extradata_size = size;
3598 memcpy(st->codec->extradata, pkt.data, size);
3605 av_free_packet(&pkt);
3609 /* compute the needed AVStream for each file */
3610 static void build_file_streams(void)
3612 FFStream *stream, *stream_next;
3615 /* gather all streams */
3616 for(stream = first_stream; stream != NULL; stream = stream_next) {
3617 AVFormatContext *infile = NULL;
3618 stream_next = stream->next;
3619 if (stream->stream_type == STREAM_TYPE_LIVE &&
3621 /* the stream comes from a file */
3622 /* try to open the file */
3624 if (stream->fmt && !strcmp(stream->fmt->name, "rtp")) {
3625 /* specific case : if transport stream output to RTP,
3626 we use a raw transport stream reader */
3627 av_dict_set(&stream->in_opts, "mpeg2ts_compute_pcr", "1", 0);
3630 http_log("Opening file '%s'\n", stream->feed_filename);
3631 if ((ret = avformat_open_input(&infile, stream->feed_filename, stream->ifmt, &stream->in_opts)) < 0) {
3632 http_log("Could not open '%s': %d\n", stream->feed_filename, ret);
3633 /* remove stream (no need to spend more time on it) */
3635 remove_stream(stream);
3637 /* find all the AVStreams inside and reference them in
3639 if (avformat_find_stream_info(infile, NULL) < 0) {
3640 http_log("Could not find codec parameters from '%s'\n",
3641 stream->feed_filename);
3642 avformat_close_input(&infile);
3645 extract_mpeg4_header(infile);
3647 for(i=0;i<infile->nb_streams;i++)
3648 add_av_stream1(stream, infile->streams[i]->codec, 1);
3650 avformat_close_input(&infile);
3656 /* compute the needed AVStream for each feed */
3657 static void build_feed_streams(void)
3659 FFStream *stream, *feed;
3662 /* gather all streams */
3663 for(stream = first_stream; stream != NULL; stream = stream->next) {
3664 feed = stream->feed;
3666 if (stream->is_feed) {
3667 for(i=0;i<stream->nb_streams;i++)
3668 stream->feed_streams[i] = i;
3670 /* we handle a stream coming from a feed */
3671 for(i=0;i<stream->nb_streams;i++)
3672 stream->feed_streams[i] = add_av_stream(feed, stream->streams[i]);
3677 /* create feed files if needed */
3678 for(feed = first_feed; feed != NULL; feed = feed->next_feed) {
3681 if (avio_check(feed->feed_filename, AVIO_FLAG_READ) > 0) {
3682 /* See if it matches */
3683 AVFormatContext *s = NULL;
3686 if (avformat_open_input(&s, feed->feed_filename, NULL, NULL) >= 0) {
3687 /* set buffer size */
3688 ffio_set_buf_size(s->pb, FFM_PACKET_SIZE);
3689 /* Now see if it matches */
3690 if (s->nb_streams == feed->nb_streams) {
3692 for(i=0;i<s->nb_streams;i++) {
3694 sf = feed->streams[i];
3697 if (sf->index != ss->index ||
3699 http_log("Index & Id do not match for stream %d (%s)\n",
3700 i, feed->feed_filename);
3703 AVCodecContext *ccf, *ccs;
3707 #define CHECK_CODEC(x) (ccf->x != ccs->x)
3709 if (CHECK_CODEC(codec_id) || CHECK_CODEC(codec_type)) {
3710 http_log("Codecs do not match for stream %d\n", i);
3712 } else if (CHECK_CODEC(bit_rate) || CHECK_CODEC(flags)) {
3713 http_log("Codec bitrates do not match for stream %d\n", i);
3715 } else if (ccf->codec_type == AVMEDIA_TYPE_VIDEO) {
3716 if (CHECK_CODEC(time_base.den) ||
3717 CHECK_CODEC(time_base.num) ||
3718 CHECK_CODEC(width) ||
3719 CHECK_CODEC(height)) {
3720 http_log("Codec width, height and framerate do not match for stream %d\n", i);
3723 } else if (ccf->codec_type == AVMEDIA_TYPE_AUDIO) {
3724 if (CHECK_CODEC(sample_rate) ||
3725 CHECK_CODEC(channels) ||
3726 CHECK_CODEC(frame_size)) {
3727 http_log("Codec sample_rate, channels, frame_size do not match for stream %d\n", i);
3731 http_log("Unknown codec type\n");
3739 http_log("Deleting feed file '%s' as stream counts differ (%d != %d)\n",
3740 feed->feed_filename, s->nb_streams, feed->nb_streams);
3742 avformat_close_input(&s);
3744 http_log("Deleting feed file '%s' as it appears to be corrupt\n",
3745 feed->feed_filename);
3748 if (feed->readonly) {
3749 http_log("Unable to delete feed file '%s' as it is marked readonly\n",
3750 feed->feed_filename);
3753 unlink(feed->feed_filename);
3756 if (avio_check(feed->feed_filename, AVIO_FLAG_WRITE) <= 0) {
3757 AVFormatContext s1 = {0}, *s = &s1;
3759 if (feed->readonly) {
3760 http_log("Unable to create feed file '%s' as it is marked readonly\n",
3761 feed->feed_filename);
3765 /* only write the header of the ffm file */
3766 if (avio_open(&s->pb, feed->feed_filename, AVIO_FLAG_WRITE) < 0) {
3767 http_log("Could not open output feed file '%s'\n",
3768 feed->feed_filename);
3771 s->oformat = feed->fmt;
3772 s->nb_streams = feed->nb_streams;
3773 s->streams = feed->streams;
3774 if (avformat_write_header(s, NULL) < 0) {
3775 http_log("Container doesn't supports the required parameters\n");
3778 /* XXX: need better api */
3779 av_freep(&s->priv_data);
3782 /* get feed size and write index */
3783 fd = open(feed->feed_filename, O_RDONLY);
3785 http_log("Could not open output feed file '%s'\n",
3786 feed->feed_filename);
3790 feed->feed_write_index = FFMAX(ffm_read_write_index(fd), FFM_PACKET_SIZE);
3791 feed->feed_size = lseek(fd, 0, SEEK_END);
3792 /* ensure that we do not wrap before the end of file */
3793 if (feed->feed_max_size && feed->feed_max_size < feed->feed_size)
3794 feed->feed_max_size = feed->feed_size;
3800 /* compute the bandwidth used by each stream */
3801 static void compute_bandwidth(void)
3807 for(stream = first_stream; stream != NULL; stream = stream->next) {
3809 for(i=0;i<stream->nb_streams;i++) {
3810 AVStream *st = stream->streams[i];
3811 switch(st->codec->codec_type) {
3812 case AVMEDIA_TYPE_AUDIO:
3813 case AVMEDIA_TYPE_VIDEO:
3814 bandwidth += st->codec->bit_rate;
3820 stream->bandwidth = (bandwidth + 999) / 1000;
3824 /* add a codec and set the default parameters */
3825 static void add_codec(FFStream *stream, AVCodecContext *av)
3829 /* compute default parameters */
3830 switch(av->codec_type) {
3831 case AVMEDIA_TYPE_AUDIO:
3832 if (av->bit_rate == 0)
3833 av->bit_rate = 64000;
3834 if (av->sample_rate == 0)
3835 av->sample_rate = 22050;
3836 if (av->channels == 0)
3839 case AVMEDIA_TYPE_VIDEO:
3840 if (av->bit_rate == 0)
3841 av->bit_rate = 64000;
3842 if (av->time_base.num == 0){
3843 av->time_base.den = 5;
3844 av->time_base.num = 1;
3846 if (av->width == 0 || av->height == 0) {
3850 /* Bitrate tolerance is less for streaming */
3851 if (av->bit_rate_tolerance == 0)
3852 av->bit_rate_tolerance = FFMAX(av->bit_rate / 4,
3853 (int64_t)av->bit_rate*av->time_base.num/av->time_base.den);
3858 if (av->max_qdiff == 0)
3860 av->qcompress = 0.5;
3863 if (!av->nsse_weight)
3864 av->nsse_weight = 8;
3866 av->frame_skip_cmp = FF_CMP_DCTMAX;
3868 av->me_method = ME_EPZS;
3869 av->rc_buffer_aggressivity = 1.0;
3872 av->rc_eq = "tex^qComp";
3873 if (!av->i_quant_factor)
3874 av->i_quant_factor = -0.8;
3875 if (!av->b_quant_factor)
3876 av->b_quant_factor = 1.25;
3877 if (!av->b_quant_offset)
3878 av->b_quant_offset = 1.25;
3879 if (!av->rc_max_rate)
3880 av->rc_max_rate = av->bit_rate * 2;
3882 if (av->rc_max_rate && !av->rc_buffer_size) {
3883 av->rc_buffer_size = av->rc_max_rate;
3892 st = av_mallocz(sizeof(AVStream));
3895 st->codec = avcodec_alloc_context3(NULL);
3896 stream->streams[stream->nb_streams++] = st;
3897 memcpy(st->codec, av, sizeof(AVCodecContext));
3900 static enum AVCodecID opt_audio_codec(const char *arg)
3902 AVCodec *p= avcodec_find_encoder_by_name(arg);
3904 if (p == NULL || p->type != AVMEDIA_TYPE_AUDIO)
3905 return AV_CODEC_ID_NONE;
3910 static enum AVCodecID opt_video_codec(const char *arg)
3912 AVCodec *p= avcodec_find_encoder_by_name(arg);
3914 if (p == NULL || p->type != AVMEDIA_TYPE_VIDEO)
3915 return AV_CODEC_ID_NONE;
3920 /* simplistic plugin support */
3923 static void load_module(const char *filename)
3926 void (*init_func)(void);
3927 dll = dlopen(filename, RTLD_NOW);
3929 fprintf(stderr, "Could not load module '%s' - %s\n",
3930 filename, dlerror());
3934 init_func = dlsym(dll, "ffserver_module_init");
3937 "%s: init function 'ffserver_module_init()' not found\n",
3946 static int ffserver_opt_default(const char *opt, const char *arg,
3947 AVCodecContext *avctx, int type)
3950 const AVOption *o = av_opt_find(avctx, opt, NULL, type, 0);
3952 ret = av_opt_set(avctx, opt, arg, 0);
3956 static int ffserver_opt_preset(const char *arg,
3957 AVCodecContext *avctx, int type,
3958 enum AVCodecID *audio_id, enum AVCodecID *video_id)
3961 char filename[1000], tmp[1000], tmp2[1000], line[1000];
3963 AVCodec *codec = avcodec_find_encoder(avctx->codec_id);
3965 if (!(f = get_preset_file(filename, sizeof(filename), arg, 0,
3966 codec ? codec->name : NULL))) {
3967 fprintf(stderr, "File for preset '%s' not found\n", arg);
3972 int e= fscanf(f, "%999[^\n]\n", line) - 1;
3973 if(line[0] == '#' && !e)
3975 e|= sscanf(line, "%999[^=]=%999[^\n]\n", tmp, tmp2) - 2;
3977 fprintf(stderr, "%s: Invalid syntax: '%s'\n", filename, line);
3981 if(!strcmp(tmp, "acodec")){
3982 *audio_id = opt_audio_codec(tmp2);
3983 }else if(!strcmp(tmp, "vcodec")){
3984 *video_id = opt_video_codec(tmp2);
3985 }else if(!strcmp(tmp, "scodec")){
3986 /* opt_subtitle_codec(tmp2); */
3987 }else if(ffserver_opt_default(tmp, tmp2, avctx, type) < 0){
3988 fprintf(stderr, "%s: Invalid option or argument: '%s', parsed as '%s' = '%s'\n", filename, line, tmp, tmp2);
3999 static AVOutputFormat *ffserver_guess_format(const char *short_name, const char *filename,
4000 const char *mime_type)
4002 AVOutputFormat *fmt = av_guess_format(short_name, filename, mime_type);
4005 AVOutputFormat *stream_fmt;
4006 char stream_format_name[64];
4008 snprintf(stream_format_name, sizeof(stream_format_name), "%s_stream", fmt->name);
4009 stream_fmt = av_guess_format(stream_format_name, NULL, NULL);
4018 static void report_config_error(const char *filename, int line_num, int *errors, const char *fmt, ...)
4022 fprintf(stderr, "%s:%d: ", filename, line_num);
4023 vfprintf(stderr, fmt, vl);
4029 static int parse_ffconfig(const char *filename)
4036 int val, errors, line_num;
4037 FFStream **last_stream, *stream, *redirect;
4038 FFStream **last_feed, *feed, *s;
4039 AVCodecContext audio_enc, video_enc;
4040 enum AVCodecID audio_id, video_id;
4042 f = fopen(filename, "r");
4050 first_stream = NULL;
4051 last_stream = &first_stream;
4053 last_feed = &first_feed;
4057 audio_id = AV_CODEC_ID_NONE;
4058 video_id = AV_CODEC_ID_NONE;
4060 #define ERROR(...) report_config_error(filename, line_num, &errors, __VA_ARGS__)
4062 if (fgets(line, sizeof(line), f) == NULL)
4068 if (*p == '\0' || *p == '#')
4071 get_arg(cmd, sizeof(cmd), &p);
4073 if (!av_strcasecmp(cmd, "Port")) {
4074 get_arg(arg, sizeof(arg), &p);
4076 if (val < 1 || val > 65536) {
4077 ERROR("Invalid_port: %s\n", arg);
4079 my_http_addr.sin_port = htons(val);
4080 } else if (!av_strcasecmp(cmd, "BindAddress")) {
4081 get_arg(arg, sizeof(arg), &p);
4082 if (resolve_host(&my_http_addr.sin_addr, arg) != 0) {
4083 ERROR("%s:%d: Invalid host/IP address: %s\n", arg);
4085 } else if (!av_strcasecmp(cmd, "NoDaemon")) {
4086 ffserver_daemon = 0;
4087 } else if (!av_strcasecmp(cmd, "RTSPPort")) {
4088 get_arg(arg, sizeof(arg), &p);
4090 if (val < 1 || val > 65536) {
4091 ERROR("%s:%d: Invalid port: %s\n", arg);
4093 my_rtsp_addr.sin_port = htons(atoi(arg));
4094 } else if (!av_strcasecmp(cmd, "RTSPBindAddress")) {
4095 get_arg(arg, sizeof(arg), &p);
4096 if (resolve_host(&my_rtsp_addr.sin_addr, arg) != 0) {
4097 ERROR("Invalid host/IP address: %s\n", arg);
4099 } else if (!av_strcasecmp(cmd, "MaxHTTPConnections")) {
4100 get_arg(arg, sizeof(arg), &p);
4102 if (val < 1 || val > 65536) {
4103 ERROR("Invalid MaxHTTPConnections: %s\n", arg);
4105 nb_max_http_connections = val;
4106 } else if (!av_strcasecmp(cmd, "MaxClients")) {
4107 get_arg(arg, sizeof(arg), &p);
4109 if (val < 1 || val > nb_max_http_connections) {
4110 ERROR("Invalid MaxClients: %s\n", arg);
4112 nb_max_connections = val;
4114 } else if (!av_strcasecmp(cmd, "MaxBandwidth")) {
4116 get_arg(arg, sizeof(arg), &p);
4118 if (llval < 10 || llval > 10000000) {
4119 ERROR("Invalid MaxBandwidth: %s\n", arg);
4121 max_bandwidth = llval;
4122 } else if (!av_strcasecmp(cmd, "CustomLog")) {
4123 if (!ffserver_debug)
4124 get_arg(logfilename, sizeof(logfilename), &p);
4125 } else if (!av_strcasecmp(cmd, "<Feed")) {
4126 /*********************************************/
4127 /* Feed related options */
4129 if (stream || feed) {
4130 ERROR("Already in a tag\n");
4132 feed = av_mallocz(sizeof(FFStream));
4133 get_arg(feed->filename, sizeof(feed->filename), &p);
4134 q = strrchr(feed->filename, '>');
4138 for (s = first_feed; s; s = s->next) {
4139 if (!strcmp(feed->filename, s->filename)) {
4140 ERROR("Feed '%s' already registered\n", s->filename);
4144 feed->fmt = av_guess_format("ffm", NULL, NULL);
4145 /* defaut feed file */
4146 snprintf(feed->feed_filename, sizeof(feed->feed_filename),
4147 "/tmp/%s.ffm", feed->filename);
4148 feed->feed_max_size = 5 * 1024 * 1024;
4150 feed->feed = feed; /* self feeding :-) */
4152 /* add in stream list */
4153 *last_stream = feed;
4154 last_stream = &feed->next;
4155 /* add in feed list */
4157 last_feed = &feed->next_feed;
4159 } else if (!av_strcasecmp(cmd, "Launch")) {
4163 feed->child_argv = av_mallocz(64 * sizeof(char *));
4165 for (i = 0; i < 62; i++) {
4166 get_arg(arg, sizeof(arg), &p);
4170 feed->child_argv[i] = av_strdup(arg);
4173 feed->child_argv[i] = av_malloc(30 + strlen(feed->filename));
4175 snprintf(feed->child_argv[i], 30+strlen(feed->filename),
4177 (my_http_addr.sin_addr.s_addr == INADDR_ANY) ? "127.0.0.1" :
4178 inet_ntoa(my_http_addr.sin_addr),
4179 ntohs(my_http_addr.sin_port), feed->filename);
4181 } else if (!av_strcasecmp(cmd, "ReadOnlyFile")) {
4183 get_arg(feed->feed_filename, sizeof(feed->feed_filename), &p);
4185 } else if (stream) {
4186 get_arg(stream->feed_filename, sizeof(stream->feed_filename), &p);
4188 } else if (!av_strcasecmp(cmd, "File")) {
4190 get_arg(feed->feed_filename, sizeof(feed->feed_filename), &p);
4192 get_arg(stream->feed_filename, sizeof(stream->feed_filename), &p);
4193 } else if (!av_strcasecmp(cmd, "Truncate")) {
4195 get_arg(arg, sizeof(arg), &p);
4196 feed->truncate = strtod(arg, NULL);
4198 } else if (!av_strcasecmp(cmd, "FileMaxSize")) {
4203 get_arg(arg, sizeof(arg), &p);
4205 fsize = strtod(p1, &p1);
4206 switch(toupper(*p1)) {
4211 fsize *= 1024 * 1024;
4214 fsize *= 1024 * 1024 * 1024;
4217 feed->feed_max_size = (int64_t)fsize;
4218 if (feed->feed_max_size < FFM_PACKET_SIZE*4) {
4219 ERROR("Feed max file size is too small, must be at least %d\n", FFM_PACKET_SIZE*4);
4222 } else if (!av_strcasecmp(cmd, "</Feed>")) {
4224 ERROR("No corresponding <Feed> for </Feed>\n");
4227 } else if (!av_strcasecmp(cmd, "<Stream")) {
4228 /*********************************************/
4229 /* Stream related options */
4231 if (stream || feed) {
4232 ERROR("Already in a tag\n");
4235 stream = av_mallocz(sizeof(FFStream));
4236 get_arg(stream->filename, sizeof(stream->filename), &p);
4237 q = strrchr(stream->filename, '>');
4241 for (s = first_stream; s; s = s->next) {
4242 if (!strcmp(stream->filename, s->filename)) {
4243 ERROR("Stream '%s' already registered\n", s->filename);
4247 stream->fmt = ffserver_guess_format(NULL, stream->filename, NULL);
4248 avcodec_get_context_defaults3(&video_enc, NULL);
4249 avcodec_get_context_defaults3(&audio_enc, NULL);
4251 audio_id = AV_CODEC_ID_NONE;
4252 video_id = AV_CODEC_ID_NONE;
4254 audio_id = stream->fmt->audio_codec;
4255 video_id = stream->fmt->video_codec;
4258 *last_stream = stream;
4259 last_stream = &stream->next;
4261 } else if (!av_strcasecmp(cmd, "Feed")) {
4262 get_arg(arg, sizeof(arg), &p);
4267 while (sfeed != NULL) {
4268 if (!strcmp(sfeed->filename, arg))
4270 sfeed = sfeed->next_feed;
4273 ERROR("feed '%s' not defined\n", arg);
4275 stream->feed = sfeed;
4277 } else if (!av_strcasecmp(cmd, "Format")) {
4278 get_arg(arg, sizeof(arg), &p);
4280 if (!strcmp(arg, "status")) {
4281 stream->stream_type = STREAM_TYPE_STATUS;
4284 stream->stream_type = STREAM_TYPE_LIVE;
4285 /* jpeg cannot be used here, so use single frame jpeg */
4286 if (!strcmp(arg, "jpeg"))
4287 strcpy(arg, "mjpeg");
4288 stream->fmt = ffserver_guess_format(arg, NULL, NULL);
4290 ERROR("Unknown Format: %s\n", arg);
4294 audio_id = stream->fmt->audio_codec;
4295 video_id = stream->fmt->video_codec;
4298 } else if (!av_strcasecmp(cmd, "InputFormat")) {
4299 get_arg(arg, sizeof(arg), &p);
4301 stream->ifmt = av_find_input_format(arg);
4302 if (!stream->ifmt) {
4303 ERROR("Unknown input format: %s\n", arg);
4306 } else if (!av_strcasecmp(cmd, "FaviconURL")) {
4307 if (stream && stream->stream_type == STREAM_TYPE_STATUS) {
4308 get_arg(stream->feed_filename, sizeof(stream->feed_filename), &p);
4310 ERROR("FaviconURL only permitted for status streams\n");
4312 } else if (!av_strcasecmp(cmd, "Author")) {
4314 get_arg(stream->author, sizeof(stream->author), &p);
4315 } else if (!av_strcasecmp(cmd, "Comment")) {
4317 get_arg(stream->comment, sizeof(stream->comment), &p);
4318 } else if (!av_strcasecmp(cmd, "Copyright")) {
4320 get_arg(stream->copyright, sizeof(stream->copyright), &p);
4321 } else if (!av_strcasecmp(cmd, "Title")) {
4323 get_arg(stream->title, sizeof(stream->title), &p);
4324 } else if (!av_strcasecmp(cmd, "Preroll")) {
4325 get_arg(arg, sizeof(arg), &p);
4327 stream->prebuffer = atof(arg) * 1000;
4328 } else if (!av_strcasecmp(cmd, "StartSendOnKey")) {
4330 stream->send_on_key = 1;
4331 } else if (!av_strcasecmp(cmd, "AudioCodec")) {
4332 get_arg(arg, sizeof(arg), &p);
4333 audio_id = opt_audio_codec(arg);
4334 if (audio_id == AV_CODEC_ID_NONE) {
4335 ERROR("Unknown AudioCodec: %s\n", arg);
4337 } else if (!av_strcasecmp(cmd, "VideoCodec")) {
4338 get_arg(arg, sizeof(arg), &p);
4339 video_id = opt_video_codec(arg);
4340 if (video_id == AV_CODEC_ID_NONE) {
4341 ERROR("Unknown VideoCodec: %s\n", arg);
4343 } else if (!av_strcasecmp(cmd, "MaxTime")) {
4344 get_arg(arg, sizeof(arg), &p);
4346 stream->max_time = atof(arg) * 1000;
4347 } else if (!av_strcasecmp(cmd, "AudioBitRate")) {
4348 get_arg(arg, sizeof(arg), &p);
4350 audio_enc.bit_rate = lrintf(atof(arg) * 1000);
4351 } else if (!av_strcasecmp(cmd, "AudioChannels")) {
4352 get_arg(arg, sizeof(arg), &p);
4354 audio_enc.channels = atoi(arg);
4355 } else if (!av_strcasecmp(cmd, "AudioSampleRate")) {
4356 get_arg(arg, sizeof(arg), &p);
4358 audio_enc.sample_rate = atoi(arg);
4359 } else if (!av_strcasecmp(cmd, "AudioQuality")) {
4360 get_arg(arg, sizeof(arg), &p);
4362 // audio_enc.quality = atof(arg) * 1000;
4364 } else if (!av_strcasecmp(cmd, "VideoBitRateRange")) {
4366 int minrate, maxrate;
4368 get_arg(arg, sizeof(arg), &p);
4370 if (sscanf(arg, "%d-%d", &minrate, &maxrate) == 2) {
4371 video_enc.rc_min_rate = minrate * 1000;
4372 video_enc.rc_max_rate = maxrate * 1000;
4374 ERROR("Incorrect format for VideoBitRateRange -- should be <min>-<max>: %s\n", arg);
4377 } else if (!av_strcasecmp(cmd, "Debug")) {
4379 get_arg(arg, sizeof(arg), &p);
4380 video_enc.debug = strtol(arg,0,0);
4382 } else if (!av_strcasecmp(cmd, "Strict")) {
4384 get_arg(arg, sizeof(arg), &p);
4385 video_enc.strict_std_compliance = atoi(arg);
4387 } else if (!av_strcasecmp(cmd, "VideoBufferSize")) {
4389 get_arg(arg, sizeof(arg), &p);
4390 video_enc.rc_buffer_size = atoi(arg) * 8*1024;
4392 } else if (!av_strcasecmp(cmd, "VideoBitRateTolerance")) {
4394 get_arg(arg, sizeof(arg), &p);
4395 video_enc.bit_rate_tolerance = atoi(arg) * 1000;
4397 } else if (!av_strcasecmp(cmd, "VideoBitRate")) {
4398 get_arg(arg, sizeof(arg), &p);
4400 video_enc.bit_rate = atoi(arg) * 1000;
4402 } else if (!av_strcasecmp(cmd, "VideoSize")) {
4403 get_arg(arg, sizeof(arg), &p);
4405 av_parse_video_size(&video_enc.width, &video_enc.height, arg);
4406 if ((video_enc.width % 16) != 0 ||
4407 (video_enc.height % 16) != 0) {
4408 ERROR("Image size must be a multiple of 16\n");
4411 } else if (!av_strcasecmp(cmd, "VideoFrameRate")) {
4412 get_arg(arg, sizeof(arg), &p);
4414 AVRational frame_rate;
4415 if (av_parse_video_rate(&frame_rate, arg) < 0) {
4416 ERROR("Incorrect frame rate: %s\n", arg);
4418 video_enc.time_base.num = frame_rate.den;
4419 video_enc.time_base.den = frame_rate.num;
4422 } else if (!av_strcasecmp(cmd, "VideoGopSize")) {
4423 get_arg(arg, sizeof(arg), &p);
4425 video_enc.gop_size = atoi(arg);
4426 } else if (!av_strcasecmp(cmd, "VideoIntraOnly")) {
4428 video_enc.gop_size = 1;
4429 } else if (!av_strcasecmp(cmd, "VideoHighQuality")) {
4431 video_enc.mb_decision = FF_MB_DECISION_BITS;
4432 } else if (!av_strcasecmp(cmd, "Video4MotionVector")) {
4434 video_enc.mb_decision = FF_MB_DECISION_BITS; //FIXME remove
4435 video_enc.flags |= CODEC_FLAG_4MV;
4437 } else if (!av_strcasecmp(cmd, "AVOptionVideo") ||
4438 !av_strcasecmp(cmd, "AVOptionAudio")) {
4440 AVCodecContext *avctx;
4442 get_arg(arg, sizeof(arg), &p);
4443 get_arg(arg2, sizeof(arg2), &p);
4444 if (!av_strcasecmp(cmd, "AVOptionVideo")) {
4446 type = AV_OPT_FLAG_VIDEO_PARAM;
4449 type = AV_OPT_FLAG_AUDIO_PARAM;
4451 if (ffserver_opt_default(arg, arg2, avctx, type|AV_OPT_FLAG_ENCODING_PARAM)) {
4452 ERROR("AVOption error: %s %s\n", arg, arg2);
4454 } else if (!av_strcasecmp(cmd, "AVPresetVideo") ||
4455 !av_strcasecmp(cmd, "AVPresetAudio")) {
4456 AVCodecContext *avctx;
4458 get_arg(arg, sizeof(arg), &p);
4459 if (!av_strcasecmp(cmd, "AVPresetVideo")) {
4461 video_enc.codec_id = video_id;
4462 type = AV_OPT_FLAG_VIDEO_PARAM;
4465 audio_enc.codec_id = audio_id;
4466 type = AV_OPT_FLAG_AUDIO_PARAM;
4468 if (ffserver_opt_preset(arg, avctx, type|AV_OPT_FLAG_ENCODING_PARAM, &audio_id, &video_id)) {
4469 ERROR("AVPreset error: %s\n", arg);
4471 } else if (!av_strcasecmp(cmd, "VideoTag")) {
4472 get_arg(arg, sizeof(arg), &p);
4473 if ((strlen(arg) == 4) && stream)
4474 video_enc.codec_tag = MKTAG(arg[0], arg[1], arg[2], arg[3]);
4475 } else if (!av_strcasecmp(cmd, "BitExact")) {
4477 video_enc.flags |= CODEC_FLAG_BITEXACT;
4478 } else if (!av_strcasecmp(cmd, "DctFastint")) {
4480 video_enc.dct_algo = FF_DCT_FASTINT;
4481 } else if (!av_strcasecmp(cmd, "IdctSimple")) {
4483 video_enc.idct_algo = FF_IDCT_SIMPLE;
4484 } else if (!av_strcasecmp(cmd, "Qscale")) {
4485 get_arg(arg, sizeof(arg), &p);
4487 video_enc.flags |= CODEC_FLAG_QSCALE;
4488 video_enc.global_quality = FF_QP2LAMBDA * atoi(arg);
4490 } else if (!av_strcasecmp(cmd, "VideoQDiff")) {
4491 get_arg(arg, sizeof(arg), &p);
4493 video_enc.max_qdiff = atoi(arg);
4494 if (video_enc.max_qdiff < 1 || video_enc.max_qdiff > 31) {
4495 ERROR("VideoQDiff out of range\n");
4498 } else if (!av_strcasecmp(cmd, "VideoQMax")) {
4499 get_arg(arg, sizeof(arg), &p);
4501 video_enc.qmax = atoi(arg);
4502 if (video_enc.qmax < 1 || video_enc.qmax > 31) {
4503 ERROR("VideoQMax out of range\n");
4506 } else if (!av_strcasecmp(cmd, "VideoQMin")) {
4507 get_arg(arg, sizeof(arg), &p);
4509 video_enc.qmin = atoi(arg);
4510 if (video_enc.qmin < 1 || video_enc.qmin > 31) {
4511 ERROR("VideoQMin out of range\n");
4514 } else if (!av_strcasecmp(cmd, "LumaElim")) {
4515 get_arg(arg, sizeof(arg), &p);
4517 video_enc.luma_elim_threshold = atoi(arg);
4518 } else if (!av_strcasecmp(cmd, "ChromaElim")) {
4519 get_arg(arg, sizeof(arg), &p);
4521 video_enc.chroma_elim_threshold = atoi(arg);
4522 } else if (!av_strcasecmp(cmd, "LumiMask")) {
4523 get_arg(arg, sizeof(arg), &p);
4525 video_enc.lumi_masking = atof(arg);
4526 } else if (!av_strcasecmp(cmd, "DarkMask")) {
4527 get_arg(arg, sizeof(arg), &p);
4529 video_enc.dark_masking = atof(arg);
4530 } else if (!av_strcasecmp(cmd, "NoVideo")) {
4531 video_id = AV_CODEC_ID_NONE;
4532 } else if (!av_strcasecmp(cmd, "NoAudio")) {
4533 audio_id = AV_CODEC_ID_NONE;
4534 } else if (!av_strcasecmp(cmd, "ACL")) {
4535 parse_acl_row(stream, feed, NULL, p, filename, line_num);
4536 } else if (!av_strcasecmp(cmd, "DynamicACL")) {
4538 get_arg(stream->dynamic_acl, sizeof(stream->dynamic_acl), &p);
4540 } else if (!av_strcasecmp(cmd, "RTSPOption")) {
4541 get_arg(arg, sizeof(arg), &p);
4543 av_freep(&stream->rtsp_option);
4544 stream->rtsp_option = av_strdup(arg);
4546 } else if (!av_strcasecmp(cmd, "MulticastAddress")) {
4547 get_arg(arg, sizeof(arg), &p);
4549 if (resolve_host(&stream->multicast_ip, arg) != 0) {
4550 ERROR("Invalid host/IP address: %s\n", arg);
4552 stream->is_multicast = 1;
4553 stream->loop = 1; /* default is looping */
4555 } else if (!av_strcasecmp(cmd, "MulticastPort")) {
4556 get_arg(arg, sizeof(arg), &p);
4558 stream->multicast_port = atoi(arg);
4559 } else if (!av_strcasecmp(cmd, "MulticastTTL")) {
4560 get_arg(arg, sizeof(arg), &p);
4562 stream->multicast_ttl = atoi(arg);
4563 } else if (!av_strcasecmp(cmd, "NoLoop")) {
4566 } else if (!av_strcasecmp(cmd, "</Stream>")) {
4568 ERROR("No corresponding <Stream> for </Stream>\n");
4570 if (stream->feed && stream->fmt && strcmp(stream->fmt->name, "ffm") != 0) {
4571 if (audio_id != AV_CODEC_ID_NONE) {
4572 audio_enc.codec_type = AVMEDIA_TYPE_AUDIO;
4573 audio_enc.codec_id = audio_id;
4574 add_codec(stream, &audio_enc);
4576 if (video_id != AV_CODEC_ID_NONE) {
4577 video_enc.codec_type = AVMEDIA_TYPE_VIDEO;
4578 video_enc.codec_id = video_id;
4579 add_codec(stream, &video_enc);
4584 } else if (!av_strcasecmp(cmd, "<Redirect")) {
4585 /*********************************************/
4587 if (stream || feed || redirect) {
4588 ERROR("Already in a tag\n");
4590 redirect = av_mallocz(sizeof(FFStream));
4591 *last_stream = redirect;
4592 last_stream = &redirect->next;
4594 get_arg(redirect->filename, sizeof(redirect->filename), &p);
4595 q = strrchr(redirect->filename, '>');
4598 redirect->stream_type = STREAM_TYPE_REDIRECT;
4600 } else if (!av_strcasecmp(cmd, "URL")) {
4602 get_arg(redirect->feed_filename, sizeof(redirect->feed_filename), &p);
4603 } else if (!av_strcasecmp(cmd, "</Redirect>")) {
4605 ERROR("No corresponding <Redirect> for </Redirect>\n");
4607 if (!redirect->feed_filename[0]) {
4608 ERROR("No URL found for <Redirect>\n");
4612 } else if (!av_strcasecmp(cmd, "LoadModule")) {
4613 get_arg(arg, sizeof(arg), &p);
4617 ERROR("Module support not compiled into this version: '%s'\n", arg);
4620 ERROR("Incorrect keyword: '%s'\n", cmd);
4632 static void handle_child_exit(int sig)
4637 while ((pid = waitpid(-1, &status, WNOHANG)) > 0) {
4640 for (feed = first_feed; feed; feed = feed->next) {
4641 if (feed->pid == pid) {
4642 int uptime = time(0) - feed->pid_start;
4645 fprintf(stderr, "%s: Pid %d exited with status %d after %d seconds\n", feed->filename, pid, status, uptime);
4648 /* Turn off any more restarts */
4649 feed->child_argv = 0;
4654 need_to_start_children = 1;
4657 static void opt_debug(void)
4660 ffserver_daemon = 0;
4661 logfilename[0] = '-';
4664 void show_help_default(const char *opt, const char *arg)
4666 printf("usage: ffserver [options]\n"
4667 "Hyper fast multi format Audio/Video streaming server\n");
4669 show_help_options(options, "Main options:", 0, 0, 0);
4672 static const OptionDef options[] = {
4673 #include "cmdutils_common_opts.h"
4674 { "n", OPT_BOOL, {(void *)&no_launch }, "enable no-launch mode" },
4675 { "d", 0, {(void*)opt_debug}, "enable debug mode" },
4676 { "f", HAS_ARG | OPT_STRING, {(void*)&config_filename }, "use configfile instead of /etc/ffserver.conf", "configfile" },
4680 int main(int argc, char **argv)
4682 struct sigaction sigact = { { 0 } };
4684 parse_loglevel(argc, argv, options);
4686 avformat_network_init();
4688 show_banner(argc, argv, options);
4690 my_program_name = argv[0];
4691 my_program_dir = getcwd(0, 0);
4692 ffserver_daemon = 1;
4694 parse_options(NULL, argc, argv, options, NULL);
4696 unsetenv("http_proxy"); /* Kill the http_proxy */
4698 av_lfg_init(&random_state, av_get_random_seed());
4700 sigact.sa_handler = handle_child_exit;
4701 sigact.sa_flags = SA_NOCLDSTOP | SA_RESTART;
4702 sigaction(SIGCHLD, &sigact, 0);
4704 if (parse_ffconfig(config_filename) < 0) {
4705 fprintf(stderr, "Incorrect config file - exiting.\n");
4709 /* open log file if needed */
4710 if (logfilename[0] != '\0') {
4711 if (!strcmp(logfilename, "-"))
4714 logfile = fopen(logfilename, "a");
4715 av_log_set_callback(http_av_log);
4718 build_file_streams();
4720 build_feed_streams();
4722 compute_bandwidth();
4724 /* put the process in background and detach it from its TTY */
4725 if (ffserver_daemon) {
4732 } else if (pid > 0) {
4739 open("/dev/null", O_RDWR);
4740 if (strcmp(logfilename, "-") != 0) {
4750 signal(SIGPIPE, SIG_IGN);
4752 if (ffserver_daemon)
4755 if (http_server() < 0) {
4756 http_log("Could not start server\n");