29 #include "libavutil/avstring.h"
32 #include "libavutil/base64.h"
33 #include "libavutil/md5.h"
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;
287 if (ptimestamp) *ptimestamp = timestamp;
307 &seq, flags, *timestamp);
313 memcpy (rdt->
buffer, buf + pos, len - pos);
329 pkt->
pts = *timestamp;
351 pkt, ×tamp,
NULL, 0, 0, flags);
357 rv =
ff_rdt_parse_header(buf, len, &set_id, &seq_no, &stream_id, &is_keyframe, ×tamp);
378 pkt, ×tamp, buf, len, 0, 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;
413 const char *p = line;
417 }
else if (
av_strstart(p,
"StartTime:integer;", &p))
419 else if (
av_strstart(p,
"ASMRuleBook:string;", &p)) {
425 if (first == -1) first = n;
428 count *
sizeof(*rdt->
rmst))) < 0) {
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;
543 for (i = 0; i < rdt->
nb_rmst; i++)
555 #define RDT_HANDLER(n, s, t) \
556 static RTPDynamicProtocolHandler rdt_ ## n ## _handler = { \
559 .codec_id = AV_CODEC_ID_NONE, \
560 .parse_sdp_a_line = rdt_parse_sdp_line, \
561 .alloc = rdt_new_context, \
562 .free = rdt_free_context, \
563 .parse_packet = rdt_parse_packet \
static void real_parse_asm_rulebook(AVFormatContext *s, AVStream *orig_st, const char *p)
int n_streams
streams with identifical content in this set
#define RTP_MAX_PACKET_LENGTH
static int is_keyframe(NalUnitType naltype)
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/JPEG specific private data.
AVCodecContext * codec
Codec context associated with this stream.
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
void ff_rdt_subscribe_rule(char *cmd, int size, int stream_nr, int rule_nr)
Add subscription information to Subscribe parameter string.
static int rdt_parse_sdp_line(AVFormatContext *s, int st_index, PayloadContext *rdt, const char *line)
void av_freep(void *ptr)
Free a memory block which has been allocated with av_malloc(z)() or av_realloc() and set the pointer ...
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.
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...
int av_reallocp(void *ptr, size_t size)
Allocate or reallocate a block of memory.
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)
AVStream * avformat_new_stream(AVFormatContext *s, const AVCodec *c)
Add a new stream to a media file.
void ff_register_rdt_dynamic_payload_handlers(void)
Register RDT-related dynamic payload handlers with our cache.
void ff_rdt_parse_close(RDTDemuxContext *s)
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
DynamicPayloadPacketHandlerProc parse_packet
Parse handler for this dynamic packet.
AVFormatContext * ic
the containing (RTSP) demux context
#define FF_INPUT_BUFFER_PADDING_SIZE
Required number of additionally allocated bytes at the end of the input bitstream for decoding...
unsigned int nb_streams
Number of elements in AVFormatContext.streams.
int(* DynamicPayloadPacketHandlerProc)(AVFormatContext *ctx, PayloadContext *s, AVStream *st, AVPacket *pkt, uint32_t *timestamp, const uint8_t *buf, int len, uint16_t seq, int flags)
Packet parsing for "private" payloads in the RTP specs.
int bit_rate
the average bitrate
AVStream ** streams
A list of all streams in the file.
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.
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.
static int rdt_parse_packet(AVFormatContext *ctx, PayloadContext *rdt, AVStream *st, AVPacket *pkt, uint32_t *timestamp, const uint8_t *buf, int len, uint16_t rtp_seq, int flags)
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.
AVIOContext * pb
I/O 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)
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.
void * dynamic_protocol_context
static unsigned int get_bits_long(GetBitContext *s, int n)
Read 0-32 bits.
#define MKTAG(a, b, c, d)
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
#define RDT_HANDLER(n, s, t)
This structure stores compressed data.
int64_t pts
Presentation timestamp in AVStream->time_base units; the time at which the decompressed packet will b...
size_t av_strlcatf(char *dst, size_t size, const char *fmt,...) av_printf_format(3
Append output to a string, according to a format.
void * av_mallocz(size_t size) av_malloc_attrib 1(1)
Allocate a block of size bytes with alignment suitable for all memory accesses (including vectors if ...