Home
last modified time | relevance | path

Searched refs:task (Results 1 – 25 of 393) sorted by relevance

12345678910>>...16

/freebsd-13.1/sys/compat/linuxkpi/common/src/
H A Dlinux_kthread.c69 kthread_unpark(task); in linux_kthread_stop()
70 wake_up_process(task); in linux_kthread_stop()
76 retval = task->task_ret; in linux_kthread_stop()
77 put_task_struct(task); in linux_kthread_stop()
87 wake_up_process(task); in linux_kthread_park()
97 task = current; in linux_kthread_parkme()
115 task = current; in linux_kthread_should_park()
136 task = td->td_lkpi_task; in linux_kthread_setup_and_run()
138 task->task_data = arg; in linux_kthread_setup_and_run()
146 return (task); in linux_kthread_setup_and_run()
[all …]
H A Dlinux_schedule.c107 sleepq_lock(task); in wake_up_task()
113 sleepq_release(task); in wake_up_task()
177 task = wq->private; in autoremove_wake_function()
272 task = current; in linux_wait_event_common()
279 sleepq_lock(task); in linux_wait_event_common()
281 ret = linux_add_to_sleepqueue(task, task, "wevent", timeout, in linux_wait_event_common()
302 task = current; in linux_schedule_timeout()
312 sleepq_lock(task); in linux_schedule_timeout()
315 ret = linux_add_to_sleepqueue(task, task, "sched", timeout, in linux_schedule_timeout()
374 task = current; in linux_wait_on_bit_timeout()
[all …]
/freebsd-13.1/contrib/ntp/lib/isc/
H A Dtask.c325 isc_mem_put(manager->mctx, task, sizeof(*task)); in task_finished()
340 task = isc_mem_get(manager->mctx, sizeof(*task)); in isc__task_create()
346 isc_mem_put(manager->mctx, task, sizeof(*task)); in isc__task_create()
358 task->now = 0; in isc__task_create()
359 memset(task->name, 0, sizeof(task->name)); in isc__task_create()
379 isc_mem_put(manager->mctx, task, sizeof(*task)); in isc__task_create()
877 memset(task->name, 0, sizeof(task->name)); in isc__task_setname()
878 strncpy(task->name, name, sizeof(task->name) - 1); in isc__task_setname()
960 return (task); in pop_readyq()
1518 task = NEXT(task, link)) { in isc__taskmgr_destroy()
[all …]
H A Dtask_api.c150 task->methods->send(task, eventp); in isc_task_send()
171 return (task->methods->unsend(task, sender, type, tag, events)); in isc_task_unsend()
179 return (task->methods->onshutdown(task, action, arg)); in isc_task_onshutdown()
186 task->methods->shutdown(task); in isc_task_shutdown()
193 task->methods->setname(task, name, tag); in isc_task_setname()
201 return (task->methods->purgeevents(task, sender, type, tag)); in isc_task_purge()
208 return (task->methods->beginexclusive(task)); in isc_task_beginexclusive()
215 task->methods->endexclusive(task); in isc_task_endexclusive()
222 task->methods->setprivilege(task, priv); in isc_task_setprivilege()
229 return (task->methods->privilege(task)); in isc_task_privilege()
[all …]
H A Dratelimiter.c42 isc_task_t * task; member
72 rl->task = task; in isc_ratelimiter_create()
140 REQUIRE(task != NULL); in isc_ratelimiter_enqueue()
148 ev->ev_sender = task; in isc_ratelimiter_enqueue()
155 ev->ev_sender = task; in isc_ratelimiter_enqueue()
164 isc_task_send(task, eventp); in isc_ratelimiter_enqueue()
175 UNUSED(task); in ratelimiter_tick()
213 isc_task_t *task; in isc_ratelimiter_shutdown() local
221 task = ev->ev_sender; in isc_ratelimiter_shutdown()
222 isc_task_send(task, &ev); in isc_ratelimiter_shutdown()
[all …]
H A Dondestroy.c42 isc_ondestroy_register(isc_ondestroy_t *ondest, isc_task_t *task, in isc_ondestroy_register() argument
49 REQUIRE(task != NULL); in isc_ondestroy_register()
56 isc_task_attach(task, &thetask); in isc_ondestroy_register()
68 isc_task_t *task; in isc_ondestroy_notify() local
76 task = eventp->ev_sender; in isc_ondestroy_notify()
79 isc_task_sendanddetach(&task, &eventp); in isc_ondestroy_notify()
H A Dsocket_api.c133 isc_socket_sendto(isc_socket_t *sock, isc_region_t *region, isc_task_t *task, in isc_socket_sendto() argument
139 return (sock->methods->sendto(sock, region, task, action, arg, address, in isc_socket_sendto()
144 isc_socket_connect(isc_socket_t *sock, isc_sockaddr_t *addr, isc_task_t *task, in isc_socket_connect() argument
149 return (sock->methods->connect(sock, addr, task, action, arg)); in isc_socket_connect()
154 isc_task_t *task, isc_taskaction_t action, const void *arg) in isc_socket_recv() argument
158 return (sock->methods->recv(sock, region, minimum, task, action, arg)); in isc_socket_recv()
162 isc_socket_cancel(isc_socket_t *sock, isc_task_t *task, unsigned int how) { in isc_socket_cancel() argument
165 sock->methods->cancel(sock, task, how); in isc_socket_cancel()
201 isc_task_t *task, isc_socket_t **socketp) in isc_socket_fdwatchcreate() argument
206 callback, cbarg, task, in isc_socket_fdwatchcreate()
/freebsd-13.1/sys/compat/linuxkpi/common/include/linux/
H A Dsched.h94 #define task_pid_group_leader(task) (task)->task_thread->td_proc->p_pid argument
95 #define task_pid(task) ((task)->pid) argument
96 #define task_pid_nr(task) ((task)->pid) argument
97 #define task_pid_vnr(task) ((task)->pid) argument
101 #define task_euid(task) ((task)->task_thread->td_ucred->cr_uid) argument
103 #define get_task_state(task) atomic_read(&(task)->state) argument
104 #define set_task_state(task, x) atomic_set(&(task)->state, (x)) argument
105 #define __set_task_state(task, x) ((task)->state.counter = (x)) argument
134 #define signal_pending(task) linux_signal_pending(task) argument
135 #define fatal_signal_pending(task) linux_fatal_signal_pending(task) argument
[all …]
H A Dkthread.h63 #define kthread_stop(task) linux_kthread_stop(task) argument
65 #define kthread_should_stop_task(task) linux_kthread_should_stop_task(task) argument
66 #define kthread_park(task) linux_kthread_park(task) argument
69 #define kthread_unpark(task) linux_kthread_unpark(task) argument
/freebsd-13.1/contrib/ntp/lib/isc/include/isc/
H A Dtask.h124 void (*send)(isc_task_t *task, isc_event_t **eventp);
130 void (*shutdown)(isc_task_t *task);
137 isc_result_t (*beginexclusive)(isc_task_t *task);
138 void (*endexclusive)(isc_task_t *task);
140 isc_boolean_t (*privilege)(isc_task_t *task);
471 isc_task_shutdown(isc_task_t *task);
541 isc_task_getname(isc_task_t *task);
559 isc_task_gettag(isc_task_t *task);
571 isc_task_beginexclusive(isc_task_t *task);
591 isc_task_endexclusive(isc_task_t *task);
[all …]
H A Dsocket.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,
693 isc_task_t *task, isc_taskaction_t action,
761 isc_task_t *task, isc_taskaction_t action, const void *arg);
769 unsigned int minimum, isc_task_t *task,
[all …]
/freebsd-13.1/sys/contrib/openzfs/module/os/freebsd/spl/
H A Dspl_taskq.c271 taskq_remove(task); in taskq_free()
315 task->tqent_func(task->tqent_arg); in taskq_run()
316 taskq_free(task); in taskq_run()
323 taskq_ent_t *task; in taskq_dispatch_delay() local
338 if (task == NULL) in taskq_dispatch_delay()
357 taskq_ent_t *task; in taskq_dispatch() local
372 if (task == NULL) in taskq_dispatch()
380 TASK_INIT(&task->tqent_task, prio, taskq_run, task); in taskq_dispatch()
390 task->tqent_func(task->tqent_arg); in taskq_run_ent()
406 task->tqent_id = 0; in taskq_dispatch_ent()
[all …]
/freebsd-13.1/sys/cddl/compat/opensolaris/kern/
H A Dopensolaris_taskq.c117 taskq_ent_t *task = arg; in taskq_run() local
119 task->tqent_func(task->tqent_arg); in taskq_run()
127 taskq_ent_t *task; in taskq_dispatch() local
141 if (task == NULL) in taskq_dispatch()
144 task->tqent_func = func; in taskq_dispatch()
145 task->tqent_arg = arg; in taskq_dispatch()
147 TASK_INIT(&task->tqent_task, prio, taskq_run, task); in taskq_dispatch()
158 task->tqent_func(task->tqent_arg); in taskq_run_ent()
163 taskq_ent_t *task) in taskq_dispatch_ent() argument
174 task->tqent_arg = arg; in taskq_dispatch_ent()
[all …]
/freebsd-13.1/sys/kern/
H A Dsubr_taskqueue.c220 taskqueue_enqueue_locked(struct taskqueue *queue, struct task *task) in taskqueue_enqueue_locked() argument
222 struct task *ins; in taskqueue_enqueue_locked()
277 taskqueue_enqueue(struct taskqueue *queue, struct task *task) in taskqueue_enqueue() argument
449 struct task *task; in taskqueue_run_locked() local
477 task->ta_func(task->ta_context, pending); in taskqueue_run_locked()
480 wakeup(task); in taskqueue_run_locked()
497 task_is_running(struct taskqueue *queue, struct task *task) in task_is_running() argument
520 retval = task->ta_pending > 0 || task_is_running(queue, task); in taskqueue_poll_is_busy()
532 STAILQ_REMOVE(&queue->tq_queue, task, task, ta_link); in taskqueue_cancel_locked()
576 taskqueue_drain(struct taskqueue *queue, struct task *task) in taskqueue_drain() argument
[all …]
/freebsd-13.1/contrib/llvm-project/openmp/runtime/src/
H A Dkmp_taskdeps.h91 kmp_depnode_t *node = task->td_depnode; in __kmp_release_deps()
103 if (task->td_dephash) { in __kmp_release_deps()
106 gtid, task)); in __kmp_release_deps()
107 __kmp_dephash_free(thread, task->td_dephash); in __kmp_release_deps()
108 task->td_dephash = NULL; in __kmp_release_deps()
115 gtid, task)); in __kmp_release_deps()
118 node->dn.task = in __kmp_release_deps()
132 if (successor->dn.task) { in __kmp_release_deps()
135 gtid, successor->dn.task, task)); in __kmp_release_deps()
148 successor->dn.task, in __kmp_release_deps()
[all …]
H A Dkmp_tasking.cpp1098 task->td_last_tied = task; in __kmp_init_implicit_task()
1155 if (task && task->td_dephash) { in __kmp_free_implicit_task()
1408 return task; in __kmp_task_alloc()
1618 ((void (*)(void *))(*(task->routine)))(task->shareds); in __kmp_invoke_task()
1622 (*(task->routine))(gtid, task); in __kmp_invoke_task()
2727 return task; in __kmp_remove_my_task()
2859 return task; in __kmp_steal_task()
3990 td->td_allow_completion_event.ed.task = task; in __kmpc_task_allow_completion_event()
4112 return task; in __kmp_task_dup_alloc()
4134 : task(_task), taskdata(KMP_TASK_TO_TASKDATA(task)), in kmp_taskloop_bounds_t()
[all …]
H A Dkmp_cancel.cpp81 kmp_taskdata_t *task; in __kmpc_cancel() local
84 task = this_thr->th.th_current_task; in __kmpc_cancel()
85 KMP_DEBUG_ASSERT(task); in __kmpc_cancel()
87 taskgroup = task->td_taskgroup; in __kmpc_cancel()
194 kmp_taskdata_t *task; in __kmpc_cancellationpoint() local
197 task = this_thr->th.th_current_task; in __kmpc_cancellationpoint()
198 KMP_DEBUG_ASSERT(task); in __kmpc_cancellationpoint()
200 taskgroup = task->td_taskgroup; in __kmpc_cancellationpoint()
321 kmp_taskdata_t *task; in __kmp_get_cancellation_status() local
323 task = this_thr->th.th_current_task; in __kmp_get_cancellation_status()
[all …]
H A Dkmp_taskdeps.cpp38 node->dn.task = NULL; // will point to the right task in __kmp_init_node()
251 if (dep->dn.task) { in __kmp_depnode_link_successor()
253 if (dep->dn.task) { in __kmp_depnode_link_successor()
254 __kmp_track_dependence(gtid, dep, node, task); in __kmp_depnode_link_successor()
259 KMP_TASK_TO_TASKDATA(task))); in __kmp_depnode_link_successor()
276 if (sink->dn.task) { in __kmp_depnode_link_successor()
279 if (sink->dn.task) { in __kmp_depnode_link_successor()
280 __kmp_track_dependence(gtid, sink, source, task); in __kmp_depnode_link_successor()
285 KMP_TASK_TO_TASKDATA(task))); in __kmp_depnode_link_successor()
448 if (n_mtxs < MAX_MTX_DEPS && task != NULL) { in __kmp_check_deps()
[all …]
/freebsd-13.1/sys/sys/
H A Dtaskqueue.h50 struct task t;
84 int taskqueue_enqueue(struct taskqueue *queue, struct task *task);
90 int taskqueue_poll_is_busy(struct taskqueue *queue, struct task *task);
91 int taskqueue_cancel(struct taskqueue *queue, struct task *task,
95 void taskqueue_drain(struct taskqueue *queue, struct task *task);
123 #define TASK_INIT_FLAGS(task, priority, func, context, flags) do { \ argument
124 (task)->ta_pending = 0; \
125 (task)->ta_priority = (priority); \
126 (task)->ta_flags = (flags); \
127 (task)->ta_func = (func); \
[all …]
/freebsd-13.1/contrib/ntp/lib/isc/tests/
H A Dsocket_test.c47 event_done(isc_task_t *task, isc_event_t *event) { in event_done() argument
51 UNUSED(task); in event_done()
88 isc_task_t *task = NULL; in ATF_TC_BODY() local
116 result = isc_task_create(taskmgr, 0, &task); in ATF_TC_BODY()
124 result = isc_socket_sendto(s1, &r, task, event_done, &completion, in ATF_TC_BODY()
141 isc_task_detach(&task); in ATF_TC_BODY()
159 isc_task_t *task = NULL; in ATF_TC_BODY() local
190 result = isc_task_create(taskmgr, 0, &task); in ATF_TC_BODY()
198 result = isc_socket_sendto(s1, &r, task, event_done, &completion, in ATF_TC_BODY()
210 result = isc_socket_sendto(s1, &r, task, event_done, &completion, in ATF_TC_BODY()
[all …]
H A Dtask_test.c42 set(isc_task_t *task, isc_event_t *event) { in set() argument
45 UNUSED(task); in set()
57 UNUSED(task); in set_and_drop()
78 isc_task_t *task = NULL; in ATF_TC_BODY() local
88 isc_task_destroy(&task); in ATF_TC_BODY()
89 ATF_REQUIRE_EQ(task, NULL); in ATF_TC_BODY()
101 isc_task_t *task = NULL; in ATF_TC_BODY() local
125 isc_task_send(task, &event); in ATF_TC_BODY()
132 isc_task_send(task, &event); in ATF_TC_BODY()
145 isc_task_destroy(&task); in ATF_TC_BODY()
[all …]
/freebsd-13.1/contrib/apr-util/misc/
H A Dapr_thread_pool.c160 assert(task != in pop_task()
167 return task; in pop_task()
176 assert(task != NULL); in pop_task()
189 return task; in pop_task()
197 assert(task != NULL); in waiting_time()
198 assert(task != in waiting_time()
260 task = pop_task(me); in thread_pool_func()
266 task->func(t, task->param); in thread_pool_func()
944 task = data; in apr_thread_pool_task_owner_get()
945 if (!task) { in apr_thread_pool_task_owner_get()
[all …]
/freebsd-13.1/sys/dev/usb/net/
H A Dusb_ethernet.c109 struct usb_ether_cfg_task *task; in ue_queue_command() local
125 task->hdr.pm_callback = fn; in ue_queue_command()
126 task->ue = ue; in ue_queue_command()
207 struct usb_ether_cfg_task *task = in ue_attach_post_task() local
209 struct usb_ether *ue = task->ue; in ue_attach_post_task()
382 struct usb_ether *ue = task->ue; in ue_start_task()
401 struct usb_ether *ue = task->ue; in ue_stop_task()
435 struct usb_ether *ue = task->ue; in ue_promisc_task()
445 struct usb_ether *ue = task->ue; in ue_setmulti_task()
477 struct usb_ether *ue = task->ue; in ue_ifmedia_task()
[all …]
/freebsd-13.1/sys/contrib/openzfs/module/os/linux/spl/
H A Dspl-thread.c183 struct task_struct *task = current; local
187 sigorsets(&set, &task->blocked, &set);
189 spin_lock_irq(&task->sighand->siglock);
193 if ((ret = dequeue_signal(task, &set, &__info, &__type)) != 0) {
195 if ((ret = dequeue_signal(task, &set, &__info)) != 0) {
198 spin_unlock_irq(&task->sighand->siglock);
211 spin_unlock_irq(&task->sighand->siglock);
/freebsd-13.1/sys/contrib/openzfs/module/zfs/
H A Dzvol.c1481 zvol_task_t *task; in zvol_task_alloc() local
1488 task->op = op; in zvol_task_alloc()
1495 return (task); in zvol_task_alloc()
1517 zvol_rename_minors_impl(task->name1, task->name2); in zvol_task_cb()
1520 zvol_set_snapdev_impl(task->name1, task->value); in zvol_task_cb()
1523 zvol_set_volmode_impl(task->name1, task->value); in zvol_task_cb()
1566 zvol_task_t *task; in zvol_set_snapdev_sync_cb() local
1573 if (task == NULL) in zvol_set_snapdev_sync_cb()
1659 if (task == NULL) in zvol_set_volmode_sync_cb()
1720 if (task == NULL) in zvol_remove_minors()
[all …]

12345678910>>...16