Lines Matching refs:work_list
2059 static bool dequeue_work_batch(struct drbd_work_queue *queue, struct list_head *work_list) in dequeue_work_batch() argument
2062 list_splice_tail_init(&queue->q, work_list); in dequeue_work_batch()
2064 return !list_empty(work_list); in dequeue_work_batch()
2067 static void wait_for_work(struct drbd_connection *connection, struct list_head *work_list) in wait_for_work() argument
2073 dequeue_work_batch(&connection->sender_work, work_list); in wait_for_work()
2074 if (!list_empty(work_list)) in wait_for_work()
2100 list_splice_tail_init(&connection->sender_work.q, work_list); in wait_for_work()
2102 if (!list_empty(work_list) || signal_pending(current)) { in wait_for_work()
2157 LIST_HEAD(work_list); in drbd_worker()
2163 if (list_empty(&work_list)) { in drbd_worker()
2165 wait_for_work(connection, &work_list); in drbd_worker()
2185 if (!list_empty(&work_list)) { in drbd_worker()
2186 w = list_first_entry(&work_list, struct drbd_work, list); in drbd_worker()
2201 if (!list_empty(&work_list)) { in drbd_worker()
2202 w = list_first_entry(&work_list, struct drbd_work, list); in drbd_worker()
2207 dequeue_work_batch(&connection->sender_work, &work_list); in drbd_worker()
2208 } while (!list_empty(&work_list) || test_bit(DEVICE_WORK_PENDING, &connection->flags)); in drbd_worker()