Searched refs:task (Results 1 - 25 of 138) sorted by relevance

123456

/bind-9.11.3/lib/isc/
H A Dtask.c14 * XXXRTH Need to document the states a task can be in, and the rules
31 #include <isc/task.h>
45 * when built without threads we share a single global task manager and use
46 * an integrated event loop for socket, timer, and other generic task events.
48 * we don't use either of them: an application can have multiple task managers
62 #define XTRACE(m) fprintf(stderr, "task %p thread %lu: %s\n", \
63 task, isc_thread_self(), (m))
64 #define XTTRACE(t, m) fprintf(stderr, "task %p thread %lu: %s\n", \
100 /* Locked by task lock. */
112 /* Locked by task manage
303 task_finished(isc__task_t *task) argument
340 isc__task_t *task; local
417 task_shutdown(isc__task_t *task) argument
461 task_ready(isc__task_t *task) argument
482 task_detach(isc__task_t *task) argument
512 isc__task_t *task; local
536 task_send(isc__task_t *task, isc_event_t **eventp) argument
569 isc__task_t *task = (isc__task_t *)task0; local
612 isc__task_t *task; local
646 dequeue_events(isc__task_t *task, void *sender, isc_eventtype_t first, isc_eventtype_t last, void *tag, isc_eventlist_t *events, isc_boolean_t purging) argument
690 isc__task_t *task = (isc__task_t *)task0; local
720 isc__task_purge(isc_task_t *task, void *sender, isc_eventtype_t type, void *tag) argument
734 isc__task_t *task = (isc__task_t *)task0; local
777 isc__task_unsendrange(isc_task_t *task, void *sender, isc_eventtype_t first, isc_eventtype_t last, void *tag, isc_eventlist_t *events) argument
792 isc__task_unsend(isc_task_t *task, void *sender, isc_eventtype_t type, void *tag, isc_eventlist_t *events) argument
809 isc__task_t *task = (isc__task_t *)task0; local
847 isc__task_t *task = (isc__task_t *)task0; local
879 isc__task_t *task = (isc__task_t *)task0; local
895 isc__task_t *task = (isc__task_t *)task0; local
904 isc__task_t *task = (isc__task_t *)task0; local
913 isc__task_t *task = (isc__task_t *)task0; local
925 isc__task_t *task = (isc__task_t *)task0; local
968 isc__task_t *task; local
992 push_readyq(isc__taskmgr_t *manager, isc__task_t *task) argument
1002 isc__task_t *task; local
1495 isc__task_t *task; local
1686 isc__task_t *task = (isc__task_t *) task0; local
1718 isc__task_t *task = (isc__task_t *)task0; local
1746 isc__task_t *task = (isc__task_t *)task0; local
1762 isc__task_t *task = (isc__task_t *)task0; local
1789 isc__task_t *task = (isc__task_t *)task0; local
1805 isc__task_t *task = (isc__task_t *)t; local
1817 isc__task_t *task = NULL; local
1927 isc__task_t *task = NULL; local
2165 isc_task_send(isc_task_t *task, isc_event_t **eventp) argument
2193 isc_task_unsend(isc_task_t *task, void *sender, isc_eventtype_t type, void *tag, isc_eventlist_t *events) argument
2205 isc_task_onshutdown(isc_task_t *task, isc_taskaction_t action, void *arg) argument
2216 isc_task_shutdown(isc_task_t *task) argument
2234 isc_task_setname(isc_task_t *task, const char *name, void *tag) argument
2244 isc_task_purge(isc_task_t *task, void *sender, isc_eventtype_t type, void *tag) argument
2255 isc_task_beginexclusive(isc_task_t *task) argument
2265 isc_task_endexclusive(isc_task_t *task) argument
2275 isc_task_setprivilege(isc_task_t *task, isc_boolean_t priv) argument
2285 isc_task_privilege(isc_task_t *task) argument
2295 isc_task_getcurrenttime(isc_task_t *task, isc_stdtime_t *t) argument
2303 isc_task_getcurrenttimex(isc_task_t *task, isc_time_t *t) argument
2315 isc_task_purgerange(isc_task_t *task, void *sender, isc_eventtype_t first, isc_eventtype_t last, void *tag) argument
[all...]
H A Dondestroy.c20 #include <isc/task.h>
33 isc_ondestroy_register(isc_ondestroy_t *ondest, isc_task_t *task, argument
40 REQUIRE(task != NULL);
47 isc_task_attach(task, &thetask);
59 isc_task_t *task; local
67 task = eventp->ev_sender;
70 isc_task_sendanddetach(&task, &eventp);
H A Dsocket_api.c143 isc_socket_sendto(isc_socket_t *sock, isc_region_t *region, isc_task_t *task, argument
150 return (isc__socket_sendto(sock, region, task,
153 return (sock->methods->sendto(sock, region, task, action, arg, address,
158 isc_socket_connect(isc_socket_t *sock, isc_sockaddr_t *addr, isc_task_t *task, argument
164 return (isc__socket_connect(sock, addr, task, action, arg));
166 return (sock->methods->connect(sock, addr, task, action, arg));
171 isc_task_t *task, isc_taskaction_t action, void *arg)
177 task, action, arg));
179 return (sock->methods->recv(sock, region, minimum, task, action, arg));
183 isc_socket_cancel(isc_socket_t *sock, isc_task_t *task, unsigne argument
170 isc_socket_recv(isc_socket_t *sock, isc_region_t *region, unsigned int minimum, isc_task_t *task, isc_taskaction_t action, void *arg) argument
239 isc_socket_fdwatchcreate(isc_socketmgr_t *manager, int fd, int flags, isc_sockfdwatch_t callback, void *cbarg, isc_task_t *task, isc_socket_t **socketp) argument
305 isc_socket_recvv(isc_socket_t *sock, isc_bufferlist_t *buflist, unsigned int minimum, isc_task_t *task, isc_taskaction_t action, void *arg) argument
313 isc_socket_recv2(isc_socket_t *sock, isc_region_t *region, unsigned int minimum, isc_task_t *task, isc_socketevent_t *event, unsigned int flags) argument
321 isc_socket_send(isc_socket_t *sock, isc_region_t *region, isc_task_t *task, isc_taskaction_t action, void *arg) argument
328 isc_socket_sendv(isc_socket_t *sock, isc_bufferlist_t *buflist, isc_task_t *task, isc_taskaction_t action, void *arg) argument
335 isc_socket_sendtov(isc_socket_t *sock, isc_bufferlist_t *buflist, isc_task_t *task, isc_taskaction_t action, void *arg, isc_sockaddr_t *address, struct in6_pktinfo *pktinfo) argument
344 isc_socket_sendtov2(isc_socket_t *sock, isc_bufferlist_t *buflist, isc_task_t *task, isc_taskaction_t action, void *arg, isc_sockaddr_t *address, struct in6_pktinfo *pktinfo, unsigned int flags) argument
354 isc_socket_sendto2(isc_socket_t *sock, isc_region_t *region, isc_task_t *task, isc_sockaddr_t *address, struct in6_pktinfo *pktinfo, isc_socketevent_t *event, unsigned int flags) argument
386 isc_socket_accept(isc_socket_t *sock, isc_task_t *task, isc_taskaction_t action, void *arg) argument
[all...]
H A Dratelimiter.c15 #include <isc/task.h>
31 isc_task_t * task; member in struct:isc_ratelimiter
44 ratelimiter_tick(isc_task_t *task, isc_event_t *event);
47 ratelimiter_shutdowncomplete(isc_task_t *task, isc_event_t *event);
51 isc_task_t *task, isc_ratelimiter_t **ratelimiterp)
62 rl->task = task;
75 NULL, NULL, rl->task, ratelimiter_tick,
140 isc_ratelimiter_enqueue(isc_ratelimiter_t *rl, isc_task_t *task, argument
147 REQUIRE(task !
50 isc_ratelimiter_create(isc_mem_t *mctx, isc_timermgr_t *timermgr, isc_task_t *task, isc_ratelimiter_t **ratelimiterp) argument
196 ratelimiter_tick(isc_task_t *task, isc_event_t *event) argument
240 isc_task_t *task; local
267 ratelimiter_shutdowncomplete(isc_task_t *task, isc_event_t *event) argument
[all...]
/bind-9.11.3/lib/isc/include/isc/
H A Dtask.h18 /*! \file isc/task.h
19 * \brief The task system provides a lightweight execution context, which is
22 * When a task's event queue is non-empty, the
23 * task is runnable. A small work crew of threads, typically one per CPU,
47 * Events which have been queued for a task but not delivered may be removed
48 * from the task's event queue by purging or unsending.
101 /*% Task and task manager methods */
110 void (*setexcltask)(isc_taskmgr_t *mgr, isc_task_t *task);
118 void (*send)(isc_task_t *task, isc_event_t **eventp);
120 unsigned int (*unsend)(isc_task_t *task, voi
[all...]
H A Dondestroy.h47 * X_ondestroy(X *instance, isc_task_t *task,
49 * return(isc_ondestroy_register(&instance->ondest, task,eventp));
85 isc_ondestroy_register(isc_ondestroy_t *ondest, isc_task_t *task,
89 * Stores task and *eventp away inside *ondest. Ownership of **event is
90 * taken from the caller (and *eventp is set to NULL). The task is attached
97 * Dispatches the event(s) to the task(s) that were given in
H A Dratelimiter.h39 isc_task_t *task, isc_ratelimiter_t **ratelimiterp);
69 isc_ratelimiter_enqueue(isc_ratelimiter_t *rl, isc_task_t *task,
75 * to doing an isc_task_send() to the 'task', except that the
79 * '(*eventp)->ev_sender' is used to hold the task. The caller
80 * must ensure that the task exists until the event is delivered.
86 *\li 'task' to be non NULL.
107 * dispatched to the task are dispatched immediately with
113 *\li The rate limiter is no longer attached to its task.
H A Dsocket.h20 * sources in the task system.
23 * event queue of the task which requested the I/O.
28 * Clients of this module must not be holding a socket's task's lock when
331 void *cbarg, isc_task_t *task,
342 isc_task_t *task, isc_taskaction_t action,
346 isc_task_t *task, isc_sockaddr_t *address,
351 isc_task_t *task, isc_taskaction_t action,
354 unsigned int minimum, isc_task_t *task,
357 unsigned int minimum, isc_task_t *task,
359 void (*cancel)(isc_socket_t *sock, isc_task_t *task,
[all...]
/bind-9.11.3/bin/tests/
H A Dshutdown_test.c20 #include <isc/task.h>
27 isc_task_t * task; member in struct:__anon41
46 t1_shutdown(isc_task_t *task, isc_event_t *event) { argument
49 printf("task %s (%p) t1_shutdown\n", info->name, task);
50 isc_task_detach(&info->task);
55 t2_shutdown(isc_task_t *task, isc_event_t *event) { argument
58 printf("task %s (%p) t2_shutdown\n", info->name, task);
64 shutdown_action(isc_task_t *task, isc_event_ argument
84 foo_event(isc_task_t *task, isc_event_t *event) argument
90 tick(isc_task_t *task, isc_event_t *event) argument
165 isc_task_t *task; local
[all...]
H A Dratelimiter_test.c16 #include <isc/task.h>
28 static void utick(isc_task_t *task, isc_event_t *event);
29 static void shutdown_rl(isc_task_t *task, isc_event_t *event);
30 static void shutdown_all(isc_task_t *task, isc_event_t *event);
54 ltick(isc_task_t *task, isc_event_t *event) { argument
55 UNUSED(task);
63 utick(isc_task_t *task, isc_event_t *event) { argument
65 UNUSED(task);
74 shutdown_rl(isc_task_t *task, isc_event_t *event) { argument
75 UNUSED(task);
82 shutdown_all(isc_task_t *task, isc_event_t *event) argument
[all...]
H A Dsock_test.c21 #include <isc/task.h>
29 my_shutdown(isc_task_t *task, isc_event_t *event) { argument
32 printf("shutdown %s (%p)\n", name, task);
38 my_send(isc_task_t *task, isc_event_t *event) { argument
45 printf("my_send: %s task %p\n\t(sock %p, base %p, length %d, n %d, "
47 (char *)(event->ev_arg), task, sock,
53 isc_task_shutdown(task);
63 my_recv(isc_task_t *task, isc_event_t *event) { argument
96 isc_task_shutdown(task);
113 isc_socket_send(sock, &region, task, my_sen
126 my_http_get(isc_task_t *task, isc_event_t *event) argument
154 my_connect(isc_task_t *task, isc_event_t *event) argument
194 my_listen(isc_task_t *task, isc_event_t *event) argument
243 timeout(isc_task_t *task, isc_event_t *event) argument
[all...]
H A Dtimer_test.c19 #include <isc/task.h>
30 shutdown_task(isc_task_t *task, isc_event_t *event) { argument
33 printf("task %p shutdown %s\n", task, name);
38 tick(isc_task_t *task, isc_event_t *event) { argument
43 printf("task %s (%p) tick\n", name, task);
66 timeout(isc_task_t *task, isc_event_t *event) { argument
77 printf("task %s (%p) %s timeout\n", name, task, typ
[all...]
/bind-9.11.3/bin/tests/system/dyndb/driver/
H A Dlock.c7 #include <isc/task.h>
13 * Lock BIND dispatcher and allow only single task to run.
16 * All calls to isc_task_beginexclusive() have to operate on the same task
19 * For this reason this wrapper function always works with inst->task.
20 * As a result, this function have to be be called only from inst->task.
29 * @param[in] inst The instance with the only task which is allowed to run.
37 *statep = isc_task_beginexclusive(inst->task);
42 * Exit task-exclusive mode.
50 isc_task_endexclusive(inst->task);
/bind-9.11.3/lib/dns/
H A Dtcpmsg.c17 #include <isc/task.h>
39 recv_length(isc_task_t *task, isc_event_t *ev_in) { argument
79 task, recv_message, tcpmsg);
89 isc_task_send(tcpmsg->task, &dev);
90 tcpmsg->task = NULL;
96 recv_message(isc_task_t *task, isc_event_t *ev_in) { argument
101 (void)task;
119 isc_task_send(tcpmsg->task, &dev);
120 tcpmsg->task = NULL;
137 tcpmsg->task
155 dns_tcpmsg_readmessage(dns_tcpmsg_t *tcpmsg, isc_task_t *task, isc_taskaction_t action, void *arg) argument
[all...]
H A Dbyaddr.c19 #include <isc/task.h>
116 isc_task_t * task; member in struct:dns_byaddr
166 lookup_done(isc_task_t *task, isc_event_t *event) { argument
173 REQUIRE(byaddr->task == task);
175 UNUSED(task);
185 isc_task_sendanddetach(&byaddr->task, (isc_event_t **)&byaddr->event);
211 unsigned int options, isc_task_t *task,
236 byaddr->task = NULL;
237 isc_task_attach(task,
210 dns_byaddr_create(isc_mem_t *mctx, isc_netaddr_t *address, dns_view_t *view, unsigned int options, isc_task_t *task, isc_taskaction_t action, void *arg, dns_byaddr_t **byaddrp) argument
[all...]
/bind-9.11.3/lib/isccc/
H A Dccmsg.c31 #include <isc/task.h>
45 recv_length(isc_task_t *task, isc_event_t *ev_in) { argument
83 task, recv_message, ccmsg);
93 isc_task_send(ccmsg->task, &dev);
94 ccmsg->task = NULL;
100 recv_message(isc_task_t *task, isc_event_t *ev_in) { argument
105 (void)task;
121 isc_task_send(ccmsg->task, &dev);
122 ccmsg->task = NULL;
139 ccmsg->task
156 isccc_ccmsg_readmessage(isccc_ccmsg_t *ccmsg, isc_task_t *task, isc_taskaction_t action, void *arg) argument
[all...]
/bind-9.11.3/lib/dns/include/dns/
H A Drequest.h70 *\li 'taskmgr' is a valid task manager.
90 dns_requestmgr_whenshutdown(dns_requestmgr_t *requestmgr, isc_task_t *task,
93 * Send '*eventp' to 'task' when 'requestmgr' has completed shutdown.
104 *\li 'task' is a valid task.
160 unsigned int timeout, isc_task_t *task,
178 * because it was canceled, a completion event will be sent to 'task'.
188 *\li 'task' is a valid task.
198 unsigned int timeout, isc_task_t *task,
[all...]
H A Dtcpmsg.h28 isc_task_t *task; member in struct:dns_tcpmsg
72 isc_task_t *task, isc_taskaction_t action, void *arg);
81 *\li "task", "taskaction", and "arg" be valid.
H A Dxfrin.h51 isc_socketmgr_t *socketmgr, isc_task_t *task,
59 isc_task_t *task, dns_xfrindone_t done,
67 isc_task_t *task, dns_xfrindone_t done,
75 * called in the context of 'task', with 'zone' and a result
/bind-9.11.3/bin/tests/tasks/
H A Dt_tasks.c21 #include <isc/task.h>
45 t1_callback(isc_task_t *task, isc_event_t *event) { argument
49 UNUSED(task);
56 t_info("task %s\n", (char *)event->ev_arg);
61 t1_shutdown(isc_task_t *task, isc_event_t *event) { argument
63 UNUSED(task);
70 my_tick(isc_task_t *task, isc_event_t *event) { argument
72 UNUSED(task);
224 * structure (socket, timer, task, etc) but this is just a test
383 static const char *a1 = "The task subsyste
407 t2_shutdown(isc_task_t *task, isc_event_t *event) argument
444 t2_callback(isc_task_t *task, isc_event_t *event) argument
604 t3_sde1(isc_task_t *task, isc_event_t *event) argument
622 t3_sde2(isc_task_t *task, isc_event_t *event) argument
640 t3_event1(isc_task_t *task, isc_event_t *event) argument
665 t3_event2(isc_task_t *task, isc_event_t *event) argument
679 isc_task_t *task; local
869 t4_event1(isc_task_t *task, isc_event_t *event) argument
894 t4_sde(isc_task_t *task, isc_event_t *event) argument
910 isc_task_t *task; local
1081 t7_event1(isc_task_t *task, isc_event_t *event) argument
1090 t7_sde(isc_task_t *task, isc_event_t *event) argument
1127 isc_task_t *task; local
1321 t10_event1(isc_task_t *task, isc_event_t *event) argument
1353 t10_event2(isc_task_t *task, isc_event_t *event) argument
1412 t10_sde(isc_task_t *task, isc_event_t *event) argument
1451 isc_task_t *task; local
1799 t11_event1(isc_task_t *task, isc_event_t *event) argument
1831 t11_event2(isc_task_t *task, isc_event_t *event) argument
1840 t11_sde(isc_task_t *task, isc_event_t *event) argument
1876 isc_task_t *task; local
2226 t14_callback(isc_task_t *task, isc_event_t *event) argument
[all...]
/bind-9.11.3/lib/dns/tests/
H A Ddispatch_test.c20 #include <isc/task.h>
141 senddone(isc_task_t *task, isc_event_t *event) { argument
144 UNUSED(task);
151 nameserver(isc_task_t *task, isc_event_t *event) { argument
175 result = isc_socket_sendto(sock, &region, task, senddone, sock,
187 result = isc_socket_sendto(sock, &region, task, senddone, sock,
202 response(isc_task_t *task, isc_event_t *event) { argument
207 UNUSED(task);
225 startit(isc_task_t *task, isc_event_t *event) { argument
230 result = isc_socket_sendto(sock, event->ev_arg, task, senddon
244 isc_task_t *task = NULL; local
[all...]
/bind-9.11.3/lib/isc/tests/
H A Dtask_test.c19 #include <isc/task.h>
29 /* task event handler, sets a boolean to true */
34 set(isc_task_t *task, isc_event_t *event) { argument
37 UNUSED(task);
46 set_and_drop(isc_task_t *task, isc_event_t *event) { argument
49 UNUSED(task);
63 /* Create a task */
66 atf_tc_set_md_var(tc, "descr", "create and destroy a task");
70 isc_task_t *task = NULL; local
77 result = isc_task_create(taskmgr, 0, &task);
93 isc_task_t *task = NULL; local
[all...]
/bind-9.11.3/lib/isccc/include/isccc/
H A Dccmsg.h43 isc_task_t *task; member in struct:isccc_ccmsg
87 isc_task_t *task, isc_taskaction_t action, void *arg);
96 *\li "task", "taskaction", and "arg" be valid.
/bind-9.11.3/bin/tests/system/tkey/
H A Dkeydelete.c25 #include <isc/task.h>
62 recvquery(isc_task_t *task, isc_event_t *event) { argument
67 UNUSED(task);
106 sendquery(isc_task_t *task, isc_event_t *event) { argument
130 task, recvquery, query, &request);
151 isc_task_t *task; local
181 task = NULL;
182 RUNCHECK(isc_task_create(taskmgr, 0, &task));
219 RUNCHECK(isc_app_onrun(mctx, task, sendquery, NULL));
243 isc_task_shutdown(task);
[all...]
/bind-9.11.3/bin/named/
H A Dlwdclient.c17 #include <isc/task.h>
32 lwdclientmgr_shutdown_callback(isc_task_t *task, isc_event_t *ev);
70 cm->task = NULL;
99 result = isc_task_create(taskmgr, 0, &cm->task);
102 isc_task_setname(cm->task, "lwdclient", NULL);
107 result = isc_task_onshutdown(cm->task, lwdclientmgr_shutdown_callback,
124 if (cm->task != NULL)
125 isc_task_detach(&cm->task);
172 isc_task_detach(&cm->task);
226 ns_lwdclient_recv(isc_task_t *task, isc_event_ argument
354 lwdclientmgr_shutdown_callback(isc_task_t *task, isc_event_t *ev) argument
442 ns_lwdclient_send(isc_task_t *task, isc_event_t *ev) argument
[all...]

Completed in 33 milliseconds

123456