Home
last modified time | relevance | path

Searched refs:work_list (Results 1 – 25 of 30) sorted by relevance

12

/linux/io_uring/
H A Dtw.c173 if (mpscq_push(&ctx->work_list, &req->io_task_work.node)) { in io_req_local_work_add()
258 while (!mpscq_empty(&ctx->work_list)) { in io_cancel_local_task_work()
261 node = mpscq_pop(&ctx->work_list, &ctx->work_head); in io_cancel_local_task_work()
292 struct llist_node *node = mpscq_pop(&ctx->work_list, &ctx->work_head); in __io_run_local_work_loop()
H A Dio-wq.c104 struct io_wq_work_list work_list; member
274 !wq_list_empty(&acct->work_list); in __io_acct_run_queue()
449 if (wq_list_empty(&acct->work_list)) in io_wq_hash_defer()
453 next = container_of(acct->work_list.first, struct io_wq_work, list); in io_wq_hash_defer()
536 wq_list_for_each(node, prev, &acct->work_list) { in io_get_next_work()
545 wq_list_del(&acct->work_list, node, prev); in io_get_next_work()
556 wq_list_cut(&acct->work_list, &tail->list, prev); in io_get_next_work()
1015 wq_list_add_tail(&work->list, &acct->work_list); in io_wq_insert_work()
1025 wq_list_add_after(&work->list, &tail->list, &acct->work_list); in io_wq_insert_work()
1141 wq_list_del(&acct->work_list, &work->list, prev); in io_wq_remove_pending()
[all …]
/linux/drivers/block/drbd/
H A Ddrbd_worker.c2059 static bool dequeue_work_batch(struct drbd_work_queue *queue, struct list_head *work_list) in dequeue_work_batch() argument
2062 list_splice_tail_init(&queue->q, work_list); in dequeue_work_batch()
2064 return !list_empty(work_list); in dequeue_work_batch()
2067 static void wait_for_work(struct drbd_connection *connection, struct list_head *work_list) in wait_for_work() argument
2073 dequeue_work_batch(&connection->sender_work, work_list); in wait_for_work()
2074 if (!list_empty(work_list)) in wait_for_work()
2100 list_splice_tail_init(&connection->sender_work.q, work_list); in wait_for_work()
2102 if (!list_empty(work_list) || signal_pending(current)) { in wait_for_work()
2157 LIST_HEAD(work_list); in drbd_worker()
2163 if (list_empty(&work_list)) { in drbd_worker()
[all …]
H A Ddrbd_receiver.c242 LIST_HEAD(work_list); in drbd_free_peer_reqs()
247 list_splice_init(list, &work_list); in drbd_free_peer_reqs()
250 list_for_each_entry_safe(peer_req, t, &work_list, w.list) { in drbd_free_peer_reqs()
262 LIST_HEAD(work_list); in drbd_finish_peer_reqs()
267 list_splice_init(&device->done_ee, &work_list); in drbd_finish_peer_reqs()
274 list_for_each_entry_safe(peer_req, t, &work_list, w.list) { in drbd_finish_peer_reqs()
/linux/tools/perf/
H A Dbuiltin-sched.c179 struct list_head work_list;
1221 INIT_LIST_HEAD(&atoms->work_list); in latency_runtime_event()
1233 if (!list_empty(&atoms->work_list)) { in latency_runtime_event()
1234 atom = list_entry(atoms->work_list.prev, struct work_atom, list); in latency_runtime_event()
1245 list_add_tail(&atom->list, &atoms->work_list); in latency_wakeup_event()
1267 BUG_ON(list_empty(&atoms->work_list)); in latency_wakeup_event()
1269 atom = list_entry(atoms->work_list.prev, struct work_atom, list); in latency_wakeup_event()
1283 if (list_empty(&atoms->work_list)) in latency_wakeup_event()
1286 atom = list_entry(atoms->work_list.prev, struct work_atom, list); in latency_wakeup_event()
1325 list_for_each_entry_safe(atom, tmp, &atoms->work_list, lis in latency_migrate_task_event()
115 struct list_head work_list; global() member
1352 output_lat_thread(struct perf_sched * sched,struct work_atoms * work_list) output_lat_thread() argument
3527 struct work_atoms *work_list; perf_sched__lat() local
[all...]
/linux/drivers/dma/idxd/
H A Dirq.c115 list_add_tail(&d->list, &ie->work_list); in idxd_abort_invalid_int_handle_descs()
118 list_for_each_entry_safe(d, t, &ie->work_list, list) { in idxd_abort_invalid_int_handle_descs()
622 &irq_entry->work_list); in irq_process_pending_llist()
638 if (list_empty(&irq_entry->work_list)) { in irq_process_work_list()
643 list_for_each_entry_safe(desc, n, &irq_entry->work_list, list) { in irq_process_work_list()
H A Dsubmit.c81 list_for_each_entry_safe(d, n, &ie->work_list, list) { in list_abort_desc()
121 list_add_tail(&d->list, &ie->work_list); in llist_abort_desc()
H A Didxd.h90 struct list_head work_list; member
H A Ddevice.c1283 list_add_tail(&desc->list, &ie->work_list); in idxd_flush_pending_descs()
1286 list_for_each_entry_safe(desc, itr, &ie->work_list, list) in idxd_flush_pending_descs()
/linux/drivers/android/binder/
H A Dthread.rs266 work_list: List<DTRWrap<dyn DeliverToRead>>, field
295 work_list: List::new(), in new()
306 let ret = self.work_list.pop_front(); in pop_work()
307 self.process_work_list = !self.work_list.is_empty(); in pop_work()
315 self.work_list.push_back(work); in push_work()
342 self.work_list.push_back(work); in push_work_deferred()
468 if print_all || inner.current_transaction.is_some() || !inner.work_list.is_empty() { in debug_print()
492 for work in &inner.work_list { in debug_print()
1474 !inner.work_list.is_empty(), in read()
/linux/drivers/dma/
H A Dpl330.c429 struct list_head work_list; member
2047 list_for_each_entry(desc, &pch->work_list, node) { in fill_queue()
2079 list_for_each_entry_safe(desc, _dt, &pch->work_list, node) in pl330_tasklet()
2089 if (list_empty(&pch->work_list)) { in pl330_tasklet()
2112 list_move_tail(&desc->node, &pch->work_list); in pl330_tasklet()
2305 list_for_each_entry(desc, &pch->work_list , node) { in pl330_terminate_all()
2311 list_splice_tail_init(&pch->work_list, &pl330->desc_pool); in pl330_terminate_all()
2342 list_for_each_entry(desc, &pch->work_list, node) { in pl330_pause()
2367 list_splice_tail_init(&pch->work_list, &pch->dmac->desc_pool); in pl330_free_chan_resources()
2428 list_for_each_entry(desc, &pch->work_list, node) { in pl330_tx_status()
[all …]
/linux/sound/soc/fsl/
H A Dimx-pcm-rpmsg.h496 struct work_of_rpmsg work_list[WORK_MAX_NUM]; member
H A Dimx-pcm-rpmsg.c115 memcpy(&info->work_list[index].msg, msg, in imx_rpmsg_insert_workqueue()
118 queue_work(info->rpmsg_wq, &info->work_list[index].work); in imx_rpmsg_insert_workqueue()
710 INIT_WORK(&info->work_list[i].work, imx_rpmsg_pcm_work); in imx_rpmsg_pcm_probe()
711 info->work_list[i].info = info; in imx_rpmsg_pcm_probe()
/linux/drivers/scsi/bnx2i/
H A Dbnx2i_init.c441 list_for_each_entry_safe(work, tmp, &p->work_list, list) { in bnx2i_cpu_offline()
491 INIT_LIST_HEAD(&p->work_list); in bnx2i_mod_init()
H A Dbnx2i_hwi.c1856 LIST_HEAD(work_list); in bnx2i_percpu_io_thread()
1862 while (!list_empty(&p->work_list)) { in bnx2i_percpu_io_thread()
1863 list_splice_init(&p->work_list, &work_list); in bnx2i_percpu_io_thread()
1866 list_for_each_entry_safe(work, tmp, &work_list, list) { in bnx2i_percpu_io_thread()
1934 list_add_tail(&bnx2i_work->list, &p->work_list); in bnx2i_queue_scsi_cmd_resp()
H A Dbnx2i.h779 struct list_head work_list; member
/linux/drivers/scsi/qedi/
H A Dqedi_main.c1236 list_add_tail(&qedi_cmd->cqe_work.list, &p->work_list); in qedi_queue_cqe()
1251 list_add_tail(&qedi_work->list, &p->work_list); in qedi_queue_cqe()
1921 LIST_HEAD(work_list); in qedi_percpu_io_thread()
1927 while (!list_empty(&p->work_list)) { in qedi_percpu_io_thread()
1928 list_splice_init(&p->work_list, &work_list); in qedi_percpu_io_thread()
1931 list_for_each_entry_safe(work, tmp, &work_list, list) { in qedi_percpu_io_thread()
1975 list_for_each_entry_safe(work, tmp, &p->work_list, list) { in qedi_cpu_offline()
2907 INIT_LIST_HEAD(&p->work_list); in qedi_init()
H A Dqedi.h380 struct list_head work_list; member
/linux/include/linux/
H A Dkthread.h147 struct list_head work_list; member
H A Dio_uring_types.h445 struct mpscq work_list; member
/linux/fs/
H A Dfs-writeback.c191 list_add_tail(&work->list, &wb->work_list); in wb_queue_work()
2252 !list_empty(&wb->work_list)) in wb_writeback()
2335 if (!list_empty(&wb->work_list)) { in get_next_work_item()
2336 work = list_entry(wb->work_list.next, in get_next_work_item()
2499 } while (!list_empty(&wb->work_list)); in wb_workfn()
2511 if (!list_empty(&wb->work_list)) in wb_workfn()
/linux/drivers/vhost/
H A Dvhost.c252 llist_add(&work->node, &worker->work_list); in vhost_worker_queue()
325 if (worker && !llist_empty(&worker->work_list)) in vhost_vq_has_work()
417 node = llist_del_all(&worker->work_list); in vhost_run_work_kthread_list()
444 node = llist_del_all(&worker->work_list); in vhost_run_work_list()
716 WARN_ON(!llist_empty(&worker->work_list)); in vhost_worker_destroy()
844 init_llist_head(&worker->work_list); in vhost_worker_create()
913 !llist_empty(&old_worker->work_list)); in __vhost_vq_attach_worker()
/linux/sound/soc/
H A Dsoc-dapm.c257 list_add_tail(&w->work_list, &list); in dapm_widget_invalidate_paths()
260 list_for_each_entry(w, &list, work_list) { in dapm_widget_invalidate_paths()
267 list_add_tail(&node->work_list, &list); in dapm_widget_invalidate_paths()
1456 list_for_each_entry(w, widgets, work_list)
1518 list_add_tail(&widget->work_list, list); in dapm_is_connected_ep()
/linux/drivers/scsi/qla4xxx/
H A Dql4_def.h809 struct list_head work_list; member
/linux/fs/ocfs2/dlm/
H A Ddlmcommon.h158 struct list_head work_list; member

12