Home
last modified time | relevance | path

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

12345678910>>...27

/netbsd-src/external/mpl/dhcp/bind/dist/lib/isc/
H A Dtask.c69 fprintf(stderr, "task %p thread %zu: %s\n", task, isc_tid_v, (m))
161 isc_task_purgeevent(isc_task_t *task, isc_event_t *event);
163 isc_taskmgr_setexcltask(isc_taskmgr_t *mgr, isc_task_t *task);
172 task_finished(isc_task_t *task) { in task_finished() argument
173 isc_taskmgr_t *manager = task->manager; in task_finished()
175 REQUIRE(EMPTY(task->events)); in task_finished()
176 REQUIRE(task->nevents == 0); in task_finished()
177 REQUIRE(EMPTY(task->on_shutdown)); in task_finished()
178 REQUIRE(task->state == task_state_done); in task_finished()
182 isc_refcount_destroy(&task->running); in task_finished()
[all …]
H A Dratelimiter.c40 isc_task_t *task; member
53 ratelimiter_tick(isc_task_t *task, isc_event_t *event);
56 ratelimiter_shutdowncomplete(isc_task_t *task, isc_event_t *event);
60 isc_task_t *task, isc_ratelimiter_t **ratelimiterp) { in isc_ratelimiter_create() argument
68 .task = task, in isc_ratelimiter_create()
80 rl->task, ratelimiter_tick, rl, &rl->timer); in isc_ratelimiter_create()
144 isc_ratelimiter_enqueue(isc_ratelimiter_t *rl, isc_task_t *task, in isc_ratelimiter_enqueue() argument
150 REQUIRE(task != NULL); in isc_ratelimiter_enqueue()
159 ev->ev_sender = task; in isc_ratelimiter_enqueue()
170 ev->ev_sender = task; in isc_ratelimiter_enqueue()
[all …]
/netbsd-src/external/mpl/bind/dist/lib/isc/
H A Dtask.c
H A Dratelimiter.c40 isc_task_t *task; global() member
60 isc_ratelimiter_create(isc_mem_t * mctx,isc_timermgr_t * timermgr,isc_task_t * task,isc_ratelimiter_t ** ratelimiterp) isc_ratelimiter_create() argument
144 isc_ratelimiter_enqueue(isc_ratelimiter_t * rl,isc_task_t * task,isc_event_t ** eventp) isc_ratelimiter_enqueue() argument
203 ratelimiter_tick(isc_task_t * task,isc_event_t * event) ratelimiter_tick() argument
246 isc_task_t *task; isc_ratelimiter_shutdown() local
280 ratelimiter_shutdowncomplete(isc_task_t * task,isc_event_t * event) ratelimiter_shutdowncomplete() argument
/netbsd-src/external/gpl3/gcc/dist/libgomp/
H A Dtask.c66 gomp_init_task (struct gomp_task *task, struct gomp_task *parent_task, in gomp_init_task() argument
77 task->parent = parent_task; in gomp_init_task()
78 priority_queue_init (&task->children_queue); in gomp_init_task()
79 task->taskgroup = NULL; in gomp_init_task()
80 task->dependers = NULL; in gomp_init_task()
81 task->depend_hash = NULL; in gomp_init_task()
82 task->taskwait = NULL; in gomp_init_task()
83 task->depend_count = 0; in gomp_init_task()
84 task->completion_sem = NULL; in gomp_init_task()
85 task->deferred_p = false; in gomp_init_task()
[all …]
H A Dtaskloop.c184 && thr->task in GOMP_taskloop()
185 && thr->task->taskgroup) in GOMP_taskloop()
187 if (thr->task->taskgroup->cancelled) in GOMP_taskloop()
189 if (thr->task->taskgroup->workshare in GOMP_taskloop()
190 && thr->task->taskgroup->prev in GOMP_taskloop()
191 && thr->task->taskgroup->prev->cancelled) in GOMP_taskloop()
210 || (thr->task && thr->task->final_task) in GOMP_taskloop()
216 struct gomp_task task[num_tasks]; in GOMP_taskloop() local
217 struct gomp_task *parent = thr->task; in GOMP_taskloop()
225 gomp_init_task (&task[i], parent, gomp_icv (false)); in GOMP_taskloop()
[all …]
H A Dpriority_queue.c41 struct gomp_task *task) in priority_queue_task_in_list_p() argument
46 if (priority_node_to_task (type, p) == task) in priority_queue_task_in_list_p()
59 struct gomp_task *task) in priority_queue_task_in_tree_p() argument
62 = priority_queue_lookup_priority (head, task->priority); in priority_queue_task_in_tree_p()
65 return priority_queue_task_in_list_p (type, list, task); in priority_queue_task_in_tree_p()
74 struct gomp_task *task) in priority_queue_task_in_queue_p() argument
79 return priority_queue_task_in_tree_p (type, head, task); in priority_queue_task_in_queue_p()
81 return priority_queue_task_in_list_p (type, &head->l, task); in priority_queue_task_in_queue_p()
181 struct gomp_task *task = priority_tree_find (type, node->right, pred); in priority_tree_find() local
182 if (task) in priority_tree_find()
[all …]
/netbsd-src/external/gpl3/gcc.old/dist/libgomp/
H A Dtask.c65 gomp_init_task (struct gomp_task *task, struct gomp_task *parent_task, in gomp_init_task() argument
76 task->parent = parent_task; in gomp_init_task()
77 task->icv = *prev_icv; in gomp_init_task()
78 task->kind = GOMP_TASK_IMPLICIT; in gomp_init_task()
79 task->taskwait = NULL; in gomp_init_task()
80 task->in_tied_task = false; in gomp_init_task()
81 task->final_task = false; in gomp_init_task()
82 task->copy_ctors_done = false; in gomp_init_task()
83 task->parent_depends_on = false; in gomp_init_task()
84 priority_queue_init (&task->children_queue); in gomp_init_task()
[all …]
H A Dtaskloop.c165 && thr->task in GOMP_taskloop()
166 && thr->task->taskgroup) in GOMP_taskloop()
168 if (thr->task->taskgroup->cancelled) in GOMP_taskloop()
170 if (thr->task->taskgroup->workshare in GOMP_taskloop()
171 && thr->task->taskgroup->prev in GOMP_taskloop()
172 && thr->task->taskgroup->prev->cancelled) in GOMP_taskloop()
191 || (thr->task && thr->task->final_task) in GOMP_taskloop()
197 struct gomp_task task[num_tasks]; in GOMP_taskloop() local
198 struct gomp_task *parent = thr->task; in GOMP_taskloop()
206 gomp_init_task (&task[i], parent, gomp_icv (false)); in GOMP_taskloop()
[all …]
/netbsd-src/sbin/dmctl/
H A Ddmctl.c152 libdm_task_t task; in main() local
202 task = libdm_task_create(cmdname); in main()
204 (*commands[i].cmd_func)(argc, argv, task); in main()
214 dmctl_get_version(int argc __unused, char *argv[] __unused, libdm_task_t task) in dmctl_get_version() argument
218 (void)libdm_task_get_cmd_version(task, ver, sizeof(ver)); in dmctl_get_version()
222 if (libdm_task_run(task) != 0) in dmctl_get_version()
225 (void)libdm_task_get_cmd_version(task, ver, 3); in dmctl_get_version()
228 libdm_task_destroy(task); in dmctl_get_version()
236 dmctl_get_targets(int argc __unused, char *argv[] __unused, libdm_task_t task) in dmctl_get_targets() argument
243 if (libdm_task_run(task) != 0) in dmctl_get_targets()
[all …]
/netbsd-src/external/mit/libuv/dist/test/
H A Drunner.c86 task_entry_t* task; in run_tests() local
91 for (task = TASKS; task->main; task++, actual++) { in run_tests()
92 if (!task->is_helper) { in run_tests()
109 for (task = TASKS; task->main; task++) { in run_tests()
110 if (task->is_helper) { in run_tests()
114 test_result = run_test(task->task_name, benchmark_output, current); in run_tests()
170 task_entry_t* task; in run_test() local
189 for (task = TASKS; task->main; task++) { in run_test()
190 if (task->is_helper && strcmp(test, task->process_name) == 0) { in run_test()
191 return task->main(); in run_test()
[all …]
/netbsd-src/sys/dev/sdmmc/
H A Dld_sdmmc.c71 #define LD_SDMMC_MAXTASKCNT 8 /* number of tasks in task pool */
76 struct sdmmc_task task; member
130 struct ld_sdmmc_task *task; in ld_sdmmc_task_get() local
134 if (sc->sc_dying || (task = TAILQ_FIRST(&sc->sc_freeq)) == NULL) in ld_sdmmc_task_get()
136 TAILQ_REMOVE(&sc->sc_freeq, task, task_entry); in ld_sdmmc_task_get()
137 TAILQ_INSERT_TAIL(&sc->sc_xferq, task, task_entry); in ld_sdmmc_task_get()
138 KASSERT(task->task_bp == NULL); in ld_sdmmc_task_get()
139 KASSERT(task->task_errorp == NULL); in ld_sdmmc_task_get()
141 return task; in ld_sdmmc_task_get()
145 ld_sdmmc_task_put(struct ld_sdmmc_softc *sc, struct ld_sdmmc_task *task) in ld_sdmmc_task_put() argument
157 ld_sdmmc_task_cancel(struct ld_sdmmc_softc * sc,struct ld_sdmmc_task * task) ld_sdmmc_task_cancel() argument
248 struct ld_sdmmc_task *task; ld_sdmmc_attach() local
352 struct ld_sdmmc_task *task; ld_sdmmc_detach() local
399 struct ld_sdmmc_task *task; ld_sdmmc_start() local
424 struct ld_sdmmc_task *task = (struct ld_sdmmc_task *)arg; ld_sdmmc_restart() local
440 struct ld_sdmmc_task *task = (struct ld_sdmmc_task *)arg; ld_sdmmc_dobio() local
519 struct ld_sdmmc_task *task = arg; ld_sdmmc_dodiscard() local
551 struct ld_sdmmc_task *task; ld_sdmmc_discard() local
579 struct ld_sdmmc_task *task = arg; ld_sdmmc_docachesync() local
603 struct ld_sdmmc_task *task; ld_sdmmc_cachesync() local
[all...]
/netbsd-src/sys/arch/arm/sunxi/
H A Dsun8i_crypto.c269 SDT_PROBE_DEFINE1(sdt, sun8i_crypto, task, ctor__success,
271 SDT_PROBE_DEFINE1(sdt, sun8i_crypto, task, ctor__failure,
273 SDT_PROBE_DEFINE1(sdt, sun8i_crypto, task, dtor,
275 SDT_PROBE_DEFINE1(sdt, sun8i_crypto, task, get,
277 SDT_PROBE_DEFINE1(sdt, sun8i_crypto, task, put,
280 SDT_PROBE_DEFINE6(sdt, sun8i_crypto, task, load,
287 SDT_PROBE_DEFINE3(sdt, sun8i_crypto, task, misaligned,
291 SDT_PROBE_DEFINE2(sdt, sun8i_crypto, task, done,
510 struct sun8i_crypto_task *task = vtask; in sun8i_crypto_task_ctor() local
515 error = sun8i_crypto_allocbuf(sc, sizeof(*task->ct_desc), in sun8i_crypto_task_ctor()
[all …]
/netbsd-src/external/mpl/dhcp/bind/dist/lib/isc/include/isc/
H A Dtask.h144 isc_task_ready(isc_task_t *task);
150 isc_task_run(isc_task_t *task);
205 isc_task_send(isc_task_t *task, isc_event_t **eventp);
208 isc_task_sendto(isc_task_t *task, isc_event_t **eventp, int c);
254 isc_task_purgerange(isc_task_t *task, void *sender, isc_eventtype_t first,
280 isc_task_purge(isc_task_t *task, void *sender, isc_eventtype_t type, void *tag);
311 isc_task_purgeevent(isc_task_t *task, isc_event_t *event);
343 isc_task_unsendrange(isc_task_t *task, void *sender, isc_eventtype_t first,
371 isc_task_unsend(isc_task_t *task, void *sender, isc_eventtype_t type, void *tag,
402 isc_task_onshutdown(isc_task_t *task, isc_taskaction_t action, void *arg);
[all …]
/netbsd-src/external/mpl/bind/dist/lib/isc/include/isc/
H A Dtask.h
/netbsd-src/external/mpl/bind/dist/tests/isc/
H A Dtask_test.c
/netbsd-src/external/gpl2/lvm2/dist/libdm/ioctl/
H A Dlibdm-nbsd-iface.c286 struct dm_task *task; in _check_version() local
289 if (!(task = dm_task_create(DM_DEVICE_VERSION))) { in _check_version()
295 r = dm_task_run(task); in _check_version()
296 dm_task_get_driver_version(task, version, size); in _check_version()
297 dm_task_destroy(task); in _check_version()
661 static int _flatten(struct dm_task *dmt, libdm_task_t task) in _flatten() argument
748 libdm_task_set_minor(dmt->minor, task); in _flatten()
753 libdm_task_set_name(dmt->dev_name, task); in _flatten()
756 libdm_task_set_uuid(dmt->uuid, task); in _flatten()
774 libdm_task_set_flags(task, flags); in _flatten()
[all …]
H A Dlibdm_netbsd.c102 nbsd_dm_dict_to_dmi(libdm_task_t task, const int cmd) in nbsd_dm_dict_to_dmi() argument
121 dmi->open_count = libdm_task_get_open_num(task); in nbsd_dm_dict_to_dmi()
122 dmi->event_nr = libdm_task_get_event_num(task); in nbsd_dm_dict_to_dmi()
123 dmi->flags = libdm_task_get_flags(task); in nbsd_dm_dict_to_dmi()
124 dmi->target_count = libdm_task_get_target_num(task); in nbsd_dm_dict_to_dmi()
126 minor = libdm_task_get_minor(task); in nbsd_dm_dict_to_dmi()
133 name = libdm_task_get_name(task); in nbsd_dm_dict_to_dmi()
134 uuid = libdm_task_get_uuid(task); in nbsd_dm_dict_to_dmi()
151 libdm_task_get_cmd_version(task, dmi->version, 3); in nbsd_dm_dict_to_dmi()
156 r = dm_list_versions(task, dmi); in nbsd_dm_dict_to_dmi()
[all …]
/netbsd-src/sys/external/bsd/drm2/dist/drm/
H A Ddrm_flip_work.c44 struct drm_flip_task *task; in drm_flip_work_allocate_task() local
46 task = kzalloc(sizeof(*task), flags); in drm_flip_work_allocate_task()
47 if (task) in drm_flip_work_allocate_task()
48 task->data = data; in drm_flip_work_allocate_task()
50 return task; in drm_flip_work_allocate_task()
63 struct drm_flip_task *task) in drm_flip_work_queue_task() argument
68 list_add_tail(&task->node, &work->queued); in drm_flip_work_queue_task()
83 struct drm_flip_task *task; in drm_flip_work_queue() local
85 task = drm_flip_work_allocate_task(val, in drm_flip_work_queue()
87 if (task) { in drm_flip_work_queue()
[all …]
/netbsd-src/external/gpl3/gcc.old/dist/libgomp/config/nvptx/
H A Dteam.c105 struct gomp_task *task = thr->task; in gomp_thread_start() local
107 gomp_finish_task (task); in gomp_thread_start()
123 struct gomp_task *task; in gomp_team_start() local
130 task = thr->task; in gomp_team_start()
131 icv = task ? &task->icv : &gomp_global_icv; in gomp_team_start()
147 thr->task = &team->implicit_task[0]; in gomp_team_start()
149 gomp_init_task (thr->task, task, icv); in gomp_team_start()
168 nthr->task = &team->implicit_task[i]; in gomp_team_start()
169 gomp_init_task (nthr->task, task, icv); in gomp_team_start()
/netbsd-src/sys/dev/usb/
H A Dusb.c175 SDT_PROBE_DEFINE3(usb, kernel, task, add,
177 SDT_PROBE_DEFINE2(usb, kernel, task, rem__start,
179 SDT_PROBE_DEFINE3(usb, kernel, task, rem__done,
183 SDT_PROBE_DEFINE4(usb, kernel, task, rem__wait__start,
188 SDT_PROBE_DEFINE5(usb, kernel, task, rem__wait__done,
195 SDT_PROBE_DEFINE1(usb, kernel, task, start, "struct usb_task *"/*task*/);
196 SDT_PROBE_DEFINE1(usb, kernel, task, done, "struct usb_task *"/*task*/);
565 usb_add_task(struct usbd_device *dev, struct usb_task *task, int queue) in usb_add_task() argument
570 SDT_PROBE3(usb, kernel, task, add, dev, task, queue); in usb_add_task()
576 if (atomic_cas_uint(&task->queue, USB_NUM_TASKQS, queue) == in usb_add_task()
[all …]
/netbsd-src/external/gpl3/gcc/dist/libgomp/config/nvptx/
H A Dteam.c108 struct gomp_task *task = thr->task; in gomp_thread_start() local
110 gomp_finish_task (task); in gomp_thread_start()
126 struct gomp_task *task; in gomp_team_start() local
133 task = thr->task; in gomp_team_start()
134 icv = task ? &task->icv : &gomp_global_icv; in gomp_team_start()
150 thr->task = &team->implicit_task[0]; in gomp_team_start()
152 gomp_init_task (thr->task, task, icv); in gomp_team_start()
171 nthr->task = &team->implicit_task[i]; in gomp_team_start()
172 gomp_init_task (nthr->task, task, icv); in gomp_team_start()
/netbsd-src/external/gpl3/gcc/dist/libgomp/config/gcn/
H A Dteam.c142 struct gomp_task *task = thr->task; in gomp_thread_start() local
144 gomp_finish_task (task); in gomp_thread_start()
157 struct gomp_task *task; in gomp_team_start() local
164 task = thr->task; in gomp_team_start()
165 icv = task ? &task->icv : &gomp_global_icv; in gomp_team_start()
181 thr->task = &team->implicit_task[0]; in gomp_team_start()
183 gomp_init_task (thr->task, task, icv); in gomp_team_start()
202 nthr->task = &team->implicit_task[i]; in gomp_team_start()
203 gomp_init_task (nthr->task, task, icv); in gomp_team_start()
/netbsd-src/external/gpl3/gcc.old/dist/libgomp/config/gcn/
H A Dteam.c142 struct gomp_task *task = thr->task; in gomp_thread_start() local
144 gomp_finish_task (task); in gomp_thread_start()
157 struct gomp_task *task; in gomp_team_start() local
164 task = thr->task; in gomp_team_start()
165 icv = task ? &task->icv : &gomp_global_icv; in gomp_team_start()
181 thr->task = &team->implicit_task[0]; in gomp_team_start()
183 gomp_init_task (thr->task, task, icv); in gomp_team_start()
202 nthr->task = &team->implicit_task[i]; in gomp_team_start()
203 gomp_init_task (nthr->task, task, icv); in gomp_team_start()
/netbsd-src/external/mpl/dhcp/bind/dist/lib/dns/
H A Dtcpmsg.c45 recv_length(isc_task_t *task, isc_event_t *ev_in) { in recv_length() argument
84 result = isc_socket_recv(tcpmsg->sock, &region, 0, task, recv_message, in recv_length()
95 isc_task_send(tcpmsg->task, &dev); in recv_length()
96 tcpmsg->task = NULL; in recv_length()
102 recv_message(isc_task_t *task, isc_event_t *ev_in) { in recv_message() argument
107 (void)task; in recv_message()
125 isc_task_send(tcpmsg->task, &dev); in recv_message()
126 tcpmsg->task = NULL; in recv_message()
143 tcpmsg->task = NULL; /* None yet. */ in dns_tcpmsg_init()
158 dns_tcpmsg_readmessage(dns_tcpmsg_t *tcpmsg, isc_task_t *task, in dns_tcpmsg_readmessage() argument
[all …]

12345678910>>...27