Commit d600db5f authored by Jean-Paul Saman's avatar Jean-Paul Saman

libvlc_event_*: fix locking

(cherry picked from commit 13b7d257)

Reverted change to libvlc_event_manger_release().
parent e755c4dd
...@@ -107,7 +107,9 @@ void libvlc_event_manager_release( libvlc_event_manager_t * p_em ) ...@@ -107,7 +107,9 @@ void libvlc_event_manager_release( libvlc_event_manager_t * p_em )
free( p_lg ); free( p_lg );
} }
vlc_array_clear( &p_em->listeners_groups ); vlc_array_clear( &p_em->listeners_groups );
libvlc_release( p_em->p_libvlc_instance ); libvlc_release( p_em->p_libvlc_instance );
free( p_em ); free( p_em );
} }
...@@ -122,9 +124,14 @@ void libvlc_event_manager_register_event_type( ...@@ -122,9 +124,14 @@ void libvlc_event_manager_register_event_type(
libvlc_exception_t * p_e ) libvlc_exception_t * p_e )
{ {
libvlc_event_listeners_group_t * listeners_group; libvlc_event_listeners_group_t * listeners_group;
vlc_mutex_lock( &p_em->object_lock );
listeners_group = malloc(sizeof(libvlc_event_listeners_group_t)); listeners_group = malloc(sizeof(libvlc_event_listeners_group_t));
if( !listeners_group ) if( !listeners_group )
{ {
vlc_mutex_unlock( &p_em->object_lock );
libvlc_exception_raise( p_e, "No Memory left" ); libvlc_exception_raise( p_e, "No Memory left" );
return; return;
} }
...@@ -132,7 +139,6 @@ void libvlc_event_manager_register_event_type( ...@@ -132,7 +139,6 @@ void libvlc_event_manager_register_event_type(
listeners_group->event_type = event_type; listeners_group->event_type = event_type;
vlc_array_init( &listeners_group->listeners ); vlc_array_init( &listeners_group->listeners );
vlc_mutex_lock( &p_em->object_lock );
vlc_array_append( &p_em->listeners_groups, listeners_group ); vlc_array_append( &p_em->listeners_groups, listeners_group );
vlc_mutex_unlock( &p_em->object_lock ); vlc_mutex_unlock( &p_em->object_lock );
} }
...@@ -171,6 +177,7 @@ void libvlc_event_send( libvlc_event_manager_t * p_em, ...@@ -171,6 +177,7 @@ void libvlc_event_send( libvlc_event_manager_t * p_em,
if( !array_listeners_cached ) if( !array_listeners_cached )
{ {
fprintf(stderr, "Can't alloc memory in libvlc_event_send" ); fprintf(stderr, "Can't alloc memory in libvlc_event_send" );
vlc_mutex_unlock( &p_em->object_lock );
return; return;
} }
...@@ -187,6 +194,7 @@ void libvlc_event_send( libvlc_event_manager_t * p_em, ...@@ -187,6 +194,7 @@ void libvlc_event_send( libvlc_event_manager_t * p_em,
if( !listeners_group ) if( !listeners_group )
{ {
vlc_mutex_unlock( &p_em->object_lock );
free( array_listeners_cached ); free( array_listeners_cached );
return; return;
} }
...@@ -215,9 +223,10 @@ void libvlc_event_send( libvlc_event_manager_t * p_em, ...@@ -215,9 +223,10 @@ void libvlc_event_send( libvlc_event_manager_t * p_em,
listener_cached->pf_callback( p_event, listener_cached->p_user_data ); listener_cached->pf_callback( p_event, listener_cached->p_user_data );
listener_cached++; listener_cached++;
} }
vlc_mutex_unlock( &p_em->event_sending_lock );
free( array_listeners_cached ); free( array_listeners_cached );
vlc_mutex_unlock( &p_em->event_sending_lock );
} }
/* /*
...@@ -299,9 +308,13 @@ void libvlc_event_attach( libvlc_event_manager_t * p_event_manager, ...@@ -299,9 +308,13 @@ void libvlc_event_attach( libvlc_event_manager_t * p_event_manager,
libvlc_event_listener_t * listener; libvlc_event_listener_t * listener;
int i; int i;
vlc_mutex_lock( &p_event_manager->object_lock );
listener = malloc(sizeof(libvlc_event_listener_t)); listener = malloc(sizeof(libvlc_event_listener_t));
if( !listener ) if( !listener )
{ {
vlc_mutex_unlock( &p_event_manager->object_lock );
libvlc_exception_raise( p_e, "No Memory left" ); libvlc_exception_raise( p_e, "No Memory left" );
return; return;
} }
...@@ -310,7 +323,6 @@ void libvlc_event_attach( libvlc_event_manager_t * p_event_manager, ...@@ -310,7 +323,6 @@ void libvlc_event_attach( libvlc_event_manager_t * p_event_manager,
listener->p_user_data = p_user_data; listener->p_user_data = p_user_data;
listener->pf_callback = pf_callback; listener->pf_callback = pf_callback;
vlc_mutex_lock( &p_event_manager->object_lock );
for( i = 0; i < vlc_array_count(&p_event_manager->listeners_groups); i++ ) for( i = 0; i < vlc_array_count(&p_event_manager->listeners_groups); i++ )
{ {
listeners_group = vlc_array_item_at_index(&p_event_manager->listeners_groups, i); listeners_group = vlc_array_item_at_index(&p_event_manager->listeners_groups, i);
...@@ -321,9 +333,11 @@ void libvlc_event_attach( libvlc_event_manager_t * p_event_manager, ...@@ -321,9 +333,11 @@ void libvlc_event_attach( libvlc_event_manager_t * p_event_manager,
return; return;
} }
} }
vlc_mutex_unlock( &p_event_manager->object_lock );
free(listener); free(listener);
vlc_mutex_unlock( &p_event_manager->object_lock );
libvlc_exception_raise( p_e, libvlc_exception_raise( p_e,
"This object event manager doesn't know about '%s' events", "This object event manager doesn't know about '%s' events",
libvlc_event_type_name(event_type)); libvlc_event_type_name(event_type));
...@@ -344,8 +358,8 @@ void libvlc_event_detach( libvlc_event_manager_t *p_event_manager, ...@@ -344,8 +358,8 @@ void libvlc_event_detach( libvlc_event_manager_t *p_event_manager,
libvlc_event_listener_t * listener; libvlc_event_listener_t * listener;
int i, j; int i, j;
vlc_mutex_lock( &p_event_manager->event_sending_lock );
vlc_mutex_lock( &p_event_manager->object_lock ); vlc_mutex_lock( &p_event_manager->object_lock );
for( i = 0; i < vlc_array_count(&p_event_manager->listeners_groups); i++) for( i = 0; i < vlc_array_count(&p_event_manager->listeners_groups); i++)
{ {
listeners_group = vlc_array_item_at_index(&p_event_manager->listeners_groups, i); listeners_group = vlc_array_item_at_index(&p_event_manager->listeners_groups, i);
...@@ -367,14 +381,13 @@ void libvlc_event_detach( libvlc_event_manager_t *p_event_manager, ...@@ -367,14 +381,13 @@ void libvlc_event_detach( libvlc_event_manager_t *p_event_manager,
free( listener ); free( listener );
vlc_array_remove( &listeners_group->listeners, j ); vlc_array_remove( &listeners_group->listeners, j );
vlc_mutex_unlock( &p_event_manager->object_lock ); vlc_mutex_unlock( &p_event_manager->object_lock );
vlc_mutex_unlock( &p_event_manager->event_sending_lock );
return; return;
} }
} }
} }
} }
vlc_mutex_unlock( &p_event_manager->object_lock ); vlc_mutex_unlock( &p_event_manager->object_lock );
vlc_mutex_unlock( &p_event_manager->event_sending_lock );
libvlc_exception_raise( p_e, libvlc_exception_raise( p_e,
"This object event manager doesn't know about '%s,%p,%p' event observer", "This object event manager doesn't know about '%s,%p,%p' event observer",
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment