git.sesse.net Git - ffmpeg/blob - ffserver.c

   1 /*
   2  * Multiple format streaming server
   3  * Copyright (c) 2000, 2001, 2002 Fabrice Bellard
   4  *
   5  * This library is free software; you can redistribute it and/or
   6  * modify it under the terms of the GNU Lesser General Public
   7  * License as published by the Free Software Foundation; either
   8  * version 2 of the License, or (at your option) any later version.
   9  *
  10  * This library is distributed in the hope that it will be useful,
  11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * Lesser General Public License for more details.
  14  *
  15  * You should have received a copy of the GNU Lesser General Public
  16  * License along with this library; if not, write to the Free Software
  17  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  18  */
  19 #define HAVE_AV_CONFIG_H
  20 #include "avformat.h"
  21
  22 #include <stdarg.h>
  23 #include <netinet/in.h>
  24 #include <unistd.h>
  25 #include <fcntl.h>
  26 #include <sys/ioctl.h>
  27 #include <sys/poll.h>
  28 #include <errno.h>
  29 #include <sys/time.h>
  30 #include <time.h>
  31 #include <getopt.h>
  32 #include <sys/types.h>
  33 #include <sys/socket.h>
  34 #include <sys/wait.h>
  35 #include <arpa/inet.h>
  36 #include <netdb.h>
  37 #include <ctype.h>
  38 #include <signal.h>
  39
  40 /* maximum number of simultaneous HTTP connections */
  41 #define HTTP_MAX_CONNECTIONS 2000
  42
  43 enum HTTPState {
  44     HTTPSTATE_WAIT_REQUEST,
  45     HTTPSTATE_SEND_HEADER,
  46     HTTPSTATE_SEND_DATA_HEADER,
  47     HTTPSTATE_SEND_DATA,
  48     HTTPSTATE_SEND_DATA_TRAILER,
  49     HTTPSTATE_RECEIVE_DATA,
  50     HTTPSTATE_WAIT_FEED,
  51 };
  52
  53 const char *http_state[] = {
  54     "WAIT_REQUEST",
  55     "SEND_HEADER",
  56     "SEND_DATA_HEADER",
  57     "SEND_DATA",
  58     "SEND_DATA_TRAILER",
  59     "RECEIVE_DATA",
  60     "WAIT_FEED",
  61 };
  62
  63 #define IOBUFFER_INIT_SIZE 8192
  64 #define PBUFFER_INIT_SIZE 8192
  65
  66 /* coef for exponential mean for bitrate estimation in statistics */
  67 #define AVG_COEF 0.9
  68
  69 /* timeouts are in ms */
  70 #define REQUEST_TIMEOUT (15 * 1000)
  71 #define SYNC_TIMEOUT (10 * 1000)
  72
  73 typedef struct {
  74     INT64 count1, count2;
  75     long time1, time2;
  76 } DataRateData;
  77
  78 /* context associated with one connection */
  79 typedef struct HTTPContext {
  80     enum HTTPState state;
  81     int fd; /* socket file descriptor */
  82     struct sockaddr_in from_addr; /* origin */
  83     struct pollfd *poll_entry; /* used when polling */
  84     long timeout;
  85     UINT8 *buffer_ptr, *buffer_end;
  86     int http_error;
  87     struct HTTPContext *next;
  88     int got_key_frame; /* stream 0 => 1, stream 1 => 2, stream 2=> 4 */
  89     INT64 data_count;
  90     /* feed input */
  91     int feed_fd;
  92     /* input format handling */
  93     AVFormatContext *fmt_in;
  94     /* output format handling */
  95     struct FFStream *stream;
  96     /* -1 is invalid stream */
  97     int feed_streams[MAX_STREAMS]; /* index of streams in the feed */
  98     int switch_feed_streams[MAX_STREAMS]; /* index of streams in the feed */
  99     int switch_pending;
 100     AVFormatContext fmt_ctx;
 101     int last_packet_sent; /* true if last data packet was sent */
 102     int suppress_log;
 103     int bandwidth;
 104     long start_time;            /* In milliseconds - this wraps fairly often */
 105     DataRateData datarate;
 106     int wmp_client_id;
 107     char protocol[16];
 108     char method[16];
 109     char url[128];
 110     int buffer_size;
 111     UINT8 *buffer;
 112     int pbuffer_size;
 113     UINT8 *pbuffer;
 114 } HTTPContext;
 115
 116 /* each generated stream is described here */
 117 enum StreamType {
 118     STREAM_TYPE_LIVE,
 119     STREAM_TYPE_STATUS,
 120     STREAM_TYPE_REDIRECT,
 121 };
 122
 123 /* description of each stream of the ffserver.conf file */
 124 typedef struct FFStream {
 125     enum StreamType stream_type;
 126     char filename[1024];     /* stream filename */
 127     struct FFStream *feed;
 128     AVOutputFormat *fmt;
 129     int nb_streams;
 130     int prebuffer;      /* Number of millseconds early to start */
 131     long max_time;      /* Number of milliseconds to run */
 132     int send_on_key;
 133     AVStream *streams[MAX_STREAMS];
 134     int feed_streams[MAX_STREAMS]; /* index of streams in the feed */
 135     char feed_filename[1024]; /* file name of the feed storage, or
 136                                  input file name for a stream */
 137     char author[512];
 138     char title[512];
 139     char copyright[512];
 140     char comment[512];
 141     pid_t pid;  /* Of ffmpeg process */
 142     time_t pid_start;  /* Of ffmpeg process */
 143     char **child_argv;
 144     struct FFStream *next;
 145     /* feed specific */
 146     int feed_opened;     /* true if someone if writing to feed */
 147     int is_feed;         /* true if it is a feed */
 148     int conns_served;
 149     INT64 bytes_served;
 150     INT64 feed_max_size;      /* maximum storage size */
 151     INT64 feed_write_index;   /* current write position in feed (it wraps round) */
 152     INT64 feed_size;          /* current size of feed */
 153     struct FFStream *next_feed;
 154 } FFStream;
 155
 156 typedef struct FeedData {
 157     long long data_count;
 158     float avg_frame_size;   /* frame size averraged over last frames with exponential mean */
 159 } FeedData;
 160
 161 struct sockaddr_in my_addr;
 162 char logfilename[1024];
 163 HTTPContext *first_http_ctx;
 164 FFStream *first_feed;   /* contains only feeds */
 165 FFStream *first_stream; /* contains all streams, including feeds */
 166
 167 static int handle_http(HTTPContext *c);
 168 static int http_parse_request(HTTPContext *c);
 169 static int http_send_data(HTTPContext *c);
 170 static void compute_stats(HTTPContext *c);
 171 static int open_input_stream(HTTPContext *c, const char *info);
 172 static int http_start_receive_data(HTTPContext *c);
 173 static int http_receive_data(HTTPContext *c);
 174
 175 static const char *my_program_name;
 176
 177 static int ffserver_debug;
 178 static int no_launch;
 179 static int need_to_start_children;
 180
 181 int nb_max_connections;
 182 int nb_connections;
 183
 184 int nb_max_bandwidth;
 185 int nb_bandwidth;
 186
 187 static long cur_time;           // Making this global saves on passing it around everywhere
 188
 189 static long gettime_ms(void)
 190 {
 191     struct timeval tv;
 192
 193     gettimeofday(&tv,NULL);
 194     return (long long)tv.tv_sec * 1000 + (tv.tv_usec / 1000);
 195 }
 196
 197 static FILE *logfile = NULL;
 198
 199 static void http_log(char *fmt, ...)
 200 {
 201     va_list ap;
 202     va_start(ap, fmt);
 203
 204     if (logfile) {
 205         vfprintf(logfile, fmt, ap);
 206         fflush(logfile);
 207     }
 208     va_end(ap);
 209 }
 210
 211 static void log_connection(HTTPContext *c)
 212 {
 213     char buf1[32], buf2[32], *p;
 214     time_t ti;
 215
 216     if (c->suppress_log)
 217         return;
 218
 219     /* XXX: reentrant function ? */
 220     p = inet_ntoa(c->from_addr.sin_addr);
 221     strcpy(buf1, p);
 222     ti = time(NULL);
 223     p = ctime(&ti);
 224     strcpy(buf2, p);
 225     p = buf2 + strlen(p) - 1;
 226     if (*p == '\n')
 227         *p = '\0';
 228     http_log("%s - - [%s] \"%s %s %s\" %d %lld\n",
 229              buf1, buf2, c->method, c->url, c->protocol, (c->http_error ? c->http_error : 200), c->data_count);
 230 }
 231
 232 static void update_datarate(DataRateData *drd, INT64 count)
 233 {
 234     if (!drd->time1 && !drd->count1) {
 235         drd->time1 = drd->time2 = cur_time;
 236         drd->count1 = drd->count2 = count;
 237     } else {
 238         if (cur_time - drd->time2 > 5000) {
 239             drd->time1 = drd->time2;
 240             drd->count1 = drd->count2;
 241             drd->time2 = cur_time;
 242             drd->count2 = count;
 243         }
 244     }
 245 }
 246
 247 /* In bytes per second */
 248 static int compute_datarate(DataRateData *drd, INT64 count)
 249 {
 250     if (cur_time == drd->time1)
 251         return 0;
 252
 253     return ((count - drd->count1) * 1000) / (cur_time - drd->time1);
 254 }
 255
 256 static void start_children(FFStream *feed)
 257 {
 258     if (no_launch)
 259         return;
 260
 261     for (; feed; feed = feed->next) {
 262         if (feed->child_argv && !feed->pid) {
 263             feed->pid_start = time(0);
 264
 265             feed->pid = fork();
 266
 267             if (feed->pid < 0) {
 268                 fprintf(stderr, "Unable to create children\n");
 269                 exit(1);
 270             }
 271             if (!feed->pid) {
 272                 /* In child */
 273                 char pathname[1024];
 274                 char *slash;
 275                 int i;
 276
 277                 for (i = 3; i < 256; i++) {
 278                     close(i);
 279                 }
 280
 281                 if (!ffserver_debug) {
 282                     i = open("/dev/null", O_RDWR);
 283                     if (i)
 284                         dup2(i, 0);
 285                     dup2(i, 1);
 286                     dup2(i, 2);
 287                     if (i)
 288                         close(i);
 289                 }
 290
 291                 pstrcpy(pathname, sizeof(pathname), my_program_name);
 292
 293                 slash = strrchr(pathname, '/');
 294                 if (!slash) {
 295                     slash = pathname;
 296                 } else {
 297                     slash++;
 298                 }
 299                 strcpy(slash, "ffmpeg");
 300
 301                 execvp(pathname, feed->child_argv);
 302
 303                 _exit(1);
 304             }
 305         }
 306     }
 307 }
 308
 309 /* main loop of the http server */
 310 static int http_server(struct sockaddr_in my_addr)
 311 {
 312     int server_fd, tmp, ret;
 313     struct sockaddr_in from_addr;
 314     struct pollfd poll_table[HTTP_MAX_CONNECTIONS + 1], *poll_entry;
 315     HTTPContext *c, **cp;
 316
 317     server_fd = socket(AF_INET,SOCK_STREAM,0);
 318     if (server_fd < 0) {
 319         perror ("socket");
 320         return -1;
 321     }
 322
 323     tmp = 1;
 324     setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR, &tmp, sizeof(tmp));
 325
 326     if (bind (server_fd, (struct sockaddr *) &my_addr, sizeof (my_addr)) < 0) {
 327         perror ("bind");
 328         close(server_fd);
 329         return -1;
 330     }
 331
 332     if (listen (server_fd, 5) < 0) {
 333         perror ("listen");
 334         close(server_fd);
 335         return -1;
 336     }
 337
 338     http_log("ffserver started.\n");
 339
 340     start_children(first_feed);
 341
 342     fcntl(server_fd, F_SETFL, O_NONBLOCK);
 343     first_http_ctx = NULL;
 344     nb_connections = 0;
 345     first_http_ctx = NULL;
 346     for(;;) {
 347         poll_entry = poll_table;
 348         poll_entry->fd = server_fd;
 349         poll_entry->events = POLLIN;
 350         poll_entry++;
 351
 352         /* wait for events on each HTTP handle */
 353         c = first_http_ctx;
 354         while (c != NULL) {
 355             int fd;
 356             fd = c->fd;
 357             switch(c->state) {
 358             case HTTPSTATE_WAIT_REQUEST:
 359                 c->poll_entry = poll_entry;
 360                 poll_entry->fd = fd;
 361                 poll_entry->events = POLLIN;
 362                 poll_entry++;
 363                 break;
 364             case HTTPSTATE_SEND_HEADER:
 365             case HTTPSTATE_SEND_DATA_HEADER:
 366             case HTTPSTATE_SEND_DATA:
 367             case HTTPSTATE_SEND_DATA_TRAILER:
 368                 c->poll_entry = poll_entry;
 369                 poll_entry->fd = fd;
 370                 poll_entry->events = POLLOUT;
 371                 poll_entry++;
 372                 break;
 373             case HTTPSTATE_RECEIVE_DATA:
 374                 c->poll_entry = poll_entry;
 375                 poll_entry->fd = fd;
 376                 poll_entry->events = POLLIN;
 377                 poll_entry++;
 378                 break;
 379             case HTTPSTATE_WAIT_FEED:
 380                 /* need to catch errors */
 381                 c->poll_entry = poll_entry;
 382                 poll_entry->fd = fd;
 383                 poll_entry->events = POLLIN;/* Maybe this will work */
 384                 poll_entry++;
 385                 break;
 386             default:
 387                 c->poll_entry = NULL;
 388                 break;
 389             }
 390             c = c->next;
 391         }
 392
 393         /* wait for an event on one connection. We poll at least every
 394            second to handle timeouts */
 395         do {
 396             ret = poll(poll_table, poll_entry - poll_table, 1000);
 397         } while (ret == -1);
 398
 399         cur_time = gettime_ms();
 400
 401         if (need_to_start_children) {
 402             need_to_start_children = 0;
 403             start_children(first_feed);
 404         }
 405
 406         /* now handle the events */
 407
 408         cp = &first_http_ctx;
 409         while ((*cp) != NULL) {
 410             c = *cp;
 411             if (handle_http (c) < 0) {
 412                 /* close and free the connection */
 413                 log_connection(c);
 414                 close(c->fd);
 415                 if (c->fmt_in)
 416                     av_close_input_file(c->fmt_in);
 417                 *cp = c->next;
 418                 nb_bandwidth -= c->bandwidth;
 419                 av_free(c->buffer);
 420                 av_free(c->pbuffer);
 421                 av_free(c);
 422                 nb_connections--;
 423             } else {
 424                 cp = &c->next;
 425             }
 426         }
 427
 428         /* new connection request ? */
 429         poll_entry = poll_table;
 430         if (poll_entry->revents & POLLIN) {
 431             int fd, len;
 432
 433             len = sizeof(from_addr);
 434             fd = accept(server_fd, (struct sockaddr *)&from_addr,
 435                         &len);
 436             if (fd >= 0) {
 437                 fcntl(fd, F_SETFL, O_NONBLOCK);
 438                 /* XXX: should output a warning page when coming
 439                    close to the connection limit */
 440                 if (nb_connections >= nb_max_connections) {
 441                     c = NULL;
 442                 } else {
 443                     /* add a new connection */
 444                     c = av_mallocz(sizeof(HTTPContext));
 445                     if (c) {
 446                         c->next = first_http_ctx;
 447                         first_http_ctx = c;
 448                         c->fd = fd;
 449                         c->poll_entry = NULL;
 450                         c->from_addr = from_addr;
 451                         c->state = HTTPSTATE_WAIT_REQUEST;
 452                         c->buffer = av_malloc(c->buffer_size = IOBUFFER_INIT_SIZE);
 453                         c->pbuffer = av_malloc(c->pbuffer_size = PBUFFER_INIT_SIZE);
 454                         if (!c->buffer || !c->pbuffer) {
 455                             av_free(c->buffer);
 456                             av_free(c->pbuffer);
 457                             av_freep(&c);
 458                         } else {
 459                             c->buffer_ptr = c->buffer;
 460                             c->buffer_end = c->buffer + c->buffer_size;
 461                             c->timeout = cur_time + REQUEST_TIMEOUT;
 462                             c->start_time = cur_time;
 463                             nb_connections++;
 464                         }
 465                     }
 466                 }
 467                 if (!c) {
 468                     close(fd);
 469                 }
 470             }
 471         }
 472         poll_entry++;
 473     }
 474 }
 475
 476 static int handle_http(HTTPContext *c)
 477 {
 478     int len;
 479
 480     switch(c->state) {
 481     case HTTPSTATE_WAIT_REQUEST:
 482         /* timeout ? */
 483         if ((c->timeout - cur_time) < 0)
 484             return -1;
 485         if (c->poll_entry->revents & (POLLERR | POLLHUP))
 486             return -1;
 487
 488         /* no need to read if no events */
 489         if (!(c->poll_entry->revents & POLLIN))
 490             return 0;
 491         /* read the data */
 492         len = read(c->fd, c->buffer_ptr, c->buffer_end - c->buffer_ptr);
 493         if (len < 0) {
 494             if (errno != EAGAIN && errno != EINTR)
 495                 return -1;
 496         } else if (len == 0) {
 497             return -1;
 498         } else {
 499             /* search for end of request. XXX: not fully correct since garbage could come after the end */
 500             UINT8 *ptr;
 501             c->buffer_ptr += len;
 502             ptr = c->buffer_ptr;
 503             if ((ptr >= c->buffer + 2 && !memcmp(ptr-2, "\n\n", 2)) ||
 504                 (ptr >= c->buffer + 4 && !memcmp(ptr-4, "\r\n\r\n", 4))) {
 505                 /* request found : parse it and reply */
 506                 if (http_parse_request(c) < 0)
 507                     return -1;
 508             } else if (ptr >= c->buffer_end) {
 509                 /* request too long: cannot do anything */
 510                 return -1;
 511             }
 512         }
 513         break;
 514
 515     case HTTPSTATE_SEND_HEADER:
 516         if (c->poll_entry->revents & (POLLERR | POLLHUP))
 517             return -1;
 518
 519         /* no need to read if no events */
 520         if (!(c->poll_entry->revents & POLLOUT))
 521             return 0;
 522         len = write(c->fd, c->buffer_ptr, c->buffer_end - c->buffer_ptr);
 523         if (len < 0) {
 524             if (errno != EAGAIN && errno != EINTR) {
 525                 /* error : close connection */
 526                 return -1;
 527             }
 528         } else {
 529             c->buffer_ptr += len;
 530             if (c->stream)
 531                 c->stream->bytes_served += len;
 532             c->data_count += len;
 533             if (c->buffer_ptr >= c->buffer_end) {
 534                 /* if error, exit */
 535                 if (c->http_error)
 536                     return -1;
 537                 /* all the buffer was send : synchronize to the incoming stream */
 538                 c->state = HTTPSTATE_SEND_DATA_HEADER;
 539                 c->buffer_ptr = c->buffer_end = c->buffer;
 540             }
 541         }
 542         break;
 543
 544     case HTTPSTATE_SEND_DATA:
 545     case HTTPSTATE_SEND_DATA_HEADER:
 546     case HTTPSTATE_SEND_DATA_TRAILER:
 547         /* no need to read if no events */
 548         if (c->poll_entry->revents & (POLLERR | POLLHUP))
 549             return -1;
 550
 551         if (!(c->poll_entry->revents & POLLOUT))
 552             return 0;
 553         if (http_send_data(c) < 0)
 554             return -1;
 555         break;
 556     case HTTPSTATE_RECEIVE_DATA:
 557         /* no need to read if no events */
 558         if (c->poll_entry->revents & (POLLERR | POLLHUP))
 559             return -1;
 560         if (!(c->poll_entry->revents & POLLIN))
 561             return 0;
 562         if (http_receive_data(c) < 0)
 563             return -1;
 564         break;
 565     case HTTPSTATE_WAIT_FEED:
 566         /* no need to read if no events */
 567         if (c->poll_entry->revents & (POLLIN | POLLERR | POLLHUP))
 568             return -1;
 569
 570         /* nothing to do, we'll be waken up by incoming feed packets */
 571         break;
 572     default:
 573         return -1;
 574     }
 575     return 0;
 576 }
 577
 578 static int extract_rates(char *rates, int ratelen, const char *request)
 579 {
 580     const char *p;
 581
 582     for (p = request; *p && *p != '\r' && *p != '\n'; ) {
 583         if (strncasecmp(p, "Pragma:", 7) == 0) {
 584             const char *q = p + 7;
 585
 586             while (*q && *q != '\n' && isspace(*q))
 587                 q++;
 588
 589             if (strncasecmp(q, "stream-switch-entry=", 20) == 0) {
 590                 int stream_no;
 591                 int rate_no;
 592
 593                 q += 20;
 594
 595                 memset(rates, 0xff, ratelen);
 596
 597                 while (1) {
 598                     while (*q && *q != '\n' && *q != ':')
 599                         q++;
 600
 601                     if (sscanf(q, ":%d:%d", &stream_no, &rate_no) != 2) {
 602                         break;
 603                     }
 604                     stream_no--;
 605                     if (stream_no < ratelen && stream_no >= 0) {
 606                         rates[stream_no] = rate_no;
 607                     }
 608
 609                     while (*q && *q != '\n' && !isspace(*q))
 610                         q++;
 611                 }
 612
 613                 return 1;
 614             }
 615         }
 616         p = strchr(p, '\n');
 617         if (!p)
 618             break;
 619
 620         p++;
 621     }
 622
 623     return 0;
 624 }
 625
 626 static int find_stream_in_feed(FFStream *feed, AVCodecContext *codec, int bit_rate)
 627 {
 628     int i;
 629     int best_bitrate = 100000000;
 630     int best = -1;
 631
 632     for (i = 0; i < feed->nb_streams; i++) {
 633         AVCodecContext *feed_codec = &feed->streams[i]->codec;
 634
 635         if (feed_codec->codec_id != codec->codec_id ||
 636             feed_codec->sample_rate != codec->sample_rate ||
 637             feed_codec->width != codec->width ||
 638             feed_codec->height != codec->height) {
 639             continue;
 640         }
 641
 642         /* Potential stream */
 643
 644         /* We want the fastest stream less than bit_rate, or the slowest
 645          * faster than bit_rate
 646          */
 647
 648         if (feed_codec->bit_rate <= bit_rate) {
 649             if (best_bitrate > bit_rate || feed_codec->bit_rate > best_bitrate) {
 650                 best_bitrate = feed_codec->bit_rate;
 651                 best = i;
 652             }
 653         } else {
 654             if (feed_codec->bit_rate < best_bitrate) {
 655                 best_bitrate = feed_codec->bit_rate;
 656                 best = i;
 657             }
 658         }
 659     }
 660
 661     return best;
 662 }
 663
 664 static int modify_current_stream(HTTPContext *c, char *rates)
 665 {
 666     int i;
 667     FFStream *req = c->stream;
 668     int action_required = 0;
 669
 670     for (i = 0; i < req->nb_streams; i++) {
 671         AVCodecContext *codec = &req->streams[i]->codec;
 672
 673         switch(rates[i]) {
 674             case 0:
 675                 c->switch_feed_streams[i] = req->feed_streams[i];
 676                 break;
 677             case 1:
 678                 c->switch_feed_streams[i] = find_stream_in_feed(req->feed, codec, codec->bit_rate / 2);
 679                 break;
 680             case 2:
 681                 /* Wants off or slow */
 682                 c->switch_feed_streams[i] = find_stream_in_feed(req->feed, codec, codec->bit_rate / 4);
 683 #ifdef WANTS_OFF
 684                 /* This doesn't work well when it turns off the only stream! */
 685                 c->switch_feed_streams[i] = -2;
 686                 c->feed_streams[i] = -2;
 687 #endif
 688                 break;
 689         }
 690
 691         if (c->switch_feed_streams[i] >= 0 && c->switch_feed_streams[i] != c->feed_streams[i])
 692             action_required = 1;
 693     }
 694
 695     return action_required;
 696 }
 697
 698
 699 static void do_switch_stream(HTTPContext *c, int i)
 700 {
 701     if (c->switch_feed_streams[i] >= 0) {
 702 #ifdef PHILIP
 703         c->feed_streams[i] = c->switch_feed_streams[i];
 704 #endif
 705
 706         /* Now update the stream */
 707     }
 708     c->switch_feed_streams[i] = -1;
 709 }
 710
 711 /* parse http request and prepare header */
 712 static int http_parse_request(HTTPContext *c)
 713 {
 714     char *p;
 715     int post;
 716     int doing_asx;
 717     int doing_asf_redirector;
 718     int doing_ram;
 719     char cmd[32];
 720     char info[1024], *filename;
 721     char url[1024], *q;
 722     char protocol[32];
 723     char msg[1024];
 724     const char *mime_type;
 725     FFStream *stream;
 726     int i;
 727     char ratebuf[32];
 728     char *useragent = 0;
 729
 730     p = c->buffer;
 731     q = cmd;
 732     while (!isspace(*p) && *p != '\0') {
 733         if ((q - cmd) < sizeof(cmd) - 1)
 734             *q++ = *p;
 735         p++;
 736     }
 737     *q = '\0';
 738
 739     pstrcpy(c->method, sizeof(c->method), cmd);
 740
 741     if (!strcmp(cmd, "GET"))
 742         post = 0;
 743     else if (!strcmp(cmd, "POST"))
 744         post = 1;
 745     else
 746         return -1;
 747
 748     while (isspace(*p)) p++;
 749     q = url;
 750     while (!isspace(*p) && *p != '\0') {
 751         if ((q - url) < sizeof(url) - 1)
 752             *q++ = *p;
 753         p++;
 754     }
 755     *q = '\0';
 756
 757     pstrcpy(c->url, sizeof(c->url), url);
 758
 759     while (isspace(*p)) p++;
 760     q = protocol;
 761     while (!isspace(*p) && *p != '\0') {
 762         if ((q - protocol) < sizeof(protocol) - 1)
 763             *q++ = *p;
 764         p++;
 765     }
 766     *q = '\0';
 767     if (strcmp(protocol, "HTTP/1.0") && strcmp(protocol, "HTTP/1.1"))
 768         return -1;
 769
 770     pstrcpy(c->protocol, sizeof(c->protocol), protocol);
 771
 772     /* find the filename and the optional info string in the request */
 773     p = url;
 774     if (*p == '/')
 775         p++;
 776     filename = p;
 777     p = strchr(p, '?');
 778     if (p) {
 779         pstrcpy(info, sizeof(info), p);
 780         *p = '\0';
 781     } else {
 782         info[0] = '\0';
 783     }
 784
 785     for (p = c->buffer; *p && *p != '\r' && *p != '\n'; ) {
 786         if (strncasecmp(p, "User-Agent:", 11) == 0) {
 787             useragent = p + 11;
 788             if (*useragent && *useragent != '\n' && isspace(*useragent))
 789                 useragent++;
 790             break;
 791         }
 792         p = strchr(p, '\n');
 793         if (!p)
 794             break;
 795
 796         p++;
 797     }
 798
 799     if (strlen(filename) > 4 && strcmp(".asx", filename + strlen(filename) - 4) == 0) {
 800         doing_asx = 1;
 801         filename[strlen(filename)-1] = 'f';
 802     } else {
 803         doing_asx = 0;
 804     }
 805
 806     if (strlen(filename) > 4 && strcmp(".asf", filename + strlen(filename) - 4) == 0 &&
 807         (!useragent || strncasecmp(useragent, "NSPlayer", 8) != 0)) {
 808         /* if this isn't WMP or lookalike, return the redirector file */
 809         doing_asf_redirector = 1;
 810     } else {
 811         doing_asf_redirector = 0;
 812     }
 813
 814     if (strlen(filename) > 4 &&
 815         (strcmp(".rpm", filename + strlen(filename) - 4) == 0 ||
 816          strcmp(".ram", filename + strlen(filename) - 4) == 0)) {
 817         doing_ram = 1;
 818         strcpy(filename + strlen(filename)-2, "m");
 819     } else {
 820         doing_ram = 0;
 821     }
 822
 823     stream = first_stream;
 824     while (stream != NULL) {
 825         if (!strcmp(stream->filename, filename))
 826             break;
 827         stream = stream->next;
 828     }
 829     if (stream == NULL) {
 830         sprintf(msg, "File '%s' not found", url);
 831         goto send_error;
 832     }
 833
 834     c->stream = stream;
 835     memcpy(c->feed_streams, stream->feed_streams, sizeof(c->feed_streams));
 836     memset(c->switch_feed_streams, -1, sizeof(c->switch_feed_streams));
 837
 838     if (stream->stream_type == STREAM_TYPE_REDIRECT) {
 839         c->http_error = 301;
 840         q = c->buffer;
 841         q += sprintf(q, "HTTP/1.0 301 Moved\r\n");
 842         q += sprintf(q, "Location: %s\r\n", stream->feed_filename);
 843         q += sprintf(q, "Content-type: text/html\r\n");
 844         q += sprintf(q, "\r\n");
 845         q += sprintf(q, "<html><head><title>Moved</title></head><body>\r\n");
 846         q += sprintf(q, "You should be <a href=\"%s\">redirected</a>.\r\n", stream->feed_filename);
 847         q += sprintf(q, "</body></html>\r\n");
 848
 849         /* prepare output buffer */
 850         c->buffer_ptr = c->buffer;
 851         c->buffer_end = q;
 852         c->state = HTTPSTATE_SEND_HEADER;
 853         return 0;
 854     }
 855
 856     /* If this is WMP, get the rate information */
 857     if (extract_rates(ratebuf, sizeof(ratebuf), c->buffer)) {
 858         if (modify_current_stream(c, ratebuf)) {
 859             for (i = 0; i < sizeof(c->feed_streams) / sizeof(c->feed_streams[0]); i++) {
 860                 if (c->switch_feed_streams[i] >= 0)
 861                     do_switch_stream(c, i);
 862             }
 863         }
 864     }
 865
 866     if (post == 0 && stream->stream_type == STREAM_TYPE_LIVE) {
 867         /* See if we meet the bandwidth requirements */
 868         for(i=0;i<stream->nb_streams;i++) {
 869             AVStream *st = stream->streams[i];
 870             switch(st->codec.codec_type) {
 871             case CODEC_TYPE_AUDIO:
 872                 c->bandwidth += st->codec.bit_rate;
 873                 break;
 874             case CODEC_TYPE_VIDEO:
 875                 c->bandwidth += st->codec.bit_rate;
 876                 break;
 877             default:
 878                 av_abort();
 879             }
 880         }
 881     }
 882
 883     c->bandwidth /= 1000;
 884     nb_bandwidth += c->bandwidth;
 885
 886     if (post == 0 && nb_max_bandwidth < nb_bandwidth) {
 887         c->http_error = 200;
 888         q = c->buffer;
 889         q += sprintf(q, "HTTP/1.0 200 Server too busy\r\n");
 890         q += sprintf(q, "Content-type: text/html\r\n");
 891         q += sprintf(q, "\r\n");
 892         q += sprintf(q, "<html><head><title>Too busy</title></head><body>\r\n");
 893         q += sprintf(q, "The server is too busy to serve your request at this time.<p>\r\n");
 894         q += sprintf(q, "The bandwidth being served (including your stream) is %dkbit/sec, and this exceeds the limit of %dkbit/sec\r\n",
 895             nb_bandwidth, nb_max_bandwidth);
 896         q += sprintf(q, "</body></html>\r\n");
 897
 898         /* prepare output buffer */
 899         c->buffer_ptr = c->buffer;
 900         c->buffer_end = q;
 901         c->state = HTTPSTATE_SEND_HEADER;
 902         return 0;
 903     }
 904
 905     if (doing_asx || doing_ram || doing_asf_redirector) {
 906         char *hostinfo = 0;
 907
 908         for (p = c->buffer; *p && *p != '\r' && *p != '\n'; ) {
 909             if (strncasecmp(p, "Host:", 5) == 0) {
 910                 hostinfo = p + 5;
 911                 break;
 912             }
 913             p = strchr(p, '\n');
 914             if (!p)
 915                 break;
 916
 917             p++;
 918         }
 919
 920         if (hostinfo) {
 921             char *eoh;
 922             char hostbuf[260];
 923
 924             while (isspace(*hostinfo))
 925                 hostinfo++;
 926
 927             eoh = strchr(hostinfo, '\n');
 928             if (eoh) {
 929                 if (eoh[-1] == '\r')
 930                     eoh--;
 931
 932                 if (eoh - hostinfo < sizeof(hostbuf) - 1) {
 933                     memcpy(hostbuf, hostinfo, eoh - hostinfo);
 934                     hostbuf[eoh - hostinfo] = 0;
 935
 936                     c->http_error = 200;
 937                     q = c->buffer;
 938                     if (doing_asx) {
 939                         q += sprintf(q, "HTTP/1.0 200 ASX Follows\r\n");
 940                         q += sprintf(q, "Content-type: video/x-ms-asf\r\n");
 941                         q += sprintf(q, "\r\n");
 942                         q += sprintf(q, "<ASX Version=\"3\">\r\n");
 943                         q += sprintf(q, "<!-- Autogenerated by ffserver -->\r\n");
 944                         q += sprintf(q, "<ENTRY><REF HREF=\"http://%s/%s%s\"/></ENTRY>\r\n",
 945                                 hostbuf, filename, info);
 946                         q += sprintf(q, "</ASX>\r\n");
 947                     } else if (doing_ram) {
 948                         q += sprintf(q, "HTTP/1.0 200 RAM Follows\r\n");
 949                         q += sprintf(q, "Content-type: audio/x-pn-realaudio\r\n");
 950                         q += sprintf(q, "\r\n");
 951                         q += sprintf(q, "# Autogenerated by ffserver\r\n");
 952                         q += sprintf(q, "http://%s/%s%s\r\n",
 953                                 hostbuf, filename, info);
 954                     } else if (doing_asf_redirector) {
 955                         q += sprintf(q, "HTTP/1.0 200 ASF Redirect follows\r\n");
 956                         q += sprintf(q, "Content-type: video/x-ms-asf\r\n");
 957                         q += sprintf(q, "\r\n");
 958                         q += sprintf(q, "[Reference]\r\n");
 959                         q += sprintf(q, "Ref1=http://%s/%s%s\r\n",
 960                                 hostbuf, filename, info);
 961                     } else
 962                         av_abort();
 963
 964                     /* prepare output buffer */
 965                     c->buffer_ptr = c->buffer;
 966                     c->buffer_end = q;
 967                     c->state = HTTPSTATE_SEND_HEADER;
 968                     return 0;
 969                 }
 970             }
 971         }
 972
 973         sprintf(msg, "ASX/RAM file not handled");
 974         goto send_error;
 975     }
 976
 977     stream->conns_served++;
 978
 979     /* XXX: add there authenticate and IP match */
 980
 981     if (post) {
 982         /* if post, it means a feed is being sent */
 983         if (!stream->is_feed) {
 984             /* However it might be a status report from WMP! Lets log the data
 985              * as it might come in handy one day
 986              */
 987             char *logline = 0;
 988             int client_id = 0;
 989
 990             for (p = c->buffer; *p && *p != '\r' && *p != '\n'; ) {
 991                 if (strncasecmp(p, "Pragma: log-line=", 17) == 0) {
 992                     logline = p;
 993                     break;
 994                 }
 995                 if (strncasecmp(p, "Pragma: client-id=", 18) == 0) {
 996                     client_id = strtol(p + 18, 0, 10);
 997                 }
 998                 p = strchr(p, '\n');
 999                 if (!p)
1000                     break;
1001
1002                 p++;
1003             }
1004
1005             if (logline) {
1006                 char *eol = strchr(logline, '\n');
1007
1008                 logline += 17;
1009
1010                 if (eol) {
1011                     if (eol[-1] == '\r')
1012                         eol--;
1013                     http_log("%.*s\n", eol - logline, logline);
1014                     c->suppress_log = 1;
1015                 }
1016             }
1017
1018 #ifdef DEBUG_WMP
1019             http_log("\nGot request:\n%s\n", c->buffer);
1020 #endif
1021
1022             if (client_id && extract_rates(ratebuf, sizeof(ratebuf), c->buffer)) {
1023                 HTTPContext *wmpc;
1024
1025                 /* Now we have to find the client_id */
1026                 for (wmpc = first_http_ctx; wmpc; wmpc = wmpc->next) {
1027                     if (wmpc->wmp_client_id == client_id)
1028                         break;
1029                 }
1030
1031                 if (wmpc) {
1032                     if (modify_current_stream(wmpc, ratebuf)) {
1033                         wmpc->switch_pending = 1;
1034                     }
1035                 }
1036             }
1037
1038             sprintf(msg, "POST command not handled");
1039             goto send_error;
1040         }
1041         if (http_start_receive_data(c) < 0) {
1042             sprintf(msg, "could not open feed");
1043             goto send_error;
1044         }
1045         c->http_error = 0;
1046         c->state = HTTPSTATE_RECEIVE_DATA;
1047         return 0;
1048     }
1049
1050 #ifdef DEBUG_WMP
1051     if (strcmp(stream->filename + strlen(stream->filename) - 4, ".asf") == 0) {
1052         http_log("\nGot request:\n%s\n", c->buffer);
1053     }
1054 #endif
1055
1056     if (c->stream->stream_type == STREAM_TYPE_STATUS)
1057         goto send_stats;
1058
1059     /* open input stream */
1060     if (open_input_stream(c, info) < 0) {
1061         sprintf(msg, "Input stream corresponding to '%s' not found", url);
1062         goto send_error;
1063     }
1064
1065     /* prepare http header */
1066     q = c->buffer;
1067     q += sprintf(q, "HTTP/1.0 200 OK\r\n");
1068     mime_type = c->stream->fmt->mime_type;
1069     if (!mime_type)
1070         mime_type = "application/x-octet_stream";
1071     q += sprintf(q, "Pragma: no-cache\r\n");
1072
1073     /* for asf, we need extra headers */
1074     if (!strcmp(c->stream->fmt->name,"asf")) {
1075         /* Need to allocate a client id */
1076         static int wmp_session;
1077
1078         if (!wmp_session)
1079             wmp_session = time(0) & 0xffffff;
1080
1081         c->wmp_client_id = ++wmp_session;
1082
1083         q += sprintf(q, "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);
1084         mime_type = "application/octet-stream";
1085     }
1086     q += sprintf(q, "Content-Type: %s\r\n", mime_type);
1087     q += sprintf(q, "\r\n");
1088
1089     /* prepare output buffer */
1090     c->http_error = 0;
1091     c->buffer_ptr = c->buffer;
1092     c->buffer_end = q;
1093     c->state = HTTPSTATE_SEND_HEADER;
1094     return 0;
1095  send_error:
1096     c->http_error = 404;
1097     q = c->buffer;
1098     q += sprintf(q, "HTTP/1.0 404 Not Found\r\n");
1099     q += sprintf(q, "Content-type: %s\r\n", "text/html");
1100     q += sprintf(q, "\r\n");
1101     q += sprintf(q, "<HTML>\n");
1102     q += sprintf(q, "<HEAD><TITLE>404 Not Found</TITLE></HEAD>\n");
1103     q += sprintf(q, "<BODY>%s</BODY>\n", msg);
1104     q += sprintf(q, "</HTML>\n");
1105
1106     /* prepare output buffer */
1107     c->buffer_ptr = c->buffer;
1108     c->buffer_end = q;
1109     c->state = HTTPSTATE_SEND_HEADER;
1110     return 0;
1111  send_stats:
1112     compute_stats(c);
1113     c->http_error = 200; /* horrible : we use this value to avoid
1114                             going to the send data state */
1115     c->state = HTTPSTATE_SEND_HEADER;
1116     return 0;
1117 }
1118
1119 static int fmt_bytecount(char *q, INT64 count)
1120 {
1121     static const char *suffix = " kMGTP";
1122     const char *s;
1123
1124     for (s = suffix; count >= 100000 && s[1]; count /= 1000, s++) {
1125     }
1126
1127     return sprintf(q, "%lld%c", count, *s);
1128 }
1129
1130 static void compute_stats(HTTPContext *c)
1131 {
1132     HTTPContext *c1;
1133     FFStream *stream;
1134     char *q, *p;
1135     time_t ti;
1136     int i;
1137     char *new_buffer;
1138
1139     new_buffer = av_malloc(65536);
1140     if (new_buffer) {
1141         av_free(c->buffer);
1142         c->buffer_size = 65536;
1143         c->buffer = new_buffer;
1144         c->buffer_ptr = c->buffer;
1145         c->buffer_end = c->buffer + c->buffer_size;
1146     }
1147
1148     q = c->buffer;
1149     q += sprintf(q, "HTTP/1.0 200 OK\r\n");
1150     q += sprintf(q, "Content-type: %s\r\n", "text/html");
1151     q += sprintf(q, "Pragma: no-cache\r\n");
1152     q += sprintf(q, "\r\n");
1153
1154     q += sprintf(q, "<HEAD><TITLE>FFServer Status</TITLE>\n");
1155     if (c->stream->feed_filename) {
1156         q += sprintf(q, "<link rel=\"shortcut icon\" href=\"%s\">\n", c->stream->feed_filename);
1157     }
1158     q += sprintf(q, "</HEAD>\n<BODY>");
1159     q += sprintf(q, "<H1>FFServer Status</H1>\n");
1160     /* format status */
1161     q += sprintf(q, "<H2>Available Streams</H2>\n");
1162     q += sprintf(q, "<TABLE cellspacing=0 cellpadding=4>\n");
1163     q += sprintf(q, "<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");
1164     stream = first_stream;
1165     while (stream != NULL) {
1166         char sfilename[1024];
1167         char *eosf;
1168
1169         if (stream->feed != stream) {
1170             pstrcpy(sfilename, sizeof(sfilename) - 1, stream->filename);
1171             eosf = sfilename + strlen(sfilename);
1172             if (eosf - sfilename >= 4) {
1173                 if (strcmp(eosf - 4, ".asf") == 0) {
1174                     strcpy(eosf - 4, ".asx");
1175                 } else if (strcmp(eosf - 3, ".rm") == 0) {
1176                     strcpy(eosf - 3, ".ram");
1177                 }
1178             }
1179
1180             q += sprintf(q, "<TR><TD><A HREF=\"/%s\">%s</A> ",
1181                          sfilename, stream->filename);
1182             q += sprintf(q, "<td align=right> %d <td align=right> ",
1183                         stream->conns_served);
1184             q += fmt_bytecount(q, stream->bytes_served);
1185             switch(stream->stream_type) {
1186             case STREAM_TYPE_LIVE:
1187                 {
1188                     int audio_bit_rate = 0;
1189                     int video_bit_rate = 0;
1190                     char *audio_codec_name = "";
1191                     char *video_codec_name = "";
1192                     char *audio_codec_name_extra = "";
1193                     char *video_codec_name_extra = "";
1194
1195                     for(i=0;i<stream->nb_streams;i++) {
1196                         AVStream *st = stream->streams[i];
1197                         AVCodec *codec = avcodec_find_encoder(st->codec.codec_id);
1198                         switch(st->codec.codec_type) {
1199                         case CODEC_TYPE_AUDIO:
1200                             audio_bit_rate += st->codec.bit_rate;
1201                             if (codec) {
1202                                 if (*audio_codec_name)
1203                                     audio_codec_name_extra = "...";
1204                                 audio_codec_name = codec->name;
1205                             }
1206                             break;
1207                         case CODEC_TYPE_VIDEO:
1208                             video_bit_rate += st->codec.bit_rate;
1209                             if (codec) {
1210                                 if (*video_codec_name)
1211                                     video_codec_name_extra = "...";
1212                                 video_codec_name = codec->name;
1213                             }
1214                             break;
1215                         default:
1216                             av_abort();
1217                         }
1218                     }
1219                     q += sprintf(q, "<TD align=center> %s <TD align=right> %d <TD align=right> %d <TD> %s %s <TD align=right> %d <TD> %s %s",
1220                                  stream->fmt->name,
1221                                  (audio_bit_rate + video_bit_rate) / 1000,
1222                                  video_bit_rate / 1000, video_codec_name, video_codec_name_extra,
1223                                  audio_bit_rate / 1000, audio_codec_name, audio_codec_name_extra);
1224                     if (stream->feed) {
1225                         q += sprintf(q, "<TD>%s", stream->feed->filename);
1226                     } else {
1227                         q += sprintf(q, "<TD>%s", stream->feed_filename);
1228                     }
1229                     q += sprintf(q, "\n");
1230                 }
1231                 break;
1232             default:
1233                 q += sprintf(q, "<TD align=center> - <TD align=right> - <TD align=right> - <td><td align=right> - <TD>\n");
1234                 break;
1235             }
1236         }
1237         stream = stream->next;
1238     }
1239     q += sprintf(q, "</TABLE>\n");
1240
1241     stream = first_stream;
1242     while (stream != NULL) {
1243         if (stream->feed == stream) {
1244             q += sprintf(q, "<h2>Feed %s</h2>", stream->filename);
1245             if (stream->pid) {
1246                 FILE *pid_stat;
1247                 char ps_cmd[64];
1248
1249                 q += sprintf(q, "Running as pid %d.\n", stream->pid);
1250
1251 #ifdef linux
1252                 /* This is somewhat linux specific I guess */
1253                 snprintf(ps_cmd, sizeof(ps_cmd), "ps -o \"%%cpu,bsdtime\" --no-headers %d", stream->pid);
1254
1255                 pid_stat = popen(ps_cmd, "r");
1256                 if (pid_stat) {
1257                     char cpuperc[10];
1258                     char cpuused[64];
1259
1260                     if (fscanf(pid_stat, "%10s %64s", cpuperc, cpuused) == 2) {
1261                         q += sprintf(q, "Currently using %s%% of the cpu. Total time used %s.\n",
1262                             cpuperc, cpuused);
1263                     }
1264                     fclose(pid_stat);
1265                 }
1266 #endif
1267
1268                 q += sprintf(q, "<p>");
1269             }
1270             q += sprintf(q, "<table cellspacing=0 cellpadding=4><tr><th>Stream<th>type<th>kbits/s<th align=left>codec<th align=left>Parameters\n");
1271
1272             for (i = 0; i < stream->nb_streams; i++) {
1273                 AVStream *st = stream->streams[i];
1274                 AVCodec *codec = avcodec_find_encoder(st->codec.codec_id);
1275                 char *type = "unknown";
1276                 char parameters[64];
1277
1278                 parameters[0] = 0;
1279
1280                 switch(st->codec.codec_type) {
1281                 case CODEC_TYPE_AUDIO:
1282                     type = "audio";
1283                     break;
1284                 case CODEC_TYPE_VIDEO:
1285                     type = "video";
1286                     sprintf(parameters, "%dx%d, q=%d-%d, fps=%d", st->codec.width, st->codec.height,
1287                                 st->codec.qmin, st->codec.qmax, st->codec.frame_rate / FRAME_RATE_BASE);
1288                     break;
1289                 default:
1290                     av_abort();
1291                 }
1292                 q += sprintf(q, "<tr><td align=right>%d<td>%s<td align=right>%d<td>%s<td>%s\n",
1293                         i, type, st->codec.bit_rate/1000, codec ? codec->name : "", parameters);
1294             }
1295             q += sprintf(q, "</table>\n");
1296
1297         }
1298         stream = stream->next;
1299     }
1300
1301 #if 0
1302     {
1303         float avg;
1304         AVCodecContext *enc;
1305         char buf[1024];
1306
1307         /* feed status */
1308         stream = first_feed;
1309         while (stream != NULL) {
1310             q += sprintf(q, "<H1>Feed '%s'</H1>\n", stream->filename);
1311             q += sprintf(q, "<TABLE>\n");
1312             q += sprintf(q, "<TR><TD>Parameters<TD>Frame count<TD>Size<TD>Avg bitrate (kbits/s)\n");
1313             for(i=0;i<stream->nb_streams;i++) {
1314                 AVStream *st = stream->streams[i];
1315                 FeedData *fdata = st->priv_data;
1316                 enc = &st->codec;
1317
1318                 avcodec_string(buf, sizeof(buf), enc);
1319                 avg = fdata->avg_frame_size * (float)enc->rate * 8.0;
1320                 if (enc->codec->type == CODEC_TYPE_AUDIO && enc->frame_size > 0)
1321                     avg /= enc->frame_size;
1322                 q += sprintf(q, "<TR><TD>%s <TD> %d <TD> %Ld <TD> %0.1f\n",
1323                              buf, enc->frame_number, fdata->data_count, avg / 1000.0);
1324             }
1325             q += sprintf(q, "</TABLE>\n");
1326             stream = stream->next_feed;
1327         }
1328     }
1329 #endif
1330
1331     /* connection status */
1332     q += sprintf(q, "<H2>Connection Status</H2>\n");
1333
1334     q += sprintf(q, "Number of connections: %d / %d<BR>\n",
1335                  nb_connections, nb_max_connections);
1336
1337     q += sprintf(q, "Bandwidth in use: %dk / %dk<BR>\n",
1338                  nb_bandwidth, nb_max_bandwidth);
1339
1340     q += sprintf(q, "<TABLE>\n");
1341     q += sprintf(q, "<TR><Th>#<Th>File<Th>IP<Th>State<Th>Target bits/sec<Th>Actual bits/sec<Th>Bytes transferred\n");
1342     c1 = first_http_ctx;
1343     i = 0;
1344     while (c1 != NULL && q < (char *) c->buffer + c->buffer_size - 2048) {
1345         int bitrate;
1346         int j;
1347
1348         bitrate = 0;
1349         for (j = 0; j < c1->stream->nb_streams; j++) {
1350             if (c1->feed_streams[j] >= 0) {
1351                 bitrate += c1->stream->feed->streams[c1->feed_streams[j]]->codec.bit_rate;
1352             }
1353         }
1354
1355         i++;
1356         p = inet_ntoa(c1->from_addr.sin_addr);
1357         q += sprintf(q, "<TR><TD><B>%d</B><TD>%s%s <TD> %s <TD> %s <td align=right>",
1358                      i, c1->stream->filename,
1359                      c1->state == HTTPSTATE_RECEIVE_DATA ? "(input)" : "",
1360                      p,
1361                      http_state[c1->state]);
1362         q += fmt_bytecount(q, bitrate);
1363         q += sprintf(q, "<td align=right>");
1364         q += fmt_bytecount(q, compute_datarate(&c1->datarate, c1->data_count) * 8);
1365         q += sprintf(q, "<td align=right>");
1366         q += fmt_bytecount(q, c1->data_count);
1367         *q++ = '\n';
1368         c1 = c1->next;
1369     }
1370     q += sprintf(q, "</TABLE>\n");
1371
1372     /* date */
1373     ti = time(NULL);
1374     p = ctime(&ti);
1375     q += sprintf(q, "<HR size=1 noshade>Generated at %s", p);
1376     q += sprintf(q, "</BODY>\n</HTML>\n");
1377
1378     c->buffer_ptr = c->buffer;
1379     c->buffer_end = q;
1380 }
1381
1382
1383 static void http_write_packet(void *opaque,
1384                               unsigned char *buf, int size)
1385 {
1386     HTTPContext *c = opaque;
1387
1388     if (c->buffer_ptr == c->buffer_end || !c->buffer_ptr)
1389         c->buffer_ptr = c->buffer_end = c->buffer;
1390
1391     if (c->buffer_end - c->buffer + size > c->buffer_size) {
1392         int new_buffer_size = c->buffer_size * 2;
1393         UINT8 *new_buffer;
1394
1395         if (new_buffer_size <= c->buffer_end - c->buffer + size) {
1396             new_buffer_size = c->buffer_end - c->buffer + size + c->buffer_size;
1397         }
1398
1399         new_buffer = av_malloc(new_buffer_size);
1400         if (new_buffer) {
1401             memcpy(new_buffer, c->buffer, c->buffer_end - c->buffer);
1402             c->buffer_end += (new_buffer - c->buffer);
1403             c->buffer_ptr += (new_buffer - c->buffer);
1404             av_free(c->buffer);
1405             c->buffer = new_buffer;
1406             c->buffer_size = new_buffer_size;
1407         } else {
1408             av_abort();
1409         }
1410     }
1411
1412     memcpy(c->buffer_end, buf, size);
1413     c->buffer_end += size;
1414 }
1415
1416 static int open_input_stream(HTTPContext *c, const char *info)
1417 {
1418     char buf[128];
1419     char input_filename[1024];
1420     AVFormatContext *s;
1421     int buf_size;
1422     INT64 stream_pos;
1423
1424     /* find file name */
1425     if (c->stream->feed) {
1426         strcpy(input_filename, c->stream->feed->feed_filename);
1427         buf_size = FFM_PACKET_SIZE;
1428         /* compute position (absolute time) */
1429         if (find_info_tag(buf, sizeof(buf), "date", info)) {
1430             stream_pos = parse_date(buf, 0);
1431         } else if (find_info_tag(buf, sizeof(buf), "buffer", info)) {
1432             int prebuffer = strtol(buf, 0, 10);
1433             stream_pos = gettime() - prebuffer * 1000000;
1434         } else {
1435             stream_pos = gettime() - c->stream->prebuffer * 1000;
1436         }
1437     } else {
1438         strcpy(input_filename, c->stream->feed_filename);
1439         buf_size = 0;
1440         /* compute position (relative time) */
1441         if (find_info_tag(buf, sizeof(buf), "date", info)) {
1442             stream_pos = parse_date(buf, 1);
1443         } else {
1444             stream_pos = 0;
1445         }
1446     }
1447     if (input_filename[0] == '\0')
1448         return -1;
1449
1450     /* open stream */
1451     if (av_open_input_file(&s, input_filename, NULL, buf_size, NULL) < 0)
1452         return -1;
1453     c->fmt_in = s;
1454
1455     if (c->fmt_in->iformat->read_seek) {
1456         c->fmt_in->iformat->read_seek(c->fmt_in, stream_pos);
1457     }
1458
1459     //    printf("stream %s opened pos=%0.6f\n", input_filename, stream_pos / 1000000.0);
1460     return 0;
1461 }
1462
1463 static int http_prepare_data(HTTPContext *c)
1464 {
1465     int i;
1466
1467     switch(c->state) {
1468     case HTTPSTATE_SEND_DATA_HEADER:
1469         memset(&c->fmt_ctx, 0, sizeof(c->fmt_ctx));
1470         pstrcpy(c->fmt_ctx.author, sizeof(c->fmt_ctx.author), c->stream->author);
1471         pstrcpy(c->fmt_ctx.comment, sizeof(c->fmt_ctx.comment), c->stream->comment);
1472         pstrcpy(c->fmt_ctx.copyright, sizeof(c->fmt_ctx.copyright), c->stream->copyright);
1473         pstrcpy(c->fmt_ctx.title, sizeof(c->fmt_ctx.title), c->stream->title);
1474
1475         if (c->stream->feed) {
1476             /* open output stream by using specified codecs */
1477             c->fmt_ctx.oformat = c->stream->fmt;
1478             c->fmt_ctx.nb_streams = c->stream->nb_streams;
1479             for(i=0;i<c->fmt_ctx.nb_streams;i++) {
1480                 AVStream *st;
1481                 st = av_mallocz(sizeof(AVStream));
1482                 c->fmt_ctx.streams[i] = st;
1483                 if (c->stream->feed == c->stream)
1484                     memcpy(st, c->stream->streams[i], sizeof(AVStream));
1485                 else
1486                     memcpy(st, c->stream->feed->streams[c->stream->feed_streams[i]], sizeof(AVStream));
1487
1488                 st->codec.frame_number = 0; /* XXX: should be done in
1489                                                AVStream, not in codec */
1490             }
1491             c->got_key_frame = 0;
1492         } else {
1493             /* open output stream by using codecs in specified file */
1494             c->fmt_ctx.oformat = c->stream->fmt;
1495             c->fmt_ctx.nb_streams = c->fmt_in->nb_streams;
1496             for(i=0;i<c->fmt_ctx.nb_streams;i++) {
1497                 AVStream *st;
1498                 st = av_mallocz(sizeof(AVStream));
1499                 c->fmt_ctx.streams[i] = st;
1500                 memcpy(st, c->fmt_in->streams[i], sizeof(AVStream));
1501                 st->codec.frame_number = 0; /* XXX: should be done in
1502                                                AVStream, not in codec */
1503             }
1504             c->got_key_frame = 0;
1505         }
1506         init_put_byte(&c->fmt_ctx.pb, c->pbuffer, c->pbuffer_size,
1507                       1, c, NULL, http_write_packet, NULL);
1508         c->fmt_ctx.pb.is_streamed = 1;
1509         /* prepare header */
1510         av_write_header(&c->fmt_ctx);
1511         c->state = HTTPSTATE_SEND_DATA;
1512         c->last_packet_sent = 0;
1513         break;
1514     case HTTPSTATE_SEND_DATA:
1515         /* find a new packet */
1516 #if 0
1517         fifo_total_size = http_fifo_write_count - c->last_http_fifo_write_count;
1518         if (fifo_total_size >= ((3 * FIFO_MAX_SIZE) / 4)) {
1519             /* overflow : resync. We suppose that wptr is at this
1520                point a pointer to a valid packet */
1521             c->rptr = http_fifo.wptr;
1522             c->got_key_frame = 0;
1523         }
1524
1525         start_rptr = c->rptr;
1526         if (fifo_read(&http_fifo, (UINT8 *)&hdr, sizeof(hdr), &c->rptr) < 0)
1527             return 0;
1528         payload_size = ntohs(hdr.payload_size);
1529         payload = av_malloc(payload_size);
1530         if (fifo_read(&http_fifo, payload, payload_size, &c->rptr) < 0) {
1531             /* cannot read all the payload */
1532             av_free(payload);
1533             c->rptr = start_rptr;
1534             return 0;
1535         }
1536
1537         c->last_http_fifo_write_count = http_fifo_write_count -
1538             fifo_size(&http_fifo, c->rptr);
1539
1540         if (c->stream->stream_type != STREAM_TYPE_MASTER) {
1541             /* test if the packet can be handled by this format */
1542             ret = 0;
1543             for(i=0;i<c->fmt_ctx.nb_streams;i++) {
1544                 AVStream *st = c->fmt_ctx.streams[i];
1545                 if (test_header(&hdr, &st->codec)) {
1546                     /* only begin sending when got a key frame */
1547                     if (st->codec.key_frame)
1548                         c->got_key_frame |= 1 << i;
1549                     if (c->got_key_frame & (1 << i)) {
1550                         ret = c->fmt_ctx.format->write_packet(&c->fmt_ctx, i,
1551                                                                    payload, payload_size);
1552                     }
1553                     break;
1554                 }
1555             }
1556             if (ret) {
1557                 /* must send trailer now */
1558                 c->state = HTTPSTATE_SEND_DATA_TRAILER;
1559             }
1560         } else {
1561             /* master case : send everything */
1562             char *q;
1563             q = c->buffer;
1564             memcpy(q, &hdr, sizeof(hdr));
1565             q += sizeof(hdr);
1566             memcpy(q, payload, payload_size);
1567             q += payload_size;
1568             c->buffer_ptr = c->buffer;
1569             c->buffer_end = q;
1570         }
1571         av_free(payload);
1572 #endif
1573         {
1574             AVPacket pkt;
1575
1576             /* read a packet from the input stream */
1577             if (c->stream->feed) {
1578                 ffm_set_write_index(c->fmt_in,
1579                                     c->stream->feed->feed_write_index,
1580                                     c->stream->feed->feed_size);
1581             }
1582
1583             if (c->stream->max_time &&
1584                 c->stream->max_time + c->start_time - cur_time < 0) {
1585                 /* We have timed out */
1586                 c->state = HTTPSTATE_SEND_DATA_TRAILER;
1587             } else if (av_read_packet(c->fmt_in, &pkt) < 0) {
1588                 if (c->stream->feed && c->stream->feed->feed_opened) {
1589                     /* if coming from feed, it means we reached the end of the
1590                        ffm file, so must wait for more data */
1591                     c->state = HTTPSTATE_WAIT_FEED;
1592                     return 1; /* state changed */
1593                 } else {
1594                     /* must send trailer now because eof or error */
1595                     c->state = HTTPSTATE_SEND_DATA_TRAILER;
1596                 }
1597             } else {
1598                 /* send it to the appropriate stream */
1599                 if (c->stream->feed) {
1600                     /* if coming from a feed, select the right stream */
1601                     if (c->switch_pending) {
1602                         c->switch_pending = 0;
1603                         for(i=0;i<c->stream->nb_streams;i++) {
1604                             if (c->switch_feed_streams[i] == pkt.stream_index) {
1605                                 if (pkt.flags & PKT_FLAG_KEY) {
1606                                     do_switch_stream(c, i);
1607                                 }
1608                             }
1609                             if (c->switch_feed_streams[i] >= 0) {
1610                                 c->switch_pending = 1;
1611                             }
1612                         }
1613                     }
1614                     for(i=0;i<c->stream->nb_streams;i++) {
1615                         if (c->feed_streams[i] == pkt.stream_index) {
1616                             pkt.stream_index = i;
1617                             if (pkt.flags & PKT_FLAG_KEY) {
1618                                 c->got_key_frame |= 1 << i;
1619                             }
1620                             /* See if we have all the key frames, then
1621                              * we start to send. This logic is not quite
1622                              * right, but it works for the case of a
1623                              * single video stream with one or more
1624                              * audio streams (for which every frame is
1625                              * typically a key frame).
1626                              */
1627                             if (!c->stream->send_on_key || ((c->got_key_frame + 1) >> c->stream->nb_streams)) {
1628                                 goto send_it;
1629                             }
1630                         }
1631                     }
1632                 } else {
1633                     AVCodecContext *codec;
1634                 send_it:
1635                     /* Fudge here */
1636                     codec = &c->fmt_ctx.streams[pkt.stream_index]->codec;
1637
1638                     codec->key_frame = ((pkt.flags & PKT_FLAG_KEY) != 0);
1639
1640 #ifdef PJSG
1641                     if (codec->codec_type == CODEC_TYPE_AUDIO) {
1642                         codec->frame_size = (codec->sample_rate * pkt.duration + 500000) / 1000000;
1643                         /* printf("Calculated size %d, from sr %d, duration %d\n", codec->frame_size, codec->sample_rate, pkt.duration); */
1644                     }
1645 #endif
1646
1647                     if (av_write_packet(&c->fmt_ctx, &pkt, 0))
1648                         c->state = HTTPSTATE_SEND_DATA_TRAILER;
1649
1650                     codec->frame_number++;
1651                 }
1652
1653                 av_free_packet(&pkt);
1654             }
1655         }
1656         break;
1657     default:
1658     case HTTPSTATE_SEND_DATA_TRAILER:
1659         /* last packet test ? */
1660         if (c->last_packet_sent)
1661             return -1;
1662         /* prepare header */
1663         av_write_trailer(&c->fmt_ctx);
1664         c->last_packet_sent = 1;
1665         break;
1666     }
1667     return 0;
1668 }
1669
1670 /* should convert the format at the same time */
1671 static int http_send_data(HTTPContext *c)
1672 {
1673     int len, ret;
1674
1675     while (c->buffer_ptr >= c->buffer_end) {
1676         ret = http_prepare_data(c);
1677         if (ret < 0)
1678             return -1;
1679         else if (ret == 0) {
1680             continue;
1681         } else {
1682             /* state change requested */
1683             return 0;
1684         }
1685     }
1686
1687     if (c->buffer_end > c->buffer_ptr) {
1688         len = write(c->fd, c->buffer_ptr, c->buffer_end - c->buffer_ptr);
1689         if (len < 0) {
1690             if (errno != EAGAIN && errno != EINTR) {
1691                 /* error : close connection */
1692                 return -1;
1693             }
1694         } else {
1695             c->buffer_ptr += len;
1696             c->data_count += len;
1697             update_datarate(&c->datarate, c->data_count);
1698             if (c->stream)
1699                 c->stream->bytes_served += len;
1700         }
1701     }
1702     return 0;
1703 }
1704
1705 static int http_start_receive_data(HTTPContext *c)
1706 {
1707     int fd;
1708
1709     if (c->stream->feed_opened)
1710         return -1;
1711
1712     /* open feed */
1713     fd = open(c->stream->feed_filename, O_RDWR);
1714     if (fd < 0)
1715         return -1;
1716     c->feed_fd = fd;
1717
1718     c->stream->feed_write_index = ffm_read_write_index(fd);
1719     c->stream->feed_size = lseek(fd, 0, SEEK_END);
1720     lseek(fd, 0, SEEK_SET);
1721
1722     /* init buffer input */
1723     c->buffer_ptr = c->buffer;
1724     c->buffer_end = c->buffer + FFM_PACKET_SIZE;
1725     c->stream->feed_opened = 1;
1726     return 0;
1727 }
1728
1729 static int http_receive_data(HTTPContext *c)
1730 {
1731     HTTPContext *c1;
1732
1733     if (c->buffer_end > c->buffer_ptr) {
1734         int len;
1735
1736         len = read(c->fd, c->buffer_ptr, c->buffer_end - c->buffer_ptr);
1737         if (len < 0) {
1738             if (errno != EAGAIN && errno != EINTR) {
1739                 /* error : close connection */
1740                 goto fail;
1741             }
1742         } else if (len == 0) {
1743             /* end of connection : close it */
1744             goto fail;
1745         } else {
1746             c->buffer_ptr += len;
1747             c->data_count += len;
1748             update_datarate(&c->datarate, c->data_count);
1749         }
1750     }
1751
1752     if (c->buffer_ptr >= c->buffer_end) {
1753         FFStream *feed = c->stream;
1754         /* a packet has been received : write it in the store, except
1755            if header */
1756         if (c->data_count > FFM_PACKET_SIZE) {
1757
1758             //            printf("writing pos=0x%Lx size=0x%Lx\n", feed->feed_write_index, feed->feed_size);
1759             /* XXX: use llseek or url_seek */
1760             lseek(c->feed_fd, feed->feed_write_index, SEEK_SET);
1761             write(c->feed_fd, c->buffer, FFM_PACKET_SIZE);
1762
1763             feed->feed_write_index += FFM_PACKET_SIZE;
1764             /* update file size */
1765             if (feed->feed_write_index > c->stream->feed_size)
1766                 feed->feed_size = feed->feed_write_index;
1767
1768             /* handle wrap around if max file size reached */
1769             if (feed->feed_write_index >= c->stream->feed_max_size)
1770                 feed->feed_write_index = FFM_PACKET_SIZE;
1771
1772             /* write index */
1773             ffm_write_write_index(c->feed_fd, feed->feed_write_index);
1774
1775             /* wake up any waiting connections */
1776             for(c1 = first_http_ctx; c1 != NULL; c1 = c1->next) {
1777                 if (c1->state == HTTPSTATE_WAIT_FEED &&
1778                     c1->stream->feed == c->stream->feed) {
1779                     c1->state = HTTPSTATE_SEND_DATA;
1780                 }
1781             }
1782         } else {
1783             /* We have a header in our hands that contains useful data */
1784             AVFormatContext s;
1785             AVInputFormat *fmt_in;
1786             ByteIOContext *pb = &s.pb;
1787             int i;
1788
1789             memset(&s, 0, sizeof(s));
1790
1791             url_open_buf(pb, c->buffer, c->buffer_end - c->buffer, URL_RDONLY);
1792             pb->buf_end = c->buffer_end;        /* ?? */
1793             pb->is_streamed = 1;
1794
1795             /* use feed output format name to find corresponding input format */
1796             fmt_in = av_find_input_format(feed->fmt->name);
1797             if (!fmt_in)
1798                 goto fail;
1799
1800             s.priv_data = av_mallocz(fmt_in->priv_data_size);
1801             if (!s.priv_data)
1802                 goto fail;
1803
1804             if (fmt_in->read_header(&s, 0) < 0) {
1805                 av_freep(&s.priv_data);
1806                 goto fail;
1807             }
1808
1809             /* Now we have the actual streams */
1810             if (s.nb_streams != feed->nb_streams) {
1811                 av_freep(&s.priv_data);
1812                 goto fail;
1813             }
1814             for (i = 0; i < s.nb_streams; i++) {
1815                 memcpy(&feed->streams[i]->codec,
1816                        &s.streams[i]->codec, sizeof(AVCodecContext));
1817             }
1818             av_freep(&s.priv_data);
1819         }
1820         c->buffer_ptr = c->buffer;
1821     }
1822
1823     return 0;
1824  fail:
1825     c->stream->feed_opened = 0;
1826     close(c->feed_fd);
1827     return -1;
1828 }
1829
1830 /* return the stream number in the feed */
1831 int add_av_stream(FFStream *feed,
1832                   AVStream *st)
1833 {
1834     AVStream *fst;
1835     AVCodecContext *av, *av1;
1836     int i;
1837
1838     av = &st->codec;
1839     for(i=0;i<feed->nb_streams;i++) {
1840         st = feed->streams[i];
1841         av1 = &st->codec;
1842         if (av1->codec_id == av->codec_id &&
1843             av1->codec_type == av->codec_type &&
1844             av1->bit_rate == av->bit_rate) {
1845
1846             switch(av->codec_type) {
1847             case CODEC_TYPE_AUDIO:
1848                 if (av1->channels == av->channels &&
1849                     av1->sample_rate == av->sample_rate)
1850                     goto found;
1851                 break;
1852             case CODEC_TYPE_VIDEO:
1853                 if (av1->width == av->width &&
1854                     av1->height == av->height &&
1855                     av1->frame_rate == av->frame_rate &&
1856                     av1->gop_size == av->gop_size)
1857                     goto found;
1858                 break;
1859             default:
1860                 av_abort();
1861             }
1862         }
1863     }
1864
1865     fst = av_mallocz(sizeof(AVStream));
1866     if (!fst)
1867         return -1;
1868     fst->priv_data = av_mallocz(sizeof(FeedData));
1869     memcpy(&fst->codec, av, sizeof(AVCodecContext));
1870     feed->streams[feed->nb_streams++] = fst;
1871     return feed->nb_streams - 1;
1872  found:
1873     return i;
1874 }
1875
1876 /* compute the needed AVStream for each feed */
1877 void build_feed_streams(void)
1878 {
1879     FFStream *stream, *feed;
1880     int i;
1881
1882     /* gather all streams */
1883     for(stream = first_stream; stream != NULL; stream = stream->next) {
1884         feed = stream->feed;
1885         if (feed) {
1886             if (!stream->is_feed) {
1887                 for(i=0;i<stream->nb_streams;i++) {
1888                     stream->feed_streams[i] = add_av_stream(feed, stream->streams[i]);
1889                 }
1890             }
1891         }
1892     }
1893
1894     /* gather all streams */
1895     for(stream = first_stream; stream != NULL; stream = stream->next) {
1896         feed = stream->feed;
1897         if (feed) {
1898             if (stream->is_feed) {
1899                 for(i=0;i<stream->nb_streams;i++) {
1900                     stream->feed_streams[i] = i;
1901                 }
1902             }
1903         }
1904     }
1905
1906     /* create feed files if needed */
1907     for(feed = first_feed; feed != NULL; feed = feed->next_feed) {
1908         int fd;
1909
1910         if (!url_exist(feed->feed_filename)) {
1911             AVFormatContext s1, *s = &s1;
1912
1913             /* only write the header of the ffm file */
1914             if (url_fopen(&s->pb, feed->feed_filename, URL_WRONLY) < 0) {
1915                 fprintf(stderr, "Could not open output feed file '%s'\n",
1916                         feed->feed_filename);
1917                 exit(1);
1918             }
1919             s->oformat = feed->fmt;
1920             s->nb_streams = feed->nb_streams;
1921             for(i=0;i<s->nb_streams;i++) {
1922                 AVStream *st;
1923                 st = feed->streams[i];
1924                 s->streams[i] = st;
1925             }
1926             av_write_header(s);
1927             /* XXX: need better api */
1928             av_freep(&s->priv_data);
1929             url_fclose(&s->pb);
1930         }
1931         /* get feed size and write index */
1932         fd = open(feed->feed_filename, O_RDONLY);
1933         if (fd < 0) {
1934             fprintf(stderr, "Could not open output feed file '%s'\n",
1935                     feed->feed_filename);
1936             exit(1);
1937         }
1938
1939         feed->feed_write_index = ffm_read_write_index(fd);
1940         feed->feed_size = lseek(fd, 0, SEEK_END);
1941         /* ensure that we do not wrap before the end of file */
1942         if (feed->feed_max_size < feed->feed_size)
1943             feed->feed_max_size = feed->feed_size;
1944
1945         close(fd);
1946     }
1947 }
1948
1949 static void get_arg(char *buf, int buf_size, const char **pp)
1950 {
1951     const char *p;
1952     char *q;
1953     int quote;
1954
1955     p = *pp;
1956     while (isspace(*p)) p++;
1957     q = buf;
1958     quote = 0;
1959     if (*p == '\"' || *p == '\'')
1960         quote = *p++;
1961     for(;;) {
1962         if (quote) {
1963             if (*p == quote)
1964                 break;
1965         } else {
1966             if (isspace(*p))
1967                 break;
1968         }
1969         if (*p == '\0')
1970             break;
1971         if ((q - buf) < buf_size - 1)
1972             *q++ = *p;
1973         p++;
1974     }
1975     *q = '\0';
1976     if (quote && *p == quote)
1977         p++;
1978     *pp = p;
1979 }
1980
1981 /* add a codec and set the default parameters */
1982 void add_codec(FFStream *stream, AVCodecContext *av)
1983 {
1984     AVStream *st;
1985
1986     /* compute default parameters */
1987     switch(av->codec_type) {
1988     case CODEC_TYPE_AUDIO:
1989         if (av->bit_rate == 0)
1990             av->bit_rate = 64000;
1991         if (av->sample_rate == 0)
1992             av->sample_rate = 22050;
1993         if (av->channels == 0)
1994             av->channels = 1;
1995         break;
1996     case CODEC_TYPE_VIDEO:
1997         if (av->bit_rate == 0)
1998             av->bit_rate = 64000;
1999         if (av->frame_rate == 0)
2000             av->frame_rate = 5 * FRAME_RATE_BASE;
2001         if (av->width == 0 || av->height == 0) {
2002             av->width = 160;
2003             av->height = 128;
2004         }
2005         /* Bitrate tolerance is less for streaming */
2006         if (av->bit_rate_tolerance == 0)
2007             av->bit_rate_tolerance = av->bit_rate / 4;
2008         if (av->qmin == 0)
2009             av->qmin = 3;
2010         if (av->qmax == 0)
2011             av->qmax = 31;
2012         if (av->max_qdiff == 0)
2013             av->max_qdiff = 3;
2014         av->qcompress = 0.5;
2015         av->qblur = 0.5;
2016
2017         break;
2018     default:
2019         av_abort();
2020     }
2021
2022     st = av_mallocz(sizeof(AVStream));
2023     if (!st)
2024         return;
2025     stream->streams[stream->nb_streams++] = st;
2026     memcpy(&st->codec, av, sizeof(AVCodecContext));
2027 }
2028
2029 int opt_audio_codec(const char *arg)
2030 {
2031     AVCodec *p;
2032
2033     p = first_avcodec;
2034     while (p) {
2035         if (!strcmp(p->name, arg) && p->type == CODEC_TYPE_AUDIO)
2036             break;
2037         p = p->next;
2038     }
2039     if (p == NULL) {
2040         return CODEC_ID_NONE;
2041     }
2042
2043     return p->id;
2044 }
2045
2046 int opt_video_codec(const char *arg)
2047 {
2048     AVCodec *p;
2049
2050     p = first_avcodec;
2051     while (p) {
2052         if (!strcmp(p->name, arg) && p->type == CODEC_TYPE_VIDEO)
2053             break;
2054         p = p->next;
2055     }
2056     if (p == NULL) {
2057         return CODEC_ID_NONE;
2058     }
2059
2060     return p->id;
2061 }
2062
2063 int parse_ffconfig(const char *filename)
2064 {
2065     FILE *f;
2066     char line[1024];
2067     char cmd[64];
2068     char arg[1024];
2069     const char *p;
2070     int val, errors, line_num;
2071     FFStream **last_stream, *stream, *redirect;
2072     FFStream **last_feed, *feed;
2073     AVCodecContext audio_enc, video_enc;
2074     int audio_id, video_id;
2075
2076     f = fopen(filename, "r");
2077     if (!f) {
2078         perror(filename);
2079         return -1;
2080     }
2081
2082     errors = 0;
2083     line_num = 0;
2084     first_stream = NULL;
2085     last_stream = &first_stream;
2086     first_feed = NULL;
2087     last_feed = &first_feed;
2088     stream = NULL;
2089     feed = NULL;
2090     redirect = NULL;
2091     audio_id = CODEC_ID_NONE;
2092     video_id = CODEC_ID_NONE;
2093     for(;;) {
2094         if (fgets(line, sizeof(line), f) == NULL)
2095             break;
2096         line_num++;
2097         p = line;
2098         while (isspace(*p))
2099             p++;
2100         if (*p == '\0' || *p == '#')
2101             continue;
2102
2103         get_arg(cmd, sizeof(cmd), &p);
2104
2105         if (!strcasecmp(cmd, "Port")) {
2106             get_arg(arg, sizeof(arg), &p);
2107             my_addr.sin_port = htons (atoi(arg));
2108         } else if (!strcasecmp(cmd, "BindAddress")) {
2109             get_arg(arg, sizeof(arg), &p);
2110             if (!inet_aton(arg, &my_addr.sin_addr)) {
2111                 fprintf(stderr, "%s:%d: Invalid IP address: %s\n",
2112                         filename, line_num, arg);
2113                 errors++;
2114             }
2115         } else if (!strcasecmp(cmd, "MaxClients")) {
2116             get_arg(arg, sizeof(arg), &p);
2117             val = atoi(arg);
2118             if (val < 1 || val > HTTP_MAX_CONNECTIONS) {
2119                 fprintf(stderr, "%s:%d: Invalid MaxClients: %s\n",
2120                         filename, line_num, arg);
2121                 errors++;
2122             } else {
2123                 nb_max_connections = val;
2124             }
2125         } else if (!strcasecmp(cmd, "MaxBandwidth")) {
2126             get_arg(arg, sizeof(arg), &p);
2127             val = atoi(arg);
2128             if (val < 10 || val > 100000) {
2129                 fprintf(stderr, "%s:%d: Invalid MaxBandwidth: %s\n",
2130                         filename, line_num, arg);
2131                 errors++;
2132             } else {
2133                 nb_max_bandwidth = val;
2134             }
2135         } else if (!strcasecmp(cmd, "CustomLog")) {
2136             get_arg(logfilename, sizeof(logfilename), &p);
2137         } else if (!strcasecmp(cmd, "<Feed")) {
2138             /*********************************************/
2139             /* Feed related options */
2140             char *q;
2141             if (stream || feed) {
2142                 fprintf(stderr, "%s:%d: Already in a tag\n",
2143                         filename, line_num);
2144             } else {
2145                 feed = av_mallocz(sizeof(FFStream));
2146                 /* add in stream list */
2147                 *last_stream = feed;
2148                 last_stream = &feed->next;
2149                 /* add in feed list */
2150                 *last_feed = feed;
2151                 last_feed = &feed->next_feed;
2152
2153                 get_arg(feed->filename, sizeof(feed->filename), &p);
2154                 q = strrchr(feed->filename, '>');
2155                 if (*q)
2156                     *q = '\0';
2157                 feed->fmt = guess_format("ffm", NULL, NULL);
2158                 /* defaut feed file */
2159                 snprintf(feed->feed_filename, sizeof(feed->feed_filename),
2160                          "/tmp/%s.ffm", feed->filename);
2161                 feed->feed_max_size = 5 * 1024 * 1024;
2162                 feed->is_feed = 1;
2163                 feed->feed = feed; /* self feeding :-) */
2164             }
2165         } else if (!strcasecmp(cmd, "Launch")) {
2166             if (feed) {
2167                 int i;
2168
2169                 feed->child_argv = (char **) av_mallocz(64 * sizeof(char *));
2170
2171                 feed->child_argv[0] = av_malloc(7);
2172                 strcpy(feed->child_argv[0], "ffmpeg");
2173
2174                 for (i = 1; i < 62; i++) {
2175                     char argbuf[256];
2176
2177                     get_arg(argbuf, sizeof(argbuf), &p);
2178                     if (!argbuf[0])
2179                         break;
2180
2181                     feed->child_argv[i] = av_malloc(strlen(argbuf + 1));
2182                     strcpy(feed->child_argv[i], argbuf);
2183                 }
2184
2185                 feed->child_argv[i] = av_malloc(30 + strlen(feed->filename));
2186
2187                 snprintf(feed->child_argv[i], 256, "http://127.0.0.1:%d/%s",
2188                     ntohs(my_addr.sin_port), feed->filename);
2189             }
2190         } else if (!strcasecmp(cmd, "File")) {
2191             if (feed) {
2192                 get_arg(feed->feed_filename, sizeof(feed->feed_filename), &p);
2193             } else if (stream) {
2194                 get_arg(stream->feed_filename, sizeof(stream->feed_filename), &p);
2195             }
2196         } else if (!strcasecmp(cmd, "FileMaxSize")) {
2197             if (feed) {
2198                 const char *p1;
2199                 double fsize;
2200
2201                 get_arg(arg, sizeof(arg), &p);
2202                 p1 = arg;
2203                 fsize = strtod(p1, (char **)&p1);
2204                 switch(toupper(*p1)) {
2205                 case 'K':
2206                     fsize *= 1024;
2207                     break;
2208                 case 'M':
2209                     fsize *= 1024 * 1024;
2210                     break;
2211                 case 'G':
2212                     fsize *= 1024 * 1024 * 1024;
2213                     break;
2214                 }
2215                 feed->feed_max_size = (INT64)fsize;
2216             }
2217         } else if (!strcasecmp(cmd, "</Feed>")) {
2218             if (!feed) {
2219                 fprintf(stderr, "%s:%d: No corresponding <Feed> for </Feed>\n",
2220                         filename, line_num);
2221                 errors++;
2222             } else {
2223                 /* Make sure that we start out clean */
2224                 if (unlink(feed->feed_filename) < 0
2225                     && errno != ENOENT) {
2226                     fprintf(stderr, "%s:%d: Unable to clean old feed file '%s': %s\n",
2227                         filename, line_num, feed->feed_filename, strerror(errno));
2228                     errors++;
2229                 }
2230             }
2231             feed = NULL;
2232         } else if (!strcasecmp(cmd, "<Stream")) {
2233             /*********************************************/
2234             /* Stream related options */
2235             char *q;
2236             if (stream || feed) {
2237                 fprintf(stderr, "%s:%d: Already in a tag\n",
2238                         filename, line_num);
2239             } else {
2240                 stream = av_mallocz(sizeof(FFStream));
2241                 *last_stream = stream;
2242                 last_stream = &stream->next;
2243
2244                 get_arg(stream->filename, sizeof(stream->filename), &p);
2245                 q = strrchr(stream->filename, '>');
2246                 if (*q)
2247                     *q = '\0';
2248                 stream->fmt = guess_format(NULL, stream->filename, NULL);
2249                 memset(&audio_enc, 0, sizeof(AVCodecContext));
2250                 memset(&video_enc, 0, sizeof(AVCodecContext));
2251                 audio_id = CODEC_ID_NONE;
2252                 video_id = CODEC_ID_NONE;
2253                 if (stream->fmt) {
2254                     audio_id = stream->fmt->audio_codec;
2255                     video_id = stream->fmt->video_codec;
2256                 }
2257             }
2258         } else if (!strcasecmp(cmd, "Feed")) {
2259             get_arg(arg, sizeof(arg), &p);
2260             if (stream) {
2261                 FFStream *sfeed;
2262
2263                 sfeed = first_feed;
2264                 while (sfeed != NULL) {
2265                     if (!strcmp(sfeed->filename, arg))
2266                         break;
2267                     sfeed = sfeed->next_feed;
2268                 }
2269                 if (!sfeed) {
2270                     fprintf(stderr, "%s:%d: feed '%s' not defined\n",
2271                             filename, line_num, arg);
2272                 } else {
2273                     stream->feed = sfeed;
2274                 }
2275             }
2276         } else if (!strcasecmp(cmd, "Format")) {
2277             get_arg(arg, sizeof(arg), &p);
2278             if (!strcmp(arg, "status")) {
2279                 stream->stream_type = STREAM_TYPE_STATUS;
2280                 stream->fmt = NULL;
2281             } else {
2282                 stream->stream_type = STREAM_TYPE_LIVE;
2283                 /* jpeg cannot be used here, so use single frame jpeg */
2284                 if (!strcmp(arg, "jpeg"))
2285                     strcpy(arg, "singlejpeg");
2286                 stream->fmt = guess_format(arg, NULL, NULL);
2287                 if (!stream->fmt) {
2288                     fprintf(stderr, "%s:%d: Unknown Format: %s\n",
2289                             filename, line_num, arg);
2290                     errors++;
2291                 }
2292             }
2293             if (stream->fmt) {
2294                 audio_id = stream->fmt->audio_codec;
2295                 video_id = stream->fmt->video_codec;
2296             }
2297         } else if (!strcasecmp(cmd, "FaviconURL")) {
2298             if (stream && stream->stream_type == STREAM_TYPE_STATUS) {
2299                 get_arg(stream->feed_filename, sizeof(stream->feed_filename), &p);
2300             } else {
2301                 fprintf(stderr, "%s:%d: FaviconURL only permitted for status streams\n",
2302                             filename, line_num);
2303                 errors++;
2304             }
2305         } else if (!strcasecmp(cmd, "Author")) {
2306             if (stream) {
2307                 get_arg(stream->author, sizeof(stream->author), &p);
2308             }
2309         } else if (!strcasecmp(cmd, "Comment")) {
2310             if (stream) {
2311                 get_arg(stream->comment, sizeof(stream->comment), &p);
2312             }
2313         } else if (!strcasecmp(cmd, "Copyright")) {
2314             if (stream) {
2315                 get_arg(stream->copyright, sizeof(stream->copyright), &p);
2316             }
2317         } else if (!strcasecmp(cmd, "Title")) {
2318             if (stream) {
2319                 get_arg(stream->title, sizeof(stream->title), &p);
2320             }
2321         } else if (!strcasecmp(cmd, "Preroll")) {
2322             get_arg(arg, sizeof(arg), &p);
2323             if (stream) {
2324                 stream->prebuffer = atoi(arg) * 1000;
2325             }
2326         } else if (!strcasecmp(cmd, "StartSendOnKey")) {
2327             if (stream) {
2328                 stream->send_on_key = 1;
2329             }
2330         } else if (!strcasecmp(cmd, "AudioCodec")) {
2331             get_arg(arg, sizeof(arg), &p);
2332             audio_id = opt_audio_codec(arg);
2333             if (audio_id == CODEC_ID_NONE) {
2334                 fprintf(stderr, "%s:%d: Unknown AudioCodec: %s\n",
2335                         filename, line_num, arg);
2336                 errors++;
2337             }
2338         } else if (!strcasecmp(cmd, "VideoCodec")) {
2339             get_arg(arg, sizeof(arg), &p);
2340             video_id = opt_video_codec(arg);
2341             if (video_id == CODEC_ID_NONE) {
2342                 fprintf(stderr, "%s:%d: Unknown VideoCodec: %s\n",
2343                         filename, line_num, arg);
2344                 errors++;
2345             }
2346         } else if (!strcasecmp(cmd, "MaxTime")) {
2347             get_arg(arg, sizeof(arg), &p);
2348             if (stream) {
2349                 stream->max_time = atoi(arg) * 1000;
2350             }
2351         } else if (!strcasecmp(cmd, "AudioBitRate")) {
2352             get_arg(arg, sizeof(arg), &p);
2353             if (stream) {
2354                 audio_enc.bit_rate = atoi(arg) * 1000;
2355             }
2356         } else if (!strcasecmp(cmd, "AudioChannels")) {
2357             get_arg(arg, sizeof(arg), &p);
2358             if (stream) {
2359                 audio_enc.channels = atoi(arg);
2360             }
2361         } else if (!strcasecmp(cmd, "AudioSampleRate")) {
2362             get_arg(arg, sizeof(arg), &p);
2363             if (stream) {
2364                 audio_enc.sample_rate = atoi(arg);
2365             }
2366         } else if (!strcasecmp(cmd, "VideoBitRate")) {
2367             get_arg(arg, sizeof(arg), &p);
2368             if (stream) {
2369                 video_enc.bit_rate = atoi(arg) * 1000;
2370             }
2371         } else if (!strcasecmp(cmd, "VideoSize")) {
2372             get_arg(arg, sizeof(arg), &p);
2373             if (stream) {
2374                 parse_image_size(&video_enc.width, &video_enc.height, arg);
2375                 if ((video_enc.width % 16) != 0 ||
2376                     (video_enc.height % 16) != 0) {
2377                     fprintf(stderr, "%s:%d: Image size must be a multiple of 16\n",
2378                             filename, line_num);
2379                     errors++;
2380                 }
2381             }
2382         } else if (!strcasecmp(cmd, "VideoFrameRate")) {
2383             get_arg(arg, sizeof(arg), &p);
2384             if (stream) {
2385                 video_enc.frame_rate = (int)(strtod(arg, NULL) * FRAME_RATE_BASE);
2386             }
2387         } else if (!strcasecmp(cmd, "VideoGopSize")) {
2388             get_arg(arg, sizeof(arg), &p);
2389             if (stream) {
2390                 video_enc.gop_size = atoi(arg);
2391             }
2392         } else if (!strcasecmp(cmd, "VideoIntraOnly")) {
2393             if (stream) {
2394                 video_enc.gop_size = 1;
2395             }
2396         } else if (!strcasecmp(cmd, "VideoHighQuality")) {
2397             if (stream) {
2398                 video_enc.flags |= CODEC_FLAG_HQ;
2399             }
2400         } else if (!strcasecmp(cmd, "VideoQDiff")) {
2401             if (stream) {
2402                 video_enc.max_qdiff = atoi(arg);
2403                 if (video_enc.max_qdiff < 1 || video_enc.max_qdiff > 31) {
2404                     fprintf(stderr, "%s:%d: VideoQDiff out of range\n",
2405                             filename, line_num);
2406                     errors++;
2407                 }
2408             }
2409         } else if (!strcasecmp(cmd, "VideoQMax")) {
2410             if (stream) {
2411                 video_enc.qmax = atoi(arg);
2412                 if (video_enc.qmax < 1 || video_enc.qmax > 31) {
2413                     fprintf(stderr, "%s:%d: VideoQMax out of range\n",
2414                             filename, line_num);
2415                     errors++;
2416                 }
2417             }
2418         } else if (!strcasecmp(cmd, "VideoQMin")) {
2419             if (stream) {
2420                 video_enc.qmin = atoi(arg);
2421                 if (video_enc.qmin < 1 || video_enc.qmin > 31) {
2422                     fprintf(stderr, "%s:%d: VideoQMin out of range\n",
2423                             filename, line_num);
2424                     errors++;
2425                 }
2426             }
2427         } else if (!strcasecmp(cmd, "NoVideo")) {
2428             video_id = CODEC_ID_NONE;
2429         } else if (!strcasecmp(cmd, "NoAudio")) {
2430             audio_id = CODEC_ID_NONE;
2431         } else if (!strcasecmp(cmd, "</Stream>")) {
2432             if (!stream) {
2433                 fprintf(stderr, "%s:%d: No corresponding <Stream> for </Stream>\n",
2434                         filename, line_num);
2435                 errors++;
2436             }
2437             if (stream->feed && stream->fmt && strcmp(stream->fmt->name, "ffm") != 0) {
2438                 if (audio_id != CODEC_ID_NONE) {
2439                     audio_enc.codec_type = CODEC_TYPE_AUDIO;
2440                     audio_enc.codec_id = audio_id;
2441                     add_codec(stream, &audio_enc);
2442                 }
2443                 if (video_id != CODEC_ID_NONE) {
2444                     video_enc.codec_type = CODEC_TYPE_VIDEO;
2445                     video_enc.codec_id = video_id;
2446                     add_codec(stream, &video_enc);
2447                 }
2448             }
2449             stream = NULL;
2450         } else if (!strcasecmp(cmd, "<Redirect")) {
2451             /*********************************************/
2452             char *q;
2453             if (stream || feed || redirect) {
2454                 fprintf(stderr, "%s:%d: Already in a tag\n",
2455                         filename, line_num);
2456                 errors++;
2457             } else {
2458                 redirect = av_mallocz(sizeof(FFStream));
2459                 *last_stream = redirect;
2460                 last_stream = &redirect->next;
2461
2462                 get_arg(redirect->filename, sizeof(redirect->filename), &p);
2463                 q = strrchr(redirect->filename, '>');
2464                 if (*q)
2465                     *q = '\0';
2466                 redirect->stream_type = STREAM_TYPE_REDIRECT;
2467             }
2468         } else if (!strcasecmp(cmd, "URL")) {
2469             if (redirect) {
2470                 get_arg(redirect->feed_filename, sizeof(redirect->feed_filename), &p);
2471             }
2472         } else if (!strcasecmp(cmd, "</Redirect>")) {
2473             if (!redirect) {
2474                 fprintf(stderr, "%s:%d: No corresponding <Redirect> for </Redirect>\n",
2475                         filename, line_num);
2476                 errors++;
2477             }
2478             if (!redirect->feed_filename[0]) {
2479                 fprintf(stderr, "%s:%d: No URL found for <Redirect>\n",
2480                         filename, line_num);
2481                 errors++;
2482             }
2483             redirect = NULL;
2484         } else {
2485             fprintf(stderr, "%s:%d: Incorrect keyword: '%s'\n",
2486                     filename, line_num, cmd);
2487             errors++;
2488         }
2489     }
2490
2491     fclose(f);
2492     if (errors)
2493         return -1;
2494     else
2495         return 0;
2496 }
2497
2498
2499 void *http_server_thread(void *arg)
2500 {
2501     http_server(my_addr);
2502     return NULL;
2503 }
2504
2505 #if 0
2506 static void write_packet(FFCodec *ffenc,
2507                          UINT8 *buf, int size)
2508 {
2509     PacketHeader hdr;
2510     AVCodecContext *enc = &ffenc->enc;
2511     UINT8 *wptr;
2512     mk_header(&hdr, enc, size);
2513     wptr = http_fifo.wptr;
2514     fifo_write(&http_fifo, (UINT8 *)&hdr, sizeof(hdr), &wptr);
2515     fifo_write(&http_fifo, buf, size, &wptr);
2516     /* atomic modification of wptr */
2517     http_fifo.wptr = wptr;
2518     ffenc->data_count += size;
2519     ffenc->avg_frame_size = ffenc->avg_frame_size * AVG_COEF + size * (1.0 - AVG_COEF);
2520 }
2521 #endif
2522
2523 void help(void)
2524 {
2525     printf("ffserver version " FFMPEG_VERSION ", Copyright (c) 2000, 2001, 2002 Fabrice Bellard\n"
2526            "usage: ffserver [-L] [-h] [-f configfile]\n"
2527            "Hyper fast multi format Audio/Video streaming server\n"
2528            "\n"
2529            "-L            : print the LICENCE\n"
2530            "-h            : this help\n"
2531            "-f configfile : use configfile instead of /etc/ffserver.conf\n"
2532            );
2533 }
2534
2535 void licence(void)
2536 {
2537     printf(
2538     "ffserver version " FFMPEG_VERSION "\n"
2539     "Copyright (c) 2000, 2001, 2002 Fabrice Bellard\n"
2540     "This library is free software; you can redistribute it and/or\n"
2541     "modify it under the terms of the GNU Lesser General Public\n"
2542     "License as published by the Free Software Foundation; either\n"
2543     "version 2 of the License, or (at your option) any later version.\n"
2544     "\n"
2545     "This library is distributed in the hope that it will be useful,\n"
2546     "but WITHOUT ANY WARRANTY; without even the implied warranty of\n"
2547     "MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU\n"
2548     "Lesser General Public License for more details.\n"
2549     "\n"
2550     "You should have received a copy of the GNU Lesser General Public\n"
2551     "License along with this library; if not, write to the Free Software\n"
2552     "Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA\n"
2553     );
2554 }
2555
2556 static void handle_child_exit(int sig)
2557 {
2558     pid_t pid;
2559     int status;
2560
2561     while ((pid = waitpid(-1, &status, WNOHANG)) > 0) {
2562         FFStream *feed;
2563
2564         for (feed = first_feed; feed; feed = feed->next) {
2565             if (feed->pid == pid) {
2566                 int uptime = time(0) - feed->pid_start;
2567
2568                 feed->pid = 0;
2569                 fprintf(stderr, "%s: Pid %d exited with status %d after %d seconds\n", feed->filename, pid, status, uptime);
2570
2571                 if (uptime < 30) {
2572                     /* Turn off any more restarts */
2573                     feed->child_argv = 0;
2574                 }
2575             }
2576         }
2577     }
2578
2579     need_to_start_children = 1;
2580 }
2581
2582 int main(int argc, char **argv)
2583 {
2584     const char *config_filename;
2585     int c;
2586     struct sigaction sigact;
2587
2588     register_all();
2589
2590     config_filename = "/etc/ffserver.conf";
2591
2592     my_program_name = argv[0];
2593
2594     for(;;) {
2595         c = getopt_long_only(argc, argv, "ndLh?f:", NULL, NULL);
2596         if (c == -1)
2597             break;
2598         switch(c) {
2599         case 'L':
2600             licence();
2601             exit(1);
2602         case '?':
2603         case 'h':
2604             help();
2605             exit(1);
2606         case 'n':
2607             no_launch = 1;
2608             break;
2609         case 'd':
2610             ffserver_debug = 1;
2611             break;
2612         case 'f':
2613             config_filename = optarg;
2614             break;
2615         default:
2616             exit(2);
2617         }
2618     }
2619
2620     putenv("http_proxy");               /* Kill the http_proxy */
2621
2622     /* address on which the server will handle connections */
2623     my_addr.sin_family = AF_INET;
2624     my_addr.sin_port = htons (8080);
2625     my_addr.sin_addr.s_addr = htonl (INADDR_ANY);
2626     nb_max_connections = 5;
2627     nb_max_bandwidth = 1000;
2628     first_stream = NULL;
2629     logfilename[0] = '\0';
2630
2631     memset(&sigact, 0, sizeof(sigact));
2632     sigact.sa_handler = handle_child_exit;
2633     sigact.sa_flags = SA_NOCLDSTOP | SA_RESTART;
2634     sigaction(SIGCHLD, &sigact, 0);
2635
2636     if (parse_ffconfig(config_filename) < 0) {
2637         fprintf(stderr, "Incorrect config file - exiting.\n");
2638         exit(1);
2639     }
2640
2641     build_feed_streams();
2642
2643     /* signal init */
2644     signal(SIGPIPE, SIG_IGN);
2645
2646     /* open log file if needed */
2647     if (logfilename[0] != '\0') {
2648         if (!strcmp(logfilename, "-"))
2649             logfile = stdout;
2650         else
2651             logfile = fopen(logfilename, "w");
2652     }
2653
2654     if (http_server(my_addr) < 0) {
2655         fprintf(stderr, "Could not start http server\n");
2656         exit(1);
2657     }
2658
2659     return 0;
2660 }