Home
last modified time | relevance | path

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

12345678910>>...16

/freebsd-14.2/sys/compat/linuxkpi/common/src/
H A Dlinux_kthread.c67 kthread_unpark(task); in linux_kthread_stop()
68 wake_up_process(task); in linux_kthread_stop()
74 retval = task->task_ret; in linux_kthread_stop()
75 put_task_struct(task); in linux_kthread_stop()
85 wake_up_process(task); in linux_kthread_park()
95 task = current; in linux_kthread_parkme()
113 task = current; in linux_kthread_should_park()
136 task->task_data = arg; in linux_kthread_setup_and_run()
144 return (task); in linux_kthread_setup_and_run()
153 task->task_ret = task->task_fn(task->task_data); in linux_kthread_fn()
[all …]
H A Dlinux_schedule.c105 sleepq_lock(task); in wake_up_task()
111 sleepq_release(task); in wake_up_task()
175 task = wq->private; in autoremove_wake_function()
270 task = current; in linux_wait_event_common()
277 sleepq_lock(task); in linux_wait_event_common()
279 ret = linux_add_to_sleepqueue(task, task, "wevent", timeout, in linux_wait_event_common()
300 task = current; in linux_schedule_timeout()
310 sleepq_lock(task); in linux_schedule_timeout()
313 ret = linux_add_to_sleepqueue(task, task, "sched", timeout, in linux_schedule_timeout()
372 task = current; in linux_wait_on_bit_timeout()
[all …]
/freebsd-14.2/contrib/ntp/libntp/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 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()
/freebsd-14.2/sys/compat/linuxkpi/common/include/linux/
H A Dsched.h101 #define task_pid_group_leader(task) (task)->task_thread->td_proc->p_pid argument
102 #define task_pid(task) ((task)->pid) argument
103 #define task_pid_nr(task) ((task)->pid) argument
104 #define task_pid_vnr(task) ((task)->pid) argument
108 #define task_euid(task) ((task)->task_thread->td_ucred->cr_uid) argument
110 #define get_task_state(task) atomic_read(&(task)->state) argument
111 #define set_task_state(task, x) atomic_set(&(task)->state, (x)) argument
112 #define __set_task_state(task, x) ((task)->state.counter = (x)) argument
154 #define signal_pending(task) linux_signal_pending(task) argument
155 #define fatal_signal_pending(task) linux_fatal_signal_pending(task) argument
[all …]
H A Dkthread.h48 struct task_struct *task; member
54 struct task task; member
82 #define kthread_stop(task) linux_kthread_stop(task) argument
84 #define kthread_should_stop_task(task) linux_kthread_should_stop_task(task) argument
85 #define kthread_park(task) linux_kthread_park(task) argument
88 #define kthread_unpark(task) linux_kthread_unpark(task) argument
101 struct task __task; \
126 TASK_INIT(&work->task, 0, lkpi_kthread_work_fn, work); in kthread_init_work()
134 error = taskqueue_enqueue_flags(worker->tq, &work->task, in kthread_queue_work()
148 taskqueue_drain(work->tq, &work->task); in kthread_cancel_work_sync()
[all …]
/freebsd-14.2/contrib/ntp/libntp/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-14.2/sys/cddl/compat/opensolaris/kern/
H A Dopensolaris_taskq.c115 taskq_ent_t *task = arg; in taskq_run() local
117 task->tqent_func(task->tqent_arg); in taskq_run()
125 taskq_ent_t *task; in taskq_dispatch() local
139 if (task == NULL) in taskq_dispatch()
142 task->tqent_func = func; in taskq_dispatch()
143 task->tqent_arg = arg; in taskq_dispatch()
145 TASK_INIT(&task->tqent_task, prio, taskq_run, task); in taskq_dispatch()
156 task->tqent_func(task->tqent_arg); in taskq_run_ent()
161 taskq_ent_t *task) in taskq_dispatch_ent() argument
172 task->tqent_arg = arg; in taskq_dispatch_ent()
[all …]
/freebsd-14.2/sys/contrib/openzfs/module/os/freebsd/spl/
H A Dspl_taskq.c273 taskq_remove(task); in taskq_free()
319 task->tqent_func(task->tqent_arg); in taskq_run()
320 taskq_free(task); in taskq_run()
327 taskq_ent_t *task; in taskq_dispatch_delay() local
342 if (task == NULL) in taskq_dispatch_delay()
360 taskq_ent_t *task; in taskq_dispatch() local
375 if (task == NULL) in taskq_dispatch()
382 TASK_INIT(&task->tqent_task, prio, taskq_run, task); in taskq_dispatch()
394 task->tqent_func(task->tqent_arg); in taskq_run_ent()
408 task->tqent_id = 0; in taskq_dispatch_ent()
[all …]
/freebsd-14.2/contrib/llvm-project/openmp/runtime/src/
H A Dkmp_taskdeps.h97 if (task->is_taskgraph && !(__kmp_tdg_is_recording(task->tdg->tdg_status))) { in __kmp_release_deps()
98 kmp_node_info_t *TaskInfo = &(task->tdg->record_map[task->td_task_id]); in __kmp_release_deps()
125 if (task->td_dephash) { in __kmp_release_deps()
128 gtid, task)); in __kmp_release_deps()
130 task->td_dephash = NULL; in __kmp_release_deps()
137 gtid, task)); in __kmp_release_deps()
141 if (!task->is_taskgraph || in __kmp_release_deps()
142 (task->is_taskgraph && !__kmp_tdg_is_recording(task->tdg->tdg_status))) in __kmp_release_deps()
144 node->dn.task = in __kmp_release_deps()
167 gtid, successor->dn.task, task)); in __kmp_release_deps()
[all …]
H A Dkmp_tasking.cpp1363 task->td_last_tied = task;
1423 if (task && task->td_dephash) {
1679 return task;
1913 (*(task->routine))(gtid, task);
3146 return task;
3216 return task;
3347 return task;
4600 td->td_allow_completion_event.ed.task = task;
4736 return task;
4758 : task(_task), taskdata(KMP_TASK_TO_TASKDATA(task)),
[all …]
H A Dkmp_taskdeps.cpp224 if (source->dn.task && sink_task) { in __kmp_track_dependence()
288 kmp_taskdata_t *td = KMP_TASK_TO_TASKDATA(task); in __kmpc_task_get_depnode()
309 if (task) { in __kmp_depnode_link_successor()
317 if (dep->dn.task) { in __kmp_depnode_link_successor()
319 if (dep->dn.task) { in __kmp_depnode_link_successor()
351 if (task) { in __kmp_depnode_link_successor()
358 if (sink->dn.task) { in __kmp_depnode_link_successor()
361 if (sink->dn.task) { in __kmp_depnode_link_successor()
371 KMP_TASK_TO_TASKDATA(task))); in __kmp_depnode_link_successor()
641 node->dn.task = task; in __kmp_check_deps()
[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 …]
/freebsd-14.2/sys/kern/
H A Dsubr_taskqueue.c128 task_get_busy(struct taskqueue *queue, struct task *task) in task_get_busy() argument
234 struct task *ins; in taskqueue_enqueue_locked()
235 struct task *prev; in taskqueue_enqueue_locked()
317 taskqueue_enqueue(struct taskqueue *queue, struct task *task) in taskqueue_enqueue() argument
489 struct task *task; in taskqueue_run_locked() local
518 task->ta_func(task->ta_context, pending); in taskqueue_run_locked()
521 wakeup(task); in taskqueue_run_locked()
543 taskqueue_poll_is_busy(struct taskqueue *queue, struct task *task) in taskqueue_poll_is_busy() argument
555 taskqueue_cancel_locked(struct taskqueue *queue, struct task *task, in taskqueue_cancel_locked() argument
562 STAILQ_REMOVE(&queue->tq_queue, task, task, ta_link); in taskqueue_cancel_locked()
[all …]
/freebsd-14.2/sys/contrib/dev/mediatek/mt76/
H A Dutil.h38 struct task_struct *task; member
83 if (!IS_ERR(w->task)) in mt76_worker_setup()
86 rc = PTR_ERR(w->task); in mt76_worker_setup()
87 w->task = NULL; in mt76_worker_setup()
95 if (w->task == NULL) in mt76_worker_schedule()
107 if (w->task == NULL) in mt76_worker_enable()
118 if (w->task == NULL) in mt76_worker_disable()
121 kthread_park(w->task); in mt76_worker_disable()
129 if (w->task == NULL) in mt76_worker_teardown()
132 kthread_stop(w->task); in mt76_worker_teardown()
[all …]
/freebsd-14.2/sys/sys/
H A Dtaskqueue.h78 int taskqueue_enqueue(struct taskqueue *queue, struct task *task);
79 int taskqueue_enqueue_flags(struct taskqueue *queue, struct task *task,
86 int taskqueue_poll_is_busy(struct taskqueue *queue, struct task *task);
87 int taskqueue_cancel(struct taskqueue *queue, struct task *task,
91 void taskqueue_drain(struct taskqueue *queue, struct task *task);
119 #define TASK_INIT_FLAGS(task, priority, func, context, flags) do { \ argument
120 (task)->ta_pending = 0; \
121 (task)->ta_priority = (priority); \
122 (task)->ta_flags = (flags); \
123 (task)->ta_func = (func); \
[all …]
H A D_task.h47 struct task { struct
48 STAILQ_ENTRY(task) ta_link; /* (q) link for queue */
66 struct task t; argument
/freebsd-14.2/sys/dev/usb/net/
H A Dusb_ethernet.c106 struct usb_ether_cfg_task *task; in ue_queue_command() local
122 task->hdr.pm_callback = fn; in ue_queue_command()
123 task->ue = ue; in ue_queue_command()
204 struct usb_ether_cfg_task *task = in ue_attach_post_task() local
206 struct usb_ether *ue = task->ue; in ue_attach_post_task()
372 struct usb_ether *ue = task->ue; in ue_start_task()
391 struct usb_ether *ue = task->ue; in ue_stop_task()
425 struct usb_ether *ue = task->ue; in ue_promisc_task()
435 struct usb_ether *ue = task->ue; in ue_setmulti_task()
467 struct usb_ether *ue = task->ue; in ue_ifmedia_task()
[all …]
/freebsd-14.2/sys/contrib/openzfs/module/os/linux/spl/
H A Dspl-thread.c175 struct task_struct *task = current; local
179 sigorsets(&set, &task->blocked, &set);
181 spin_lock_irq(&task->sighand->siglock);
184 if (dequeue_signal(task, &set, &__info, &__type) != 0) {
186 if (dequeue_signal(task, &set, &__info) != 0) {
189 spin_unlock_irq(&task->sighand->siglock);
202 spin_unlock_irq(&task->sighand->siglock);
/freebsd-14.2/sys/contrib/openzfs/module/zfs/
H A Dzvol.c1438 zvol_task_t *task; in zvol_task_alloc() local
1445 task->op = op; in zvol_task_alloc()
1452 return (task); in zvol_task_alloc()
1474 zvol_rename_minors_impl(task->name1, task->name2); in zvol_task_cb()
1477 zvol_set_snapdev_impl(task->name1, task->value); in zvol_task_cb()
1480 zvol_set_volmode_impl(task->name1, task->value); in zvol_task_cb()
1523 zvol_task_t *task; in zvol_set_snapdev_sync_cb() local
1530 if (task == NULL) in zvol_set_snapdev_sync_cb()
1616 if (task == NULL) in zvol_set_volmode_sync_cb()
1677 if (task == NULL) in zvol_remove_minors()
[all …]
/freebsd-14.2/sys/net80211/
H A Dieee80211_var.h149 struct task ic_promisc_task;/* deferred promisc update */
150 struct task ic_mcast_task; /* deferred mcast update */
151 struct task ic_chan_task; /* deferred channel change */
153 struct task ic_chw_task; /* deferred HT CHW update */
154 struct task ic_restart_task; /* deferred device restart */
421 struct task iv_nstate_task[NET80211_IV_NSTATE_NUM];
580 struct task iv_wme_task; /* deferred VAP WME update */
852 ieee80211_runtask(struct ieee80211com *ic, struct task *task) in ieee80211_runtask() argument
854 taskqueue_enqueue(ic->ic_tq, task); in ieee80211_runtask()
861 ieee80211_draintask(struct ieee80211com *ic, struct task *task) in ieee80211_draintask() argument
[all …]
/freebsd-14.2/cddl/contrib/opensolaris/lib/pyzfs/common/
H A Dutil.py67 def __init__(self, eno, task=None, why=None): argument
75 self.task = task
80 if self.task:
81 s += self.task + ": "
/freebsd-14.2/sys/dev/hyperv/vmbus/
H A Dvmbus_chanvar.h58 struct task ch_task;
59 struct task ch_poll_task;
129 struct task ch_attach_task; /* run in ch_mgmt_tq */
130 struct task ch_detach_task; /* run in ch_mgmt_tq */
/freebsd-14.2/sys/dev/isci/scil/
H A Dscic_task_request.h169 #define scic_task_request_construct(controller, dev, tag, task, mem, handle) \
171 #define scic_task_request_construct_ssp(task) SCI_FAILURE
172 #define scic_task_request_construct_sata(task) SCI_FAILURE

12345678910>>...16