Home
last modified time | relevance | path

Searched refs:sender_work (Results 1 – 7 of 7) sorted by relevance

/linux/drivers/block/drbd/
H A Ddrbd_worker.c96 drbd_queue_work(&peer_device->connection->sender_work, &peer_req->w); in drbd_endio_read_sec_final()
449 &first_peer_device(device)->connection->sender_work, in resync_timer_fn()
878 drbd_queue_work(&connection->sender_work, &dw->w); in drbd_resync_finished()
2073 dequeue_work_batch(&connection->sender_work, work_list); in wait_for_work()
2096 prepare_to_wait(&connection->sender_work.q_wait, &wait, TASK_INTERRUPTIBLE); in wait_for_work()
2098 spin_lock(&connection->sender_work.q_lock); /* FIXME get rid of this one? */ in wait_for_work()
2099 if (!list_empty(&connection->sender_work.q)) in wait_for_work()
2100 list_splice_tail_init(&connection->sender_work.q, work_list); in wait_for_work()
2101 spin_unlock(&connection->sender_work.q_lock); /* FIXME get rid of this one? */ in wait_for_work()
2135 finish_wait(&connection->sender_work.q_wait, &wait); in wait_for_work()
[all …]
H A Ddrbd_req.c161 wake_up(&connection->sender_work.q_wait); in wake_all_senders()
661 drbd_queue_work(&connection->sender_work, in __req_mod()
697 drbd_queue_work(&connection->sender_work, in __req_mod()
713 drbd_queue_work(&connection->sender_work, in __req_mod()
825 drbd_queue_work(&connection->sender_work, in __req_mod()
848 drbd_queue_work(&connection->sender_work, in __req_mod()
H A Ddrbd_int.h682 struct drbd_work_queue sender_work; member
1817 struct drbd_work_queue *q = &connection->sender_work; in drbd_device_post_work()
2182 connection->sender_work, in dec_ap_bio()
H A Ddrbd_nl.c1367 drbd_flush_workqueue(&connection->sender_work); in conn_reconfig_start()
1915 drbd_flush_workqueue(&connection->sender_work); in drbd_adm_attach()
2598 drbd_flush_workqueue(&connection->sender_work); in drbd_adm_connect()
2984 drbd_flush_workqueue(&first_peer_device(device)->connection->sender_work); in drbd_adm_invalidate()
3062 drbd_flush_workqueue(&first_peer_device(device)->connection->sender_work); in drbd_adm_invalidate_peer()
4376 drbd_flush_workqueue(&connection->sender_work); in adm_del_minor()
H A Ddrbd_main.c1917 &first_peer_device(device)->connection->sender_work, in drbd_queue_unplug()
2046 D_ASSERT(device, list_empty(&first_peer_device(device)->connection->sender_work.q)); in drbd_device_cleanup()
2582 drbd_init_workqueue(&connection->sender_work); in conn_create()
3503 drbd_queue_work(&peer_device->connection->sender_work, in drbd_queue_bitmap_io()
H A Ddrbd_state.c1480 drbd_queue_work(&connection->sender_work, in _drbd_set_state()
2364 drbd_queue_work(&connection->sender_work, &acscw->w); in _conn_request_state()
H A Ddrbd_receiver.c5012 drbd_flush_workqueue(&peer_device->connection->sender_work); in drbd_disconnected()
5019 drbd_flush_workqueue(&peer_device->connection->sender_work); in drbd_disconnected()
5699 drbd_queue_work(&peer_device->connection->sender_work, &dw->w); in got_OVResult()