/freebsd-9.3-release/sys/ofed/include/linux/ |
H A D | kthread.h | 44 struct task_struct *task; local 46 task = arg; 47 task_struct_set(curthread, task); 48 if (task->should_stop == 0) 49 task->task_ret = task->task_fn(task->task_data); 50 PROC_LOCK(task->task_thread->td_proc); 51 task->should_stop = TASK_STOPPED; 52 wakeup(task); 60 struct task_struct *task; local 91 kthread_stop(struct task_struct *task) argument [all...] |
/freebsd-9.3-release/sys/sys/ |
H A D | _task.h | 35 * Each task includes a function which is called from 37 * field of struct task and the second argument is a count of how many 38 * times the task was enqueued before the call to taskqueue_run(). 46 struct task { struct 47 STAILQ_ENTRY(task) ta_link; /* (q) link for queue */ 50 task_fn_t *ta_func; /* (c) task handler */
|
H A D | taskqueue.h | 45 struct task t; 64 int taskqueue_enqueue(struct taskqueue *queue, struct task *task); 67 int taskqueue_cancel(struct taskqueue *queue, struct task *task, 71 void taskqueue_drain(struct taskqueue *queue, struct task *task); 94 * Initialise a task structure. 96 #define TASK_INIT(task, priority, func, context) do { \ 97 (task) [all...] |
/freebsd-9.3-release/contrib/bind9/lib/isc/ |
H A D | task_api.c | 27 #include <isc/task.h> 146 isc_task_send(isc_task_t *task, isc_event_t **eventp) { argument 147 REQUIRE(ISCAPI_TASK_VALID(task)); 150 task->methods->send(task, eventp); 166 isc_task_unsend(isc_task_t *task, void *sender, isc_eventtype_t type, argument 169 REQUIRE(ISCAPI_TASK_VALID(task)); 171 return (task->methods->unsend(task, sender, type, tag, events)); 175 isc_task_onshutdown(isc_task_t *task, isc_taskaction_ argument 183 isc_task_shutdown(isc_task_t *task) argument 190 isc_task_setname(isc_task_t *task, const char *name, void *tag) argument 197 isc_task_purge(isc_task_t *task, void *sender, isc_eventtype_t type, void *tag) argument 205 isc_taskmgr_setexcltask(isc_taskmgr_t *mgr, isc_task_t *task) argument 216 isc_task_beginexclusive(isc_task_t *task) argument 223 isc_task_endexclusive(isc_task_t *task) argument 230 isc_task_setprivilege(isc_task_t *task, isc_boolean_t priv) argument 237 isc_task_privilege(isc_task_t *task) argument 249 isc_task_purgerange(isc_task_t *task, void *sender, isc_eventtype_t first, isc_eventtype_t last, void *tag) argument [all...] |
H A D | task.c | 25 * XXXRTH Need to document the states a task can be in, and the rules 38 #include <isc/task.h> 51 * when built without threads we share a single global task manager and use 52 * an integrated event loop for socket, timer, and other generic task events. 54 * we don't use either of them: an application can have multiple task managers 70 #define XTRACE(m) fprintf(stderr, "task %p thread %lu: %s\n", \ 71 task, isc_thread_self(), (m)) 72 #define XTTRACE(t, m) fprintf(stderr, "task %p thread %lu: %s\n", \ 108 /* Locked by task lock. */ 118 /* Locked by task manage 304 task_finished(isc__task_t *task) argument 340 isc__task_t *task; local 415 task_shutdown(isc__task_t *task) argument 458 task_ready(isc__task_t *task) argument 479 task_detach(isc__task_t *task) argument 509 isc__task_t *task; local 533 task_send(isc__task_t *task, isc_event_t **eventp) argument 564 isc__task_t *task = (isc__task_t *)task0; local 607 isc__task_t *task; local 641 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 684 isc__task_t *task = (isc__task_t *)task0; local 713 isc__task_purge(isc_task_t *task, void *sender, isc_eventtype_t type, void *tag) argument 727 isc__task_t *task = (isc__task_t *)task0; local 769 isc__task_unsendrange(isc_task_t *task, void *sender, isc_eventtype_t first, isc_eventtype_t last, void *tag, isc_eventlist_t *events) argument 784 isc__task_unsend(isc_task_t *task, void *sender, isc_eventtype_t type, void *tag, isc_eventlist_t *events) argument 801 isc__task_t *task = (isc__task_t *)task0; local 839 isc__task_t *task = (isc__task_t *)task0; local 871 isc__task_t *task = (isc__task_t *)task0; local 888 isc__task_t *task = (isc__task_t *)task0; local 897 isc__task_t *task = (isc__task_t *)task0; local 906 isc__task_t *task = (isc__task_t *)task0; local 949 isc__task_t *task; local 973 push_readyq(isc__taskmgr_t *manager, isc__task_t *task) argument 982 isc__task_t *task; local 1458 isc__task_t *task; local 1649 isc__task_t *task = (isc__task_t *) task0; local 1675 isc__task_t *task = (isc__task_t *)task0; local 1700 isc__task_t *task = (isc__task_t *)task0; local 1716 isc__task_t *task = (isc__task_t *)task0; local 1743 isc__task_t *task = (isc__task_t *)task0; local 1761 isc__task_t *task = (isc__task_t *)t; local 1773 isc__task_t *task = NULL; local [all...] |
H A D | ondestroy.c | 29 #include <isc/task.h> 42 isc_ondestroy_register(isc_ondestroy_t *ondest, isc_task_t *task, argument 49 REQUIRE(task != NULL); 56 isc_task_attach(task, &thetask); 68 isc_task_t *task; local 76 task = eventp->ev_sender; 79 isc_task_sendanddetach(&task, &eventp);
|
H A D | ratelimiter.c | 26 #include <isc/task.h> 42 isc_task_t * task; member in struct:isc_ratelimiter 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) 72 rl->task = task; 83 NULL, NULL, rl->task, ratelimiter_tick, 133 isc_ratelimiter_enqueue(isc_ratelimiter_t *rl, isc_task_t *task, argument 140 REQUIRE(task ! 60 isc_ratelimiter_create(isc_mem_t *mctx, isc_timermgr_t *timermgr, isc_task_t *task, isc_ratelimiter_t **ratelimiterp) argument 169 ratelimiter_tick(isc_task_t *task, isc_event_t *event) argument 213 isc_task_t *task; local 236 ratelimiter_shutdowncomplete(isc_task_t *task, isc_event_t *event) argument [all...] |
H A D | socket_api.c | 133 isc_socket_sendto(isc_socket_t *sock, isc_region_t *region, isc_task_t *task, argument 139 return (sock->methods->sendto(sock, region, task, action, arg, address, 145 isc_task_t *task, isc_sockaddr_t *address, 151 return (sock->methods->sendto2(sock, region, task, address, 156 isc_socket_connect(isc_socket_t *sock, isc_sockaddr_t *addr, isc_task_t *task, argument 161 return (sock->methods->connect(sock, addr, task, action, arg)); 166 isc_task_t *task, isc_taskaction_t action, const void *arg) 170 return (sock->methods->recv(sock, region, minimum, task, action, arg)); 175 unsigned int minimum, isc_task_t *task, 180 return (sock->methods->recv2(sock, region, minimum, task, 144 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 165 isc_socket_recv(isc_socket_t *sock, isc_region_t *region, unsigned int minimum, isc_task_t *task, isc_taskaction_t action, const void *arg) argument 174 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 185 isc_socket_cancel(isc_socket_t *sock, isc_task_t *task, unsigned int how) argument 222 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 [all...] |
/freebsd-9.3-release/contrib/ntp/lib/isc/ |
H A D | task.c | 25 * XXXRTH Need to document the states a task can be in, and the rules 38 #include <isc/task.h> 51 * when built without threads we share a single global task manager and use 52 * an integrated event loop for socket, timer, and other generic task events. 54 * we don't use either of them: an application can have multiple task managers 70 #define XTRACE(m) fprintf(stderr, "task %p thread %lu: %s\n", \ 71 task, isc_thread_self(), (m)) 72 #define XTTRACE(t, m) fprintf(stderr, "task %p thread %lu: %s\n", \ 108 /* Locked by task lock. */ 118 /* Locked by task manage 297 task_finished(isc__task_t *task) argument 333 isc__task_t *task; local 412 task_shutdown(isc__task_t *task) argument 455 task_ready(isc__task_t *task) argument 476 task_detach(isc__task_t *task) argument 506 isc__task_t *task; local 530 task_send(isc__task_t *task, isc_event_t **eventp) argument 561 isc__task_t *task = (isc__task_t *)task0; local 604 isc__task_t *task; local 638 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 681 isc__task_t *task = (isc__task_t *)task0; local 710 isc__task_purge(isc_task_t *task, void *sender, isc_eventtype_t type, void *tag) argument 724 isc__task_t *task = (isc__task_t *)task0; local 766 isc__task_unsendrange(isc_task_t *task, void *sender, isc_eventtype_t first, isc_eventtype_t last, void *tag, isc_eventlist_t *events) argument 781 isc__task_unsend(isc_task_t *task, void *sender, isc_eventtype_t type, void *tag, isc_eventlist_t *events) argument 798 isc__task_t *task = (isc__task_t *)task0; local 836 isc__task_t *task = (isc__task_t *)task0; local 868 isc__task_t *task = (isc__task_t *)task0; local 885 isc__task_t *task = (isc__task_t *)task0; local 894 isc__task_t *task = (isc__task_t *)task0; local 903 isc__task_t *task = (isc__task_t *)task0; local 946 isc__task_t *task; local 970 push_readyq(isc__taskmgr_t *manager, isc__task_t *task) argument 979 isc__task_t *task; local 1458 isc__task_t *task; local 1643 isc__task_t *task = (isc__task_t *)task0; local 1665 isc__task_t *task = (isc__task_t *)task0; local 1681 isc__task_t *task = (isc__task_t *)task0; local 1708 isc__task_t *task = (isc__task_t *)task0; local 1726 isc__task_t *task = (isc__task_t *)t; local 1737 isc__task_t *task; local [all...] |
H A D | task_api.c | 27 #include <isc/task.h> 146 isc_task_send(isc_task_t *task, isc_event_t **eventp) { argument 147 REQUIRE(ISCAPI_TASK_VALID(task)); 150 task->methods->send(task, eventp); 166 isc_task_unsend(isc_task_t *task, void *sender, isc_eventtype_t type, argument 169 REQUIRE(ISCAPI_TASK_VALID(task)); 171 return (task->methods->unsend(task, sender, type, tag, events)); 175 isc_task_onshutdown(isc_task_t *task, isc_taskaction_ argument 183 isc_task_shutdown(isc_task_t *task) argument 190 isc_task_setname(isc_task_t *task, const char *name, void *tag) argument 197 isc_task_purge(isc_task_t *task, void *sender, isc_eventtype_t type, void *tag) argument 205 isc_task_beginexclusive(isc_task_t *task) argument 212 isc_task_endexclusive(isc_task_t *task) argument 219 isc_task_setprivilege(isc_task_t *task, isc_boolean_t priv) argument 226 isc_task_privilege(isc_task_t *task) argument 238 isc_task_purgerange(isc_task_t *task, void *sender, isc_eventtype_t first, isc_eventtype_t last, void *tag) argument [all...] |
H A D | ondestroy.c | 29 #include <isc/task.h> 42 isc_ondestroy_register(isc_ondestroy_t *ondest, isc_task_t *task, argument 49 REQUIRE(task != NULL); 56 isc_task_attach(task, &thetask); 68 isc_task_t *task; local 76 task = eventp->ev_sender; 79 isc_task_sendanddetach(&task, &eventp);
|
H A D | ratelimiter.c | 26 #include <isc/task.h> 42 isc_task_t * task; member in struct:isc_ratelimiter 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) 72 rl->task = task; 83 NULL, NULL, rl->task, ratelimiter_tick, 133 isc_ratelimiter_enqueue(isc_ratelimiter_t *rl, isc_task_t *task, argument 140 REQUIRE(task ! 60 isc_ratelimiter_create(isc_mem_t *mctx, isc_timermgr_t *timermgr, isc_task_t *task, isc_ratelimiter_t **ratelimiterp) argument 169 ratelimiter_tick(isc_task_t *task, isc_event_t *event) argument 213 isc_task_t *task; local 236 ratelimiter_shutdowncomplete(isc_task_t *task, isc_event_t *event) argument [all...] |
/freebsd-9.3-release/contrib/ntp/lib/isc/include/isc/ |
H A D | task.h | 27 /*! \file isc/task.h 28 * \brief The task system provides a lightweight execution context, which is 31 * When a task's event queue is non-empty, the 32 * task is runnable. A small work crew of threads, typically one per CPU, 56 * Events which have been queued for a task but not delivered may be removed 57 * from the task's event queue by purging or unsending. 109 /*% Task and task manager methods */ 124 void (*send)(isc_task_t *task, 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_ [all...] |
H A D | ondestroy.h | 56 * X_ondestroy(X *instance, isc_task_t *task, 58 * return(isc_ondestroy_register(&instance->ondest, task,eventp)); 94 isc_ondestroy_register(isc_ondestroy_t *ondest, isc_task_t *task, 98 * Stores task and *eventp away inside *ondest. Ownership of **event is 99 * taken from the caller (and *eventp is set to NULL). The task is attached 106 * Dispatches the event(s) to the task(s) that were given in
|
H A D | socket.h | 29 * sources in the task system. 32 * event queue of the task which requested the I/O. 37 * Clients of this module must not be holding a socket's task's lock when 272 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, [all...] |
/freebsd-9.3-release/sys/cddl/compat/opensolaris/kern/ |
H A D | opensolaris_taskq.c | 107 taskq_ent_t *task = arg; local 109 task->tqent_func(task->tqent_arg); 111 uma_zfree(taskq_zone, task); 117 taskq_ent_t *task; local 125 * If TQ_FRONT is given, we want higher priority for this task, so it 130 task = uma_zalloc(taskq_zone, mflag); 131 if (task == NULL) 134 task->tqent_func = func; 135 task 146 taskq_ent_t *task = arg; local 152 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, u_int flags, taskq_ent_t *task) argument [all...] |
/freebsd-9.3-release/contrib/bind9/lib/isc/include/isc/ |
H A D | task.h | 27 /*! \file isc/task.h 28 * \brief The task system provides a lightweight execution context, which is 31 * When a task's event queue is non-empty, the 32 * task is runnable. A small work crew of threads, typically one per CPU, 56 * Events which have been queued for a task but not delivered may be removed 57 * from the task's event queue by purging or unsending. 109 /*% Task and task manager methods */ 118 void (*setexcltask)(isc_taskmgr_t *mgr, isc_task_t *task); 126 void (*send)(isc_task_t *task, isc_event_t **eventp); 128 unsigned int (*unsend)(isc_task_t *task, voi [all...] |
H A D | ondestroy.h | 56 * X_ondestroy(X *instance, isc_task_t *task, 58 * return(isc_ondestroy_register(&instance->ondest, task,eventp)); 94 isc_ondestroy_register(isc_ondestroy_t *ondest, isc_task_t *task, 98 * Stores task and *eventp away inside *ondest. Ownership of **event is 99 * taken from the caller (and *eventp is set to NULL). The task is attached 106 * Dispatches the event(s) to the task(s) that were given in
|
/freebsd-9.3-release/sys/dev/isci/scil/ |
H A D | scic_task_request.h | 62 * task management requests. 76 * based task managment request object. 78 * @return Return the size of the SCIC task request object. 86 * task management requests, regardless of protocol. Memory 87 * initialization and functionality common to all task request types 91 * the user task request object and the core task request object. 94 * for which to build the task managmement request. 96 * object for which to build the task management request. 99 * memory when the task i [all...] |
/freebsd-9.3-release/sys/kern/ |
H A D | subr_taskqueue.c | 51 struct task *tb_running; 56 STAILQ_HEAD(, task) tq_queue; 168 taskqueue_enqueue_locked(struct taskqueue *queue, struct task *task) argument 170 struct task *ins; 171 struct task *prev; 176 if (task->ta_pending) { 177 if (task->ta_pending < USHRT_MAX) 178 task->ta_pending++; 185 prev = STAILQ_LAST(&queue->tq_queue, task, ta_lin 210 taskqueue_enqueue(struct taskqueue *queue, struct task *task) argument 302 struct task *task; local 342 task_is_running(struct taskqueue *queue, struct task *task) argument 355 taskqueue_cancel_locked(struct taskqueue *queue, struct task *task, u_int *pendp) argument 368 taskqueue_cancel(struct taskqueue *queue, struct task *task, u_int *pendp) argument 401 taskqueue_drain(struct taskqueue *queue, struct task *task) argument 416 struct task *task; local 580 taskqueue_enqueue_fast(struct taskqueue *queue, struct task *task) argument [all...] |
/freebsd-9.3-release/sys/dev/smc/ |
H A D | if_smcvar.h | 49 struct task smc_intr; 50 struct task smc_rx; 51 struct task smc_tx;
|
/freebsd-9.3-release/contrib/bind9/lib/dns/include/dns/ |
H A D | request.h | 77 *\li 'taskmgr' is a valid task manager. 97 dns_requestmgr_whenshutdown(dns_requestmgr_t *requestmgr, isc_task_t *task, 100 * Send '*eventp' to 'task' when 'requestmgr' has completed shutdown. 111 *\li 'task' is a valid task. 167 unsigned int timeout, isc_task_t *task, 183 * because it was canceled, a completion event will be sent to 'task'. 193 *\li 'task' is a valid task. 203 unsigned int timeout, isc_task_t *task, [all...] |
/freebsd-9.3-release/contrib/bind9/lib/dns/ |
H A D | tcpmsg.c | 25 #include <isc/task.h> 47 recv_length(isc_task_t *task, isc_event_t *ev_in) { argument 87 task, recv_message, tcpmsg); 97 isc_task_send(tcpmsg->task, &dev); 98 tcpmsg->task = NULL; 104 recv_message(isc_task_t *task, isc_event_t *ev_in) { argument 109 (void)task; 127 isc_task_send(tcpmsg->task, &dev); 128 tcpmsg->task = NULL; 145 tcpmsg->task 163 dns_tcpmsg_readmessage(dns_tcpmsg_t *tcpmsg, isc_task_t *task, isc_taskaction_t action, void *arg) argument [all...] |
/freebsd-9.3-release/contrib/bind9/lib/isccc/ |
H A D | ccmsg.c | 40 #include <isc/task.h> 54 recv_length(isc_task_t *task, isc_event_t *ev_in) { argument 92 task, recv_message, ccmsg); 102 isc_task_send(ccmsg->task, &dev); 103 ccmsg->task = NULL; 109 recv_message(isc_task_t *task, isc_event_t *ev_in) { argument 114 (void)task; 130 isc_task_send(ccmsg->task, &dev); 131 ccmsg->task = NULL; 148 ccmsg->task 165 isccc_ccmsg_readmessage(isccc_ccmsg_t *ccmsg, isc_task_t *task, isc_taskaction_t action, void *arg) argument [all...] |
/freebsd-9.3-release/contrib/ntp/lib/isc/tests/ |
H A D | socket_test.c | 47 event_done(isc_task_t *task, isc_event_t *event) { argument 51 UNUSED(task); 88 isc_task_t *task = NULL; local 116 result = isc_task_create(taskmgr, 0, &task); 124 result = isc_socket_sendto(s1, &r, task, event_done, &completion, 134 result = isc_socket_recv(s2, &r, 1, task, event_done, &completion); 141 isc_task_detach(&task); 159 isc_task_t *task = NULL; local 190 result = isc_task_create(taskmgr, 0, &task); 198 result = isc_socket_sendto(s1, &r, task, event_don [all...] |