X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=src%2Fplaylist%2Fservices_discovery.c;h=03b11caef566673ee2bc2e690494f1bbe11c112c;hb=64fb2cd16e78f0862051020f33a998626b2340bf;hp=e7d924994ea4d60c7f65dc168fa209fde32d37a0;hpb=e31c7798f239aa6ea94c8ba302c663405d4d9a27;p=vlc diff --git a/src/playlist/services_discovery.c b/src/playlist/services_discovery.c index e7d924994e..03b11caef5 100644 --- a/src/playlist/services_discovery.c +++ b/src/playlist/services_discovery.c @@ -31,7 +31,8 @@ #include "playlist_internal.h" #include "../libvlc.h" -static void RunSD( services_discovery_t *p_sd ); + +static void services_discovery_Destructor ( services_discovery_t * p_sd ); /* * Services discovery @@ -46,7 +47,7 @@ static void RunSD( services_discovery_t *p_sd ); char ** __services_discovery_GetServicesNames( vlc_object_t * p_super, char ***pppsz_longnames ) { - return module_GetModulesNamesForCapability( p_super, "services_discovery", + return module_GetModulesNamesForCapability( "services_discovery", pppsz_longnames ); } @@ -57,13 +58,13 @@ services_discovery_t * services_discovery_Create ( vlc_object_t * p_super, const char * psz_module_name ) { services_discovery_t *p_sd; + assert( psz_module_name ); p_sd = vlc_custom_create( p_super, sizeof( *p_sd ), VLC_OBJECT_GENERIC, "services discovery" ); if( !p_sd ) return NULL; - p_sd->pf_run = NULL; - p_sd->psz_localized_name = NULL; + p_sd->psz_module = strdup( psz_module_name ); vlc_event_manager_init( &p_sd->event_manager, p_sd, (vlc_object_t *)p_sd ); vlc_event_manager_register_event_type( &p_sd->event_manager, @@ -75,79 +76,81 @@ services_discovery_Create ( vlc_object_t * p_super, const char * psz_module_name vlc_event_manager_register_event_type( &p_sd->event_manager, vlc_ServicesDiscoveryEnded ); - p_sd->p_module = module_Need( p_sd, "services_discovery", psz_module_name, true ); - - if( p_sd->p_module == NULL ) - { - msg_Err( p_super, "no suitable services discovery module" ); - vlc_object_release( p_sd ); - return NULL; - } - p_sd->psz_module = strdup( psz_module_name ); - p_sd->b_die = false; /* FIXME */ - vlc_object_attach( p_sd, p_super ); + return p_sd; } -/*********************************************************************** - * Destroy - ***********************************************************************/ -void services_discovery_Destroy ( services_discovery_t * p_sd ) +static void ObjectKillChildrens( vlc_object_t *p_obj ) { - vlc_event_manager_fini( &p_sd->event_manager ); - - free( p_sd->psz_module ); - free( p_sd->psz_localized_name ); + vlc_list_t *p_list; + int i; + vlc_object_kill( p_obj ); - vlc_object_detach( p_sd ); - vlc_object_release( p_sd ); + p_list = vlc_list_children( p_obj ); + for( i = 0; i < p_list->i_count; i++ ) + ObjectKillChildrens( p_list->p_values[i].p_object ); + vlc_list_release( p_list ); } /*********************************************************************** - * Start + * Stop ***********************************************************************/ -int services_discovery_Start ( services_discovery_t * p_sd ) +bool services_discovery_Start ( services_discovery_t * p_sd ) { - if ((p_sd->pf_run != NULL) - && vlc_thread_create( p_sd, "services_discovery", RunSD, - VLC_THREAD_PRIORITY_LOW, false)) + assert(!p_sd->p_module); + + p_sd->p_module = module_need( p_sd, "services_discovery", p_sd->psz_module, true ); + + if( p_sd->p_module == NULL ) { - msg_Err( p_sd, "cannot create services discovery thread" ); - vlc_object_release( p_sd ); - return VLC_EGENERIC; + msg_Err( p_sd, "no suitable services discovery module" ); + return false; } - return VLC_SUCCESS; + + vlc_event_t event = { + .type = vlc_ServicesDiscoveryStarted + }; + vlc_event_send( &p_sd->event_manager, &event ); + return true; } - + /*********************************************************************** * Stop ***********************************************************************/ void services_discovery_Stop ( services_discovery_t * p_sd ) { - vlc_object_kill( p_sd ); - if( p_sd->pf_run ) vlc_thread_join( p_sd ); + vlc_event_t event = { + .type = vlc_ServicesDiscoveryEnded + }; + + ObjectKillChildrens( VLC_OBJECT(p_sd) ); + + vlc_event_send( &p_sd->event_manager, &event ); - module_Unneed( p_sd, p_sd->p_module ); + module_unneed( p_sd, p_sd->p_module ); + p_sd->p_module = NULL; } /*********************************************************************** - * GetLocalizedName + * Destructor ***********************************************************************/ -char * -services_discovery_GetLocalizedName ( services_discovery_t * p_sd ) +static void services_discovery_Destructor ( services_discovery_t * p_sd ) { - return p_sd->psz_localized_name ? strdup( p_sd->psz_localized_name ) : NULL; + assert(!p_sd->p_module); /* Forgot to call Stop */ + + vlc_event_manager_fini( &p_sd->event_manager ); + free( p_sd->psz_module ); + vlc_object_release( p_sd ); } /*********************************************************************** - * SetLocalizedName + * GetLocalizedName ***********************************************************************/ -void -services_discovery_SetLocalizedName ( services_discovery_t * p_sd, const char *psz ) +char * +services_discovery_GetLocalizedName ( services_discovery_t * p_sd ) { - free( p_sd->psz_localized_name ); - p_sd->psz_localized_name = strdup(psz); + return strdup( module_get_name( p_sd->p_module, true ) ); } /*********************************************************************** @@ -187,23 +190,6 @@ services_discovery_RemoveItem ( services_discovery_t * p_sd, input_item_t * p_it vlc_event_send( &p_sd->event_manager, &event ); } -/*********************************************************************** - * RunSD (Private) - ***********************************************************************/ -static void RunSD( services_discovery_t *p_sd ) -{ - vlc_event_t event; - - event.type = vlc_ServicesDiscoveryStarted; - vlc_event_send( &p_sd->event_manager, &event ); - - p_sd->pf_run( p_sd ); - - event.type = vlc_ServicesDiscoveryEnded; - vlc_event_send( &p_sd->event_manager, &event ); - return; -} - /* * Playlist - Services discovery bridge */ @@ -214,18 +200,37 @@ static void playlist_sd_item_added( const vlc_event_t * p_event, void * user_dat input_item_t * p_input = p_event->u.services_discovery_item_added.p_new_item; const char * psz_cat = p_event->u.services_discovery_item_added.psz_category; playlist_item_t *p_new_item, * p_parent = user_data; + playlist_t * p_playlist = p_parent->p_playlist; - msg_Dbg( p_parent->p_playlist, "Adding %s in %s", + msg_Dbg( p_playlist, "Adding %s in %s", p_input->psz_name ? p_input->psz_name : "(null)", psz_cat ? psz_cat : "(null)" ); - p_new_item = playlist_NodeAddInput( p_parent->p_playlist, p_input, p_parent, - PLAYLIST_APPEND, PLAYLIST_END, false ); + PL_LOCK; + /* If p_parent is in root category (this is clearly a hack) and we have a cat */ + if( !EMPTY_STR(psz_cat) && + p_parent->p_parent == p_playlist->p_root_category ) + { + /* */ + playlist_item_t * p_cat; + p_cat = playlist_ChildSearchName( p_parent, psz_cat ); + if( !p_cat ) + { + p_cat = playlist_NodeCreate( p_playlist, psz_cat, + p_parent, 0, NULL ); + p_cat->i_flags &= ~PLAYLIST_SKIP_FLAG; + } + p_parent = p_cat; + } + + p_new_item = playlist_NodeAddInput( p_playlist, p_input, p_parent, + PLAYLIST_APPEND, PLAYLIST_END, pl_Locked ); if( p_new_item ) { p_new_item->i_flags &= ~PLAYLIST_SKIP_FLAG; p_new_item->i_flags &= ~PLAYLIST_SAVE_FLAG; } + PL_UNLOCK; } /* A new item has been removed from a certain sd */ @@ -247,11 +252,12 @@ static void playlist_sd_item_removed( const vlc_event_t * p_event, void * user_d vlc_object_unlock( p_parent->p_playlist ); return; } - vlc_object_unlock( p_parent->p_playlist ); /* Delete the non-node item normally */ - playlist_DeleteInputInParent( p_parent->p_playlist, p_input->i_id, - p_parent, false ); + playlist_DeleteFromInputInParent( p_parent->p_playlist, p_input->i_id, + p_parent, pl_Locked ); + + vlc_object_unlock( p_parent->p_playlist ); } int playlist_ServicesDiscoveryAdd( playlist_t *p_playlist, const char *psz_modules ) @@ -288,17 +294,11 @@ int playlist_ServicesDiscoveryAdd( playlist_t *p_playlist, const char *psz_modu if( !p_sd ) continue; - char * psz = services_discovery_GetLocalizedName( p_sd ); - assert( psz ); - playlist_NodesPairCreate( p_playlist, psz, - &p_cat, &p_one, false ); - free( psz ); - vlc_event_attach( services_discovery_EventManager( p_sd ), vlc_ServicesDiscoveryItemAdded, playlist_sd_item_added, p_one ); - + vlc_event_attach( services_discovery_EventManager( p_sd ), vlc_ServicesDiscoveryItemAdded, playlist_sd_item_added, @@ -314,22 +314,36 @@ int playlist_ServicesDiscoveryAdd( playlist_t *p_playlist, const char *psz_modu playlist_sd_item_removed, p_cat ); - services_discovery_Start( p_sd ); + bool ret = services_discovery_Start( p_sd ); + if(!ret) + { + vlc_object_release( p_sd ); + return VLC_EGENERIC; + } + + char *psz = services_discovery_GetLocalizedName( p_sd ); + assert( psz ); + PL_LOCK; + playlist_NodesPairCreate( p_playlist, psz, + &p_cat, &p_one, false ); + PL_UNLOCK; + free( psz ); /* Free in playlist_ServicesDiscoveryRemove */ p_sds = malloc( sizeof(struct playlist_services_discovery_support_t) ); if( !p_sds ) - { - msg_Err( p_playlist, "No more memory" ); return VLC_ENOMEM; - } + + /* We want tree-view for service directory */ + p_one->p_input->b_prefers_tree = true; p_sds->p_sd = p_sd; p_sds->p_one = p_one; p_sds->p_cat = p_cat; PL_LOCK; - TAB_APPEND( p_playlist->i_sds, p_playlist->pp_sds, p_sds ); + TAB_APPEND( pl_priv(p_playlist)->i_sds, pl_priv(p_playlist)->pp_sds, p_sds ); PL_UNLOCK; + } return retval; @@ -342,12 +356,12 @@ int playlist_ServicesDiscoveryRemove( playlist_t * p_playlist, int i; PL_LOCK; - for( i = 0 ; i< p_playlist->i_sds ; i ++ ) + for( i = 0 ; i< pl_priv(p_playlist)->i_sds ; i ++ ) { - if( !strcmp( psz_module, p_playlist->pp_sds[i]->p_sd->psz_module ) ) + if( !strcmp( psz_module, pl_priv(p_playlist)->pp_sds[i]->p_sd->psz_module ) ) { - p_sds = p_playlist->pp_sds[i]; - REMOVE_ELEM( p_playlist->pp_sds, p_playlist->i_sds, i ); + p_sds = pl_priv(p_playlist)->pp_sds[i]; + REMOVE_ELEM( pl_priv(p_playlist)->pp_sds, pl_priv(p_playlist)->i_sds, i ); break; } } @@ -359,8 +373,6 @@ int playlist_ServicesDiscoveryRemove( playlist_t * p_playlist, return VLC_EGENERIC; } - services_discovery_Stop( p_sds->p_sd ); - vlc_event_detach( services_discovery_EventManager( p_sds->p_sd ), vlc_ServicesDiscoveryItemAdded, playlist_sd_item_added, @@ -391,7 +403,8 @@ int playlist_ServicesDiscoveryRemove( playlist_t * p_playlist, } PL_UNLOCK; - services_discovery_Destroy( p_sds->p_sd ); + services_discovery_StopAndRelease( p_sds->p_sd ); + free( p_sds ); return VLC_SUCCESS; } @@ -402,9 +415,9 @@ bool playlist_IsServicesDiscoveryLoaded( playlist_t * p_playlist, int i; PL_LOCK; - for( i = 0 ; i< p_playlist->i_sds ; i ++ ) + for( i = 0 ; i< pl_priv(p_playlist)->i_sds ; i ++ ) { - if( !strcmp( psz_module, p_playlist->pp_sds[i]->p_sd->psz_module ) ) + if( !strcmp( psz_module, pl_priv(p_playlist)->pp_sds[i]->p_sd->psz_module ) ) { PL_UNLOCK; return true; @@ -414,3 +427,9 @@ bool playlist_IsServicesDiscoveryLoaded( playlist_t * p_playlist, return false; } +void playlist_ServicesDiscoveryKillAll( playlist_t *p_playlist ) +{ + while( pl_priv(p_playlist)->i_sds > 0 ) + playlist_ServicesDiscoveryRemove( p_playlist, + pl_priv(p_playlist)->pp_sds[0]->p_sd->psz_module ); +}