1 /*****************************************************************************
3 *****************************************************************************
4 * Copyright (C) 2003 VideoLAN
5 * $Id: rtp.c,v 1.7 2003/11/21 15:32:08 fenrir Exp $
7 * Authors: Laurent Aimar <fenrir@via.ecp.fr>
9 * This program is free software; you can redistribute it and/or modify
10 * it under the terms of the GNU General Public License as published by
11 * the Free Software Foundation; either version 2 of the License, or
12 * (at your option) any later version.
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 * GNU General Public License for more details.
19 * You should have received a copy of the GNU General Public License
20 * along with this program; if not, write to the Free Software
21 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111, USA.
22 *****************************************************************************/
24 /*****************************************************************************
26 *****************************************************************************/
30 #include <vlc/input.h>
36 /*****************************************************************************
38 *****************************************************************************/
39 static int Open ( vlc_object_t * );
40 static void Close( vlc_object_t * );
43 set_description( _("RTP stream") );
44 set_capability( "sout stream", 0 );
45 add_shortcut( "rtp" );
46 set_callbacks( Open, Close );
49 /*****************************************************************************
51 *****************************************************************************/
52 static sout_stream_id_t *Add ( sout_stream_t *, es_format_t * );
53 static int Del ( sout_stream_t *, sout_stream_id_t * );
54 static int Send( sout_stream_t *, sout_stream_id_t *, sout_buffer_t* );
57 struct sout_stream_sys_t
67 httpd_host_t *p_httpd_host;
68 httpd_file_t *p_httpd_file;
71 char *psz_destination;
75 /* when need to use a private one or when using muxer */
78 /* in case we do TS/PS over rtp */
80 sout_access_out_t *p_access;
82 sout_access_out_t *p_grab;
84 uint32_t i_timestamp_start;
86 sout_buffer_t *packet;
90 sout_stream_id_t **es;
93 typedef int (*pf_rtp_packetizer_t)( sout_stream_t *, sout_stream_id_t *, sout_buffer_t * );
94 struct sout_stream_id_t
97 uint8_t i_payload_type;
99 uint32_t i_timestamp_start;
106 char *psz_destination;
110 /* Packetizer specific fields */
111 pf_rtp_packetizer_t pf_packetize;
114 /* for sending the packets */
115 sout_access_out_t *p_access;
116 sout_input_t *p_input;
118 static int AccessOutGrabberWrite( sout_access_out_t *, sout_buffer_t * );
120 static int HttpCallback( httpd_file_callback_args_t *p_args,
121 uint8_t *p_request, int i_request,
122 uint8_t **pp_data, int *pi_data );
124 /*****************************************************************************
126 *****************************************************************************/
127 static int Open( vlc_object_t *p_this )
129 sout_stream_t *p_stream = (sout_stream_t*)p_this;
130 sout_instance_t *p_sout = p_stream->p_sout;
131 sout_stream_sys_t *p_sys;
135 p_sys = malloc( sizeof( sout_stream_sys_t ) );
136 p_sys->psz_destination = sout_cfg_find_value( p_stream->p_cfg, "dst" );
137 if( ( val = sout_cfg_find_value( p_stream->p_cfg, "port" ) ) )
139 p_sys->i_port = atoi( val );
141 if( !p_sys->psz_destination || *p_sys->psz_destination == '\0' || p_sys->i_port <= 0 )
143 msg_Err( p_stream, "invalid/missing dst or port" );
147 if( ( val = sout_cfg_find_value( p_stream->p_cfg, "ttl" ) ) )
149 p_sys->i_ttl = atoi( val );
153 p_sys->i_ttl = config_GetInt( p_stream, "ttl" );
156 p_sys->i_payload_type = 96;
159 p_sys->psz_sdp = NULL;
161 p_sys->i_sdp_id = mdate();
162 p_sys->i_sdp_version = 1;
163 p_sys->psz_sdp = NULL;
164 p_sys->p_httpd = NULL;
165 p_sys->p_httpd_host = NULL;
166 p_sys->p_httpd_file = NULL;
168 if( ( val = sout_cfg_find_value( p_stream->p_cfg, "mux" ) ) )
170 sout_access_out_t *p_grab;
174 char url[strlen( p_sys->psz_destination ) + 1 + 12 + 1];
176 /* Check muxer type */
177 if( !strncasecmp( val, "ps", 2 ) || !strncasecmp( val, "mpeg1", 5 ) )
179 psz_rtpmap = "MP2P/90000";
181 else if( !strncasecmp( val, "ts", 2 ) )
183 psz_rtpmap = "MP2T/90000";
184 p_sys->i_payload_type = 33;
188 msg_Err( p_stream, "unsupported muxer type with rtp (only ts/ps)" );
192 /* create the access out */
193 if( p_sys->i_ttl > 0 )
195 sprintf( access, "udp{raw,ttl=%d}", p_sys->i_ttl );
199 sprintf( access, "udp{raw}" );
201 sprintf( url, "%s:%d", p_sys->psz_destination, p_sys->i_port );
202 if( ( p_sys->p_access = sout_AccessOutNew( p_sout, access, url ) ) == NULL )
204 msg_Err( p_stream, "cannot create the access out for %s://%s",
209 p_sys->i_mtu = config_GetInt( p_stream, "mtu" ); /* XXX beurk */
210 if( p_sys->i_mtu <= 16 )
212 /* better than nothing */
216 /* the access out grabber TODO export it as sout_AccessOutGrabberNew */
217 p_grab = p_sys->p_grab = vlc_object_create( p_sout, sizeof( sout_access_out_t ) );
218 p_grab->p_module = NULL;
219 p_grab->p_sout = p_sout;
220 p_grab->psz_access = strdup( "grab" );
221 p_grab->p_cfg = NULL;
222 p_grab->psz_name = strdup( "" );
223 p_grab->p_sys = (sout_access_out_sys_t*)p_stream;
224 p_grab->pf_seek = NULL;
225 p_grab->pf_write = AccessOutGrabberWrite;
228 if( ( p_sys->p_mux = sout_MuxNew( p_sout, val, p_sys->p_grab ) ) == NULL )
230 msg_Err( p_stream, "cannot create the muxer (%s)", val );
231 sout_AccessOutDelete( p_sys->p_grab );
232 sout_AccessOutDelete( p_sys->p_access );
236 p_sout->i_preheader = __MAX( p_sout->i_preheader, p_sys->p_mux->i_preheader );
238 /* create the SDP only once */
239 p_sys->psz_sdp = malloc( 200 + 20 + 10 + strlen( p_sys->psz_destination ) + 10 + 10 + 10 + 10 + strlen( psz_rtpmap ) );
240 sprintf( p_sys->psz_sdp,
242 "o=- "I64Fd" %d IN IP4 127.0.0.1\n"
245 "m=video %d RTP/AVP %d\n"
247 p_sys->i_sdp_id, p_sys->i_sdp_version,
248 p_sys->psz_destination, p_sys->i_ttl,
249 p_sys->i_port, p_sys->i_payload_type,
250 p_sys->i_payload_type, psz_rtpmap );
252 fprintf( stderr, "sdp=%s", p_sys->psz_sdp );
254 /* create the rtp context */
255 p_sys->ssrc[0] = rand()&0xff;
256 p_sys->ssrc[1] = rand()&0xff;
257 p_sys->ssrc[2] = rand()&0xff;
258 p_sys->ssrc[3] = rand()&0xff;
259 p_sys->i_sequence = rand()&0xffff;
260 p_sys->i_timestamp_start = rand()&0xffffffff;
261 p_sys->packet = NULL;
266 p_sys->p_access = NULL;
267 p_sys->p_grab = NULL;
270 if( ( val = sout_cfg_find_value( p_stream->p_cfg, "sdp" ) ) )
274 vlc_UrlParse( &url, val, 0 );
275 if( url.psz_protocol && !strcmp( url.psz_protocol, "http" ) )
277 if( ( p_sys->p_httpd = httpd_Find( VLC_OBJECT(p_stream), VLC_TRUE ) ) )
279 p_sys->p_httpd_host = p_sys->p_httpd->pf_register_host( p_sys->p_httpd,
282 if( p_sys->p_httpd_host )
284 p_sys->p_httpd_file =
285 p_sys->p_httpd->pf_register_file( p_sys->p_httpd,
286 url.psz_path ? url.psz_path : "/",
289 HttpCallback, HttpCallback,
293 if( p_sys->p_httpd_file == NULL )
295 msg_Err( p_stream, "cannot export sdp as http" );
300 msg_Warn( p_stream, "unknow protocol for SDP (%s)", url.psz_protocol );
302 vlc_UrlClean( &url );
305 vlc_mutex_init( p_stream, &p_sys->lock_sdp );
307 p_stream->pf_add = Add;
308 p_stream->pf_del = Del;
309 p_stream->pf_send = Send;
311 p_stream->p_sys = p_sys;
316 /*****************************************************************************
318 *****************************************************************************/
319 static void Close( vlc_object_t * p_this )
321 sout_stream_t *p_stream = (sout_stream_t*)p_this;
322 sout_stream_sys_t *p_sys = p_stream->p_sys;
326 sout_MuxDelete( p_sys->p_mux );
327 sout_AccessOutDelete( p_sys->p_access );
328 sout_AccessOutDelete( p_sys->p_grab );
331 sout_BufferDelete( p_stream->p_sout, p_sys->packet );
335 vlc_mutex_destroy( &p_sys->lock_sdp );
337 if( p_sys->p_httpd_file )
339 p_sys->p_httpd->pf_unregister_file( p_sys->p_httpd, p_sys->p_httpd_file );
341 if( p_sys->p_httpd_host )
343 p_sys->p_httpd->pf_unregister_host( p_sys->p_httpd, p_sys->p_httpd_host );
347 httpd_Release( p_sys->p_httpd );
352 free( p_sys->psz_sdp );
358 /*****************************************************************************
360 *****************************************************************************/
361 static void SDPGenerate( sout_stream_t *p_stream )
363 sout_stream_sys_t *p_sys = p_stream->p_sys;
368 i_size = strlen( "v=0\n" ) +
369 strlen( "o=- * * IN IP4 127.0.0.1\n" ) +
370 strlen( "s=NONE\n" ) +
371 strlen( "c=IN IP4 */*\n" ) +
372 strlen( p_sys->psz_destination ) +
374 for( i = 0; i < p_sys->i_es; i++ )
376 sout_stream_id_t *id = p_sys->es[i];
378 i_size += strlen( "m=**d*o * RTP/AVP *\n" ) + 10 + 10;
382 i_size += strlen( "a=rtpmap:* *\n" ) + strlen( id->psz_rtpmap )+10;
386 i_size += strlen( "a=fmtp:* *\n" ) + strlen( id->psz_fmtp ) + 10;
390 p = psz_sdp = malloc( i_size );
391 p += sprintf( p, "v=0\n" );
392 p += sprintf( p, "o=- "I64Fd" %d IN IP4 127.0.0.1\n", p_sys->i_sdp_id, p_sys->i_sdp_version );
393 p += sprintf( p, "s=NONE\n" );
394 p += sprintf( p, "c=IN IP4 %s/%d\n", p_sys->psz_destination, p_sys->i_ttl );
396 for( i = 0; i < p_sys->i_es; i++ )
398 sout_stream_id_t *id = p_sys->es[i];
400 if( id->i_cat == AUDIO_ES )
402 p += sprintf( p, "m=audio %d RTP/AVP %d\n",
403 id->i_port, id->i_payload_type );
405 else if( id->i_cat == VIDEO_ES )
407 p += sprintf( p, "m=video %d RTP/AVP %d\n",
408 id->i_port, id->i_payload_type );
416 p += sprintf( p, "a=rtpmap:%d %s\n", id->i_payload_type, id->psz_rtpmap );
420 p += sprintf( p, "a=fmtp:%d %s\n", id->i_payload_type, id->psz_fmtp );
424 vlc_mutex_lock( &p_sys->lock_sdp );
425 free( p_sys->psz_sdp );
426 p_sys->psz_sdp = psz_sdp;
427 vlc_mutex_unlock( &p_sys->lock_sdp );
429 p_sys->i_sdp_version++;
431 fprintf( stderr, "sdp=%s", p_sys->psz_sdp );
434 /*****************************************************************************
436 *****************************************************************************/
438 static int rtp_packetize_l16 ( sout_stream_t *, sout_stream_id_t *, sout_buffer_t * );
439 static int rtp_packetize_l8 ( sout_stream_t *, sout_stream_id_t *, sout_buffer_t * );
440 static int rtp_packetize_mpa ( sout_stream_t *, sout_stream_id_t *, sout_buffer_t * );
441 static int rtp_packetize_mpv ( sout_stream_t *, sout_stream_id_t *, sout_buffer_t * );
442 static int rtp_packetize_ac3 ( sout_stream_t *, sout_stream_id_t *, sout_buffer_t * );
443 static int rtp_packetize_split( sout_stream_t *, sout_stream_id_t *, sout_buffer_t * );
444 static int rtp_packetize_mp4a ( sout_stream_t *, sout_stream_id_t *, sout_buffer_t * );
446 static void sprintf_hexa( char *s, uint8_t *p_data, int i_data )
448 static const char hex[16] = "0123456789ABCDEF";
451 for( i = 0; i < i_data; i++ )
453 s[2*i+0] = hex[(p_data[i]>>8)&0xf];
454 s[2*i+1] = hex[(p_data[i] )&0xf];
459 static sout_stream_id_t * Add ( sout_stream_t *p_stream, es_format_t *p_fmt )
461 sout_instance_t *p_sout = p_stream->p_sout;
462 sout_stream_sys_t *p_sys = p_stream->p_sys;
463 sout_stream_id_t *id;
464 sout_access_out_t *p_access = NULL;
467 char url[strlen( p_sys->psz_destination ) + 1 + 12 + 1];
469 if( p_sys->p_mux != NULL )
471 sout_input_t *p_input = NULL;
472 if( ( p_input = sout_MuxAddStream( p_sys->p_mux, p_fmt ) ) == NULL )
474 msg_Err( p_stream, "cannot add this stream to the muxer" );
478 id = malloc( sizeof( sout_stream_id_t ) );
480 id->p_input = p_input;
481 id->pf_packetize= NULL;
486 /* first try to create the access out */
487 if( p_sys->i_ttl > 0 )
489 sprintf( access, "udp{raw,ttl=%d}", p_sys->i_ttl );
493 sprintf( access, "udp{raw}" );
495 sprintf( url, "%s:%d", p_sys->psz_destination, p_sys->i_port );
496 if( ( p_access = sout_AccessOutNew( p_sout, access, url ) ) == NULL )
498 msg_Err( p_stream, "cannot create the access out for %s://%s",
503 /* not create the rtp specific stuff */
504 id = malloc( sizeof( sout_stream_id_t ) );
505 id->p_access = p_access;
507 id->psz_rtpmap = NULL;
509 id->psz_destination = strdup( p_sys->psz_destination );
510 id->i_port = p_sys->i_port;
512 switch( p_fmt->i_codec )
514 case VLC_FOURCC( 's', '1', '6', 'b' ):
515 if( p_fmt->audio.i_channels == 1 && p_fmt->audio.i_rate == 44100 )
517 id->i_payload_type = 11;
519 else if( p_fmt->audio.i_channels == 2 && p_fmt->audio.i_rate == 44100 )
521 id->i_payload_type = 10;
525 id->i_payload_type = p_sys->i_payload_type++;
527 id->psz_rtpmap = malloc( strlen( "L16/*/*" ) + 20+1 );
528 sprintf( id->psz_rtpmap, "L16/%d/%d", p_fmt->audio.i_rate, p_fmt->audio.i_channels );
529 id->i_clock_rate = p_fmt->audio.i_rate;
530 id->pf_packetize = rtp_packetize_l16;
532 case VLC_FOURCC( 'u', '8', ' ', ' ' ):
533 id->i_payload_type = p_sys->i_payload_type++;
534 id->psz_rtpmap = malloc( strlen( "L8/*/*" ) + 20+1 );
535 sprintf( id->psz_rtpmap, "L8/%d/%d", p_fmt->audio.i_rate, p_fmt->audio.i_channels );
536 id->i_clock_rate = p_fmt->audio.i_rate;
537 id->pf_packetize = rtp_packetize_l8;
539 case VLC_FOURCC( 'm', 'p', 'g', 'a' ):
540 id->i_payload_type = 14;
541 id->i_clock_rate = 90000;
542 id->psz_rtpmap = strdup( "MPA/90000" );
543 id->pf_packetize = rtp_packetize_mpa;
545 case VLC_FOURCC( 'm', 'p', 'g', 'v' ):
546 id->i_payload_type = 32;
547 id->i_clock_rate = 90000;
548 id->psz_rtpmap = strdup( "MPV/90000" );
549 id->pf_packetize = rtp_packetize_mpv;
551 case VLC_FOURCC( 'a', '5', '2', ' ' ):
552 id->i_payload_type = p_sys->i_payload_type++;
553 id->i_clock_rate = 90000;
554 id->psz_rtpmap = strdup( "ac3/90000" );
555 id->pf_packetize = rtp_packetize_ac3;
557 case VLC_FOURCC( 'm', 'p', '4', 'v' ):
559 char hexa[2*p_fmt->i_extra +1];
561 id->i_payload_type = p_sys->i_payload_type++;
562 id->i_clock_rate = 90000;
563 id->psz_rtpmap = strdup( "MP4V-ES/90000" );
564 id->pf_packetize = rtp_packetize_split;
565 if( p_fmt->i_extra > 0 )
567 id->psz_fmtp = malloc( 100 + 2 * p_fmt->i_extra );
568 sprintf_hexa( hexa, p_fmt->p_extra, p_fmt->i_extra );
569 sprintf( id->psz_fmtp,
570 "profile-level-id=3; config=%s", hexa );
574 case VLC_FOURCC( 'm', 'p', '4', 'a' ):
576 char hexa[2*p_fmt->i_extra +1];
578 id->i_payload_type = p_sys->i_payload_type++;
579 id->i_clock_rate = p_fmt->audio.i_rate;
580 id->psz_rtpmap = malloc( strlen( "mpeg4-generic/" ) + 12 );
581 sprintf( id->psz_rtpmap, "mpeg4-generic/%d", p_fmt->audio.i_rate );
582 id->pf_packetize = rtp_packetize_mp4a;
583 id->psz_fmtp = malloc( 200 + 2 * p_fmt->i_extra );
584 sprintf_hexa( hexa, p_fmt->p_extra, p_fmt->i_extra );
585 sprintf( id->psz_fmtp,
586 "streamtype=5; profile-level-id=15; mode=AAC-hbr; config=%s; "
587 "SizeLength=13; IndexLength=3; IndexDeltaLength=3; Profile=1;", hexa );
592 msg_Err( p_stream, "cannot add this stream (unsupported codec:%4.4s)", (char*)&p_fmt->i_codec );
596 id->i_cat = p_fmt->i_cat;
598 id->ssrc[0] = rand()&0xff;
599 id->ssrc[1] = rand()&0xff;
600 id->ssrc[2] = rand()&0xff;
601 id->ssrc[3] = rand()&0xff;
602 id->i_sequence = rand()&0xffff;
603 id->i_timestamp_start = rand()&0xffffffff;
605 id->i_mtu = config_GetInt( p_stream, "mtu" ); /* XXX beuk */
606 if( id->i_mtu <= 16 )
608 /* better than nothing */
612 msg_Dbg( p_stream, "access out %s:%s mtu=%d", access, url, id->i_mtu );
614 /* Update p_sys context */
615 /* update port used (2 -> 1 rtp, 1 rtcp )*/
616 TAB_APPEND( p_sys->i_es, p_sys->es, id );
617 if( p_sys->p_mux == NULL )
620 SDPGenerate( p_stream );
626 static int Del ( sout_stream_t *p_stream, sout_stream_id_t *id )
628 sout_stream_sys_t *p_sys = p_stream->p_sys;
630 TAB_REMOVE( p_sys->i_es, p_sys->es, id );
636 free( id->psz_rtpmap );
640 free( id->psz_fmtp );
642 free( id->psz_destination );
643 sout_AccessOutDelete( id->p_access );
645 else if( id->p_input )
647 sout_MuxDeleteStream( p_sys->p_mux, id->p_input );
653 static int Send ( sout_stream_t *p_stream, sout_stream_id_t *id, sout_buffer_t *p_buffer )
655 sout_buffer_t *p_next;
657 if( p_stream->p_sys->p_mux )
659 sout_MuxSendBuffer( p_stream->p_sys->p_mux, id->p_input, p_buffer );
665 p_next = p_buffer->p_next;
666 if( id->pf_packetize( p_stream, id, p_buffer ) )
670 sout_BufferDelete( p_stream->p_sout, p_buffer );
677 static int HttpCallback( httpd_file_callback_args_t *p_args,
678 uint8_t *p_request, int i_request,
679 uint8_t **pp_data, int *pi_data )
681 sout_stream_sys_t *p_sys = (sout_stream_sys_t*)p_args;
682 vlc_mutex_lock( &p_sys->lock_sdp );
683 if( p_sys->psz_sdp && *p_sys->psz_sdp )
685 *pi_data = strlen( p_sys->psz_sdp );
686 *pp_data = malloc( *pi_data );
687 memcpy( *pp_data, p_sys->psz_sdp, *pi_data );
694 vlc_mutex_unlock( &p_sys->lock_sdp );
699 static int AccessOutGrabberWriteBuffer( sout_stream_t *p_stream, sout_buffer_t *p_buffer )
701 sout_stream_sys_t *p_sys = p_stream->p_sys;
703 int64_t i_dts = p_buffer->i_dts;
704 uint32_t i_timestamp = i_dts * 9 / 100;
706 uint8_t *p_data = p_buffer->p_buffer;
707 unsigned int i_data = p_buffer->i_size;
708 unsigned int i_max = p_sys->i_mtu - 12;
710 int i_packet = ( p_buffer->i_size + i_max - 1 ) / i_max;
716 /* output complete packet */
718 p_sys->packet->i_size + i_data > i_max )
720 sout_AccessOutWrite( p_sys->p_access, p_sys->packet );
721 p_sys->packet = NULL;
724 if( p_sys->packet == NULL )
726 /* allocate a new packet */
727 p_sys->packet = sout_BufferNew( p_stream->p_sout, p_sys->i_mtu );
728 p_sys->packet->p_buffer[ 0] = 0x80;
729 p_sys->packet->p_buffer[ 1] = p_sys->i_payload_type;
730 p_sys->packet->p_buffer[ 2] = ( p_sys->i_sequence >> 8)&0xff;
731 p_sys->packet->p_buffer[ 3] = ( p_sys->i_sequence )&0xff;
732 p_sys->packet->p_buffer[ 4] = ( i_timestamp >> 24 )&0xff;
733 p_sys->packet->p_buffer[ 5] = ( i_timestamp >> 16 )&0xff;
734 p_sys->packet->p_buffer[ 6] = ( i_timestamp >> 8 )&0xff;
735 p_sys->packet->p_buffer[ 7] = ( i_timestamp )&0xff;
736 p_sys->packet->p_buffer[ 8] = p_sys->ssrc[0];
737 p_sys->packet->p_buffer[ 9] = p_sys->ssrc[1];
738 p_sys->packet->p_buffer[10] = p_sys->ssrc[2];
739 p_sys->packet->p_buffer[11] = p_sys->ssrc[3];
740 p_sys->packet->i_size = 12;
742 p_sys->packet->i_dts = i_dts;
743 p_sys->packet->i_length = p_buffer->i_length / i_packet;
744 i_dts += p_sys->packet->i_length;
749 i_size = __MIN( i_data, p_sys->i_mtu - p_sys->packet->i_size );
751 memcpy( &p_sys->packet->p_buffer[p_sys->packet->i_size],
755 p_sys->packet->i_size += i_size;
763 static int AccessOutGrabberWrite( sout_access_out_t *p_access, sout_buffer_t *p_buffer )
765 sout_stream_t *p_stream = (sout_stream_t*)p_access->p_sys;
767 //fprintf( stderr, "received buffer size=%d\n", p_buffer->i_size );
771 sout_buffer_t *p_next;
773 AccessOutGrabberWriteBuffer( p_stream, p_buffer );
775 p_next = p_buffer->p_next;
776 sout_BufferDelete( p_access->p_sout, p_buffer );
784 static void rtp_packetize_common( sout_stream_id_t *id, sout_buffer_t *out, int b_marker, int64_t i_pts )
786 uint32_t i_timestamp = i_pts * (int64_t)id->i_clock_rate / (int64_t)1000000;
788 out->p_buffer[0] = 0x80;
789 out->p_buffer[1] = (b_marker?0x80:0x00)|id->i_payload_type;
790 out->p_buffer[2] = ( id->i_sequence >> 8)&0xff;
791 out->p_buffer[3] = ( id->i_sequence )&0xff;
792 out->p_buffer[4] = ( i_timestamp >> 24 )&0xff;
793 out->p_buffer[5] = ( i_timestamp >> 16 )&0xff;
794 out->p_buffer[6] = ( i_timestamp >> 8 )&0xff;
795 out->p_buffer[7] = ( i_timestamp )&0xff;
797 out->p_buffer[ 8] = id->ssrc[0];
798 out->p_buffer[ 9] = id->ssrc[1];
799 out->p_buffer[10] = id->ssrc[2];
800 out->p_buffer[11] = id->ssrc[3];
806 static int rtp_packetize_mpa( sout_stream_t *p_stream, sout_stream_id_t *id, sout_buffer_t *in )
808 int i_max = id->i_mtu - 12 - 4; /* payload max in one packet */
809 int i_count = ( in->i_size + i_max - 1 ) / i_max;
811 uint8_t *p_data = in->p_buffer;
812 int i_data = in->i_size;
815 for( i = 0; i < i_count; i++ )
817 int i_payload = __MIN( i_max, i_data );
818 sout_buffer_t *out = sout_BufferNew( p_stream->p_sout, 16 + i_payload );
820 /* rtp common header */
821 rtp_packetize_common( id, out, (i == i_count - 1)?1:0, in->i_pts );
823 out->p_buffer[12] = 0;
824 out->p_buffer[13] = 0;
825 /* fragment offset in the current frame */
826 out->p_buffer[14] = ( (i*i_max) >> 8 )&0xff;
827 out->p_buffer[15] = ( (i*i_max) )&0xff;
828 memcpy( &out->p_buffer[16], p_data, i_payload );
830 out->i_size = 16 + i_payload;
831 out->i_dts = in->i_dts + i * in->i_length / i_count;
832 out->i_length = in->i_length / i_count;
834 sout_AccessOutWrite( id->p_access, out );
844 static int rtp_packetize_mpv( sout_stream_t *p_stream, sout_stream_id_t *id, sout_buffer_t *in )
846 int i_max = id->i_mtu - 12 - 4; /* payload max in one packet */
847 int i_count = ( in->i_size + i_max - 1 ) / i_max;
849 uint8_t *p_data = in->p_buffer;
850 int i_data = in->i_size;
852 int b_sequence_start = 0;
853 int i_temporal_ref = 0;
854 int i_picture_coding_type = 0;
855 int i_fbv = 0, i_bfc = 0, i_ffv = 0, i_ffc = 0;
856 int b_start_slice = 0;
858 /* preparse this packet to get some info */
862 int i_rest = in->i_size;
867 ( p[0] != 0x00 || p[1] != 0x00 || p[2] != 0x01 ) )
881 /* sequence start code */
882 b_sequence_start = 1;
884 else if( *p == 0x00 && i_rest >= 4 )
887 i_temporal_ref = ( p[1] << 2) |((p[2]>>6)&0x03);
888 i_picture_coding_type = (p[2] >> 3)&0x07;
890 if( i_rest > 4 && ( i_picture_coding_type == 2 || i_picture_coding_type == 3 ) )
892 i_ffc = (p[3] >> 2)&0x01;
893 i_bfc = ((p[3]&0x03) << 1)|((p[4]>>7)&0x01);
894 if( i_picture_coding_type == 3 )
896 i_fbv = (p[4]>>6)&0x01;
897 i_bfc = (p[4]>>3)&0x07;
901 else if( *p <= 0xaf )
908 for( i = 0; i < i_count; i++ )
910 int i_payload = __MIN( i_max, i_data );
911 sout_buffer_t *out = sout_BufferNew( p_stream->p_sout, 16 + i_payload );
912 uint32_t h = ( i_temporal_ref << 16 )|
913 ( b_sequence_start << 13 )|
914 ( b_start_slice << 12 )|
915 ( i == i_count - 1 ? 1 << 11 : 0 )|
916 ( i_picture_coding_type << 8 )|
917 ( i_fbv << 7 )|( i_bfc << 4 )|( i_ffv << 3 )|i_ffc;
919 /* rtp common header */
920 rtp_packetize_common( id, out, (i == i_count - 1)?1:0, in->i_pts );
922 /* MBZ:5 T:1 TR:10 AN:1 N:1 S:1 B:1 E:1 P:3 FBV:1 BFC:3 FFV:1 FFC:3 */
923 out->p_buffer[12] = ( h >> 24 )&0xff;
924 out->p_buffer[13] = ( h >> 16 )&0xff;
925 out->p_buffer[14] = ( h >> 8 )&0xff;
926 out->p_buffer[15] = ( h )&0xff;
928 memcpy( &out->p_buffer[16], p_data, i_payload );
930 out->i_size = 16 + i_payload;
931 out->i_dts = in->i_dts + i * in->i_length / i_count;
932 out->i_length = in->i_length / i_count;
934 sout_AccessOutWrite( id->p_access, out );
942 static int rtp_packetize_ac3( sout_stream_t *p_stream, sout_stream_id_t *id, sout_buffer_t *in )
944 int i_max = id->i_mtu - 12 - 2; /* payload max in one packet */
945 int i_count = ( in->i_size + i_max - 1 ) / i_max;
947 uint8_t *p_data = in->p_buffer;
948 int i_data = in->i_size;
951 for( i = 0; i < i_count; i++ )
953 int i_payload = __MIN( i_max, i_data );
954 sout_buffer_t *out = sout_BufferNew( p_stream->p_sout, 14 + i_payload );
956 /* rtp common header */
957 rtp_packetize_common( id, out, (i == i_count - 1)?1:0, in->i_pts );
959 out->p_buffer[12] = 1;
961 out->p_buffer[13] = 0x00;
963 memcpy( &out->p_buffer[14], p_data, i_payload );
965 out->i_size = 14 + i_payload;
966 out->i_dts = in->i_dts + i * in->i_length / i_count;
967 out->i_length = in->i_length / i_count;
969 sout_AccessOutWrite( id->p_access, out );
978 static int rtp_packetize_split( sout_stream_t *p_stream, sout_stream_id_t *id, sout_buffer_t *in )
980 int i_max = id->i_mtu - 12; /* payload max in one packet */
981 int i_count = ( in->i_size + i_max - 1 ) / i_max;
983 uint8_t *p_data = in->p_buffer;
984 int i_data = in->i_size;
987 for( i = 0; i < i_count; i++ )
989 int i_payload = __MIN( i_max, i_data );
990 sout_buffer_t *out = sout_BufferNew( p_stream->p_sout, 12 + i_payload );
992 /* rtp common header */
993 rtp_packetize_common( id, out, ((i == i_count - 1)?1:0), (in->i_pts > 0 ? in->i_pts : in->i_dts) );
994 memcpy( &out->p_buffer[12], p_data, i_payload );
996 out->i_size = 12 + i_payload;
997 out->i_dts = in->i_dts + i * in->i_length / i_count;
998 out->i_length = in->i_length / i_count;
1000 sout_AccessOutWrite( id->p_access, out );
1002 p_data += i_payload;
1003 i_data -= i_payload;
1009 static int rtp_packetize_l16( sout_stream_t *p_stream, sout_stream_id_t *id, sout_buffer_t *in )
1011 int i_max = id->i_mtu - 12; /* payload max in one packet */
1012 int i_count = ( in->i_size + i_max - 1 ) / i_max;
1014 uint8_t *p_data = in->p_buffer;
1015 int i_data = in->i_size;
1020 int i_payload = (__MIN( i_max, i_data )/4)*4;
1021 sout_buffer_t *out = sout_BufferNew( p_stream->p_sout, 12 + i_payload );
1023 /* rtp common header */
1024 rtp_packetize_common( id, out, 0, (in->i_pts > 0 ? in->i_pts : in->i_dts) );
1025 memcpy( &out->p_buffer[12], p_data, i_payload );
1027 out->i_size = 12 + i_payload;
1028 out->i_dts = in->i_dts + i_packet * in->i_length / i_count;
1029 out->i_length = in->i_length / i_count;
1031 sout_AccessOutWrite( id->p_access, out );
1033 p_data += i_payload;
1034 i_data -= i_payload;
1041 static int rtp_packetize_l8( sout_stream_t *p_stream, sout_stream_id_t *id, sout_buffer_t *in )
1043 int i_max = id->i_mtu - 12; /* payload max in one packet */
1044 int i_count = ( in->i_size + i_max - 1 ) / i_max;
1046 uint8_t *p_data = in->p_buffer;
1047 int i_data = in->i_size;
1052 int i_payload = (__MIN( i_max, i_data )/2)*2;
1053 sout_buffer_t *out = sout_BufferNew( p_stream->p_sout, 12 + i_payload );
1055 /* rtp common header */
1056 rtp_packetize_common( id, out, 0, (in->i_pts > 0 ? in->i_pts : in->i_dts) );
1057 memcpy( &out->p_buffer[12], p_data, i_payload );
1059 out->i_size = 12 + i_payload;
1060 out->i_dts = in->i_dts + i_packet * in->i_length / i_count;
1061 out->i_length = in->i_length / i_count;
1063 sout_AccessOutWrite( id->p_access, out );
1065 p_data += i_payload;
1066 i_data -= i_payload;
1072 static int rtp_packetize_mp4a( sout_stream_t *p_stream, sout_stream_id_t *id, sout_buffer_t *in )
1074 int i_max = id->i_mtu - 16; /* payload max in one packet */
1075 int i_count = ( in->i_size + i_max - 1 ) / i_max;
1077 uint8_t *p_data = in->p_buffer;
1078 int i_data = in->i_size;
1081 for( i = 0; i < i_count; i++ )
1083 int i_payload = __MIN( i_max, i_data );
1084 sout_buffer_t *out = sout_BufferNew( p_stream->p_sout, 16 + i_payload );
1086 /* rtp common header */
1087 rtp_packetize_common( id, out, ((i == i_count - 1)?1:0), (in->i_pts > 0 ? in->i_pts : in->i_dts) );
1089 /* AU headers length (bits) */
1090 out->p_buffer[12] = 0;
1091 out->p_buffer[13] = 2*8;
1092 /* for each AU length 13 bits + idx 3bits, */
1093 out->p_buffer[14] = ( in->i_size >> 5 )&&0xff;
1094 out->p_buffer[15] = ( (in->i_size&&0xff)<<3 )|0;
1096 memcpy( &out->p_buffer[16], p_data, i_payload );
1098 out->i_size = 16 + i_payload;
1099 out->i_dts = in->i_dts + i * in->i_length / i_count;
1100 out->i_length = in->i_length / i_count;
1102 sout_AccessOutWrite( id->p_access, out );
1104 p_data += i_payload;
1105 i_data -= i_payload;