diff options
author | wm4 <wm4@nowhere> | 2012-08-01 17:30:31 +0200 |
---|---|---|
committer | wm4 <wm4@nowhere> | 2012-08-01 17:47:14 +0200 |
commit | 59b938c8aa7d903e849748b737d45ccd949ef419 (patch) | |
tree | 8418d35dc94e3e7a8f185a1e63dbdad45e271e8d /stream/realrtsp | |
parent | c92538dfaa5eb7e9b2773f158cbb310545116abe (diff) | |
download | mpv-59b938c8aa7d903e849748b737d45ccd949ef419.tar.bz2 mpv-59b938c8aa7d903e849748b737d45ccd949ef419.tar.xz |
stream: remove native RTSP/RTP/PNM support
There are still various other RTSP implementations available, such as
libnemesi, live555, and libav. The mplayer native version was a huge
chunk of old unmaintained code.
Diffstat (limited to 'stream/realrtsp')
-rw-r--r-- | stream/realrtsp/asmrp.c | 690 | ||||
-rw-r--r-- | stream/realrtsp/asmrp.h | 47 | ||||
-rw-r--r-- | stream/realrtsp/real.c | 653 | ||||
-rw-r--r-- | stream/realrtsp/real.h | 60 | ||||
-rw-r--r-- | stream/realrtsp/rmff.c | 876 | ||||
-rw-r--r-- | stream/realrtsp/rmff.h | 275 | ||||
-rw-r--r-- | stream/realrtsp/sdpplin.c | 388 | ||||
-rw-r--r-- | stream/realrtsp/sdpplin.h | 108 | ||||
-rw-r--r-- | stream/realrtsp/xbuffer.c | 117 | ||||
-rw-r--r-- | stream/realrtsp/xbuffer.h | 40 |
10 files changed, 0 insertions, 3254 deletions
diff --git a/stream/realrtsp/asmrp.c b/stream/realrtsp/asmrp.c deleted file mode 100644 index bcbe1c9389..0000000000 --- a/stream/realrtsp/asmrp.c +++ /dev/null @@ -1,690 +0,0 @@ -/* - * This file was ported to MPlayer from xine CVS asmrp.c,v 1.2 2002/12/17 16:49:48 - */ - -/* - * Copyright (C) 2002 the xine project - * - * This file is part of xine, a free video player. - * - * xine 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. - * - * xine 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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA - * - * - * a parser for real's asm rules - * - * grammar for these rules: - * - - rule_book = { rule } - rule = ( '#' condition { ',' assignment } | [ assignment {',' assignment} ]) ';' - assignment = id '=' const - const = ( number | string ) - condition = comp_expr { ( '&&' | '||' ) comp_expr } - comp_expr = operand { ( '<' | '<=' | '==' | '>=' | '>' ) operand } - operand = ( '$' id | num | '(' condition ')' ) - - */ - -#include <stdlib.h> -#include <stdio.h> -#include <string.h> -#include "mp_msg.h" -#include "asmrp.h" - -/* -#define LOG -*/ - -#define ASMRP_SYM_NONE 0 -#define ASMRP_SYM_EOF 1 - -#define ASMRP_SYM_NUM 2 -#define ASMRP_SYM_ID 3 -#define ASMRP_SYM_STRING 4 - -#define ASMRP_SYM_HASH 10 -#define ASMRP_SYM_SEMICOLON 11 -#define ASMRP_SYM_COMMA 12 -#define ASMRP_SYM_EQUALS 13 -#define ASMRP_SYM_AND 14 -#define ASMRP_SYM_OR 15 -#define ASMRP_SYM_LESS 16 -#define ASMRP_SYM_LEQ 17 -#define ASMRP_SYM_GEQ 18 -#define ASMRP_SYM_GREATER 19 -#define ASMRP_SYM_DOLLAR 20 -#define ASMRP_SYM_LPAREN 21 -#define ASMRP_SYM_RPAREN 22 - -#define ASMRP_MAX_ID 1024 - -#define ASMRP_MAX_SYMTAB 10 - -typedef struct { - char *id; - int v; -} asmrp_sym_t; - -typedef struct { - - /* public part */ - - int sym; - int num; - - char str[ASMRP_MAX_ID]; - - /* private part */ - - char *buf; - int pos; - char ch; - - asmrp_sym_t sym_tab[ASMRP_MAX_SYMTAB]; - int sym_tab_num; - -} asmrp_t; - -static asmrp_t *asmrp_new (void) { - - asmrp_t *p; - - p = malloc (sizeof (asmrp_t)); - - p->sym_tab_num = 0; - p->sym = ASMRP_SYM_NONE; - - return p; -} - -static void asmrp_dispose (asmrp_t *p) { - - int i; - - for (i=0; i<p->sym_tab_num; i++) - free (p->sym_tab[i].id); - - free(p->buf); - free (p); -} - -static void asmrp_getch (asmrp_t *p) { - p->ch = p->buf[p->pos]; - p->pos++; - -#ifdef LOG - printf ("%c\n", p->ch); -#endif - -} - -static void asmrp_init (asmrp_t *p, const char *str) { - - p->buf = strdup (str); - p->pos = 0; - - asmrp_getch (p); -} - -static void asmrp_number (asmrp_t *p) { - - int num; - - num = 0; - while ( (p->ch>='0') && (p->ch<='9') ) { - - num = num*10 + (p->ch - '0'); - - asmrp_getch (p); - } - - p->sym = ASMRP_SYM_NUM; - p->num = num; -} - -static void asmrp_string (asmrp_t *p) { - - int l; - - l = 0; - - while ( (p->ch!='"') && (p->ch>=32) ) { - - if(l < ASMRP_MAX_ID - 1) - p->str[l++] = p->ch; - else - mp_msg(MSGT_STREAM, MSGL_ERR, "error: string too long, ignoring char %c.\n", p->ch); - - asmrp_getch (p); - } - p->str[l]=0; - - if (p->ch=='"') - asmrp_getch (p); - - p->sym = ASMRP_SYM_STRING; -} - -static void asmrp_identifier (asmrp_t *p) { - - int l; - - l = 0; - - while ( ((p->ch>='A') && (p->ch<='z')) - || ((p->ch>='0') && (p->ch<='9'))) { - - if(l < ASMRP_MAX_ID - 1) - p->str[l++] = p->ch; - else - mp_msg(MSGT_STREAM, MSGL_ERR, "error: identifier too long, ignoring char %c.\n", p->ch); - - asmrp_getch (p); - } - p->str[l]=0; - - p->sym = ASMRP_SYM_ID; -} - -#ifdef LOG -static void asmrp_print_sym (asmrp_t *p) { - - printf ("symbol: "); - - switch (p->sym) { - - case ASMRP_SYM_NONE: - printf ("NONE\n"); - break; - - case ASMRP_SYM_EOF: - printf ("EOF\n"); - break; - - case ASMRP_SYM_NUM: - printf ("NUM %d\n", p->num); - break; - - case ASMRP_SYM_ID: - printf ("ID '%s'\n", p->str); - break; - - case ASMRP_SYM_STRING: - printf ("STRING \"%s\"\n", p->str); - break; - - case ASMRP_SYM_HASH: - printf ("#\n"); - break; - - case ASMRP_SYM_SEMICOLON: - printf (";\n"); - break; - case ASMRP_SYM_COMMA: - printf (",\n"); - break; - case ASMRP_SYM_EQUALS: - printf ("==\n"); - break; - case ASMRP_SYM_AND: - printf ("&&\n"); - break; - case ASMRP_SYM_OR: - printf ("||\n"); - break; - case ASMRP_SYM_LESS: - printf ("<\n"); - break; - case ASMRP_SYM_LEQ: - printf ("<=\n"); - break; - case ASMRP_SYM_GEQ: - printf (">=\n"); - break; - case ASMRP_SYM_GREATER: - printf (">\n"); - break; - case ASMRP_SYM_DOLLAR: - printf ("$\n"); - break; - case ASMRP_SYM_LPAREN: - printf ("(\n"); - break; - case ASMRP_SYM_RPAREN: - printf (")\n"); - break; - - default: - printf ("unknown symbol %d\n", p->sym); - } -} -#endif - -static void asmrp_get_sym (asmrp_t *p) { - - while (p->ch <= 32) { - if (p->ch == 0) { - p->sym = ASMRP_SYM_EOF; - return; - } - - asmrp_getch (p); - } - - if (p->ch == '\\') - asmrp_getch (p); - - switch (p->ch) { - - case '#': - p->sym = ASMRP_SYM_HASH; - asmrp_getch (p); - break; - case ';': - p->sym = ASMRP_SYM_SEMICOLON; - asmrp_getch (p); - break; - case ',': - p->sym = ASMRP_SYM_COMMA; - asmrp_getch (p); - break; - case '=': - p->sym = ASMRP_SYM_EQUALS; - asmrp_getch (p); - if (p->ch=='=') - asmrp_getch (p); - break; - case '&': - p->sym = ASMRP_SYM_AND; - asmrp_getch (p); - if (p->ch=='&') - asmrp_getch (p); - break; - case '|': - p->sym = ASMRP_SYM_OR; - asmrp_getch (p); - if (p->ch=='|') - asmrp_getch (p); - break; - case '<': - p->sym = ASMRP_SYM_LESS; - asmrp_getch (p); - if (p->ch=='=') { - p->sym = ASMRP_SYM_LEQ; - asmrp_getch (p); - } - break; - case '>': - p->sym = ASMRP_SYM_GREATER; - asmrp_getch (p); - if (p->ch=='=') { - p->sym = ASMRP_SYM_GEQ; - asmrp_getch (p); - } - break; - case '$': - p->sym = ASMRP_SYM_DOLLAR; - asmrp_getch (p); - break; - case '(': - p->sym = ASMRP_SYM_LPAREN; - asmrp_getch (p); - break; - case ')': - p->sym = ASMRP_SYM_RPAREN; - asmrp_getch (p); - break; - - case '"': - asmrp_getch (p); - asmrp_string (p); - break; - - case '0': case '1': case '2': case '3': case '4': - case '5': case '6': case '7': case '8': case '9': - asmrp_number (p); - break; - - default: - asmrp_identifier (p); - } - -#ifdef LOG - asmrp_print_sym (p); -#endif - -} - -static int asmrp_find_id (asmrp_t *p, char *s) { - - int i; - - for (i=0; i<p->sym_tab_num; i++) { - if (!strcmp (s, p->sym_tab[i].id)) - return i; - } - - return -1; -} - -static int asmrp_set_id (asmrp_t *p, char *s, int v) { - - int i; - - i = asmrp_find_id (p, s); - - if (i<0) { - if (p->sym_tab_num == ASMRP_MAX_SYMTAB - 1) { - mp_msg(MSGT_STREAM, MSGL_ERR, "sym_tab overflow, ignoring identifier %s\n", s); - return 0; - } - i = p->sym_tab_num; - p->sym_tab_num++; - p->sym_tab[i].id = strdup (s); - -#ifdef LOG - printf ("new symbol '%s'\n", s); -#endif - - } - - p->sym_tab[i].v = v; - -#ifdef LOG - printf ("symbol '%s' assigned %d\n", s, v); -#endif - - return i; -} - -static int asmrp_condition (asmrp_t *p) ; - -static int asmrp_operand (asmrp_t *p) { - - int i, ret; - -#ifdef LOG - printf ("operand\n"); -#endif - - ret = 0; - - switch (p->sym) { - - case ASMRP_SYM_DOLLAR: - - asmrp_get_sym (p); - - if (p->sym != ASMRP_SYM_ID) { - mp_msg(MSGT_STREAM, MSGL_ERR, "error: identifier expected.\n"); - break; - } - - i = asmrp_find_id (p, p->str); - if (i<0) { - mp_msg(MSGT_STREAM, MSGL_ERR, "error: unknown identifier %s\n", p->str); - } else - ret = p->sym_tab[i].v; - - asmrp_get_sym (p); - break; - - case ASMRP_SYM_NUM: - ret = p->num; - - asmrp_get_sym (p); - break; - - case ASMRP_SYM_LPAREN: - asmrp_get_sym (p); - - ret = asmrp_condition (p); - - if (p->sym != ASMRP_SYM_RPAREN) { - mp_msg(MSGT_STREAM, MSGL_ERR, "error: ) expected.\n"); - break; - } - - asmrp_get_sym (p); - break; - - default: - mp_msg(MSGT_STREAM, MSGL_ERR, "syntax error, $ number or ( expected\n"); - } - -#ifdef LOG - printf ("operand done, =%d\n", ret); -#endif - - return ret; -} - - -static int asmrp_comp_expression (asmrp_t *p) { - - int a; - -#ifdef LOG - printf ("comp_expression\n"); -#endif - - a = asmrp_operand (p); - - while ( (p->sym == ASMRP_SYM_LESS) - || (p->sym == ASMRP_SYM_LEQ) - || (p->sym == ASMRP_SYM_EQUALS) - || (p->sym == ASMRP_SYM_GEQ) - || (p->sym == ASMRP_SYM_GREATER) ) { - int op = p->sym; - int b; - - asmrp_get_sym (p); - - b = asmrp_operand (p); - - switch (op) { - case ASMRP_SYM_LESS: - a = a<b; - break; - case ASMRP_SYM_LEQ: - a = a<=b; - break; - case ASMRP_SYM_EQUALS: - a = a==b; - break; - case ASMRP_SYM_GEQ: - a = a>=b; - break; - case ASMRP_SYM_GREATER: - a = a>b; - break; - } - - } - -#ifdef LOG - printf ("comp_expression done = %d\n", a); -#endif - return a; -} - -static int asmrp_condition (asmrp_t *p) { - - int a; - -#ifdef LOG - printf ("condition\n"); -#endif - - a = asmrp_comp_expression (p); - - while ( (p->sym == ASMRP_SYM_AND) || (p->sym == ASMRP_SYM_OR) ) { - int op, b; - - op = p->sym; - - asmrp_get_sym (p); - - b = asmrp_comp_expression (p); - - switch (op) { - case ASMRP_SYM_AND: - a = a & b; - break; - case ASMRP_SYM_OR: - a = a | b; - break; - } - } - -#ifdef LOG - printf ("condition done = %d\n", a); -#endif - return a; -} - -static void asmrp_assignment (asmrp_t *p) { - -#ifdef LOG - printf ("assignment\n"); -#endif - - if (p->sym == ASMRP_SYM_COMMA || p->sym == ASMRP_SYM_SEMICOLON) { -#ifdef LOG - printf ("empty assignment\n"); -#endif - return; - } - - if (p->sym != ASMRP_SYM_ID) { - mp_msg(MSGT_STREAM, MSGL_ERR, "error: identifier expected\n"); - return; - } - asmrp_get_sym (p); - - if (p->sym != ASMRP_SYM_EQUALS) { - mp_msg(MSGT_STREAM, MSGL_ERR, "error: = expected\n"); - return; - } - asmrp_get_sym (p); - - if ( (p->sym != ASMRP_SYM_NUM) && (p->sym != ASMRP_SYM_STRING) - && (p->sym != ASMRP_SYM_ID)) { - mp_msg(MSGT_STREAM, MSGL_ERR, "error: number or string expected\n"); - return; - } - asmrp_get_sym (p); - -#ifdef LOG - printf ("assignment done\n"); -#endif -} - -static int asmrp_rule (asmrp_t *p) { - - int ret; - -#ifdef LOG - printf ("rule\n"); -#endif - - ret = 1; - - if (p->sym == ASMRP_SYM_HASH) { - - asmrp_get_sym (p); - ret = asmrp_condition (p); - - while (p->sym == ASMRP_SYM_COMMA) { - - asmrp_get_sym (p); - - asmrp_assignment (p); - } - - } else if (p->sym != ASMRP_SYM_SEMICOLON) { - - asmrp_assignment (p); - - while (p->sym == ASMRP_SYM_COMMA) { - - asmrp_get_sym (p); - asmrp_assignment (p); - } - } - -#ifdef LOG - printf ("rule done = %d\n", ret); -#endif - - if (p->sym != ASMRP_SYM_SEMICOLON) { - mp_msg(MSGT_STREAM, MSGL_ERR, "semicolon expected.\n"); - return ret; - } - - asmrp_get_sym (p); - - return ret; -} - -static int asmrp_eval (asmrp_t *p, int *matches) { - - int rule_num, num_matches; - -#ifdef LOG - printf ("eval\n"); -#endif - - asmrp_get_sym (p); - - rule_num = 0; num_matches = 0; - while (p->sym != ASMRP_SYM_EOF) { - - if (asmrp_rule (p)) { -#ifdef LOG - printf ("rule #%d is true\n", rule_num); -#endif - if(num_matches < MAX_RULEMATCHES - 1) - matches[num_matches++] = rule_num; - else - mp_msg(MSGT_STREAM, MSGL_ERR, - "Ignoring matched asm rule %d, too many matched rules.\n", rule_num); - } - - rule_num++; - } - - matches[num_matches] = -1; - return num_matches; -} - -int asmrp_match (const char *rules, int bandwidth, int *matches) { - - asmrp_t *p; - int num_matches; - - p = asmrp_new (); - - asmrp_init (p, rules); - - asmrp_set_id (p, "Bandwidth", bandwidth); - asmrp_set_id (p, "OldPNMPlayer", 0); - - num_matches = asmrp_eval (p, matches); - - asmrp_dispose (p); - - return num_matches; -} diff --git a/stream/realrtsp/asmrp.h b/stream/realrtsp/asmrp.h deleted file mode 100644 index b5616db59a..0000000000 --- a/stream/realrtsp/asmrp.h +++ /dev/null @@ -1,47 +0,0 @@ -/* - * This file was ported to MPlayer from xine CVS asmrp.h,v 1.1 2002/12/12 22:14:54 - */ - -/* - * Copyright (C) 2002 the xine project - * - * This file is part of xine, a free video player. - * - * xine 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. - * - * xine 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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA - * - * - * a parser for real's asm rules - * - * grammar for these rules: - * - - rule_book = { '#' rule ';'} - rule = condition {',' assignment} - assignment = id '=' const - const = ( number | string ) - condition = comp_expr { ( '&&' | '||' ) comp_expr } - comp_expr = operand { ( '<' | '<=' | '==' | '>=' | '>' ) operand } - operand = ( '$' id | num | '(' condition ')' ) - - */ - -#ifndef MPLAYER_ASMRP_H -#define MPLAYER_ASMRP_H - -#define MAX_RULEMATCHES 16 - -int asmrp_match (const char *rules, int bandwidth, int *matches) ; - -#endif /* MPLAYER_ASMRP_H */ diff --git a/stream/realrtsp/real.c b/stream/realrtsp/real.c deleted file mode 100644 index daee0cd34a..0000000000 --- a/stream/realrtsp/real.c +++ /dev/null @@ -1,653 +0,0 @@ -/* - * This file was ported to MPlayer from xine CVS real.c,v 1.8 2003/03/30 17:11:50 - */ - -/* - * Copyright (C) 2002 the xine project - * - * This file is part of xine, a free video player. - * - * xine 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. - * - * xine 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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA - * - * - * special functions for real streams. - * adopted from joschkas real tools. - * - */ - -#include <stdio.h> -#include <string.h> - -#include <libavutil/common.h> -#include <libavutil/attributes.h> -#include <libavutil/md5.h> -#include <libavutil/intreadwrite.h> -#include <libavutil/base64.h> -#include <libavutil/avutil.h> - -#include "config.h" -#include "real.h" -#include "asmrp.h" -#include "sdpplin.h" -#include "xbuffer.h" - -#include "stream/http.h" -#include "mp_msg.h" - -/* -#define LOG -*/ - -#define XOR_TABLE_SIZE 37 - -static const unsigned char xor_table[XOR_TABLE_SIZE] = { - 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 }; - - -#define BUF_SIZE 4096 - -#ifdef LOG -static void hexdump (const char *buf, int length) { - - int i; - - printf (" hexdump> "); - for (i = 0; i < length; i++) { - unsigned char c = buf[i]; - - printf ("%02x", c); - - if ((i % 16) == 15) - printf ("\n "); - - if ((i % 2) == 1) - printf (" "); - - } - printf ("\n"); -} -#endif - - -static void real_calc_response_and_checksum (char *response, char *chksum, char *challenge) { - - int ch_len; - int i; - unsigned char zres[16], buf[64]; - - /* initialize buffer */ - AV_WB32(buf, 0xa1e9149d); - AV_WB32(buf+4, 0x0e6b3b59); - - /* some (length) checks */ - if (challenge != NULL) - { - ch_len = strlen (challenge); - - if (ch_len == 40) /* what a hack... */ - ch_len=32; - if ( ch_len > 56 ) ch_len=56; - - /* copy challenge to buf */ - memcpy(buf+8, challenge, ch_len); - memset(buf+8+ch_len, 0, 56-ch_len); - } - - /* xor challenge bytewise with xor_table */ - for (i=0; i<XOR_TABLE_SIZE; i++) - buf[8+i] ^= xor_table[i]; - - av_md5_sum(zres, buf, 64); - - /* convert zres to ascii string */ - for (i=0; i<16; i++ ) - sprintf(response+i*2, "%02x", zres[i]); - - /* add tail */ - strcpy (&response[32], "01d0a8e3"); - - /* calculate checksum */ - for (i=0; i<8; i++) - chksum[i] = response[i*4]; - chksum[8] = 0; -} - - -/* - * takes a MLTI-Chunk and a rule number got from match_asm_rule, - * returns a pointer to selected data and number of bytes in that. - */ - -static int select_mlti_data(const char *mlti_chunk, int mlti_size, int selection, char **out) { - - int numrules, codec, size; - int i; - - /* MLTI chunk should begin with MLTI */ - - if ((mlti_chunk[0] != 'M') - ||(mlti_chunk[1] != 'L') - ||(mlti_chunk[2] != 'T') - ||(mlti_chunk[3] != 'I')) - { -#ifdef LOG - printf("libreal: MLTI tag not detected, copying data\n"); -#endif - *out = xbuffer_copyin(*out, 0, mlti_chunk, mlti_size); - return mlti_size; - } - - mlti_chunk+=4; - - /* next 16 bits are the number of rules */ - numrules=AV_RB16(mlti_chunk); - if (selection >= numrules) return 0; - - /* now <numrules> indices of codecs follows */ - /* we skip to selection */ - mlti_chunk+=(selection+1)*2; - - /* get our index */ - codec=AV_RB16(mlti_chunk); - - /* skip to number of codecs */ - mlti_chunk+=(numrules-selection)*2; - - /* get number of codecs */ - numrules=AV_RB16(mlti_chunk); - - if (codec >= numrules) { - mp_msg(MSGT_STREAM, MSGL_WARN, "realrtsp: codec index >= number of codecs. %i %i\n", - codec, numrules); - return 0; - } - - mlti_chunk+=2; - - /* now seek to selected codec */ - for (i=0; i<codec; i++) { - size=AV_RB32(mlti_chunk); - mlti_chunk+=size+4; - } - - size=AV_RB32(mlti_chunk); - -#ifdef LOG - hexdump(mlti_chunk+4, size); -#endif - *out = xbuffer_copyin(*out, 0, mlti_chunk+4, size); - return size; -} - -/* - * looking at stream description. - */ - -static rmff_header_t *real_parse_sdp(char *data, char **stream_rules, uint32_t bandwidth) { - - sdpplin_t *desc; - rmff_header_t *header; - char *buf; - 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(data); - - if (!desc) return NULL; - - buf = xbuffer_init(2048); - header=calloc(1,sizeof(rmff_header_t)); - - 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); - header->streams=calloc(1,sizeof(rmff_mdpr_t*)*(desc->stream_count+1)); -#ifdef LOG - printf("number of streams: %u\n", desc->stream_count); -#endif - - for (i=0; i<desc->stream_count; i++) { - - int j=0; - int n; - char b[64]; - int rulematches[MAX_RULEMATCHES]; - - if (!desc->stream[i]) - continue; -#ifdef LOG - printf("calling asmrp_match with:\n%s\n%u\n", desc->stream[i]->asm_rule_book, bandwidth); -#endif - n=asmrp_match(desc->stream[i]->asm_rule_book, bandwidth, rulematches); - for (j=0; j<n; j++) { -#ifdef LOG - printf("asmrp rule match: %u for stream %u\n", rulematches[j], desc->stream[i]->stream_id); -#endif - sprintf(b,"stream=%u;rule=%u,", desc->stream[i]->stream_id, rulematches[j]); - *stream_rules = xbuffer_strcat(*stream_rules, b); - } - - if (!desc->stream[i]->mlti_data) { - len = 0; - buf = xbuffer_free(buf); - } else - len=select_mlti_data(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); - - duration=FFMAX(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=FFMAX(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); - - rmff_fix_header(header); - buf = xbuffer_free(buf); - sdpplin_free(desc); - - return header; -} - -int real_get_rdt_chunk(rtsp_t *rtsp_session, char **buffer, int rdt_rawdata) { - - int n=1; - uint8_t header[8]; - rmff_pheader_t ph; - int size; - int flags1, flags2; - int unknown1 av_unused; - uint32_t ts; - static uint32_t prev_ts = -1; - static int prev_stream_number = -1; - - n=rtsp_read_data(rtsp_session, header, 8); - if (n<8) return 0; - if (header[0] != 0x24) - { - mp_msg(MSGT_STREAM, MSGL_WARN, "realrtsp: rdt chunk not recognized: got 0x%02x\n", - header[0]); - return 0; - } - /* header[1] is channel, normally 0, ignored */ - size=(header[2]<<8)+header[3]; - flags1=header[4]; - if ((flags1 & 0xc0) != 0x40) - { -#ifdef LOG - printf("got flags1: 0x%02x\n",flags1); -#endif - if(header[6] == 0x06) { // eof packet - rtsp_read_data(rtsp_session, header, 7); // Skip the rest of the eof packet - /* Some files have short auxiliary streams, we must ignore eof packets - * for these streams to avoid premature eof. - * Now the code declares eof only if the stream with id == 0 gets eof - * (old code was: eof on the first eof packet received). - */ - if(flags1 & 0x7c) // ignore eof for streams with id != 0 - return 0; - mp_msg(MSGT_STREAM, MSGL_INFO, "realrtsp: Stream EOF detected\n"); - return -1; - } - 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; -#ifdef LOG - printf("ignoring bytes:\n"); - hexdump(header, 8); -#endif - n=rtsp_read_data(rtsp_session, header+4, 4); - if (n<4) return 0; - flags1=header[4]; - size-=9; - } - flags2=header[7]; - // header[5..6] == frame number in stream - unknown1=(header[5]<<16)+(header[6]<<8)+(header[7]); - n=rtsp_read_data(rtsp_session, header, 6); - if (n<6) return 0; - ts=AV_RB32(header); - -#ifdef LOG - printf("ts: %u, size: %u, flags: 0x%02x, unknown values: 0x%06x 0x%02x 0x%02x\n", - ts, size, flags1, unknown1, header[4], header[5]); -#endif - size+=2; - - ph.object_version=0; - ph.length=size; - ph.stream_number=(flags1>>1)&0x1f; - ph.timestamp=ts; - ph.reserved=0; - if ((flags2&1) == 0 && (prev_ts != ts || prev_stream_number != ph.stream_number)) - { - prev_ts = ts; - prev_stream_number = ph.stream_number; - ph.flags=2; - } - else - ph.flags=0; - *buffer = xbuffer_ensure_size(*buffer, 12+size); - if(rdt_rawdata) { - if (size < 12) - return 0; - n=rtsp_read_data(rtsp_session, *buffer, size-12); - return (n <= 0) ? 0 : n; - } - rmff_dump_pheader(&ph, *buffer); - if (size < 12) - return 0; - size-=12; - n=rtsp_read_data(rtsp_session, (*buffer)+12, size); - - return (n <= 0) ? 0 : n+12; -} - -static int convert_timestamp(char *str, int *sec, int *msec) { - int hh, mm, ss, ms = 0; - - // Timestamp may be optionally quoted with ", skip it - // Since the url is escaped when we get here, we skip the string "%22" - if (!strncmp(str, "%22", 3)) - str += 3; - if (sscanf(str, "%d:%d:%d.%d", &hh, &mm, &ss, &ms) < 3) { - hh = 0; - if (sscanf(str, "%d:%d.%d", &mm, &ss, &ms) < 2) { - mm = 0; - if (sscanf(str, "%d.%d", &ss, &ms) < 1) { - ss = 0; - ms = 0; - } - } - } - if (sec) - *sec = hh * 3600 + mm * 60 + ss; - if (msec) - *msec = ms; - return 1; -} - -//! 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_t *rts |