95 const char *challenge)
97 int ch_len = strlen (challenge), i;
98 unsigned char zres[16],
99 buf[64] = { 0xa1, 0xe9, 0x14, 0x9d, 0x0e, 0x6b, 0x3b, 0x59 };
100 #define XOR_TABLE_SIZE 37
102 0x05, 0x18, 0x74, 0xd0, 0x0d, 0x09, 0x02, 0x53,
103 0xc0, 0x01, 0x05, 0x05, 0x67, 0x03, 0x19, 0x70,
104 0x08, 0x27, 0x66, 0x10, 0x10, 0x72, 0x08, 0x09,
105 0x63, 0x11, 0x03, 0x71, 0x08, 0x08, 0x70, 0x02,
106 0x10, 0x57, 0x05, 0x18, 0x54 };
111 else if (ch_len > 56)
113 memcpy(buf + 8, challenge, ch_len);
117 buf[8 + i] ^= xor_table[i];
123 strcpy (response + 32,
"01d0a8e3");
126 for (i = 0; i < 8; i++)
127 chksum[i] = response[i * 4];
157 if (tag ==
MKTAG(
'M',
'L',
'T',
'I')) {
162 if (rule_nr < 0 || rule_nr >= num)
191 int *pset_id,
int *pseq_no,
int *pstream_id,
192 int *pis_keyframe, uint32_t *ptimestamp)
195 int consumed = 0, set_id, seq_no, stream_id, is_keyframe,
196 len_included, need_reliable;
200 while (len >= 5 && buf[1] == 0xFF ) {
203 if (!(buf[0] & 0x80))
280 if (stream_id == 0x1f)
283 if (pset_id) *pset_id = set_id;
284 if (pseq_no) *pseq_no = seq_no;
285 if (pstream_id) *pstream_id = stream_id;
286 if (pis_keyframe) *pis_keyframe = is_keyframe;
287 if (ptimestamp) *ptimestamp = timestamp;
296 const uint8_t *buf,
int len,
int flags)
307 &seq, flags, *timestamp);
313 memcpy (rdt->
buffer, buf + pos, len - pos);
329 pkt->
pts = *timestamp;
336 uint8_t **bufptr,
int len)
338 uint8_t *buf = bufptr ? *bufptr :
NULL;
339 int seq_no,
flags = 0, stream_id, set_id, is_keyframe;
351 pkt, ×tamp,
NULL, 0, flags);
357 rv =
ff_rdt_parse_header(buf, len, &set_id, &seq_no, &stream_id, &is_keyframe, ×tamp);
378 pkt, ×tamp, buf, len, flags);
385 int stream_nr,
int rule_nr)
387 av_strlcatf(cmd, size,
"stream=%d;rule=%d,stream=%d;rule=%d",
388 stream_nr, rule_nr * 2, stream_nr, rule_nr * 2 + 1);
391 static unsigned char *
394 unsigned char *target;
400 *target_len = len * 3 / 4;
411 const char *p = line;
415 }
else if (
av_strstart(p,
"StartTime:integer;", &p))
417 else if (
av_strstart(p,
"ASMRuleBook:string;", &p)) {
423 if (first == -1) first = n;
429 (count - rdt->
nb_rmst) *
sizeof(*rmst));
449 if (sscanf(p,
" %*1[Aa]verage%*1[Bb]andwidth=%d", &st->
codec->
bit_rate) == 1)
451 if (!(p = strchr(p,
',')) || p > end)
464 st->
id = orig_st->
id;
476 int n_rules = 0, odd = 0;
495 if (!(end = strchr(p,
';')))
497 if (!odd && end != p) {
516 const char *p = line;
541 for (i = 0; i < rdt->
nb_rmst; i++)
553 #define RDT_HANDLER(n, s, t) \
554 static RTPDynamicProtocolHandler ff_rdt_ ## n ## _handler = { \
557 .codec_id = CODEC_ID_NONE, \
558 .parse_sdp_a_line = rdt_parse_sdp_line, \
559 .alloc = rdt_new_context, \
560 .free = rdt_free_context, \
561 .parse_packet = rdt_parse_packet \
static void real_parse_asm_rulebook(AVFormatContext *s, AVStream *orig_st, const char *p)
void * av_mallocz(size_t size)
Allocate a block of size bytes with alignment suitable for all memory accesses (including vectors if ...
int n_streams
streams with identifical content in this set
AV_WL32 AV_WL24 AV_WL16 AV_WB32 AV_WB24 AV_RB16
#define RTP_MAX_PACKET_LENGTH
RMStream * ff_rm_alloc_rmstream(void)
static unsigned int get_bits(GetBitContext *s, int n)
Read 1-25 bits.
int avformat_open_input(AVFormatContext **ps, const char *filename, AVInputFormat *fmt, AVDictionary **options)
Open an input stream and read the header.
char buffer[RTP_MAX_PACKET_LENGTH+FF_INPUT_BUFFER_PADDING_SIZE]
RTP/H264 specific private data.
int ff_rdt_parse_packet(RDTDemuxContext *s, AVPacket *pkt, uint8_t **bufptr, int len)
Parse RDT-style packet data (header + media data).
int index
stream index in AVFormatContext
int64_t avio_seek(AVIOContext *s, int64_t offset, int whence)
fseek() equivalent for AVIOContext.
void * av_realloc(void *ptr, size_t size)
Allocate or reallocate a block of memory.
unsigned int avio_rb16(AVIOContext *s)
void ff_rdt_subscribe_rule(char *cmd, int size, int stream_nr, int rule_nr)
Add subscription information to Subscribe parameter string.
DynamicPayloadPacketHandlerProc parse_packet
parse handler for this dynamic packet.
static int rdt_parse_sdp_line(AVFormatContext *s, int st_index, PayloadContext *rdt, const char *line)
void av_freep(void *arg)
Free a memory block which has been allocated with av_malloc(z)() or av_realloc() and set the pointer ...
static int rdt_parse_packet(AVFormatContext *ctx, PayloadContext *rdt, AVStream *st, AVPacket *pkt, uint32_t *timestamp, const uint8_t *buf, int len, int flags)
int ff_rm_read_mdpr_codecdata(AVFormatContext *s, AVIOContext *pb, AVStream *st, RMStream *rst, int codec_data_size)
Read the MDPR chunk, which contains stream-specific codec initialization parameters.
unsigned int avio_rb32(AVIOContext *s)
int id
format-specific stream ID
int ff_rm_parse_packet(AVFormatContext *s, AVIOContext *pb, AVStream *st, RMStream *rst, int len, AVPacket *pkt, int *seq, int flags, int64_t ts)
Parse one rm-stream packet from the input bytestream.
AVStream ** streams
Each RDT stream-set (represented by one RTSPStream) can contain multiple streams (of the same content...
static int get_bits_count(const GetBitContext *s)
bitstream reader API header.
static int rdt_load_mdpr(PayloadContext *rdt, AVStream *st, int rule_nr)
void av_md5_sum(uint8_t *dst, const uint8_t *src, const int len)
static av_always_inline int64_t avio_tell(AVIOContext *s)
ftell() equivalent for AVIOContext.
void ff_rdt_parse_close(RDTDemuxContext *s)
AVIOContext * avio_alloc_context(unsigned char *buffer, int buffer_size, int write_flag, void *opaque, int(*read_packet)(void *opaque, uint8_t *buf, int buf_size), int(*write_packet)(void *opaque, uint8_t *buf, int buf_size), int64_t(*seek)(void *opaque, int64_t offset, int whence))
Allocate and initialize an AVIOContext for buffered I/O.
void av_free(void *ptr)
Free a memory block which has been allocated with av_malloc(z)() or av_realloc(). ...
static PayloadContext * rdt_new_context(void)
int audio_pkt_cnt
remaining audio packets in rmdec
unsigned int avio_rl32(AVIOContext *s)
AVStream * avformat_new_stream(AVFormatContext *s, AVCodec *c)
Add a new stream to a media file.
AVFormatContext * ic
the containing (RTSP) demux context
AVCodecContext * codec
codec context
unsigned int nb_streams
A list of all streams in the file.
int bit_rate
the average bitrate
static av_always_inline int64_t avio_skip(AVIOContext *s, int64_t offset)
Skip given number of bytes forward.
static void rdt_free_context(PayloadContext *rdt)
int ff_rdt_parse_header(const uint8_t *buf, int len, int *pset_id, int *pseq_no, int *pstream_id, int *pis_keyframe, uint32_t *ptimestamp)
Actual data handling.
int frame_size
Samples per packet, initialized when calling 'init'.
DynamicPayloadPacketHandlerProc parse_packet
enum AVMediaType codec_type
int ff_rm_retrieve_cache(AVFormatContext *s, AVIOContext *pb, AVStream *st, RMStream *rst, AVPacket *pkt)
Retrieve one cached packet from the rm-context.
#define RTP_FLAG_KEY
RTP packet contains a keyframe.
void ff_register_dynamic_payload_handler(RTPDynamicProtocolHandler *handler)
RDTDemuxContext * ff_rdt_parse_open(AVFormatContext *ic, int first_stream_of_set_idx, void *priv_data, RTPDynamicProtocolHandler *handler)
Allocate and init the RDT parsing context.
static unsigned char * rdt_parse_b64buf(unsigned int *target_len, const char *p)
static unsigned int get_bits1(GetBitContext *s)
static void skip_bits(GetBitContext *s, int n)
int(* DynamicPayloadPacketHandlerProc)(AVFormatContext *ctx, PayloadContext *s, AVStream *st, AVPacket *pkt, uint32_t *timestamp, const uint8_t *buf, int len, int flags)
Packet parsing for "private" payloads in the RTP specs.
void ff_real_parse_sdp_a_line(AVFormatContext *s, int stream_index, const char *line)
Parse a server-related SDP line.
static int init_get_bits(GetBitContext *s, const uint8_t *buffer, int bit_size)
Initialize GetBitContext.
size_t av_strlcatf(char *dst, size_t size, const char *fmt,...)
void * dynamic_protocol_context
#define FF_INPUT_BUFFER_PADDING_SIZE
Required number of additionally allocated bytes at the end of the input bitstream for decoding...
static unsigned int get_bits_long(GetBitContext *s, int n)
Read 0-32 bits.
int av_strstart(const char *str, const char *pfx, const char **ptr)
Return non-zero if pfx is a prefix of str.
int ffio_init_context(AVIOContext *s, unsigned char *buffer, int buffer_size, int write_flag, void *opaque, int(*read_packet)(void *opaque, uint8_t *buf, int buf_size), int(*write_packet)(void *opaque, uint8_t *buf, int buf_size), int64_t(*seek)(void *opaque, int64_t offset, int whence))
static void real_parse_asm_rule(AVStream *st, const char *p, const char *end)
void ff_rdt_calc_response_and_checksum(char response[41], char chksum[9], const char *challenge)
Calculate the response (RealChallenge2 in the RTSP header) to the challenge (RealChallenge1 in the RT...
void ff_rm_free_rmstream(RMStream *rms)
void avformat_close_input(AVFormatContext **s)
Close an opened input AVFormatContext.
static AVStream * add_dstream(AVFormatContext *s, AVStream *orig_st)
unsigned int mlti_data_size
int av_base64_decode(uint8_t *out, const char *in, int out_size)
Decode a base64-encoded string.
AVInputFormat ff_rdt_demuxer
void av_register_rdt_dynamic_payload_handlers(void)
Register RDT-related dynamic payload handlers with our cache.
#define MKTAG(a, b, c, d)
#define RDT_HANDLER(n, s, t)
int64_t pts
Presentation timestamp in AVStream->time_base units; the time at which the decompressed packet will b...