Lines Matching refs:work_list
2077 static bool dequeue_work_batch(struct drbd_work_queue *queue, struct list_head *work_list) in dequeue_work_batch() argument
2080 list_splice_tail_init(&queue->q, work_list); in dequeue_work_batch()
2082 return !list_empty(work_list); in dequeue_work_batch()
2085 static void wait_for_work(struct drbd_connection *connection, struct list_head *work_list) in wait_for_work() argument
2091 dequeue_work_batch(&connection->sender_work, work_list); in wait_for_work()
2092 if (!list_empty(work_list)) in wait_for_work()
2118 list_splice_tail_init(&connection->sender_work.q, work_list); in wait_for_work()
2120 if (!list_empty(work_list) || signal_pending(current)) { in wait_for_work()
2175 LIST_HEAD(work_list); in drbd_worker()
2181 if (list_empty(&work_list)) { in drbd_worker()
2183 wait_for_work(connection, &work_list); in drbd_worker()
2203 if (!list_empty(&work_list)) { in drbd_worker()
2204 w = list_first_entry(&work_list, struct drbd_work, list); in drbd_worker()
2219 if (!list_empty(&work_list)) { in drbd_worker()
2220 w = list_first_entry(&work_list, struct drbd_work, list); in drbd_worker()
2225 dequeue_work_batch(&connection->sender_work, &work_list); in drbd_worker()
2226 } while (!list_empty(&work_list) || test_bit(DEVICE_WORK_PENDING, &connection->flags)); in drbd_worker()