* Decodes base64 strings (based upon b64 package)
*/
-static char *b64_decode(const char *in, char *out, int *size)
-{
- char dtable[256]; /* Encode / decode table */
- int i,j,k;
+static char *b64_decode(const char *in, char *out, int *size) {
- for (i = 0; i < 255; i++) {
- dtable[i] = 0x80;
- }
- for (i = 'A'; i <= 'Z'; i++) {
- dtable[i] = 0 + (i - 'A');
- }
- for (i = 'a'; i <= 'z'; i++) {
- dtable[i] = 26 + (i - 'a');
- }
- for (i = '0'; i <= '9'; i++) {
- dtable[i] = 52 + (i - '0');
+ char dtable[256]; /* Encode / decode table */
+ int i,k;
+ unsigned int j;
+
+ for (i = 0; i < 255; i++) {
+ dtable[i] = 0x80;
+ }
+ for (i = 'A'; i <= 'Z'; i++) {
+ dtable[i] = 0 + (i - 'A');
+ }
+ for (i = 'a'; i <= 'z'; i++) {
+ dtable[i] = 26 + (i - 'a');
+ }
+ for (i = '0'; i <= '9'; i++) {
+ dtable[i] = 52 + (i - '0');
+ }
+ dtable['+'] = 62;
+ dtable['/'] = 63;
+ dtable['='] = 0;
+
+ k=0;
+ /*CONSTANTCONDITION*/
+ for (j=0; j<strlen(in); j+=4) {
+ char a[4], b[4];
+
+ for (i = 0; i < 4; i++) {
+ int c = in[i+j];
+
+ if (dtable[c] & 0x80) {
+ printf("Illegal character '%c' in input.\n", c);
+ exit(1);
+ }
+ a[i] = (char) c;
+ b[i] = (char) dtable[c];
}
- dtable['+'] = 62;
- dtable['/'] = 63;
- dtable['='] = 0;
-
- k=0;
- /*CONSTANTCONDITION*/
- for (j=0; j<strlen(in); j+=4)
- {
- char a[4], b[4];
-
- for (i = 0; i < 4; i++)
- {
- int c = in[i+j];
-
- if (dtable[c] & 0x80)
- {
- printf("Illegal character '%c' in input.\n", c);
- exit(1);
- }
- a[i] = (char) c;
- b[i] = (char) dtable[c];
- }
- //xine_buffer_ensure_size(out, k+3);
- out[k++] = (b[0] << 2) | (b[1] >> 4);
- out[k++] = (b[1] << 4) | (b[2] >> 2);
- out[k++] = (b[2] << 6) | b[3];
- i = a[2] == '=' ? 1 : (a[3] == '=' ? 2 : 3);
- if (i < 3)
- {
- out[k]=0;
- *size=k;
- return out;
- }
+ //xine_buffer_ensure_size(out, k+3);
+ out[k++] = (b[0] << 2) | (b[1] >> 4);
+ out[k++] = (b[1] << 4) | (b[2] >> 2);
+ out[k++] = (b[2] << 6) | b[3];
+ i = a[2] == '=' ? 1 : (a[3] == '=' ? 2 : 3);
+ if (i < 3) {
+ out[k]=0;
+ *size=k;
+ return out;
}
- out[k]=0;
- *size=k;
- return out;
+ }
+ out[k]=0;
+ *size=k;
+ return out;
}
-static char *nl(char *data)
-{
- char *nlptr = (data) ? strchr(data,'\n') : NULL;
- return (nlptr) ? nlptr + 1 : NULL;
+static char *nl(char *data) {
+
+ char *nlptr = (data) ? strchr(data,'\n') : NULL;
+ return (nlptr) ? nlptr + 1 : NULL;
}
-static int filter(const char *in, const char *filter, char **out)
-{
- int flen=strlen(filter);
- int len;
-
- if (!in)
- return 0;
-
- len = (strchr(in,'\n')) ? strchr(in,'\n')-in : strlen(in);
- if (!strncmp(in,filter,flen))
- {
- if(in[flen]=='"') flen++;
- if(in[len-1]==13) len--;
- if(in[len-1]=='"') len--;
- memcpy(*out, in+flen, len-flen+1);
- (*out)[len-flen]=0;
- return len-flen;
- }
+static int filter(const char *in, const char *filter, char **out) {
+
+ int flen=strlen(filter);
+ int len;
- return 0;
+ if (!in) return 0;
+
+ len = (strchr(in,'\n')) ? strchr(in,'\n')-in : strlen(in);
+ if (!strncmp(in,filter,flen)) {
+ if(in[flen]=='"') flen++;
+ if(in[len-1]==13) len--;
+ if(in[len-1]=='"') len--;
+ memcpy(*out, in+flen, len-flen+1);
+ (*out)[len-flen]=0;
+ return len-flen;
+ }
+ return 0;
}
-static sdpplin_stream_t *sdpplin_parse_stream(char **data)
-{
- sdpplin_stream_t *desc = malloc(sizeof(sdpplin_stream_t));
- char *buf = malloc(32000);
- char *decoded = malloc(32000);
- int handled;
+static sdpplin_stream_t *sdpplin_parse_stream(char **data) {
+
+ sdpplin_stream_t *desc = malloc(sizeof(sdpplin_stream_t));
+ char *buf = malloc(32000);
+ char *decoded = malloc(32000);
+ int handled;
+
+ if( !desc ) return NULL;
+ memset(desc, 0, sizeof(sdpplin_stream_t));
+
+ if( !buf ) goto error;
+ if( !decoded ) goto error;
+
+ if (filter(*data, "m=", &buf)) {
+ desc->id = strdup(buf);
+ } else {
+ lprintf("sdpplin: no m= found.\n");
+ goto error;
+ }
+ *data=nl(*data);
- if( !desc ) goto error;
- memset(desc, 0, sizeof(sdpplin_stream_t));
+ while (*data && **data && *data[0]!='m') {
+ handled=0;
- if (filter(*data, "m=", &buf))
- {
- desc->id = strdup(buf);
+ if(filter(*data,"a=control:streamid=",&buf)) {
+ desc->stream_id=atoi(buf);
+ handled=1;
+ *data=nl(*data);
+ }
+ if(filter(*data,"a=MaxBitRate:integer;",&buf)) {
+ desc->max_bit_rate=atoi(buf);
+ if (!desc->avg_bit_rate)
+ desc->avg_bit_rate=desc->max_bit_rate;
+ handled=1;
+ *data=nl(*data);
+ }
+ if(filter(*data,"a=MaxPacketSize:integer;",&buf)) {
+ desc->max_packet_size=atoi(buf);
+ if (!desc->avg_packet_size)
+ desc->avg_packet_size=desc->max_packet_size;
+ handled=1;
+ *data=nl(*data);
+ }
+ if(filter(*data,"a=StartTime:integer;",&buf)) {
+ desc->start_time=atoi(buf);
+ handled=1;
+ *data=nl(*data);
+ }
+ if(filter(*data,"a=Preroll:integer;",&buf)) {
+ desc->preroll=atoi(buf);
+ handled=1;
+ *data=nl(*data);
+ }
+ if(filter(*data,"a=length:npt=",&buf)) {
+ desc->duration=(uint32_t)(atof(buf)*1000);
+ handled=1;
+ *data=nl(*data);
}
- else
- {
- lprintf("sdpplin: no m= found.\n");
- if( decoded ) free(decoded);
- if( desc ) free( desc );
- if( buf ) free( buf );
- return NULL;
+ if(filter(*data,"a=StreamName:string;",&buf)) {
+ desc->stream_name=strdup(buf);
+ desc->stream_name_size=strlen(desc->stream_name);
+ handled=1;
+ *data=nl(*data);
}
- *data=nl(*data);
-
- while (*data && **data && *data[0]!='m')
- {
- handled=0;
-
- if(filter(*data,"a=control:streamid=",&buf))
- {
- desc->stream_id=atoi(buf);
- handled=1;
- *data=nl(*data);
- }
- if(filter(*data,"a=MaxBitRate:integer;",&buf))
- {
- desc->max_bit_rate=atoi(buf);
- if (!desc->avg_bit_rate)
- desc->avg_bit_rate=desc->max_bit_rate;
- handled=1;
- *data=nl(*data);
- }
- if(filter(*data,"a=MaxPacketSize:integer;",&buf))
- {
- desc->max_packet_size=atoi(buf);
- if (!desc->avg_packet_size)
- desc->avg_packet_size=desc->max_packet_size;
- handled=1;
- *data=nl(*data);
- }
- if(filter(*data,"a=StartTime:integer;",&buf))
- {
- desc->start_time=atoi(buf);
- handled=1;
- *data=nl(*data);
- }
- if(filter(*data,"a=Preroll:integer;",&buf))
- {
- desc->preroll=atoi(buf);
- handled=1;
- *data=nl(*data);
- }
- if(filter(*data,"a=length:npt=",&buf))
- {
- desc->duration=(uint32_t)(atof(buf)*1000);
- handled=1;
- *data=nl(*data);
- }
- if(filter(*data,"a=StreamName:string;",&buf))
- {
- desc->stream_name=strdup(buf);
- desc->stream_name_size=strlen(desc->stream_name);
- handled=1;
- *data=nl(*data);
- }
- if(filter(*data,"a=mimetype:string;",&buf))
- {
- desc->mime_type=strdup(buf);
- desc->mime_type_size=strlen(desc->mime_type);
- handled=1;
- *data=nl(*data);
- }
- if(filter(*data,"a=OpaqueData:buffer;",&buf))
- {
- decoded = b64_decode(buf, decoded, &(desc->mlti_data_size));
- desc->mlti_data = malloc(sizeof(char)*desc->mlti_data_size);
- memcpy(desc->mlti_data, decoded, desc->mlti_data_size);
- handled=1;
- *data=nl(*data);
- lprintf("mlti_data_size: %i\n", desc->mlti_data_size);
- }
- if(filter(*data,"a=ASMRuleBook:string;",&buf))
- {
- desc->asm_rule_book=strdup(buf);
- handled=1;
- *data=nl(*data);
- }
-
- if(!handled)
- {
+ if(filter(*data,"a=mimetype:string;",&buf)) {
+ desc->mime_type=strdup(buf);
+ desc->mime_type_size=strlen(desc->mime_type);
+ handled=1;
+ *data=nl(*data);
+ }
+ if(filter(*data,"a=OpaqueData:buffer;",&buf)) {
+ decoded = b64_decode(buf, decoded, &(desc->mlti_data_size));
+ desc->mlti_data = malloc(sizeof(char)*desc->mlti_data_size);
+ memcpy(desc->mlti_data, decoded, desc->mlti_data_size);
+ handled=1;
+ *data=nl(*data);
+ lprintf("mlti_data_size: %i\n", desc->mlti_data_size);
+ }
+ if(filter(*data,"a=ASMRuleBook:string;",&buf)) {
+ desc->asm_rule_book=strdup(buf);
+ handled=1;
+ *data=nl(*data);
+ }
+
+ if(!handled) {
#ifdef LOG
- int len=strchr(*data,'\n')-(*data);
- memcpy(buf, *data, len+1);
- buf[len]=0;
- printf("libreal: sdpplin: not handled: '%s'\n", buf);
+ int len=strchr(*data,'\n')-(*data);
+ memcpy(buf, *data, len+1);
+ buf[len]=0;
+ printf("libreal: sdpplin: not handled: '%s'\n", buf);
#endif
- *data=nl(*data);
- }
+ *data=nl(*data);
}
- if( buf ) free(buf);
- if( decoded )free(decoded);
- return desc;
+ }
+ if( buf ) free(buf);
+ if( decoded )free(decoded);
+ return desc;
+
+error:
+ if( decoded ) free(decoded);
+ if( desc ) free( desc );
+ if( buf ) free( buf );
+ return NULL;
}
-sdpplin_t *sdpplin_parse(char *data)
-{
- sdpplin_t *desc = malloc(sizeof(sdpplin_t));
- sdpplin_stream_t *stream;
- char *buf=malloc(3200);
- char *decoded=malloc(3200);
- int handled;
- int len;
-
- if( !desc ) return NULL;
- if( !buf )
- {
- free( desc );
- return NULL;
+sdpplin_t *sdpplin_parse(char *data) {
+
+ sdpplin_t *desc = malloc(sizeof(sdpplin_t));
+ sdpplin_stream_t *stream;
+ char *buf=malloc(3200);
+ char *decoded=malloc(3200);
+ int handled;
+ int len;
+
+ if( !desc ) return NULL;
+ if( !buf ) {
+ free( desc );
+ return NULL;
+ }
+ if( !decoded ) {
+ free( buf );
+ free( desc );
+ return NULL;
+ }
+ memset(desc, 0, sizeof(sdpplin_t));
+
+ while (data && *data) {
+ handled=0;
+
+ if (filter(data, "m=", &buf)) {
+ stream=sdpplin_parse_stream(&data);
+ lprintf("got data for stream id %u\n", stream->stream_id);
+ desc->stream[stream->stream_id]=stream;
+ continue;
+ }
+ if(filter(data,"a=Title:buffer;",&buf)) {
+ decoded=b64_decode(buf, decoded, &len);
+ desc->title=strdup(decoded);
+ handled=1;
+ data=nl(data);
}
- if( !decoded )
- {
- free( buf );
- free( desc );
- return NULL;
+ if(filter(data,"a=Author:buffer;",&buf)) {
+ decoded=b64_decode(buf, decoded, &len);
+ desc->author=strdup(decoded);
+ handled=1;
+ data=nl(data);
}
- memset(desc, 0, sizeof(sdpplin_t));
-
- while (data && *data)
- {
- handled=0;
-
- if (filter(data, "m=", &buf))
- {
- stream=sdpplin_parse_stream(&data);
- lprintf("got data for stream id %u\n", stream->stream_id);
- desc->stream[stream->stream_id]=stream;
- continue;
- }
- if(filter(data,"a=Title:buffer;",&buf))
- {
- decoded=b64_decode(buf, decoded, &len);
- desc->title=strdup(decoded);
- handled=1;
- data=nl(data);
- }
- if(filter(data,"a=Author:buffer;",&buf))
- {
- decoded=b64_decode(buf, decoded, &len);
- desc->author=strdup(decoded);
- handled=1;
- data=nl(data);
- }
- if(filter(data,"a=Copyright:buffer;",&buf))
- {
- decoded=b64_decode(buf, decoded, &len);
- desc->copyright=strdup(decoded);
- handled=1;
- data=nl(data);
- }
- if(filter(data,"a=Abstract:buffer;",&buf))
- {
- decoded=b64_decode(buf, decoded, &len);
- desc->abstract=strdup(decoded);
- handled=1;
- data=nl(data);
- }
- if(filter(data,"a=StreamCount:integer;",&buf))
- {
- desc->stream_count=atoi(buf);
- desc->stream = malloc(sizeof(sdpplin_stream_t*)*desc->stream_count);
- handled=1;
- data=nl(data);
- }
- if(filter(data,"a=Flags:integer;",&buf))
- {
- desc->flags=atoi(buf);
- handled=1;
- data=nl(data);
- }
-
- if(!handled)
- {
+ if(filter(data,"a=Copyright:buffer;",&buf)) {
+ decoded=b64_decode(buf, decoded, &len);
+ desc->copyright=strdup(decoded);
+ handled=1;
+ data=nl(data);
+ }
+ if(filter(data,"a=Abstract:buffer;",&buf)) {
+ decoded=b64_decode(buf, decoded, &len);
+ desc->abstract=strdup(decoded);
+ handled=1;
+ data=nl(data);
+ }
+ if(filter(data,"a=StreamCount:integer;",&buf)) {
+ desc->stream_count=atoi(buf);
+ desc->stream = malloc(sizeof(sdpplin_stream_t*)*desc->stream_count);
+ handled=1;
+ data=nl(data);
+ }
+ if(filter(data,"a=Flags:integer;",&buf)) {
+ desc->flags=atoi(buf);
+ handled=1;
+ data=nl(data);
+ }
+
+ if(!handled) {
#ifdef LOG
- int len=strchr(data,'\n')-data;
- memcpy(buf, data, len+1);
- buf[len]=0;
- printf("libreal: sdpplin: not handled: '%s'\n", buf);
+ int len=strchr(data,'\n')-data;
+ memcpy(buf, data, len+1);
+ buf[len]=0;
+ printf("libreal: sdpplin: not handled: '%s'\n", buf);
#endif
- data=nl(data);
- }
+ data=nl(data);
}
+ }
- free(decoded);
- free(buf);
- return desc;
+ free(decoded);
+ free(buf);
+ return desc;
}
-void sdpplin_free(sdpplin_t *description)
-{
- /* TODO: free strings */
+void sdpplin_free(sdpplin_t *description) {
+
+ int i;
+
+ if( !description ) return;
+
+ for( i=0; i<description->stream_count; i++ ) {
+ if( description->stream[i] ) {
+ if( description->stream[i]->id ) free( description->stream[i]->id );
+ if( description->stream[i]->bandwidth ) free( description->stream[i]->bandwidth );
+ if( description->stream[i]->range ) free( description->stream[i]->range );
+ if( description->stream[i]->length ) free( description->stream[i]->length );
+ if( description->stream[i]->rtpmap ) free( description->stream[i]->rtpmap );
+ if( description->stream[i]->mimetype ) free( description->stream[i]->mimetype );
+ if( description->stream[i]->stream_name ) free( description->stream[i]->stream_name );
+ if( description->stream[i]->mime_type ) free( description->stream[i]->mime_type );
+ if( description->stream[i]->mlti_data ) free( description->stream[i]->mlti_data );
+ if( description->stream[i]->rmff_flags ) free( description->stream[i]->rmff_flags );
+ if( description->stream[i]->asm_rule_book ) free( description->stream[i]->asm_rule_book );
+ }
+ }
+ free( description->stream );
+
+ if( description->owner ) free( description->owner );
+ if( description->session_name ) free( description->session_name );
+ if( description->session_info ) free( description->session_info );
+ if( description->uri ) free( description->uri );
+ if( description->email ) free( description->email );
+ if( description->phone ) free( description->phone );
+ if( description->connection ) free( description->connection );
+ if( description->bandwidth ) free( description->bandwidth );
+ if( description->title ) free( description->title );
+ if( description->author ) free( description->author );
+ if( description->copyright ) free( description->copyright );
+ if( description->keywords ) free( description->keywords );
+ if( description->asm_rule_book ) free( description->asm_rule_book );
+ if( description->abstract ) free( description->abstract );
+ if( description->range ) free( description->range );
free(description);
}