| /freebsd/sys/compat/linuxkpi/common/src/ |
| H A D | linux_work.c | 99 wq = work->work_queue; in linux_work_exec_unblock()
121 tq = dwork->work.work_queue->taskqueue; in linux_delayed_work_enqueue()
152 work->work_queue = wq; in linux_queue_work_on()
240 dwork->work.work_queue = wq; in linux_queue_delayed_work_on()
282 wq = work->work_queue; in linux_work_fn()
386 tq = work->work_queue->taskqueue; in linux_cancel_work()
421 tq = work->work_queue->taskqueue; in linux_cancel_work_sync()
426 tq = work->work_queue->taskqueue; in linux_cancel_work_sync()
487 tq = dwork->work.work_queue->taskqueue; in linux_cancel_delayed_work()
533 tq = dwork->work.work_queue->taskqueue; in linux_cancel_delayed_work_sync_int()
[all …]
|
| /freebsd/share/examples/scsi_target/ |
| H A D | scsi_target.c | 76 static struct ccb_queue work_queue; variable
121 TAILQ_INIT(&work_queue); in main()
354 while ((ccb_h = TAILQ_FIRST(&work_queue)) != NULL) { in cleanup()
355 TAILQ_REMOVE(&work_queue, ccb_h, periph_links.tqe); in cleanup()
493 if ((ccb_h = TAILQ_FIRST(&work_queue)) != NULL) { in request_loop()
523 TAILQ_REMOVE(&work_queue, ccb_h, in request_loop()
533 if (!TAILQ_EMPTY(&work_queue)) in request_loop()
582 TAILQ_INSERT_TAIL(&work_queue, &ccb->ccb_h, in handle_read()
602 TAILQ_INSERT_HEAD(&work_queue, &ccb->ccb_h, in handle_read()
673 TAILQ_REMOVE(&work_queue, &atio->ccb_h, periph_links.tqe); in work_atio()
[all …]
|
| /freebsd/sys/cam/scsi/ |
| H A D | scsi_targ_bh.c | 85 struct ccb_queue work_queue; member
405 TAILQ_INIT(&softc->work_queue); in targbhctor()
453 ccbh = TAILQ_FIRST(&softc->work_queue); in targbhstart()
457 TAILQ_REMOVE(&softc->work_queue, ccbh, periph_links.tqe); in targbhstart()
519 ccbh = TAILQ_FIRST(&softc->work_queue); in targbhstart()
633 TAILQ_INSERT_HEAD(&softc->work_queue, &atio->ccb_h, in targbhdone()
637 TAILQ_INSERT_TAIL(&softc->work_queue, &atio->ccb_h, in targbhdone()
|
| H A D | scsi_target.c | 80 struct descr_queue work_queue; member
213 TAILQ_INIT(&softc->work_queue); in targopen()
575 TAILQ_INSERT_TAIL(&softc->work_queue, in targwrite()
622 descr = TAILQ_FIRST(&softc->work_queue); in targstart()
626 TAILQ_REMOVE(&softc->work_queue, descr, tqe); in targstart()
627 next_descr = TAILQ_FIRST(&softc->work_queue); in targstart()
1034 while ((descr = TAILQ_FIRST(&softc->work_queue)) != NULL) { in abort_all_pending()
1037 TAILQ_REMOVE(&softc->work_queue, descr, tqe); in abort_all_pending()
|
| /freebsd/sys/compat/linuxkpi/common/include/linux/ |
| H A D | workqueue.h | 68 struct workqueue_struct *work_queue; member
115 (work)->work_queue = NULL; \
|
| /freebsd/sys/dev/mlx5/mlx5_core/ |
| H A D | mlx5_eswitch.c | 978 flush_workqueue(esw->work_queue); in esw_disable_vport()
1084 esw->work_queue = create_singlethread_workqueue("mlx5_esw_wq"); in mlx5_eswitch_init()
1085 if (!esw->work_queue) { in mlx5_eswitch_init()
1116 if (esw->work_queue) in mlx5_eswitch_init()
1117 destroy_workqueue(esw->work_queue); in mlx5_eswitch_init()
1134 destroy_workqueue(esw->work_queue); in mlx5_eswitch_cleanup()
1154 queue_work(esw->work_queue, &vport->vport_change_handler); in mlx5_eswitch_vport_event()
|
| H A D | eswitch.h | 137 struct workqueue_struct *work_queue;
135 struct workqueue_struct *work_queue; global() member
|
| /freebsd/sys/cam/ctl/ |
| H A D | scsi_ctl.c | 107 STAILQ_HEAD(, ccb_hdr) work_queue;
463 STAILQ_INIT(&softc->work_queue); in ctlferegister()
780 ccb_h = STAILQ_FIRST(&softc->work_queue); in ctlfestart()
785 STAILQ_REMOVE_HEAD(&softc->work_queue, periph_links.stqe); in ctlfestart()
910 if (!STAILQ_EMPTY(&softc->work_queue)) in ctlfestart()
1239 STAILQ_INSERT_HEAD(&softc->work_queue, &atio->ccb_h, in ctlfedone()
1867 STAILQ_FOREACH(hdr, &softc->work_queue, periph_links.stqe) { in ctlfe_dump_queue()
1921 STAILQ_INSERT_TAIL(&softc->work_queue, &ccb->ccb_h, in ctlfe_datamove()
1974 STAILQ_INSERT_TAIL(&softc->work_queue, &ccb->ccb_h, in ctlfe_done()
|
| /freebsd/usr.sbin/camdd/ |
| H A D | camdd.c | 389 STAILQ_HEAD(,camdd_buf) work_queue;
592 STAILQ_INIT(&dev->work_queue); in camdd_alloc_dev()
623 EV_SET(&ke[num_ke++], (uintptr_t)&dev->work_queue, EVFILT_USER, in camdd_alloc_dev()
1752 if ((STAILQ_EMPTY(&dev->work_queue))
1826 for (buf = STAILQ_FIRST(&dev->work_queue);
1828 buf = STAILQ_FIRST(&dev->work_queue)) {
1829 STAILQ_REMOVE_HEAD(&dev->work_queue,
2059 EV_SET(&ke, (uintptr_t)&dev->peer_dev->work_queue, EVFILT_USER, 0,
2112 STAILQ_INSERT_TAIL(&dev->peer_dev->work_queue, buf1,
3361 EV_SET(&ke, (uintptr_t)&devs[i]->work_queue,
|