| /f-stack/dpdk/examples/vhost_blk/ |
| H A D | blk.c | 44 struct vhost_blk_task *task, in vhost_bdev_blk_readwrite() argument
59 task->iovs[i].iov_len); in vhost_bdev_blk_readwrite()
62 task->iovs[i].iov_len); in vhost_bdev_blk_readwrite()
63 offset += task->iovs[i].iov_len; in vhost_bdev_blk_readwrite()
72 struct vhost_blk_task *task) in vhost_bdev_process_blk_commands() argument
81 switch (task->req->type) { in vhost_bdev_process_blk_commands()
89 task->req_idx); in vhost_bdev_process_blk_commands()
95 task->req->sector, task->data_len); in vhost_bdev_process_blk_commands()
104 task->req_idx); in vhost_bdev_process_blk_commands()
110 task->req->sector, task->data_len); in vhost_bdev_process_blk_commands()
[all …]
|
| H A D | vhost_blk.c | 320 if (setup_iovs_from_inflight_desc(task->ctrlr, task->vq, in process_blk_task()
321 task->req_idx, task->iovs, &task->iovs_cnt, in process_blk_task()
327 if (setup_iovs_from_descs_packed(task->ctrlr, task->vq, in process_blk_task()
328 task->req_idx, task->iovs, &task->iovs_cnt, in process_blk_task()
335 if (setup_iovs_from_descs_split(task->ctrlr, task->vq, in process_blk_task()
336 task->req_idx, task->iovs, &task->iovs_cnt, &payload)) { in process_blk_task()
344 assert(sizeof(*task->req) == task->iovs[0].iov_len); in process_blk_task()
347 task->status = (uint8_t *)task->iovs[task->iovs_cnt - 1].iov_base; in process_blk_task()
348 assert(sizeof(*task->status) == task->iovs[task->iovs_cnt - 1].iov_len); in process_blk_task()
351 task->data_len = payload - task->iovs[0].iov_len - in process_blk_task()
[all …]
|
| /f-stack/freebsd/contrib/openzfs/module/os/freebsd/spl/ |
| H A D | spl_taskq.c | 271 taskq_remove(task); in taskq_free()
315 task->tqent_func(task->tqent_arg); in taskq_run()
316 taskq_free(task); in taskq_run()
323 taskq_ent_t *task; in taskq_dispatch_delay() local
338 if (task == NULL) in taskq_dispatch_delay()
357 taskq_ent_t *task; in taskq_dispatch() local
372 if (task == NULL) in taskq_dispatch()
380 TASK_INIT(&task->tqent_task, prio, taskq_run, task); in taskq_dispatch()
390 task->tqent_func(task->tqent_arg); in taskq_run_ent()
406 task->tqent_id = 0; in taskq_dispatch_ent()
[all …]
|
| /f-stack/freebsd/kern/ |
| H A D | subr_taskqueue.c | 224 taskqueue_enqueue_locked(struct taskqueue *queue, struct task *task) in taskqueue_enqueue_locked() argument
226 struct task *ins; in taskqueue_enqueue_locked()
281 taskqueue_enqueue(struct taskqueue *queue, struct task *task) in taskqueue_enqueue() argument
452 struct task *task; in taskqueue_run_locked() local
480 task->ta_func(task->ta_context, pending); in taskqueue_run_locked()
483 wakeup(task); in taskqueue_run_locked()
500 task_is_running(struct taskqueue *queue, struct task *task) in task_is_running() argument
523 retval = task->ta_pending > 0 || task_is_running(queue, task); in taskqueue_poll_is_busy()
535 STAILQ_REMOVE(&queue->tq_queue, task, task, ta_link); in taskqueue_cancel_locked()
579 taskqueue_drain(struct taskqueue *queue, struct task *task) in taskqueue_drain() argument
[all …]
|
| H A D | sys_socket.c | 444 static STAILQ_HEAD(, task) soaio_jobs;
446 static struct task soaio_kproc_task;
472 struct task *task; in soaio_kproc_loop() local
490 task = STAILQ_FIRST(&soaio_jobs); in soaio_kproc_loop()
493 pending = task->ta_pending; in soaio_kproc_loop()
494 task->ta_pending = 0; in soaio_kproc_loop()
497 task->ta_func(task->ta_context, pending); in soaio_kproc_loop()
567 soaio_enqueue(struct task *task) in soaio_enqueue() argument
571 MPASS(task->ta_pending == 0); in soaio_enqueue()
572 task->ta_pending++; in soaio_enqueue()
[all …]
|
| H A D | subr_firmware.c | 129 static struct task firmware_unload_task;
290 struct task fwload_task; in firmware_get_flags()
393 struct task *setroot_task; in firmware_mountroot()
395 setroot_task = malloc(sizeof(struct task), M_TEMP, M_NOWAIT); in firmware_mountroot()
|
| /f-stack/app/nginx-1.16.1/src/core/ |
| H A D | ngx_thread_pool.c | 217 ngx_thread_task_t *task; in ngx_thread_task_alloc() local
220 if (task == NULL) { in ngx_thread_task_alloc()
224 task->ctx = task + 1; in ngx_thread_task_alloc()
226 return task; in ngx_thread_task_alloc()
252 task->event.active = 1; in ngx_thread_task_post()
255 task->next = NULL; in ngx_thread_task_post()
262 *tp->queue.last = task; in ngx_thread_task_post()
342 task->handler(task->ctx, tp->log); in ngx_thread_pool_cycle()
348 task->next = NULL; in ngx_thread_pool_cycle()
382 while (task) { in ngx_thread_pool_handler()
[all …]
|
| H A D | ngx_thread_pool.h | 33 ngx_int_t ngx_thread_task_post(ngx_thread_pool_t *tp, ngx_thread_task_t *task);
|
| /f-stack/dpdk/lib/librte_eal/windows/ |
| H A D | eal_alarm.c | 81 struct alarm_task *task = arg; in alarm_task_exec() local
82 task->ret = alarm_set(task->entry, task->deadline); in alarm_task_exec()
133 struct alarm_task task = { in rte_eal_alarm_set() local
144 ret = task.ret; in rte_eal_alarm_set()
217 struct intr_task *task = arg; in intr_thread_entry() local
218 task->func(task->arg); in intr_thread_entry()
225 struct intr_task task; in intr_thread_exec_sync() local
228 task.func = func; in intr_thread_exec_sync()
229 task.arg = arg; in intr_thread_exec_sync()
230 rte_spinlock_init(&task.lock); in intr_thread_exec_sync()
[all …]
|
| /f-stack/freebsd/sys/ |
| H A D | taskqueue.h | 50 struct task t;
84 int taskqueue_enqueue(struct taskqueue *queue, struct task *task);
90 int taskqueue_poll_is_busy(struct taskqueue *queue, struct task *task);
91 int taskqueue_cancel(struct taskqueue *queue, struct task *task,
95 void taskqueue_drain(struct taskqueue *queue, struct task *task);
123 #define TASK_INIT_FLAGS(task, priority, func, context, flags) do { \ argument
124 (task)->ta_pending = 0; \
125 (task)->ta_priority = (priority); \
126 (task)->ta_flags = (flags); \
127 (task)->ta_func = (func); \
[all …]
|
| H A D | _task.h | 48 struct task { struct
49 STAILQ_ENTRY(task) ta_link; /* (q) link for queue */
|
| H A D | gtaskqueue.h | 67 void gtaskqueue_drain(struct gtaskqueue *queue, struct gtask *task);
72 int grouptaskqueue_enqueue(struct gtaskqueue *queue, struct gtask *task);
|
| H A D | eventvar.h | 64 struct task kq_task;
|
| /f-stack/app/nginx-1.16.1/src/os/unix/ |
| H A D | ngx_linux_sendfile_chain.c | 318 ngx_thread_task_t *task; in ngx_linux_sendfile_thread() local
325 task = c->sendfile_task; in ngx_linux_sendfile_thread()
327 if (task == NULL) { in ngx_linux_sendfile_thread()
329 if (task == NULL) { in ngx_linux_sendfile_thread()
333 task->handler = ngx_linux_sendfile_thread_handler; in ngx_linux_sendfile_thread()
335 c->sendfile_task = task; in ngx_linux_sendfile_thread()
338 ctx = task->ctx; in ngx_linux_sendfile_thread()
341 if (task->event.complete) { in ngx_linux_sendfile_thread()
342 task->event.complete = 0; in ngx_linux_sendfile_thread()
380 if (task->event.active && ctx->file == file) { in ngx_linux_sendfile_thread()
[all …]
|
| H A D | ngx_files.c | 98 ngx_thread_task_t *task; in ngx_thread_read() local
105 task = file->thread_task; in ngx_thread_read()
107 if (task == NULL) { in ngx_thread_read()
109 if (task == NULL) { in ngx_thread_read()
113 file->thread_task = task; in ngx_thread_read()
116 ctx = task->ctx; in ngx_thread_read()
118 if (task->event.complete) { in ngx_thread_read()
487 task = file->thread_task; in ngx_thread_write_chain_to_file()
489 if (task == NULL) { in ngx_thread_write_chain_to_file()
492 if (task == NULL) { in ngx_thread_write_chain_to_file()
[all …]
|
| /f-stack/app/redis-5.0.5/deps/hiredis/ |
| H A D | hiredis.c | 106 r = createReplyObject(task->type); in createStringObject()
126 if (task->parent) { in createStringObject()
127 parent = task->parent->obj; in createStringObject()
129 parent->element[task->idx] = r; in createStringObject()
151 if (task->parent) { in createArrayObject()
152 parent = task->parent->obj; in createArrayObject()
154 parent->element[task->idx] = r; in createArrayObject()
168 if (task->parent) { in createIntegerObject()
169 parent = task->parent->obj; in createIntegerObject()
183 if (task->parent) { in createNilObject()
[all …]
|
| /f-stack/freebsd/contrib/openzfs/module/zfs/ |
| H A D | zvol.c | 1427 zvol_task_t *task; in zvol_task_alloc() local
1435 task->op = op; in zvol_task_alloc()
1444 return (task); in zvol_task_alloc()
1466 zvol_rename_minors_impl(task->name1, task->name2); in zvol_task_cb()
1469 zvol_set_snapdev_impl(task->name1, task->value); in zvol_task_cb()
1472 zvol_set_volmode_impl(task->name1, task->value); in zvol_task_cb()
1515 zvol_task_t *task; in zvol_set_snapdev_sync_cb() local
1522 if (task == NULL) in zvol_set_snapdev_sync_cb()
1608 if (task == NULL) in zvol_set_volmode_sync_cb()
1669 if (task == NULL) in zvol_remove_minors()
[all …]
|
| /f-stack/freebsd/net80211/ |
| H A D | ieee80211_var.h | 151 struct task ic_promisc_task;/* deferred promisc update */
152 struct task ic_mcast_task; /* deferred mcast update */
153 struct task ic_chan_task; /* deferred channel change */
155 struct task ic_chw_task; /* deferred HT CHW update */
156 struct task ic_restart_task; /* deferred device restart */
419 struct task iv_swbmiss_task;/* deferred iv_bmiss call */
574 struct task iv_wme_task; /* deferred VAP WME update */
845 ieee80211_runtask(struct ieee80211com *ic, struct task *task) in ieee80211_runtask() argument
847 taskqueue_enqueue(ic->ic_tq, task); in ieee80211_runtask()
854 ieee80211_draintask(struct ieee80211com *ic, struct task *task) in ieee80211_draintask() argument
[all …]
|
| /f-stack/dpdk/drivers/net/hinic/ |
| H A D | hinic_pmd_tx.c | 529 task->pkt_info2 |= in hinic_set_l4_csum_info()
532 task->pkt_info2 |= in hinic_set_l4_csum_info()
540 task->pkt_info1 |= in hinic_set_l4_csum_info()
542 task->pkt_info0 |= in hinic_set_l4_csum_info()
544 task->pkt_info1 |= in hinic_set_l4_csum_info()
546 task->pkt_info0 |= in hinic_set_l4_csum_info()
562 task->pkt_info0 |= in hinic_set_tso_info()
590 task->pkt_info0 = 0; in hinic_fill_tx_offload_info()
591 task->pkt_info1 = 0; in hinic_fill_tx_offload_info()
592 task->pkt_info2 = 0; in hinic_fill_tx_offload_info()
[all …]
|
| /f-stack/tools/compat/include/sys/ |
| H A D | _task.h | 47 struct task { struct
48 STAILQ_ENTRY(task) ta_link; /* (q) link for queue */
|
| /f-stack/app/nginx-1.16.1/src/http/ |
| H A D | ngx_http_copy_filter_module.c | 28 static ngx_int_t ngx_http_copy_thread_handler(ngx_thread_task_t *task,
263 ngx_http_copy_thread_handler(ngx_thread_task_t *task, ngx_file_t *file) in ngx_http_copy_thread_handler() argument
292 task->event.data = r; in ngx_http_copy_thread_handler()
293 task->event.handler = ngx_http_copy_thread_event_handler; in ngx_http_copy_thread_handler()
295 if (ngx_thread_task_post(tp, task) != NGX_OK) { in ngx_http_copy_thread_handler()
|
| /f-stack/freebsd/contrib/openzfs/config/ |
| H A D | kernel-userns-capabilities.m4 | 30 struct task_struct *task = NULL;
34 result = has_capability(task, cap);
|
| /f-stack/freebsd/net/ |
| H A D | bridgestp.h | 328 struct task bp_statetask;
329 struct task bp_rtagetask;
330 struct task bp_mediatask;
|
| /f-stack/dpdk/doc/guides/sample_app_ug/ |
| H A D | pipeline.rst | 114 1. *Packet processing task*: Process bursts of input packets read from the pipeline input ports.
116 2. *Message handling task*: Periodically, the data plane thread pauses the packet processing task a…
|
| /f-stack/app/micro_thread/ |
| H A D | mt_api.cpp | 483 IMtTask* task = (IMtTask*)arg; in mt_task_process() local
484 if (!task) in mt_task_process()
490 rc = task->Process(); in mt_task_process()
496 task->SetResult(rc); in mt_task_process()
505 IMtTask* task = NULL; in mt_exec_all_task() local
521 task = *it; in mt_exec_all_task()
522 sub = MtFrame::CreateThread(mt_task_process, task, false); in mt_exec_all_task()
|