| 1 |
|
|---|
| 2 |
|
|---|
| 3 |
|
|---|
| 4 |
|
|---|
| 5 |
|
|---|
| 6 |
|
|---|
| 7 |
|
|---|
| 8 |
|
|---|
| 9 |
|
|---|
| 10 |
|
|---|
| 11 |
|
|---|
| 12 |
|
|---|
| 13 |
|
|---|
| 14 |
|
|---|
| 15 |
|
|---|
| 16 |
|
|---|
| 17 |
|
|---|
| 18 |
|
|---|
| 19 |
|
|---|
| 20 |
|
|---|
| 21 |
|
|---|
| 22 |
|
|---|
| 23 |
|
|---|
| 24 |
#ifdef HAVE_CONFIG_H |
|---|
| 25 |
# include "config.h" |
|---|
| 26 |
#endif |
|---|
| 27 |
|
|---|
| 28 |
#include <assert.h> |
|---|
| 29 |
#include <vlc_common.h> |
|---|
| 30 |
#include <vlc_sout.h> |
|---|
| 31 |
#include <vlc_playlist.h> |
|---|
| 32 |
#include <vlc_interface.h> |
|---|
| 33 |
#include "playlist_internal.h" |
|---|
| 34 |
#include "stream_output/stream_output.h" |
|---|
| 35 |
|
|---|
| 36 |
|
|---|
| 37 |
|
|---|
| 38 |
|
|---|
| 39 |
static void VariablesInit( playlist_t *p_playlist ); |
|---|
| 40 |
static void playlist_Destructor( vlc_object_t * p_this ); |
|---|
| 41 |
|
|---|
| 42 |
static int RandomCallback( vlc_object_t *p_this, char const *psz_cmd, |
|---|
| 43 |
vlc_value_t oldval, vlc_value_t newval, void *a ) |
|---|
| 44 |
{ |
|---|
| 45 |
(void)psz_cmd; (void)oldval; (void)newval; (void)a; |
|---|
| 46 |
|
|---|
| 47 |
((playlist_t*)p_this)->b_reset_currently_playing = true; |
|---|
| 48 |
playlist_Signal( ((playlist_t*)p_this) ); |
|---|
| 49 |
return VLC_SUCCESS; |
|---|
| 50 |
} |
|---|
| 51 |
|
|---|
| 52 |
|
|---|
| 53 |
|
|---|
| 54 |
|
|---|
| 55 |
|
|---|
| 56 |
|
|---|
| 57 |
|
|---|
| 58 |
|
|---|
| 59 |
playlist_t * playlist_Create( vlc_object_t *p_parent ) |
|---|
| 60 |
{ |
|---|
| 61 |
static const char playlist_name[] = "playlist"; |
|---|
| 62 |
playlist_t *p_playlist; |
|---|
| 63 |
bool b_save; |
|---|
| 64 |
|
|---|
| 65 |
|
|---|
| 66 |
p_playlist = vlc_custom_create( p_parent, sizeof( *p_playlist ), |
|---|
| 67 |
VLC_OBJECT_GENERIC, playlist_name ); |
|---|
| 68 |
if( !p_playlist ) |
|---|
| 69 |
return NULL; |
|---|
| 70 |
|
|---|
| 71 |
TAB_INIT( p_playlist->i_sds, p_playlist->pp_sds ); |
|---|
| 72 |
MALLOC_NULL( p_playlist->p, playlist_private_t ); |
|---|
| 73 |
memset( p_playlist->p, 0, sizeof( playlist_private_t ) ); |
|---|
| 74 |
|
|---|
| 75 |
libvlc_priv(p_parent->p_libvlc)->p_playlist = p_playlist; |
|---|
| 76 |
|
|---|
| 77 |
VariablesInit( p_playlist ); |
|---|
| 78 |
|
|---|
| 79 |
|
|---|
| 80 |
p_playlist->i_last_playlist_id = 0; |
|---|
| 81 |
p_playlist->p_input = NULL; |
|---|
| 82 |
|
|---|
| 83 |
p_playlist->gc_date = 0; |
|---|
| 84 |
p_playlist->b_cant_sleep = false; |
|---|
| 85 |
|
|---|
| 86 |
ARRAY_INIT( p_playlist->items ); |
|---|
| 87 |
ARRAY_INIT( p_playlist->all_items ); |
|---|
| 88 |
ARRAY_INIT( p_playlist->items_to_delete ); |
|---|
| 89 |
ARRAY_INIT( p_playlist->current ); |
|---|
| 90 |
|
|---|
| 91 |
p_playlist->i_current_index = 0; |
|---|
| 92 |
p_playlist->b_reset_currently_playing = true; |
|---|
| 93 |
p_playlist->last_rebuild_date = 0; |
|---|
| 94 |
|
|---|
| 95 |
p_playlist->b_tree = var_CreateGetBool( p_playlist, "playlist-tree" ); |
|---|
| 96 |
|
|---|
| 97 |
p_playlist->b_doing_ml = false; |
|---|
| 98 |
|
|---|
| 99 |
p_playlist->b_auto_preparse = |
|---|
| 100 |
var_CreateGetBool( p_playlist, "auto-preparse" ) ; |
|---|
| 101 |
|
|---|
| 102 |
PL_LOCK; |
|---|
| 103 |
p_playlist->p_root_category = playlist_NodeCreate( p_playlist, NULL, NULL, |
|---|
| 104 |
0, NULL ); |
|---|
| 105 |
p_playlist->p_root_onelevel = playlist_NodeCreate( p_playlist, NULL, NULL, |
|---|
| 106 |
0, p_playlist->p_root_category->p_input ); |
|---|
| 107 |
PL_UNLOCK; |
|---|
| 108 |
|
|---|
| 109 |
if( !p_playlist->p_root_category || !p_playlist->p_root_onelevel ) |
|---|
| 110 |
return NULL; |
|---|
| 111 |
|
|---|
| 112 |
|
|---|
| 113 |
PL_LOCK; |
|---|
| 114 |
playlist_NodesPairCreate( p_playlist, _( "Playlist" ), |
|---|
| 115 |
&p_playlist->p_local_category, |
|---|
| 116 |
&p_playlist->p_local_onelevel, false ); |
|---|
| 117 |
PL_UNLOCK; |
|---|
| 118 |
|
|---|
| 119 |
p_playlist->p_local_category->i_flags |= PLAYLIST_RO_FLAG; |
|---|
| 120 |
p_playlist->p_local_onelevel->i_flags |= PLAYLIST_RO_FLAG; |
|---|
| 121 |
|
|---|
| 122 |
if( !p_playlist->p_local_category || !p_playlist->p_local_onelevel || |
|---|
| 123 |
!p_playlist->p_local_category->p_input || |
|---|
| 124 |
!p_playlist->p_local_onelevel->p_input ) |
|---|
| 125 |
return NULL; |
|---|
| 126 |
|
|---|
| 127 |
if( config_GetInt( p_playlist, "media-library") ) |
|---|
| 128 |
{ |
|---|
| 129 |
PL_LOCK; |
|---|
| 130 |
playlist_NodesPairCreate( p_playlist, _( "Media Library" ), |
|---|
| 131 |
&p_playlist->p_ml_category, |
|---|
| 132 |
&p_playlist->p_ml_onelevel, false ); |
|---|
| 133 |
PL_UNLOCK; |
|---|
| 134 |
|
|---|
| 135 |
if(!p_playlist->p_ml_category || !p_playlist->p_ml_onelevel) |
|---|
| 136 |
return NULL; |
|---|
| 137 |
|
|---|
| 138 |
p_playlist->p_ml_category->i_flags |= PLAYLIST_RO_FLAG; |
|---|
| 139 |
p_playlist->p_ml_onelevel->i_flags |= PLAYLIST_RO_FLAG; |
|---|
| 140 |
} |
|---|
| 141 |
else |
|---|
| 142 |
{ |
|---|
| 143 |
p_playlist->p_ml_category = p_playlist->p_ml_onelevel = NULL; |
|---|
| 144 |
} |
|---|
| 145 |
|
|---|
| 146 |
|
|---|
| 147 |
p_playlist->status.p_item = NULL; |
|---|
| 148 |
p_playlist->status.p_node = p_playlist->p_local_onelevel; |
|---|
| 149 |
p_playlist->request.b_request = false; |
|---|
| 150 |
p_playlist->status.i_status = PLAYLIST_STOPPED; |
|---|
| 151 |
|
|---|
| 152 |
p_playlist->i_sort = SORT_ID; |
|---|
| 153 |
p_playlist->i_order = ORDER_NORMAL; |
|---|
| 154 |
|
|---|
| 155 |
|
|---|
| 156 |
b_save = p_playlist->b_auto_preparse; |
|---|
| 157 |
p_playlist->b_auto_preparse = false; |
|---|
| 158 |
playlist_MLLoad( p_playlist ); |
|---|
| 159 |
p_playlist->b_auto_preparse = true; |
|---|
| 160 |
|
|---|
| 161 |
vlc_object_set_destructor( p_playlist, playlist_Destructor ); |
|---|
| 162 |
|
|---|
| 163 |
return p_playlist; |
|---|
| 164 |
} |
|---|
| 165 |
|
|---|
| 166 |
|
|---|
| 167 |
|
|---|
| 168 |
|
|---|
| 169 |
|
|---|
| 170 |
|
|---|
| 171 |
|
|---|
| 172 |
|
|---|
| 173 |
|
|---|
| 174 |
static void playlist_Destructor( vlc_object_t * p_this ) |
|---|
| 175 |
{ |
|---|
| 176 |
playlist_t * p_playlist = (playlist_t *)p_this; |
|---|
| 177 |
|
|---|
| 178 |
if( p_playlist->p->p_preparse ) |
|---|
| 179 |
{ |
|---|
| 180 |
vlc_object_release( p_playlist->p->p_preparse ); |
|---|
| 181 |
} |
|---|
| 182 |
|
|---|
| 183 |
if( p_playlist->p->p_fetcher ) |
|---|
| 184 |
{ |
|---|
| 185 |
vlc_object_release( p_playlist->p->p_fetcher ); |
|---|
| 186 |
} |
|---|
| 187 |
msg_Dbg( p_this, "Destroyed" ); |
|---|
| 188 |
} |
|---|
| 189 |
|
|---|
| 190 |
|
|---|
| 191 |
static void ObjectGarbageCollector( playlist_t *p_playlist, bool b_force ) |
|---|
| 192 |
{ |
|---|
| 193 |
if( !b_force ) |
|---|
| 194 |
{ |
|---|
| 195 |
if( mdate() - p_playlist->gc_date < 1000000 ) |
|---|
| 196 |
{ |
|---|
| 197 |
p_playlist->b_cant_sleep = true; |
|---|
| 198 |
return; |
|---|
| 199 |
} |
|---|
| 200 |
else if( p_playlist->gc_date == 0 ) |
|---|
| 201 |
return; |
|---|
| 202 |
} |
|---|
| 203 |
|
|---|
| 204 |
p_playlist->b_cant_sleep = false; |
|---|
| 205 |
} |
|---|
| 206 |
|
|---|
| 207 |
|
|---|
| 208 |
static void input_state_changed( const vlc_event_t * event, void * data ) |
|---|
| 209 |
{ |
|---|
| 210 |
(void)event; |
|---|
| 211 |
playlist_t * p_playlist = data; |
|---|
| 212 |
playlist_Signal( p_playlist ); |
|---|
| 213 |
} |
|---|
| 214 |
|
|---|
| 215 |
|
|---|
| 216 |
static void input_selected_stream_changed( const vlc_event_t * event, void * data ) |
|---|
| 217 |
{ |
|---|
| 218 |
(void)event; |
|---|
| 219 |
playlist_t * p_playlist = data; |
|---|
| 220 |
PL_LOCK; |
|---|
| 221 |
p_playlist->gc_date = mdate(); |
|---|
| 222 |
vlc_object_signal_unlocked( p_playlist ); |
|---|
| 223 |
PL_UNLOCK; |
|---|
| 224 |
} |
|---|
| 225 |
|
|---|
| 226 |
|
|---|
| 227 |
void playlist_release_current_input( playlist_t * p_playlist ) |
|---|
| 228 |
{ |
|---|
| 229 |
PL_ASSERT_LOCKED; |
|---|
| 230 |
|
|---|
| 231 |
if( !p_playlist->p_input ) return; |
|---|
| 232 |
|
|---|
| 233 |
input_thread_t * p_input = p_playlist->p_input; |
|---|
| 234 |
vlc_event_manager_t * p_em = input_get_event_manager( p_input ); |
|---|
| 235 |
|
|---|
| 236 |
vlc_event_detach( p_em, vlc_InputStateChanged, |
|---|
| 237 |
input_state_changed, p_playlist ); |
|---|
| 238 |
vlc_event_detach( p_em, vlc_InputSelectedStreamChanged, |
|---|
| 239 |
input_selected_stream_changed, p_playlist ); |
|---|
| 240 |
p_playlist->p_input = NULL; |
|---|
| 241 |
|
|---|
| 242 |
|
|---|
| 243 |
|
|---|
| 244 |
PL_UNLOCK; |
|---|
| 245 |
vlc_thread_join( p_input ); |
|---|
| 246 |
vlc_object_release( p_input ); |
|---|
| 247 |
PL_LOCK; |
|---|
| 248 |
} |
|---|
| 249 |
|
|---|
| 250 |
void playlist_set_current_input( |
|---|
| 251 |
playlist_t * p_playlist, input_thread_t * p_input ) |
|---|
| 252 |
{ |
|---|
| 253 |
PL_ASSERT_LOCKED; |
|---|
| 254 |
|
|---|
| 255 |
playlist_release_current_input( p_playlist ); |
|---|
| 256 |
|
|---|
| 257 |
if( p_input ) |
|---|
| 258 |
{ |
|---|
| 259 |
vlc_object_yield( p_input ); |
|---|
| 260 |
p_playlist->p_input = p_input; |
|---|
| 261 |
vlc_event_manager_t * p_em = input_get_event_manager( p_input ); |
|---|
| 262 |
vlc_event_attach( p_em, vlc_InputStateChanged, |
|---|
| 263 |
input_state_changed, p_playlist ); |
|---|
| 264 |
vlc_event_attach( p_em, vlc_InputSelectedStreamChanged, |
|---|
| 265 |
input_selected_stream_changed, p_playlist ); |
|---|
| 266 |
} |
|---|
| 267 |
} |
|---|
| 268 |
|
|---|
| 269 |
|
|---|
| 270 |
|
|---|
| 271 |
input_thread_t * playlist_CurrentInput( playlist_t * p_playlist ) |
|---|
| 272 |
{ |
|---|
| 273 |
input_thread_t * p_input; |
|---|
| 274 |
PL_LOCK; |
|---|
| 275 |
p_input = p_playlist->p_input; |
|---|
| 276 |
if( p_input ) vlc_object_yield( p_input ); |
|---|
| 277 |
PL_UNLOCK; |
|---|
| 278 |
return p_input; |
|---|
| 279 |
} |
|---|
| 280 |
|
|---|
| 281 |
|
|---|
| 282 |
|
|---|
| 283 |
|
|---|
| 284 |
|
|---|
| 285 |
|
|---|
| 286 |
|
|---|
| 287 |
playlist_item_t * get_current_status_item( playlist_t * p_playlist ) |
|---|
| 288 |
{ |
|---|
| 289 |
PL_ASSERT_LOCKED; |
|---|
| 290 |
|
|---|
| 291 |
return p_playlist->status.p_item; |
|---|
| 292 |
} |
|---|
| 293 |
|
|---|
| 294 |
playlist_item_t * get_current_status_node( playlist_t * p_playlist ) |
|---|
| 295 |
{ |
|---|
| 296 |
PL_ASSERT_LOCKED; |
|---|
| 297 |
|
|---|
| 298 |
return p_playlist->status.p_node; |
|---|
| 299 |
} |
|---|
| 300 |
|
|---|
| 301 |
void set_current_status_item( playlist_t * p_playlist, |
|---|
| 302 |
playlist_item_t * p_item ) |
|---|
| 303 |
{ |
|---|
| 304 |
PL_ASSERT_LOCKED; |
|---|
| 305 |
|
|---|
| 306 |
if( p_playlist->status.p_item && |
|---|
| 307 |
p_playlist->status.p_item->i_flags & PLAYLIST_REMOVE_FLAG && |
|---|
| 308 |
p_playlist->status.p_item != p_item ) |
|---|
| 309 |
{ |
|---|
| 310 |
|
|---|
| 311 |
|
|---|
| 312 |
} |
|---|
| 313 |
p_playlist->status.p_item = p_item; |
|---|
| 314 |
} |
|---|
| 315 |
|
|---|
| 316 |
void set_current_status_node( playlist_t * p_playlist, |
|---|
| 317 |
playlist_item_t * p_node ) |
|---|
| 318 |
{ |
|---|
| 319 |
PL_ASSERT_LOCKED; |
|---|
| 320 |
|
|---|
| 321 |
if( p_playlist->status.p_node && |
|---|
| 322 |
p_playlist->status.p_node->i_flags & PLAYLIST_REMOVE_FLAG && |
|---|
| 323 |
p_playlist->status.p_node != p_node ) |
|---|
| 324 |
{ |
|---|
| 325 |
|
|---|
| 326 |
|
|---|
| 327 |
} |
|---|
| 328 |
p_playlist->status.p_node = p_node; |
|---|
| 329 |
} |
|---|
| 330 |
|
|---|
| 331 |
|
|---|
| 332 |
|
|---|
| 333 |
|
|---|
| 334 |
|
|---|
| 335 |
|
|---|
| 336 |
|
|---|
| 337 |
|
|---|
| 338 |
|
|---|
| 339 |
void playlist_MainLoop( playlist_t *p_playlist ) |
|---|
| 340 |
{ |
|---|
| 341 |
playlist_item_t *p_item = NULL; |
|---|
| 342 |
bool b_playexit = var_GetBool( p_playlist, "play-and-exit" ); |
|---|
| 343 |
|
|---|
| 344 |
PL_ASSERT_LOCKED; |
|---|
| 345 |
|
|---|
| 346 |
if( p_playlist->b_reset_currently_playing && |
|---|
| 347 |
mdate() - p_playlist->last_rebuild_date > 30000 ) |
|---|
| 348 |
{ |
|---|
| 349 |
ResetCurrentlyPlaying( p_playlist, var_GetBool( p_playlist, "random" ), |
|---|
| 350 |
get_current_status_item( p_playlist ) ); |
|---|
| 351 |
p_playlist->last_rebuild_date = mdate(); |
|---|
| 352 |
} |
|---|
| 353 |
|
|---|
| 354 |
check_input: |
|---|
| 355 |
|
|---|
| 356 |
if( p_playlist->p_input ) |
|---|
| 357 |
{ |
|---|
| 358 |
if( p_playlist->request.b_request && !p_playlist->p_input->b_die ) |
|---|
| 359 |
{ |
|---|
| 360 |
PL_DEBUG( "incoming request - stopping current input" ); |
|---|
| 361 |
input_StopThread( p_playlist->p_input ); |
|---|
| 362 |
} |
|---|
| 363 |
|
|---|
| 364 |
|
|---|
| 365 |
if( p_playlist->p_input->b_dead ) |
|---|
| 366 |
{ |
|---|
| 367 |
int i_activity; |
|---|
| 368 |
input_thread_t *p_input; |
|---|
| 369 |
sout_instance_t **pp_sout = &p_playlist->p->p_sout; |
|---|
| 370 |
|
|---|
| 371 |
PL_DEBUG( "dead input" ); |
|---|
| 372 |
|
|---|
| 373 |
p_input = p_playlist->p_input; |
|---|
| 374 |
|
|---|
| 375 |
assert( *pp_sout == NULL ); |
|---|
| 376 |
if( var_CreateGetBool( p_input, "sout-keep" ) ) |
|---|
| 377 |
*pp_sout = input_DetachSout( p_input ); |
|---|
| 378 |
|
|---|
| 379 |
|
|---|
| 380 |
playlist_release_current_input( p_playlist ); |
|---|
| 381 |
|
|---|
| 382 |
p_playlist->gc_date = mdate(); |
|---|
| 383 |
p_playlist->b_cant_sleep = true; |
|---|
| 384 |
|
|---|
| 385 |
i_activity= var_GetInteger( p_playlist, "activity" ); |
|---|
| 386 |
var_SetInteger( p_playlist, "activity", i_activity - |
|---|
| 387 |
DEFAULT_INPUT_ACTIVITY ); |
|---|
| 388 |
|
|---|
| 389 |
goto check_input; |
|---|
| 390 |
} |
|---|
| 391 |
|
|---|
| 392 |
else if( p_playlist->p_input->b_die ) |
|---|
| 393 |
{ |
|---|
| 394 |
PL_DEBUG( "dying input" ); |
|---|
| 395 |
PL_UNLOCK; |
|---|
| 396 |
msleep( INTF_IDLE_SLEEP ); |
|---|
| 397 |
PL_LOCK; |
|---|
| 398 |
goto check_input; |
|---|
| 399 |
} |
|---|
| 400 |
|
|---|
| 401 |
else if( p_playlist->p_input->b_error |
|---|
| 402 |
|| p_playlist->p_input->b_eof ) |
|---|
| 403 |
{ |
|---|
| 404 |
PL_DEBUG( "finished input" ); |
|---|
| 405 |
input_StopThread( p_playlist->p_input ); |
|---|
| 406 |
|
|---|
| 407 |
goto check_input; |
|---|
| 408 |
} |
|---|
| 409 |
else if( p_playlist->p_input->i_state != INIT_S ) |
|---|
| 410 |
{ |
|---|
| 411 |
ObjectGarbageCollector( p_playlist, false ); |
|---|
| 412 |
} |
|---|
| 413 |
} |
|---|
| 414 |
else |
|---|
| 415 |
{ |
|---|
| 416 |
|
|---|
| 417 |
|
|---|
| 418 |
|
|---|
| 419 |
|
|---|
| 420 |
|
|---|
| 421 |
|
|---|
| 422 |
int i_status = p_playlist->request.b_request ? |
|---|
| 423 |
p_playlist->request.i_status : p_playlist->status.i_status; |
|---|
| 424 |
if( i_status != PLAYLIST_STOPPED ) |
|---|
| 425 |
{ |
|---|
| 426 |
msg_Dbg( p_playlist, "starting new item" ); |
|---|
| 427 |
p_item = playlist_NextItem( p_playlist ); |
|---|
| 428 |
|
|---|
| 429 |
if( p_item == NULL ) |
|---|
| 430 |
{ |
|---|
| 431 |
msg_Dbg( p_playlist, "nothing to play" ); |
|---|
| 432 |
p_playlist->status.i_status = PLAYLIST_STOPPED; |
|---|
| 433 |
|
|---|
| 434 |
if( b_playexit == true ) |
|---|
| 435 |
{ |
|---|
| 436 |
msg_Info( p_playlist, "end of playlist, exiting" ); |
|---|
| 437 |
vlc_object_kill( p_playlist->p_libvlc ); |
|---|
| 438 |
} |
|---|
| 439 |
ObjectGarbageCollector( p_playlist, true ); |
|---|
| 440 |
return; |
|---|
| 441 |
} |
|---|
| 442 |
playlist_PlayItem( p_playlist, p_item ); |
|---|
| 443 |
|
|---|
| 444 |
goto check_input; |
|---|
| 445 |
} |
|---|
| 446 |
else |
|---|
| 447 |
{ |
|---|
| 448 |
const bool b_gc_forced = p_playlist->status.i_status != PLAYLIST_STOPPED; |
|---|
| 449 |
|
|---|
| 450 |
p_playlist->status.i_status = PLAYLIST_STOPPED; |
|---|
| 451 |
|
|---|
| 452 |
|
|---|
| 453 |
ObjectGarbageCollector( p_playlist, b_gc_forced ); |
|---|
| 454 |
} |
|---|
| 455 |
} |
|---|
| 456 |
} |
|---|
| 457 |
|
|---|
| 458 |
|
|---|
| 459 |
|
|---|
| 460 |
|
|---|
| 461 |
|
|---|
| 462 |
|
|---|
| 463 |
|
|---|
| 464 |
|
|---|
| 465 |
void playlist_LastLoop( playlist_t *p_playlist ) |
|---|
| 466 |
{ |
|---|
| 467 |
|
|---|
| 468 |
while( 1 ) |
|---|
| 469 |
{ |
|---|
| 470 |
PL_LOCK; |
|---|
| 471 |
if( p_playlist->p_input == NULL ) |
|---|
| 472 |
{ |
|---|
| 473 |
PL_UNLOCK; |
|---|
| 474 |
break; |
|---|
| 475 |
} |
|---|
| 476 |
|
|---|
| 477 |
if( p_playlist->p_input->b_dead ) |
|---|
| 478 |
{ |
|---|
| 479 |
|
|---|
| 480 |
playlist_release_current_input( p_playlist ); |
|---|
| 481 |
|
|---|
| 482 |
|
|---|
| 483 |
|
|---|
| 484 |
|
|---|
| 485 |
PL_UNLOCK; |
|---|
| 486 |
continue; |
|---|
| 487 |
} |
|---|
| 488 |
else if( p_playlist->p_input->b_die ) |
|---|
| 489 |
{ |
|---|
| 490 |
|
|---|
| 491 |
; |
|---|
| 492 |
} |
|---|
| 493 |
else if( p_playlist->p_input->b_error || p_playlist->p_input->b_eof ) |
|---|
| 494 |
{ |
|---|
| 495 |
input_StopThread( p_playlist->p_input ); |
|---|
| 496 |
PL_UNLOCK; |
|---|
| 497 |
continue; |
|---|
| 498 |
} |
|---|
| 499 |
else |
|---|
| 500 |
{ |
|---|
| 501 |
p_playlist->p_input->b_eof = 1; |
|---|
| 502 |
} |
|---|
| 503 |
PL_UNLOCK; |
|---|
| 504 |
|
|---|
| 505 |
msleep( INTF_IDLE_SLEEP ); |
|---|
| 506 |
} |
|---|
| 507 |
|
|---|
| 508 |
#ifdef ENABLE_SOUT |
|---|
| 509 |
|
|---|
| 510 |
sout_instance_t *p_sout = p_playlist->p->p_sout; |
|---|
| 511 |
if (p_sout) |
|---|
| 512 |
sout_DeleteInstance( p_sout ); |
|---|
| 513 |
#endif |
|---|
| 514 |
|
|---|
| 515 |
|
|---|
| 516 |
|
|---|
| 517 |
playlist_ServicesDiscoveryKillAll( p_playlist ); |
|---|
| 518 |
playlist_MLDump( p_playlist ); |
|---|
| 519 |
|
|---|
| 520 |
vlc_object_kill( p_playlist->p->p_preparse ); |
|---|
| 521 |
vlc_thread_join( p_playlist->p->p_preparse ); |
|---|
| 522 |
vlc_object_kill( p_playlist->p->p_fetcher ); |
|---|
| 523 |
vlc_thread_join( p_playlist->p->p_fetcher ); |
|---|
| 524 |
|
|---|
| 525 |
PL_LOCK; |
|---|
| 526 |
|
|---|
| 527 |
|
|---|
| 528 |
set_current_status_node( p_playlist, NULL ); |
|---|
| 529 |
|
|---|
| 530 |
|
|---|
| 531 |
set_current_status_item( p_playlist, NULL ); |
|---|
| 532 |
|
|---|
| 533 |
FOREACH_ARRAY( playlist_item_t *p_del, p_playlist->all_items ) |
|---|
| 534 |
free( p_del->pp_children ); |
|---|
| 535 |
vlc_gc_decref( p_del->p_input ); |
|---|
| 536 |
free( p_del ); |
|---|
| 537 |
FOREACH_END(); |
|---|
| 538 |
ARRAY_RESET( p_playlist->all_items ); |
|---|
| 539 |
FOREACH_ARRAY( playlist_item_t *p_del, p_playlist->items_to_delete ) |
|---|
| 540 |
free( p_del->pp_children ); |
|---|
| 541 |
vlc_gc_decref( p_del->p_input ); |
|---|
| 542 |
free( p_del ); |
|---|
| 543 |
FOREACH_END(); |
|---|
| 544 |
ARRAY_RESET( p_playlist->items_to_delete ); |
|---|
| 545 |
|
|---|
| 546 |
ARRAY_RESET( p_playlist->items ); |
|---|
| 547 |
ARRAY_RESET( p_playlist->current ); |
|---|
| 548 |
|
|---|
| 549 |
PL_UNLOCK; |
|---|
| 550 |
} |
|---|
| 551 |
|
|---|
| 552 |
|
|---|
| 553 |
|
|---|
| 554 |
|
|---|
| 555 |
|
|---|
| 556 |
|
|---|
| 557 |
|
|---|
| 558 |
|
|---|
| 559 |
void playlist_PreparseLoop( playlist_preparse_t *p_obj ) |
|---|
| 560 |
{ |
|---|
| 561 |
playlist_t *p_playlist = (playlist_t *)p_obj->p_parent; |
|---|
| 562 |
input_item_t *p_current; |
|---|
| 563 |
int i_activity; |
|---|
| 564 |
|
|---|
| 565 |
vlc_object_lock( p_obj ); |
|---|
| 566 |
|
|---|
| 567 |
while( vlc_object_alive( p_obj ) ) |
|---|
| 568 |
{ |
|---|
| 569 |
if( p_obj->i_waiting == 0 ) |
|---|
| 570 |
{ |
|---|
| 571 |
vlc_object_wait( p_obj ); |
|---|
| 572 |
continue; |
|---|
| 573 |
} |
|---|
| 574 |
|
|---|
| 575 |
p_current = p_obj->pp_waiting[0]; |
|---|
| 576 |
REMOVE_ELEM( p_obj->pp_waiting, p_obj->i_waiting, 0 ); |
|---|
| 577 |
vlc_object_unlock( p_obj ); |
|---|
| 578 |
|
|---|
| 579 |
PL_LOCK; |
|---|
| 580 |
if( p_current ) |
|---|
| 581 |
{ |
|---|
| 582 |
if( p_current->i_type == ITEM_TYPE_FILE ) |
|---|
| 583 |
{ |
|---|
| 584 |
stats_TimerStart( p_playlist, "Preparse run", |
|---|
| 585 |
STATS_TIMER_PREPARSE ); |
|---|
| 586 |
|
|---|
| 587 |
if( !input_item_IsPreparsed( p_current ) ) |
|---|
| 588 |
{ |
|---|
| 589 |
PL_UNLOCK; |
|---|
| 590 |
input_Preparse( p_playlist, p_current ); |
|---|
| 591 |
PL_LOCK; |
|---|
| 592 |
} |
|---|
| 593 |
stats_TimerStop( p_playlist, STATS_TIMER_PREPARSE ); |
|---|
| 594 |
PL_UNLOCK; |
|---|
| 595 |
input_item_SetPreparsed( p_current, true ); |
|---|
| 596 |
var_SetInteger( p_playlist, "item-change", p_current->i_id ); |
|---|
| 597 |
PL_LOCK; |
|---|
| 598 |
} |
|---|
| 599 |
|
|---|
| 600 |
|
|---|
| 601 |
|
|---|
| 602 |
|
|---|
| 603 |
|
|---|
| 604 |
char *psz_arturl = input_item_GetArtURL( p_current ); |
|---|
| 605 |
char *psz_name = input_item_GetName( p_current ); |
|---|
| 606 |
if( p_playlist->p->p_fetcher->i_art_policy == ALBUM_ART_ALL && |
|---|
| 607 |
( !psz_arturl || strncmp( psz_arturl, "file://", 7 ) ) ) |
|---|
| 608 |
{ |
|---|
| 609 |
PL_DEBUG("meta ok for %s, need to fetch art", psz_name ); |
|---|
| 610 |
vlc_object_lock( p_playlist->p->p_fetcher ); |
|---|
| 611 |
if( vlc_object_alive( p_playlist->p->p_fetcher ) ) |
|---|
| 612 |
{ |
|---|
| 613 |
INSERT_ELEM( p_playlist->p->p_fetcher->pp_waiting, |
|---|
| 614 |
p_playlist->p->p_fetcher->i_waiting, |
|---|
| 615 |
p_playlist->p->p_fetcher->i_waiting, p_current); |
|---|
| 616 |
vlc_object_signal_unlocked( p_playlist->p->p_fetcher ); |
|---|
| 617 |
} |
|---|
| 618 |
else |
|---|
| 619 |
vlc_gc_decref( p_current ); |
|---|
| 620 |
vlc_object_unlock( p_playlist->p->p_fetcher ); |
|---|
| 621 |
} |
|---|
| 622 |
else |
|---|
| 623 |
{ |
|---|
| 624 |
PL_DEBUG( "no fetch required for %s (art currently %s)", |
|---|
| 625 |
psz_name, psz_arturl ); |
|---|
| 626 |
vlc_gc_decref( p_current ); |
|---|
| 627 |
} |
|---|
| 628 |
free( psz_name ); |
|---|
| 629 |
free( psz_arturl ); |
|---|
| 630 |
PL_UNLOCK; |
|---|
| 631 |
} |
|---|
| 632 |
else |
|---|
| 633 |
PL_UNLOCK; |
|---|
| 634 |
|
|---|
| 635 |
vlc_object_lock( p_obj ); |
|---|
| 636 |
i_activity = var_GetInteger( p_playlist, "activity" ); |
|---|
| 637 |
if( i_activity < 0 ) i_activity = 0; |
|---|
| 638 |
vlc_object_unlock( p_obj ); |
|---|
| 639 |
|
|---|
| 640 |
msleep( (i_activity+1) * 1000 ); |
|---|
| 641 |
vlc_object_lock( p_obj ); |
|---|
| 642 |
} |
|---|
| 643 |
|
|---|
| 644 |
while( p_obj->i_waiting > 0 ) |
|---|
| 645 |
{ |
|---|
| 646 |
vlc_gc_decref( p_obj->pp_waiting[0] ); |
|---|
| 647 |
REMOVE_ELEM( p_obj->pp_waiting, p_obj->i_waiting, 0 ); |
|---|
| 648 |
} |
|---|
| 649 |
|
|---|
| 650 |
vlc_object_unlock( p_obj ); |
|---|
| 651 |
} |
|---|
| 652 |
|
|---|
| 653 |
|
|---|
| 654 |
|
|---|
| 655 |
|
|---|
| 656 |
|
|---|
| 657 |
|
|---|
| 658 |
|
|---|
| 659 |
|
|---|
| 660 |
void playlist_FetcherLoop( playlist_fetcher_t *p_obj ) |
|---|
| 661 |
{ |
|---|
| 662 |
playlist_t *p_playlist = (playlist_t *)p_obj->p_parent; |
|---|
| 663 |
input_item_t *p_item; |
|---|
| 664 |
int i_activity; |
|---|
| 665 |
|
|---|
| 666 |
vlc_object_lock( p_obj ); |
|---|
| 667 |
|
|---|
| 668 |
while( vlc_object_alive( p_obj ) ) |
|---|
| 669 |
{ |
|---|
| 670 |
if( p_obj->i_waiting == 0 ) |
|---|
| 671 |
{ |
|---|
| 672 |
vlc_object_wait( p_obj ); |
|---|
| 673 |
continue; |
|---|
| 674 |
} |
|---|
| 675 |
|
|---|
| 676 |
p_item = p_obj->pp_waiting[0]; |
|---|
| 677 |
REMOVE_ELEM( p_obj->pp_waiting, p_obj->i_waiting, 0 ); |
|---|
| 678 |
vlc_object_unlock( p_obj ); |
|---|
| 679 |
if( p_item ) |
|---|
| 680 |
{ |
|---|
| 681 |
int i_ret; |
|---|
| 682 |
|
|---|
| 683 |
|
|---|
| 684 |
|
|---|
| 685 |
|
|---|
| 686 |
for( i_ret = 0; i_ret < 10 && !input_item_IsPreparsed( p_item ); i_ret++ ) |
|---|
| 687 |
{ |
|---|
| 688 |
bool b_break; |
|---|
| 689 |
PL_LOCK; |
|---|
| 690 |
b_break = ( !p_playlist->p_input || input_GetItem(p_playlist->p_input) != p_item || |
|---|
| 691 |
p_playlist->p_input->b_die || p_playlist->p_input->b_eof || p_playlist->p_input->b_error ); |
|---|
| 692 |
PL_UNLOCK; |
|---|
| 693 |
if( b_break ) |
|---|
| 694 |
break; |
|---|
| 695 |
msleep( 50000 ); |
|---|
| 696 |
} |
|---|
| 697 |
|
|---|
| 698 |
i_ret = input_ArtFind( p_playlist, p_item ); |
|---|
| 699 |
if( i_ret == 1 ) |
|---|
| 700 |
{ |
|---|
| 701 |
PL_DEBUG( "downloading art for %s", p_item->psz_name ); |
|---|
| 702 |
if( input_DownloadAndCacheArt( p_playlist, p_item ) ) |
|---|
| 703 |
input_item_SetArtNotFound( p_item, true ); |
|---|
| 704 |
else { |
|---|
| 705 |
input_item_SetArtFetched( p_item, true ); |
|---|
| 706 |
var_SetInteger( p_playlist, "item-change", |
|---|
| 707 |
p_item->i_id ); |
|---|
| 708 |
} |
|---|
| 709 |
} |
|---|
| 710 |
else if( i_ret == 0 ) |
|---|
| 711 |
{ |
|---|
| 712 |
PL_DEBUG( "found art for %s in cache", p_item->psz_name ); |
|---|
| 713 |
input_item_SetArtFetched( p_item, true ); |
|---|
| 714 |
var_SetInteger( p_playlist, "item-change", p_item->i_id ); |
|---|
| 715 |
} |
|---|
| 716 |
else |
|---|
| 717 |
{ |
|---|
| 718 |
PL_DEBUG( "art not found for %s", p_item->psz_name ); |
|---|
| 719 |
input_item_SetArtNotFound( p_item, true ); |
|---|
| 720 |
} |
|---|
| 721 |
vlc_gc_decref( p_item ); |
|---|
| 722 |
} |
|---|
| 723 |
vlc_object_lock( p_obj ); |
|---|
| 724 |
i_activity = var_GetInteger( p_playlist, "activity" ); |
|---|
| 725 |
if( i_activity < 0 ) i_activity = 0; |
|---|
| 726 |
vlc_object_unlock( p_obj ); |
|---|
| 727 |
|
|---|
| 728 |
msleep( (i_activity+1) * 1000 ); |
|---|
| 729 |
vlc_object_lock( p_obj ); |
|---|
| 730 |
} |
|---|
| 731 |
|
|---|
| 732 |
while( p_obj->i_waiting > 0 ) |
|---|
| 733 |
{ |
|---|
| 734 |
vlc_gc_decref( p_obj->pp_waiting[0] ); |
|---|
| 735 |
REMOVE_ELEM( p_obj->pp_waiting, p_obj->i_waiting, 0 ); |
|---|
| 736 |
} |
|---|
| 737 |
|
|---|
| 738 |
vlc_object_unlock( p_obj ); |
|---|
| 739 |
} |
|---|
| 740 |
|
|---|
| 741 |
static void VariablesInit( playlist_t *p_playlist ) |
|---|
| 742 |
{ |
|---|
| 743 |
vlc_value_t val; |
|---|
| 744 |
|
|---|
| 745 |
var_Create( p_playlist, "intf-change", VLC_VAR_BOOL ); |
|---|
| 746 |
val.b_bool = true; |
|---|
| 747 |
var_Set( p_playlist, "intf-change", val ); |
|---|
| 748 |
|
|---|
| 749 |
var_Create( p_playlist, "item-change", VLC_VAR_INTEGER ); |
|---|
| 750 |
val.i_int = -1; |
|---|
| 751 |
var_Set( p_playlist, "item-change", val ); |
|---|
| 752 |
|
|---|
| 753 |
var_Create( p_playlist, "item-deleted", VLC_VAR_INTEGER ); |
|---|
| 754 |
val.i_int = -1; |
|---|
| 755 |
var_Set( p_playlist, "item-deleted", val ); |
|---|
| 756 |
|
|---|
| 757 |
var_Create( p_playlist, "item-append", VLC_VAR_ADDRESS ); |
|---|
| 758 |
|
|---|
| 759 |
var_Create( p_playlist, "playlist-current", VLC_VAR_INTEGER ); |
|---|
| 760 |
val.i_int = -1; |
|---|
| 761 |
var_Set( p_playlist, "playlist-current", val ); |
|---|
| 762 |
|
|---|
| 763 |
var_Create( p_playlist, "activity", VLC_VAR_INTEGER ); |
|---|
| 764 |
var_SetInteger( p_playlist, "activity", 0 ); |
|---|
| 765 |
|
|---|
| 766 |
|
|---|
| 767 |
var_CreateGetBool( p_playlist, "play-and-stop" ); |
|---|
| 768 |
var_CreateGetBool( p_playlist, "play-and-exit" ); |
|---|
| 769 |
var_CreateGetBool( p_playlist, "random" ); |
|---|
| 770 |
var_CreateGetBool( p_playlist, "repeat" ); |
|---|
| 771 |
var_CreateGetBool( p_playlist, "loop" ); |
|---|
| 772 |
|
|---|
| 773 |
var_AddCallback( p_playlist, "random", RandomCallback, NULL ); |
|---|
| 774 |
} |
|---|