| /netbsd-src/external/mpl/dhcp/bind/dist/lib/isc/ |
| H A D | task.c | 1 /* $NetBSD: task.c,v 1.1 2024/02/18 20:57:50 christos Exp $ */ 19 * XXXRTH Need to document the states a task can be in, and the rules 39 #include <isc/task.h> 56 * Task manager is built around 'as little locking as possible' concept. 57 * Each thread has his own queue of tasks to be run, if a task is in running 58 * state it will stay on the runner it's currently on, if a task is in idle 62 * To make load even some tasks (from task pools) are bound to specific 69 fprintf(stderr, "task %p thread %zu: %s\n", task, isc_tid_v, (m)) 71 fprintf(stderr, "task %p thread %zu: %s\n", (t), isc_tid_v, (m)) 106 /* Locked by task lock. */ [all …]
|
| /netbsd-src/external/mpl/bind/dist/lib/isc/ |
| H A D | task.c | |
| /netbsd-src/external/mpl/dhcp/bind/dist/lib/isc/include/isc/ |
| H A D | task.h | 1 /* $NetBSD: task.h,v 1.1 2024/02/18 20:57:54 christos Exp $ */ 22 /*! \file isc/task.h 23 * \brief The task system provides a lightweight execution context, which is 26 * When a task's event queue is non-empty, the 27 * task is runnable. A small work crew of threads, typically one per CPU, 51 * Events which have been queued for a task but not delivered may be removed 52 * from the task's event queue by purging or unsending. 112 * Create a task, optionally bound to a particular threadid. 117 * before the task must yield to other tasks waiting to execute. If 118 * quantum is zero, then the default quantum of the task manager will [all …]
|
| /netbsd-src/external/mpl/bind/dist/lib/isc/include/isc/ |
| H A D | task.h | |
| /netbsd-src/external/gpl3/gcc/dist/libgomp/ |
| H A D | task.c | 26 /* This file handles the maintenance of tasks in response to task 63 /* Create a new task data structure. */ 66 gomp_init_task (struct gomp_task *task, struct gomp_task *parent_task, in gomp_init_task() argument 71 overhead of task creation low. In the nqueens-1.c test, for a in gomp_init_task() 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() [all …]
|
| H A D | taskloop.c | 29 /* Called when encountering an explicit task directive. If IF_CLAUSE is 30 false, then we must not delay in executing the task. If UNTIED is true, 31 then the task may be executed by any member of the team. */ 43 /* If pthread_mutex_* is used for omp_*lock*, then each task must be in GOMP_taskloop() 184 && 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() [all …]
|
| /netbsd-src/external/gpl3/gcc.old/dist/libgomp/ |
| H A D | task.c | 26 /* This file handles the maintenance of tasks in response to task 62 /* Create a new task data structure. */ 65 gomp_init_task (struct gomp_task *task, struct gomp_task *parent_task, in gomp_init_task() argument 70 overhead of task creation low. In the nqueens-1.c test, for a in gomp_init_task() 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() [all …]
|
| H A D | taskloop.c | 29 /* Called when encountering an explicit task directive. If IF_CLAUSE is 30 false, then we must not delay in executing the task. If UNTIED is true, 31 then the task may be executed by any member of the team. */ 43 /* If pthread_mutex_* is used for omp_*lock*, then each task must be in GOMP_taskloop() 165 && 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() [all …]
|
| /netbsd-src/external/gpl3/binutils/dist/gold/ |
| H A D | workqueue.h | 42 // specific task class will inherit from this one. 44 class Task 47 Task() in Task() function 50 virtual ~Task() in ~Task() 53 // Check whether the Task can be run now. This method is only 54 // called with the workqueue lock held. If the Task can run, this 56 // must be released before the Task can run. 60 // Lock all the resources required by the Task, and store the locks 67 // Run the task. 71 // Return whether this task should run soon. [all …]
|
| H A D | token.h | 30 class Task; variable 33 // class Task. We define this class here because we need it in 53 push_front(Task* t); 57 push_back(Task* t); 59 // Remove the first Task on the list and return it. Return NULL if 61 Task* 66 Task* head_; 68 Task* tail_; 74 // A write lock may be held by a single Task at a time. This is used 77 // A blocker is used to indicate that a Task A must be run after some [all …]
|
| H A D | workqueue.cc | 39 Task_list::push_back(Task* t) in push_back() 57 Task_list::push_front(Task* t) in push_front() 72 // Remove and return the first Task waiting for this lock to be 75 inline Task* 78 Task* ret = this->head_; in pop_front() 148 // Add a task to the end of a specific queue, or put it on the list 152 Workqueue::add_to_queue(Task_list* queue, Task* t, bool front) in add_to_queue() 176 // Add a task to the queue. 179 Workqueue::queue(Task* t) in queue() 184 // Queue a task which should run soon. [all …]
|
| H A D | readsyms.h | 41 // This Task is responsible for reading the symbols from an input 44 // been read, this queues up another task to actually add the symbols 49 class Read_symbols : public Task 55 // the associated Add_symbols task from running before the previous 56 // one has completed; it will be NULL for the first task. 78 // Requeue a Read_symbols task to search for the next object with 85 // The standard Task methods. 129 // This Task handles adding the symbols to the symbol table. These 133 class Add_symbols : public Task 136 // THIS_BLOCKER is used to prevent this task from running before the [all …]
|
| /netbsd-src/external/gpl3/binutils.old/dist/gold/ |
| H A D | workqueue.h | 42 // specific task class will inherit from this one. 44 class Task 47 Task() in Task() function 50 virtual ~Task() in ~Task() 53 // Check whether the Task can be run now. This method is only 54 // called with the workqueue lock held. If the Task can run, this 56 // must be released before the Task can run. 60 // Lock all the resources required by the Task, and store the locks 67 // Run the task. 71 // Return whether this task should run soon. [all …]
|
| H A D | token.h | 30 class Task; variable 33 // class Task. We define this class here because we need it in 53 push_front(Task* t); 57 push_back(Task* t); 59 // Remove the first Task on the list and return it. Return NULL if 61 Task* 66 Task* head_; 68 Task* tail_; 74 // A write lock may be held by a single Task at a time. This is used 77 // A blocker is used to indicate that a Task A must be run after some [all …]
|
| H A D | workqueue.cc | 39 Task_list::push_back(Task* t) in push_back() 57 Task_list::push_front(Task* t) in push_front() 72 // Remove and return the first Task waiting for this lock to be 75 inline Task* 78 Task* ret = this->head_; in pop_front() 148 // Add a task to the end of a specific queue, or put it on the list 152 Workqueue::add_to_queue(Task_list* queue, Task* t, bool front) in add_to_queue() 176 // Add a task to the queue. 179 Workqueue::queue(Task* t) in queue() 184 // Queue a task which should run soon. [all …]
|
| H A D | readsyms.h | 41 // This Task is responsible for reading the symbols from an input 44 // been read, this queues up another task to actually add the symbols 49 class Read_symbols : public Task 55 // the associated Add_symbols task from running before the previous 56 // one has completed; it will be NULL for the first task. 78 // Requeue a Read_symbols task to search for the next object with 85 // The standard Task methods. 129 // This Task handles adding the symbols to the symbol table. These 133 class Add_symbols : public Task 136 // THIS_BLOCKER is used to prevent this task from running before the [all …]
|
| /netbsd-src/sys/dev/sdmmc/ |
| H A D | ld_sdmmc.c | 71 #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 D | sun8i_crypto.c | 269 SDT_PROBE_DEFINE1(sdt, sun8i_crypto, task, ctor__success, 270 "struct sun8i_crypto_task *"/*task*/); 271 SDT_PROBE_DEFINE1(sdt, sun8i_crypto, task, ctor__failure, 273 SDT_PROBE_DEFINE1(sdt, sun8i_crypto, task, dtor, 274 "struct sun8i_crypto_task *"/*task*/); 275 SDT_PROBE_DEFINE1(sdt, sun8i_crypto, task, get, 276 "struct sun8i_crypto_task *"/*task*/); 277 SDT_PROBE_DEFINE1(sdt, sun8i_crypto, task, put, 278 "struct sun8i_crypto_task *"/*task*/); 280 SDT_PROBE_DEFINE6(sdt, sun8i_crypto, task, load, [all …]
|
| /netbsd-src/external/mit/libuv/dist/test/ |
| H A D | runner.c | 27 #include "task.h" 86 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() [all …]
|
| /netbsd-src/sbin/dmctl/ |
| H A D | dmctl.c | 152 libdm_task_t task; in main() local 198 * Create libdm task, and pass it to command handler later. in main() 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 [all …]
|
| /netbsd-src/external/mpl/bind/dist/tests/isc/ |
| H A D | task_test.c | |
| /netbsd-src/external/apache2/llvm/dist/llvm/utils/vscode/llvm/src/ |
| H A D | litTaskProvider.ts | 6 * The task name 8 task: string; property 15 private litPromise: Thenable<vscode.Task[]> | undefined = undefined; 28 public provideTasks(): Thenable<vscode.Task[]> | undefined { 35 public resolveTask(_task: vscode.Task): vscode.Task | undefined { 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') { 46 return new vscode.Task( [all …]
|
| /netbsd-src/external/gpl2/lvm2/dist/libdm/ioctl/ |
| H A D | libdm-nbsd-iface.c | 68 * names then dm task type 232 * Destroy dm task structure there are some dynamically alocated values there. 286 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() 660 /* Parse given dm task structure to proplib dictionary. */ 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() [all …]
|
| /netbsd-src/sys/external/bsd/drm2/dist/drm/ |
| H A D | drm_flip_work.c | 36 * drm_flip_work_allocate_task - allocate a flip-work task 37 * @data: data associated to the task 44 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() 55 * drm_flip_work_queue_task - queue a specific task 57 * @task: the task to handle 59 * Queues task, that will later be run (passed back to drm_flip_func_t [all …]
|
| /netbsd-src/sys/dev/usb/ |
| H A D | usb.c | 175 SDT_PROBE_DEFINE3(usb, kernel, task, add, 176 "struct usbd_device *"/*dev*/, "struct usb_task *"/*task*/, "int"/*q*/); 177 SDT_PROBE_DEFINE2(usb, kernel, task, rem__start, 178 "struct usbd_device *"/*dev*/, "struct usb_task *"/*task*/); 179 SDT_PROBE_DEFINE3(usb, kernel, task, rem__done, 181 "struct usb_task *"/*task*/, 183 SDT_PROBE_DEFINE4(usb, kernel, task, rem__wait__start, 185 "struct usb_task *"/*task*/, 188 SDT_PROBE_DEFINE5(usb, kernel, task, rem__wait__done, 190 "struct usb_task *"/*task*/, [all …]
|