1 /*****************************************************************************
2 * bridge.c: bridge stream output module
3 *****************************************************************************
4 * Copyright (C) 2005-2008 VLC authors and VideoLAN
6 * Authors: Christophe Massiot <massiot@via.ecp.fr>
7 * Antoine Cellerier <dionoea at videolan dot org>
9 * This program is free software; you can redistribute it and/or modify it
10 * under the terms of the GNU Lesser General Public License as published by
11 * the Free Software Foundation; either version 2.1 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 Lesser General Public License for more details.
19 * You should have received a copy of the GNU Lesser General Public License
20 * along with this program; if not, write to the Free Software Foundation,
21 * Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
22 *****************************************************************************/
24 /*****************************************************************************
26 *****************************************************************************/
32 #include <vlc_common.h>
33 #include <vlc_plugin.h>
35 #include <vlc_block.h>
37 /*****************************************************************************
39 *****************************************************************************/
40 #define ID_TEXT N_("ID")
41 #define ID_LONGTEXT N_( \
42 "Integer identifier for this elementary stream. This will be used to " \
43 "\"find\" this stream later." )
45 #define DEST_TEXT N_( "Destination bridge-in name" )
46 #define DEST_LONGTEXT N_( \
47 "Name of the destination bridge-in. If you do not need more " \
48 "than one bridge-in at a time, you can discard this option." )
50 #define DELAY_TEXT N_("Delay")
51 #define DELAY_LONGTEXT N_("Pictures coming from the picture video outputs " \
52 "will be delayed according to this value (in milliseconds, should be "\
53 ">= 100 ms). For high values, you will need to raise caching values." )
55 #define ID_OFFSET_TEXT N_("ID Offset")
56 #define ID_OFFSET_LONGTEXT N_("Offset to add to the stream IDs specified in " \
57 "bridge_out to obtain the stream IDs bridge_in will register.")
59 #define NAME_TEXT N_( "Name of current instance" )
60 #define NAME_LONGTEXT N_( \
61 "Name of this bridge-in instance. If you do not need more " \
62 "than one bridge-in at a time, you can discard this option." )
64 #define PLACEHOLDER_TEXT N_( "Fallback to placeholder stream when out of data" )
65 #define PLACEHOLDER_LONGTEXT N_( \
66 "If set to true, the bridge will discard all input elementary streams " \
67 "except if it doesn't receive data from another bridge-in. This can " \
68 "be used to configure a place holder stream when the real source " \
69 "breaks. Source and placeholder streams should have the same format." )
71 #define PLACEHOLDER_DELAY_TEXT N_( "Placeholder delay" )
72 #define PLACEHOLDER_DELAY_LONGTEXT N_( \
73 "Delay (in ms) before the placeholder kicks in." )
75 #define PLACEHOLDER_IFRAME_TEXT N_( "Wait for I frame before toggling placeholder" )
76 #define PLACEHOLDER_IFRAME_LONGTEXT N_( \
77 "If enabled, switching between the placeholder and the normal stream " \
78 "will only occur on I frames. This will remove artifacts on stream " \
79 "switching at the expense of a slightly longer delay, depending on " \
80 "the frequence of I frames in the streams." )
82 static int OpenOut ( vlc_object_t
* );
83 static void CloseOut( vlc_object_t
* );
84 static int OpenIn ( vlc_object_t
* );
85 static void CloseIn ( vlc_object_t
* );
87 #define SOUT_CFG_PREFIX_OUT "sout-bridge-out-"
88 #define SOUT_CFG_PREFIX_IN "sout-bridge-in-"
91 set_shortname( N_("Bridge"))
92 set_description( N_("Bridge stream output"))
94 set_section( N_("Bridge out"), NULL
)
95 set_capability( "sout output", 50 )
96 add_shortcut( "bridge-out" )
97 /* Only usable with VLM. No category so not in gui preferences
98 set_category( CAT_SOUT )
99 set_subcategory( SUBCAT_SOUT_STREAM )*/
100 add_integer( SOUT_CFG_PREFIX_OUT
"id", 0, ID_TEXT
, ID_LONGTEXT
,
102 add_string( SOUT_CFG_PREFIX_OUT
"in-name", "default",
103 DEST_TEXT
, DEST_LONGTEXT
, false )
104 set_callbacks( OpenOut
, CloseOut
)
107 set_section( N_("Bridge in"), NULL
)
108 set_capability( "sout filter", 50 )
109 add_shortcut( "bridge-in" )
110 /*set_category( CAT_SOUT )
111 set_subcategory( SUBCAT_SOUT_STREAM )*/
112 add_integer( SOUT_CFG_PREFIX_IN
"delay", 0, DELAY_TEXT
,
113 DELAY_LONGTEXT
, false )
114 add_integer( SOUT_CFG_PREFIX_IN
"id-offset", 8192, ID_OFFSET_TEXT
,
115 ID_OFFSET_LONGTEXT
, false )
116 add_string( SOUT_CFG_PREFIX_IN
"name", "default",
117 NAME_TEXT
, NAME_LONGTEXT
, false )
118 add_bool( SOUT_CFG_PREFIX_IN
"placeholder", false,
119 PLACEHOLDER_TEXT
, PLACEHOLDER_LONGTEXT
, false )
120 add_integer( SOUT_CFG_PREFIX_IN
"placeholder-delay", 200,
121 PLACEHOLDER_DELAY_TEXT
, PLACEHOLDER_DELAY_LONGTEXT
, false )
122 add_bool( SOUT_CFG_PREFIX_IN
"placeholder-switch-on-iframe", true,
123 PLACEHOLDER_IFRAME_TEXT
, PLACEHOLDER_IFRAME_LONGTEXT
, false )
124 set_callbacks( OpenIn
, CloseIn
)
129 /*****************************************************************************
131 *****************************************************************************/
132 static const char *const ppsz_sout_options_out
[] = {
133 "id", "in-name", NULL
136 static const char *const ppsz_sout_options_in
[] = {
137 "delay", "id-offset", "name",
138 "placeholder", "placeholder-delay", "placeholder-switch-on-iframe",
142 static void *AddOut( sout_stream_t
*, const es_format_t
* );
143 static void DelOut( sout_stream_t
*, void * );
144 static int SendOut( sout_stream_t
*, void *, block_t
* );
146 static void *AddIn( sout_stream_t
*, const es_format_t
* );
147 static void DelIn( sout_stream_t
*, void * );
148 static int SendIn( sout_stream_t
*, void *, block_t
* );
150 typedef struct sout_stream_id_sys_t sout_stream_id_sys_t
;
152 typedef struct bridged_es_t
160 sout_stream_id_sys_t
*id
;
165 typedef struct bridge_t
167 bridged_es_t
**pp_es
;
171 static vlc_mutex_t lock
= VLC_STATIC_MUTEX
;
177 typedef struct out_sout_stream_sys_t
184 } out_sout_stream_sys_t
;
186 /*****************************************************************************
188 *****************************************************************************/
189 static int OpenOut( vlc_object_t
*p_this
)
191 sout_stream_t
*p_stream
= (sout_stream_t
*)p_this
;
192 out_sout_stream_sys_t
*p_sys
;
195 config_ChainParse( p_stream
, SOUT_CFG_PREFIX_OUT
, ppsz_sout_options_out
,
198 p_sys
= malloc( sizeof( out_sout_stream_sys_t
) );
199 if( unlikely( !p_sys
) )
201 p_sys
->b_inited
= false;
203 var_Get( p_stream
, SOUT_CFG_PREFIX_OUT
"id", &val
);
204 p_sys
->i_id
= val
.i_int
;
206 var_Get( p_stream
, SOUT_CFG_PREFIX_OUT
"in-name", &val
);
207 if( asprintf( &p_sys
->psz_name
, "bridge-struct-%s", val
.psz_string
)<0 )
209 free( val
.psz_string
);
213 free( val
.psz_string
);
215 p_stream
->pf_add
= AddOut
;
216 p_stream
->pf_del
= DelOut
;
217 p_stream
->pf_send
= SendOut
;
219 p_stream
->p_sys
= p_sys
;
220 p_stream
->pace_nocontrol
= true;
225 /*****************************************************************************
227 *****************************************************************************/
228 static void CloseOut( vlc_object_t
* p_this
)
230 sout_stream_t
*p_stream
= (sout_stream_t
*)p_this
;
231 out_sout_stream_sys_t
*p_sys
= (out_sout_stream_sys_t
*)p_stream
->p_sys
;
233 free( p_sys
->psz_name
);
237 static void *AddOut( sout_stream_t
*p_stream
, const es_format_t
*p_fmt
)
239 vlc_object_t
*vlc
= VLC_OBJECT(vlc_object_instance(p_stream
));
240 out_sout_stream_sys_t
*p_sys
= (out_sout_stream_sys_t
*)p_stream
->p_sys
;
245 if ( p_sys
->b_inited
)
247 msg_Err( p_stream
, "bridge-out can only handle 1 es at a time." );
250 p_sys
->b_inited
= true;
252 vlc_mutex_lock( &lock
);
254 p_bridge
= var_GetAddress( vlc
, p_sys
->psz_name
);
255 if ( p_bridge
== NULL
)
257 p_bridge
= xmalloc( sizeof( bridge_t
) );
259 var_Create( vlc
, p_sys
->psz_name
, VLC_VAR_ADDRESS
);
260 var_SetAddress( vlc
, p_sys
->psz_name
, p_bridge
);
262 p_bridge
->i_es_num
= 0;
263 p_bridge
->pp_es
= NULL
;
266 for ( i
= 0; i
< p_bridge
->i_es_num
; i
++ )
268 if ( p_bridge
->pp_es
[i
]->b_empty
&& !p_bridge
->pp_es
[i
]->b_changed
)
272 if ( i
== p_bridge
->i_es_num
)
274 p_bridge
->pp_es
= xrealloc( p_bridge
->pp_es
,
275 (p_bridge
->i_es_num
+ 1) * sizeof(bridged_es_t
*) );
276 p_bridge
->i_es_num
++;
277 p_bridge
->pp_es
[i
] = xmalloc( sizeof(bridged_es_t
) );
280 p_sys
->p_es
= p_es
= p_bridge
->pp_es
[i
];
283 p_es
->fmt
.i_id
= p_sys
->i_id
;
284 p_es
->p_block
= NULL
;
285 p_es
->pp_last
= &p_es
->p_block
;
286 p_es
->b_empty
= false;
289 p_es
->i_last
= VLC_TICK_INVALID
;
290 p_es
->b_changed
= true;
292 msg_Dbg( p_stream
, "bridging out input codec=%4.4s id=%d pos=%d",
293 (char*)&p_es
->fmt
.i_codec
, p_es
->fmt
.i_id
, i
);
295 vlc_mutex_unlock( &lock
);
300 static void DelOut( sout_stream_t
*p_stream
, void *id
)
303 out_sout_stream_sys_t
*p_sys
= (out_sout_stream_sys_t
*)p_stream
->p_sys
;
306 if ( !p_sys
->b_inited
)
309 vlc_mutex_lock( &lock
);
313 p_es
->b_empty
= true;
314 block_ChainRelease( p_es
->p_block
);
315 p_es
->p_block
= NULL
;
317 p_es
->b_changed
= true;
318 vlc_mutex_unlock( &lock
);
320 p_sys
->b_inited
= false;
323 static int SendOut( sout_stream_t
*p_stream
, void *id
, block_t
*p_buffer
)
325 out_sout_stream_sys_t
*p_sys
= (out_sout_stream_sys_t
*)p_stream
->p_sys
;
328 if ( (out_sout_stream_sys_t
*)id
!= p_sys
)
330 block_ChainRelease( p_buffer
);
334 vlc_mutex_lock( &lock
);
337 *p_es
->pp_last
= p_buffer
;
338 while ( p_buffer
!= NULL
)
340 p_es
->pp_last
= &p_buffer
->p_next
;
341 p_buffer
= p_buffer
->p_next
;
344 vlc_mutex_unlock( &lock
);
354 typedef struct in_sout_stream_sys_t
362 bool b_switch_on_iframe
;
364 vlc_tick_t i_placeholder_delay
;
365 sout_stream_id_sys_t
*id_video
;
366 vlc_tick_t i_last_video
;
367 sout_stream_id_sys_t
*id_audio
;
368 vlc_tick_t i_last_audio
;
369 } in_sout_stream_sys_t
;
371 enum { placeholder_on
, placeholder_off
};
373 /*****************************************************************************
375 *****************************************************************************/
376 static int OpenIn( vlc_object_t
*p_this
)
378 sout_stream_t
*p_stream
= (sout_stream_t
*)p_this
;
379 in_sout_stream_sys_t
*p_sys
;
382 p_sys
= malloc( sizeof( in_sout_stream_sys_t
) );
383 if( unlikely( !p_sys
) )
386 config_ChainParse( p_stream
, SOUT_CFG_PREFIX_IN
, ppsz_sout_options_in
,
389 var_Get( p_stream
, SOUT_CFG_PREFIX_IN
"id-offset", &val
);
390 p_sys
->i_id_offset
= val
.i_int
;
392 var_Get( p_stream
, SOUT_CFG_PREFIX_IN
"delay", &val
);
393 p_sys
->i_delay
= VLC_TICK_FROM_MS(val
.i_int
);
395 var_Get( p_stream
, SOUT_CFG_PREFIX_IN
"name", &val
);
396 if( asprintf( &p_sys
->psz_name
, "bridge-struct-%s", val
.psz_string
)<0 )
398 free( val
.psz_string
);
402 free( val
.psz_string
);
404 var_Get( p_stream
, SOUT_CFG_PREFIX_IN
"placeholder", &val
);
405 p_sys
->b_placeholder
= val
.b_bool
;
407 var_Get( p_stream
, SOUT_CFG_PREFIX_IN
"placeholder-switch-on-iframe", &val
);
408 p_sys
->b_switch_on_iframe
= val
.b_bool
;
410 p_sys
->i_state
= placeholder_on
;
412 var_Get( p_stream
, SOUT_CFG_PREFIX_IN
"placeholder-delay", &val
);
413 p_sys
->i_placeholder_delay
= VLC_TICK_FROM_MS(val
.i_int
);
415 p_sys
->i_last_video
= VLC_TICK_INVALID
;
416 p_sys
->i_last_audio
= VLC_TICK_INVALID
;
417 p_sys
->id_video
= NULL
;
418 p_sys
->id_audio
= NULL
;
420 p_stream
->pf_add
= AddIn
;
421 p_stream
->pf_del
= DelIn
;
422 p_stream
->pf_send
= SendIn
;
424 p_stream
->p_sys
= p_sys
;
425 p_stream
->pace_nocontrol
= true;
430 /*****************************************************************************
432 *****************************************************************************/
433 static void CloseIn( vlc_object_t
* p_this
)
435 sout_stream_t
*p_stream
= (sout_stream_t
*)p_this
;
436 in_sout_stream_sys_t
*p_sys
= (in_sout_stream_sys_t
*)p_stream
->p_sys
;
438 free( p_sys
->psz_name
);
442 struct sout_stream_id_sys_t
444 sout_stream_id_sys_t
*id
;
445 enum es_format_category_e i_cat
; /* es category. Used for placeholder option */
448 static void* AddIn( sout_stream_t
*p_stream
, const es_format_t
*p_fmt
)
450 in_sout_stream_sys_t
*p_sys
= (in_sout_stream_sys_t
*)p_stream
->p_sys
;
452 sout_stream_id_sys_t
*id
= malloc( sizeof( sout_stream_id_sys_t
) );
453 if( !id
) return NULL
;
455 id
->id
= sout_StreamIdAdd( p_stream
->p_next
, p_fmt
);
462 if( p_sys
->b_placeholder
)
464 id
->i_cat
= p_fmt
->i_cat
;
465 switch( p_fmt
->i_cat
)
468 if( p_sys
->id_video
!= NULL
)
469 msg_Err( p_stream
, "We already had a video es!" );
470 p_sys
->id_video
= id
->id
;
473 if( p_sys
->id_audio
!= NULL
)
474 msg_Err( p_stream
, "We already had an audio es!" );
475 p_sys
->id_audio
= id
->id
;
485 static void DelIn( sout_stream_t
*p_stream
, void *_id
)
487 in_sout_stream_sys_t
*p_sys
= (in_sout_stream_sys_t
*)p_stream
->p_sys
;
488 sout_stream_id_sys_t
*id
= (sout_stream_id_sys_t
*)_id
;
490 if( id
== p_sys
->id_video
) p_sys
->id_video
= NULL
;
491 if( id
== p_sys
->id_audio
) p_sys
->id_audio
= NULL
;
493 sout_StreamIdDel( p_stream
->p_next
, id
->id
);
497 static int SendIn( sout_stream_t
*p_stream
, void *_id
, block_t
*p_buffer
)
499 vlc_object_t
*vlc
= VLC_OBJECT(vlc_object_instance(p_stream
));
500 in_sout_stream_sys_t
*p_sys
= (in_sout_stream_sys_t
*)p_stream
->p_sys
;
501 sout_stream_id_sys_t
*id
= (sout_stream_id_sys_t
*)_id
;
505 vlc_tick_t i_date
= vlc_tick_now();
507 /* First forward the packet for our own ES */
508 if( !p_sys
->b_placeholder
)
509 sout_StreamIdSend( p_stream
->p_next
, id
->id
, p_buffer
);
511 /* Then check all bridged streams */
512 vlc_mutex_lock( &lock
);
514 p_bridge
= var_GetAddress( vlc
, p_sys
->psz_name
);
518 for ( i
= 0; i
< p_bridge
->i_es_num
; i
++ )
520 if ( !p_bridge
->pp_es
[i
]->b_empty
)
523 while ( p_bridge
->pp_es
[i
]->p_block
!= NULL
524 && (p_bridge
->pp_es
[i
]->p_block
->i_dts
+ p_sys
->i_delay
526 || p_bridge
->pp_es
[i
]->p_block
->i_dts
+ p_sys
->i_delay
527 < p_bridge
->pp_es
[i
]->i_last
) )
529 block_t
*p_block
= p_bridge
->pp_es
[i
]->p_block
;
530 msg_Dbg( p_stream
, "dropping a packet (%"PRId64
")",
531 i_date
- p_block
->i_dts
- p_sys
->i_delay
);
532 p_bridge
->pp_es
[i
]->p_block
533 = p_bridge
->pp_es
[i
]->p_block
->p_next
;
534 block_Release( p_block
);
537 if ( p_bridge
->pp_es
[i
]->p_block
== NULL
)
539 p_bridge
->pp_es
[i
]->pp_last
= &p_bridge
->pp_es
[i
]->p_block
;
542 if ( p_bridge
->pp_es
[i
]->b_changed
)
544 if ( p_bridge
->pp_es
[i
]->b_empty
&& p_bridge
->pp_es
[i
]->id
!= NULL
)
546 sout_StreamIdDel( p_stream
->p_next
, p_bridge
->pp_es
[i
]->id
);
550 /* We need at least two packets to enter the mux. */
551 if ( p_bridge
->pp_es
[i
]->p_block
== NULL
552 || p_bridge
->pp_es
[i
]->p_block
->p_next
== NULL
)
557 p_bridge
->pp_es
[i
]->fmt
.i_id
+= p_sys
->i_id_offset
;
558 if( !p_sys
->b_placeholder
)
560 p_bridge
->pp_es
[i
]->id
= sout_StreamIdAdd(
561 p_stream
->p_next
, &p_bridge
->pp_es
[i
]->fmt
);
562 if ( p_bridge
->pp_es
[i
]->id
== NULL
)
564 msg_Warn( p_stream
, "couldn't create chain for id %d",
565 p_bridge
->pp_es
[i
]->fmt
.i_id
);
568 msg_Dbg( p_stream
, "bridging in input codec=%4.4s id=%d pos=%d",
569 (char*)&p_bridge
->pp_es
[i
]->fmt
.i_codec
,
570 p_bridge
->pp_es
[i
]->fmt
.i_id
, i
);
573 p_bridge
->pp_es
[i
]->b_changed
= false;
575 if ( p_bridge
->pp_es
[i
]->b_empty
)
578 if ( p_bridge
->pp_es
[i
]->p_block
== NULL
)
580 if ( p_bridge
->pp_es
[i
]->id
!= NULL
581 && p_bridge
->pp_es
[i
]->i_last
< i_date
)
583 if( !p_sys
->b_placeholder
)
584 sout_StreamIdDel( p_stream
->p_next
, p_bridge
->pp_es
[i
]->id
);
585 p_bridge
->pp_es
[i
]->fmt
.i_id
-= p_sys
->i_id_offset
;
586 p_bridge
->pp_es
[i
]->b_changed
= true;
587 p_bridge
->pp_es
[i
]->id
= NULL
;
592 if ( p_bridge
->pp_es
[i
]->id
!= NULL
|| p_sys
->b_placeholder
)
594 block_t
*p_block
= p_bridge
->pp_es
[i
]->p_block
;
595 while ( p_block
!= NULL
)
597 p_bridge
->pp_es
[i
]->i_last
= p_block
->i_dts
;
598 p_block
->i_pts
+= p_sys
->i_delay
;
599 p_block
->i_dts
+= p_sys
->i_delay
;
600 p_block
= p_block
->p_next
;
602 sout_stream_id_sys_t
*newid
= NULL
;
603 if( p_sys
->b_placeholder
)
605 switch( p_bridge
->pp_es
[i
]->fmt
.i_cat
)
608 p_sys
->i_last_video
= i_date
;
609 newid
= p_sys
->id_video
;
612 if( !p_sys
->b_switch_on_iframe
||
613 p_sys
->i_state
== placeholder_off
||
614 ( p_bridge
->pp_es
[i
]->fmt
.i_cat
== VIDEO_ES
&&
615 p_bridge
->pp_es
[i
]->p_block
->i_flags
& BLOCK_FLAG_TYPE_I
) )
617 sout_StreamIdSend( p_stream
->p_next
,
619 p_bridge
->pp_es
[i
]->p_block
);
620 p_sys
->i_state
= placeholder_off
;
624 newid
= p_sys
->id_audio
;
627 p_sys
->i_last_audio
= i_date
;
630 sout_StreamIdSend( p_stream
->p_next
,
631 newid
?newid
:p_bridge
->pp_es
[i
]->id
,
632 p_bridge
->pp_es
[i
]->p_block
);
636 else /* !b_placeholder */
637 sout_StreamIdSend( p_stream
->p_next
,
638 p_bridge
->pp_es
[i
]->id
,
639 p_bridge
->pp_es
[i
]->p_block
);
643 block_ChainRelease( p_bridge
->pp_es
[i
]->p_block
);
646 p_bridge
->pp_es
[i
]->p_block
= NULL
;
647 p_bridge
->pp_es
[i
]->pp_last
= &p_bridge
->pp_es
[i
]->p_block
;
652 for ( i
= 0; i
< p_bridge
->i_es_num
; i
++ )
653 free( p_bridge
->pp_es
[i
] );
654 free( p_bridge
->pp_es
);
656 var_Destroy( vlc
, p_sys
->psz_name
);
660 if( p_sys
->b_placeholder
)
665 if( ( p_sys
->i_last_video
+ p_sys
->i_placeholder_delay
< i_date
666 && ( !p_sys
->b_switch_on_iframe
667 || p_buffer
->i_flags
& BLOCK_FLAG_TYPE_I
) )
668 || p_sys
->i_state
== placeholder_on
)
670 sout_StreamIdSend( p_stream
->p_next
, id
->id
, p_buffer
);
671 p_sys
->i_state
= placeholder_on
;
674 block_Release( p_buffer
);
678 if( p_sys
->i_last_audio
+ p_sys
->i_placeholder_delay
< i_date
)
679 sout_StreamIdSend( p_stream
->p_next
, id
->id
, p_buffer
);
681 block_Release( p_buffer
);
685 block_Release( p_buffer
); /* FIXME: placeholder subs anyone? */
690 vlc_mutex_unlock( &lock
);