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

1234567891011>>

/freebsd-9.3-release/sys/ofed/include/linux/
H A Dkthread.h44 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.h35 * 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 Dtaskqueue.h45 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 Dtask_api.c27 #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 Dtask.c25 * 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 Dondestroy.c29 #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 Dratelimiter.c26 #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 Dsocket_api.c133 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 Dtask.c25 * 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 Dtask_api.c27 #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 Dondestroy.c29 #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 Dratelimiter.c26 #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 Dtask.h27 /*! \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 Dondestroy.h56 * 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 Dsocket.h29 * 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 Dopensolaris_taskq.c107 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 Dtask.h27 /*! \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 Dondestroy.h56 * 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 Dscic_task_request.h62 * 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 Dsubr_taskqueue.c51 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 Dif_smcvar.h49 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 Drequest.h77 *\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 Dtcpmsg.c25 #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 Dccmsg.c40 #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 Dsocket_test.c47 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...]

Completed in 149 milliseconds

1234567891011>>