lib/isc/task.c

52  * an integrated event loop for socket, timer, and other generic task events.
111 	isc_eventlist_t			events;
204 		      isc_eventlist_t *events);
207 		 void *tag, isc_eventlist_t *events);
300 	REQUIRE(EMPTY(task->events));
354 	INIT_LIST(task->events);
427 			INSIST(EMPTY(task->events));
435 		 * Note that we post shutdown events LIFO.
442 			ENQUEUE(task->events, event, ev_link);
488 		INSIST(EMPTY(task->events));
491 		 * pending events.  We could try to optimize and
548 		INSIST(EMPTY(task->events));
553 	ENQUEUE(task->events, event, ev_link);
592 		 * task.  It thus doesn't matter if events are added,
640 	       isc_eventlist_t *events, isc_boolean_t purging)
652 	 * whose tag is 'tag' will be dequeued.  If 'purging', matching events
660 	for (event = HEAD(task->events); event != NULL; event = next_event) {
666 			DEQUEUE(task->events, event, ev_link);
667 			ENQUEUE(*events, event, ev_link);
683 	isc_eventlist_t events;
687 	 * Purge events from a task's event queue.
692 	ISC_LIST_INIT(events);
694 	count = dequeue_events(task, sender, first, last, tag, &events,
697 	for (event = HEAD(events); event != NULL; event = next_event) {
714 	 * Purge events from a task's event queue.
746 	for (curr_event = HEAD(task->events);
751 			DEQUEUE(task->events, curr_event, ev_link);
768 		      isc_eventlist_t *events)
771 	 * Remove events from a task's event queue.
777 			       last, tag, events, ISC_FALSE));
782 		 void *tag, isc_eventlist_t *events)
785 	 * Remove events from a task's event queue.
791 			       type, tag, events, ISC_FALSE));
1100 				if (!EMPTY(task->events)) {
1101 					event = HEAD(task->events);
1102 					DEQUEUE(task->events, event, ev_link);
1125 				    EMPTY(task->events) &&
1131 					 * pending events for this task,
1141 					 * the "if EMPTY(task->events)" block
1144 					 *	If we post no shutdown events,
1147 					 *	If we did post shutdown events,
1155 				if (EMPTY(task->events)) {
1540 	 * Dispatch the shutdown events.