/freebsd-10.2-release/sys/ofed/include/linux/ |
H A D | kthread.h | 45 struct task_struct *task; local 47 task = arg; 48 task_struct_set(curthread, task); 49 if (task->should_stop == 0) 50 task->task_ret = task->task_fn(task->task_data); 51 PROC_LOCK(task->task_thread->td_proc); 52 task->should_stop = TASK_STOPPED; 53 wakeup(task); 61 struct task_struct *task; local 92 kthread_stop(struct task_struct *task) argument [all...] |
/freebsd-10.2-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; 74 int taskqueue_enqueue(struct taskqueue *queue, struct task *task); 77 int taskqueue_cancel(struct taskqueue *queue, struct task *task, 81 void taskqueue_drain(struct taskqueue *queue, struct task *task); 107 * Initialise a task structure. 109 #define TASK_INIT(task, priority, func, context) do { \ 110 (task) [all...] |
/freebsd-10.2-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...] |
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, 144 isc_socket_connect(isc_socket_t *sock, isc_sockaddr_t *addr, isc_task_t *task, argument 149 return (sock->methods->connect(sock, addr, task, action, arg)); 154 isc_task_t *task, isc_taskaction_t action, const void *arg) 158 return (sock->methods->recv(sock, region, minimum, task, action, arg)); 162 isc_socket_cancel(isc_socket_t *sock, isc_task_t *task, unsigned int how) { argument 165 sock->methods->cancel(sock, task, how); 201 isc_task_t *task, isc_socket_t **socketp) 206 callback, cbarg, task, 153 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 199 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-10.2-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...] |
H A D | httpd.h | 28 #include <isc/task.h> 40 isc_httpdmgr_create(isc_mem_t *mctx, isc_socket_t *sock, isc_task_t *task,
|
H A D | ratelimiter.h | 48 isc_task_t *task, isc_ratelimiter_t **ratelimiterp); 71 isc_ratelimiter_enqueue(isc_ratelimiter_t *rl, isc_task_t *task, 77 * to doing an isc_task_send() to the 'task', except that the 81 * '(*eventp)->ev_sender' is used to hold the task. The caller 82 * must ensure that the task exists until the event is delivered. 88 *\li 'task' to be non NULL. 99 * dispatched to the task are dispatched immediately with 105 *\li The rate limiter is no longer attached to its task.
|
/freebsd-10.2-release/sys/dev/wtap/wtap_hal/ |
H A D | handler.h | 46 struct task proc;
|
/freebsd-10.2-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-10.2-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-10.2-release/sys/kern/ |
H A D | subr_taskqueue.c | 51 struct task *tb_running; 56 STAILQ_HEAD(, task) tq_queue; 189 taskqueue_enqueue_locked(struct taskqueue *queue, struct task *task) argument 191 struct task *ins; 192 struct task *prev; 197 if (task->ta_pending) { 198 if (task->ta_pending < USHRT_MAX) 199 task->ta_pending++; 206 prev = STAILQ_LAST(&queue->tq_queue, task, ta_lin 231 taskqueue_enqueue(struct taskqueue *queue, struct task *task) argument 323 struct task *task; local 363 task_is_running(struct taskqueue *queue, struct task *task) argument 376 taskqueue_cancel_locked(struct taskqueue *queue, struct task *task, u_int *pendp) argument 389 taskqueue_cancel(struct taskqueue *queue, struct task *task, u_int *pendp) argument 422 taskqueue_drain(struct taskqueue *queue, struct task *task) argument 437 struct task *task; local 623 taskqueue_enqueue_fast(struct taskqueue *queue, struct task *task) argument [all...] |
/freebsd-10.2-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-10.2-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...] |
H A D | task_test.c | 27 #include <isc/task.h> 37 /* task event handler, sets a boolean to true */ 42 set(isc_task_t *task, isc_event_t *event) { argument 45 UNUSED(task); 54 set_and_drop(isc_task_t *task, isc_event_t *event) { argument 57 UNUSED(task); 71 /* Create a task */ 74 atf_tc_set_md_var(tc, "descr", "create and destroy a task"); 78 isc_task_t *task = NULL; local 85 result = isc_task_create(taskmgr, 0, &task); 101 isc_task_t *task = NULL; local [all...] |
/freebsd-10.2-release/sys/dev/firewire/ |
H A D | fwohcivar.h | 74 struct task fwohci_task_busreset; 75 struct task fwohci_task_sid; 76 struct task fwohci_task_dma;
|
/freebsd-10.2-release/cddl/contrib/opensolaris/lib/pyzfs/common/ |
H A D | util.py | 64 __slots__ = "why", "task", "errno" 67 def __init__(self, eno, task=None, why=None): 70 task -- a string describing the task that failed 75 self.task = task 80 if self.task: 81 s += self.task + ": "
|
/freebsd-10.2-release/contrib/gdb/gdb/ |
H A D | gnu-nat.c | 129 to INF's msg port and task port respectively. If it has no msg port, 133 (refport = inf->task->port, 0), 0, \ 173 struct proc *task; /* The mach task. */ 176 /* True if THREADS needn't be validated by querying the task. We assume that 177 we and the task in question are the only ones frobbing the thread list, 220 /* The task suspend count used when gdb has control. This is normally 1 to 222 system servers) it may be desirable to let the task continue to run 226 /* The task suspend count left when detaching from a task 172 struct proc *task; /* The mach task. */ member in struct:inf 742 struct proc *task = inf->task; local 910 struct proc *task = inf->task; local 991 struct proc *task = inf->task; local 1207 struct proc *task = inf->task; local 1999 struct proc *task = current_inferior->task; local 2246 gnu_read_inferior(task_t task, CORE_ADDR addr, char *myaddr, int length) argument 2290 gnu_write_inferior(task_t task, CORE_ADDR addr, char *myaddr, int length) argument 2452 task_t task = (current_inferior local 2480 task_t task; local [all...] |
/freebsd-10.2-release/contrib/ntp/lib/isc/win32/ |
H A D | app.c | 38 #include <isc/task.h> 102 isc__app_onrun(isc_mem_t *mctx, isc_task_t *task, isc_taskaction_t action, argument 116 * Note that we store the task to which we're going to send the event 119 isc_task_attach(task, &cloned_task); 138 isc_task_t *task; local 154 task = event->ev_sender; 156 isc_task_sendanddetach(&task, &event);
|
/freebsd-10.2-release/sys/dev/iwi/ |
H A D | if_iwivar.h | 189 struct task sc_radiontask; /* radio on processing */ 190 struct task sc_radiofftask; /* radio off processing */ 191 struct task sc_restarttask; /* restart adapter processing */ 192 struct task sc_disassoctask; 193 struct task sc_wmetask; /* set wme parameters */ 194 struct task sc_monitortask;
|