1 /*****************************************************************************
2 * rtsp.c: minimalistic implementation of rtsp protocol.
3 * Not RFC 2326 compilant yet and only handle REAL RTSP.
4 *****************************************************************************
5 * Copyright (C) 2002-2004 the xine project
6 * Copyright (C) 2005 VideoLAN
9 * Authors: Gildas Bazin <gbazin@videolan.org>
10 * Adapted from xine which itself adapted it from joschkas real tools.
12 * This program is free software; you can redistribute it and/or modify
13 * it under the terms of the GNU General Public License as published by
14 * the Free Software Foundation; either version 2 of the License, or
15 * (at your option) any later version.
17 * This program is distributed in the hope that it will be useful,
18 * but WITHOUT ANY WARRANTY; without even the implied warranty of
19 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
20 * GNU General Public License for more details.
22 * You should have received a copy of the GNU General Public License
23 * along with this program; if not, write to the Free Software
24 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
25 *****************************************************************************/
32 #define HEADER_SIZE 1024
33 #define MAX_FIELDS 256
46 unsigned int server_state;
52 char *answers[MAX_FIELDS]; /* data of last message */
53 char *scheduled[MAX_FIELDS]; /* will be sent with next message */
60 const char rtsp_protocol_version[]="RTSP/1.0";
63 #define RTSP_CONNECTED 1
66 #define RTSP_PLAYING 8
67 #define RTSP_RECORDING 16
69 /* server capabilities */
70 #define RTSP_OPTIONS 0x001
71 #define RTSP_DESCRIBE 0x002
72 #define RTSP_ANNOUNCE 0x004
73 #define RTSP_SETUP 0x008
74 #define RTSP_GET_PARAMETER 0x010
75 #define RTSP_SET_PARAMETER 0x020
76 #define RTSP_TEARDOWN 0x040
77 #define RTSP_PLAY 0x080
78 #define RTSP_RECORD 0x100
81 * rtsp_get gets a line from stream
82 * and returns a null terminated string (must be freed).
85 static char *rtsp_get( rtsp_client_t *rtsp )
87 char *psz_buffer = malloc( BUF_SIZE );
88 char *psz_string = NULL;
90 if( rtsp->pf_read_line( rtsp->p_userdata, (uint8_t*)psz_buffer, (unsigned int)BUF_SIZE ) >= 0 )
92 //printf( "<< '%s'\n", psz_buffer );
93 psz_string = strdup( psz_buffer );
102 * rtsp_put puts a line on stream
105 static int rtsp_put( rtsp_client_t *rtsp, const char *psz_string )
107 unsigned int i_buffer = strlen( psz_string );
108 char *psz_buffer = malloc( i_buffer + 3 );
111 strcpy( psz_buffer, psz_string );
112 psz_buffer[i_buffer] = '\r'; psz_buffer[i_buffer+1] = '\n';
113 psz_buffer[i_buffer+2] = 0;
115 i_ret = rtsp->pf_write( rtsp->p_userdata, (uint8_t*)psz_buffer, i_buffer + 2 );
122 * extract server status code
125 static int rtsp_get_status_code( rtsp_client_t *rtsp, const char *psz_string )
130 if( !strncmp( psz_string, "RTSP/1.0", sizeof("RTSP/1.0") - 1 ) )
132 memcpy( psz_buffer, psz_string + sizeof("RTSP/1.0"), 3 );
134 i_code = atoi( psz_buffer );
136 else if( !strncmp( psz_string, "SET_PARAMETER", 8 ) )
138 return RTSP_STATUS_SET_PARAMETER;
143 //fprintf( stderr, "librtsp: server responds: '%s'\n", psz_string );
153 static int rtsp_send_request( rtsp_client_t *rtsp, const char *psz_type,
154 const char *psz_what )
156 char **ppsz_payload = rtsp->p_private->scheduled;
160 psz_buffer = malloc( strlen(psz_type) + strlen(psz_what) +
161 sizeof("RTSP/1.0") + 2 );
163 sprintf( psz_buffer, "%s %s %s", psz_type, psz_what, "RTSP/1.0" );
164 i_ret = rtsp_put( rtsp, psz_buffer );
168 while( *ppsz_payload )
170 rtsp_put( rtsp, *ppsz_payload );
173 rtsp_put( rtsp, "" );
174 rtsp_unschedule_all( rtsp );
180 * schedule standard fields
183 static void rtsp_schedule_standard( rtsp_client_t *rtsp )
187 sprintf( tmp, "Cseq: %u", rtsp->p_private->cseq);
188 rtsp_schedule_field( rtsp, tmp );
190 if( rtsp->p_private->session )
193 buf = malloc( strlen(rtsp->p_private->session) + 15 );
194 sprintf( buf, "Session: %s", rtsp->p_private->session );
195 rtsp_schedule_field( rtsp, buf );
201 * get the answers, if server responses with something != 200, return NULL
204 static int rtsp_get_answers( rtsp_client_t *rtsp )
207 unsigned int answer_seq;
208 char **answer_ptr = rtsp->p_private->answers;
212 answer = rtsp_get( rtsp );
213 if( !answer ) return 0;
214 code = rtsp_get_status_code( rtsp, answer );
217 rtsp_free_answers( rtsp );
219 do { /* while we get answer lines */
221 answer = rtsp_get( rtsp );
222 if( !answer ) return 0;
224 if( !strncasecmp( answer, "Cseq:", 5 ) )
226 sscanf( answer, "%*s %u", &answer_seq );
227 if( rtsp->p_private->cseq != answer_seq )
229 //fprintf( stderr, "warning: Cseq mismatch. got %u, assumed %u",
230 // answer_seq, rtsp->p_private->cseq );
232 rtsp->p_private->cseq = answer_seq;
235 if( !strncasecmp( answer, "Server:", 7 ) )
237 char *buf = malloc( strlen(answer) );
238 sscanf( answer, "%*s %s", buf );
239 if( rtsp->p_private->server ) free( rtsp->p_private->server );
240 rtsp->p_private->server = buf;
242 if( !strncasecmp( answer, "Session:", 8 ) )
244 char *buf = malloc( strlen(answer) );
245 sscanf( answer, "%*s %s", buf );
246 if( rtsp->p_private->session )
248 if( strcmp( buf, rtsp->p_private->session ) )
251 // "rtsp: warning: setting NEW session: %s\n", buf );
252 free( rtsp->p_private->session );
253 rtsp->p_private->session = strdup( buf );
258 //fprintf( stderr, "setting session id to: %s\n", buf );
259 rtsp->p_private->session = strdup( buf );
264 *answer_ptr = answer;
266 } while( (strlen(answer) != 0) && (++ans_count < MAX_FIELDS) );
268 rtsp->p_private->cseq++;
271 rtsp_schedule_standard( rtsp );
280 int rtsp_send_ok( rtsp_client_t *rtsp )
284 rtsp_put( rtsp, "RTSP/1.0 200 OK" );
285 sprintf( cseq, "CSeq: %u", rtsp->p_private->cseq );
286 rtsp_put( rtsp, cseq );
287 rtsp_put( rtsp, "" );
292 * implementation of must-have rtsp requests; functions return
293 * server status code.
296 int rtsp_request_options( rtsp_client_t *rtsp, const char *what )
300 if( what ) buf = strdup(what);
303 buf = malloc( strlen(rtsp->p_private->host) + 16 );
304 sprintf( buf, "rtsp://%s:%i", rtsp->p_private->host,
305 rtsp->p_private->port );
307 rtsp_send_request( rtsp, "OPTIONS", buf );
310 return rtsp_get_answers( rtsp );
313 int rtsp_request_describe( rtsp_client_t *rtsp, const char *what )
323 buf = malloc( strlen(rtsp->p_private->host) +
324 strlen(rtsp->p_private->path) + 16 );
325 sprintf( buf, "rtsp://%s:%i/%s", rtsp->p_private->host,
326 rtsp->p_private->port, rtsp->p_private->path );
328 rtsp_send_request( rtsp, "DESCRIBE", buf );
331 return rtsp_get_answers( rtsp );
334 int rtsp_request_setup( rtsp_client_t *rtsp, const char *what )
336 rtsp_send_request( rtsp, "SETUP", what );
337 return rtsp_get_answers( rtsp );
340 int rtsp_request_setparameter( rtsp_client_t *rtsp, const char *what )
350 buf = malloc( strlen(rtsp->p_private->host) +
351 strlen(rtsp->p_private->path) + 16 );
352 sprintf( buf, "rtsp://%s:%i/%s", rtsp->p_private->host,
353 rtsp->p_private->port, rtsp->p_private->path );
356 rtsp_send_request( rtsp, "SET_PARAMETER", buf );
359 return rtsp_get_answers( rtsp );
362 int rtsp_request_play( rtsp_client_t *rtsp, const char *what )
368 buf = strdup( what );
372 buf = malloc( strlen(rtsp->p_private->host) +
373 strlen(rtsp->p_private->path) + 16 );
374 sprintf( buf, "rtsp://%s:%i/%s", rtsp->p_private->host,
375 rtsp->p_private->port, rtsp->p_private->path );
378 rtsp_send_request( rtsp, "PLAY", buf );
381 return rtsp_get_answers( rtsp );
384 int rtsp_request_tearoff( rtsp_client_t *rtsp, const char *what )
386 rtsp_send_request( rtsp, "TEAROFF", what );
387 return rtsp_get_answers( rtsp );
391 * read opaque data from stream
394 int rtsp_read_data( rtsp_client_t *rtsp, uint8_t *buffer, unsigned int size )
400 i = rtsp->pf_read( rtsp->p_userdata, (uint8_t*)buffer, (unsigned int) 4 );
401 if( i < 4 ) return i;
403 if( buffer[0]=='S' && buffer[1]=='E' && buffer[2]=='T' &&
406 char *rest = rtsp_get( rtsp );
407 if( !rest ) return -1;
413 rest = rtsp_get( rtsp );
414 if( !rest ) return -1;
416 if( !strncasecmp( rest, "Cseq:", 5 ) )
417 sscanf( rest, "%*s %u", &seq );
423 //fprintf(stderr, "warning: cseq not recognized!\n");
427 /* lets make the server happy */
428 rtsp_put( rtsp, "RTSP/1.0 451 Parameter Not Understood" );
430 sprintf( rest,"CSeq: %u", seq );
431 rtsp_put( rtsp, rest );
432 rtsp_put( rtsp, "" );
434 i = rtsp->pf_read( rtsp->p_userdata, (unsigned char*)buffer, size );
438 i = rtsp->pf_read( rtsp->p_userdata, (unsigned char*)buffer + 4, size - 4 );
442 else i = rtsp->pf_read( rtsp->p_userdata, (unsigned char*)buffer, size );
444 //fprintf( stderr, "<< %d of %d bytes\n", i, size );
450 * connect to a rtsp server
453 int rtsp_connect( rtsp_client_t *rtsp, const char *psz_mrl,
454 const char *psz_user_agent )
459 unsigned int hostend, pathbegin, i;
461 if( !psz_mrl ) return -1;
462 s = malloc( sizeof(rtsp_t) );
465 if( !strncmp( psz_mrl, "rtsp://", 7 ) ) psz_mrl += 7;
466 mrl_ptr = strdup( psz_mrl );
468 for( i=0; i<MAX_FIELDS; i++ )
471 s->scheduled[i]=NULL;
475 s->port = 554; /* rtsp standard port */
477 s->mrl = strdup(psz_mrl);
486 if( psz_user_agent ) s->user_agent = strdup( psz_user_agent );
487 else s->user_agent = strdup( "User-Agent: RealMedia Player Version "
488 "6.0.9.1235 (linux-2.0-libc6-i386-gcc2.95)" );
490 slash = strchr( mrl_ptr, '/' );
491 colon = strchr( mrl_ptr, ':' );
493 if( !slash ) slash = mrl_ptr + strlen(mrl_ptr) + 1;
494 if( !colon ) colon = slash;
495 if( colon > slash ) colon = slash;
497 pathbegin = slash - mrl_ptr;
498 hostend = colon - mrl_ptr;
500 s->host = malloc(hostend+1);
501 strncpy( s->host, mrl_ptr, hostend );
502 s->host[hostend] = 0;
504 if( pathbegin < strlen(mrl_ptr) ) s->path = strdup(mrl_ptr+pathbegin+1);
507 char buffer[pathbegin-hostend];
509 strncpy( buffer, mrl_ptr+hostend+1, pathbegin-hostend-1 );
510 buffer[pathbegin-hostend-1] = 0;
511 s->port = atoi(buffer);
512 if( s->port < 0 || s->port > 65535 ) s->port = 554;
516 //fprintf( stderr, "got mrl: %s %i %s\n", s->host, s->port, s->path );
518 s->s = rtsp->pf_connect( rtsp->p_userdata, s->host, s->port );
522 //fprintf(stderr, "rtsp: failed to connect to '%s'\n", s->host);
527 s->server_state = RTSP_CONNECTED;
529 /* now lets send an options request. */
530 rtsp_schedule_field( rtsp, "CSeq: 1");
531 rtsp_schedule_field( rtsp, s->user_agent);
532 rtsp_schedule_field( rtsp, "ClientChallenge: "
533 "9e26d33f2984236010ef6253fb1887f7");
534 rtsp_schedule_field( rtsp, "PlayerStarttime: [28/03/2003:22:50:23 00:00]");
535 rtsp_schedule_field( rtsp, "CompanyID: KnKV4M4I/B2FjJ1TToLycw==" );
536 rtsp_schedule_field( rtsp, "GUID: 00000000-0000-0000-0000-000000000000" );
537 rtsp_schedule_field( rtsp, "RegionData: 0" );
538 rtsp_schedule_field( rtsp, "ClientID: "
539 "Linux_2.4_6.0.9.1235_play32_RN01_EN_586" );
540 /*rtsp_schedule_field( rtsp, "Pragma: initiate-session" );*/
541 rtsp_request_options( rtsp, NULL );
547 * closes an rtsp connection
550 void rtsp_close( rtsp_client_t *rtsp )
552 if( rtsp->p_private->server_state )
554 /* TODO: send a TEAROFF */
555 rtsp->pf_disconnect( rtsp->p_userdata );
558 if( rtsp->p_private->path ) free( rtsp->p_private->path );
559 if( rtsp->p_private->host ) free( rtsp->p_private->host );
560 if( rtsp->p_private->mrl ) free( rtsp->p_private->mrl );
561 if( rtsp->p_private->session ) free( rtsp->p_private->session );
562 if( rtsp->p_private->user_agent ) free( rtsp->p_private->user_agent );
563 if( rtsp->p_private->server ) free( rtsp->p_private->server );
564 rtsp_free_answers( rtsp );
565 rtsp_unschedule_all( rtsp );
566 free( rtsp->p_private );
570 * search in answers for tags. returns a pointer to the content
571 * after the first matched tag. returns NULL if no match found.
574 char *rtsp_search_answers( rtsp_client_t *rtsp, const char *tag )
579 if( !rtsp->p_private->answers ) return NULL;
580 answer = rtsp->p_private->answers;
584 if( !strncasecmp( *answer, tag, strlen(tag) ) )
586 ptr = strchr(*answer, ':');
588 while( *ptr == ' ' ) ptr++;
598 * session id management
601 void rtsp_set_session( rtsp_client_t *rtsp, const char *id )
603 if( rtsp->p_private->session ) free( rtsp->p_private->session );
604 rtsp->p_private->session = strdup(id);
607 char *rtsp_get_session( rtsp_client_t *rtsp )
609 return rtsp->p_private->session;
612 char *rtsp_get_mrl( rtsp_client_t *rtsp )
614 return rtsp->p_private->mrl;
618 * schedules a field for transmission
621 void rtsp_schedule_field( rtsp_client_t *rtsp, const char *string )
625 if( !string ) return;
627 while( rtsp->p_private->scheduled[i] ) i++;
629 rtsp->p_private->scheduled[i] = strdup(string);
633 * removes the first scheduled field which prefix matches string.
636 void rtsp_unschedule_field( rtsp_client_t *rtsp, const char *string )
638 char **ptr = rtsp->p_private->scheduled;
640 if( !string ) return;
644 if( !strncmp(*ptr, string, strlen(string)) ) break;
646 if( *ptr ) free( *ptr );
655 * unschedule all fields
658 void rtsp_unschedule_all( rtsp_client_t *rtsp )
662 if( !rtsp->p_private->scheduled ) return;
663 ptr = rtsp->p_private->scheduled;
676 void rtsp_free_answers( rtsp_client_t *rtsp )
680 if( !rtsp->p_private->answers ) return;
681 answer = rtsp->p_private->answers;