54 t1_callback(isc_task_t *task, isc_event_t *event) {
65 	t_info("task %s\n", (char *)event->ev_arg);
66 	isc_event_free(&event);
70 t1_shutdown(isc_task_t *task, isc_event_t *event) {
74 	t_info("shutdown %s\n", (char *)event->ev_arg);
75 	isc_event_free(&event);
79 my_tick(isc_task_t *task, isc_event_t *event) {
83 	t_info("%s\n", (char *)event->ev_arg);
84 	isc_event_free(&event);
100 	isc_event_t		*event;
225 	event = isc_event_allocate(mctx, (void *)1, 1, t1_callback, "1",
226 				   sizeof(*event));
227 	if (event == NULL) {
232 	isc_task_send(task1, &event);
234 	event = isc_event_allocate(mctx, (void *)1, 1, t1_callback, "1",
235 				   sizeof(*event));
236 	if (event == NULL) {
241 	isc_task_send(task1, &event);
243 	event = isc_event_allocate(mctx, (void *)1, 1, t1_callback, "1",
244 				   sizeof(*event));
245 	if (event == NULL) {
250 	isc_task_send(task1, &event);
252 	event = isc_event_allocate(mctx, (void *)1, 1, t1_callback, "1",
253 				   sizeof(*event));
254 	if (event == NULL) {
259 	isc_task_send(task1, &event);
261 	event = isc_event_allocate(mctx, (void *)1, 1, t1_callback, "1",
262 				   sizeof(*event));
263 	if (event == NULL) {
268 	isc_task_send(task1, &event);
270 	event = isc_event_allocate(mctx, (void *)1, 1, t1_callback, "1",
271 				   sizeof(*event));
272 	if (event == NULL) {
277 	isc_task_send(task1, &event);
279 	event = isc_event_allocate(mctx, (void *)1, 1, t1_callback, "1",
280 				   sizeof(*event));
281 	if (event == NULL) {
286 	isc_task_send(task1, &event);
288 	event = isc_event_allocate(mctx, (void *)1, 1, t1_callback, "1",
289 				   sizeof(*event));
290 	if (event == NULL) {
295 	isc_task_send(task1, &event);
297 	event = isc_event_allocate(mctx, (void *)1, 1, t1_callback, "1",
298 				   sizeof(*event));
299 	if (event == NULL) {
304 	isc_task_send(task1, &event);
306 	event = isc_event_allocate(mctx, (void *)1, 1, t1_callback, "2",
307 				   sizeof(*event));
308 	if (event == NULL) {
313 	isc_task_send(task2, &event);
315 	event = isc_event_allocate(mctx, (void *)1, 1, t1_callback, "3",
316 				   sizeof(*event));
317 	if (event == NULL) {
322 	isc_task_send(task3, &event);
324 	event = isc_event_allocate(mctx, (void *)1, 1, t1_callback, "4",
325 				   sizeof(*event));
326 	if (event == NULL) {
331 	isc_task_send(task4, &event);
333 	event = isc_event_allocate(mctx, (void *)1, 1, t1_callback, "2",
334 				   sizeof(*event));
335 	if (event == NULL) {
340 	isc_task_send(task2, &event);
342 	event = isc_event_allocate(mctx, (void *)1, 1, t1_callback, "3",
343 				   sizeof(*event));
344 	if (event == NULL) {
349 	isc_task_send(task3, &event);
351 	event = isc_event_allocate(mctx, (void *)1, 1, t1_callback, "4",
352 				   sizeof(*event));
353 	if (event == NULL) {
358 	isc_task_send(task4, &event);
401 t2_shutdown(isc_task_t *task, isc_event_t *event) {
407 	if (event->ev_arg != NULL) {
408 		isc_task_destroy((isc_task_t**) &event->ev_arg);
438 t2_callback(isc_task_t *task, isc_event_t *event) {
448 	if (event->ev_arg) {
450 		event->ev_arg = (void *)(((uintptr_t) event->ev_arg) - 1);
472 		isc_task_send(newtask, &event);
486 	isc_event_t		*event;
543 					(void *)ntasks, sizeof(*event));
598 t3_sde1(isc_task_t *task, isc_event_t *event) {
612 	isc_event_free(&event);
616 t3_sde2(isc_task_t *task, isc_event_t *event) {
630 	isc_event_free(&event);
634 t3_event1(isc_task_t *task, isc_event_t *event) {
655 	isc_event_free(&event);
659 t3_event2(isc_task_t *task, isc_event_t *event) {
663 	isc_event_free(&event);
675 	isc_event_t	*event;
746 	 * This event causes the task to wait on T3_cv.
748 	event = isc_event_allocate(mctx, &senders[1], event_type, t3_event1,
749 				   NULL, sizeof(*event));
750 	if (event == NULL) {
758 	isc_task_send(task, &event);
761 	 * Now we fill up the task's event queue with some events.
764 		event = isc_event_allocate(mctx, &senders[1], event_type,
765 					   t3_event2, NULL, sizeof(*event));
766 		if (event == NULL) {
774 		isc_task_send(task, &event);
863 t4_event1(isc_task_t *task, isc_event_t *event) {
884 	isc_event_free(&event);
888 t4_sde(isc_task_t *task, isc_event_t *event) {
895 	isc_event_free(&event);
908 	isc_event_t	*event;
981 	 * This event causes the task to wait on T4_cv.
983 	event = isc_event_allocate(mctx, &senders[1], event_type, t4_event1,
984 				   NULL, sizeof(*event));
985 	if (event == NULL) {
994 	isc_task_send(task, &event);
1063 t7_event1(isc_task_t *task, isc_event_t *event) {
1068 	isc_event_free(&event);
1072 t7_sde(isc_task_t *task, isc_event_t *event) {
1100 	isc_event_free(&event);
1113 	isc_event_t	*event;
1200 	event = isc_event_allocate(mctx, &senders[1], event_type, t7_event1,
1201 				   NULL, sizeof(*event));
1202 	if (event == NULL) {
1211 	isc_task_send(task, &event);
1304 t10_event1(isc_task_t *task, isc_event_t *event) {
1332 	isc_event_free(&event);
1336 t10_event2(isc_task_t *task, isc_event_t *event) {
1350 		       event->ev_sender,
1351 		       (int)event->ev_type,
1352 		       event->ev_tag,
1353 		       event->ev_attributes & ISC_EVENTATTR_NOPURGE ?
1358 	    (T10_purge_sender == event->ev_sender)) {
1362 		if (T10_purge_type_first == event->ev_type) {
1366 		if ((T10_purge_type_first <= event->ev_type) &&
1367 		    (event->ev_type <= T10_purge_type_last)) {
1372 	    (T10_purge_tag == event->ev_tag)) {
1377 		if (event->ev_attributes & ISC_EVENTATTR_NOPURGE) {
1378 			t_info("event %p,%d,%p matched but was not purgable\n",
1379 				event->ev_sender, (int)event->ev_type,
1380 			       event->ev_tag);
1383 			t_info("*** event %p,%d,%p not purged\n",
1384 			       event->ev_sender, (int)event->ev_type,
1385 			       event->ev_tag);
1390 	isc_event_free(&event);
1395 t10_sde(isc_task_t *task, isc_event_t *event) {
1423 	isc_event_free(&event);
1437 	isc_event_t	*event;
1532 	event = isc_event_allocate(mctx, (void *)1, (isc_eventtype_t)T_CONTROL,
1533 				   t10_event1, NULL, sizeof(*event));
1535 	if (event == NULL) {
1545 	isc_task_send(task, &event);
1560 					    t10_event2, NULL, sizeof(*event));
1637 	 * Unblock the task, allowing event processing.
1783 t11_event1(isc_task_t *task, isc_event_t *event) {
1811 	isc_event_free(&event);
1815 t11_event2(isc_task_t *task, isc_event_t *event) {
1819 	isc_event_free(&event);
1824 t11_sde(isc_task_t *task, isc_event_t *event) {
1852 	isc_event_free(&event);
1990 	 * Unblock the task, allowing event processing.
2054 		"When the event is marked as purgable, a call to "
2055 		"isc_task_purgeevent(task, event) purges the event 'event' "
2069 			"When the event is not marked as purgable, a call to "
2070 			"isc_task_purgeevent(task, event) does not purge the "
2071 			"event 'event' from the task's queue and returns "
2097 		"to 'last' inclusive from the task's event queue and "
2211 t14_callback(isc_task_t *task, isc_event_t *event) {
2212 	int taskno = *(int *)(event->ev_arg);
2238 		isc_mem_put(event->ev_destroy_arg, event->ev_arg, sizeof (int));
2239 		isc_event_free(&event);
2241 		isc_task_send(task, &event);
2294 		isc_event_t *event;
2311 		event = isc_event_allocate(mctx, NULL, 1, t14_callback,
2312 					   v, sizeof(*event));
2313 		if (event == NULL) {
2318 		isc_task_send(tasks[i], &event);

Indexes created Tue Jul 24 14:28:13 CEST 2018