Lines Matching refs:work_list
2069 static bool dequeue_work_batch(struct drbd_work_queue *queue, struct list_head *work_list) in dequeue_work_batch() argument
2072 list_splice_tail_init(&queue->q, work_list); in dequeue_work_batch()
2074 return !list_empty(work_list); in dequeue_work_batch()
2077 static void wait_for_work(struct drbd_connection *connection, struct list_head *work_list) in wait_for_work() argument
2083 dequeue_work_batch(&connection->sender_work, work_list); in wait_for_work()
2084 if (!list_empty(work_list)) in wait_for_work()
2110 list_splice_tail_init(&connection->sender_work.q, work_list); in wait_for_work()
2112 if (!list_empty(work_list) || signal_pending(current)) { in wait_for_work()
2167 LIST_HEAD(work_list); in drbd_worker()
2173 if (list_empty(&work_list)) { in drbd_worker()
2175 wait_for_work(connection, &work_list); in drbd_worker()
2195 if (!list_empty(&work_list)) { in drbd_worker()
2196 w = list_first_entry(&work_list, struct drbd_work, list); in drbd_worker()
2211 if (!list_empty(&work_list)) { in drbd_worker()
2212 w = list_first_entry(&work_list, struct drbd_work, list); in drbd_worker()
2217 dequeue_work_batch(&connection->sender_work, &work_list); in drbd_worker()
2218 } while (!list_empty(&work_list) || test_bit(DEVICE_WORK_PENDING, &connection->flags)); in drbd_worker()