1 /*****************************************************************************
3 *****************************************************************************
4 * Copyright (C) 2008 Laurent Aimar
7 * Authors: Laurent Aimar < fenrir _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 *****************************************************************************/
33 #include <vlc_common.h>
34 #include <vlc_atomic.h>
39 #include "../libvlc.h"
40 #include "../stream_output/stream_output.h"
41 #include "../audio_output/aout_internal.h"
42 #include "../video_output/vout_control.h"
43 #include "input_interface.h"
46 struct input_resource_t
50 vlc_object_t
*p_parent
;
52 /* This lock is used to serialize request and protect
57 input_thread_t
*p_input
;
59 sout_instance_t
*p_sout
;
60 vout_thread_t
*p_vout_free
;
62 /* This lock is used to protect vout resources access (for hold)
63 * It is a special case because of embed video (possible deadlock
64 * between vout window request and vout holds in some(qt4) interface)
66 vlc_mutex_t lock_hold
;
68 /* You need lock+lock_hold to write to the following variables and
69 * only lock or lock_hold to read them */
71 vout_thread_t
**pp_vout
;
75 audio_output_t
*p_aout
;
79 static void DestroySout( input_resource_t
*p_resource
)
82 if( p_resource
->p_sout
)
83 sout_DeleteInstance( p_resource
->p_sout
);
85 p_resource
->p_sout
= NULL
;
88 static sout_instance_t
*RequestSout( input_resource_t
*p_resource
,
89 sout_instance_t
*p_sout
, const char *psz_sout
)
92 if( !p_sout
&& !psz_sout
)
94 if( p_resource
->p_sout
)
95 msg_Dbg( p_resource
->p_sout
, "destroying useless sout" );
96 DestroySout( p_resource
);
100 assert( !p_sout
|| ( !p_resource
->p_sout
&& !psz_sout
) );
102 /* Check the validity of the sout */
103 if( p_resource
->p_sout
&&
104 strcmp( p_resource
->p_sout
->psz_sout
, psz_sout
) )
106 msg_Dbg( p_resource
->p_parent
, "destroying unusable sout" );
107 DestroySout( p_resource
);
112 if( p_resource
->p_sout
)
115 msg_Dbg( p_resource
->p_parent
, "reusing sout" );
116 msg_Dbg( p_resource
->p_parent
, "you probably want to use gather stream_out" );
120 /* Create a new one */
121 p_resource
->p_sout
= sout_NewInstance( p_resource
->p_parent
, psz_sout
);
124 p_sout
= p_resource
->p_sout
;
125 p_resource
->p_sout
= NULL
;
131 p_resource
->p_sout
= p_sout
;
135 VLC_UNUSED (p_resource
); VLC_UNUSED (p_sout
); VLC_UNUSED (psz_sout
);
141 static void DestroyVout( input_resource_t
*p_resource
)
143 assert( p_resource
->i_vout
== 0 );
145 if( p_resource
->p_vout_free
)
146 vout_CloseAndRelease( p_resource
->p_vout_free
);
148 p_resource
->p_vout_free
= NULL
;
151 static void DisplayVoutTitle( input_resource_t
*p_resource
,
152 vout_thread_t
*p_vout
)
154 if( p_resource
->p_input
== NULL
)
157 /* TODO display the title only one time for the same input ? */
159 input_item_t
*p_item
= input_GetItem( p_resource
->p_input
);
161 char *psz_nowplaying
= input_item_GetNowPlaying( p_item
);
162 if( psz_nowplaying
&& *psz_nowplaying
)
164 vout_DisplayTitle( p_vout
, psz_nowplaying
);
168 char *psz_artist
= input_item_GetArtist( p_item
);
169 char *psz_name
= input_item_GetTitle( p_item
);
171 if( !psz_name
|| *psz_name
== '\0' )
174 psz_name
= input_item_GetName( p_item
);
176 if( psz_artist
&& *psz_artist
)
179 if( asprintf( &psz_string
, "%s - %s", psz_name
, psz_artist
) != -1 )
181 vout_DisplayTitle( p_vout
, psz_string
);
187 vout_DisplayTitle( p_vout
, psz_name
);
192 free( psz_nowplaying
);
194 static vout_thread_t
*RequestVout( input_resource_t
*p_resource
,
195 vout_thread_t
*p_vout
,
196 video_format_t
*p_fmt
, unsigned dpb_size
,
199 vlc_assert_locked( &p_resource
->lock
);
201 if( !p_vout
&& !p_fmt
)
203 if( p_resource
->p_vout_free
)
205 msg_Dbg( p_resource
->p_vout_free
, "destroying useless vout" );
206 vout_CloseAndRelease( p_resource
->p_vout_free
);
207 p_resource
->p_vout_free
= NULL
;
215 if( !p_vout
&& p_resource
->p_vout_free
)
217 msg_Dbg( p_resource
->p_parent
, "trying to reuse free vout" );
218 p_vout
= p_resource
->p_vout_free
;
220 p_resource
->p_vout_free
= NULL
;
224 assert( p_vout
!= p_resource
->p_vout_free
);
226 vlc_mutex_lock( &p_resource
->lock_hold
);
227 TAB_REMOVE( p_resource
->i_vout
, p_resource
->pp_vout
, p_vout
);
228 vlc_mutex_unlock( &p_resource
->lock_hold
);
232 vout_configuration_t cfg
= {
234 .input
= VLC_OBJECT(p_resource
->p_input
),
237 .dpb_size
= dpb_size
,
239 p_vout
= vout_Request( p_resource
->p_parent
, &cfg
);
243 DisplayVoutTitle( p_resource
, p_vout
);
245 vlc_mutex_lock( &p_resource
->lock_hold
);
246 TAB_APPEND( p_resource
->i_vout
, p_resource
->pp_vout
, p_vout
);
247 vlc_mutex_unlock( &p_resource
->lock_hold
);
255 vlc_mutex_lock( &p_resource
->lock_hold
);
256 TAB_REMOVE( p_resource
->i_vout
, p_resource
->pp_vout
, p_vout
);
257 const int i_vout_active
= p_resource
->i_vout
;
258 vlc_mutex_unlock( &p_resource
->lock_hold
);
260 if( p_resource
->p_vout_free
|| i_vout_active
> 0 || !b_recycle
)
263 msg_Dbg( p_resource
->p_parent
, "destroying vout (already one saved or active)" );
264 vout_CloseAndRelease( p_vout
);
268 msg_Dbg( p_resource
->p_parent
, "saving a free vout" );
269 vout_Flush( p_vout
, 1 );
270 vout_FlushSubpictureChannel( p_vout
, -1 );
272 vout_configuration_t cfg
= {
279 p_resource
->p_vout_free
= vout_Request( p_resource
->p_parent
, &cfg
);
284 static vout_thread_t
*HoldVout( input_resource_t
*p_resource
)
286 /* TODO FIXME: p_resource->pp_vout order is NOT stable */
287 vlc_mutex_lock( &p_resource
->lock_hold
);
289 vout_thread_t
*p_vout
= p_resource
->i_vout
> 0 ? p_resource
->pp_vout
[0] : NULL
;
291 vlc_object_hold( p_vout
);
293 vlc_mutex_unlock( &p_resource
->lock_hold
);
298 static void HoldVouts( input_resource_t
*p_resource
, vout_thread_t
***ppp_vout
,
301 vout_thread_t
**pp_vout
;
306 vlc_mutex_lock( &p_resource
->lock_hold
);
308 if( p_resource
->i_vout
<= 0 )
311 pp_vout
= malloc( p_resource
->i_vout
* sizeof(*pp_vout
) );
316 *pi_vout
= p_resource
->i_vout
;
318 for( int i
= 0; i
< p_resource
->i_vout
; i
++ )
320 pp_vout
[i
] = p_resource
->pp_vout
[i
];
321 vlc_object_hold( pp_vout
[i
] );
325 vlc_mutex_unlock( &p_resource
->lock_hold
);
329 audio_output_t
*input_resource_GetAout( input_resource_t
*p_resource
)
331 audio_output_t
*p_aout
;
333 vlc_mutex_lock( &p_resource
->lock_hold
);
334 p_aout
= p_resource
->p_aout
;
336 if( p_aout
== NULL
|| p_resource
->b_aout_busy
)
338 msg_Dbg( p_resource
->p_parent
, "creating audio output" );
339 vlc_mutex_unlock( &p_resource
->lock_hold
);
341 p_aout
= aout_New( p_resource
->p_parent
);
343 return NULL
; /* failed */
345 vlc_mutex_lock( &p_resource
->lock_hold
);
346 if( p_resource
->p_aout
== NULL
)
347 p_resource
->p_aout
= p_aout
;
350 msg_Dbg( p_resource
->p_parent
, "reusing audio output" );
352 if( p_resource
->p_aout
== p_aout
)
354 assert( !p_resource
->b_aout_busy
);
355 p_resource
->b_aout_busy
= true;
357 vlc_mutex_unlock( &p_resource
->lock_hold
);
361 void input_resource_PutAout( input_resource_t
*p_resource
,
362 audio_output_t
*p_aout
)
364 assert( p_aout
!= NULL
);
366 vlc_mutex_lock( &p_resource
->lock_hold
);
367 if( p_aout
== p_resource
->p_aout
)
369 assert( p_resource
->b_aout_busy
);
370 p_resource
->b_aout_busy
= false;
371 msg_Dbg( p_resource
->p_parent
, "keeping audio output" );
375 msg_Dbg( p_resource
->p_parent
, "destroying extra audio output" );
376 vlc_mutex_unlock( &p_resource
->lock_hold
);
379 aout_Destroy( p_aout
);
382 audio_output_t
*input_resource_HoldAout( input_resource_t
*p_resource
)
384 audio_output_t
*p_aout
;
386 vlc_mutex_lock( &p_resource
->lock_hold
);
387 p_aout
= p_resource
->p_aout
;
389 vlc_object_hold( p_aout
);
390 vlc_mutex_unlock( &p_resource
->lock_hold
);
395 void input_resource_ResetAout( input_resource_t
*p_resource
)
397 audio_output_t
*p_aout
= NULL
;
399 vlc_mutex_lock( &p_resource
->lock_hold
);
400 if( !p_resource
->b_aout_busy
)
401 p_aout
= p_resource
->p_aout
;
403 p_resource
->p_aout
= NULL
;
404 p_resource
->b_aout_busy
= false;
405 vlc_mutex_unlock( &p_resource
->lock_hold
);
408 aout_Destroy( p_aout
);
412 input_resource_t
*input_resource_New( vlc_object_t
*p_parent
)
414 input_resource_t
*p_resource
= calloc( 1, sizeof(*p_resource
) );
418 atomic_init( &p_resource
->refs
, 1 );
419 p_resource
->p_parent
= p_parent
;
420 vlc_mutex_init( &p_resource
->lock
);
421 vlc_mutex_init( &p_resource
->lock_hold
);
425 void input_resource_Release( input_resource_t
*p_resource
)
427 if( atomic_fetch_sub( &p_resource
->refs
, 1 ) != 1 )
430 DestroySout( p_resource
);
431 DestroyVout( p_resource
);
432 if( p_resource
->p_aout
!= NULL
)
433 aout_Destroy( p_resource
->p_aout
);
435 vlc_mutex_destroy( &p_resource
->lock_hold
);
436 vlc_mutex_destroy( &p_resource
->lock
);
440 input_resource_t
*input_resource_Hold( input_resource_t
*p_resource
)
442 atomic_fetch_add( &p_resource
->refs
, 1 );
446 void input_resource_SetInput( input_resource_t
*p_resource
, input_thread_t
*p_input
)
448 vlc_mutex_lock( &p_resource
->lock
);
450 if( p_resource
->p_input
&& !p_input
)
451 assert( p_resource
->i_vout
== 0 );
454 p_resource
->p_input
= p_input
;
456 vlc_mutex_unlock( &p_resource
->lock
);
459 vout_thread_t
*input_resource_RequestVout( input_resource_t
*p_resource
,
460 vout_thread_t
*p_vout
,
461 video_format_t
*p_fmt
, unsigned dpb_size
,
464 vlc_mutex_lock( &p_resource
->lock
);
465 vout_thread_t
*p_ret
= RequestVout( p_resource
, p_vout
, p_fmt
, dpb_size
, b_recycle
);
466 vlc_mutex_unlock( &p_resource
->lock
);
470 vout_thread_t
*input_resource_HoldVout( input_resource_t
*p_resource
)
472 return HoldVout( p_resource
);
475 void input_resource_HoldVouts( input_resource_t
*p_resource
, vout_thread_t
***ppp_vout
,
478 HoldVouts( p_resource
, ppp_vout
, pi_vout
);
481 void input_resource_TerminateVout( input_resource_t
*p_resource
)
483 input_resource_RequestVout( p_resource
, NULL
, NULL
, 0, false );
485 bool input_resource_HasVout( input_resource_t
*p_resource
)
487 vlc_mutex_lock( &p_resource
->lock
);
488 assert( !p_resource
->p_input
);
489 const bool b_vout
= p_resource
->p_vout_free
!= NULL
;
490 vlc_mutex_unlock( &p_resource
->lock
);
496 sout_instance_t
*input_resource_RequestSout( input_resource_t
*p_resource
, sout_instance_t
*p_sout
, const char *psz_sout
)
498 vlc_mutex_lock( &p_resource
->lock
);
499 sout_instance_t
*p_ret
= RequestSout( p_resource
, p_sout
, psz_sout
);
500 vlc_mutex_unlock( &p_resource
->lock
);
504 void input_resource_TerminateSout( input_resource_t
*p_resource
)
506 input_resource_RequestSout( p_resource
, NULL
, NULL
);
509 void input_resource_Terminate( input_resource_t
*p_resource
)
511 input_resource_TerminateSout( p_resource
);
512 input_resource_ResetAout( p_resource
);
513 input_resource_TerminateVout( p_resource
);