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	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)
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)
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)
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.
int	main (int argc, char **argv)

Variables
const char	program_name [] = "ffserver"
	program name, defined by the program for show_version().
const int	program_birth_year = 2000
	program birth year, defined by the program for show_banner()
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 1301 of file ffserver.c.

Function Documentation

static void new_connection ( int  server_fd, int  is_rtsp  )

static

Definition at line 734 of file ffserver.c.

Referenced by http_server().

static void close_connection ( HTTPContext *  c )

static

Definition at line 785 of file ffserver.c.

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

static int handle_connection ( HTTPContext *  c )

static

Definition at line 872 of file ffserver.c.

Referenced by http_server().

static void compute_status ( HTTPContext *  c )

static

Definition at line 1749 of file ffserver.c.

Referenced by http_parse_request().

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

static

Definition at line 2014 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 1311 of file ffserver.c.

Referenced by handle_connection().

static int http_send_data ( HTTPContext *  c )

static

Definition at line 2347 of file ffserver.c.

Referenced by handle_connection().

static int http_start_receive_data ( HTTPContext *  c )

static

Definition at line 2467 of file ffserver.c.

Referenced by http_parse_request().

static int http_receive_data ( HTTPContext *  c )

static

Definition at line 2529 of file ffserver.c.

Referenced by handle_connection().

static int rtsp_parse_request ( HTTPContext *  c )

static

Definition at line 2717 of file ffserver.c.

Referenced by handle_connection().

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

static

Definition at line 2864 of file ffserver.c.

Referenced by rtsp_parse_request().

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

static

Definition at line 2854 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 2938 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 3119 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 3145 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 2806 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 3179 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

Definition at line 3246 of file ffserver.c.

Referenced by rtsp_cmd_setup(), and start_multicast().

static void htmlstrip ( char *  s )

static

Definition at line 259 of file ffserver.c.

Referenced by http_parse_request().

static int64_t ffm_read_write_index ( int  fd )

static

Definition at line 267 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 278 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 292 of file ffserver.c.

Referenced by http_prepare_data().

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

static

Definition at line 300 of file ffserver.c.

Referenced by http_vlog().

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

static

Definition at line 314 of file ffserver.c.

Referenced by http_av_log(), and http_log().

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

static

Definition at line 334 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 342 of file ffserver.c.

Referenced by main().

static void log_connection ( HTTPContext *  c )

static

Definition at line 354 of file ffserver.c.

Referenced by http_server().

static void update_datarate ( DataRateData *  drd, int64_t  count  )

static

Definition at line 364 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 378 of file ffserver.c.

Referenced by compute_status().

static void start_children ( FFServerStream *  feed )

static

Definition at line 387 of file ffserver.c.

Referenced by http_server().

static int socket_open_listen ( struct sockaddr_in *  my_addr )

static

Definition at line 451 of file ffserver.c.

Referenced by http_server().

static void start_multicast ( void  )

static

Definition at line 488 of file ffserver.c.

Referenced by http_server().

static int http_server ( void  )

static

Definition at line 549 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 715 of file ffserver.c.

Referenced by new_connection().

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

static

Definition at line 1049 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 1096 of file ffserver.c.

Referenced by modify_current_stream().

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

static

Definition at line 1134 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 1172 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 1190 of file ffserver.c.

Referenced by validate_acl().

static void free_acl_list ( FFServerIPAddressACL *  in_acl )

static

Definition at line 1227 of file ffserver.c.

Referenced by validate_acl().

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

static

Definition at line 1239 of file ffserver.c.

Referenced by validate_acl().

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

static

Definition at line 1256 of file ffserver.c.

Referenced by http_parse_request().

static void compute_real_filename ( char *  filename, int  max_size  )

static

Definition at line 1277 of file ffserver.c.

Referenced by http_parse_request().

static void fmt_bytecount ( AVIOContext *  pb, int64_t  count  )

static

Definition at line 1739 of file ffserver.c.

Referenced by compute_status().

static int64_t get_server_clock ( HTTPContext *  c )

static

Definition at line 2093 of file ffserver.c.

Referenced by http_send_data().

static int64_t get_packet_send_clock ( HTTPContext *  c )

static

Definition at line 2101 of file ffserver.c.

Referenced by http_send_data().

static int http_prepare_data ( HTTPContext *  c )

static

Definition at line 2116 of file ffserver.c.

Referenced by http_send_data().

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

static

Definition at line 2690 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 2711 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 2911 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 2925 of file ffserver.c.

Referenced by rtsp_cmd_setup().

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

static

Definition at line 3085 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 3345 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 3374 of file ffserver.c.

Referenced by build_feed_streams().

static void remove_stream ( FFServerStream *  stream )

static

Definition at line 3416 of file ffserver.c.

Referenced by build_file_streams().

static void extract_mpeg4_header ( AVFormatContext *  infile )

static

Definition at line 3429 of file ffserver.c.

Referenced by build_file_streams().

static void build_file_streams ( void  )

static

Definition at line 3481 of file ffserver.c.

Referenced by main().

static void build_feed_streams ( void  )

static

Definition at line 3538 of file ffserver.c.

Referenced by main().

static void compute_bandwidth ( void  )

static

Definition at line 3685 of file ffserver.c.

Referenced by main().

static void handle_child_exit ( int  sig )

static

Definition at line 3708 of file ffserver.c.

Referenced by main().

static void opt_debug ( void  )

static

Definition at line 3735 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 3741 of file ffserver.c.

Referenced by show_help().

int main	(	int	argc,
		char **	argv
	)

Definition at line 3757 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(), main(), 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 ffprobe_show_program_version(), and 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 243 of file ffserver.c.

Referenced by main(), and start_children().

int no_launch

static

Definition at line 245 of file ffserver.c.

Referenced by start_children().

int need_to_start_children

static

Definition at line 246 of file ffserver.c.

Referenced by handle_child_exit(), and http_server().

unsigned int nb_connections

static

Definition at line 249 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 251 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 253 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 255 of file ffserver.c.

FILE* logfile = NULL

static

Definition at line 257 of file ffserver.c.

Referenced by http_vlog(), and main().