FFmpeg
 All Data Structures Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros Groups Pages
Data Structures | Macros | Enumerations | Functions | Variables
ffserver.c File Reference

multiple format streaming server based on the FFmpeg libraries More...

#include "config.h"
#include <string.h>
#include <stdlib.h>
#include <stdio.h>
#include "libavformat/avformat.h"
#include "libavformat/ffm.h"
#include "libavformat/network.h"
#include "libavformat/os_support.h"
#include "libavformat/rtpdec.h"
#include "libavformat/rtpproto.h"
#include "libavformat/rtsp.h"
#include "libavformat/rtspcodes.h"
#include "libavformat/avio_internal.h"
#include "libavformat/internal.h"
#include "libavformat/url.h"
#include "libavutil/avassert.h"
#include "libavutil/avstring.h"
#include "libavutil/lfg.h"
#include "libavutil/dict.h"
#include "libavutil/intreadwrite.h"
#include "libavutil/mathematics.h"
#include "libavutil/random_seed.h"
#include "libavutil/parseutils.h"
#include "libavutil/opt.h"
#include "libavutil/time.h"
#include <stdarg.h>
#include <fcntl.h>
#include <sys/ioctl.h>
#include <errno.h>
#include <sys/wait.h>
#include <signal.h>
#include "cmdutils.h"
#include "ffserver_config.h"
#include "cmdutils_common_opts.h"

Go to the source code of this file.

Data Structures

struct  RTSPActionServerSetup
 
struct  DataRateData
 
struct  HTTPContext
 
struct  FeedData
 

Macros

#define closesocket   close
 
#define IOBUFFER_INIT_SIZE   8192
 
#define HTTP_REQUEST_TIMEOUT   (15 * 1000)
 
#define RTSP_REQUEST_TIMEOUT   (3600 * 24 * 1000)
 
#define SYNC_TIMEOUT   (10 * 1000)
 
#define CHECK_CODEC(x)   (ccf->x != ccs->x)
 

Enumerations

enum  HTTPState {
  HTTPSTATE_WAIT_REQUEST, HTTPSTATE_SEND_HEADER, HTTPSTATE_SEND_DATA_HEADER, HTTPSTATE_SEND_DATA,
  HTTPSTATE_SEND_DATA_TRAILER, HTTPSTATE_RECEIVE_DATA, HTTPSTATE_WAIT_FEED, HTTPSTATE_READY,
  RTSPSTATE_WAIT_REQUEST, RTSPSTATE_SEND_REPLY, RTSPSTATE_SEND_PACKET
}
 
enum  RedirType {
  REDIR_NONE, REDIR_ASX, REDIR_RAM, REDIR_ASF,
  REDIR_RTSP, REDIR_SDP
}
 

Functions

static void new_connection (int server_fd, int is_rtsp)
 
static void close_connection (HTTPContext *c)
 
static int handle_connection (HTTPContext *c)
 
static void print_stream_params (AVIOContext *pb, FFServerStream *stream)
 
static void compute_status (HTTPContext *c)
 
static int open_input_stream (HTTPContext *c, const char *info)
 
static int http_parse_request (HTTPContext *c)
 
static int http_send_data (HTTPContext *c)
 
static int http_start_receive_data (HTTPContext *c)
 
static int http_receive_data (HTTPContext *c)
 
static int rtsp_parse_request (HTTPContext *c)
 
static void rtsp_cmd_describe (HTTPContext *c, const char *url)
 
static void rtsp_cmd_options (HTTPContext *c, const char *url)
 
static void rtsp_cmd_setup (HTTPContext *c, const char *url, RTSPMessageHeader *h)
 
static void rtsp_cmd_play (HTTPContext *c, const char *url, RTSPMessageHeader *h)
 
static void rtsp_cmd_interrupt (HTTPContext *c, const char *url, RTSPMessageHeader *h, int pause_only)
 
static int prepare_sdp_description (FFServerStream *stream, uint8_t **pbuffer, struct in_addr my_ip)
 
static HTTPContext * rtp_new_connection (struct sockaddr_in *from_addr, FFServerStream *stream, const char *session_id, enum RTSPLowerTransport rtp_protocol)
 
static int rtp_new_av_stream (HTTPContext *c, int stream_index, struct sockaddr_in *dest_addr, HTTPContext *rtsp_c)
 add a new RTP stream in an RTP connection (used in RTSP SETUP command). More...
 
static void htmlstrip (char *s)
 
static int64_t ffm_read_write_index (int fd)
 
static int ffm_write_write_index (int fd, int64_t pos)
 
static void ffm_set_write_index (AVFormatContext *s, int64_t pos, int64_t file_size)
 
static char * ctime1 (char *buf2, int buf_size)
 
static void http_vlog (const char *fmt, va_list vargs)
 
static void http_log (const char *fmt,...)
 
static void http_av_log (void *ptr, int level, const char *fmt, va_list vargs)
 
static void log_connection (HTTPContext *c)
 
static void update_datarate (DataRateData *drd, int64_t count)
 
static int compute_datarate (DataRateData *drd, int64_t count)
 
static void start_children (FFServerStream *feed)
 
static int socket_open_listen (struct sockaddr_in *my_addr)
 
static void start_multicast (void)
 
static int http_server (void)
 
static void start_wait_request (HTTPContext *c, int is_rtsp)
 
static void http_send_too_busy_reply (int fd)
 
static int extract_rates (char *rates, int ratelen, const char *request)
 
static int find_stream_in_feed (FFServerStream *feed, AVCodecContext *codec, int bit_rate)
 
static int modify_current_stream (HTTPContext *c, char *rates)
 
static void get_word (char *buf, int buf_size, const char **pp)
 
static FFServerIPAddressACL * parse_dynamic_acl (FFServerStream *stream, HTTPContext *c)
 
static void free_acl_list (FFServerIPAddressACL *in_acl)
 
static int validate_acl_list (FFServerIPAddressACL *in_acl, HTTPContext *c)
 
static int validate_acl (FFServerStream *stream, HTTPContext *c)
 
static void compute_real_filename (char *filename, int max_size)
 compute the real filename of a file by matching it without its extensions to all the stream's filenames More...
 
static void fmt_bytecount (AVIOContext *pb, int64_t count)
 
static int64_t get_server_clock (HTTPContext *c)
 
static int64_t get_packet_send_clock (HTTPContext *c)
 
static int http_prepare_data (HTTPContext *c)
 
static void rtsp_reply_header (HTTPContext *c, enum RTSPStatusCode error_number)
 
static void rtsp_reply_error (HTTPContext *c, enum RTSPStatusCode error_number)
 
static HTTPContext * find_rtp_session (const char *session_id)
 
static RTSPTransportField * find_transport (RTSPMessageHeader *h, enum RTSPLowerTransport lower_transport)
 
static HTTPContext * find_rtp_session_with_url (const char *url, const char *session_id)
 find an RTP connection by using the session ID. More...
 
static AVStream * add_av_stream1 (FFServerStream *stream, AVCodecContext *codec, int copy)
 
static int add_av_stream (FFServerStream *feed, AVStream *st)
 
static void remove_stream (FFServerStream *stream)
 
static void extract_mpeg4_header (AVFormatContext *infile)
 
static void build_file_streams (void)
 
static void build_feed_streams (void)
 
static void compute_bandwidth (void)
 
static void handle_child_exit (int sig)
 
static void opt_debug (void)
 
void show_help_default (const char *opt, const char *arg)
 Per-fftool specific help handler. More...
 
int main (int argc, char **argv)
 

Variables

const char program_name [] = "ffserver"
 program name, defined by the program for show_version(). More...
 
const int program_birth_year = 2000
 program birth year, defined by the program for show_banner() More...
 
static const OptionDef options []
 
static const char *const http_state []
 
static HTTPContext * first_http_ctx
 
static FFServerConfig config
 
static const char * my_program_name
 
static int no_launch
 
static int need_to_start_children
 
static unsigned int nb_connections
 
static uint64_t current_bandwidth
 
static int64_t cur_time
 
static AVLFG random_state
 
static FILE * logfile = NULL
 

Detailed Description

multiple format streaming server based on the FFmpeg libraries

Definition in file ffserver.c.

Macro Definition Documentation

#define closesocket   close

Definition at line 28 of file ffserver.c.

Referenced by close_connection(), ff_listen_bind(), http_server(), new_connection(), sctp_close(), sctp_open(), socket_open_listen(), tcp_close(), tcp_open(), udp_close(), udp_open(), udp_socket_create(), unix_close(), and unix_open().

#define IOBUFFER_INIT_SIZE   8192

Definition at line 110 of file ffserver.c.

Referenced by new_connection(), and rtp_new_connection().

#define HTTP_REQUEST_TIMEOUT   (15 * 1000)

Definition at line 113 of file ffserver.c.

Referenced by start_wait_request().

#define RTSP_REQUEST_TIMEOUT   (3600 * 24 * 1000)

Definition at line 114 of file ffserver.c.

Referenced by start_wait_request().

#define SYNC_TIMEOUT   (10 * 1000)

Definition at line 116 of file ffserver.c.

#define CHECK_CODEC (   x)    (ccf->x != ccs->x)

Referenced by build_feed_streams().

Enumeration Type Documentation

enum HTTPState
Enumerator
HTTPSTATE_WAIT_REQUEST 
HTTPSTATE_SEND_HEADER 
HTTPSTATE_SEND_DATA_HEADER 
HTTPSTATE_SEND_DATA 
HTTPSTATE_SEND_DATA_TRAILER 
HTTPSTATE_RECEIVE_DATA 
HTTPSTATE_WAIT_FEED 
HTTPSTATE_READY 
RTSPSTATE_WAIT_REQUEST 
RTSPSTATE_SEND_REPLY 
RTSPSTATE_SEND_PACKET 

Definition at line 79 of file ffserver.c.

enum RedirType
Enumerator
REDIR_NONE 
REDIR_ASX 
REDIR_RAM 
REDIR_ASF 
REDIR_RTSP 
REDIR_SDP 

Definition at line 1304 of file ffserver.c.

Function Documentation

static void new_connection ( int  server_fd,
int  is_rtsp 
)
static

Definition at line 730 of file ffserver.c.

Referenced by http_server().

static void close_connection ( HTTPContext *  c)
static

Definition at line 781 of file ffserver.c.

Referenced by handle_connection(), http_server(), and rtsp_cmd_interrupt().

static int handle_connection ( HTTPContext *  c)
static

Definition at line 865 of file ffserver.c.

Referenced by http_server().

static void print_stream_params ( AVIOContext *  pb,
FFServerStream *  stream 
)
inlinestatic

Definition at line 1753 of file ffserver.c.

Referenced by compute_status().

static void compute_status ( HTTPContext *  c)
static

Definition at line 1799 of file ffserver.c.

Referenced by http_parse_request().

static int open_input_stream ( HTTPContext *  c,
const char *  info 
)
static

Definition at line 2029 of file ffserver.c.

Referenced by http_parse_request(), http_prepare_data(), rtsp_cmd_setup(), and start_multicast().

static int http_parse_request ( HTTPContext *  c)
static

Definition at line 1314 of file ffserver.c.

Referenced by handle_connection().

static int http_send_data ( HTTPContext *  c)
static

Definition at line 2379 of file ffserver.c.

Referenced by handle_connection().

static int http_start_receive_data ( HTTPContext *  c)
static

Definition at line 2500 of file ffserver.c.

Referenced by http_parse_request().

static int http_receive_data ( HTTPContext *  c)
static

Definition at line 2561 of file ffserver.c.

Referenced by handle_connection().

static int rtsp_parse_request ( HTTPContext *  c)
static

Definition at line 2751 of file ffserver.c.

Referenced by handle_connection().

static void rtsp_cmd_describe ( HTTPContext *  c,
const char *  url 
)
static

Definition at line 2902 of file ffserver.c.

Referenced by rtsp_parse_request().

static void rtsp_cmd_options ( HTTPContext *  c,
const char *  url 
)
static

Definition at line 2892 of file ffserver.c.

Referenced by rtsp_parse_request().

static void rtsp_cmd_setup ( HTTPContext *  c,
const char *  url,
RTSPMessageHeader *  h 
)
static

Definition at line 2977 of file ffserver.c.

Referenced by rtsp_parse_request().

static void rtsp_cmd_play ( HTTPContext *  c,
const char *  url,
RTSPMessageHeader *  h 
)
static

Definition at line 3160 of file ffserver.c.

Referenced by rtsp_parse_request().

static void rtsp_cmd_interrupt ( HTTPContext *  c,
const char *  url,
RTSPMessageHeader *  h,
int  pause_only 
)
static

Definition at line 3186 of file ffserver.c.

Referenced by rtsp_parse_request().

static int prepare_sdp_description ( FFServerStream *  stream,
uint8_t **  pbuffer,
struct in_addr  my_ip 
)
static

Definition at line 2840 of file ffserver.c.

Referenced by http_parse_request(), and rtsp_cmd_describe().

static HTTPContext * rtp_new_connection ( struct sockaddr_in *  from_addr,
FFServerStream *  stream,
const char *  session_id,
enum RTSPLowerTransport  rtp_protocol 
)
static

Definition at line 3220 of file ffserver.c.

Referenced by rtsp_cmd_setup(), and start_multicast().

static int rtp_new_av_stream ( HTTPContext *  c,
int  stream_index,
struct sockaddr_in *  dest_addr,
HTTPContext *  rtsp_c 
)
static

add a new RTP stream in an RTP connection (used in RTSP SETUP command).

If RTP/TCP protocol is used, TCP connection 'rtsp_c' is used.

Definition at line 3289 of file ffserver.c.

Referenced by rtsp_cmd_setup(), and start_multicast().

static void htmlstrip ( char *  s)
static

Definition at line 261 of file ffserver.c.

Referenced by http_parse_request().

static int64_t ffm_read_write_index ( int  fd)
static

Definition at line 269 of file ffserver.c.

Referenced by build_feed_streams(), and http_start_receive_data().

static int ffm_write_write_index ( int  fd,
int64_t  pos 
)
static

Definition at line 280 of file ffserver.c.

Referenced by http_receive_data(), and http_start_receive_data().

static void ffm_set_write_index ( AVFormatContext *  s,
int64_t  pos,
int64_t  file_size 
)
static

Definition at line 294 of file ffserver.c.

Referenced by http_prepare_data().

static char* ctime1 ( char *  buf2,
int  buf_size 
)
static

Definition at line 302 of file ffserver.c.

Referenced by http_vlog().

static void http_vlog ( const char *  fmt,
va_list  vargs 
)
static

Definition at line 316 of file ffserver.c.

Referenced by http_av_log(), and http_log().

static void http_log ( const char *  fmt,
  ... 
)
static

Definition at line 336 of file ffserver.c.

Referenced by build_feed_streams(), build_file_streams(), http_av_log(), http_parse_request(), http_prepare_data(), http_receive_data(), http_server(), http_start_receive_data(), log_connection(), main(), new_connection(), open_input_stream(), rtp_new_av_stream(), start_children(), and start_multicast().

static void http_av_log ( void *  ptr,
int  level,
const char *  fmt,
va_list  vargs 
)
static

Definition at line 344 of file ffserver.c.

Referenced by main().

static void log_connection ( HTTPContext *  c)
static

Definition at line 356 of file ffserver.c.

Referenced by http_server().

static void update_datarate ( DataRateData *  drd,
int64_t  count 
)
static

Definition at line 366 of file ffserver.c.

Referenced by http_receive_data(), and http_send_data().

static int compute_datarate ( DataRateData *  drd,
int64_t  count 
)
static

Definition at line 380 of file ffserver.c.

Referenced by compute_status().

static void start_children ( FFServerStream *  feed)
static

Definition at line 389 of file ffserver.c.

Referenced by http_server().

static int socket_open_listen ( struct sockaddr_in *  my_addr)
static

Definition at line 453 of file ffserver.c.

Referenced by http_server().

static void start_multicast ( void  )
static

Definition at line 490 of file ffserver.c.

Referenced by http_server().

static int http_server ( void  )
static

Definition at line 550 of file ffserver.c.

Referenced by main().

static void start_wait_request ( HTTPContext *  c,
int  is_rtsp 
)
static

Definition at line 701 of file ffserver.c.

Referenced by handle_connection(), and new_connection().

static void http_send_too_busy_reply ( int  fd)
static

Definition at line 711 of file ffserver.c.

Referenced by new_connection().

static int extract_rates ( char *  rates,
int  ratelen,
const char *  request 
)
static

Definition at line 1046 of file ffserver.c.

Referenced by http_parse_request().

static int find_stream_in_feed ( FFServerStream *  feed,
AVCodecContext *  codec,
int  bit_rate 
)
static

Definition at line 1093 of file ffserver.c.

Referenced by modify_current_stream().

static int modify_current_stream ( HTTPContext *  c,
char *  rates 
)
static

Definition at line 1131 of file ffserver.c.

Referenced by http_parse_request().

static void get_word ( char *  buf,
int  buf_size,
const char **  pp 
)
static

Definition at line 1171 of file ffserver.c.

Referenced by http_parse_request(), and rtsp_parse_request().

static FFServerIPAddressACL* parse_dynamic_acl ( FFServerStream *  stream,
HTTPContext *  c 
)
static

Definition at line 1189 of file ffserver.c.

Referenced by validate_acl().

static void free_acl_list ( FFServerIPAddressACL *  in_acl)
static

Definition at line 1230 of file ffserver.c.

Referenced by validate_acl().

static int validate_acl_list ( FFServerIPAddressACL *  in_acl,
HTTPContext *  c 
)
static

Definition at line 1242 of file ffserver.c.

Referenced by validate_acl().

static int validate_acl ( FFServerStream *  stream,
HTTPContext *  c 
)
static

Definition at line 1259 of file ffserver.c.

Referenced by http_parse_request().

static void compute_real_filename ( char *  filename,
int  max_size 
)
static

compute the real filename of a file by matching it without its extensions to all the stream's filenames

Definition at line 1280 of file ffserver.c.

Referenced by http_parse_request().

static void fmt_bytecount ( AVIOContext *  pb,
int64_t  count 
)
static

Definition at line 1743 of file ffserver.c.

Referenced by compute_status().

static int64_t get_server_clock ( HTTPContext *  c)
static

Definition at line 2115 of file ffserver.c.

Referenced by http_send_data().

static int64_t get_packet_send_clock ( HTTPContext *  c)
static

Definition at line 2122 of file ffserver.c.

Referenced by http_send_data().

static int http_prepare_data ( HTTPContext *  c)
static

Definition at line 2136 of file ffserver.c.

Referenced by http_send_data().

static void rtsp_reply_header ( HTTPContext *  c,
enum RTSPStatusCode  error_number 
)
static

Definition at line 2724 of file ffserver.c.

Referenced by rtsp_cmd_describe(), rtsp_cmd_interrupt(), rtsp_cmd_play(), rtsp_cmd_setup(), and rtsp_reply_error().

static void rtsp_reply_error ( HTTPContext *  c,
enum RTSPStatusCode  error_number 
)
static

Definition at line 2745 of file ffserver.c.

Referenced by rtsp_cmd_describe(), rtsp_cmd_interrupt(), rtsp_cmd_play(), rtsp_cmd_setup(), and rtsp_parse_request().

static HTTPContext* find_rtp_session ( const char *  session_id)
static

Definition at line 2950 of file ffserver.c.

Referenced by find_rtp_session_with_url(), and rtsp_cmd_setup().

static RTSPTransportField* find_transport ( RTSPMessageHeader *  h,
enum RTSPLowerTransport  lower_transport 
)
static

Definition at line 2964 of file ffserver.c.

Referenced by rtsp_cmd_setup().

static HTTPContext* find_rtp_session_with_url ( const char *  url,
const char *  session_id 
)
static

find an RTP connection by using the session ID.

Check consistency with filename

Definition at line 3126 of file ffserver.c.

Referenced by rtsp_cmd_interrupt(), and rtsp_cmd_play().

static AVStream* add_av_stream1 ( FFServerStream *  stream,
AVCodecContext *  codec,
int  copy 
)
static

Definition at line 3388 of file ffserver.c.

Referenced by add_av_stream(), and build_file_streams().

static int add_av_stream ( FFServerStream *  feed,
AVStream *  st 
)
static

Definition at line 3421 of file ffserver.c.

Referenced by build_feed_streams().

static void remove_stream ( FFServerStream *  stream)
static

Definition at line 3463 of file ffserver.c.

Referenced by build_file_streams().

static void extract_mpeg4_header ( AVFormatContext *  infile)
static

Definition at line 3476 of file ffserver.c.

Referenced by build_file_streams().

static void build_file_streams ( void  )
static

Definition at line 3527 of file ffserver.c.

Referenced by main().

static void build_feed_streams ( void  )
static

Definition at line 3584 of file ffserver.c.

Referenced by main().

static void compute_bandwidth ( void  )
static

Definition at line 3743 of file ffserver.c.

Referenced by main().

static void handle_child_exit ( int  sig)
static

Definition at line 3766 of file ffserver.c.

Referenced by main().

static void opt_debug ( void  )
static

Definition at line 3793 of file ffserver.c.

void show_help_default ( const char *  opt,
const char *  arg 
)

Per-fftool specific help handler.

Implemented in each fftool, called by show_help().

Definition at line 3799 of file ffserver.c.

Referenced by show_help().

int main ( int  argc,
char **  argv 
)

Definition at line 3815 of file ffserver.c.

Variable Documentation

const char program_name[] = "ffserver"

program name, defined by the program for show_version().

Definition at line 74 of file ffserver.c.

Referenced by compute_status(), expand_filename_template(), init_report(), print_program_info(), show_help_default(), show_license(), and show_usage().

const int program_birth_year = 2000

program birth year, defined by the program for show_banner()

Definition at line 75 of file ffserver.c.

Referenced by print_program_info().

const OptionDef options[]
static

Definition at line 77 of file ffserver.c.

const char* const http_state[]
static
Initial value:
= {
"HTTP_WAIT_REQUEST",
"HTTP_SEND_HEADER",
"SEND_DATA_HEADER",
"SEND_DATA",
"SEND_DATA_TRAILER",
"RECEIVE_DATA",
"WAIT_FEED",
"READY",
"RTSP_WAIT_REQUEST",
"RTSP_SEND_REPLY",
"RTSP_SEND_PACKET",
}

Definition at line 94 of file ffserver.c.

Referenced by compute_status().

HTTPContext* first_http_ctx
static

Definition at line 198 of file ffserver.c.

Referenced by close_connection(), compute_status(), http_server(), new_connection(), and rtp_new_connection().

FFServerConfig config
static
Initial value:
= {
.nb_max_http_connections = 2000,
.nb_max_connections = 5,
.max_bandwidth = 1000,
.use_defaults = 1,
}

Definition at line 200 of file ffserver.c.

Referenced by dshow_cycle_formats(), dshow_set_audio_buffer_size(), dxva2_create_decoder(), parse_dsd_prop(), parse_fmtp_config(), and wavpack_encode_init().

const char* my_program_name
static

Definition at line 244 of file ffserver.c.

Referenced by main(), and start_children().

int no_launch
static

Definition at line 246 of file ffserver.c.

Referenced by start_children().

int need_to_start_children
static

Definition at line 247 of file ffserver.c.

Referenced by handle_child_exit(), and http_server().

unsigned int nb_connections
static

Definition at line 250 of file ffserver.c.

Referenced by close_connection(), compute_status(), http_send_too_busy_reply(), new_connection(), and rtp_new_connection().

uint64_t current_bandwidth
static

Definition at line 252 of file ffserver.c.

Referenced by close_connection(), compute_status(), http_parse_request(), and rtp_new_connection().

int64_t cur_time
static

Definition at line 255 of file ffserver.c.

Referenced by audio_read_packet(), check_keyboard_interaction(), compute_datarate(), get_server_clock(), handle_connection(), http_prepare_data(), http_server(), open_input_stream(), output_segment_list(), print_report(), start_wait_request(), transcode(), update_datarate(), and video_refresh().

AVLFG random_state
static

Definition at line 257 of file ffserver.c.

FILE* logfile = NULL
static

Definition at line 259 of file ffserver.c.

Referenced by http_vlog(), and main().

Generated on Thu Sep 10 2015 11:39:07 for FFmpeg by   doxygen 1.8.6