HTTPSTATE_WAIT_REQUEST,

HTTPSTATE_SEND_HEADER,

HTTPSTATE_SEND_DATA_HEADER,

HTTPSTATE_SEND_DATA, /* sending TCP or UDP data */

HTTPSTATE_SEND_DATA_TRAILER,

HTTPSTATE_RECEIVE_DATA,

HTTPSTATE_WAIT_FEED, /* wait for data from the feed */

HTTPSTATE_READY,

RTSPSTATE_WAIT_REQUEST,

RTSPSTATE_SEND_REPLY,

RTSPSTATE_SEND_PACKET,

enum HTTPState state;

int fd; /* socket file descriptor */

struct sockaddr_in from_addr; /* origin */

struct pollfd *poll_entry; /* used when polling */

int64_t timeout;

uint8_t *buffer_ptr, *buffer_end;

int http_error;

int post;

int chunked_encoding;

int chunk_size; /* 0 if it needs to be read */

struct HTTPContext *next;

int got_key_frame; /* stream 0 => 1, stream 1 => 2, stream 2=> 4 */

int64_t data_count;

/* feed input */

int feed_fd;

/* input format handling */

AVFormatContext *fmt_in;

int64_t start_time; /* In milliseconds - this wraps fairly often */

int64_t first_pts; /* initial pts value */

int64_t cur_pts; /* current pts value from the stream in us */

int64_t cur_frame_duration; /* duration of the current frame in us */

int cur_frame_bytes; /* output frame size, needed to compute

the time at which we send each

packet */

int pts_stream_index; /* stream we choose as clock reference */

int64_t cur_clock; /* current clock reference value in us */

/* output format handling */

struct FFServerStream *stream;

/* -1 is invalid stream */

int feed_streams[FFSERVER_MAX_STREAMS]; /* index of streams in the feed */

int switch_feed_streams[FFSERVER_MAX_STREAMS]; /* index of streams in the feed */

int switch_pending;

AVFormatContext *pfmt_ctx; /* instance of FFServerStream for one user */

int last_packet_sent; /* true if last data packet was sent */

int suppress_log;

DataRateData datarate;

int wmp_client_id;

char protocol[16];

char method[16];

char url[128];

char clean_url[128*7];

int buffer_size;

uint8_t *buffer;

int is_packetized; /* if true, the stream is packetized */

int packet_stream_index; /* current stream for output in state machine */

/* RTSP state specific */

uint8_t *pb_buffer; /* XXX: use that in all the code */

AVIOContext *pb;

int seq; /* RTSP sequence number */

/* RTP state specific */

enum RTSPLowerTransport rtp_protocol;

char session_id[32]; /* session id */

AVFormatContext *rtp_ctx[FFSERVER_MAX_STREAMS];

/* RTP/UDP specific */

URLContext *rtp_handles[FFSERVER_MAX_STREAMS];

/* RTP/TCP specific */

struct HTTPContext *rtsp_c;

uint8_t *packet_buffer, *packet_buffer_ptr, *packet_buffer_end;