Home
last modified time | relevance | path

Searched refs:isc_task_t (Results 1 – 25 of 27) sorted by relevance

12

/freebsd-12.1/contrib/ntp/lib/isc/include/isc/
H A Dtask.h117 isc_task_t **taskp);
121 void (*attach)(isc_task_t *source, isc_task_t **targetp);
122 void (*detach)(isc_task_t **taskp);
123 void (*destroy)(isc_task_t **taskp);
130 void (*shutdown)(isc_task_t *task);
178 isc_task_t **taskp);
212 isc_task_attach(isc_task_t *source, isc_task_t **targetp);
228 isc_task_detach(isc_task_t **taskp);
541 isc_task_getname(isc_task_t *task);
559 isc_task_gettag(isc_task_t *task);
[all …]
H A Dsocket.h272 void *cbarg, isc_task_t *task,
283 isc_task_t *task, isc_taskaction_t action,
287 isc_task_t *task, isc_taskaction_t action,
290 unsigned int minimum, isc_task_t *task,
292 void (*cancel)(isc_socket_t *sock, isc_task_t *task,
358 isc_task_t *task,
462 isc_socket_cancel(isc_socket_t *sock, isc_task_t *task,
693 isc_task_t *task, isc_taskaction_t action,
761 isc_task_t *task, isc_taskaction_t action, const void *arg);
769 unsigned int minimum, isc_task_t *task,
[all …]
H A Dtypes.h93 typedef struct isc_task isc_task_t; /*%< Task */ typedef
94 typedef ISC_LIST(isc_task_t) isc_tasklist_t; /*%< Task List */
101 typedef void (*isc_taskaction_t)(isc_task_t *, isc_event_t *);
102 typedef int (*isc_sockfdwatch_t)(isc_task_t *, isc_socket_t *, void *, int);
H A Dratelimiter.h48 isc_task_t *task, isc_ratelimiter_t **ratelimiterp);
71 isc_ratelimiter_enqueue(isc_ratelimiter_t *rl, isc_task_t *task,
H A Dtimer.h113 isc_task_t *task,
173 isc_task_t *task,
H A Dondestroy.h94 isc_ondestroy_register(isc_ondestroy_t *ondest, isc_task_t *task,
H A Dtaskpool.h87 isc_taskpool_gettask(isc_taskpool_t *pool, isc_task_t **targetp);
H A Dhttpd.h40 isc_httpdmgr_create(isc_mem_t *mctx, isc_socket_t *sock, isc_task_t *task,
H A Dapp.h160 isc_app_onrun(isc_mem_t *mctx, isc_task_t *task, isc_taskaction_t action,
/freebsd-12.1/contrib/ntp/lib/isc/
H A Dtask_api.c118 isc_task_t **taskp) in isc_task_create()
127 isc_task_attach(isc_task_t *source, isc_task_t **targetp) { in isc_task_attach()
137 isc_task_detach(isc_task_t **taskp) { in isc_task_detach()
146 isc_task_send(isc_task_t *task, isc_event_t **eventp) { in isc_task_send()
156 isc_task_sendanddetach(isc_task_t **taskp, isc_event_t **eventp) { in isc_task_sendanddetach()
183 isc_task_shutdown(isc_task_t *task) { in isc_task_shutdown()
190 isc_task_setname(isc_task_t *task, const char *name, void *tag) { in isc_task_setname()
205 isc_task_beginexclusive(isc_task_t *task) { in isc_task_beginexclusive()
212 isc_task_endexclusive(isc_task_t *task) { in isc_task_endexclusive()
219 isc_task_setprivilege(isc_task_t *task, isc_boolean_t priv) { in isc_task_setprivilege()
[all …]
H A Dtask.c105 isc_task_t common;
184 isc_task_t **taskp);
186 isc__task_attach(isc_task_t *source0, isc_task_t **targetp);
188 isc__task_detach(isc_task_t **taskp);
220 isc__task_gettag(isc_task_t *task0);
330 isc_task_t **taskp) in isc__task_create()
386 *taskp = (isc_task_t *)task; in isc__task_create()
392 isc__task_attach(isc_task_t *source0, isc_task_t **targetp) { in isc__task_attach()
408 *targetp = (isc_task_t *)source; in isc__task_attach()
1114 (isc_task_t *)task, in dispatch()
[all …]
H A Dratelimiter.c42 isc_task_t * task;
54 ratelimiter_tick(isc_task_t *task, isc_event_t *event);
57 ratelimiter_shutdowncomplete(isc_task_t *task, isc_event_t *event);
61 isc_task_t *task, isc_ratelimiter_t **ratelimiterp) in isc_ratelimiter_create()
133 isc_ratelimiter_enqueue(isc_ratelimiter_t *rl, isc_task_t *task, in isc_ratelimiter_enqueue()
169 ratelimiter_tick(isc_task_t *task, isc_event_t *event) { in ratelimiter_tick()
203 isc_task_t *evtask = p->ev_sender; in ratelimiter_tick()
213 isc_task_t *task; in isc_ratelimiter_shutdown()
236 ratelimiter_shutdowncomplete(isc_task_t *task, isc_event_t *event) { in ratelimiter_shutdowncomplete()
H A Dondestroy.c42 isc_ondestroy_register(isc_ondestroy_t *ondest, isc_task_t *task, in isc_ondestroy_register()
46 isc_task_t *thetask = NULL; in isc_ondestroy_register()
68 isc_task_t *task; in isc_ondestroy_notify()
H A Dsocket_api.c133 isc_socket_sendto(isc_socket_t *sock, isc_region_t *region, isc_task_t *task, in isc_socket_sendto()
144 isc_socket_connect(isc_socket_t *sock, isc_sockaddr_t *addr, isc_task_t *task, in isc_socket_connect()
154 isc_task_t *task, isc_taskaction_t action, const void *arg) in isc_socket_recv()
162 isc_socket_cancel(isc_socket_t *sock, isc_task_t *task, unsigned int how) { in isc_socket_cancel()
201 isc_task_t *task, isc_socket_t **socketp) in isc_socket_fdwatchcreate()
H A Dtaskpool.c38 isc_task_t ** tasks;
59 pool->tasks = isc_mem_get(mctx, ntasks * sizeof(isc_task_t *)); in alloc_pool()
102 isc_taskpool_gettask(isc_taskpool_t *pool, isc_task_t **targetp) { in isc_taskpool_gettask()
170 pool->ntasks * sizeof(isc_task_t *)); in isc_taskpool_destroy()
H A Dhttpd.c140 isc_task_t *task; /*%< owning task */
212 static void isc_httpd_accept(isc_task_t *, isc_event_t *);
213 static void isc_httpd_recvdone(isc_task_t *, isc_event_t *);
214 static void isc_httpd_senddone(isc_task_t *, isc_event_t *);
256 isc_httpdmgr_create(isc_mem_t *mctx, isc_socket_t *sock, isc_task_t *task, in isc_httpdmgr_create()
516 isc_httpd_accept(isc_task_t *task, isc_event_t *ev) in isc_httpd_accept()
660 isc_httpd_recvdone(isc_task_t *task, isc_event_t *ev) in isc_httpd_recvdone()
915 isc_httpd_senddone(isc_task_t *task, isc_event_t *ev) in isc_httpd_senddone()
H A Dtimer_api.c100 isc_task_t *task, isc_taskaction_t action, const void *arg, in isc_timer_create()
H A Dtimer.c89 isc_task_t * task;
134 isc_task_t *task, isc_taskaction_t action, const void *arg,
396 isc_task_t *task, isc_taskaction_t action, const void *arg, in isc__timer_create()
/freebsd-12.1/contrib/ntp/lib/isc/tests/
H A Dtask_test.c42 set(isc_task_t *task, isc_event_t *event) { in set()
54 set_and_drop(isc_task_t *task, isc_event_t *event) { in set_and_drop()
78 isc_task_t *task = NULL; in ATF_TC_BODY()
101 isc_task_t *task = NULL; in ATF_TC_BODY()
158 isc_task_t *task1 = NULL, *task2 = NULL; in ATF_TC_BODY()
287 isc_task_t *task1 = NULL, *task2 = NULL; in ATF_TC_BODY()
H A Dsocket_test.c47 event_done(isc_task_t *task, isc_event_t *event) { in event_done()
88 isc_task_t *task = NULL; in ATF_TC_BODY()
159 isc_task_t *task = NULL; in ATF_TC_BODY()
H A Dtaskpool_test.c120 isc_task_t *task1 = NULL, *task2 = NULL, *task3 = NULL; in ATF_TC_BODY()
159 isc_task_t *task1 = NULL, *task2 = NULL, *task3 = NULL; in ATF_TC_BODY()
/freebsd-12.1/contrib/ntp/lib/isc/win32/
H A Dapp.c102 isc__app_onrun(isc_mem_t *mctx, isc_task_t *task, isc_taskaction_t action, in isc__app_onrun()
105 isc_task_t *cloned_task = NULL; in isc__app_onrun()
138 isc_task_t *task; in isc__app_run()
H A Dsocket.c1923 isc_task_t *task; in send_recvdone_event()
1945 isc_task_t *task; in send_senddone_event()
1969 isc_task_t *task; in send_acceptdone_event()
1989 isc_task_t *task; in send_connectdone_event()
2742 isc_task_t *ntask = NULL; in queue_receive_event()
2770 isc_task_t *ntask = NULL; in socket_recv()
2963 isc_task_t *ntask = NULL; in socket_send()
3137 isc_task_t *task, in isc__socket_sendto2()
3307 isc_task_t *ntask = NULL; in isc__socket_accept()
3425 isc_task_t *ntask = NULL; in isc__socket_connect()
[all …]
/freebsd-12.1/contrib/ntp/lib/isc/unix/
H A Dsocket.c352 isc_task_t *fdwatchtask;
509 isc_task_t *task,
2906 isc_task_t *sender; in dispatch_recv()
2940 isc_task_t *sender; in dispatch_send()
3031 isc_task_t *task; in send_recvdone_event()
3054 isc_task_t *task; in send_senddone_event()
3087 isc_task_t *task; in internal_accept()
4467 isc_task_t *ntask = NULL; in socket_recv()
4648 isc_task_t *ntask = NULL; in socket_send()
4822 isc_task_t *task, in isc__socket_sendto2()
[all …]
H A Dapp.c88 isc_task_t *task,
387 isc__app_onrun(isc_mem_t *mctx, isc_task_t *task, isc_taskaction_t action, in isc__app_onrun()
391 isc_task_t *cloned_task = NULL; in isc__app_onrun()
571 isc_task_t *task; in isc__app_ctxrun()

12