/////event_del(&queue_add_event);
close(event_add_pipe[0]);
/// TODO; flush QueueEvents fd's and delete it.
- ev_io_stop(event_base, NULL);
+ ev_io_stop(event_base, &queue_add_event);
+ ev_unloop(event_base, EVUNLOOP_ALL);
}
/* Unblock the other side */
// read(fd, buf, 1);
ev_loop (event_base, 0);
CtdlClearSystemContext();
ev_default_destroy ();
+
+ DeleteHash(&QueueEvents);
+ InboundEventQueue = NULL;
+ DeleteHash(&InboundEventQueues[0]);
+ DeleteHash(&InboundEventQueues[1]);
citthread_mutex_destroy(&EventQueueMutex);
+
+
return(NULL);
}