00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022 #ifndef AVFORMAT_RTPDEC_H
00023 #define AVFORMAT_RTPDEC_H
00024
00025 #include "libavcodec/avcodec.h"
00026 #include "avformat.h"
00027 #include "rtp.h"
00028
00029 typedef struct PayloadContext PayloadContext;
00030 typedef struct RTPDynamicProtocolHandler_s RTPDynamicProtocolHandler;
00031
00032 #define RTP_MIN_PACKET_LENGTH 12
00033 #define RTP_MAX_PACKET_LENGTH 1500
00034
00035 #define RTP_REORDER_QUEUE_DEFAULT_SIZE 10
00036
00037 #define RTP_NOTS_VALUE ((uint32_t)-1)
00038
00039 typedef struct RTPDemuxContext RTPDemuxContext;
00040 RTPDemuxContext *rtp_parse_open(AVFormatContext *s1, AVStream *st, URLContext *rtpc, int payload_type, int queue_size);
00041 void rtp_parse_set_dynamic_protocol(RTPDemuxContext *s, PayloadContext *ctx,
00042 RTPDynamicProtocolHandler *handler);
00043 int rtp_parse_packet(RTPDemuxContext *s, AVPacket *pkt,
00044 uint8_t **buf, int len);
00045 void rtp_parse_close(RTPDemuxContext *s);
00046 int64_t ff_rtp_queued_packet_time(RTPDemuxContext *s);
00047 void ff_rtp_reset_packet_queue(RTPDemuxContext *s);
00048 int rtp_get_local_rtp_port(URLContext *h);
00049 int rtp_get_local_rtcp_port(URLContext *h);
00050
00051 int rtp_set_remote_url(URLContext *h, const char *uri);
00052
00064 void rtp_send_punch_packets(URLContext* rtp_handle);
00065
00071 int rtp_check_and_send_back_rr(RTPDemuxContext *s, int count);
00072
00076 int rtp_get_rtcp_file_handle(URLContext *h);
00077
00078
00079 typedef struct {
00080 uint16_t max_seq;
00081 uint32_t cycles;
00082 uint32_t base_seq;
00083 uint32_t bad_seq;
00084 int probation;
00085 int received;
00086 int expected_prior;
00087 int received_prior;
00088 uint32_t transit;
00089 uint32_t jitter;
00090 } RTPStatistics;
00091
00092 #define RTP_FLAG_KEY 0x1
00093 #define RTP_FLAG_MARKER 0x2
00094
00106 typedef int (*DynamicPayloadPacketHandlerProc) (AVFormatContext *ctx,
00107 PayloadContext *s,
00108 AVStream *st,
00109 AVPacket * pkt,
00110 uint32_t *timestamp,
00111 const uint8_t * buf,
00112 int len, int flags);
00113
00114 struct RTPDynamicProtocolHandler_s {
00115
00116 const char enc_name[50];
00117 enum AVMediaType codec_type;
00118 enum CodecID codec_id;
00119 int static_payload_id;
00120
00121
00122
00123
00124 int (*parse_sdp_a_line) (AVFormatContext *s,
00125 int st_index,
00126 PayloadContext *priv_data,
00127 const char *line);
00128 PayloadContext *(*open) (void);
00129 void (*close)(PayloadContext *protocol_data);
00130 DynamicPayloadPacketHandlerProc parse_packet;
00131
00132 struct RTPDynamicProtocolHandler_s *next;
00133 };
00134
00135 typedef struct RTPPacket {
00136 uint16_t seq;
00137 uint8_t *buf;
00138 int len;
00139 int64_t recvtime;
00140 struct RTPPacket *next;
00141 } RTPPacket;
00142
00143
00144 struct RTPDemuxContext {
00145 AVFormatContext *ic;
00146 AVStream *st;
00147 int payload_type;
00148 uint32_t ssrc;
00149 uint16_t seq;
00150 uint32_t timestamp;
00151 uint32_t base_timestamp;
00152 uint32_t cur_timestamp;
00153 int64_t range_start_offset;
00154 int max_payload_size;
00155 struct MpegTSContext *ts;
00156 int read_buf_index;
00157 int read_buf_size;
00158
00159 URLContext *rtp_ctx;
00160 char hostname[256];
00161
00162 RTPStatistics statistics;
00163
00165 int prev_ret;
00166 RTPPacket* queue;
00167 int queue_len;
00168 int queue_size;
00169
00171
00172 int64_t last_rtcp_ntp_time;
00173 int64_t first_rtcp_ntp_time;
00174 uint32_t last_rtcp_timestamp;
00175 int64_t rtcp_ts_offset;
00176
00177
00178 unsigned int packet_count;
00179 unsigned int octet_count;
00180 unsigned int last_octet_count;
00181 int first_packet;
00182
00183 uint8_t buf[RTP_MAX_PACKET_LENGTH];
00184 uint8_t *buf_ptr;
00185
00186
00187 DynamicPayloadPacketHandlerProc parse_packet;
00188 PayloadContext *dynamic_protocol_context;
00189 int max_frames_per_packet;
00190 };
00191
00192 void ff_register_dynamic_payload_handler(RTPDynamicProtocolHandler *handler);
00193 RTPDynamicProtocolHandler *ff_rtp_handler_find_by_name(const char *name,
00194 enum AVMediaType codec_type);
00195 RTPDynamicProtocolHandler *ff_rtp_handler_find_by_id(int id,
00196 enum AVMediaType codec_type);
00197
00198 int ff_rtsp_next_attr_and_value(const char **p, char *attr, int attr_size, char *value, int value_size);
00199
00200 int ff_parse_fmtp(AVStream *stream, PayloadContext *data, const char *p,
00201 int (*parse_fmtp)(AVStream *stream,
00202 PayloadContext *data,
00203 char *attr, char *value));
00204
00205 void av_register_rtp_dynamic_payload_handlers(void);
00206
00207 #endif