/***************************************************************************** * real.c: real rtsp input ***************************************************************************** * Copyright (C) 2002-2004 the xine project * Copyright (C) 2005 VideoLAN * $Id$ * * Authors: Gildas Bazin * Adapted from xine which itself adapted it from joschkas real tools. * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License along * with this program; if not, write to the Free Software Foundation, Inc., * 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA. *****************************************************************************/ #ifdef HAVE_CONFIG_H # include "config.h" #endif #include #include #include #include #include "rtsp.h" #include "real.h" #include "real_sdpplin.h" #define XOR_TABLE_LEN 37 static const unsigned char xor_table[] = { 0x05, 0x18, 0x74, 0xd0, 0x0d, 0x09, 0x02, 0x53, 0xc0, 0x01, 0x05, 0x05, 0x67, 0x03, 0x19, 0x70, 0x08, 0x27, 0x66, 0x10, 0x10, 0x72, 0x08, 0x09, 0x63, 0x11, 0x03, 0x71, 0x08, 0x08, 0x70, 0x02, 0x10, 0x57, 0x05, 0x18, 0x54, 0x00, 0x00, 0x00 }; #define BE_32(x) GetDWBE(x) #define LE_32(x) GetDWLE(x) #define BE_16(x) GetWBE(x) #define LE_16(x) GetWLE(x) #define BE_32C(x,y) do {uint32_t in=y; *(uint32_t *)(x)=GetDWBE(&in);} while(0) #define LE_32C(x,y) do {uint32_t in=y; *(uint32_t *)(x)=GetDWLE(&in);} while(0) #define MAX(x,y) ((x>y) ? x : y) static void hash(stream_t *p_access, char *field, char *param) { uint32_t a, b, c, d; /* fill variables */ a = LE_32(field); b = LE_32(field+4); c = LE_32(field+8); d = LE_32(field+12); msg_Dbg(p_access, "hash input: %x %x %x %x", a, b, c, d); a = ((b & c) | (~b & d)) + LE_32((param+0x00)) + a - 0x28955B88; a = ((a << 0x07) | (a >> 0x19)) + b; d = ((a & b) | (~a & c)) + LE_32((param+0x04)) + d - 0x173848AA; d = ((d << 0x0c) | (d >> 0x14)) + a; c = ((d & a) | (~d & b)) + LE_32((param+0x08)) + c + 0x242070DB; c = ((c << 0x11) | (c >> 0x0f)) + d; b = ((c & d) | (~c & a)) + LE_32((param+0x0c)) + b - 0x3E423112; b = ((b << 0x16) | (b >> 0x0a)) + c; a = ((b & c) | (~b & d)) + LE_32((param+0x10)) + a - 0x0A83F051; a = ((a << 0x07) | (a >> 0x19)) + b; d = ((a & b) | (~a & c)) + LE_32((param+0x14)) + d + 0x4787C62A; d = ((d << 0x0c) | (d >> 0x14)) + a; c = ((d & a) | (~d & b)) + LE_32((param+0x18)) + c - 0x57CFB9ED; c = ((c << 0x11) | (c >> 0x0f)) + d; b = ((c & d) | (~c & a)) + LE_32((param+0x1c)) + b - 0x02B96AFF; b = ((b << 0x16) | (b >> 0x0a)) + c; a = ((b & c) | (~b & d)) + LE_32((param+0x20)) + a + 0x698098D8; a = ((a << 0x07) | (a >> 0x19)) + b; d = ((a & b) | (~a & c)) + LE_32((param+0x24)) + d - 0x74BB0851; d = ((d << 0x0c) | (d >> 0x14)) + a; c = ((d & a) | (~d & b)) + LE_32((param+0x28)) + c - 0x0000A44F; c = ((c << 0x11) | (c >> 0x0f)) + d; b = ((c & d) | (~c & a)) + LE_32((param+0x2C)) + b - 0x76A32842; b = ((b << 0x16) | (b >> 0x0a)) + c; a = ((b & c) | (~b & d)) + LE_32((param+0x30)) + a + 0x6B901122; a = ((a << 0x07) | (a >> 0x19)) + b; d = ((a & b) | (~a & c)) + LE_32((param+0x34)) + d - 0x02678E6D; d = ((d << 0x0c) | (d >> 0x14)) + a; c = ((d & a) | (~d & b)) + LE_32((param+0x38)) + c - 0x5986BC72; c = ((c << 0x11) | (c >> 0x0f)) + d; b = ((c & d) | (~c & a)) + LE_32((param+0x3c)) + b + 0x49B40821; b = ((b << 0x16) | (b >> 0x0a)) + c; a = ((b & d) | (~d & c)) + LE_32((param+0x04)) + a - 0x09E1DA9E; a = ((a << 0x05) | (a >> 0x1b)) + b; d = ((a & c) | (~c & b)) + LE_32((param+0x18)) + d - 0x3FBF4CC0; d = ((d << 0x09) | (d >> 0x17)) + a; c = ((d & b) | (~b & a)) + LE_32((param+0x2c)) + c + 0x265E5A51; c = ((c << 0x0e) | (c >> 0x12)) + d; b = ((c & a) | (~a & d)) + LE_32((param+0x00)) + b - 0x16493856; b = ((b << 0x14) | (b >> 0x0c)) + c; a = ((b & d) | (~d & c)) + LE_32((param+0x14)) + a - 0x29D0EFA3; a = ((a << 0x05) | (a >> 0x1b)) + b; d = ((a & c) | (~c & b)) + LE_32((param+0x28)) + d + 0x02441453; d = ((d << 0x09) | (d >> 0x17)) + a; c = ((d & b) | (~b & a)) + LE_32((param+0x3c)) + c - 0x275E197F; c = ((c << 0x0e) | (c >> 0x12)) + d; b = ((c & a) | (~a & d)) + LE_32((param+0x10)) + b - 0x182C0438; b = ((b << 0x14) | (b >> 0x0c)) + c; a = ((b & d) | (~d & c)) + LE_32((param+0x24)) + a + 0x21E1CDE6; a = ((a << 0x05) | (a >> 0x1b)) + b; d = ((a & c) | (~c & b)) + LE_32((param+0x38)) + d - 0x3CC8F82A; d = ((d << 0x09) | (d >> 0x17)) + a; c = ((d & b) | (~b & a)) + LE_32((param+0x0c)) + c - 0x0B2AF279; c = ((c << 0x0e) | (c >> 0x12)) + d; b = ((c & a) | (~a & d)) + LE_32((param+0x20)) + b + 0x455A14ED; b = ((b << 0x14) | (b >> 0x0c)) + c; a = ((b & d) | (~d & c)) + LE_32((param+0x34)) + a - 0x561C16FB; a = ((a << 0x05) | (a >> 0x1b)) + b; d = ((a & c) | (~c & b)) + LE_32((param+0x08)) + d - 0x03105C08; d = ((d << 0x09) | (d >> 0x17)) + a; c = ((d & b) | (~b & a)) + LE_32((param+0x1c)) + c + 0x676F02D9; c = ((c << 0x0e) | (c >> 0x12)) + d; b = ((c & a) | (~a & d)) + LE_32((param+0x30)) + b - 0x72D5B376; b = ((b << 0x14) | (b >> 0x0c)) + c; a = (b ^ c ^ d) + LE_32((param+0x14)) + a - 0x0005C6BE; a = ((a << 0x04) | (a >> 0x1c)) + b; d = (a ^ b ^ c) + LE_32((param+0x20)) + d - 0x788E097F; d = ((d << 0x0b) | (d >> 0x15)) + a; c = (d ^ a ^ b) + LE_32((param+0x2c)) + c + 0x6D9D6122; c = ((c << 0x10) | (c >> 0x10)) + d; b = (c ^ d ^ a) + LE_32((param+0x38)) + b - 0x021AC7F4; b = ((b << 0x17) | (b >> 0x09)) + c; a = (b ^ c ^ d) + LE_32((param+0x04)) + a - 0x5B4115BC; a = ((a << 0x04) | (a >> 0x1c)) + b; d = (a ^ b ^ c) + LE_32((param+0x10)) + d + 0x4BDECFA9; d = ((d << 0x0b) | (d >> 0x15)) + a; c = (d ^ a ^ b) + LE_32((param+0x1c)) + c - 0x0944B4A0; c = ((c << 0x10) | (c >> 0x10)) + d; b = (c ^ d ^ a) + LE_32((param+0x28)) + b - 0x41404390; b = ((b << 0x17) | (b >> 0x09)) + c; a = (b ^ c ^ d) + LE_32((param+0x34)) + a + 0x289B7EC6; a = ((a << 0x04) | (a >> 0x1c)) + b; d = (a ^ b ^ c) + LE_32((param+0x00)) + d - 0x155ED806; d = ((d << 0x0b) | (d >> 0x15)) + a; c = (d ^ a ^ b) + LE_32((param+0x0c)) + c - 0x2B10CF7B; c = ((c << 0x10) | (c >> 0x10)) + d; b = (c ^ d ^ a) + LE_32((param+0x18)) + b + 0x04881D05; b = ((b << 0x17) | (b >> 0x09)) + c; a = (b ^ c ^ d) + LE_32((param+0x24)) + a - 0x262B2FC7; a = ((a << 0x04) | (a >> 0x1c)) + b; d = (a ^ b ^ c) + LE_32((param+0x30)) + d - 0x1924661B; d = ((d << 0x0b) | (d >> 0x15)) + a; c = (d ^ a ^ b) + LE_32((param+0x3c)) + c + 0x1fa27cf8; c = ((c << 0x10) | (c >> 0x10)) + d; b = (c ^ d ^ a) + LE_32((param+0x08)) + b - 0x3B53A99B; b = ((b << 0x17) | (b >> 0x09)) + c; a = ((~d | b) ^ c) + LE_32((param+0x00)) + a - 0x0BD6DDBC; a = ((a << 0x06) | (a >> 0x1a)) + b; d = ((~c | a) ^ b) + LE_32((param+0x1c)) + d + 0x432AFF97; d = ((d << 0x0a) | (d >> 0x16)) + a; c = ((~b | d) ^ a) + LE_32((param+0x38)) + c - 0x546BDC59; c = ((c << 0x0f) | (c >> 0x11)) + d; b = ((~a | c) ^ d) + LE_32((param+0x14)) + b - 0x036C5FC7; b = ((b << 0x15) | (b >> 0x0b)) + c; a = ((~d | b) ^ c) + LE_32((param+0x30)) + a + 0x655B59C3; a = ((a << 0x06) | (a >> 0x1a)) + b; d = ((~c | a) ^ b) + LE_32((param+0x0C)) + d - 0x70F3336E; d = ((d << 0x0a) | (d >> 0x16)) + a; c = ((~b | d) ^ a) + LE_32((param+0x28)) + c - 0x00100B83; c = ((c << 0x0f) | (c >> 0x11)) + d; b = ((~a | c) ^ d) + LE_32((param+0x04)) + b - 0x7A7BA22F; b = ((b << 0x15) | (b >> 0x0b)) + c; a = ((~d | b) ^ c) + LE_32((param+0x20)) + a + 0x6FA87E4F; a = ((a << 0x06) | (a >> 0x1a)) + b; d = ((~c | a) ^ b) + LE_32((param+0x3c)) + d - 0x01D31920; d = ((d << 0x0a) | (d >> 0x16)) + a; c = ((~b | d) ^ a) + LE_32((param+0x18)) + c - 0x5CFEBCEC; c = ((c << 0x0f) | (c >> 0x11)) + d; b = ((~a | c) ^ d) + LE_32((param+0x34)) + b + 0x4E0811A1; b = ((b << 0x15) | (b >> 0x0b)) + c; a = ((~d | b) ^ c) + LE_32((param+0x10)) + a - 0x08AC817E; a = ((a << 0x06) | (a >> 0x1a)) + b; d = ((~c | a) ^ b) + LE_32((param+0x2c)) + d - 0x42C50DCB; d = ((d << 0x0a) | (d >> 0x16)) + a; c = ((~b | d) ^ a) + LE_32((param+0x08)) + c + 0x2AD7D2BB; c = ((c << 0x0f) | (c >> 0x11)) + d; b = ((~a | c) ^ d) + LE_32((param+0x24)) + b - 0x14792C6F; b = ((b << 0x15) | (b >> 0x0b)) + c; msg_Dbg(p_access, "hash output: %x %x %x %x", a, b, c, d); a += LE_32(field); b += LE_32(field+4); c += LE_32(field+8); d += LE_32(field+12); LE_32C(field, a); LE_32C(field+4, b); LE_32C(field+8, c); LE_32C(field+12, d); } static void call_hash (stream_t * p_access, char *key, char *challenge, unsigned int len) { uint8_t *ptr1, *ptr2; uint32_t a, b, c, d, tmp; ptr1=(uint8_t*)(key+16); ptr2=(uint8_t*)(key+20); a = LE_32(ptr1); b = (a >> 3) & 0x3f; a += len * 8; LE_32C(ptr1, a); if (a < (len << 3)) { msg_Dbg(p_access, "not verified: (len << 3) > a true"); ptr2 += 4; } tmp = LE_32(ptr2) + (len >> 0x1d); LE_32C(ptr2, tmp); a = 64 - b; c = 0; if (a <= len) { memcpy(key+b+24, challenge, a); hash(p_access, key, key+24); c = a; d = c + 0x3f; while ( d < len ) { msg_Dbg(p_access, "not verified: while ( d < len )"); hash(p_access, key, challenge+d-0x3f); d += 64; c += 64; } b = 0; } memcpy(key+b+24, challenge+c, len-c); } static void calc_response (stream_t *p_access, char *result, char *field) { char buf1[128]; char buf2[128]; int i; memset (buf1, 0, 64); *buf1 = 128; memcpy (buf2, field+16, 8); i = ( LE_32((buf2)) >> 3 ) & 0x3f; if (i < 56) { i = 56 - i; } else { msg_Dbg(p_access, "not verified: ! (i < 56)"); i = 120 - i; } call_hash (p_access, field, buf1, i); call_hash (p_access, field, buf2, 8); memcpy (result, field, 16); } static void calc_response_string (stream_t *p_access, char *result, char *challenge) { char field[128] = { 0x01, 0x23, 0x45, 0x67, 0x89, 0xAB, 0xCD, 0xEF, 0xFE, 0xDC, 0xBA, 0x98, 0x76, 0x54, 0x32, 0x10, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00 }; char zres[20]; int i; /* calculate response */ call_hash(p_access, field, challenge, 64); calc_response(p_access, zres,field); /* convert zres to ascii string */ for (i=0; i<16; i++ ) { char a, b; a = (zres[i] >> 4) & 15; b = zres[i] & 15; result[i*2] = ((a<10) ? (a+48) : (a+87)) & 255; result[i*2+1] = ((b<10) ? (b+48) : (b+87)) & 255; } } static void real_calc_response_and_checksum (stream_t *p_access, char *response, char *chksum, char *challenge) { int ch_len, resp_len; int i; char *ptr; char buf[128]; /* initialize return values */ memset(response, 0, 64); memset(chksum, 0, 34); /* initialize buffer */ memset(buf, 0, 128); ptr=buf; BE_32C(ptr, 0xa1e9149d); ptr+=4; BE_32C(ptr, 0x0e6b3b59); ptr+=4; /* some (length) checks */ if (challenge != NULL) { ch_len = strlen (challenge); if (ch_len == 40) /* what a hack... */ { challenge[32]=0; ch_len=32; } if ( ch_len > 56 ) ch_len=56; /* copy challenge to buf */ memcpy(ptr, challenge, ch_len); } /* xor challenge bytewise with xor_table */ for (i=0; i= numrules) return 0; /* now indices of codecs follows */ /* we skip to selection */ mlti_chunk+=(selection+1)*2; /* get our index */ codec=BE_16(mlti_chunk); /* skip to number of codecs */ mlti_chunk+=(numrules-selection)*2; /* get number of codecs */ numrules=BE_16(mlti_chunk); if (codec >= numrules) { msg_Dbg(p_access, "codec index >= number of codecs. %i %i", codec, numrules); return 0; } mlti_chunk+=2; /* now seek to selected codec */ for( int i = 0; i < codec; i++ ) { size=BE_32(mlti_chunk); mlti_chunk+=size+4; } size=BE_32(mlti_chunk); memcpy(*out, mlti_chunk+4, __MIN(size,MLTI_BUF_MAX_SIZE)); return size; } /* * looking at stream description. */ static rmff_header_t *real_parse_sdp(stream_t *p_access, char *data, char **stream_rules, uint32_t bandwidth) { sdpplin_t *desc = NULL; rmff_header_t *header = NULL; char *buf = NULL; int len, i; int max_bit_rate=0; int avg_bit_rate=0; int max_packet_size=0; int avg_packet_size=0; int duration=0; if( !data ) return NULL; desc=sdpplin_parse(p_access, data); if( !desc ) return NULL; buf = malloc(MLTI_BUF_MAX_SIZE); if( !buf ) goto error; header = calloc( 1, sizeof(rmff_header_t) ); if( !header ) goto error; header->fileheader=rmff_new_fileheader(4+desc->stream_count); header->cont=rmff_new_cont( desc->title, desc->author, desc->copyright, desc->abstract); header->data=rmff_new_dataheader(0,0); if( !header->data ) goto error; header->streams = calloc( desc->stream_count+1, sizeof(rmff_mdpr_t*) ); if( !header->streams ) goto error; msg_Dbg(p_access, "number of streams: %u", desc->stream_count); for (i=0; istream_count; i++) { int j=0; int n; char b[64]; int rulematches[16]; msg_Dbg(p_access, "calling asmrp_match with: bandwidth: %u, rule book: >>%s<<", bandwidth, desc->stream[i]->asm_rule_book); n=asmrp_match(desc->stream[i]->asm_rule_book, bandwidth, rulematches, sizeof(rulematches)/sizeof(rulematches[0])); for (j=0; jstream[i]->stream_id); sprintf(b,"stream=%u;rule=%u,", desc->stream[i]->stream_id, rulematches[j]); strcat(*stream_rules, b); } if (!desc->stream[i]->mlti_data) { len = 0; free( buf ); buf = NULL; } else len=select_mlti_data(p_access, desc->stream[i]->mlti_data, desc->stream[i]->mlti_data_size, rulematches[0], &buf); header->streams[i]=rmff_new_mdpr( desc->stream[i]->stream_id, desc->stream[i]->max_bit_rate, desc->stream[i]->avg_bit_rate, desc->stream[i]->max_packet_size, desc->stream[i]->avg_packet_size, desc->stream[i]->start_time, desc->stream[i]->preroll, desc->stream[i]->duration, desc->stream[i]->stream_name, desc->stream[i]->mime_type, len, buf); if( !header->streams[i] ) goto error; duration=MAX(duration,desc->stream[i]->duration); max_bit_rate+=desc->stream[i]->max_bit_rate; avg_bit_rate+=desc->stream[i]->avg_bit_rate; max_packet_size=MAX(max_packet_size, desc->stream[i]->max_packet_size); if (avg_packet_size) avg_packet_size=(avg_packet_size + desc->stream[i]->avg_packet_size) / 2; else avg_packet_size=desc->stream[i]->avg_packet_size; } if (*stream_rules && strlen(*stream_rules) && (*stream_rules)[strlen(*stream_rules)-1] == ',') (*stream_rules)[strlen(*stream_rules)-1]=0; /* delete last ',' in stream_rules */ header->prop=rmff_new_prop( max_bit_rate, avg_bit_rate, max_packet_size, avg_packet_size, 0, duration, 0, 0, 0, desc->stream_count, desc->flags); if( !header->prop ) goto error; rmff_fix_header(p_access, header); sdpplin_free( desc ); free( buf ); return header; error: sdpplin_free( desc ); rmff_free_header( header ); free( buf ); return NULL; } int real_get_rdt_chunk_header(rtsp_client_t *rtsp_session, rmff_pheader_t *ph) { stream_t *p_access = (stream_t*)rtsp_session->p_userdata; int n=1; uint8_t header[8]; int size; int flags1; int unknown1; uint32_t ts; n=rtsp_read_data(rtsp_session, header, 8); if (n<8) return 0; if (header[0] != 0x24) { msg_Dbg(p_access, "rdt-chunk-header: rdt chunk not recognized, got 0x%02x", header[0]); return 0; } size=(header[1]<<16)+(header[2]<<8)+(header[3]); flags1=header[4]; if ((flags1!=0x40)&&(flags1!=0x42)) { msg_Dbg(p_access, "rdt-chunk-header: got flags1: 0x%02x", flags1); if (header[6]==0x06) { msg_Dbg(p_access, "rdt-chunk-header: got end of stream packet"); return 0; } header[0]=header[5]; header[1]=header[6]; header[2]=header[7]; n=rtsp_read_data(rtsp_session, header+3, 5); if (n<5) return 0; msg_Dbg(p_access, "rdt-chunk-header: ignoring bytes"); n=rtsp_read_data(rtsp_session, header+4, 4); if (n<4) return 0; flags1=header[4]; size-=9; } unknown1=(header[5]<<16)+(header[6]<<8)+(header[7]); n=rtsp_read_data(rtsp_session, header, 6); if (n<6) return 0; ts=BE_32(header); #if 0 msg_Dbg(p_access, "ts: %u size: %u, flags: 0x%02x, unknown values: %u 0x%02x 0x%02x\n", ts, size, flags1, unknown1, header[4], header[5] ); #else VLC_UNUSED(unknown1); #endif size+=2; ph->object_version=0; ph->length=size; ph->stream_number=(flags1>>1)&1; ph->timestamp=ts; ph->reserved=0; ph->flags=0; /* TODO: determine keyframe flag and insert here? */ return size; } int real_get_rdt_chunk(rtsp_client_t *rtsp_session, rmff_pheader_t *ph, unsigned char **buffer) { int n; rmff_dump_pheader(ph, (char*)*buffer); if (ph->length<12) return 0; n=rtsp_read_data(rtsp_session, (uint8_t*)(*buffer + 12), ph->length - 12); return (n <= 0) ? 0 : n+12; } //! maximum size of the rtsp description, must be < INT_MAX #define MAX_DESC_BUF (20 * 1024 * 1024) rmff_header_t *real_setup_and_get_header(rtsp_client_t *rtsp_session, int bandwidth) { stream_t *p_access = (stream_t *) rtsp_session->p_userdata; char *description=NULL; char *session_id=NULL; rmff_header_t *h=NULL; char *challenge1 = NULL; char challenge2[64]; char checksum[34]; char *subscribe=NULL; char *buf = malloc(256); if( !buf ) return NULL; char *mrl=rtsp_get_mrl(rtsp_session); unsigned int size; int status; char *p_data; /* get challenge */ if (NULL == (p_data = rtsp_search_answers(rtsp_session, "RealChallenge1"))) { msg_Warn(p_access, "server did not reply with RealChallenge1, aborting!"); return NULL; } else { challenge1 = strdup(p_data); msg_Dbg(p_access, "Challenge1: %s", challenge1); } sprintf(buf, "Bandwidth: %u", bandwidth); /* request stream description */ rtsp_schedule_field(rtsp_session, "Accept: application/sdp"); rtsp_schedule_field(rtsp_session, buf); rtsp_schedule_field(rtsp_session, "GUID: 00000000-0000-0000-0000-000000000000"); rtsp_schedule_field(rtsp_session, "RegionData: 0"); rtsp_schedule_field(rtsp_session, "ClientID: Linux_2.4_6.0.9.1235_play32_RN01_EN_586"); rtsp_schedule_field(rtsp_session, "SupportsMaximumASMBandwidth: 1"); rtsp_schedule_field(rtsp_session, "Language: en-US"); rtsp_schedule_field(rtsp_session, "Require: com.real.retain-entity-for-setup"); status=rtsp_request_describe(rtsp_session,NULL); if ( status<200 || status>299 ) { msg_Warn (p_access, "server returned status code %d", status); if ((p_data = rtsp_search_answers(rtsp_session, "Alert"))) { msg_Warn(p_access, "server replied with a message: '%s'", p_data); } rtsp_send_ok( rtsp_session ); free( challenge1 ); free( buf ); return NULL; } /* receive description */ size=0; if (!rtsp_search_answers(rtsp_session,"Content-length")) msg_Dbg(p_access, "server reply missing Content-Length"); else size=atoi(rtsp_search_answers(rtsp_session,"Content-length")); if (size > MAX_DESC_BUF) { msg_Warn(p_access, "Content-length for description is too big (> %uMB), aborting.", MAX_DESC_BUF/(1024*1024) ); goto error; } if (NULL == (p_data = rtsp_search_answers(rtsp_session, "ETag"))) { msg_Warn(p_access, "ETag missing from server response, aborting!"); goto error; } else { session_id = strdup(p_data); } msg_Dbg(p_access, "Stream description size: %u", size); description = malloc(size+1); if( !description ) goto error; if( rtsp_read_data(rtsp_session, (uint8_t*)description, size) <= 0) goto error; description[size]=0; //fprintf(stderr, "%s", description); /* parse sdp (sdpplin) and create a header and a subscribe string */ subscribe = malloc(256); if( !subscribe ) goto error; strcpy(subscribe, "Subscribe: "); h=real_parse_sdp(p_access, description, &subscribe, bandwidth); if (!h) goto error; rmff_fix_header(p_access, h); #if 0 fprintf("Title: %s\nCopyright: %s\nAuthor: %s\nStreams: %i\n", h->cont->title, h->cont->copyright, h->cont->author, h->prop->num_streams); #endif /* setup our streams */ real_calc_response_and_checksum (p_access, challenge2, checksum, challenge1); buf = realloc_or_free(buf, strlen(challenge2) + strlen(checksum) + 32); if( !buf ) goto error; sprintf(buf, "RealChallenge2: %s, sd=%s", challenge2, checksum); rtsp_schedule_field(rtsp_session, buf); buf = realloc_or_free(buf, strlen(session_id) + 32); if( !buf ) goto error; sprintf(buf, "If-Match: %s", session_id); rtsp_schedule_field(rtsp_session, buf); rtsp_schedule_field(rtsp_session, "Transport: x-pn-tng/tcp;mode=play,rtp/avp/tcp;unicast;mode=play"); buf = realloc_or_free(buf, strlen(mrl) + 32); if( !buf ) goto error; sprintf(buf, "%s/streamid=0", mrl); rtsp_request_setup(rtsp_session,buf); if (h->prop->num_streams > 1) { rtsp_schedule_field(rtsp_session, "Transport: x-pn-tng/tcp;mode=play,rtp/avp/tcp;unicast;mode=play"); buf = realloc_or_free(buf, strlen(session_id) + 32); if( !buf ) goto error; sprintf(buf, "If-Match: %s", session_id); rtsp_schedule_field(rtsp_session, buf); buf = realloc_or_free(buf, strlen(mrl) + 32); if( !buf ) goto error; sprintf(buf, "%s/streamid=1", mrl); rtsp_request_setup(rtsp_session,buf); } /* set stream parameter (bandwidth) with our subscribe string */ rtsp_schedule_field(rtsp_session, subscribe); rtsp_request_setparameter(rtsp_session,NULL); /* and finally send a play request */ rtsp_schedule_field(rtsp_session, "Range: npt=0-"); rtsp_request_play(rtsp_session,NULL); free( challenge1 ); free( session_id ); free( description ); free( subscribe ); free( buf ); return h; error: rmff_free_header( h ); free( challenge1 ); free( session_id ); free( description ); free( subscribe ); free( buf ); return NULL; }