| /freebsd-12.1/contrib/ntp/lib/isc/ |
| H A D | task.c | 325 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 D | task_api.c | 150 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 D | ratelimiter.c | 42 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 D | ondestroy.c | 42 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 D | socket_api.c | 133 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-12.1/sys/compat/linuxkpi/common/src/ |
| H A D | linux_kthread.c | 69 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()
147 return (task); in linux_kthread_setup_and_run()
[all …]
|
| H A D | linux_schedule.c | 107 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-12.1/sys/compat/linuxkpi/common/include/linux/ |
| H A D | sched.h | 92 #define task_pid_group_leader(task) (task)->task_thread->td_proc->p_pid argument
93 #define task_pid(task) ((task)->pid) argument
94 #define task_pid_nr(task) ((task)->pid) argument
95 #define task_pid_vnr(task) ((task)->pid) argument
99 #define task_euid(task) ((task)->task_thread->td_ucred->cr_uid) argument
101 #define get_task_state(task) atomic_read(&(task)->state) argument
102 #define set_task_state(task, x) atomic_set(&(task)->state, (x)) argument
103 #define __set_task_state(task, x) ((task)->state.counter = (x)) argument
132 #define signal_pending(task) linux_signal_pending(task) argument
133 #define fatal_signal_pending(task) linux_fatal_signal_pending(task) argument
[all …]
|
| H A D | kthread.h | 63 #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-12.1/contrib/ntp/lib/isc/include/isc/ |
| H A D | task.h | 124 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 D | socket.h | 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,
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-12.1/sys/cddl/compat/opensolaris/kern/ |
| H A D | opensolaris_taskq.c | 108 taskq_ent_t *task = arg; in taskq_run() local
110 task->tqent_func(task->tqent_arg); in taskq_run()
118 taskq_ent_t *task; in taskq_dispatch() local
132 if (task == NULL) in taskq_dispatch()
135 task->tqent_func = func; in taskq_dispatch()
136 task->tqent_arg = arg; in taskq_dispatch()
138 TASK_INIT(&task->tqent_task, prio, taskq_run, task); in taskq_dispatch()
149 task->tqent_func(task->tqent_arg); in taskq_run_ent()
154 taskq_ent_t *task) in taskq_dispatch_ent() argument
165 task->tqent_arg = arg; in taskq_dispatch_ent()
[all …]
|
| /freebsd-12.1/sys/kern/ |
| H A D | subr_taskqueue.c | 63 struct task * const TB_DRAIN_WAITER = (struct task *)0x1;
221 struct task *ins; in taskqueue_enqueue_locked()
267 taskqueue_enqueue(struct taskqueue *queue, struct task *task) in taskqueue_enqueue() argument
444 struct task *task; in taskqueue_run_locked() local
467 task->ta_func(task->ta_context, pending); in taskqueue_run_locked()
471 wakeup(task); in taskqueue_run_locked()
491 task_is_running(struct taskqueue *queue, struct task *task) in task_is_running() argument
514 retval = task->ta_pending > 0 || task_is_running(queue, task); in taskqueue_poll_is_busy()
526 STAILQ_REMOVE(&queue->tq_queue, task, task, ta_link); in taskqueue_cancel_locked()
567 taskqueue_drain(struct taskqueue *queue, struct task *task) in taskqueue_drain() argument
[all …]
|
| /freebsd-12.1/contrib/openmp/runtime/src/ |
| H A D | kmp_tasking.cpp | 1072 task->td_last_tied = task; in __kmp_init_implicit_task()
1130 if (task && task->td_dephash) { in __kmp_free_implicit_task()
1368 return task; in __kmp_task_alloc()
1569 ((void (*)(void *))(*(task->routine)))(task->shareds); in __kmp_invoke_task()
1573 (*(task->routine))(gtid, task); in __kmp_invoke_task()
2418 return task; in __kmp_remove_my_task()
2550 return task; in __kmp_steal_task()
2602 task = NULL; in __kmp_execute_tasks_template()
3709 return task; in __kmp_task_dup_alloc()
3731 : task(_task), taskdata(KMP_TASK_TO_TASKDATA(task)), in kmp_taskloop_bounds_t()
[all …]
|
| H A D | kmp_taskdeps.h | 93 kmp_depnode_t *node = task->td_depnode; in __kmp_release_deps()
95 if (task->td_dephash) { in __kmp_release_deps()
98 gtid, task)); in __kmp_release_deps()
99 __kmp_dephash_free(thread, task->td_dephash); in __kmp_release_deps()
100 task->td_dephash = NULL; in __kmp_release_deps()
107 gtid, task)); in __kmp_release_deps()
110 node->dn.task = in __kmp_release_deps()
123 if (successor->dn.task) { in __kmp_release_deps()
126 gtid, successor->dn.task, task)); in __kmp_release_deps()
127 __kmp_omp_task(gtid, successor->dn.task, false); in __kmp_release_deps()
[all …]
|
| H A D | kmp_taskdeps.cpp | 41 node->dn.task = NULL; // will point to the rigth task in __kmp_init_node()
194 if (dep->dn.task) { in __kmp_depnode_link_successor()
196 if (dep->dn.task) { in __kmp_depnode_link_successor()
197 __kmp_track_dependence(dep, node, task); in __kmp_depnode_link_successor()
202 KMP_TASK_TO_TASKDATA(task))); in __kmp_depnode_link_successor()
219 if (sink->dn.task) { in __kmp_depnode_link_successor()
222 if (sink->dn.task) { in __kmp_depnode_link_successor()
223 __kmp_track_dependence(sink, source, task); in __kmp_depnode_link_successor()
228 KMP_TASK_TO_TASKDATA(task))); in __kmp_depnode_link_successor()
391 if (n_mtxs < MAX_MTX_DEPS && task != NULL) { in __kmp_check_deps()
[all …]
|
| H A D | kmp_cancel.cpp | 84 kmp_taskdata_t *task; in __kmpc_cancel() local
87 task = this_thr->th.th_current_task; in __kmpc_cancel()
88 KMP_DEBUG_ASSERT(task); in __kmpc_cancel()
90 taskgroup = task->td_taskgroup; in __kmpc_cancel()
197 kmp_taskdata_t *task; in __kmpc_cancellationpoint() local
200 task = this_thr->th.th_current_task; in __kmpc_cancellationpoint()
201 KMP_DEBUG_ASSERT(task); in __kmpc_cancellationpoint()
203 taskgroup = task->td_taskgroup; in __kmpc_cancellationpoint()
324 kmp_taskdata_t *task; in __kmp_get_cancellation_status() local
326 task = this_thr->th.th_current_task; in __kmp_get_cancellation_status()
[all …]
|
| /freebsd-12.1/sys/sys/ |
| H A D | taskqueue.h | 49 struct task t;
81 int taskqueue_enqueue(struct taskqueue *queue, struct task *task);
87 int taskqueue_poll_is_busy(struct taskqueue *queue, struct task *task);
88 int taskqueue_cancel(struct taskqueue *queue, struct task *task,
92 void taskqueue_drain(struct taskqueue *queue, struct task *task);
121 #define TASK_INIT(task, priority, func, context) do { \ argument
122 (task)->ta_pending = 0; \
123 (task)->ta_priority = (priority); \
124 (task)->ta_func = (func); \
125 (task)->ta_context = (context); \
|
| /freebsd-12.1/contrib/gdb/gdb/ |
| H A D | gnu-nat.c | 742 struct proc *task = inf->task; in inf_set_pid() local
760 if (task && task->port != task_port) in inf_set_pid()
778 inf->task->sc = inf->task->cur_sc = 1; in inf_set_pid()
878 if (inf->task && !inf->task->dead) in inf_set_traced()
910 struct proc *task = inf->task; in inf_update_suspends() local
922 if (task->sc > task->cur_sc) in inf_update_suspends()
935 if (task->sc != task->cur_sc) in inf_update_suspends()
991 struct proc *task = inf->task; in inf_validate_procs() local
1207 struct proc *task = inf->task; in inf_detach() local
1999 struct proc *task = current_inferior->task; in gnu_kill_inferior() local
[all …]
|
| /freebsd-12.1/contrib/ntp/lib/isc/tests/ |
| H A D | socket_test.c | 47 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 D | task_test.c | 42 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-12.1/contrib/apr-util/misc/ |
| H A D | apr_thread_pool.c | 160 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-12.1/contrib/llvm/tools/lldb/source/Plugins/Process/Darwin/ |
| H A D | MachException.cpp | 38 mach_port_t task, exception_type_t exception,
51 mach_port_t exception_port, mach_port_t thread, mach_port_t task,
246 bool MachException::Message::CatchExceptionRaise(task_t task) { in CatchExceptionRaise() argument
248 state.task_port = task; in CatchExceptionRaise()
377 Status MachException::PortInfo::Save(task_t task) { in Save() argument
383 task); in Save()
400 task, mask, count); in Save()
404 task, mask, count, error.GetError(), error.AsCString()); in Save()
420 task, mask, count); in Save()
436 Status MachException::PortInfo::Restore(task_t task) { in Restore() argument
[all …]
|
| /freebsd-12.1/sys/contrib/zstd/contrib/pzstd/utils/ |
| H A D | ThreadPool.h | 31 std::function<void()> task; in ThreadPool()
32 while (tasks_.pop(task)) { in ThreadPool()
33 task(); in ThreadPool()
54 void add(std::function<void()> task) { in add() argument
55 tasks_.push(std::move(task)); in add()
|
| /freebsd-12.1/sys/dev/usb/net/ |
| H A D | usb_ethernet.c | 109 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()
371 struct usb_ether *ue = task->ue; in ue_start_task()
390 struct usb_ether *ue = task->ue; in ue_stop_task()
424 struct usb_ether *ue = task->ue; in ue_promisc_task()
434 struct usb_ether *ue = task->ue; in ue_setmulti_task()
466 struct usb_ether *ue = task->ue; in ue_ifmedia_task()
[all …]
|