Lines Matching refs:work_list
2074 static bool dequeue_work_batch(struct drbd_work_queue *queue, struct list_head *work_list) in dequeue_work_batch() argument
2077 list_splice_tail_init(&queue->q, work_list); in dequeue_work_batch()
2079 return !list_empty(work_list); in dequeue_work_batch()
2082 static void wait_for_work(struct drbd_connection *connection, struct list_head *work_list) in wait_for_work() argument
2088 dequeue_work_batch(&connection->sender_work, work_list); in wait_for_work()
2089 if (!list_empty(work_list)) in wait_for_work()
2115 list_splice_tail_init(&connection->sender_work.q, work_list); in wait_for_work()
2117 if (!list_empty(work_list) || signal_pending(current)) { in wait_for_work()
2172 LIST_HEAD(work_list); in drbd_worker()
2178 if (list_empty(&work_list)) { in drbd_worker()
2180 wait_for_work(connection, &work_list); in drbd_worker()
2200 if (!list_empty(&work_list)) { in drbd_worker()
2201 w = list_first_entry(&work_list, struct drbd_work, list); in drbd_worker()
2216 if (!list_empty(&work_list)) { in drbd_worker()
2217 w = list_first_entry(&work_list, struct drbd_work, list); in drbd_worker()
2222 dequeue_work_batch(&connection->sender_work, &work_list); in drbd_worker()
2223 } while (!list_empty(&work_list) || test_bit(DEVICE_WORK_PENDING, &connection->flags)); in drbd_worker()