Lines Matching refs:w
105 list_del(&peer_req->w.list); in drbd_endio_read_sec_final()
112 drbd_queue_work(&peer_device->connection->sender_work, &peer_req->w); in drbd_endio_read_sec_final()
139 list_move_tail(&peer_req->w.list, &device->done_ee); in drbd_endio_write_sec_final()
320 static int w_e_send_csum(struct drbd_work *w, int cancel) in w_e_send_csum() argument
322 struct drbd_peer_request *peer_req = container_of(w, struct drbd_peer_request, w); in w_e_send_csum()
384 peer_req->w.cb = w_e_send_csum; in read_for_csum()
386 list_add_tail(&peer_req->w.list, &device->read_ee); in read_for_csum()
398 list_del(&peer_req->w.list); in read_for_csum()
407 int w_resync_timer(struct drbd_work *w, int cancel) in w_resync_timer() argument
410 container_of(w, struct drbd_device, resync_work); in w_resync_timer()
785 int w_ov_finished(struct drbd_work *w, int cancel) in w_ov_finished() argument
788 container_of(w, struct drbd_device_work, w); in w_ov_finished()
797 static int w_resync_finished(struct drbd_work *w, int cancel) in w_resync_finished() argument
800 container_of(w, struct drbd_device_work, w); in w_resync_finished()
840 dw->w.cb = w_resync_finished; in drbd_resync_finished()
843 &dw->w); in drbd_resync_finished()
983 list_add_tail(&peer_req->w.list, &device->net_ee); in move_to_net_ee_or_free()
996 int w_e_end_data_req(struct drbd_work *w, int cancel) in w_e_end_data_req() argument
998 struct drbd_peer_request *peer_req = container_of(w, struct drbd_peer_request, w); in w_e_end_data_req()
1033 int w_e_end_rsdata_req(struct drbd_work *w, int cancel) in w_e_end_rsdata_req() argument
1035 struct drbd_peer_request *peer_req = container_of(w, struct drbd_peer_request, w); in w_e_end_rsdata_req()
1083 int w_e_end_csum_rs_req(struct drbd_work *w, int cancel) in w_e_end_csum_rs_req() argument
1085 struct drbd_peer_request *peer_req = container_of(w, struct drbd_peer_request, w); in w_e_end_csum_rs_req()
1147 int w_e_end_ov_req(struct drbd_work *w, int cancel) in w_e_end_ov_req() argument
1149 struct drbd_peer_request *peer_req = container_of(w, struct drbd_peer_request, w); in w_e_end_ov_req()
1204 int w_e_end_ov_reply(struct drbd_work *w, int cancel) in w_e_end_ov_reply() argument
1206 struct drbd_peer_request *peer_req = container_of(w, struct drbd_peer_request, w); in w_e_end_ov_reply()
1298 int w_send_write_hint(struct drbd_work *w, int cancel) in w_send_write_hint() argument
1301 container_of(w, struct drbd_device, unplug_work); in w_send_write_hint()
1333 int w_send_out_of_sync(struct drbd_work *w, int cancel) in w_send_out_of_sync() argument
1335 struct drbd_request *req = container_of(w, struct drbd_request, w); in w_send_out_of_sync()
1364 int w_send_dblock(struct drbd_work *w, int cancel) in w_send_dblock() argument
1366 struct drbd_request *req = container_of(w, struct drbd_request, w); in w_send_dblock()
1393 int w_send_read_req(struct drbd_work *w, int cancel) in w_send_read_req() argument
1395 struct drbd_request *req = container_of(w, struct drbd_request, w); in w_send_read_req()
1419 int w_restart_disk_io(struct drbd_work *w, int cancel) in w_restart_disk_io() argument
1421 struct drbd_request *req = container_of(w, struct drbd_request, w); in w_restart_disk_io()
2066 struct drbd_work *w = NULL; in drbd_worker() local
2097 w = list_first_entry(&work_list, struct drbd_work, list); in drbd_worker()
2098 list_del_init(&w->list); in drbd_worker()
2099 update_worker_timing_details(connection, w->cb); in drbd_worker()
2100 if (w->cb(w, connection->cstate < C_WF_REPORT_PARAMS) == 0) in drbd_worker()
2113 w = list_first_entry(&work_list, struct drbd_work, list); in drbd_worker()
2114 list_del_init(&w->list); in drbd_worker()
2115 update_worker_timing_details(connection, w->cb); in drbd_worker()
2116 w->cb(w, 1); in drbd_worker()