switch_event_types_t type;
int i = 0;
- /* TODO listener write lock */
-
/* clear any previous event registrations */
- for( x = 0; x <= SWITCH_EVENT_ALL; x++){
+ for(x = 0; x <= SWITCH_EVENT_ALL; x++) {
event_list[x] = 0;
}
switch_event_types_t type;
uint32_t x = 0;
- /* TODO session write lock */
/* clear any previous event registrations */
for (x = 0; x <= SWITCH_EVENT_ALL; x++){
event_list[x] = 0;
}
/* create new hash */
- /* TODO make thread safe*/
switch_core_hash_init(&event_hash, session->pool);
for (i = 1; i < arity; i++){
switch_thread_rwlock_wrlock(listener->session_rwlock);
/* do the deferred remove */
- /* TODO refactor find_session_elem_by_uuid*/
for (header = event->headers; header; header = header->next) {
if ((sp = (session_elem_t*)switch_core_hash_find(listener->sessions, header->value))) {
remove_session_elem_from_listener(listener, sp);