Lines Matching refs:task
28 #include <isc/task.h>
130 /* Locked by task event serialization. */
195 /*% Locked by task event serialization. */
333 isc_task_t * task;
447 static void resquery_response(isc_task_t *task, isc_event_t *event);
448 static void resquery_connected(isc_task_t *task, isc_event_t *event);
460 static void validated(isc_task_t *task, isc_event_t *event);
478 isc_task_t *task)
496 valoptions, task, validated, valarg,
1024 isc_task_t *task;
1053 task = event->ev_sender;
1074 isc_task_sendanddetach(&task, ISC_EVENT_PTR(&event));
1217 resquery_udpconnected(isc_task_t *task, isc_event_t *event) {
1224 UNUSED(task);
1234 resquery_senddone(isc_task_t *task, isc_event_t *event) {
1249 UNUSED(task);
1365 isc_task_t *task;
1375 task = res->buckets[fctx->bucketnum].task;
1537 &addrinfo->sockaddr, task,
1676 isc_task_t *task;
1694 task = res->buckets[fctx->bucketnum].task;
1723 task,
1974 result = isc_socket_connect(socket, address, task,
1989 result = isc_socket_sendto(socket, &r, task, resquery_senddone,
2032 resquery_connected(isc_task_t *task, isc_event_t *event) {
2046 UNUSED(task);
2158 fctx_finddone(isc_task_t *task, isc_event_t *event) {
2173 UNUSED(task);
2475 res->buckets[fctx->bucketnum].task,
3179 fctx_timeout(isc_task_t *task, isc_event_t *event) {
3186 UNUSED(task);
3206 * case but is not always so, depending on the task schedule
3259 isc_task_send(fctx->res->buckets[fctx->bucketnum].task,
3265 fctx_doshutdown(isc_task_t *task, isc_event_t *event) {
3275 UNUSED(task);
3336 fctx_start(isc_task_t *task, isc_event_t *event) {
3345 UNUSED(task);
3419 fctx_join(fetchctx_t *fctx, isc_task_t *task, isc_sockaddr_t *client,
3430 * We store the task we're going to send this event to in the
3435 isc_task_attach(task, &clone);
3530 * Note! We do not attach to the task. We are relying on the
3531 * resolver to ensure that this task doesn't go away while we are
3693 res->buckets[bucketnum].task, fctx_timeout,
3988 validated(isc_task_t *task, isc_event_t *event) {
4010 UNUSED(task); /* for now */
4382 isc_task_t *task;
4396 task = res->buckets[fctx->bucketnum].task;
4638 valoptions, task);
4721 task);
4924 res->buckets[fctx->bucketnum].task);
6268 resume_dslookup(isc_task_t *task, isc_event_t *event) {
6286 UNUSED(task);
6355 nsrdataset, NULL, 0, task,
6555 resquery_response(isc_task_t *task, isc_event_t *event) {
7287 NULL, NULL, NULL, 0, task,
7353 isc_task_shutdown(res->buckets[i].task);
7354 isc_task_detach(&res->buckets[i].task);
7419 spillattimer_countdown(isc_task_t *task, isc_event_t *event) {
7427 UNUSED(task);
7465 isc_task_t *task = NULL;
7519 res->buckets[i].task = NULL;
7520 result = isc_task_create(taskmgr, 0, &res->buckets[i].task);
7535 isc_task_detach(&res->buckets[i].task);
7543 isc_task_setname(res->buckets[i].task, name, res);
7585 task = NULL;
7586 result = isc_task_create(taskmgr, 0, &task);
7591 task, spillattimer_countdown, res,
7593 isc_task_detach(&task);
7644 isc_task_shutdown(res->buckets[i].task);
7645 isc_task_detach(&res->buckets[i].task);
7658 prime_done(isc_task_t *task, isc_event_t *event) {
7669 UNUSED(task);
7749 res->buckets[0].task,
7793 dns_resolver_whenshutdown(dns_resolver_t *res, isc_task_t *task,
7812 isc_task_send(task, &event);
7815 isc_task_attach(task, &clone);
7848 isc_socket_cancel(sock, res->buckets[i].task,
7853 isc_socket_cancel(sock, res->buckets[i].task,
7940 unsigned int options, isc_task_t *task,
7948 options, task, action, arg,
7958 unsigned int options, isc_task_t *task,
8056 result = fctx_join(fctx, task, client, id, action, arg,
8068 isc_task_send(res->buckets[bucketnum].task, &event);