FFmpeg
|
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/pixdesc.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 "cmdutils_common_opts.h"
Go to the source code of this file.
Data Structures | |
struct | RTSPActionServerSetup |
struct | DataRateData |
struct | HTTPContext |
struct | IPAddressACL |
struct | FFStream |
struct | FeedData |
Macros | |
#define | closesocket close |
#define | MAX_STREAMS 20 |
#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) |
#define | ERROR(...) report_config_error(filename, line_num, AV_LOG_ERROR, &errors, __VA_ARGS__) |
#define | WARNING(...) report_config_error(filename, line_num, AV_LOG_WARNING, &warnings, __VA_ARGS__) |
Functions | |
static void | new_connection (int server_fd, int is_rtsp) |
static void | close_connection (HTTPContext *c) |
static int | handle_connection (HTTPContext *c) |
static int | http_parse_request (HTTPContext *c) |
static int | http_send_data (HTTPContext *c) |
static void | compute_status (HTTPContext *c) |
static int | open_input_stream (HTTPContext *c, const char *info) |
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 (FFStream *stream, uint8_t **pbuffer, struct in_addr my_ip) |
static HTTPContext * | rtp_new_connection (struct sockaddr_in *from_addr, FFStream *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 int | resolve_host (struct in_addr *sin_addr, const char *hostname) |
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 (FFStream *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 (FFStream *feed, AVCodecContext *codec, int bit_rate) |
static int | modify_current_stream (HTTPContext *c, char *rates) |
static void | skip_spaces (const char **pp) |
static void | get_word (char *buf, int buf_size, const char **pp) |
static void | get_arg (char *buf, int buf_size, const char **pp) |
static void | parse_acl_row (FFStream *stream, FFStream *feed, IPAddressACL *ext_acl, const char *p, const char *filename, int line_num) |
static IPAddressACL * | parse_dynamic_acl (FFStream *stream, HTTPContext *c) |
static void | free_acl_list (IPAddressACL *in_acl) |
static int | validate_acl_list (IPAddressACL *in_acl, HTTPContext *c) |
static int | validate_acl (FFStream *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 (FFStream *stream, AVCodecContext *codec, int copy) |
static int | add_av_stream (FFStream *feed, AVStream *st) |
static void | remove_stream (FFStream *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 | add_codec (FFStream *stream, AVCodecContext *av) |
static enum AVCodecID | opt_codec (const char *name, enum AVMediaType type) |
static int | ffserver_opt_default (const char *opt, const char *arg, AVCodecContext *avctx, int type) |
static int | ffserver_opt_preset (const char *arg, AVCodecContext *avctx, int type, enum AVCodecID *audio_id, enum AVCodecID *video_id) |
static AVOutputFormat * | ffserver_guess_format (const char *short_name, const char *filename, const char *mime_type) |
static void | report_config_error (const char *filename, int line_num, int log_level, int *errors, const char *fmt,...) |
static int | parse_ffconfig (const char *filename) |
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 * | http_state [] |
static struct sockaddr_in | my_http_addr |
static struct sockaddr_in | my_rtsp_addr |
static char | logfilename [1024] |
static HTTPContext * | first_http_ctx |
static FFStream * | first_feed |
static FFStream * | first_stream |
static const char * | my_program_name |
static const char * | config_filename |
static int | ffserver_debug |
static int | no_launch |
static int | need_to_start_children |
static unsigned int | nb_max_http_connections = 2000 |
static unsigned int | nb_max_connections = 5 |
static unsigned int | nb_connections |
static uint64_t | max_bandwidth = 1000 |
static uint64_t | current_bandwidth |
static int64_t | cur_time |
static AVLFG | random_state |
static FILE * | logfile = NULL |
multiple format streaming server based on the FFmpeg libraries
Definition in file ffserver.c.
#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 MAX_STREAMS 20 |
Definition at line 110 of file ffserver.c.
#define IOBUFFER_INIT_SIZE 8192 |
Definition at line 112 of file ffserver.c.
Referenced by new_connection(), and rtp_new_connection().
#define HTTP_REQUEST_TIMEOUT (15 * 1000) |
Definition at line 115 of file ffserver.c.
Referenced by start_wait_request().
#define RTSP_REQUEST_TIMEOUT (3600 * 24 * 1000) |
Definition at line 116 of file ffserver.c.
Referenced by start_wait_request().
#define SYNC_TIMEOUT (10 * 1000) |
Definition at line 118 of file ffserver.c.
#define CHECK_CODEC | ( | x | ) | (ccf->x != ccs->x) |
Referenced by build_feed_streams().
#define ERROR | ( | ... | ) | report_config_error(filename, line_num, AV_LOG_ERROR, &errors, __VA_ARGS__) |
Referenced by main(), and parse_ffconfig().
#define WARNING | ( | ... | ) | report_config_error(filename, line_num, AV_LOG_WARNING, &warnings, __VA_ARGS__) |
Referenced by parse_ffconfig().
enum HTTPState |
Definition at line 79 of file ffserver.c.
enum StreamType |
Definition at line 196 of file ffserver.c.
enum IPAddressAction |
Definition at line 202 of file ffserver.c.
enum RedirType |
Definition at line 1501 of file ffserver.c.
|
static |
Definition at line 823 of file ffserver.c.
Referenced by http_server().
|
static |
Definition at line 874 of file ffserver.c.
Referenced by handle_connection(), http_server(), and rtsp_cmd_interrupt().
|
static |
Definition at line 963 of file ffserver.c.
Referenced by http_server().
|
static |
Definition at line 1511 of file ffserver.c.
Referenced by handle_connection().
|
static |
Definition at line 2518 of file ffserver.c.
Referenced by handle_connection().
|
static |
Definition at line 1946 of file ffserver.c.
Referenced by http_parse_request().
|
static |
Definition at line 2188 of file ffserver.c.
Referenced by http_parse_request(), http_prepare_data(), rtsp_cmd_setup(), and start_multicast().
|
static |
Definition at line 2637 of file ffserver.c.
Referenced by http_parse_request().
|
static |
Definition at line 2696 of file ffserver.c.
Referenced by handle_connection().
|
static |
Definition at line 2882 of file ffserver.c.
Referenced by handle_connection().
|
static |
Definition at line 3028 of file ffserver.c.
Referenced by rtsp_parse_request().
|
static |
Definition at line 3019 of file ffserver.c.
Referenced by rtsp_parse_request().
|
static |
Definition at line 3102 of file ffserver.c.
Referenced by rtsp_parse_request().
|
static |
Definition at line 3282 of file ffserver.c.
Referenced by rtsp_parse_request().
|
static |
Definition at line 3308 of file ffserver.c.
Referenced by rtsp_parse_request().
|
static |
Definition at line 2971 of file ffserver.c.
Referenced by http_parse_request(), and rtsp_cmd_describe().
|
static |
Definition at line 3341 of file ffserver.c.
Referenced by rtsp_cmd_setup(), and start_multicast().
|
static |
Definition at line 3407 of file ffserver.c.
Referenced by rtsp_cmd_setup(), and start_multicast().
|
static |
Definition at line 329 of file ffserver.c.
Referenced by http_parse_request().
|
static |
Definition at line 337 of file ffserver.c.
Referenced by build_feed_streams(), and http_start_receive_data().
|
static |
Definition at line 348 of file ffserver.c.
Referenced by http_receive_data(), and http_start_receive_data().
|
static |
Definition at line 362 of file ffserver.c.
Referenced by http_prepare_data().
|
static |
Definition at line 372 of file ffserver.c.
Referenced by parse_acl_row(), and parse_ffconfig().
|
static |
Definition at line 405 of file ffserver.c.
Referenced by http_vlog().
|
static |
Definition at line 419 of file ffserver.c.
Referenced by http_av_log(), and http_log().
|
static |
Definition at line 437 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().
Definition at line 445 of file ffserver.c.
Referenced by main().
|
static |
Definition at line 457 of file ffserver.c.
Referenced by http_server().
|
static |
Definition at line 467 of file ffserver.c.
Referenced by http_receive_data(), and http_send_data().
|
static |
Definition at line 481 of file ffserver.c.
Referenced by compute_status().
Definition at line 490 of file ffserver.c.
Referenced by http_server().
|
static |
Definition at line 550 of file ffserver.c.
Referenced by http_server().
Definition at line 586 of file ffserver.c.
Referenced by http_server().
|
static |
Definition at line 642 of file ffserver.c.
Referenced by main().
|
static |
Definition at line 791 of file ffserver.c.
Referenced by handle_connection(), and new_connection().
|
static |
Definition at line 805 of file ffserver.c.
Referenced by new_connection().
|
static |
Definition at line 1139 of file ffserver.c.
Referenced by http_parse_request().
|
static |
Definition at line 1186 of file ffserver.c.
Referenced by modify_current_stream().
|
static |
Definition at line 1223 of file ffserver.c.
Referenced by http_parse_request().
|
static |
Definition at line 1263 of file ffserver.c.
Referenced by get_word().
|
static |
Definition at line 1272 of file ffserver.c.
Referenced by http_parse_request(), and rtsp_parse_request().
|
static |
Definition at line 1290 of file ffserver.c.
Referenced by parse_acl_row(), parse_dynamic_acl(), and parse_ffconfig().
|
static |
Definition at line 1322 of file ffserver.c.
Referenced by parse_dynamic_acl(), and parse_ffconfig().
|
static |
Definition at line 1389 of file ffserver.c.
Referenced by validate_acl().
|
static |
Definition at line 1426 of file ffserver.c.
Referenced by validate_acl().
|
static |
Definition at line 1438 of file ffserver.c.
Referenced by validate_acl().
|
static |
Definition at line 1455 of file ffserver.c.
Referenced by http_parse_request().
|
static |
Definition at line 1477 of file ffserver.c.
Referenced by http_parse_request().
|
static |
Definition at line 1936 of file ffserver.c.
Referenced by compute_status().
|
static |
Definition at line 2265 of file ffserver.c.
Referenced by http_send_data().
|
static |
Definition at line 2273 of file ffserver.c.
Referenced by http_send_data().
|
static |
Definition at line 2288 of file ffserver.c.
Referenced by http_send_data().
|
static |
Definition at line 2855 of file ffserver.c.
Referenced by rtsp_cmd_describe(), rtsp_cmd_interrupt(), rtsp_cmd_play(), rtsp_cmd_setup(), and rtsp_reply_error().
|
static |
Definition at line 2876 of file ffserver.c.
Referenced by rtsp_cmd_describe(), rtsp_cmd_interrupt(), rtsp_cmd_play(), rtsp_cmd_setup(), and rtsp_parse_request().
|
static |
Definition at line 3075 of file ffserver.c.
Referenced by find_rtp_session_with_url(), and rtsp_cmd_setup().
|
static |
Definition at line 3089 of file ffserver.c.
Referenced by rtsp_cmd_setup().
|
static |
Definition at line 3248 of file ffserver.c.
Referenced by rtsp_cmd_interrupt(), and rtsp_cmd_play().
|
static |
Definition at line 3506 of file ffserver.c.
Referenced by add_av_stream(), and build_file_streams().
Definition at line 3539 of file ffserver.c.
Referenced by build_feed_streams().
Definition at line 3579 of file ffserver.c.
Referenced by build_file_streams().
|
static |
Definition at line 3592 of file ffserver.c.
Referenced by build_file_streams().
Definition at line 3643 of file ffserver.c.
Referenced by main().
Definition at line 3695 of file ffserver.c.
Referenced by main().
Definition at line 3842 of file ffserver.c.
Referenced by main().
|
static |
Definition at line 3866 of file ffserver.c.
Referenced by parse_ffconfig().
|
static |
Definition at line 3944 of file ffserver.c.
Referenced by ffserver_opt_preset(), and parse_ffconfig().
|
static |
Definition at line 3953 of file ffserver.c.
Referenced by ffserver_opt_preset(), and parse_ffconfig().
|
static |
Definition at line 3963 of file ffserver.c.
Referenced by parse_ffconfig().
|
static |
Definition at line 4006 of file ffserver.c.
Referenced by parse_ffconfig().
|
static |
Definition at line 4024 of file ffserver.c.
|
static |
Definition at line 4035 of file ffserver.c.
Referenced by main().
|
static |
Definition at line 4678 of file ffserver.c.
Referenced by main().
Definition at line 4703 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 4709 of file ffserver.c.
Referenced by show_help().
int main | ( | int | argc, |
char ** | argv | ||
) |
Definition at line 4725 of file ffserver.c.
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().
|
static |
Definition at line 77 of file ffserver.c.
|
static |
Definition at line 94 of file ffserver.c.
Referenced by compute_status().
|
static |
Definition at line 267 of file ffserver.c.
Referenced by http_server(), and parse_ffconfig().
|
static |
Definition at line 268 of file ffserver.c.
Referenced by http_parse_request(), http_server(), and parse_ffconfig().
|
static |
Definition at line 270 of file ffserver.c.
Referenced by main(), opt_debug(), parse_ffconfig(), and transcode_init().
|
static |
Definition at line 271 of file ffserver.c.
Referenced by close_connection(), compute_status(), http_server(), new_connection(), and rtp_new_connection().
|
static |
Definition at line 272 of file ffserver.c.
Referenced by parse_ffconfig().
|
static |
Definition at line 273 of file ffserver.c.
Referenced by compute_status(), http_parse_request(), parse_ffconfig(), and remove_stream().
|
static |
Definition at line 307 of file ffserver.c.
Referenced by main(), and start_children().
|
static |
Definition at line 309 of file ffserver.c.
Referenced by main().
|
static |
Definition at line 311 of file ffserver.c.
Referenced by http_parse_request(), opt_debug(), parse_ffconfig(), and start_children().
|
static |
Definition at line 312 of file ffserver.c.
Referenced by start_children().
|
static |
Definition at line 313 of file ffserver.c.
Referenced by handle_child_exit(), and http_server().
|
static |
Definition at line 316 of file ffserver.c.
Referenced by http_server(), and parse_ffconfig().
|
static |
Definition at line 317 of file ffserver.c.
Referenced by compute_status(), http_send_too_busy_reply(), new_connection(), parse_ffconfig(), and rtp_new_connection().
|
static |
Definition at line 318 of file ffserver.c.
Referenced by close_connection(), compute_status(), http_send_too_busy_reply(), new_connection(), and rtp_new_connection().
|
static |
Definition at line 320 of file ffserver.c.
Referenced by compute_status(), hls_open(), http_parse_request(), and parse_ffconfig().
|
static |
Definition at line 321 of file ffserver.c.
Referenced by close_connection(), compute_status(), http_parse_request(), and rtp_new_connection().
|
static |
Definition at line 323 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(), print_report(), start_wait_request(), transcode(), update_datarate(), and video_refresh().
|
static |
Definition at line 325 of file ffserver.c.
|
static |
Definition at line 327 of file ffserver.c.
Referenced by http_vlog(), and main().