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
33 #include "libavformat/avformat.h"
34 // FIXME those are internal headers, ffserver _really_ shouldn't use them
35 #include "libavformat/ffm.h"
36 #include "libavformat/network.h"
37 #include "libavformat/os_support.h"
38 #include "libavformat/rtpdec.h"
39 #include "libavformat/rtpproto.h"
40 #include "libavformat/rtsp.h"
41 #include "libavformat/avio_internal.h"
42 #include "libavformat/internal.h"
43 #include "libavformat/url.h"
45 #include "libavutil/avassert.h"
46 #include "libavutil/avstring.h"
47 #include "libavutil/lfg.h"
48 #include "libavutil/dict.h"
49 #include "libavutil/intreadwrite.h"
50 #include "libavutil/mathematics.h"
51 #include "libavutil/pixdesc.h"
52 #include "libavutil/random_seed.h"
53 #include "libavutil/parseutils.h"
54 #include "libavutil/opt.h"
55 #include "libavutil/time.h"
60 #include <sys/ioctl.h>
71 const char program_name[] = "ffserver";
72 const int program_birth_year = 2000;
74 static const OptionDef options[];
77 HTTPSTATE_WAIT_REQUEST,
78 HTTPSTATE_SEND_HEADER,
79 HTTPSTATE_SEND_DATA_HEADER,
80 HTTPSTATE_SEND_DATA, /* sending TCP or UDP data */
81 HTTPSTATE_SEND_DATA_TRAILER,
82 HTTPSTATE_RECEIVE_DATA,
83 HTTPSTATE_WAIT_FEED, /* wait for data from the feed */
86 RTSPSTATE_WAIT_REQUEST,
88 RTSPSTATE_SEND_PACKET,
91 static const char *http_state[] = {
107 #define MAX_STREAMS 20
109 #define IOBUFFER_INIT_SIZE 8192
111 /* timeouts are in ms */
112 #define HTTP_REQUEST_TIMEOUT (15 * 1000)
113 #define RTSP_REQUEST_TIMEOUT (3600 * 24 * 1000)
115 #define SYNC_TIMEOUT (10 * 1000)
117 typedef struct RTSPActionServerSetup {
119 char transport_option[512];
120 } RTSPActionServerSetup;
123 int64_t count1, count2;
124 int64_t time1, time2;
127 /* context associated with one connection */
128 typedef struct HTTPContext {
129 enum HTTPState state;
130 int fd; /* socket file descriptor */
131 struct sockaddr_in from_addr; /* origin */
132 struct pollfd *poll_entry; /* used when polling */
134 uint8_t *buffer_ptr, *buffer_end;
137 int chunked_encoding;
138 int chunk_size; /* 0 if it needs to be read */
139 struct HTTPContext *next;
140 int got_key_frame; /* stream 0 => 1, stream 1 => 2, stream 2=> 4 */
144 /* input format handling */
145 AVFormatContext *fmt_in;
146 int64_t start_time; /* In milliseconds - this wraps fairly often */
147 int64_t first_pts; /* initial pts value */
148 int64_t cur_pts; /* current pts value from the stream in us */
149 int64_t cur_frame_duration; /* duration of the current frame in us */
150 int cur_frame_bytes; /* output frame size, needed to compute
151 the time at which we send each
153 int pts_stream_index; /* stream we choose as clock reference */
154 int64_t cur_clock; /* current clock reference value in us */
155 /* output format handling */
156 struct FFStream *stream;
157 /* -1 is invalid stream */
158 int feed_streams[MAX_STREAMS]; /* index of streams in the feed */
159 int switch_feed_streams[MAX_STREAMS]; /* index of streams in the feed */
161 AVFormatContext fmt_ctx; /* instance of FFStream for one user */
162 int last_packet_sent; /* true if last data packet was sent */
164 DataRateData datarate;
171 int is_packetized; /* if true, the stream is packetized */
172 int packet_stream_index; /* current stream for output in state machine */
174 /* RTSP state specific */
175 uint8_t *pb_buffer; /* XXX: use that in all the code */
177 int seq; /* RTSP sequence number */
179 /* RTP state specific */
180 enum RTSPLowerTransport rtp_protocol;
181 char session_id[32]; /* session id */
182 AVFormatContext *rtp_ctx[MAX_STREAMS];
184 /* RTP/UDP specific */
185 URLContext *rtp_handles[MAX_STREAMS];
187 /* RTP/TCP specific */
188 struct HTTPContext *rtsp_c;
189 uint8_t *packet_buffer, *packet_buffer_ptr, *packet_buffer_end;
192 /* each generated stream is described here */
196 STREAM_TYPE_REDIRECT,
199 enum IPAddressAction {
204 typedef struct IPAddressACL {
205 struct IPAddressACL *next;
206 enum IPAddressAction action;
207 /* These are in host order */
208 struct in_addr first;
212 /* description of each stream of the ffserver.conf file */
213 typedef struct FFStream {
214 enum StreamType stream_type;
215 char filename[1024]; /* stream filename */
216 struct FFStream *feed; /* feed we are using (can be null if
218 AVDictionary *in_opts; /* input parameters */
219 AVDictionary *metadata; /* metadata to set on the stream */
220 AVInputFormat *ifmt; /* if non NULL, force input format */
223 char dynamic_acl[1024];
225 int prebuffer; /* Number of millseconds early to start */
226 int64_t max_time; /* Number of milliseconds to run */
228 AVStream *streams[MAX_STREAMS];
229 int feed_streams[MAX_STREAMS]; /* index of streams in the feed */
230 char feed_filename[1024]; /* file name of the feed storage, or
231 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;
307 static const char *config_filename;
309 static int ffserver_debug;
310 static int no_launch;
311 static int need_to_start_children;
313 /* maximum number of simultaneous HTTP connections */
314 static unsigned int nb_max_http_connections = 2000;
315 static unsigned int nb_max_connections = 5;
316 static unsigned int nb_connections;
318 static uint64_t max_bandwidth = 1000;
319 static uint64_t current_bandwidth;
321 static int64_t cur_time; // Making this global saves on passing it around everywhere
323 static AVLFG random_state;
325 static FILE *logfile = NULL;
327 static void htmlstrip(char *s) {
329 s += strspn(s, "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ,. ");
335 static int64_t ffm_read_write_index(int fd)
339 if (lseek(fd, 8, SEEK_SET) < 0)
341 if (read(fd, buf, 8) != 8)
346 static int ffm_write_write_index(int fd, int64_t pos)
352 buf[i] = (pos >> (56 - i * 8)) & 0xff;
353 if (lseek(fd, 8, SEEK_SET) < 0)
355 if (write(fd, buf, 8) != 8)
360 static void ffm_set_write_index(AVFormatContext *s, int64_t pos,
363 FFMContext *ffm = s->priv_data;
364 ffm->write_index = pos;
365 ffm->file_size = file_size;
368 /* FIXME: make ffserver work with IPv6 */
369 /* resolve host with also IP address parsing */
370 static int resolve_host(struct in_addr *sin_addr, const char *hostname)
373 if (!ff_inet_aton(hostname, sin_addr)) {
375 struct addrinfo *ai, *cur;
376 struct addrinfo hints = { 0 };
377 hints.ai_family = AF_INET;
378 if (getaddrinfo(hostname, NULL, &hints, &ai))
380 /* getaddrinfo returns a linked list of addrinfo structs.
381 * Even if we set ai_family = AF_INET above, make sure
382 * that the returned one actually is of the correct type. */
383 for (cur = ai; cur; cur = cur->ai_next) {
384 if (cur->ai_family == AF_INET) {
385 *sin_addr = ((struct sockaddr_in *)cur->ai_addr)->sin_addr;
394 hp = gethostbyname(hostname);
397 memcpy(sin_addr, hp->h_addr_list[0], sizeof(struct in_addr));
403 static char *ctime1(char *buf2, int buf_size)
410 av_strlcpy(buf2, p, buf_size);
411 p = buf2 + strlen(p) - 1;
417 static void http_vlog(const char *fmt, va_list vargs)
419 static int print_prefix = 1;
423 ctime1(buf, sizeof(buf));
424 fprintf(logfile, "%s ", buf);
426 print_prefix = strstr(fmt, "\n") != NULL;
427 vfprintf(logfile, fmt, vargs);
433 __attribute__ ((format (printf, 1, 2)))
435 static void http_log(const char *fmt, ...)
438 va_start(vargs, fmt);
439 http_vlog(fmt, vargs);
443 static void http_av_log(void *ptr, int level, const char *fmt, va_list vargs)
445 static int print_prefix = 1;
446 AVClass *avc = ptr ? *(AVClass**)ptr : NULL;
447 if (level > av_log_get_level())
449 if (print_prefix && avc)
450 http_log("[%s @ %p]", avc->item_name(ptr), ptr);
451 print_prefix = strstr(fmt, "\n") != NULL;
452 http_vlog(fmt, vargs);
455 static void log_connection(HTTPContext *c)
460 http_log("%s - - [%s] \"%s %s\" %d %"PRId64"\n",
461 inet_ntoa(c->from_addr.sin_addr), c->method, c->url,
462 c->protocol, (c->http_error ? c->http_error : 200), c->data_count);
465 static void update_datarate(DataRateData *drd, int64_t count)
467 if (!drd->time1 && !drd->count1) {
468 drd->time1 = drd->time2 = cur_time;
469 drd->count1 = drd->count2 = count;
470 } else if (cur_time - drd->time2 > 5000) {
471 drd->time1 = drd->time2;
472 drd->count1 = drd->count2;
473 drd->time2 = cur_time;
478 /* In bytes per second */
479 static int compute_datarate(DataRateData *drd, int64_t count)
481 if (cur_time == drd->time1)
484 return ((count - drd->count1) * 1000) / (cur_time - drd->time1);
488 static void start_children(FFStream *feed)
493 for (; feed; feed = feed->next) {
494 if (feed->child_argv && !feed->pid) {
495 feed->pid_start = time(0);
500 http_log("Unable to create children\n");
509 /* replace "ffserver" with "ffmpeg" in the path of current program,
510 * ignore user provided path */
511 av_strlcpy(pathname, my_program_name, sizeof(pathname));
512 slash = strrchr(pathname, '/');
517 strcpy(slash, "ffmpeg");
519 http_log("Launch command line: ");
520 http_log("%s ", pathname);
521 for (i = 1; feed->child_argv[i] && feed->child_argv[i][0]; i++)
522 http_log("%s ", feed->child_argv[i]);
525 for (i = 3; i < 256; i++)
528 if (!ffserver_debug) {
529 if (!freopen("/dev/null", "r", stdin))
530 http_log("failed to redirect STDIN to /dev/null\n;");
531 if (!freopen("/dev/null", "w", stdout))
532 http_log("failed to redirect STDOUT to /dev/null\n;");
533 if (!freopen("/dev/null", "w", stderr))
534 http_log("failed to redirect STDERR to /dev/null\n;");
537 signal(SIGPIPE, SIG_DFL);
539 execvp(pathname, feed->child_argv);
547 /* open a listening socket */
548 static int socket_open_listen(struct sockaddr_in *my_addr)
552 server_fd = socket(AF_INET,SOCK_STREAM,0);
559 setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR, &tmp, sizeof(tmp));
561 my_addr->sin_family = AF_INET;
562 if (bind (server_fd, (struct sockaddr *) my_addr, sizeof (*my_addr)) < 0) {
564 snprintf(bindmsg, sizeof(bindmsg), "bind(port %d)", ntohs(my_addr->sin_port));
566 closesocket(server_fd);
570 if (listen (server_fd, 5) < 0) {
572 closesocket(server_fd);
575 ff_socket_nonblock(server_fd, 1);
580 /* start all multicast streams */
581 static void start_multicast(void)
586 struct sockaddr_in dest_addr = {0};
587 int default_port, stream_index;
590 for(stream = first_stream; stream != NULL; stream = stream->next) {
591 if (stream->is_multicast) {
592 unsigned random0 = av_lfg_get(&random_state);
593 unsigned random1 = av_lfg_get(&random_state);
594 /* open the RTP connection */
595 snprintf(session_id, sizeof(session_id), "%08x%08x",
598 /* choose a port if none given */
599 if (stream->multicast_port == 0) {
600 stream->multicast_port = default_port;
604 dest_addr.sin_family = AF_INET;
605 dest_addr.sin_addr = stream->multicast_ip;
606 dest_addr.sin_port = htons(stream->multicast_port);
608 rtp_c = rtp_new_connection(&dest_addr, stream, session_id,
609 RTSP_LOWER_TRANSPORT_UDP_MULTICAST);
613 if (open_input_stream(rtp_c, "") < 0) {
614 http_log("Could not open input stream for stream '%s'\n",
619 /* open each RTP stream */
620 for(stream_index = 0; stream_index < stream->nb_streams;
622 dest_addr.sin_port = htons(stream->multicast_port +
624 if (rtp_new_av_stream(rtp_c, stream_index, &dest_addr, NULL) < 0) {
625 http_log("Could not open output stream '%s/streamid=%d'\n",
626 stream->filename, stream_index);
631 /* change state to send data */
632 rtp_c->state = HTTPSTATE_SEND_DATA;
637 /* main loop of the http server */
638 static int http_server(void)
640 int server_fd = 0, rtsp_server_fd = 0;
641 int ret, delay, delay1;
642 struct pollfd *poll_table, *poll_entry;
643 HTTPContext *c, *c_next;
645 if(!(poll_table = av_mallocz((nb_max_http_connections + 2)*sizeof(*poll_table)))) {
646 http_log("Impossible to allocate a poll table handling %d connections.\n", nb_max_http_connections);
650 if (my_http_addr.sin_port) {
651 server_fd = socket_open_listen(&my_http_addr);
656 if (my_rtsp_addr.sin_port) {
657 rtsp_server_fd = socket_open_listen(&my_rtsp_addr);
658 if (rtsp_server_fd < 0)
662 if (!rtsp_server_fd && !server_fd) {
663 http_log("HTTP and RTSP disabled.\n");
667 http_log("FFserver started.\n");
669 start_children(first_feed);
674 poll_entry = poll_table;
676 poll_entry->fd = server_fd;
677 poll_entry->events = POLLIN;
680 if (rtsp_server_fd) {
681 poll_entry->fd = rtsp_server_fd;
682 poll_entry->events = POLLIN;
686 /* wait for events on each HTTP handle */
693 case HTTPSTATE_SEND_HEADER:
694 case RTSPSTATE_SEND_REPLY:
695 case RTSPSTATE_SEND_PACKET:
696 c->poll_entry = poll_entry;
698 poll_entry->events = POLLOUT;
701 case HTTPSTATE_SEND_DATA_HEADER:
702 case HTTPSTATE_SEND_DATA:
703 case HTTPSTATE_SEND_DATA_TRAILER:
704 if (!c->is_packetized) {
705 /* for TCP, we output as much as we can (may need to put a limit) */
706 c->poll_entry = poll_entry;
708 poll_entry->events = POLLOUT;
711 /* when ffserver is doing the timing, we work by
712 looking at which packet need to be sent every
714 delay1 = 10; /* one tick wait XXX: 10 ms assumed */
719 case HTTPSTATE_WAIT_REQUEST:
720 case HTTPSTATE_RECEIVE_DATA:
721 case HTTPSTATE_WAIT_FEED:
722 case RTSPSTATE_WAIT_REQUEST:
723 /* need to catch errors */
724 c->poll_entry = poll_entry;
726 poll_entry->events = POLLIN;/* Maybe this will work */
730 c->poll_entry = NULL;
736 /* wait for an event on one connection. We poll at least every
737 second to handle timeouts */
739 ret = poll(poll_table, poll_entry - poll_table, delay);
740 if (ret < 0 && ff_neterrno() != AVERROR(EAGAIN) &&
741 ff_neterrno() != AVERROR(EINTR))
745 cur_time = av_gettime() / 1000;
747 if (need_to_start_children) {
748 need_to_start_children = 0;
749 start_children(first_feed);
752 /* now handle the events */
753 for(c = first_http_ctx; c != NULL; c = c_next) {
755 if (handle_connection(c) < 0) {
756 /* close and free the connection */
762 poll_entry = poll_table;
764 /* new HTTP connection request ? */
765 if (poll_entry->revents & POLLIN)
766 new_connection(server_fd, 0);
769 if (rtsp_server_fd) {
770 /* new RTSP connection request ? */
771 if (poll_entry->revents & POLLIN)
772 new_connection(rtsp_server_fd, 1);
777 /* start waiting for a new HTTP/RTSP request */
778 static void start_wait_request(HTTPContext *c, int is_rtsp)
780 c->buffer_ptr = c->buffer;
781 c->buffer_end = c->buffer + c->buffer_size - 1; /* leave room for '\0' */
784 c->timeout = cur_time + RTSP_REQUEST_TIMEOUT;
785 c->state = RTSPSTATE_WAIT_REQUEST;
787 c->timeout = cur_time + HTTP_REQUEST_TIMEOUT;
788 c->state = HTTPSTATE_WAIT_REQUEST;
792 static void http_send_too_busy_reply(int fd)
795 int len = snprintf(buffer, sizeof(buffer),
796 "HTTP/1.0 503 Server too busy\r\n"
797 "Content-type: text/html\r\n"
799 "<html><head><title>Too busy</title></head><body>\r\n"
800 "<p>The server is too busy to serve your request at this time.</p>\r\n"
801 "<p>The number of current connections is %u, and this exceeds the limit of %u.</p>\r\n"
802 "</body></html>\r\n",
803 nb_connections, nb_max_connections);
804 av_assert0(len < sizeof(buffer));
805 send(fd, buffer, len, 0);
809 static void new_connection(int server_fd, int is_rtsp)
811 struct sockaddr_in from_addr;
814 HTTPContext *c = NULL;
816 len = sizeof(from_addr);
817 fd = accept(server_fd, (struct sockaddr *)&from_addr,
820 http_log("error during accept %s\n", strerror(errno));
823 ff_socket_nonblock(fd, 1);
825 if (nb_connections >= nb_max_connections) {
826 http_send_too_busy_reply(fd);
830 /* add a new connection */
831 c = av_mallocz(sizeof(HTTPContext));
836 c->poll_entry = NULL;
837 c->from_addr = from_addr;
838 c->buffer_size = IOBUFFER_INIT_SIZE;
839 c->buffer = av_malloc(c->buffer_size);
843 c->next = first_http_ctx;
847 start_wait_request(c, is_rtsp);
859 static void close_connection(HTTPContext *c)
861 HTTPContext **cp, *c1;
863 AVFormatContext *ctx;
867 /* remove connection from list */
868 cp = &first_http_ctx;
869 while ((*cp) != NULL) {
877 /* remove references, if any (XXX: do it faster) */
878 for(c1 = first_http_ctx; c1 != NULL; c1 = c1->next) {
883 /* remove connection associated resources */
887 /* close each frame parser */
888 for(i=0;i<c->fmt_in->nb_streams;i++) {
889 st = c->fmt_in->streams[i];
890 if (st->codec->codec)
891 avcodec_close(st->codec);
893 avformat_close_input(&c->fmt_in);
896 /* free RTP output streams if any */
899 nb_streams = c->stream->nb_streams;
901 for(i=0;i<nb_streams;i++) {
904 av_write_trailer(ctx);
905 av_dict_free(&ctx->metadata);
906 av_free(ctx->streams[0]);
909 h = c->rtp_handles[i];
916 if (!c->last_packet_sent && c->state == HTTPSTATE_SEND_DATA_TRAILER) {
919 if (avio_open_dyn_buf(&ctx->pb) >= 0) {
920 av_write_trailer(ctx);
921 av_freep(&c->pb_buffer);
922 avio_close_dyn_buf(ctx->pb, &c->pb_buffer);
927 for(i=0; i<ctx->nb_streams; i++)
928 av_free(ctx->streams[i]);
929 av_freep(&ctx->streams);
930 av_freep(&ctx->priv_data);
932 if (c->stream && !c->post && c->stream->stream_type == STREAM_TYPE_LIVE)
933 current_bandwidth -= c->stream->bandwidth;
935 /* signal that there is no feed if we are the feeder socket */
936 if (c->state == HTTPSTATE_RECEIVE_DATA && c->stream) {
937 c->stream->feed_opened = 0;
941 av_freep(&c->pb_buffer);
942 av_freep(&c->packet_buffer);
948 static int handle_connection(HTTPContext *c)
953 case HTTPSTATE_WAIT_REQUEST:
954 case RTSPSTATE_WAIT_REQUEST:
956 if ((c->timeout - cur_time) < 0)
958 if (c->poll_entry->revents & (POLLERR | POLLHUP))
961 /* no need to read if no events */
962 if (!(c->poll_entry->revents & POLLIN))
966 len = recv(c->fd, c->buffer_ptr, 1, 0);
968 if (ff_neterrno() != AVERROR(EAGAIN) &&
969 ff_neterrno() != AVERROR(EINTR))
971 } else if (len == 0) {
974 /* search for end of request. */
976 c->buffer_ptr += len;
978 if ((ptr >= c->buffer + 2 && !memcmp(ptr-2, "\n\n", 2)) ||
979 (ptr >= c->buffer + 4 && !memcmp(ptr-4, "\r\n\r\n", 4))) {
980 /* request found : parse it and reply */
981 if (c->state == HTTPSTATE_WAIT_REQUEST) {
982 ret = http_parse_request(c);
984 ret = rtsp_parse_request(c);
988 } else if (ptr >= c->buffer_end) {
989 /* request too long: cannot do anything */
991 } else goto read_loop;
995 case HTTPSTATE_SEND_HEADER:
996 if (c->poll_entry->revents & (POLLERR | POLLHUP))
999 /* no need to write if no events */
1000 if (!(c->poll_entry->revents & POLLOUT))
1002 len = send(c->fd, c->buffer_ptr, c->buffer_end - c->buffer_ptr, 0);
1004 if (ff_neterrno() != AVERROR(EAGAIN) &&
1005 ff_neterrno() != AVERROR(EINTR)) {
1006 /* error : close connection */
1007 av_freep(&c->pb_buffer);
1011 c->buffer_ptr += len;
1013 c->stream->bytes_served += len;
1014 c->data_count += len;
1015 if (c->buffer_ptr >= c->buffer_end) {
1016 av_freep(&c->pb_buffer);
1017 /* if error, exit */
1020 /* all the buffer was sent : synchronize to the incoming stream */
1021 c->state = HTTPSTATE_SEND_DATA_HEADER;
1022 c->buffer_ptr = c->buffer_end = c->buffer;
1027 case HTTPSTATE_SEND_DATA:
1028 case HTTPSTATE_SEND_DATA_HEADER:
1029 case HTTPSTATE_SEND_DATA_TRAILER:
1030 /* for packetized output, we consider we can always write (the
1031 input streams sets the speed). It may be better to verify
1032 that we do not rely too much on the kernel queues */
1033 if (!c->is_packetized) {
1034 if (c->poll_entry->revents & (POLLERR | POLLHUP))
1037 /* no need to read if no events */
1038 if (!(c->poll_entry->revents & POLLOUT))
1041 if (http_send_data(c) < 0)
1043 /* close connection if trailer sent */
1044 if (c->state == HTTPSTATE_SEND_DATA_TRAILER)
1047 case HTTPSTATE_RECEIVE_DATA:
1048 /* no need to read if no events */
1049 if (c->poll_entry->revents & (POLLERR | POLLHUP))
1051 if (!(c->poll_entry->revents & POLLIN))
1053 if (http_receive_data(c) < 0)
1056 case HTTPSTATE_WAIT_FEED:
1057 /* no need to read if no events */
1058 if (c->poll_entry->revents & (POLLIN | POLLERR | POLLHUP))
1061 /* nothing to do, we'll be waken up by incoming feed packets */
1064 case RTSPSTATE_SEND_REPLY:
1065 if (c->poll_entry->revents & (POLLERR | POLLHUP)) {
1066 av_freep(&c->pb_buffer);
1069 /* no need to write if no events */
1070 if (!(c->poll_entry->revents & POLLOUT))
1072 len = send(c->fd, c->buffer_ptr, c->buffer_end - c->buffer_ptr, 0);
1074 if (ff_neterrno() != AVERROR(EAGAIN) &&
1075 ff_neterrno() != AVERROR(EINTR)) {
1076 /* error : close connection */
1077 av_freep(&c->pb_buffer);
1081 c->buffer_ptr += len;
1082 c->data_count += len;
1083 if (c->buffer_ptr >= c->buffer_end) {
1084 /* all the buffer was sent : wait for a new request */
1085 av_freep(&c->pb_buffer);
1086 start_wait_request(c, 1);
1090 case RTSPSTATE_SEND_PACKET:
1091 if (c->poll_entry->revents & (POLLERR | POLLHUP)) {
1092 av_freep(&c->packet_buffer);
1095 /* no need to write if no events */
1096 if (!(c->poll_entry->revents & POLLOUT))
1098 len = send(c->fd, c->packet_buffer_ptr,
1099 c->packet_buffer_end - c->packet_buffer_ptr, 0);
1101 if (ff_neterrno() != AVERROR(EAGAIN) &&
1102 ff_neterrno() != AVERROR(EINTR)) {
1103 /* error : close connection */
1104 av_freep(&c->packet_buffer);
1108 c->packet_buffer_ptr += len;
1109 if (c->packet_buffer_ptr >= c->packet_buffer_end) {
1110 /* all the buffer was sent : wait for a new request */
1111 av_freep(&c->packet_buffer);
1112 c->state = RTSPSTATE_WAIT_REQUEST;
1116 case HTTPSTATE_READY:
1125 static int extract_rates(char *rates, int ratelen, const char *request)
1129 for (p = request; *p && *p != '\r' && *p != '\n'; ) {
1130 if (av_strncasecmp(p, "Pragma:", 7) == 0) {
1131 const char *q = p + 7;
1133 while (*q && *q != '\n' && av_isspace(*q))
1136 if (av_strncasecmp(q, "stream-switch-entry=", 20) == 0) {
1142 memset(rates, 0xff, ratelen);
1145 while (*q && *q != '\n' && *q != ':')
1148 if (sscanf(q, ":%d:%d", &stream_no, &rate_no) != 2)
1152 if (stream_no < ratelen && stream_no >= 0)
1153 rates[stream_no] = rate_no;
1155 while (*q && *q != '\n' && !av_isspace(*q))
1162 p = strchr(p, '\n');
1172 static int find_stream_in_feed(FFStream *feed, AVCodecContext *codec, int bit_rate)
1175 int best_bitrate = 100000000;
1178 for (i = 0; i < feed->nb_streams; i++) {
1179 AVCodecContext *feed_codec = feed->streams[i]->codec;
1181 if (feed_codec->codec_id != codec->codec_id ||
1182 feed_codec->sample_rate != codec->sample_rate ||
1183 feed_codec->width != codec->width ||
1184 feed_codec->height != codec->height)
1187 /* Potential stream */
1189 /* We want the fastest stream less than bit_rate, or the slowest
1190 * faster than bit_rate
1193 if (feed_codec->bit_rate <= bit_rate) {
1194 if (best_bitrate > bit_rate || feed_codec->bit_rate > best_bitrate) {
1195 best_bitrate = feed_codec->bit_rate;
1199 if (feed_codec->bit_rate < best_bitrate) {
1200 best_bitrate = feed_codec->bit_rate;
1209 static int modify_current_stream(HTTPContext *c, char *rates)
1212 FFStream *req = c->stream;
1213 int action_required = 0;
1215 /* Not much we can do for a feed */
1219 for (i = 0; i < req->nb_streams; i++) {
1220 AVCodecContext *codec = req->streams[i]->codec;
1224 c->switch_feed_streams[i] = req->feed_streams[i];
1227 c->switch_feed_streams[i] = find_stream_in_feed(req->feed, codec, codec->bit_rate / 2);
1230 /* Wants off or slow */
1231 c->switch_feed_streams[i] = find_stream_in_feed(req->feed, codec, codec->bit_rate / 4);
1233 /* This doesn't work well when it turns off the only stream! */
1234 c->switch_feed_streams[i] = -2;
1235 c->feed_streams[i] = -2;
1240 if (c->switch_feed_streams[i] >= 0 && c->switch_feed_streams[i] != c->feed_streams[i])
1241 action_required = 1;
1244 return action_required;
1247 /* XXX: factorize in utils.c ? */
1248 /* XXX: take care with different space meaning */
1249 static void skip_spaces(const char **pp)
1253 while (*p == ' ' || *p == '\t')
1258 static void get_word(char *buf, int buf_size, const char **pp)
1266 while (!av_isspace(*p) && *p != '\0') {
1267 if ((q - buf) < buf_size - 1)
1276 static void get_arg(char *buf, int buf_size, const char **pp)
1283 while (av_isspace(*p)) p++;
1286 if (*p == '\"' || *p == '\'')
1298 if ((q - buf) < buf_size - 1)
1303 if (quote && *p == quote)
1308 static void parse_acl_row(FFStream *stream, FFStream* feed, IPAddressACL *ext_acl,
1309 const char *p, const char *filename, int line_num)
1315 get_arg(arg, sizeof(arg), &p);
1316 if (av_strcasecmp(arg, "allow") == 0)
1317 acl.action = IP_ALLOW;
1318 else if (av_strcasecmp(arg, "deny") == 0)
1319 acl.action = IP_DENY;
1321 fprintf(stderr, "%s:%d: ACL action '%s' is not ALLOW or DENY\n",
1322 filename, line_num, arg);
1326 get_arg(arg, sizeof(arg), &p);
1328 if (resolve_host(&acl.first, arg) != 0) {
1329 fprintf(stderr, "%s:%d: ACL refers to invalid host or ip address '%s'\n",
1330 filename, line_num, arg);
1333 acl.last = acl.first;
1335 get_arg(arg, sizeof(arg), &p);
1338 if (resolve_host(&acl.last, arg) != 0) {
1339 fprintf(stderr, "%s:%d: ACL refers to invalid host or ip address '%s'\n",
1340 filename, line_num, arg);
1346 IPAddressACL *nacl = av_mallocz(sizeof(*nacl));
1347 IPAddressACL **naclp = 0;
1353 naclp = &stream->acl;
1359 fprintf(stderr, "%s:%d: ACL found not in <stream> or <feed>\n",
1360 filename, line_num);
1366 naclp = &(*naclp)->next;
1374 static IPAddressACL* parse_dynamic_acl(FFStream *stream, HTTPContext *c)
1379 IPAddressACL *acl = NULL;
1383 f = fopen(stream->dynamic_acl, "r");
1385 perror(stream->dynamic_acl);
1389 acl = av_mallocz(sizeof(IPAddressACL));
1393 if (fgets(line, sizeof(line), f) == NULL)
1397 while (av_isspace(*p))
1399 if (*p == '\0' || *p == '#')
1401 get_arg(cmd, sizeof(cmd), &p);
1403 if (!av_strcasecmp(cmd, "ACL"))
1404 parse_acl_row(NULL, NULL, acl, p, stream->dynamic_acl, line_num);
1411 static void free_acl_list(IPAddressACL *in_acl)
1413 IPAddressACL *pacl,*pacl2;
1423 static int validate_acl_list(IPAddressACL *in_acl, HTTPContext *c)
1425 enum IPAddressAction last_action = IP_DENY;
1427 struct in_addr *src = &c->from_addr.sin_addr;
1428 unsigned long src_addr = src->s_addr;
1430 for (acl = in_acl; acl; acl = acl->next) {
1431 if (src_addr >= acl->first.s_addr && src_addr <= acl->last.s_addr)
1432 return (acl->action == IP_ALLOW) ? 1 : 0;
1433 last_action = acl->action;
1436 /* Nothing matched, so return not the last action */
1437 return (last_action == IP_DENY) ? 1 : 0;
1440 static int validate_acl(FFStream *stream, HTTPContext *c)
1446 /* if stream->acl is null validate_acl_list will return 1 */
1447 ret = validate_acl_list(stream->acl, c);
1449 if (stream->dynamic_acl[0]) {
1450 acl = parse_dynamic_acl(stream, c);
1452 ret = validate_acl_list(acl, c);
1460 /* compute the real filename of a file by matching it without its
1461 extensions to all the stream filenames */
1462 static void compute_real_filename(char *filename, int max_size)
1469 /* compute filename by matching without the file extensions */
1470 av_strlcpy(file1, filename, sizeof(file1));
1471 p = strrchr(file1, '.');
1474 for(stream = first_stream; stream != NULL; stream = stream->next) {
1475 av_strlcpy(file2, stream->filename, sizeof(file2));
1476 p = strrchr(file2, '.');
1479 if (!strcmp(file1, file2)) {
1480 av_strlcpy(filename, stream->filename, max_size);
1495 /* parse http request and prepare header */
1496 static int http_parse_request(HTTPContext *c)
1500 enum RedirType redir_type;
1502 char info[1024], filename[1024];
1506 const char *mime_type;
1510 const char *useragent = 0;
1513 get_word(cmd, sizeof(cmd), &p);
1514 av_strlcpy(c->method, cmd, sizeof(c->method));
1516 if (!strcmp(cmd, "GET"))
1518 else if (!strcmp(cmd, "POST"))
1523 get_word(url, sizeof(url), &p);
1524 av_strlcpy(c->url, url, sizeof(c->url));
1526 get_word(protocol, sizeof(protocol), (const char **)&p);
1527 if (strcmp(protocol, "HTTP/1.0") && strcmp(protocol, "HTTP/1.1"))
1530 av_strlcpy(c->protocol, protocol, sizeof(c->protocol));
1533 http_log("%s - - New connection: %s %s\n", inet_ntoa(c->from_addr.sin_addr), cmd, url);
1535 /* find the filename and the optional info string in the request */
1536 p1 = strchr(url, '?');
1538 av_strlcpy(info, p1, sizeof(info));
1543 av_strlcpy(filename, url + ((*url == '/') ? 1 : 0), sizeof(filename)-1);
1545 for (p = c->buffer; *p && *p != '\r' && *p != '\n'; ) {
1546 if (av_strncasecmp(p, "User-Agent:", 11) == 0) {
1548 if (*useragent && *useragent != '\n' && av_isspace(*useragent))
1552 p = strchr(p, '\n');
1559 redir_type = REDIR_NONE;
1560 if (av_match_ext(filename, "asx")) {
1561 redir_type = REDIR_ASX;
1562 filename[strlen(filename)-1] = 'f';
1563 } else if (av_match_ext(filename, "asf") &&
1564 (!useragent || av_strncasecmp(useragent, "NSPlayer", 8) != 0)) {
1565 /* if this isn't WMP or lookalike, return the redirector file */
1566 redir_type = REDIR_ASF;
1567 } else if (av_match_ext(filename, "rpm,ram")) {
1568 redir_type = REDIR_RAM;
1569 strcpy(filename + strlen(filename)-2, "m");
1570 } else if (av_match_ext(filename, "rtsp")) {
1571 redir_type = REDIR_RTSP;
1572 compute_real_filename(filename, sizeof(filename) - 1);
1573 } else if (av_match_ext(filename, "sdp")) {
1574 redir_type = REDIR_SDP;
1575 compute_real_filename(filename, sizeof(filename) - 1);
1578 // "redirect" / request to index.html
1579 if (!strlen(filename))
1580 av_strlcpy(filename, "index.html", sizeof(filename) - 1);
1582 stream = first_stream;
1583 while (stream != NULL) {
1584 if (!strcmp(stream->filename, filename) && validate_acl(stream, c))
1586 stream = stream->next;
1588 if (stream == NULL) {
1589 snprintf(msg, sizeof(msg), "File '%s' not found", url);
1590 http_log("File '%s' not found\n", url);
1595 memcpy(c->feed_streams, stream->feed_streams, sizeof(c->feed_streams));
1596 memset(c->switch_feed_streams, -1, sizeof(c->switch_feed_streams));
1598 if (stream->stream_type == STREAM_TYPE_REDIRECT) {
1599 c->http_error = 301;
1601 snprintf(q, c->buffer_size,
1602 "HTTP/1.0 301 Moved\r\n"
1604 "Content-type: text/html\r\n"
1606 "<html><head><title>Moved</title></head><body>\r\n"
1607 "You should be <a href=\"%s\">redirected</a>.\r\n"
1608 "</body></html>\r\n", stream->feed_filename, stream->feed_filename);
1610 /* prepare output buffer */
1611 c->buffer_ptr = c->buffer;
1613 c->state = HTTPSTATE_SEND_HEADER;
1617 /* If this is WMP, get the rate information */
1618 if (extract_rates(ratebuf, sizeof(ratebuf), c->buffer)) {
1619 if (modify_current_stream(c, ratebuf)) {
1620 for (i = 0; i < FF_ARRAY_ELEMS(c->feed_streams); i++) {
1621 if (c->switch_feed_streams[i] >= 0)
1622 c->switch_feed_streams[i] = -1;
1627 if (c->post == 0 && stream->stream_type == STREAM_TYPE_LIVE)
1628 current_bandwidth += stream->bandwidth;
1630 /* If already streaming this feed, do not let start another feeder. */
1631 if (stream->feed_opened) {
1632 snprintf(msg, sizeof(msg), "This feed is already being received.");
1633 http_log("Feed '%s' already being received\n", stream->feed_filename);
1637 if (c->post == 0 && max_bandwidth < current_bandwidth) {
1638 c->http_error = 503;
1640 snprintf(q, c->buffer_size,
1641 "HTTP/1.0 503 Server too busy\r\n"
1642 "Content-type: text/html\r\n"
1644 "<html><head><title>Too busy</title></head><body>\r\n"
1645 "<p>The server is too busy to serve your request at this time.</p>\r\n"
1646 "<p>The bandwidth being served (including your stream) is %"PRIu64"kbit/sec, "
1647 "and this exceeds the limit of %"PRIu64"kbit/sec.</p>\r\n"
1648 "</body></html>\r\n", current_bandwidth, max_bandwidth);
1650 /* prepare output buffer */
1651 c->buffer_ptr = c->buffer;
1653 c->state = HTTPSTATE_SEND_HEADER;
1657 if (redir_type != REDIR_NONE) {
1658 const char *hostinfo = 0;
1660 for (p = c->buffer; *p && *p != '\r' && *p != '\n'; ) {
1661 if (av_strncasecmp(p, "Host:", 5) == 0) {
1665 p = strchr(p, '\n');
1676 while (av_isspace(*hostinfo))
1679 eoh = strchr(hostinfo, '\n');
1681 if (eoh[-1] == '\r')
1684 if (eoh - hostinfo < sizeof(hostbuf) - 1) {
1685 memcpy(hostbuf, hostinfo, eoh - hostinfo);
1686 hostbuf[eoh - hostinfo] = 0;
1688 c->http_error = 200;
1690 switch(redir_type) {
1692 snprintf(q, c->buffer_size,
1693 "HTTP/1.0 200 ASX Follows\r\n"
1694 "Content-type: video/x-ms-asf\r\n"
1696 "<ASX Version=\"3\">\r\n"
1697 //"<!-- Autogenerated by ffserver -->\r\n"
1698 "<ENTRY><REF HREF=\"http://%s/%s%s\"/></ENTRY>\r\n"
1699 "</ASX>\r\n", hostbuf, filename, info);
1703 snprintf(q, c->buffer_size,
1704 "HTTP/1.0 200 RAM Follows\r\n"
1705 "Content-type: audio/x-pn-realaudio\r\n"
1707 "# Autogenerated by ffserver\r\n"
1708 "http://%s/%s%s\r\n", hostbuf, filename, info);
1712 snprintf(q, c->buffer_size,
1713 "HTTP/1.0 200 ASF Redirect follows\r\n"
1714 "Content-type: video/x-ms-asf\r\n"
1717 "Ref1=http://%s/%s%s\r\n", hostbuf, filename, info);
1722 char hostname[256], *p;
1723 /* extract only hostname */
1724 av_strlcpy(hostname, hostbuf, sizeof(hostname));
1725 p = strrchr(hostname, ':');
1728 snprintf(q, c->buffer_size,
1729 "HTTP/1.0 200 RTSP Redirect follows\r\n"
1730 /* XXX: incorrect mime type ? */
1731 "Content-type: application/x-rtsp\r\n"
1733 "rtsp://%s:%d/%s\r\n", hostname, ntohs(my_rtsp_addr.sin_port), filename);
1742 struct sockaddr_in my_addr;
1744 snprintf(q, c->buffer_size,
1745 "HTTP/1.0 200 OK\r\n"
1746 "Content-type: application/sdp\r\n"
1750 len = sizeof(my_addr);
1751 getsockname(c->fd, (struct sockaddr *)&my_addr, &len);
1753 /* XXX: should use a dynamic buffer */
1754 sdp_data_size = prepare_sdp_description(stream,
1757 if (sdp_data_size > 0) {
1758 memcpy(q, sdp_data, sdp_data_size);
1770 /* prepare output buffer */
1771 c->buffer_ptr = c->buffer;
1773 c->state = HTTPSTATE_SEND_HEADER;
1779 snprintf(msg, sizeof(msg), "ASX/RAM file not handled");
1783 stream->conns_served++;
1785 /* XXX: add there authenticate and IP match */
1788 /* if post, it means a feed is being sent */
1789 if (!stream->is_feed) {
1790 /* However it might be a status report from WMP! Let us log the
1791 * data as it might come in handy one day. */
1792 const char *logline = 0;
1795 for (p = c->buffer; *p && *p != '\r' && *p != '\n'; ) {
1796 if (av_strncasecmp(p, "Pragma: log-line=", 17) == 0) {
1800 if (av_strncasecmp(p, "Pragma: client-id=", 18) == 0)
1801 client_id = strtol(p + 18, 0, 10);
1802 p = strchr(p, '\n');
1810 char *eol = strchr(logline, '\n');
1815 if (eol[-1] == '\r')
1817 http_log("%.*s\n", (int) (eol - logline), logline);
1818 c->suppress_log = 1;
1823 http_log("\nGot request:\n%s\n", c->buffer);
1826 if (client_id && extract_rates(ratebuf, sizeof(ratebuf), c->buffer)) {
1829 /* Now we have to find the client_id */
1830 for (wmpc = first_http_ctx; wmpc; wmpc = wmpc->next) {
1831 if (wmpc->wmp_client_id == client_id)
1835 if (wmpc && modify_current_stream(wmpc, ratebuf))
1836 wmpc->switch_pending = 1;
1839 snprintf(msg, sizeof(msg), "POST command not handled");
1843 if (http_start_receive_data(c) < 0) {
1844 snprintf(msg, sizeof(msg), "could not open feed");
1848 c->state = HTTPSTATE_RECEIVE_DATA;
1853 if (strcmp(stream->filename + strlen(stream->filename) - 4, ".asf") == 0)
1854 http_log("\nGot request:\n%s\n", c->buffer);
1857 if (c->stream->stream_type == STREAM_TYPE_STATUS)
1860 /* open input stream */
1861 if (open_input_stream(c, info) < 0) {
1862 snprintf(msg, sizeof(msg), "Input stream corresponding to '%s' not found", url);
1866 /* prepare http header */
1868 av_strlcatf(c->buffer, c->buffer_size, "HTTP/1.0 200 OK\r\n");
1869 mime_type = c->stream->fmt->mime_type;
1871 mime_type = "application/x-octet-stream";
1872 av_strlcatf(c->buffer, c->buffer_size, "Pragma: no-cache\r\n");
1874 /* for asf, we need extra headers */
1875 if (!strcmp(c->stream->fmt->name,"asf_stream")) {
1876 /* Need to allocate a client id */
1878 c->wmp_client_id = av_lfg_get(&random_state);
1880 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);
1882 av_strlcatf(c->buffer, c->buffer_size, "Content-Type: %s\r\n", mime_type);
1883 av_strlcatf(c->buffer, c->buffer_size, "\r\n");
1884 q = c->buffer + strlen(c->buffer);
1886 /* prepare output buffer */
1888 c->buffer_ptr = c->buffer;
1890 c->state = HTTPSTATE_SEND_HEADER;
1893 c->http_error = 404;
1896 snprintf(q, c->buffer_size,
1897 "HTTP/1.0 404 Not Found\r\n"
1898 "Content-type: text/html\r\n"
1901 "<head><title>404 Not Found</title></head>\n"
1905 /* prepare output buffer */
1906 c->buffer_ptr = c->buffer;
1908 c->state = HTTPSTATE_SEND_HEADER;
1912 c->http_error = 200; /* horrible : we use this value to avoid
1913 going to the send data state */
1914 c->state = HTTPSTATE_SEND_HEADER;
1918 static void fmt_bytecount(AVIOContext *pb, int64_t count)
1920 static const char suffix[] = " kMGTP";
1923 for (s = suffix; count >= 100000 && s[1]; count /= 1000, s++);
1925 avio_printf(pb, "%"PRId64"%c", count, *s);
1928 static void compute_status(HTTPContext *c)
1937 if (avio_open_dyn_buf(&pb) < 0) {
1938 /* XXX: return an error ? */
1939 c->buffer_ptr = c->buffer;
1940 c->buffer_end = c->buffer;
1944 avio_printf(pb, "HTTP/1.0 200 OK\r\n");
1945 avio_printf(pb, "Content-type: %s\r\n", "text/html");
1946 avio_printf(pb, "Pragma: no-cache\r\n");
1947 avio_printf(pb, "\r\n");
1949 avio_printf(pb, "<html><head><title>%s Status</title>\n", program_name);
1950 if (c->stream->feed_filename[0])
1951 avio_printf(pb, "<link rel=\"shortcut icon\" href=\"%s\">\n", c->stream->feed_filename);
1952 avio_printf(pb, "</head>\n<body>");
1953 avio_printf(pb, "<h1>%s Status</h1>\n", program_name);
1955 avio_printf(pb, "<h2>Available Streams</h2>\n");
1956 avio_printf(pb, "<table cellspacing=0 cellpadding=4>\n");
1957 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");
1958 stream = first_stream;
1959 while (stream != NULL) {
1960 char sfilename[1024];
1963 if (stream->feed != stream) {
1964 av_strlcpy(sfilename, stream->filename, sizeof(sfilename) - 10);
1965 eosf = sfilename + strlen(sfilename);
1966 if (eosf - sfilename >= 4) {
1967 if (strcmp(eosf - 4, ".asf") == 0)
1968 strcpy(eosf - 4, ".asx");
1969 else if (strcmp(eosf - 3, ".rm") == 0)
1970 strcpy(eosf - 3, ".ram");
1971 else if (stream->fmt && !strcmp(stream->fmt->name, "rtp")) {
1972 /* generate a sample RTSP director if
1973 unicast. Generate an SDP redirector if
1975 eosf = strrchr(sfilename, '.');
1977 eosf = sfilename + strlen(sfilename);
1978 if (stream->is_multicast)
1979 strcpy(eosf, ".sdp");
1981 strcpy(eosf, ".rtsp");
1985 avio_printf(pb, "<tr><td><a href=\"/%s\">%s</a> ",
1986 sfilename, stream->filename);
1987 avio_printf(pb, "<td align=right> %d <td align=right> ",
1988 stream->conns_served);
1989 fmt_bytecount(pb, stream->bytes_served);
1990 switch(stream->stream_type) {
1991 case STREAM_TYPE_LIVE: {
1992 int audio_bit_rate = 0;
1993 int video_bit_rate = 0;
1994 const char *audio_codec_name = "";
1995 const char *video_codec_name = "";
1996 const char *audio_codec_name_extra = "";
1997 const char *video_codec_name_extra = "";
1999 for(i=0;i<stream->nb_streams;i++) {
2000 AVStream *st = stream->streams[i];
2001 AVCodec *codec = avcodec_find_encoder(st->codec->codec_id);
2002 switch(st->codec->codec_type) {
2003 case AVMEDIA_TYPE_AUDIO:
2004 audio_bit_rate += st->codec->bit_rate;
2006 if (*audio_codec_name)
2007 audio_codec_name_extra = "...";
2008 audio_codec_name = codec->name;
2011 case AVMEDIA_TYPE_VIDEO:
2012 video_bit_rate += st->codec->bit_rate;
2014 if (*video_codec_name)
2015 video_codec_name_extra = "...";
2016 video_codec_name = codec->name;
2019 case AVMEDIA_TYPE_DATA:
2020 video_bit_rate += st->codec->bit_rate;
2026 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",
2029 video_bit_rate / 1000, video_codec_name, video_codec_name_extra,
2030 audio_bit_rate / 1000, audio_codec_name, audio_codec_name_extra);
2032 avio_printf(pb, "<td>%s", stream->feed->filename);
2034 avio_printf(pb, "<td>%s", stream->feed_filename);
2035 avio_printf(pb, "\n");
2039 avio_printf(pb, "<td align=center> - <td align=right> - <td align=right> - <td><td align=right> - <td>\n");
2043 stream = stream->next;
2045 avio_printf(pb, "</table>\n");
2047 stream = first_stream;
2048 while (stream != NULL) {
2049 if (stream->feed == stream) {
2050 avio_printf(pb, "<h2>Feed %s</h2>", stream->filename);
2052 avio_printf(pb, "Running as pid %d.\n", stream->pid);
2059 /* This is somewhat linux specific I guess */
2060 snprintf(ps_cmd, sizeof(ps_cmd),
2061 "ps -o \"%%cpu,cputime\" --no-headers %d",
2064 pid_stat = popen(ps_cmd, "r");
2069 if (fscanf(pid_stat, "%9s %63s", cpuperc,
2071 avio_printf(pb, "Currently using %s%% of the cpu. Total time used %s.\n",
2079 avio_printf(pb, "<p>");
2081 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");
2083 for (i = 0; i < stream->nb_streams; i++) {
2084 AVStream *st = stream->streams[i];
2085 AVCodec *codec = avcodec_find_encoder(st->codec->codec_id);
2086 const char *type = "unknown";
2087 char parameters[64];
2091 switch(st->codec->codec_type) {
2092 case AVMEDIA_TYPE_AUDIO:
2094 snprintf(parameters, sizeof(parameters), "%d channel(s), %d Hz", st->codec->channels, st->codec->sample_rate);
2096 case AVMEDIA_TYPE_VIDEO:
2098 snprintf(parameters, sizeof(parameters), "%dx%d, q=%d-%d, fps=%d", st->codec->width, st->codec->height,
2099 st->codec->qmin, st->codec->qmax, st->codec->time_base.den / st->codec->time_base.num);
2104 avio_printf(pb, "<tr><td align=right>%d<td>%s<td align=right>%d<td>%s<td>%s\n",
2105 i, type, st->codec->bit_rate/1000, codec ? codec->name : "", parameters);
2107 avio_printf(pb, "</table>\n");
2110 stream = stream->next;
2113 /* connection status */
2114 avio_printf(pb, "<h2>Connection Status</h2>\n");
2116 avio_printf(pb, "Number of connections: %d / %d<br>\n",
2117 nb_connections, nb_max_connections);
2119 avio_printf(pb, "Bandwidth in use: %"PRIu64"k / %"PRIu64"k<br>\n",
2120 current_bandwidth, max_bandwidth);
2122 avio_printf(pb, "<table>\n");
2123 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");
2124 c1 = first_http_ctx;
2126 while (c1 != NULL) {
2132 for (j = 0; j < c1->stream->nb_streams; j++) {
2133 if (!c1->stream->feed)
2134 bitrate += c1->stream->streams[j]->codec->bit_rate;
2135 else if (c1->feed_streams[j] >= 0)
2136 bitrate += c1->stream->feed->streams[c1->feed_streams[j]]->codec->bit_rate;
2141 p = inet_ntoa(c1->from_addr.sin_addr);
2142 avio_printf(pb, "<tr><td><b>%d</b><td>%s%s<td>%s<td>%s<td>%s<td align=right>",
2144 c1->stream ? c1->stream->filename : "",
2145 c1->state == HTTPSTATE_RECEIVE_DATA ? "(input)" : "",
2148 http_state[c1->state]);
2149 fmt_bytecount(pb, bitrate);
2150 avio_printf(pb, "<td align=right>");
2151 fmt_bytecount(pb, compute_datarate(&c1->datarate, c1->data_count) * 8);
2152 avio_printf(pb, "<td align=right>");
2153 fmt_bytecount(pb, c1->data_count);
2154 avio_printf(pb, "\n");
2157 avio_printf(pb, "</table>\n");
2162 avio_printf(pb, "<hr size=1 noshade>Generated at %s", p);
2163 avio_printf(pb, "</body>\n</html>\n");
2165 len = avio_close_dyn_buf(pb, &c->pb_buffer);
2166 c->buffer_ptr = c->pb_buffer;
2167 c->buffer_end = c->pb_buffer + len;
2170 static int open_input_stream(HTTPContext *c, const char *info)
2173 char input_filename[1024];
2174 AVFormatContext *s = NULL;
2175 int buf_size, i, ret;
2178 /* find file name */
2179 if (c->stream->feed) {
2180 strcpy(input_filename, c->stream->feed->feed_filename);
2181 buf_size = FFM_PACKET_SIZE;
2182 /* compute position (absolute time) */
2183 if (av_find_info_tag(buf, sizeof(buf), "date", info)) {
2184 if ((ret = av_parse_time(&stream_pos, buf, 0)) < 0) {
2185 http_log("Invalid date specification '%s' for stream\n", buf);
2188 } else if (av_find_info_tag(buf, sizeof(buf), "buffer", info)) {
2189 int prebuffer = strtol(buf, 0, 10);
2190 stream_pos = av_gettime() - prebuffer * (int64_t)1000000;
2192 stream_pos = av_gettime() - c->stream->prebuffer * (int64_t)1000;
2194 strcpy(input_filename, c->stream->feed_filename);
2196 /* compute position (relative time) */
2197 if (av_find_info_tag(buf, sizeof(buf), "date", info)) {
2198 if ((ret = av_parse_time(&stream_pos, buf, 1)) < 0) {
2199 http_log("Invalid date specification '%s' for stream\n", buf);
2205 if (!input_filename[0]) {
2206 http_log("No filename was specified for stream\n");
2207 return AVERROR(EINVAL);
2211 if ((ret = avformat_open_input(&s, input_filename, c->stream->ifmt, &c->stream->in_opts)) < 0) {
2212 http_log("Could not open input '%s': %s\n", input_filename, av_err2str(ret));
2216 /* set buffer size */
2217 if (buf_size > 0) ffio_set_buf_size(s->pb, buf_size);
2219 s->flags |= AVFMT_FLAG_GENPTS;
2221 if (strcmp(s->iformat->name, "ffm") &&
2222 (ret = avformat_find_stream_info(c->fmt_in, NULL)) < 0) {
2223 http_log("Could not find stream info for input '%s'\n", input_filename);
2224 avformat_close_input(&s);
2228 /* choose stream as clock source (we favorize video stream if
2229 present) for packet sending */
2230 c->pts_stream_index = 0;
2231 for(i=0;i<c->stream->nb_streams;i++) {
2232 if (c->pts_stream_index == 0 &&
2233 c->stream->streams[i]->codec->codec_type == AVMEDIA_TYPE_VIDEO) {
2234 c->pts_stream_index = i;
2238 if (c->fmt_in->iformat->read_seek)
2239 av_seek_frame(c->fmt_in, -1, stream_pos, 0);
2240 /* set the start time (needed for maxtime and RTP packet timing) */
2241 c->start_time = cur_time;
2242 c->first_pts = AV_NOPTS_VALUE;
2246 /* return the server clock (in us) */
2247 static int64_t get_server_clock(HTTPContext *c)
2249 /* compute current pts value from system time */
2250 return (cur_time - c->start_time) * 1000;
2253 /* return the estimated time at which the current packet must be sent
2255 static int64_t get_packet_send_clock(HTTPContext *c)
2257 int bytes_left, bytes_sent, frame_bytes;
2259 frame_bytes = c->cur_frame_bytes;
2260 if (frame_bytes <= 0)
2263 bytes_left = c->buffer_end - c->buffer_ptr;
2264 bytes_sent = frame_bytes - bytes_left;
2265 return c->cur_pts + (c->cur_frame_duration * bytes_sent) / frame_bytes;
2270 static int http_prepare_data(HTTPContext *c)
2273 AVFormatContext *ctx;
2275 av_freep(&c->pb_buffer);
2277 case HTTPSTATE_SEND_DATA_HEADER:
2278 memset(&c->fmt_ctx, 0, sizeof(c->fmt_ctx));
2279 av_dict_copy(&(c->fmt_ctx.metadata), c->stream->metadata, 0);
2280 c->fmt_ctx.streams = av_mallocz(sizeof(AVStream *) * c->stream->nb_streams);
2282 for(i=0;i<c->stream->nb_streams;i++) {
2284 c->fmt_ctx.streams[i] = av_mallocz(sizeof(AVStream));
2285 /* if file or feed, then just take streams from FFStream struct */
2286 if (!c->stream->feed ||
2287 c->stream->feed == c->stream)
2288 src = c->stream->streams[i];
2290 src = c->stream->feed->streams[c->stream->feed_streams[i]];
2292 *(c->fmt_ctx.streams[i]) = *src;
2293 c->fmt_ctx.streams[i]->priv_data = 0;
2294 c->fmt_ctx.streams[i]->codec->frame_number = 0; /* XXX: should be done in
2295 AVStream, not in codec */
2297 /* set output format parameters */
2298 c->fmt_ctx.oformat = c->stream->fmt;
2299 c->fmt_ctx.nb_streams = c->stream->nb_streams;
2301 c->got_key_frame = 0;
2303 /* prepare header and save header data in a stream */
2304 if (avio_open_dyn_buf(&c->fmt_ctx.pb) < 0) {
2305 /* XXX: potential leak */
2308 c->fmt_ctx.pb->seekable = 0;
2311 * HACK to avoid mpeg ps muxer to spit many underflow errors
2312 * Default value from FFmpeg
2313 * Try to set it use configuration option
2315 c->fmt_ctx.max_delay = (int)(0.7*AV_TIME_BASE);
2317 if ((ret = avformat_write_header(&c->fmt_ctx, NULL)) < 0) {
2318 http_log("Error writing output header for stream '%s': %s\n",
2319 c->stream->filename, av_err2str(ret));
2322 av_dict_free(&c->fmt_ctx.metadata);
2324 len = avio_close_dyn_buf(c->fmt_ctx.pb, &c->pb_buffer);
2325 c->buffer_ptr = c->pb_buffer;
2326 c->buffer_end = c->pb_buffer + len;
2328 c->state = HTTPSTATE_SEND_DATA;
2329 c->last_packet_sent = 0;
2331 case HTTPSTATE_SEND_DATA:
2332 /* find a new packet */
2333 /* read a packet from the input stream */
2334 if (c->stream->feed)
2335 ffm_set_write_index(c->fmt_in,
2336 c->stream->feed->feed_write_index,
2337 c->stream->feed->feed_size);
2339 if (c->stream->max_time &&
2340 c->stream->max_time + c->start_time - cur_time < 0)
2341 /* We have timed out */
2342 c->state = HTTPSTATE_SEND_DATA_TRAILER;
2346 ret = av_read_frame(c->fmt_in, &pkt);
2348 if (c->stream->feed) {
2349 /* if coming from feed, it means we reached the end of the
2350 ffm file, so must wait for more data */
2351 c->state = HTTPSTATE_WAIT_FEED;
2352 return 1; /* state changed */
2353 } else if (ret == AVERROR(EAGAIN)) {
2354 /* input not ready, come back later */
2357 if (c->stream->loop) {
2358 avformat_close_input(&c->fmt_in);
2359 if (open_input_stream(c, "") < 0)
2364 /* must send trailer now because eof or error */
2365 c->state = HTTPSTATE_SEND_DATA_TRAILER;
2369 int source_index = pkt.stream_index;
2370 /* update first pts if needed */
2371 if (c->first_pts == AV_NOPTS_VALUE) {
2372 c->first_pts = av_rescale_q(pkt.dts, c->fmt_in->streams[pkt.stream_index]->time_base, AV_TIME_BASE_Q);
2373 c->start_time = cur_time;
2375 /* send it to the appropriate stream */
2376 if (c->stream->feed) {
2377 /* if coming from a feed, select the right stream */
2378 if (c->switch_pending) {
2379 c->switch_pending = 0;
2380 for(i=0;i<c->stream->nb_streams;i++) {
2381 if (c->switch_feed_streams[i] == pkt.stream_index)
2382 if (pkt.flags & AV_PKT_FLAG_KEY)
2383 c->switch_feed_streams[i] = -1;
2384 if (c->switch_feed_streams[i] >= 0)
2385 c->switch_pending = 1;
2388 for(i=0;i<c->stream->nb_streams;i++) {
2389 if (c->stream->feed_streams[i] == pkt.stream_index) {
2390 AVStream *st = c->fmt_in->streams[source_index];
2391 pkt.stream_index = i;
2392 if (pkt.flags & AV_PKT_FLAG_KEY &&
2393 (st->codec->codec_type == AVMEDIA_TYPE_VIDEO ||
2394 c->stream->nb_streams == 1))
2395 c->got_key_frame = 1;
2396 if (!c->stream->send_on_key || c->got_key_frame)
2401 AVCodecContext *codec;
2402 AVStream *ist, *ost;
2404 ist = c->fmt_in->streams[source_index];
2405 /* specific handling for RTP: we use several
2406 output stream (one for each RTP
2407 connection). XXX: need more abstract handling */
2408 if (c->is_packetized) {
2409 /* compute send time and duration */
2410 c->cur_pts = av_rescale_q(pkt.dts, ist->time_base, AV_TIME_BASE_Q);
2411 c->cur_pts -= c->first_pts;
2412 c->cur_frame_duration = av_rescale_q(pkt.duration, ist->time_base, AV_TIME_BASE_Q);
2413 /* find RTP context */
2414 c->packet_stream_index = pkt.stream_index;
2415 ctx = c->rtp_ctx[c->packet_stream_index];
2417 av_free_packet(&pkt);
2420 codec = ctx->streams[0]->codec;
2421 /* only one stream per RTP connection */
2422 pkt.stream_index = 0;
2426 codec = ctx->streams[pkt.stream_index]->codec;
2429 if (c->is_packetized) {
2430 int max_packet_size;
2431 if (c->rtp_protocol == RTSP_LOWER_TRANSPORT_TCP)
2432 max_packet_size = RTSP_TCP_MAX_PACKET_SIZE;
2434 max_packet_size = c->rtp_handles[c->packet_stream_index]->max_packet_size;
2435 ret = ffio_open_dyn_packet_buf(&ctx->pb, max_packet_size);
2437 ret = avio_open_dyn_buf(&ctx->pb);
2440 /* XXX: potential leak */
2443 ost = ctx->streams[pkt.stream_index];
2445 ctx->pb->seekable = 0;
2446 if (pkt.dts != AV_NOPTS_VALUE)
2447 pkt.dts = av_rescale_q(pkt.dts, ist->time_base, ost->time_base);
2448 if (pkt.pts != AV_NOPTS_VALUE)
2449 pkt.pts = av_rescale_q(pkt.pts, ist->time_base, ost->time_base);
2450 pkt.duration = av_rescale_q(pkt.duration, ist->time_base, ost->time_base);
2451 if ((ret = av_write_frame(ctx, &pkt)) < 0) {
2452 http_log("Error writing frame to output for stream '%s': %s\n",
2453 c->stream->filename, av_err2str(ret));
2454 c->state = HTTPSTATE_SEND_DATA_TRAILER;
2457 len = avio_close_dyn_buf(ctx->pb, &c->pb_buffer);
2458 c->cur_frame_bytes = len;
2459 c->buffer_ptr = c->pb_buffer;
2460 c->buffer_end = c->pb_buffer + len;
2462 codec->frame_number++;
2464 av_free_packet(&pkt);
2468 av_free_packet(&pkt);
2473 case HTTPSTATE_SEND_DATA_TRAILER:
2474 /* last packet test ? */
2475 if (c->last_packet_sent || c->is_packetized)
2478 /* prepare header */
2479 if (avio_open_dyn_buf(&ctx->pb) < 0) {
2480 /* XXX: potential leak */
2483 c->fmt_ctx.pb->seekable = 0;
2484 av_write_trailer(ctx);
2485 len = avio_close_dyn_buf(ctx->pb, &c->pb_buffer);
2486 c->buffer_ptr = c->pb_buffer;
2487 c->buffer_end = c->pb_buffer + len;
2489 c->last_packet_sent = 1;
2495 /* should convert the format at the same time */
2496 /* send data starting at c->buffer_ptr to the output connection
2497 (either UDP or TCP connection) */
2498 static int http_send_data(HTTPContext *c)
2503 if (c->buffer_ptr >= c->buffer_end) {
2504 ret = http_prepare_data(c);
2508 /* state change requested */
2511 if (c->is_packetized) {
2512 /* RTP data output */
2513 len = c->buffer_end - c->buffer_ptr;
2515 /* fail safe - should never happen */
2517 c->buffer_ptr = c->buffer_end;
2520 len = (c->buffer_ptr[0] << 24) |
2521 (c->buffer_ptr[1] << 16) |
2522 (c->buffer_ptr[2] << 8) |
2524 if (len > (c->buffer_end - c->buffer_ptr))
2526 if ((get_packet_send_clock(c) - get_server_clock(c)) > 0) {
2527 /* nothing to send yet: we can wait */
2531 c->data_count += len;
2532 update_datarate(&c->datarate, c->data_count);
2534 c->stream->bytes_served += len;
2536 if (c->rtp_protocol == RTSP_LOWER_TRANSPORT_TCP) {
2537 /* RTP packets are sent inside the RTSP TCP connection */
2539 int interleaved_index, size;
2541 HTTPContext *rtsp_c;
2544 /* if no RTSP connection left, error */
2547 /* if already sending something, then wait. */
2548 if (rtsp_c->state != RTSPSTATE_WAIT_REQUEST)
2550 if (avio_open_dyn_buf(&pb) < 0)
2552 interleaved_index = c->packet_stream_index * 2;
2553 /* RTCP packets are sent at odd indexes */
2554 if (c->buffer_ptr[1] == 200)
2555 interleaved_index++;
2556 /* write RTSP TCP header */
2558 header[1] = interleaved_index;
2559 header[2] = len >> 8;
2561 avio_write(pb, header, 4);
2562 /* write RTP packet data */
2564 avio_write(pb, c->buffer_ptr, len);
2565 size = avio_close_dyn_buf(pb, &c->packet_buffer);
2566 /* prepare asynchronous TCP sending */
2567 rtsp_c->packet_buffer_ptr = c->packet_buffer;
2568 rtsp_c->packet_buffer_end = c->packet_buffer + size;
2569 c->buffer_ptr += len;
2571 /* send everything we can NOW */
2572 len = send(rtsp_c->fd, rtsp_c->packet_buffer_ptr,
2573 rtsp_c->packet_buffer_end - rtsp_c->packet_buffer_ptr, 0);
2575 rtsp_c->packet_buffer_ptr += len;
2576 if (rtsp_c->packet_buffer_ptr < rtsp_c->packet_buffer_end) {
2577 /* if we could not send all the data, we will
2578 send it later, so a new state is needed to
2579 "lock" the RTSP TCP connection */
2580 rtsp_c->state = RTSPSTATE_SEND_PACKET;
2583 /* all data has been sent */
2584 av_freep(&c->packet_buffer);
2586 /* send RTP packet directly in UDP */
2588 ffurl_write(c->rtp_handles[c->packet_stream_index],
2589 c->buffer_ptr, len);
2590 c->buffer_ptr += len;
2591 /* here we continue as we can send several packets per 10 ms slot */
2594 /* TCP data output */
2595 len = send(c->fd, c->buffer_ptr, c->buffer_end - c->buffer_ptr, 0);
2597 if (ff_neterrno() != AVERROR(EAGAIN) &&
2598 ff_neterrno() != AVERROR(EINTR))
2599 /* error : close connection */
2604 c->buffer_ptr += len;
2606 c->data_count += len;
2607 update_datarate(&c->datarate, c->data_count);
2609 c->stream->bytes_served += len;
2617 static int http_start_receive_data(HTTPContext *c)
2622 if (c->stream->feed_opened) {
2623 http_log("Stream feed '%s' was not opened\n", c->stream->feed_filename);
2624 return AVERROR(EINVAL);
2627 /* Don't permit writing to this one */
2628 if (c->stream->readonly) {
2629 http_log("Cannot write to read-only file '%s'\n", c->stream->feed_filename);
2630 return AVERROR(EINVAL);
2634 fd = open(c->stream->feed_filename, O_RDWR);
2636 ret = AVERROR(errno);
2637 http_log("Could not open feed file '%s': %s\n",
2638 c->stream->feed_filename, strerror(errno));
2643 if (c->stream->truncate) {
2644 /* truncate feed file */
2645 ffm_write_write_index(c->feed_fd, FFM_PACKET_SIZE);
2646 http_log("Truncating feed file '%s'\n", c->stream->feed_filename);
2647 if (ftruncate(c->feed_fd, FFM_PACKET_SIZE) < 0) {
2648 ret = AVERROR(errno);
2649 http_log("Error truncating feed file '%s': %s\n",
2650 c->stream->feed_filename, strerror(errno));
2654 ret = ffm_read_write_index(fd);
2656 http_log("Error reading write index from feed file '%s': %s\n",
2657 c->stream->feed_filename, strerror(errno));
2660 c->stream->feed_write_index = ret;
2664 c->stream->feed_write_index = FFMAX(ffm_read_write_index(fd), FFM_PACKET_SIZE);
2665 c->stream->feed_size = lseek(fd, 0, SEEK_END);
2666 lseek(fd, 0, SEEK_SET);
2668 /* init buffer input */
2669 c->buffer_ptr = c->buffer;
2670 c->buffer_end = c->buffer + FFM_PACKET_SIZE;
2671 c->stream->feed_opened = 1;
2672 c->chunked_encoding = !!av_stristr(c->buffer, "Transfer-Encoding: chunked");
2676 static int http_receive_data(HTTPContext *c)
2679 int len, loop_run = 0;
2681 while (c->chunked_encoding && !c->chunk_size &&
2682 c->buffer_end > c->buffer_ptr) {
2683 /* read chunk header, if present */
2684 len = recv(c->fd, c->buffer_ptr, 1, 0);
2687 if (ff_neterrno() != AVERROR(EAGAIN) &&
2688 ff_neterrno() != AVERROR(EINTR))
2689 /* error : close connection */
2692 } else if (len == 0) {
2693 /* end of connection : close it */
2695 } else if (c->buffer_ptr - c->buffer >= 2 &&
2696 !memcmp(c->buffer_ptr - 1, "\r\n", 2)) {
2697 c->chunk_size = strtol(c->buffer, 0, 16);
2698 if (c->chunk_size == 0) // end of stream
2700 c->buffer_ptr = c->buffer;
2702 } else if (++loop_run > 10) {
2703 /* no chunk header, abort */
2710 if (c->buffer_end > c->buffer_ptr) {
2711 len = recv(c->fd, c->buffer_ptr,
2712 FFMIN(c->chunk_size, c->buffer_end - c->buffer_ptr), 0);
2714 if (ff_neterrno() != AVERROR(EAGAIN) &&
2715 ff_neterrno() != AVERROR(EINTR))
2716 /* error : close connection */
2718 } else if (len == 0)
2719 /* end of connection : close it */
2722 c->chunk_size -= len;
2723 c->buffer_ptr += len;
2724 c->data_count += len;
2725 update_datarate(&c->datarate, c->data_count);
2729 if (c->buffer_ptr - c->buffer >= 2 && c->data_count > FFM_PACKET_SIZE) {
2730 if (c->buffer[0] != 'f' ||
2731 c->buffer[1] != 'm') {
2732 http_log("Feed stream has become desynchronized -- disconnecting\n");
2737 if (c->buffer_ptr >= c->buffer_end) {
2738 FFStream *feed = c->stream;
2739 /* a packet has been received : write it in the store, except
2741 if (c->data_count > FFM_PACKET_SIZE) {
2742 /* XXX: use llseek or url_seek */
2743 lseek(c->feed_fd, feed->feed_write_index, SEEK_SET);
2744 if (write(c->feed_fd, c->buffer, FFM_PACKET_SIZE) < 0) {
2745 http_log("Error writing to feed file: %s\n", strerror(errno));
2749 feed->feed_write_index += FFM_PACKET_SIZE;
2750 /* update file size */
2751 if (feed->feed_write_index > c->stream->feed_size)
2752 feed->feed_size = feed->feed_write_index;
2754 /* handle wrap around if max file size reached */
2755 if (c->stream->feed_max_size && feed->feed_write_index >= c->stream->feed_max_size)
2756 feed->feed_write_index = FFM_PACKET_SIZE;
2759 if (ffm_write_write_index(c->feed_fd, feed->feed_write_index) < 0) {
2760 http_log("Error writing index to feed file: %s\n", strerror(errno));
2764 /* wake up any waiting connections */
2765 for(c1 = first_http_ctx; c1 != NULL; c1 = c1->next) {
2766 if (c1->state == HTTPSTATE_WAIT_FEED &&
2767 c1->stream->feed == c->stream->feed)
2768 c1->state = HTTPSTATE_SEND_DATA;
2771 /* We have a header in our hands that contains useful data */
2772 AVFormatContext *s = avformat_alloc_context();
2774 AVInputFormat *fmt_in;
2780 /* use feed output format name to find corresponding input format */
2781 fmt_in = av_find_input_format(feed->fmt->name);
2785 pb = avio_alloc_context(c->buffer, c->buffer_end - c->buffer,
2786 0, NULL, NULL, NULL, NULL);
2790 if (avformat_open_input(&s, c->stream->feed_filename, fmt_in, NULL) < 0) {
2795 /* Now we have the actual streams */
2796 if (s->nb_streams != feed->nb_streams) {
2797 avformat_close_input(&s);
2799 http_log("Feed '%s' stream number does not match registered feed\n",
2800 c->stream->feed_filename);
2804 for (i = 0; i < s->nb_streams; i++) {
2805 AVStream *fst = feed->streams[i];
2806 AVStream *st = s->streams[i];
2807 avcodec_copy_context(fst->codec, st->codec);
2810 avformat_close_input(&s);
2813 c->buffer_ptr = c->buffer;
2818 c->stream->feed_opened = 0;
2820 /* wake up any waiting connections to stop waiting for feed */
2821 for(c1 = first_http_ctx; c1 != NULL; c1 = c1->next) {
2822 if (c1->state == HTTPSTATE_WAIT_FEED &&
2823 c1->stream->feed == c->stream->feed)
2824 c1->state = HTTPSTATE_SEND_DATA_TRAILER;
2829 /********************************************************************/
2832 static void rtsp_reply_header(HTTPContext *c, enum RTSPStatusCode error_number)
2839 switch(error_number) {
2840 case RTSP_STATUS_OK:
2843 case RTSP_STATUS_METHOD:
2844 str = "Method Not Allowed";
2846 case RTSP_STATUS_BANDWIDTH:
2847 str = "Not Enough Bandwidth";
2849 case RTSP_STATUS_SESSION:
2850 str = "Session Not Found";
2852 case RTSP_STATUS_STATE:
2853 str = "Method Not Valid in This State";
2855 case RTSP_STATUS_AGGREGATE:
2856 str = "Aggregate operation not allowed";
2858 case RTSP_STATUS_ONLY_AGGREGATE:
2859 str = "Only aggregate operation allowed";
2861 case RTSP_STATUS_TRANSPORT:
2862 str = "Unsupported transport";
2864 case RTSP_STATUS_INTERNAL:
2865 str = "Internal Server Error";
2867 case RTSP_STATUS_SERVICE:
2868 str = "Service Unavailable";
2870 case RTSP_STATUS_VERSION:
2871 str = "RTSP Version not supported";
2874 str = "Unknown Error";
2878 avio_printf(c->pb, "RTSP/1.0 %d %s\r\n", error_number, str);
2879 avio_printf(c->pb, "CSeq: %d\r\n", c->seq);
2881 /* output GMT time */
2884 strftime(buf2, sizeof(buf2), "%a, %d %b %Y %H:%M:%S", tm);
2885 avio_printf(c->pb, "Date: %s GMT\r\n", buf2);
2888 static void rtsp_reply_error(HTTPContext *c, enum RTSPStatusCode error_number)
2890 rtsp_reply_header(c, error_number);
2891 avio_printf(c->pb, "\r\n");
2894 static int rtsp_parse_request(HTTPContext *c)
2896 const char *p, *p1, *p2;
2902 RTSPMessageHeader header1 = { 0 }, *header = &header1;
2904 c->buffer_ptr[0] = '\0';
2907 get_word(cmd, sizeof(cmd), &p);
2908 get_word(url, sizeof(url), &p);
2909 get_word(protocol, sizeof(protocol), &p);
2911 av_strlcpy(c->method, cmd, sizeof(c->method));
2912 av_strlcpy(c->url, url, sizeof(c->url));
2913 av_strlcpy(c->protocol, protocol, sizeof(c->protocol));
2915 if (avio_open_dyn_buf(&c->pb) < 0) {
2916 /* XXX: cannot do more */
2917 c->pb = NULL; /* safety */
2921 /* check version name */
2922 if (strcmp(protocol, "RTSP/1.0") != 0) {
2923 rtsp_reply_error(c, RTSP_STATUS_VERSION);
2927 /* parse each header line */
2928 /* skip to next line */
2929 while (*p != '\n' && *p != '\0')
2933 while (*p != '\0') {
2934 p1 = memchr(p, '\n', (char *)c->buffer_ptr - p);
2938 if (p2 > p && p2[-1] == '\r')
2940 /* skip empty line */
2944 if (len > sizeof(line) - 1)
2945 len = sizeof(line) - 1;
2946 memcpy(line, p, len);
2948 ff_rtsp_parse_line(header, line, NULL, NULL);
2952 /* handle sequence number */
2953 c->seq = header->seq;
2955 if (!strcmp(cmd, "DESCRIBE"))
2956 rtsp_cmd_describe(c, url);
2957 else if (!strcmp(cmd, "OPTIONS"))
2958 rtsp_cmd_options(c, url);
2959 else if (!strcmp(cmd, "SETUP"))
2960 rtsp_cmd_setup(c, url, header);
2961 else if (!strcmp(cmd, "PLAY"))
2962 rtsp_cmd_play(c, url, header);
2963 else if (!strcmp(cmd, "PAUSE"))
2964 rtsp_cmd_pause(c, url, header);
2965 else if (!strcmp(cmd, "TEARDOWN"))
2966 rtsp_cmd_teardown(c, url, header);
2968 rtsp_reply_error(c, RTSP_STATUS_METHOD);
2971 len = avio_close_dyn_buf(c->pb, &c->pb_buffer);
2972 c->pb = NULL; /* safety */
2974 /* XXX: cannot do more */
2977 c->buffer_ptr = c->pb_buffer;
2978 c->buffer_end = c->pb_buffer + len;
2979 c->state = RTSPSTATE_SEND_REPLY;
2983 static int prepare_sdp_description(FFStream *stream, uint8_t **pbuffer,
2984 struct in_addr my_ip)
2986 AVFormatContext *avc;
2987 AVStream *avs = NULL;
2988 AVOutputFormat *rtp_format = av_guess_format("rtp", NULL, NULL);
2989 AVDictionaryEntry *entry = av_dict_get(stream->metadata, "title", NULL, 0);
2992 avc = avformat_alloc_context();
2993 if (avc == NULL || !rtp_format) {
2996 avc->oformat = rtp_format;
2997 av_dict_set(&avc->metadata, "title",
2998 entry ? entry->value : "No Title", 0);
2999 avc->nb_streams = stream->nb_streams;
3000 if (stream->is_multicast) {
3001 snprintf(avc->filename, 1024, "rtp://%s:%d?multicast=1?ttl=%d",
3002 inet_ntoa(stream->multicast_ip),
3003 stream->multicast_port, stream->multicast_ttl);
3005 snprintf(avc->filename, 1024, "rtp://0.0.0.0");
3008 if (avc->nb_streams >= INT_MAX/sizeof(*avc->streams) ||
3009 !(avc->streams = av_malloc(avc->nb_streams * sizeof(*avc->streams))))
3011 if (avc->nb_streams >= INT_MAX/sizeof(*avs) ||
3012 !(avs = av_malloc(avc->nb_streams * sizeof(*avs))))
3015 for(i = 0; i < stream->nb_streams; i++) {
3016 avc->streams[i] = &avs[i];
3017 avc->streams[i]->codec = stream->streams[i]->codec;
3019 *pbuffer = av_mallocz(2048);
3020 av_sdp_create(&avc, 1, *pbuffer, 2048);
3023 av_free(avc->streams);
3024 av_dict_free(&avc->metadata);
3028 return strlen(*pbuffer);
3031 static void rtsp_cmd_options(HTTPContext *c, const char *url)
3033 // rtsp_reply_header(c, RTSP_STATUS_OK);
3034 avio_printf(c->pb, "RTSP/1.0 %d %s\r\n", RTSP_STATUS_OK, "OK");
3035 avio_printf(c->pb, "CSeq: %d\r\n", c->seq);
3036 avio_printf(c->pb, "Public: %s\r\n", "OPTIONS, DESCRIBE, SETUP, TEARDOWN, PLAY, PAUSE");
3037 avio_printf(c->pb, "\r\n");
3040 static void rtsp_cmd_describe(HTTPContext *c, const char *url)
3048 struct sockaddr_in my_addr;
3050 /* find which url is asked */
3051 av_url_split(NULL, 0, NULL, 0, NULL, 0, NULL, path1, sizeof(path1), url);
3056 for(stream = first_stream; stream != NULL; stream = stream->next) {
3057 if (!stream->is_feed &&
3058 stream->fmt && !strcmp(stream->fmt->name, "rtp") &&
3059 !strcmp(path, stream->filename)) {
3063 /* no stream found */
3064 rtsp_reply_error(c, RTSP_STATUS_SERVICE); /* XXX: right error ? */
3068 /* prepare the media description in sdp format */
3070 /* get the host IP */
3071 len = sizeof(my_addr);
3072 getsockname(c->fd, (struct sockaddr *)&my_addr, &len);
3073 content_length = prepare_sdp_description(stream, &content, my_addr.sin_addr);
3074 if (content_length < 0) {
3075 rtsp_reply_error(c, RTSP_STATUS_INTERNAL);
3078 rtsp_reply_header(c, RTSP_STATUS_OK);
3079 avio_printf(c->pb, "Content-Base: %s/\r\n", url);
3080 avio_printf(c->pb, "Content-Type: application/sdp\r\n");
3081 avio_printf(c->pb, "Content-Length: %d\r\n", content_length);
3082 avio_printf(c->pb, "\r\n");
3083 avio_write(c->pb, content, content_length);
3087 static HTTPContext *find_rtp_session(const char *session_id)
3091 if (session_id[0] == '\0')
3094 for(c = first_http_ctx; c != NULL; c = c->next) {
3095 if (!strcmp(c->session_id, session_id))
3101 static RTSPTransportField *find_transport(RTSPMessageHeader *h, enum RTSPLowerTransport lower_transport)
3103 RTSPTransportField *th;
3106 for(i=0;i<h->nb_transports;i++) {
3107 th = &h->transports[i];
3108 if (th->lower_transport == lower_transport)
3114 static void rtsp_cmd_setup(HTTPContext *c, const char *url,
3115 RTSPMessageHeader *h)
3118 int stream_index, rtp_port, rtcp_port;
3123 RTSPTransportField *th;
3124 struct sockaddr_in dest_addr;
3125 RTSPActionServerSetup setup;
3127 /* find which url is asked */
3128 av_url_split(NULL, 0, NULL, 0, NULL, 0, NULL, path1, sizeof(path1), url);
3133 /* now check each stream */
3134 for(stream = first_stream; stream != NULL; stream = stream->next) {
3135 if (!stream->is_feed &&
3136 stream->fmt && !strcmp(stream->fmt->name, "rtp")) {
3137 /* accept aggregate filenames only if single stream */
3138 if (!strcmp(path, stream->filename)) {
3139 if (stream->nb_streams != 1) {
3140 rtsp_reply_error(c, RTSP_STATUS_AGGREGATE);
3147 for(stream_index = 0; stream_index < stream->nb_streams;
3149 snprintf(buf, sizeof(buf), "%s/streamid=%d",
3150 stream->filename, stream_index);
3151 if (!strcmp(path, buf))
3156 /* no stream found */
3157 rtsp_reply_error(c, RTSP_STATUS_SERVICE); /* XXX: right error ? */
3161 /* generate session id if needed */
3162 if (h->session_id[0] == '\0') {
3163 unsigned random0 = av_lfg_get(&random_state);
3164 unsigned random1 = av_lfg_get(&random_state);
3165 snprintf(h->session_id, sizeof(h->session_id), "%08x%08x",
3169 /* find rtp session, and create it if none found */
3170 rtp_c = find_rtp_session(h->session_id);
3172 /* always prefer UDP */
3173 th = find_transport(h, RTSP_LOWER_TRANSPORT_UDP);
3175 th = find_transport(h, RTSP_LOWER_TRANSPORT_TCP);
3177 rtsp_reply_error(c, RTSP_STATUS_TRANSPORT);
3182 rtp_c = rtp_new_connection(&c->from_addr, stream, h->session_id,
3183 th->lower_transport);
3185 rtsp_reply_error(c, RTSP_STATUS_BANDWIDTH);
3189 /* open input stream */
3190 if (open_input_stream(rtp_c, "") < 0) {
3191 rtsp_reply_error(c, RTSP_STATUS_INTERNAL);
3196 /* test if stream is OK (test needed because several SETUP needs
3197 to be done for a given file) */
3198 if (rtp_c->stream != stream) {
3199 rtsp_reply_error(c, RTSP_STATUS_SERVICE);
3203 /* test if stream is already set up */
3204 if (rtp_c->rtp_ctx[stream_index]) {
3205 rtsp_reply_error(c, RTSP_STATUS_STATE);
3209 /* check transport */
3210 th = find_transport(h, rtp_c->rtp_protocol);
3211 if (!th || (th->lower_transport == RTSP_LOWER_TRANSPORT_UDP &&
3212 th->client_port_min <= 0)) {
3213 rtsp_reply_error(c, RTSP_STATUS_TRANSPORT);
3217 /* setup default options */
3218 setup.transport_option[0] = '\0';
3219 dest_addr = rtp_c->from_addr;
3220 dest_addr.sin_port = htons(th->client_port_min);
3223 if (rtp_new_av_stream(rtp_c, stream_index, &dest_addr, c) < 0) {
3224 rtsp_reply_error(c, RTSP_STATUS_TRANSPORT);
3228 /* now everything is OK, so we can send the connection parameters */
3229 rtsp_reply_header(c, RTSP_STATUS_OK);
3231 avio_printf(c->pb, "Session: %s\r\n", rtp_c->session_id);
3233 switch(rtp_c->rtp_protocol) {
3234 case RTSP_LOWER_TRANSPORT_UDP:
3235 rtp_port = ff_rtp_get_local_rtp_port(rtp_c->rtp_handles[stream_index]);
3236 rtcp_port = ff_rtp_get_local_rtcp_port(rtp_c->rtp_handles[stream_index]);
3237 avio_printf(c->pb, "Transport: RTP/AVP/UDP;unicast;"
3238 "client_port=%d-%d;server_port=%d-%d",
3239 th->client_port_min, th->client_port_max,
3240 rtp_port, rtcp_port);
3242 case RTSP_LOWER_TRANSPORT_TCP:
3243 avio_printf(c->pb, "Transport: RTP/AVP/TCP;interleaved=%d-%d",
3244 stream_index * 2, stream_index * 2 + 1);
3249 if (setup.transport_option[0] != '\0')
3250 avio_printf(c->pb, ";%s", setup.transport_option);
3251 avio_printf(c->pb, "\r\n");
3254 avio_printf(c->pb, "\r\n");
3258 /* find an rtp connection by using the session ID. Check consistency
3260 static HTTPContext *find_rtp_session_with_url(const char *url,
3261 const char *session_id)
3269 rtp_c = find_rtp_session(session_id);
3273 /* find which url is asked */
3274 av_url_split(NULL, 0, NULL, 0, NULL, 0, NULL, path1, sizeof(path1), url);
3278 if(!strcmp(path, rtp_c->stream->filename)) return rtp_c;
3279 for(s=0; s<rtp_c->stream->nb_streams; ++s) {
3280 snprintf(buf, sizeof(buf), "%s/streamid=%d",
3281 rtp_c->stream->filename, s);
3282 if(!strncmp(path, buf, sizeof(buf))) {
3283 // XXX: Should we reply with RTSP_STATUS_ONLY_AGGREGATE if nb_streams>1?
3288 if (len > 0 && path[len - 1] == '/' &&
3289 !strncmp(path, rtp_c->stream->filename, len - 1))
3294 static void rtsp_cmd_play(HTTPContext *c, const char *url, RTSPMessageHeader *h)
3298 rtp_c = find_rtp_session_with_url(url, h->session_id);
3300 rtsp_reply_error(c, RTSP_STATUS_SESSION);
3304 if (rtp_c->state != HTTPSTATE_SEND_DATA &&
3305 rtp_c->state != HTTPSTATE_WAIT_FEED &&
3306 rtp_c->state != HTTPSTATE_READY) {
3307 rtsp_reply_error(c, RTSP_STATUS_STATE);
3311 rtp_c->state = HTTPSTATE_SEND_DATA;
3313 /* now everything is OK, so we can send the connection parameters */
3314 rtsp_reply_header(c, RTSP_STATUS_OK);
3316 avio_printf(c->pb, "Session: %s\r\n", rtp_c->session_id);
3317 avio_printf(c->pb, "\r\n");
3320 static void rtsp_cmd_pause(HTTPContext *c, const char *url, RTSPMessageHeader *h)
3324 rtp_c = find_rtp_session_with_url(url, h->session_id);
3326 rtsp_reply_error(c, RTSP_STATUS_SESSION);
3330 if (rtp_c->state != HTTPSTATE_SEND_DATA &&
3331 rtp_c->state != HTTPSTATE_WAIT_FEED) {
3332 rtsp_reply_error(c, RTSP_STATUS_STATE);
3336 rtp_c->state = HTTPSTATE_READY;
3337 rtp_c->first_pts = AV_NOPTS_VALUE;
3338 /* now everything is OK, so we can send the connection parameters */
3339 rtsp_reply_header(c, RTSP_STATUS_OK);
3341 avio_printf(c->pb, "Session: %s\r\n", rtp_c->session_id);
3342 avio_printf(c->pb, "\r\n");
3345 static void rtsp_cmd_teardown(HTTPContext *c, const char *url, RTSPMessageHeader *h)
3349 rtp_c = find_rtp_session_with_url(url, h->session_id);
3351 rtsp_reply_error(c, RTSP_STATUS_SESSION);
3355 /* now everything is OK, so we can send the connection parameters */
3356 rtsp_reply_header(c, RTSP_STATUS_OK);
3358 avio_printf(c->pb, "Session: %s\r\n", rtp_c->session_id);
3359 avio_printf(c->pb, "\r\n");
3361 /* abort the session */
3362 close_connection(rtp_c);
3366 /********************************************************************/
3369 static HTTPContext *rtp_new_connection(struct sockaddr_in *from_addr,
3370 FFStream *stream, const char *session_id,
3371 enum RTSPLowerTransport rtp_protocol)
3373 HTTPContext *c = NULL;
3374 const char *proto_str;
3376 /* XXX: should output a warning page when coming
3377 close to the connection limit */
3378 if (nb_connections >= nb_max_connections)
3381 /* add a new connection */
3382 c = av_mallocz(sizeof(HTTPContext));
3387 c->poll_entry = NULL;
3388 c->from_addr = *from_addr;
3389 c->buffer_size = IOBUFFER_INIT_SIZE;
3390 c->buffer = av_malloc(c->buffer_size);
3395 av_strlcpy(c->session_id, session_id, sizeof(c->session_id));
3396 c->state = HTTPSTATE_READY;
3397 c->is_packetized = 1;
3398 c->rtp_protocol = rtp_protocol;
3400 /* protocol is shown in statistics */
3401 switch(c->rtp_protocol) {
3402 case RTSP_LOWER_TRANSPORT_UDP_MULTICAST:
3403 proto_str = "MCAST";
3405 case RTSP_LOWER_TRANSPORT_UDP:
3408 case RTSP_LOWER_TRANSPORT_TCP:
3415 av_strlcpy(c->protocol, "RTP/", sizeof(c->protocol));
3416 av_strlcat(c->protocol, proto_str, sizeof(c->protocol));
3418 current_bandwidth += stream->bandwidth;
3420 c->next = first_http_ctx;
3432 /* add a new RTP stream in an RTP connection (used in RTSP SETUP
3433 command). If RTP/TCP protocol is used, TCP connection 'rtsp_c' is
3435 static int rtp_new_av_stream(HTTPContext *c,
3436 int stream_index, struct sockaddr_in *dest_addr,
3437 HTTPContext *rtsp_c)
3439 AVFormatContext *ctx;
3442 URLContext *h = NULL;
3444 int max_packet_size;
3446 /* now we can open the relevant output stream */
3447 ctx = avformat_alloc_context();
3450 ctx->oformat = av_guess_format("rtp", NULL, NULL);
3452 st = av_mallocz(sizeof(AVStream));
3455 ctx->nb_streams = 1;
3456 ctx->streams = av_mallocz(sizeof(AVStream *) * ctx->nb_streams);
3459 ctx->streams[0] = st;
3461 if (!c->stream->feed ||
3462 c->stream->feed == c->stream)
3463 memcpy(st, c->stream->streams[stream_index], sizeof(AVStream));
3466 c->stream->feed->streams[c->stream->feed_streams[stream_index]],
3468 st->priv_data = NULL;
3470 /* build destination RTP address */
3471 ipaddr = inet_ntoa(dest_addr->sin_addr);
3473 switch(c->rtp_protocol) {
3474 case RTSP_LOWER_TRANSPORT_UDP:
3475 case RTSP_LOWER_TRANSPORT_UDP_MULTICAST:
3478 /* XXX: also pass as parameter to function ? */
3479 if (c->stream->is_multicast) {
3481 ttl = c->stream->multicast_ttl;
3484 snprintf(ctx->filename, sizeof(ctx->filename),
3485 "rtp://%s:%d?multicast=1&ttl=%d",
3486 ipaddr, ntohs(dest_addr->sin_port), ttl);
3488 snprintf(ctx->filename, sizeof(ctx->filename),
3489 "rtp://%s:%d", ipaddr, ntohs(dest_addr->sin_port));
3492 if (ffurl_open(&h, ctx->filename, AVIO_FLAG_WRITE, NULL, NULL) < 0)
3494 c->rtp_handles[stream_index] = h;
3495 max_packet_size = h->max_packet_size;
3497 case RTSP_LOWER_TRANSPORT_TCP:
3500 max_packet_size = RTSP_TCP_MAX_PACKET_SIZE;
3506 http_log("%s:%d - - \"PLAY %s/streamid=%d %s\"\n",
3507 ipaddr, ntohs(dest_addr->sin_port),
3508 c->stream->filename, stream_index, c->protocol);
3510 /* normally, no packets should be output here, but the packet size may be checked */
3511 if (ffio_open_dyn_packet_buf(&ctx->pb, max_packet_size) < 0) {
3512 /* XXX: close stream */
3515 if (avformat_write_header(ctx, NULL) < 0) {
3522 avio_close_dyn_buf(ctx->pb, &dummy_buf);
3525 c->rtp_ctx[stream_index] = ctx;
3529 /********************************************************************/
3530 /* ffserver initialization */
3532 static AVStream *add_av_stream1(FFStream *stream, AVCodecContext *codec, int copy)
3536 if(stream->nb_streams >= FF_ARRAY_ELEMS(stream->streams))
3539 fst = av_mallocz(sizeof(AVStream));
3543 fst->codec = avcodec_alloc_context3(NULL);
3544 memcpy(fst->codec, codec, sizeof(AVCodecContext));
3545 if (codec->extradata_size) {
3546 fst->codec->extradata = av_mallocz(codec->extradata_size + FF_INPUT_BUFFER_PADDING_SIZE);
3547 memcpy(fst->codec->extradata, codec->extradata,
3548 codec->extradata_size);
3551 /* live streams must use the actual feed's codec since it may be
3552 * updated later to carry extradata needed by the streams.
3556 fst->priv_data = av_mallocz(sizeof(FeedData));
3557 fst->index = stream->nb_streams;
3558 avpriv_set_pts_info(fst, 33, 1, 90000);
3559 fst->sample_aspect_ratio = codec->sample_aspect_ratio;
3560 stream->streams[stream->nb_streams++] = fst;
3564 /* return the stream number in the feed */
3565 static int add_av_stream(FFStream *feed, AVStream *st)
3568 AVCodecContext *av, *av1;
3572 for(i=0;i<feed->nb_streams;i++) {
3573 st = feed->streams[i];
3575 if (av1->codec_id == av->codec_id &&
3576 av1->codec_type == av->codec_type &&
3577 av1->bit_rate == av->bit_rate) {
3579 switch(av->codec_type) {
3580 case AVMEDIA_TYPE_AUDIO:
3581 if (av1->channels == av->channels &&
3582 av1->sample_rate == av->sample_rate)
3585 case AVMEDIA_TYPE_VIDEO:
3586 if (av1->width == av->width &&
3587 av1->height == av->height &&
3588 av1->time_base.den == av->time_base.den &&
3589 av1->time_base.num == av->time_base.num &&
3590 av1->gop_size == av->gop_size)
3599 fst = add_av_stream1(feed, av, 0);
3602 return feed->nb_streams - 1;
3605 static void remove_stream(FFStream *stream)
3609 while (*ps != NULL) {
3617 /* specific mpeg4 handling : we extract the raw parameters */
3618 static void extract_mpeg4_header(AVFormatContext *infile)
3620 int mpeg4_count, i, size;
3625 infile->flags |= AVFMT_FLAG_NOFILLIN | AVFMT_FLAG_NOPARSE;
3628 for(i=0;i<infile->nb_streams;i++) {
3629 st = infile->streams[i];
3630 if (st->codec->codec_id == AV_CODEC_ID_MPEG4 &&
3631 st->codec->extradata_size == 0) {
3638 printf("MPEG4 without extra data: trying to find header in %s\n", infile->filename);
3639 while (mpeg4_count > 0) {
3640 if (av_read_frame(infile, &pkt) < 0)
3642 st = infile->streams[pkt.stream_index];
3643 if (st->codec->codec_id == AV_CODEC_ID_MPEG4 &&
3644 st->codec->extradata_size == 0) {
3645 av_freep(&st->codec->extradata);
3646 /* fill extradata with the header */
3647 /* XXX: we make hard suppositions here ! */
3649 while (p < pkt.data + pkt.size - 4) {
3650 /* stop when vop header is found */
3651 if (p[0] == 0x00 && p[1] == 0x00 &&
3652 p[2] == 0x01 && p[3] == 0xb6) {
3653 size = p - pkt.data;
3654 // av_hex_dump_log(infile, AV_LOG_DEBUG, pkt.data, size);
3655 st->codec->extradata = av_mallocz(size + FF_INPUT_BUFFER_PADDING_SIZE);
3656 st->codec->extradata_size = size;
3657 memcpy(st->codec->extradata, pkt.data, size);
3664 av_free_packet(&pkt);
3668 /* compute the needed AVStream for each file */
3669 static void build_file_streams(void)
3671 FFStream *stream, *stream_next;
3674 /* gather all streams */
3675 for(stream = first_stream; stream != NULL; stream = stream_next) {
3676 AVFormatContext *infile = NULL;
3677 stream_next = stream->next;
3678 if (stream->stream_type == STREAM_TYPE_LIVE &&
3680 /* the stream comes from a file */
3681 /* try to open the file */
3683 if (stream->fmt && !strcmp(stream->fmt->name, "rtp")) {
3684 /* specific case : if transport stream output to RTP,
3685 we use a raw transport stream reader */
3686 av_dict_set(&stream->in_opts, "mpeg2ts_compute_pcr", "1", 0);
3689 if (!stream->feed_filename[0]) {
3690 http_log("Unspecified feed file for stream '%s'\n", stream->filename);
3694 http_log("Opening feed file '%s' for stream '%s'\n", stream->feed_filename, stream->filename);
3695 if ((ret = avformat_open_input(&infile, stream->feed_filename, stream->ifmt, &stream->in_opts)) < 0) {
3696 http_log("Could not open '%s': %s\n", stream->feed_filename, av_err2str(ret));
3697 /* remove stream (no need to spend more time on it) */
3699 remove_stream(stream);
3701 /* find all the AVStreams inside and reference them in
3703 if (avformat_find_stream_info(infile, NULL) < 0) {
3704 http_log("Could not find codec parameters from '%s'\n",
3705 stream->feed_filename);
3706 avformat_close_input(&infile);
3709 extract_mpeg4_header(infile);
3711 for(i=0;i<infile->nb_streams;i++)
3712 add_av_stream1(stream, infile->streams[i]->codec, 1);
3714 avformat_close_input(&infile);
3720 /* compute the needed AVStream for each feed */
3721 static void build_feed_streams(void)
3723 FFStream *stream, *feed;
3726 /* gather all streams */
3727 for(stream = first_stream; stream != NULL; stream = stream->next) {
3728 feed = stream->feed;
3730 if (stream->is_feed) {
3731 for(i=0;i<stream->nb_streams;i++)
3732 stream->feed_streams[i] = i;
3734 /* we handle a stream coming from a feed */
3735 for(i=0;i<stream->nb_streams;i++)
3736 stream->feed_streams[i] = add_av_stream(feed, stream->streams[i]);
3741 /* create feed files if needed */
3742 for(feed = first_feed; feed != NULL; feed = feed->next_feed) {
3745 if (avio_check(feed->feed_filename, AVIO_FLAG_READ) > 0) {
3746 /* See if it matches */
3747 AVFormatContext *s = NULL;
3750 if (avformat_open_input(&s, feed->feed_filename, NULL, NULL) >= 0) {
3751 /* set buffer size */
3752 ffio_set_buf_size(s->pb, FFM_PACKET_SIZE);
3753 /* Now see if it matches */
3754 if (s->nb_streams == feed->nb_streams) {
3756 for(i=0;i<s->nb_streams;i++) {
3758 sf = feed->streams[i];
3761 if (sf->index != ss->index ||
3763 http_log("Index & Id do not match for stream %d (%s)\n",
3764 i, feed->feed_filename);
3767 AVCodecContext *ccf, *ccs;
3771 #define CHECK_CODEC(x) (ccf->x != ccs->x)
3773 if (CHECK_CODEC(codec_id) || CHECK_CODEC(codec_type)) {
3774 http_log("Codecs do not match for stream %d\n", i);
3776 } else if (CHECK_CODEC(bit_rate) || CHECK_CODEC(flags)) {
3777 http_log("Codec bitrates do not match for stream %d\n", i);
3779 } else if (ccf->codec_type == AVMEDIA_TYPE_VIDEO) {
3780 if (CHECK_CODEC(time_base.den) ||
3781 CHECK_CODEC(time_base.num) ||
3782 CHECK_CODEC(width) ||
3783 CHECK_CODEC(height)) {
3784 http_log("Codec width, height and framerate do not match for stream %d\n", i);
3787 } else if (ccf->codec_type == AVMEDIA_TYPE_AUDIO) {
3788 if (CHECK_CODEC(sample_rate) ||
3789 CHECK_CODEC(channels) ||
3790 CHECK_CODEC(frame_size)) {
3791 http_log("Codec sample_rate, channels, frame_size do not match for stream %d\n", i);
3795 http_log("Unknown codec type\n");
3803 http_log("Deleting feed file '%s' as stream counts differ (%d != %d)\n",
3804 feed->feed_filename, s->nb_streams, feed->nb_streams);
3806 avformat_close_input(&s);
3808 http_log("Deleting feed file '%s' as it appears to be corrupt\n",
3809 feed->feed_filename);
3812 if (feed->readonly) {
3813 http_log("Unable to delete feed file '%s' as it is marked readonly\n",
3814 feed->feed_filename);
3817 unlink(feed->feed_filename);
3820 if (avio_check(feed->feed_filename, AVIO_FLAG_WRITE) <= 0) {
3821 AVFormatContext s1 = {0}, *s = &s1;
3823 if (feed->readonly) {
3824 http_log("Unable to create feed file '%s' as it is marked readonly\n",
3825 feed->feed_filename);
3829 /* only write the header of the ffm file */
3830 if (avio_open(&s->pb, feed->feed_filename, AVIO_FLAG_WRITE) < 0) {
3831 http_log("Could not open output feed file '%s'\n",
3832 feed->feed_filename);
3835 s->oformat = feed->fmt;
3836 s->nb_streams = feed->nb_streams;
3837 s->streams = feed->streams;
3838 if (avformat_write_header(s, NULL) < 0) {
3839 http_log("Container doesn't support the required parameters\n");
3842 /* XXX: need better api */
3843 av_freep(&s->priv_data);
3846 /* get feed size and write index */
3847 fd = open(feed->feed_filename, O_RDONLY);
3849 http_log("Could not open output feed file '%s'\n",
3850 feed->feed_filename);
3854 feed->feed_write_index = FFMAX(ffm_read_write_index(fd), FFM_PACKET_SIZE);
3855 feed->feed_size = lseek(fd, 0, SEEK_END);
3856 /* ensure that we do not wrap before the end of file */
3857 if (feed->feed_max_size && feed->feed_max_size < feed->feed_size)
3858 feed->feed_max_size = feed->feed_size;
3864 /* compute the bandwidth used by each stream */
3865 static void compute_bandwidth(void)
3871 for(stream = first_stream; stream != NULL; stream = stream->next) {
3873 for(i=0;i<stream->nb_streams;i++) {
3874 AVStream *st = stream->streams[i];
3875 switch(st->codec->codec_type) {
3876 case AVMEDIA_TYPE_AUDIO:
3877 case AVMEDIA_TYPE_VIDEO:
3878 bandwidth += st->codec->bit_rate;
3884 stream->bandwidth = (bandwidth + 999) / 1000;
3888 /* add a codec and set the default parameters */
3889 static void add_codec(FFStream *stream, AVCodecContext *av)
3893 if(stream->nb_streams >= FF_ARRAY_ELEMS(stream->streams))
3896 /* compute default parameters */
3897 switch(av->codec_type) {
3898 case AVMEDIA_TYPE_AUDIO:
3899 if (av->bit_rate == 0)
3900 av->bit_rate = 64000;
3901 if (av->sample_rate == 0)
3902 av->sample_rate = 22050;
3903 if (av->channels == 0)
3906 case AVMEDIA_TYPE_VIDEO:
3907 if (av->bit_rate == 0)
3908 av->bit_rate = 64000;
3909 if (av->time_base.num == 0){
3910 av->time_base.den = 5;
3911 av->time_base.num = 1;
3913 if (av->width == 0 || av->height == 0) {
3917 /* Bitrate tolerance is less for streaming */
3918 if (av->bit_rate_tolerance == 0)
3919 av->bit_rate_tolerance = FFMAX(av->bit_rate / 4,
3920 (int64_t)av->bit_rate*av->time_base.num/av->time_base.den);
3925 if (av->max_qdiff == 0)
3927 av->qcompress = 0.5;
3930 if (!av->nsse_weight)
3931 av->nsse_weight = 8;
3933 av->frame_skip_cmp = FF_CMP_DCTMAX;
3935 av->me_method = ME_EPZS;
3936 av->rc_buffer_aggressivity = 1.0;
3939 av->rc_eq = av_strdup("tex^qComp");
3940 if (!av->i_quant_factor)
3941 av->i_quant_factor = -0.8;
3942 if (!av->b_quant_factor)
3943 av->b_quant_factor = 1.25;
3944 if (!av->b_quant_offset)
3945 av->b_quant_offset = 1.25;
3946 if (!av->rc_max_rate)
3947 av->rc_max_rate = av->bit_rate * 2;
3949 if (av->rc_max_rate && !av->rc_buffer_size) {
3950 av->rc_buffer_size = av->rc_max_rate;
3959 st = av_mallocz(sizeof(AVStream));
3962 st->codec = avcodec_alloc_context3(NULL);
3963 stream->streams[stream->nb_streams++] = st;
3964 memcpy(st->codec, av, sizeof(AVCodecContext));
3967 static enum AVCodecID opt_codec(const char *name, enum AVMediaType type)
3969 AVCodec *codec = avcodec_find_encoder_by_name(name);
3971 if (!codec || codec->type != type)
3972 return AV_CODEC_ID_NONE;
3976 static int ffserver_opt_default(const char *opt, const char *arg,
3977 AVCodecContext *avctx, int type)
3980 const AVOption *o = av_opt_find(avctx, opt, NULL, type, 0);
3982 ret = av_opt_set(avctx, opt, arg, 0);
3986 static int ffserver_opt_preset(const char *arg,
3987 AVCodecContext *avctx, int type,
3988 enum AVCodecID *audio_id, enum AVCodecID *video_id)
3991 char filename[1000], tmp[1000], tmp2[1000], line[1000];
3993 AVCodec *codec = avcodec_find_encoder(avctx->codec_id);
3995 if (!(f = get_preset_file(filename, sizeof(filename), arg, 0,
3996 codec ? codec->name : NULL))) {
3997 fprintf(stderr, "File for preset '%s' not found\n", arg);
4002 int e= fscanf(f, "%999[^\n]\n", line) - 1;
4003 if(line[0] == '#' && !e)
4005 e|= sscanf(line, "%999[^=]=%999[^\n]\n", tmp, tmp2) - 2;
4007 fprintf(stderr, "%s: Invalid syntax: '%s'\n", filename, line);
4011 if(!strcmp(tmp, "acodec")){
4012 *audio_id = opt_codec(tmp2, AVMEDIA_TYPE_AUDIO);
4013 }else if(!strcmp(tmp, "vcodec")){
4014 *video_id = opt_codec(tmp2, AVMEDIA_TYPE_VIDEO);
4015 }else if(!strcmp(tmp, "scodec")){
4016 /* opt_subtitle_codec(tmp2); */
4017 }else if(ffserver_opt_default(tmp, tmp2, avctx, type) < 0){
4018 fprintf(stderr, "%s: Invalid option or argument: '%s', parsed as '%s' = '%s'\n", filename, line, tmp, tmp2);
4029 static AVOutputFormat *ffserver_guess_format(const char *short_name, const char *filename,
4030 const char *mime_type)
4032 AVOutputFormat *fmt = av_guess_format(short_name, filename, mime_type);
4035 AVOutputFormat *stream_fmt;
4036 char stream_format_name[64];
4038 snprintf(stream_format_name, sizeof(stream_format_name), "%s_stream", fmt->name);
4039 stream_fmt = av_guess_format(stream_format_name, NULL, NULL);
4048 static void report_config_error(const char *filename, int line_num, int log_level, int *errors, const char *fmt, ...)
4052 av_log(NULL, log_level, "%s:%d: ", filename, line_num);
4053 av_vlog(NULL, log_level, fmt, vl);
4059 static int parse_ffconfig(const char *filename)
4064 char arg[1024], arg2[1024];
4066 int val, errors, warnings, line_num;
4067 FFStream **last_stream, *stream, *redirect;
4068 FFStream **last_feed, *feed, *s;
4069 AVCodecContext audio_enc, video_enc;
4070 enum AVCodecID audio_id, video_id;
4073 f = fopen(filename, "r");
4075 ret = AVERROR(errno);
4076 av_log(NULL, AV_LOG_ERROR, "Could not open the configuration file '%s'\n", filename);
4080 errors = warnings = 0;
4082 first_stream = NULL;
4083 last_stream = &first_stream;
4085 last_feed = &first_feed;
4089 audio_id = AV_CODEC_ID_NONE;
4090 video_id = AV_CODEC_ID_NONE;
4091 #define ERROR(...) report_config_error(filename, line_num, AV_LOG_ERROR, &errors, __VA_ARGS__)
4092 #define WARNING(...) report_config_error(filename, line_num, AV_LOG_WARNING, &warnings, __VA_ARGS__)
4095 if (fgets(line, sizeof(line), f) == NULL)
4099 while (av_isspace(*p))
4101 if (*p == '\0' || *p == '#')
4104 get_arg(cmd, sizeof(cmd), &p);
4106 if (!av_strcasecmp(cmd, "Port")) {
4107 get_arg(arg, sizeof(arg), &p);
4109 if (val < 1 || val > 65536) {
4110 ERROR("Invalid_port: %s\n", arg);
4112 my_http_addr.sin_port = htons(val);
4113 } else if (!av_strcasecmp(cmd, "BindAddress")) {
4114 get_arg(arg, sizeof(arg), &p);
4115 if (resolve_host(&my_http_addr.sin_addr, arg) != 0) {
4116 ERROR("%s:%d: Invalid host/IP address: %s\n", arg);
4118 } else if (!av_strcasecmp(cmd, "NoDaemon")) {
4119 WARNING("NoDaemon option has no effect, you should remove it\n");
4120 } else if (!av_strcasecmp(cmd, "RTSPPort")) {
4121 get_arg(arg, sizeof(arg), &p);
4123 if (val < 1 || val > 65536) {
4124 ERROR("%s:%d: Invalid port: %s\n", arg);
4126 my_rtsp_addr.sin_port = htons(atoi(arg));
4127 } else if (!av_strcasecmp(cmd, "RTSPBindAddress")) {
4128 get_arg(arg, sizeof(arg), &p);
4129 if (resolve_host(&my_rtsp_addr.sin_addr, arg) != 0) {
4130 ERROR("Invalid host/IP address: %s\n", arg);
4132 } else if (!av_strcasecmp(cmd, "MaxHTTPConnections")) {
4133 get_arg(arg, sizeof(arg), &p);
4135 if (val < 1 || val > 65536) {
4136 ERROR("Invalid MaxHTTPConnections: %s\n", arg);
4138 nb_max_http_connections = val;
4139 } else if (!av_strcasecmp(cmd, "MaxClients")) {
4140 get_arg(arg, sizeof(arg), &p);
4142 if (val < 1 || val > nb_max_http_connections) {
4143 ERROR("Invalid MaxClients: %s\n", arg);
4145 nb_max_connections = val;
4147 } else if (!av_strcasecmp(cmd, "MaxBandwidth")) {
4149 get_arg(arg, sizeof(arg), &p);
4150 llval = strtoll(arg, NULL, 10);
4151 if (llval < 10 || llval > 10000000) {
4152 ERROR("Invalid MaxBandwidth: %s\n", arg);
4154 max_bandwidth = llval;
4155 } else if (!av_strcasecmp(cmd, "CustomLog")) {
4156 if (!ffserver_debug)
4157 get_arg(logfilename, sizeof(logfilename), &p);
4158 } else if (!av_strcasecmp(cmd, "<Feed")) {
4159 /*********************************************/
4160 /* Feed related options */
4162 if (stream || feed) {
4163 ERROR("Already in a tag\n");
4165 feed = av_mallocz(sizeof(FFStream));
4167 ret = AVERROR(ENOMEM);
4170 get_arg(feed->filename, sizeof(feed->filename), &p);
4171 q = strrchr(feed->filename, '>');
4175 for (s = first_feed; s; s = s->next) {
4176 if (!strcmp(feed->filename, s->filename)) {
4177 ERROR("Feed '%s' already registered\n", s->filename);
4181 feed->fmt = av_guess_format("ffm", NULL, NULL);
4182 /* default feed file */
4183 snprintf(feed->feed_filename, sizeof(feed->feed_filename),
4184 "/tmp/%s.ffm", feed->filename);
4185 feed->feed_max_size = 5 * 1024 * 1024;
4187 feed->feed = feed; /* self feeding :-) */
4189 /* add in stream list */
4190 *last_stream = feed;
4191 last_stream = &feed->next;
4192 /* add in feed list */
4194 last_feed = &feed->next_feed;
4196 } else if (!av_strcasecmp(cmd, "Launch")) {
4200 feed->child_argv = av_mallocz(64 * sizeof(char *));
4201 if (!feed->child_argv) {
4202 ret = AVERROR(ENOMEM);
4205 for (i = 0; i < 62; i++) {
4206 get_arg(arg, sizeof(arg), &p);
4210 feed->child_argv[i] = av_strdup(arg);
4211 if (!feed->child_argv[i]) {
4212 ret = AVERROR(ENOMEM);
4217 feed->child_argv[i] =
4218 av_asprintf("http://%s:%d/%s",
4219 (my_http_addr.sin_addr.s_addr == INADDR_ANY) ? "127.0.0.1" :
4220 inet_ntoa(my_http_addr.sin_addr), ntohs(my_http_addr.sin_port),
4222 if (!feed->child_argv[i]) {
4223 ret = AVERROR(ENOMEM);
4227 } else if (!av_strcasecmp(cmd, "File") || !av_strcasecmp(cmd, "ReadOnlyFile")) {
4229 get_arg(feed->feed_filename, sizeof(feed->feed_filename), &p);
4230 feed->readonly = !av_strcasecmp(cmd, "ReadOnlyFile");
4231 } else if (stream) {
4232 get_arg(stream->feed_filename, sizeof(stream->feed_filename), &p);
4234 } else if (!av_strcasecmp(cmd, "Truncate")) {
4236 get_arg(arg, sizeof(arg), &p);
4237 /* assume Truncate is true in case no argument is specified */
4241 WARNING("Truncate N syntax in configuration file is deprecated, "
4242 "use Truncate alone with no arguments\n");
4243 feed->truncate = strtod(arg, NULL);
4246 } else if (!av_strcasecmp(cmd, "FileMaxSize")) {
4251 get_arg(arg, sizeof(arg), &p);
4253 fsize = strtod(p1, &p1);
4254 switch(av_toupper(*p1)) {
4259 fsize *= 1024 * 1024;
4262 fsize *= 1024 * 1024 * 1024;
4265 feed->feed_max_size = (int64_t)fsize;
4266 if (feed->feed_max_size < FFM_PACKET_SIZE*4) {
4267 ERROR("Feed max file size is too small, must be at least %d\n", FFM_PACKET_SIZE*4);
4270 } else if (!av_strcasecmp(cmd, "</Feed>")) {
4272 ERROR("No corresponding <Feed> for </Feed>\n");
4275 } else if (!av_strcasecmp(cmd, "<Stream")) {
4276 /*********************************************/
4277 /* Stream related options */
4279 if (stream || feed) {
4280 ERROR("Already in a tag\n");
4283 stream = av_mallocz(sizeof(FFStream));
4285 ret = AVERROR(ENOMEM);
4288 get_arg(stream->filename, sizeof(stream->filename), &p);
4289 q = strrchr(stream->filename, '>');
4293 for (s = first_stream; s; s = s->next) {
4294 if (!strcmp(stream->filename, s->filename)) {
4295 ERROR("Stream '%s' already registered\n", s->filename);
4299 stream->fmt = ffserver_guess_format(NULL, stream->filename, NULL);
4300 avcodec_get_context_defaults3(&video_enc, NULL);
4301 avcodec_get_context_defaults3(&audio_enc, NULL);
4303 audio_id = AV_CODEC_ID_NONE;
4304 video_id = AV_CODEC_ID_NONE;
4306 audio_id = stream->fmt->audio_codec;
4307 video_id = stream->fmt->video_codec;
4310 *last_stream = stream;
4311 last_stream = &stream->next;
4313 } else if (!av_strcasecmp(cmd, "Feed")) {
4314 get_arg(arg, sizeof(arg), &p);
4319 while (sfeed != NULL) {
4320 if (!strcmp(sfeed->filename, arg))
4322 sfeed = sfeed->next_feed;
4325 ERROR("Feed with name '%s' for stream '%s' is not defined\n", arg, stream->filename);
4327 stream->feed = sfeed;
4329 } else if (!av_strcasecmp(cmd, "Format")) {
4330 get_arg(arg, sizeof(arg), &p);
4332 if (!strcmp(arg, "status")) {
4333 stream->stream_type = STREAM_TYPE_STATUS;
4336 stream->stream_type = STREAM_TYPE_LIVE;
4337 /* jpeg cannot be used here, so use single frame jpeg */
4338 if (!strcmp(arg, "jpeg"))
4339 strcpy(arg, "mjpeg");
4340 stream->fmt = ffserver_guess_format(arg, NULL, NULL);
4342 ERROR("Unknown Format: %s\n", arg);
4346 audio_id = stream->fmt->audio_codec;
4347 video_id = stream->fmt->video_codec;
4350 } else if (!av_strcasecmp(cmd, "InputFormat")) {
4351 get_arg(arg, sizeof(arg), &p);
4353 stream->ifmt = av_find_input_format(arg);
4354 if (!stream->ifmt) {
4355 ERROR("Unknown input format: %s\n", arg);
4358 } else if (!av_strcasecmp(cmd, "FaviconURL")) {
4359 if (stream && stream->stream_type == STREAM_TYPE_STATUS) {
4360 get_arg(stream->feed_filename, sizeof(stream->feed_filename), &p);
4362 ERROR("FaviconURL only permitted for status streams\n");
4364 } else if (!av_strcasecmp(cmd, "Author") ||
4365 !av_strcasecmp(cmd, "Comment") ||
4366 !av_strcasecmp(cmd, "Copyright") ||
4367 !av_strcasecmp(cmd, "Title")) {
4368 get_arg(arg, sizeof(arg), &p);
4374 for (i = 0; i < strlen(cmd); i++)
4375 key[i] = av_tolower(cmd[i]);
4377 WARNING("'%s' option in configuration file is deprecated, "
4378 "use 'Metadata %s VALUE' instead\n", cmd, key);
4379 if ((ret = av_dict_set(&stream->metadata, key, arg, 0)) < 0) {
4380 ERROR("Could not set metadata '%s' to value '%s': %s\n",
4381 key, arg, av_err2str(ret));
4384 } else if (!av_strcasecmp(cmd, "Metadata")) {
4385 get_arg(arg, sizeof(arg), &p);
4386 get_arg(arg2, sizeof(arg2), &p);
4389 if ((ret = av_dict_set(&stream->metadata, arg, arg2, 0)) < 0) {
4390 ERROR("Could not set metadata '%s' to value '%s': %s\n",
4391 arg, arg2, av_err2str(ret));
4394 } else if (!av_strcasecmp(cmd, "Preroll")) {
4395 get_arg(arg, sizeof(arg), &p);
4397 stream->prebuffer = atof(arg) * 1000;
4398 } else if (!av_strcasecmp(cmd, "StartSendOnKey")) {
4400 stream->send_on_key = 1;
4401 } else if (!av_strcasecmp(cmd, "AudioCodec")) {
4402 get_arg(arg, sizeof(arg), &p);
4403 audio_id = opt_codec(arg, AVMEDIA_TYPE_AUDIO);
4404 if (audio_id == AV_CODEC_ID_NONE) {
4405 ERROR("Unknown AudioCodec: %s\n", arg);
4407 } else if (!av_strcasecmp(cmd, "VideoCodec")) {
4408 get_arg(arg, sizeof(arg), &p);
4409 video_id = opt_codec(arg, AVMEDIA_TYPE_VIDEO);
4410 if (video_id == AV_CODEC_ID_NONE) {
4411 ERROR("Unknown VideoCodec: %s\n", arg);
4413 } else if (!av_strcasecmp(cmd, "MaxTime")) {
4414 get_arg(arg, sizeof(arg), &p);
4416 stream->max_time = atof(arg) * 1000;
4417 } else if (!av_strcasecmp(cmd, "AudioBitRate")) {
4418 get_arg(arg, sizeof(arg), &p);
4420 audio_enc.bit_rate = lrintf(atof(arg) * 1000);
4421 } else if (!av_strcasecmp(cmd, "AudioChannels")) {
4422 get_arg(arg, sizeof(arg), &p);
4424 audio_enc.channels = atoi(arg);
4425 } else if (!av_strcasecmp(cmd, "AudioSampleRate")) {
4426 get_arg(arg, sizeof(arg), &p);
4428 audio_enc.sample_rate = atoi(arg);
4429 } else if (!av_strcasecmp(cmd, "VideoBitRateRange")) {
4431 int minrate, maxrate;
4433 get_arg(arg, sizeof(arg), &p);
4435 if (sscanf(arg, "%d-%d", &minrate, &maxrate) == 2) {
4436 video_enc.rc_min_rate = minrate * 1000;
4437 video_enc.rc_max_rate = maxrate * 1000;
4439 ERROR("Incorrect format for VideoBitRateRange -- should be <min>-<max>: %s\n", arg);
4442 } else if (!av_strcasecmp(cmd, "Debug")) {
4444 get_arg(arg, sizeof(arg), &p);
4445 video_enc.debug = strtol(arg,0,0);
4447 } else if (!av_strcasecmp(cmd, "Strict")) {
4449 get_arg(arg, sizeof(arg), &p);
4450 video_enc.strict_std_compliance = atoi(arg);
4452 } else if (!av_strcasecmp(cmd, "VideoBufferSize")) {
4454 get_arg(arg, sizeof(arg), &p);
4455 video_enc.rc_buffer_size = atoi(arg) * 8*1024;
4457 } else if (!av_strcasecmp(cmd, "VideoBitRateTolerance")) {
4459 get_arg(arg, sizeof(arg), &p);
4460 video_enc.bit_rate_tolerance = atoi(arg) * 1000;
4462 } else if (!av_strcasecmp(cmd, "VideoBitRate")) {
4463 get_arg(arg, sizeof(arg), &p);
4465 video_enc.bit_rate = atoi(arg) * 1000;
4467 } else if (!av_strcasecmp(cmd, "VideoSize")) {
4468 get_arg(arg, sizeof(arg), &p);
4470 ret = av_parse_video_size(&video_enc.width, &video_enc.height, arg);
4472 ERROR("Invalid video size '%s'\n", arg);
4474 if ((video_enc.width % 16) != 0 ||
4475 (video_enc.height % 16) != 0) {
4476 ERROR("Image size must be a multiple of 16\n");
4480 } else if (!av_strcasecmp(cmd, "VideoFrameRate")) {
4481 get_arg(arg, sizeof(arg), &p);
4483 AVRational frame_rate;
4484 if (av_parse_video_rate(&frame_rate, arg) < 0) {
4485 ERROR("Incorrect frame rate: %s\n", arg);
4487 video_enc.time_base.num = frame_rate.den;
4488 video_enc.time_base.den = frame_rate.num;
4491 } else if (!av_strcasecmp(cmd, "PixelFormat")) {
4492 get_arg(arg, sizeof(arg), &p);
4494 video_enc.pix_fmt = av_get_pix_fmt(arg);
4495 if (video_enc.pix_fmt == AV_PIX_FMT_NONE) {
4496 ERROR("Unknown pixel format: %s\n", arg);
4499 } else if (!av_strcasecmp(cmd, "VideoGopSize")) {
4500 get_arg(arg, sizeof(arg), &p);
4502 video_enc.gop_size = atoi(arg);
4503 } else if (!av_strcasecmp(cmd, "VideoIntraOnly")) {
4505 video_enc.gop_size = 1;
4506 } else if (!av_strcasecmp(cmd, "VideoHighQuality")) {
4508 video_enc.mb_decision = FF_MB_DECISION_BITS;
4509 } else if (!av_strcasecmp(cmd, "Video4MotionVector")) {
4511 video_enc.mb_decision = FF_MB_DECISION_BITS; //FIXME remove
4512 video_enc.flags |= CODEC_FLAG_4MV;
4514 } else if (!av_strcasecmp(cmd, "AVOptionVideo") ||
4515 !av_strcasecmp(cmd, "AVOptionAudio")) {
4516 AVCodecContext *avctx;
4518 get_arg(arg, sizeof(arg), &p);
4519 get_arg(arg2, sizeof(arg2), &p);
4520 if (!av_strcasecmp(cmd, "AVOptionVideo")) {
4522 type = AV_OPT_FLAG_VIDEO_PARAM;
4525 type = AV_OPT_FLAG_AUDIO_PARAM;
4527 if (ffserver_opt_default(arg, arg2, avctx, type|AV_OPT_FLAG_ENCODING_PARAM)) {
4528 ERROR("Error setting %s option to %s %s\n", cmd, arg, arg2);
4530 } else if (!av_strcasecmp(cmd, "AVPresetVideo") ||
4531 !av_strcasecmp(cmd, "AVPresetAudio")) {
4532 AVCodecContext *avctx;
4534 get_arg(arg, sizeof(arg), &p);
4535 if (!av_strcasecmp(cmd, "AVPresetVideo")) {
4537 video_enc.codec_id = video_id;
4538 type = AV_OPT_FLAG_VIDEO_PARAM;
4541 audio_enc.codec_id = audio_id;
4542 type = AV_OPT_FLAG_AUDIO_PARAM;
4544 if (ffserver_opt_preset(arg, avctx, type|AV_OPT_FLAG_ENCODING_PARAM, &audio_id, &video_id)) {
4545 ERROR("AVPreset error: %s\n", arg);
4547 } else if (!av_strcasecmp(cmd, "VideoTag")) {
4548 get_arg(arg, sizeof(arg), &p);
4549 if ((strlen(arg) == 4) && stream)
4550 video_enc.codec_tag = MKTAG(arg[0], arg[1], arg[2], arg[3]);
4551 } else if (!av_strcasecmp(cmd, "BitExact")) {
4553 video_enc.flags |= CODEC_FLAG_BITEXACT;
4554 } else if (!av_strcasecmp(cmd, "DctFastint")) {
4556 video_enc.dct_algo = FF_DCT_FASTINT;
4557 } else if (!av_strcasecmp(cmd, "IdctSimple")) {
4559 video_enc.idct_algo = FF_IDCT_SIMPLE;
4560 } else if (!av_strcasecmp(cmd, "Qscale")) {
4561 get_arg(arg, sizeof(arg), &p);
4563 video_enc.flags |= CODEC_FLAG_QSCALE;
4564 video_enc.global_quality = FF_QP2LAMBDA * atoi(arg);
4566 } else if (!av_strcasecmp(cmd, "VideoQDiff")) {
4567 get_arg(arg, sizeof(arg), &p);
4569 video_enc.max_qdiff = atoi(arg);
4570 if (video_enc.max_qdiff < 1 || video_enc.max_qdiff > 31) {
4571 ERROR("VideoQDiff out of range\n");
4574 } else if (!av_strcasecmp(cmd, "VideoQMax")) {
4575 get_arg(arg, sizeof(arg), &p);
4577 video_enc.qmax = atoi(arg);
4578 if (video_enc.qmax < 1 || video_enc.qmax > 31) {
4579 ERROR("VideoQMax out of range\n");
4582 } else if (!av_strcasecmp(cmd, "VideoQMin")) {
4583 get_arg(arg, sizeof(arg), &p);
4585 video_enc.qmin = atoi(arg);
4586 if (video_enc.qmin < 1 || video_enc.qmin > 31) {
4587 ERROR("VideoQMin out of range\n");
4590 } else if (!av_strcasecmp(cmd, "LumiMask")) {
4591 get_arg(arg, sizeof(arg), &p);
4593 video_enc.lumi_masking = atof(arg);
4594 } else if (!av_strcasecmp(cmd, "DarkMask")) {
4595 get_arg(arg, sizeof(arg), &p);
4597 video_enc.dark_masking = atof(arg);
4598 } else if (!av_strcasecmp(cmd, "NoVideo")) {
4599 video_id = AV_CODEC_ID_NONE;
4600 } else if (!av_strcasecmp(cmd, "NoAudio")) {
4601 audio_id = AV_CODEC_ID_NONE;
4602 } else if (!av_strcasecmp(cmd, "ACL")) {
4603 parse_acl_row(stream, feed, NULL, p, filename, line_num);
4604 } else if (!av_strcasecmp(cmd, "DynamicACL")) {
4606 get_arg(stream->dynamic_acl, sizeof(stream->dynamic_acl), &p);
4608 } else if (!av_strcasecmp(cmd, "RTSPOption")) {
4609 get_arg(arg, sizeof(arg), &p);
4611 av_freep(&stream->rtsp_option);
4612 stream->rtsp_option = av_strdup(arg);
4614 } else if (!av_strcasecmp(cmd, "MulticastAddress")) {
4615 get_arg(arg, sizeof(arg), &p);
4617 if (resolve_host(&stream->multicast_ip, arg) != 0) {
4618 ERROR("Invalid host/IP address: %s\n", arg);
4620 stream->is_multicast = 1;
4621 stream->loop = 1; /* default is looping */
4623 } else if (!av_strcasecmp(cmd, "MulticastPort")) {
4624 get_arg(arg, sizeof(arg), &p);
4626 stream->multicast_port = atoi(arg);
4627 } else if (!av_strcasecmp(cmd, "MulticastTTL")) {
4628 get_arg(arg, sizeof(arg), &p);
4630 stream->multicast_ttl = atoi(arg);
4631 } else if (!av_strcasecmp(cmd, "NoLoop")) {
4634 } else if (!av_strcasecmp(cmd, "</Stream>")) {
4636 ERROR("No corresponding <Stream> for </Stream>\n");
4638 if (stream->feed && stream->fmt && strcmp(stream->fmt->name, "ffm") != 0) {
4639 if (audio_id != AV_CODEC_ID_NONE) {
4640 audio_enc.codec_type = AVMEDIA_TYPE_AUDIO;
4641 audio_enc.codec_id = audio_id;
4642 add_codec(stream, &audio_enc);
4644 if (video_id != AV_CODEC_ID_NONE) {
4645 video_enc.codec_type = AVMEDIA_TYPE_VIDEO;
4646 video_enc.codec_id = video_id;
4647 add_codec(stream, &video_enc);
4652 } else if (!av_strcasecmp(cmd, "<Redirect")) {
4653 /*********************************************/
4655 if (stream || feed || redirect) {
4656 ERROR("Already in a tag\n");
4658 redirect = av_mallocz(sizeof(FFStream));
4660 ret = AVERROR(ENOMEM);
4663 *last_stream = redirect;
4664 last_stream = &redirect->next;
4666 get_arg(redirect->filename, sizeof(redirect->filename), &p);
4667 q = strrchr(redirect->filename, '>');
4670 redirect->stream_type = STREAM_TYPE_REDIRECT;
4672 } else if (!av_strcasecmp(cmd, "URL")) {
4674 get_arg(redirect->feed_filename, sizeof(redirect->feed_filename), &p);
4675 } else if (!av_strcasecmp(cmd, "</Redirect>")) {
4677 ERROR("No corresponding <Redirect> for </Redirect>\n");
4679 if (!redirect->feed_filename[0]) {
4680 ERROR("No URL found for <Redirect>\n");
4684 } else if (!av_strcasecmp(cmd, "LoadModule")) {
4685 ERROR("Loadable modules no longer supported\n");
4687 ERROR("Incorrect keyword: '%s'\n", cmd);
4697 return AVERROR(EINVAL);
4702 static void handle_child_exit(int sig)
4707 while ((pid = waitpid(-1, &status, WNOHANG)) > 0) {
4710 for (feed = first_feed; feed; feed = feed->next) {
4711 if (feed->pid == pid) {
4712 int uptime = time(0) - feed->pid_start;
4715 fprintf(stderr, "%s: Pid %d exited with status %d after %d seconds\n", feed->filename, pid, status, uptime);
4718 /* Turn off any more restarts */
4719 feed->child_argv = 0;
4724 need_to_start_children = 1;
4727 static void opt_debug(void)
4730 logfilename[0] = '-';
4733 void show_help_default(const char *opt, const char *arg)
4735 printf("usage: ffserver [options]\n"
4736 "Hyper fast multi format Audio/Video streaming server\n");
4738 show_help_options(options, "Main options:", 0, 0, 0);
4741 static const OptionDef options[] = {
4742 #include "cmdutils_common_opts.h"
4743 { "n", OPT_BOOL, {(void *)&no_launch }, "enable no-launch mode" },
4744 { "d", 0, {(void*)opt_debug}, "enable debug mode" },
4745 { "f", HAS_ARG | OPT_STRING, {(void*)&config_filename }, "use configfile instead of /etc/ffserver.conf", "configfile" },
4749 int main(int argc, char **argv)
4751 struct sigaction sigact = { { 0 } };
4754 config_filename = av_strdup("/etc/ffserver.conf");
4756 parse_loglevel(argc, argv, options);
4758 avformat_network_init();
4760 show_banner(argc, argv, options);
4762 my_program_name = argv[0];
4764 parse_options(NULL, argc, argv, options, NULL);
4766 unsetenv("http_proxy"); /* Kill the http_proxy */
4768 av_lfg_init(&random_state, av_get_random_seed());
4770 sigact.sa_handler = handle_child_exit;
4771 sigact.sa_flags = SA_NOCLDSTOP | SA_RESTART;
4772 sigaction(SIGCHLD, &sigact, 0);
4774 if ((ret = parse_ffconfig(config_filename)) < 0) {
4775 fprintf(stderr, "Error reading configuration file '%s': %s\n",
4776 config_filename, av_err2str(ret));
4779 av_freep(&config_filename);
4781 /* open log file if needed */
4782 if (logfilename[0] != '\0') {
4783 if (!strcmp(logfilename, "-"))
4786 logfile = fopen(logfilename, "a");
4787 av_log_set_callback(http_av_log);
4790 build_file_streams();
4792 build_feed_streams();
4794 compute_bandwidth();
4797 signal(SIGPIPE, SIG_IGN);
4799 if (http_server() < 0) {
4800 http_log("Could not start server\n");