| /freebsd-13.1/sys/compat/linuxkpi/common/src/ |
| H A D | linux_work.c | 101 wq = work->work_queue; in linux_work_exec_unblock()
123 tq = dwork->work.work_queue->taskqueue; in linux_delayed_work_enqueue()
154 work->work_queue = wq; in linux_queue_work_on()
239 dwork->work.work_queue = wq; in linux_queue_delayed_work_on()
280 wq = work->work_queue; in linux_work_fn()
387 tq = work->work_queue->taskqueue; in linux_cancel_work_sync()
392 tq = work->work_queue->taskqueue; in linux_cancel_work_sync()
453 tq = dwork->work.work_queue->taskqueue; in linux_cancel_delayed_work()
500 tq = dwork->work.work_queue->taskqueue; in linux_cancel_delayed_work_sync()
535 tq = work->work_queue->taskqueue; in linux_flush_work()
[all …]
|
| /freebsd-13.1/share/examples/scsi_target/ |
| H A D | scsi_target.c | 78 static struct ccb_queue work_queue; variable
121 TAILQ_INIT(&work_queue); in main()
352 while ((ccb_h = TAILQ_FIRST(&work_queue)) != NULL) { in cleanup()
353 TAILQ_REMOVE(&work_queue, ccb_h, periph_links.tqe); in cleanup()
491 if ((ccb_h = TAILQ_FIRST(&work_queue)) != NULL) { in request_loop()
521 TAILQ_REMOVE(&work_queue, ccb_h, in request_loop()
531 if (!TAILQ_EMPTY(&work_queue)) in request_loop()
580 TAILQ_INSERT_TAIL(&work_queue, &ccb->ccb_h, in handle_read()
600 TAILQ_INSERT_HEAD(&work_queue, &ccb->ccb_h, in handle_read()
671 TAILQ_REMOVE(&work_queue, &atio->ccb_h, periph_links.tqe); in work_atio()
[all …]
|
| /freebsd-13.1/sys/cam/scsi/ |
| H A D | scsi_targ_bh.c | 88 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 | 83 struct descr_queue work_queue; member
216 TAILQ_INIT(&softc->work_queue); in targopen()
577 TAILQ_INSERT_TAIL(&softc->work_queue, in targwrite()
624 descr = TAILQ_FIRST(&softc->work_queue); in targstart()
628 TAILQ_REMOVE(&softc->work_queue, descr, tqe); in targstart()
629 next_descr = TAILQ_FIRST(&softc->work_queue); in targstart()
1024 while ((descr = TAILQ_FIRST(&softc->work_queue)) != NULL) { in abort_all_pending()
1027 TAILQ_REMOVE(&softc->work_queue, descr, tqe); in abort_all_pending()
|
| /freebsd-13.1/sys/compat/linuxkpi/common/include/linux/ |
| H A D | workqueue.h | 70 struct workqueue_struct *work_queue; member
117 (work)->work_queue = NULL; \
|
| /freebsd-13.1/sys/dev/mlx5/mlx5_core/ |
| H A D | mlx5_eswitch.c | 1012 flush_workqueue(esw->work_queue); in esw_disable_vport()
1118 esw->work_queue = create_singlethread_workqueue("mlx5_esw_wq"); in mlx5_eswitch_init()
1119 if (!esw->work_queue) { in mlx5_eswitch_init()
1150 if (esw->work_queue) in mlx5_eswitch_init()
1151 destroy_workqueue(esw->work_queue); in mlx5_eswitch_init()
1168 destroy_workqueue(esw->work_queue); in mlx5_eswitch_cleanup()
1188 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; member
|
| /freebsd-13.1/sys/cam/ctl/ |
| H A D | scsi_ctl.c | 110 STAILQ_HEAD(, ccb_hdr) work_queue;
466 STAILQ_INIT(&softc->work_queue); in ctlferegister()
781 ccb_h = STAILQ_FIRST(&softc->work_queue); in ctlfestart()
786 STAILQ_REMOVE_HEAD(&softc->work_queue, periph_links.stqe); in ctlfestart()
911 if (!STAILQ_EMPTY(&softc->work_queue)) in ctlfestart()
1240 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()
1922 STAILQ_INSERT_TAIL(&softc->work_queue, &ccb->ccb_h, in ctlfe_datamove()
1975 STAILQ_INSERT_TAIL(&softc->work_queue, &ccb->ccb_h, in ctlfe_done()
|
| /freebsd-13.1/usr.sbin/camdd/ |
| H A D | camdd.c | 398 STAILQ_HEAD(,camdd_buf) work_queue;
605 STAILQ_INIT(&dev->work_queue); in camdd_alloc_dev()
636 EV_SET(&ke[num_ke++], (uintptr_t)&dev->work_queue, EVFILT_USER, in camdd_alloc_dev()
1766 if ((STAILQ_EMPTY(&dev->work_queue))
1840 for (buf = STAILQ_FIRST(&dev->work_queue);
1842 buf = STAILQ_FIRST(&dev->work_queue)) {
1843 STAILQ_REMOVE_HEAD(&dev->work_queue,
2073 EV_SET(&ke, (uintptr_t)&dev->peer_dev->work_queue, EVFILT_USER, 0,
2126 STAILQ_INSERT_TAIL(&dev->peer_dev->work_queue, buf1,
3384 EV_SET(&ke, (uintptr_t)&devs[i]->work_queue,
|
| /freebsd-13.1/contrib/subversion/subversion/libsvn_wc/ |
| H A D | wc-queries.sql | 875 SELECT id FROM work_queue LIMIT 1
878 INSERT INTO work_queue (work) VALUES (?1)
881 SELECT id, work FROM work_queue ORDER BY id LIMIT 1
884 DELETE FROM work_queue WHERE id = ?1
|