Lines Matching refs:task
37 #include <isc/task.h>
144 isc_task_t *task;
182 isc_task_t *task;
218 * internal task buckets. We use multiple tasks to distribute various
220 * 1st task (task[0]) for internal control events.
222 isc_task_t *task[MAX_INTERNAL_TASKS];
292 static void destroy_disp(isc_task_t *task, isc_event_t *event);
702 destroy_disp(isc_task_t *task, isc_event_t *event) {
711 UNUSED(task);
720 "shutting down; detaching from sock %p, task %p",
721 disp->socket, disp->task[0]); /* XXXX */
730 isc_task_detach(&disp->task[i]);
880 dispsock->task = NULL;
881 isc_task_attach(disp->task[r % disp->ntasks], &dispsock->task);
977 if (dispsock->task != NULL)
978 isc_task_detach(&dispsock->task);
1129 udp_exrecv(isc_task_t *task, isc_event_t *ev) {
1132 UNUSED(task);
1139 udp_shrecv(isc_task_t *task, isc_event_t *ev) {
1142 UNUSED(task);
1225 isc_task_send(disp->task[0], &disp->ctlevent);
1409 "[a] Sent event %p buffer %p len %d to task %p",
1411 resp->task);
1413 isc_task_send(resp->task, ISC_EVENT_PTR(&rev));
1454 tcp_recv(isc_task_t *task, isc_event_t *ev_in) {
1469 UNUSED(task);
1532 isc_task_send(disp->task[0], &disp->ctlevent);
1602 "[b] Sent event %p buffer %p len %d to task %p",
1604 resp->task);
1606 isc_task_send(resp->task, ISC_EVENT_PTR(&rev));
1664 dispsock->task, udp_exrecv,
1672 disp->task[0], udp_shrecv, disp);
1686 res = dns_tcpmsg_readmessage(&disp->tcpmsg, disp->task[0],
2599 disp->task[0] = NULL;
2600 result = isc_task_create(taskmgr, 0, &disp->task[0]);
2613 isc_task_setname(disp->task[0], "tcpdispatch", disp);
2627 dispatch_log(disp, LVL(90), "created task %p", disp->task[0]);
2637 isc_task_detach(&disp->task[0]);
2698 isc_socket_cancel(disp->socket, disp->task[0],
2905 disp->task[i] = NULL;
2906 result = isc_task_create(taskmgr, 0, &disp->task[i]);
2909 isc_task_shutdown(disp->task[i]);
2910 isc_task_detach(&disp->task[i]);
2914 isc_task_setname(disp->task[i], "udpdispatch", disp);
2936 dispatch_log(disp, LVL(90), "created task %p", disp->task[0]); /* XXX */
2948 isc_task_detach(&disp->task[i]);
2994 isc_socket_cancel(disp->socket, disp->task[0],
2999 isc_socket_cancel(dispsock->socket, dispsock->task,
3010 isc_task_send(disp->task[0], &disp->ctlevent);
3015 isc_task_t *task, isc_taskaction_t action, void *arg,
3030 REQUIRE(task != NULL);
3073 isc_task_send(oldestresp->task,
3140 res->task = NULL;
3141 isc_task_attach(task, &res->task);
3160 "attached to task %p", res->task);
3177 isc_task_detach(&res->task);
3199 isc_task_t *task, isc_taskaction_t action, void *arg,
3205 return (dns_dispatch_addresponse2(disp, dest, task, action, arg,
3214 dispatch_log(disp, LVL(90), "starttcp %p", disp->task[0]);
3266 isc_socket_cancel(disp->socket, disp->task[0],
3271 isc_socket_cancel(dispsock->socket, dispsock->task,
3289 n = isc_task_unsend(res->task, res, DNS_EVENT_DISPATCH,
3306 request_log(disp, res, LVL(90), "detaching from task %p", res->task);
3307 isc_task_detach(&res->task);
3311 res->dispsocket->task, ISC_SOCKCANCEL_RECV);
3336 isc_task_send(disp->task[0], &disp->ctlevent);
3377 "cancel: failsafe event %p -> task %p",
3378 ev, resp->task);
3380 isc_task_send(resp->task, ISC_EVENT_PTR(&ev));
3473 isc_socket_cancel(disp->socket, disp->task[0],
3517 isc_task_send(disp->task[0], ISC_EVENT_PTR(&newsevent));