Home
last modified time | relevance | path

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

12

/NextBSD/contrib/ntp/lib/isc/include/isc/
HDtask.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);
124 void (*send)(isc_task_t *task, isc_event_t **eventp);
125 void (*sendanddetach)(isc_task_t **taskp, isc_event_t **eventp);
126 unsigned int (*unsend)(isc_task_t *task, void *sender, isc_eventtype_t type,
128 isc_result_t (*onshutdown)(isc_task_t *task, isc_taskaction_t action,
130 void (*shutdown)(isc_task_t *task);
131 void (*setname)(isc_task_t *task, const char *name, void *tag);
[all …]
HDsocket.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,
670 isc_task_t *task, isc_taskaction_t action, const void *arg);
693 isc_task_t *task, isc_taskaction_t action,
761 isc_task_t *task, isc_taskaction_t action, const void *arg);
[all …]
HDtypes.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);
HDratelimiter.h48 isc_task_t *task, isc_ratelimiter_t **ratelimiterp);
71 isc_ratelimiter_enqueue(isc_ratelimiter_t *rl, isc_task_t *task,
HDtimer.h113 isc_task_t *task,
173 isc_task_t *task,
HDondestroy.h94 isc_ondestroy_register(isc_ondestroy_t *ondest, isc_task_t *task,
HDtaskpool.h87 isc_taskpool_gettask(isc_taskpool_t *pool, isc_task_t **targetp);
HDhttpd.h40 isc_httpdmgr_create(isc_mem_t *mctx, isc_socket_t *sock, isc_task_t *task,
HDapp.h160 isc_app_onrun(isc_mem_t *mctx, isc_task_t *task, isc_taskaction_t action,
/NextBSD/contrib/ntp/lib/isc/
HDtask_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()
166 isc_task_unsend(isc_task_t *task, void *sender, isc_eventtype_t type, in isc_task_unsend()
175 isc_task_onshutdown(isc_task_t *task, isc_taskaction_t action, const void *arg) in isc_task_onshutdown()
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()
197 isc_task_purge(isc_task_t *task, void *sender, isc_eventtype_t type, void *tag) in isc_task_purge()
[all …]
HDtask.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);
190 isc__task_send(isc_task_t *task0, isc_event_t **eventp);
192 isc__task_sendanddetach(isc_task_t **taskp, isc_event_t **eventp);
194 isc__task_purgerange(isc_task_t *task0, void *sender, isc_eventtype_t first,
197 isc__task_purge(isc_task_t *task, void *sender, isc_eventtype_t type,
200 isc__task_purgeevent(isc_task_t *task0, isc_event_t *event);
202 isc__task_unsendrange(isc_task_t *task, void *sender, isc_eventtype_t first,
[all …]
HDratelimiter.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()
HDondestroy.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()
HDsocket_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()
HDtaskpool.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()
HDhttpd.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()
HDtimer_api.c100 isc_task_t *task, isc_taskaction_t action, const void *arg, in isc_timer_create()
HDtimer.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()
/NextBSD/contrib/ntp/lib/isc/tests/
HDtask_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()
HDsocket_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()
HDtaskpool_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()
/NextBSD/contrib/ntp/lib/isc/win32/
HDapp.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()
HDsocket.c370 static void queue_receive_event(isc_socket_t *sock, isc_task_t *task, isc_socketevent_t *dev);
1923 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()
2740 queue_receive_event(isc_socket_t *sock, isc_task_t *task, isc_socketevent_t *dev) in queue_receive_event()
2742 isc_task_t *ntask = NULL; in queue_receive_event()
2766 socket_recv(isc_socket_t *sock, isc_socketevent_t *dev, isc_task_t *task, in socket_recv()
2770 isc_task_t *ntask = NULL; in socket_recv()
2802 unsigned int minimum, isc_task_t *task, in isc__socket_recvv()
[all …]
/NextBSD/contrib/ntp/lib/isc/unix/
HDsocket.c352 isc_task_t *fdwatchtask;
442 static void internal_accept(isc_task_t *, isc_event_t *);
443 static void internal_connect(isc_task_t *, isc_event_t *);
444 static void internal_recv(isc_task_t *, isc_event_t *);
445 static void internal_send(isc_task_t *, isc_event_t *);
446 static void internal_fdwatch_write(isc_task_t *, isc_event_t *);
447 static void internal_fdwatch_read(isc_task_t *, isc_event_t *);
483 unsigned int minimum, isc_task_t *task,
487 unsigned int minimum, isc_task_t *task,
491 unsigned int minimum, isc_task_t *task,
[all …]
HDapp.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