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

1234567891011

/freebsd-10.2-release/sys/ofed/include/linux/
H A Dkthread.h45 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.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;
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 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...]
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,
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 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...]
H A Dhttpd.h28 #include <isc/task.h>
40 isc_httpdmgr_create(isc_mem_t *mctx, isc_socket_t *sock, isc_task_t *task,
H A Dratelimiter.h48 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 Dhandler.h46 struct task proc;
/freebsd-10.2-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-10.2-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-10.2-release/sys/kern/
H A Dsubr_taskqueue.c51 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 Dif_smcvar.h49 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 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...]
H A Dtask_test.c27 #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 Dfwohcivar.h74 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 Dutil.py64 __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 Dgnu-nat.c129 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 Dapp.c38 #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 Dif_iwivar.h189 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;

Completed in 125 milliseconds

1234567891011