| /openbsd-src/usr.bin/dig/lib/isc/ |
| H A D | task.c | 109 push_readyq(isc_taskmgr_t *manager, isc_task_t *task); 116 task_finished(isc_task_t *task) { in task_finished() argument 117 isc_taskmgr_t *manager = task->manager; in task_finished() 119 REQUIRE(EMPTY(task->events)); in task_finished() 120 REQUIRE(task->nevents == 0); in task_finished() 121 REQUIRE(EMPTY(task->on_shutdown)); in task_finished() 122 REQUIRE(task->references == 0); in task_finished() 123 REQUIRE(task->state == task_state_done); in task_finished() 125 UNLINK(manager->tasks, task, link); in task_finished() 127 free(task); in task_finished() [all …]
|
| H A D | timer.c | 39 isc_task_t * task; member 147 (void)isc_task_purgerange(timer->task, in destroy() 155 isc_task_detach(&timer->task); in destroy() 161 isc_task_t *task, isc_taskaction_t action, void *arg, in isc_timer_create() argument 177 REQUIRE(task != NULL); in isc_timer_create() 199 timer->task = NULL; in isc_timer_create() 200 isc_task_attach(task, &timer->task); in isc_timer_create() 221 isc_task_detach(&timer->task); in isc_timer_create() 253 (void)isc_task_purgerange(timer->task, in isc_timer_reset() 354 isc_task_send(timer->task, in dispatch()
|
| /openbsd-src/sys/dev/pci/drm/ |
| H A D | drm_flip_work.c | 39 struct drm_flip_task *task; in drm_flip_work_allocate_task() local 41 task = kzalloc(sizeof(*task), flags); in drm_flip_work_allocate_task() 42 if (task) in drm_flip_work_allocate_task() 43 task->data = data; in drm_flip_work_allocate_task() 45 return task; in drm_flip_work_allocate_task() 58 struct drm_flip_task *task) in drm_flip_work_queue_task() argument 63 list_add_tail(&task->node, &work->queued); in drm_flip_work_queue_task() 78 struct drm_flip_task *task; in drm_flip_work_queue() local 80 task = drm_flip_work_allocate_task(val, in drm_flip_work_queue() 82 if (task) { in drm_flip_work_queue() [all …]
|
| /openbsd-src/gnu/llvm/lldb/tools/debugserver/source/MacOSX/ |
| H A D | MachVMMemory.cpp | 33 nub_size_t MachVMMemory::PageSize(task_t task) { in PageSize() argument 36 if (task != TASK_NULL) { in PageSize() 40 kr = task_info(task, TASK_VM_INFO, (task_info_t)&vm_info, &info_count); in PageSize() 63 nub_size_t MachVMMemory::MaxBytesLeftInPage(task_t task, nub_addr_t addr, in MaxBytesLeftInPage() argument 65 const nub_size_t page_size = PageSize(task); in MaxBytesLeftInPage() 78 std::vector<nub_addr_t> get_dirty_pages(task_t task, mach_vm_address_t addr, in get_dirty_pages() argument 104 task, chunk_page_aligned_start_addr, in get_dirty_pages() 118 nub_bool_t MachVMMemory::GetMemoryRegionInfo(task_t task, nub_addr_t address, in GetMemoryRegionInfo() argument 120 MachVMRegion vmRegion(task); in GetMemoryRegionInfo() 127 get_dirty_pages(task, vmRegion.StartAddress(), vmRegion.GetByteSize()); in GetMemoryRegionInfo() [all …]
|
| H A D | MachTask.mm | 91 task_t task = TaskPort(); 92 err = ::task_suspend(task); 94 err.LogThreaded("::task_suspend ( target_task = 0x%4.4x )", task); 103 task_t task = TaskPort(); 104 if (task == TASK_NULL) 108 err = BasicInfo(task, &task_info); 112 err = ::task_resume(task); 115 "( target_task = 0x%4.4x )", task); 120 // task is not suspended, don't try and resume it since it is already 123 err = ::task_resume(task); [all …]
|
| H A D | MachVMMemory.h | 24 nub_size_t Read(task_t task, nub_addr_t address, void *data, 26 nub_size_t Write(task_t task, nub_addr_t address, const void *data, 28 nub_size_t PageSize(task_t task); 29 nub_bool_t GetMemoryRegionInfo(task_t task, nub_addr_t address, 31 nub_bool_t GetMemoryProfile(DNBProfileDataScanType scanType, task_t task, 38 nub_size_t MaxBytesLeftInPage(task_t task, nub_addr_t addr, nub_size_t count); 40 nub_size_t WriteRegion(task_t task, const nub_addr_t address,
|
| H A D | stack_logging.h | 80 __mach_stack_logging_get_frames(task_t task, mach_vm_address_t address, 86 task_t task, mach_vm_address_t address, 93 task_t task, uint64_t stack_identifier, 130 stack_logging_get_frames(task_t task, memory_reader_t reader, 140 task_t task, memory_reader_t reader, vm_address_t address, 146 task_t task, memory_reader_t reader, unsigned uniqued_stack,
|
| H A D | MachException.cpp | 27 mach_port_t task, exception_type_t exception, 40 mach_port_t exception_port, mach_port_t thread, mach_port_t task, 268 bool MachException::Message::CatchExceptionRaise(task_t task) { in CatchExceptionRaise() argument 270 state.task_port = task; in CatchExceptionRaise() 412 kern_return_t MachException::PortInfo::Save(task_t task) { in Save() argument 414 "MachException::PortInfo::Save ( task = 0x%4.4x )", task); in Save() 423 err = ::task_get_exception_ports(task, mask, masks, &count, ports, behaviors, in Save() 428 task, mask, count); in Save() 433 err = ::task_get_exception_ports(task, mask, masks, &count, ports, in Save() 438 task, mask, count); in Save() [all …]
|
| /openbsd-src/sys/dev/usb/ |
| H A D | usb.c | 192 /* explore task */ in usb_attach() 209 * until the USB task thread is running, which means that in usb_attach() 256 * To avoid races with the usb task thread, mark the root hub in usb_detach_roothub() 257 * as disconnecting and schedule an exploration task to detach in usb_detach_roothub() 263 * handler when unplugging an HC card otherwise the task won't be in usb_detach_roothub() 280 panic("unable to create usb abort task thread"); in usb_create_task_threads() 284 panic("unable to create usb task thread"); in usb_create_task_threads() 288 * Add a task to be performed by the task thread. This function can be 289 * called from any context and the task wil 293 usb_add_task(struct usbd_device * dev,struct usb_task * task) usb_add_task() argument 333 usb_rem_task(struct usbd_device * dev,struct usb_task * task) usb_rem_task() argument 364 usb_wait_task(struct usbd_device * dev,struct usb_task * task) usb_wait_task() argument 383 usb_rem_wait_task(struct usbd_device * dev,struct usb_task * task) usb_rem_wait_task() argument 392 struct usb_task *task; usb_task_thread() local 438 struct usb_task *task; usb_abort_task_thread() local [all...] |
| /openbsd-src/gnu/llvm/llvm/utils/vscode/llvm/src/ |
| H A D | litTaskProvider.ts | 8 task: string; property 36 const task = _task.definition.task; constant 37 if (task) { 40 if (definition.task === 'llvm-lit file') { 42 } else if (definition.task === 'llvm-lit directory') { 48 definition.task, 66 result.push(new vscode.Task({ type: 'llvm-lit', task: taskName }, 72 result.push(new vscode.Task({ type: 'llvm-lit', task: taskName },
|
| /openbsd-src/sys/dev/pci/drm/include/linux/ |
| H A D | workqueue.h | 73 struct task task; member 83 task_set(&work->task, (void (*)(void *))func, work); in INIT_WORK() 92 return task_add(work->tq, &work->task); in queue_work() 99 task_del(work->tq, &work->task); in cancel_work() 106 task_del(work->tq, &work->task); in cancel_work_sync() 109 #define work_pending(work) task_pending(&(work)->task) 130 task_add(dwork->tq, &dwork->work.task); in __delayed_work_tick() 151 .work.task = TASK_INITIALIZER((void (*)(void *))(fn), &(dw).work) \ 158 return task_add(work->tq, &work->task); in schedule_work() 191 return task_del(dwork->tq, &dwork->work.task); in cancel_delayed_work() [all …]
|
| H A D | interrupt.h | 58 struct task task; member 81 task_set(&ts->task, tasklet_run, ts); in tasklet_init() 93 task_set(&ts->task, tasklet_run, ts); in tasklet_setup() 113 task_del(taskletq, &ts->task); in tasklet_kill() 121 task_add(taskletq, &ts->task); in tasklet_schedule() 128 task_add(taskletq, &ts->task); in tasklet_hi_schedule()
|
| H A D | irq_work.h | 36 struct task task; member 47 task_set(&work->task, (void (*)(void *))func, work); in init_irq_work() 53 return task_add(work->tq, &work->task); in irq_work_queue()
|
| /openbsd-src/sys/sys/ |
| H A D | task.h | 26 struct task { struct 27 TAILQ_ENTRY(task) t_entry; 38 TAILQ_HEAD(task_list, task); argument 52 void taskq_del_barrier(struct taskq *, struct task *); 54 void task_set(struct task *, void (*)(void *), void *); 55 int task_add(struct taskq *, struct task *); 56 int task_del(struct taskq *, struct task *);
|
| /openbsd-src/gnu/usr.bin/binutils/gdb/ |
| H A D | gnu-nat.c | 133 (refport = inf->task->port, 0), 0, \ 172 struct proc *task; /* The mach task. */ member 328 int running = (proc->cur_sc == 0 && inf->task->cur_sc == 0); in proc_abort() 643 inf->task = 0; in make_inf() 742 struct proc *task = inf->task; in inf_set_pid() local 760 if (task && task->port != task_port) in inf_set_pid() 762 inf->task = 0; in inf_set_pid() 764 _proc_free (task); /* And the task. */ in inf_set_pid() 769 inf->task = make_proc (inf, task_port, PROC_TID_TASK); in inf_set_pid() 773 if (inf->task) in inf_set_pid() [all …]
|
| /openbsd-src/usr.sbin/iscsid/ |
| H A D | initiator.c | 39 struct task task; member 46 struct task task; member 55 struct pdu *initiator_text_build(struct task *, struct session *, 213 task_init(&tl->task, c->session, 1, tl, initiator_login_cb, NULL); in initiator_logout() 214 task_pdu_add(&tl->task, p); in initiator_logout() 215 conn_task_issue(c, &tl->task); in initiator_logout() 221 struct task *t; in initiator_logout() 280 task_init(&tl->task, in initiator_login_kvp() [all...] |
| H A D | iscsid.h | 75 TAILQ_HEAD(taskq, task); 287 struct task { argument 288 TAILQ_ENTRY(task) entry; argument 357 void session_task_issue(struct session *, struct task *); 358 void session_logout_issue(struct session *, struct task *); 366 void conn_task_issue(struct connection *, struct task *); 368 void conn_task_cleanup(struct connection *, struct task *); 399 void task_init(struct task *, struct session *, int, void *, 403 void task_pdu_add(struct task *, struct pdu *); 282 struct task { global() struct 284 sendqtask global() argument 285 recvqtask global() argument 286 callargtask global() argument 289 cmdseqnumtask global() argument 290 itttask global() argument 291 pendingtask global() argument
|
| H A D | vscsi.c | 43 struct task task; member 142 task_init(&t->task, s, 0, t, vscsi_callback, vscsi_fail); in vscsi_dispatch() 143 task_pdu_add(&t->task, p); in vscsi_dispatch() 144 session_task_issue(s, &t->task); in vscsi_dispatch() 221 conn_task_cleanup(c, &t->task); in vscsi_callback() 264 conn_task_cleanup(c, &t->task); in vscsi_callback() 270 conn_task_cleanup(c, &t->task); in vscsi_callback() 331 task_pdu_add(&t->task, p); in vscsi_dataout() 333 conn_task_issue(c, &t->task); in vscsi_dataout()
|
| /openbsd-src/usr.sbin/nsd/ |
| H A D | difffile.c | 1855 task_process_expire(namedb_type* db, struct task_list_d* task) in task_process_expire() argument 1858 zone_type* z = namedb_find_zone(db, task->zname); in task_process_expire() 1859 assert(task->task_type == task_expire); in task_process_expire() 1862 dname_to_string(task->zname, NULL), in task_process_expire() 1863 task->yesno?"expired":"unexpired")); in task_process_expire() 1867 dname_to_string(task->zname,0), in task_process_expire() 1868 task->yesno?"expired":"unexpired")); in task_process_expire() 1870 ok = !task->yesno; in task_process_expire() 1880 task_process_set_verbosity(struct task_list_d* task) in task_process_set_verbosity() argument 1882 DEBUG(DEBUG_IPC,1, (LOG_INFO, "verbosity task %d", (int)task->yesno)); in task_process_set_verbosity() [all …]
|
| /openbsd-src/usr.bin/dig/lib/isc/unix/ |
| H A D | app.c | 64 static isc_result_t isc_app_ctxonrun(isc_appctx_t *ctx, isc_task_t *task, 96 isc_app_onrun(isc_task_t *task, isc_taskaction_t action, in isc_app_onrun() argument 100 task, action, arg)); in isc_app_onrun() 104 isc_app_ctxonrun(isc_appctx_t *ctx, isc_task_t *task, in isc_app_ctxonrun() argument 120 isc_task_attach(task, &cloned_task); in isc_app_ctxonrun() 205 isc_task_t *task; in isc_app_ctxrun() local 218 task = event->ev_sender; in isc_app_ctxrun() 220 isc_task_sendanddetach(&task, &event); in isc_app_ctxrun()
|
| /openbsd-src/gnu/llvm/lldb/examples/darwin/heap_find/heap/ |
| H A D | heap_find.cpp | 100 extern "C" kern_return_t __mach_stack_logging_set_file_path(task_t task, 104 __mach_stack_logging_get_frames(task_t task, mach_vm_address_t address, 109 task_t task, mach_vm_address_t address, 113 task_t task, uint64_t stack_identifier, 119 static void range_info_callback(task_t task, void *baton, unsigned type, 131 typedef void range_callback_t(task_t task, void *baton, unsigned type, 457 static kern_return_t task_peek(task_t task, vm_address_t remote_address, in task_peek() argument 485 task_t task = mach_task_self(); in foreach_zone_in_this_process() local 497 task, &vm_region_base_addr, &vm_region_size, &vm_region_depth, in foreach_zone_in_this_process() 508 range_info_callback(task, info->baton, stack_logging_type_vm_region, in foreach_zone_in_this_process() [all …]
|
| /openbsd-src/usr.sbin/smtpd/ |
| H A D | mta_session.c | 115 struct mta_task *task; member 389 if (s->task) in mta_free() 390 fatalx("current task should have been deleted already"); in mta_free() 725 * possibly reuse the same task (forbidden in other cases). in mta_enter_state() 729 else if (s->task) in mta_enter_state() 730 fatalx("task should be NULL at this point"); in mta_enter_state() 732 if (s->task == NULL) in mta_enter_state() 733 s->task = mta_route_next_task(s->relay, s->route); in mta_enter_state() 734 if (s->task == NULL) { in mta_enter_state() 735 log_debug("debug: mta: %p: no task fo in mta_enter_state() [all...] |
| /openbsd-src/usr.bin/dig/lib/isc/include/isc/ |
| H A D | socket.h | 237 isc_socket_cancel(isc_socket_t *sock, isc_task_t *task, 335 isc_task_t *task, isc_taskaction_t action, 371 isc_task_t *task, isc_taskaction_t action, void *arg); 448 isc_task_t *task, isc_taskaction_t action, void *arg); 451 isc_task_t *task, isc_taskaction_t action, void *arg,
|
| /openbsd-src/sys/net/ |
| H A D | if_var.h | 45 #include <sys/task.h> 90 struct task; 190 struct task if_watchdogtask; /* [I] watchdog task */ 191 struct task if_linkstatetask; /* [I] task to do route updates */ 369 void if_addrhook_add(struct ifnet *, struct task *); 370 void if_addrhook_del(struct ifnet *, struct task *); 372 void if_linkstatehook_add(struct ifnet *, struct task *); 373 void if_linkstatehook_del(struct ifnet *, struct task *); [all...] |
| /openbsd-src/regress/usr.bin/nc/ |
| H A D | util.h | 19 struct task { struct 24 void task_enqueue(struct task *, int, const char *); argument 25 void task_run(int, struct task *, size_t);
|