Lines Matching refs:req
37 static void _drbd_start_io_acct(struct drbd_device *device, struct drbd_request *req) in _drbd_start_io_acct() argument
39 generic_start_io_acct(bio_data_dir(req->master_bio), req->i.size >> 9, in _drbd_start_io_acct()
44 static void _drbd_end_io_acct(struct drbd_device *device, struct drbd_request *req) in _drbd_end_io_acct() argument
46 generic_end_io_acct(bio_data_dir(req->master_bio), in _drbd_end_io_acct()
47 &device->vdisk->part0, req->start_jif); in _drbd_end_io_acct()
53 struct drbd_request *req; in drbd_req_new() local
55 req = mempool_alloc(drbd_request_mempool, GFP_NOIO); in drbd_req_new()
56 if (!req) in drbd_req_new()
58 memset(req, 0, sizeof(*req)); in drbd_req_new()
60 drbd_req_make_private_bio(req, bio_src); in drbd_req_new()
61 req->rq_state = bio_data_dir(bio_src) == WRITE ? RQ_WRITE : 0; in drbd_req_new()
62 req->device = device; in drbd_req_new()
63 req->master_bio = bio_src; in drbd_req_new()
64 req->epoch = 0; in drbd_req_new()
66 drbd_clear_interval(&req->i); in drbd_req_new()
67 req->i.sector = bio_src->bi_iter.bi_sector; in drbd_req_new()
68 req->i.size = bio_src->bi_iter.bi_size; in drbd_req_new()
69 req->i.local = true; in drbd_req_new()
70 req->i.waiting = false; in drbd_req_new()
72 INIT_LIST_HEAD(&req->tl_requests); in drbd_req_new()
73 INIT_LIST_HEAD(&req->w.list); in drbd_req_new()
74 INIT_LIST_HEAD(&req->req_pending_master_completion); in drbd_req_new()
75 INIT_LIST_HEAD(&req->req_pending_local); in drbd_req_new()
78 atomic_set(&req->completion_ref, 1); in drbd_req_new()
80 kref_init(&req->kref); in drbd_req_new()
81 return req; in drbd_req_new()
85 struct drbd_request *req) in drbd_remove_request_interval() argument
87 struct drbd_device *device = req->device; in drbd_remove_request_interval()
88 struct drbd_interval *i = &req->i; in drbd_remove_request_interval()
99 struct drbd_request *req = container_of(kref, struct drbd_request, kref); in drbd_req_destroy() local
100 struct drbd_device *device = req->device; in drbd_req_destroy()
101 const unsigned s = req->rq_state; in drbd_req_destroy()
103 if ((req->master_bio && !(s & RQ_POSTPONED)) || in drbd_req_destroy()
104 atomic_read(&req->completion_ref) || in drbd_req_destroy()
108 s, atomic_read(&req->completion_ref)); in drbd_req_destroy()
120 list_del_init(&req->tl_requests); in drbd_req_destroy()
124 if (!drbd_interval_empty(&req->i)) { in drbd_req_destroy()
131 drbd_remove_request_interval(root, req); in drbd_req_destroy()
132 } else if (s & (RQ_NET_MASK & ~RQ_NET_DONE) && req->i.size != 0) in drbd_req_destroy()
134 s, (unsigned long long)req->i.sector, req->i.size); in drbd_req_destroy()
153 drbd_set_out_of_sync(device, req->i.sector, req->i.size); in drbd_req_destroy()
156 drbd_set_in_sync(device, req->i.sector, req->i.size); in drbd_req_destroy()
171 drbd_al_complete_io(device, &req->i); in drbd_req_destroy()
176 (unsigned long long) req->i.sector, req->i.size); in drbd_req_destroy()
181 mempool_free(req, drbd_request_mempool); in drbd_req_destroy()
217 void drbd_req_complete(struct drbd_request *req, struct bio_and_error *m) in drbd_req_complete() argument
219 const unsigned s = req->rq_state; in drbd_req_complete()
220 struct drbd_device *device = req->device; in drbd_req_complete()
240 if (!req->master_bio) { in drbd_req_complete()
245 rw = bio_rw(req->master_bio); in drbd_req_complete()
261 error = PTR_ERR(req->private_bio); in drbd_req_complete()
271 req->epoch == atomic_read(&first_peer_device(device)->connection->current_tle_nr)) in drbd_req_complete()
275 _drbd_end_io_acct(device, req); in drbd_req_complete()
291 if (!ok && rw == READ && !list_empty(&req->tl_requests)) in drbd_req_complete()
292 req->rq_state |= RQ_POSTPONED; in drbd_req_complete()
294 if (!(req->rq_state & RQ_POSTPONED)) { in drbd_req_complete()
296 m->bio = req->master_bio; in drbd_req_complete()
297 req->master_bio = NULL; in drbd_req_complete()
302 req->i.completed = true; in drbd_req_complete()
305 if (req->i.waiting) in drbd_req_complete()
312 list_del_init(&req->req_pending_master_completion); in drbd_req_complete()
316 static int drbd_req_put_completion_ref(struct drbd_request *req, struct bio_and_error *m, int put) in drbd_req_put_completion_ref() argument
318 struct drbd_device *device = req->device; in drbd_req_put_completion_ref()
319 D_ASSERT(device, m || (req->rq_state & RQ_POSTPONED)); in drbd_req_put_completion_ref()
321 if (!atomic_sub_and_test(put, &req->completion_ref)) in drbd_req_put_completion_ref()
324 drbd_req_complete(req, m); in drbd_req_put_completion_ref()
326 if (req->rq_state & RQ_POSTPONED) { in drbd_req_put_completion_ref()
329 drbd_restart_request(req); in drbd_req_put_completion_ref()
336 static void set_if_null_req_next(struct drbd_peer_device *peer_device, struct drbd_request *req) in set_if_null_req_next() argument
342 connection->req_next = req; in set_if_null_req_next()
345 static void advance_conn_req_next(struct drbd_peer_device *peer_device, struct drbd_request *req) in advance_conn_req_next() argument
350 if (connection->req_next != req) in advance_conn_req_next()
352 list_for_each_entry_continue(req, &connection->transfer_log, tl_requests) { in advance_conn_req_next()
353 const unsigned s = req->rq_state; in advance_conn_req_next()
357 if (&req->tl_requests == &connection->transfer_log) in advance_conn_req_next()
358 req = NULL; in advance_conn_req_next()
359 connection->req_next = req; in advance_conn_req_next()
362 …ic void set_if_null_req_ack_pending(struct drbd_peer_device *peer_device, struct drbd_request *req) in set_if_null_req_ack_pending() argument
368 connection->req_ack_pending = req; in set_if_null_req_ack_pending()
371 …c void advance_conn_req_ack_pending(struct drbd_peer_device *peer_device, struct drbd_request *req) in advance_conn_req_ack_pending() argument
376 if (connection->req_ack_pending != req) in advance_conn_req_ack_pending()
378 list_for_each_entry_continue(req, &connection->transfer_log, tl_requests) { in advance_conn_req_ack_pending()
379 const unsigned s = req->rq_state; in advance_conn_req_ack_pending()
383 if (&req->tl_requests == &connection->transfer_log) in advance_conn_req_ack_pending()
384 req = NULL; in advance_conn_req_ack_pending()
385 connection->req_ack_pending = req; in advance_conn_req_ack_pending()
388 …c void set_if_null_req_not_net_done(struct drbd_peer_device *peer_device, struct drbd_request *req) in set_if_null_req_not_net_done() argument
394 connection->req_not_net_done = req; in set_if_null_req_not_net_done()
397 … void advance_conn_req_not_net_done(struct drbd_peer_device *peer_device, struct drbd_request *req) in advance_conn_req_not_net_done() argument
402 if (connection->req_not_net_done != req) in advance_conn_req_not_net_done()
404 list_for_each_entry_continue(req, &connection->transfer_log, tl_requests) { in advance_conn_req_not_net_done()
405 const unsigned s = req->rq_state; in advance_conn_req_not_net_done()
409 if (&req->tl_requests == &connection->transfer_log) in advance_conn_req_not_net_done()
410 req = NULL; in advance_conn_req_not_net_done()
411 connection->req_not_net_done = req; in advance_conn_req_not_net_done()
416 static void mod_rq_state(struct drbd_request *req, struct bio_and_error *m, in mod_rq_state() argument
419 struct drbd_device *device = req->device; in mod_rq_state()
421 unsigned s = req->rq_state; in mod_rq_state()
430 req->rq_state &= ~clear; in mod_rq_state()
431 req->rq_state |= set; in mod_rq_state()
434 if (req->rq_state == s) in mod_rq_state()
440 atomic_inc(&req->completion_ref); in mod_rq_state()
444 atomic_inc(&req->completion_ref); in mod_rq_state()
448 atomic_inc(&req->completion_ref); in mod_rq_state()
449 set_if_null_req_next(peer_device, req); in mod_rq_state()
453 kref_get(&req->kref); /* wait for the DONE */ in mod_rq_state()
458 atomic_add(req->i.size >> 9, &device->ap_in_flight); in mod_rq_state()
459 set_if_null_req_not_net_done(peer_device, req); in mod_rq_state()
462 set_if_null_req_ack_pending(peer_device, req); in mod_rq_state()
466 atomic_inc(&req->completion_ref); in mod_rq_state()
474 D_ASSERT(device, req->rq_state & RQ_LOCAL_PENDING); in mod_rq_state()
477 kref_get(&req->kref); in mod_rq_state()
482 if (req->rq_state & RQ_LOCAL_ABORTED) in mod_rq_state()
486 list_del_init(&req->req_pending_local); in mod_rq_state()
492 req->acked_jif = jiffies; in mod_rq_state()
493 advance_conn_req_ack_pending(peer_device, req); in mod_rq_state()
498 advance_conn_req_next(peer_device, req); in mod_rq_state()
503 atomic_sub(req->i.size >> 9, &device->ap_in_flight); in mod_rq_state()
506 req->net_done_jif = jiffies; in mod_rq_state()
511 advance_conn_req_next(peer_device, req); in mod_rq_state()
512 advance_conn_req_ack_pending(peer_device, req); in mod_rq_state()
513 advance_conn_req_not_net_done(peer_device, req); in mod_rq_state()
522 int refcount = atomic_read(&req->kref.refcount); in mod_rq_state()
526 s, req->rq_state, refcount, at_least); in mod_rq_state()
530 if (req->i.waiting) in mod_rq_state()
534 k_put += drbd_req_put_completion_ref(req, m, c_put); in mod_rq_state()
536 kref_sub(&req->kref, k_put, drbd_req_destroy); in mod_rq_state()
539 static void drbd_report_io_error(struct drbd_device *device, struct drbd_request *req) in drbd_report_io_error() argument
547 (req->rq_state & RQ_WRITE) ? "WRITE" : "READ", in drbd_report_io_error()
548 (unsigned long long)req->i.sector, in drbd_report_io_error()
549 req->i.size >> 9, in drbd_report_io_error()
559 static inline bool is_pending_write_protocol_A(struct drbd_request *req) in is_pending_write_protocol_A() argument
561 return (req->rq_state & in is_pending_write_protocol_A()
578 int __req_mod(struct drbd_request *req, enum drbd_req_event what, in __req_mod() argument
581 struct drbd_device *const device = req->device; in __req_mod()
604 D_ASSERT(device, !(req->rq_state & RQ_NET_MASK)); in __req_mod()
609 req->rq_state |= in __req_mod()
612 mod_rq_state(req, m, 0, RQ_NET_PENDING); in __req_mod()
617 D_ASSERT(device, !(req->rq_state & RQ_LOCAL_MASK)); in __req_mod()
618 mod_rq_state(req, m, 0, RQ_LOCAL_PENDING); in __req_mod()
622 if (req->rq_state & RQ_WRITE) in __req_mod()
623 device->writ_cnt += req->i.size >> 9; in __req_mod()
625 device->read_cnt += req->i.size >> 9; in __req_mod()
627 mod_rq_state(req, m, RQ_LOCAL_PENDING, in __req_mod()
632 mod_rq_state(req, m, 0, RQ_LOCAL_ABORTED); in __req_mod()
636 drbd_report_io_error(device, req); in __req_mod()
638 mod_rq_state(req, m, RQ_LOCAL_PENDING, RQ_LOCAL_COMPLETED); in __req_mod()
642 drbd_set_out_of_sync(device, req->i.sector, req->i.size); in __req_mod()
643 drbd_report_io_error(device, req); in __req_mod()
648 mod_rq_state(req, m, RQ_LOCAL_PENDING, RQ_LOCAL_COMPLETED); in __req_mod()
655 mod_rq_state(req, m, RQ_LOCAL_PENDING, RQ_LOCAL_COMPLETED); in __req_mod()
669 D_ASSERT(device, drbd_interval_empty(&req->i)); in __req_mod()
670 drbd_insert_interval(&device->read_requests, &req->i); in __req_mod()
674 D_ASSERT(device, req->rq_state & RQ_NET_PENDING); in __req_mod()
675 D_ASSERT(device, (req->rq_state & RQ_LOCAL_MASK) == 0); in __req_mod()
676 mod_rq_state(req, m, 0, RQ_NET_QUEUED); in __req_mod()
677 req->w.cb = w_send_read_req; in __req_mod()
679 &req->w); in __req_mod()
688 D_ASSERT(device, drbd_interval_empty(&req->i)); in __req_mod()
689 drbd_insert_interval(&device->write_requests, &req->i); in __req_mod()
711 D_ASSERT(device, req->rq_state & RQ_NET_PENDING); in __req_mod()
712 mod_rq_state(req, m, 0, RQ_NET_QUEUED|RQ_EXP_BARR_ACK); in __req_mod()
713 req->w.cb = w_send_dblock; in __req_mod()
715 &req->w); in __req_mod()
728 mod_rq_state(req, m, 0, RQ_NET_QUEUED); in __req_mod()
729 req->w.cb = w_send_out_of_sync; in __req_mod()
731 &req->w); in __req_mod()
739 mod_rq_state(req, m, RQ_NET_QUEUED, 0); in __req_mod()
744 if (is_pending_write_protocol_A(req)) in __req_mod()
747 mod_rq_state(req, m, RQ_NET_QUEUED|RQ_NET_PENDING, in __req_mod()
750 mod_rq_state(req, m, RQ_NET_QUEUED, RQ_NET_SENT); in __req_mod()
759 mod_rq_state(req, m, RQ_NET_QUEUED, RQ_NET_DONE); in __req_mod()
764 mod_rq_state(req, m, in __req_mod()
777 D_ASSERT(device, req->rq_state & RQ_NET_PENDING); in __req_mod()
778 D_ASSERT(device, req->rq_state & RQ_EXP_WRITE_ACK); in __req_mod()
779 mod_rq_state(req, m, RQ_NET_PENDING, RQ_NET_DONE|RQ_NET_OK); in __req_mod()
783 req->rq_state |= RQ_NET_SIS; in __req_mod()
794 D_ASSERT(device, req->rq_state & RQ_EXP_RECEIVE_ACK); in __req_mod()
799 mod_rq_state(req, m, RQ_NET_PENDING, RQ_NET_OK); in __req_mod()
803 D_ASSERT(device, req->rq_state & RQ_EXP_WRITE_ACK); in __req_mod()
808 D_ASSERT(device, req->rq_state & RQ_NET_PENDING); in __req_mod()
809 req->rq_state |= RQ_POSTPONED; in __req_mod()
810 if (req->i.waiting) in __req_mod()
818 mod_rq_state(req, m, RQ_NET_OK|RQ_NET_PENDING, 0); in __req_mod()
822 if (!(req->rq_state & RQ_LOCAL_COMPLETED)) in __req_mod()
824 mod_rq_state(req, m, RQ_COMPLETION_SUSP, 0); in __req_mod()
828 if (!(req->rq_state & RQ_LOCAL_COMPLETED)) in __req_mod()
831 mod_rq_state(req, m, in __req_mod()
836 if (bio_data_dir(req->master_bio) == WRITE) in __req_mod()
840 req->w.cb = w_restart_disk_io; in __req_mod()
842 &req->w); in __req_mod()
847 if (!(req->rq_state & RQ_WRITE) && !req->w.cb) { in __req_mod()
848 mod_rq_state(req, m, RQ_COMPLETION_SUSP, 0); in __req_mod()
857 if (!(req->rq_state & RQ_NET_OK)) { in __req_mod()
861 mod_rq_state(req, m, RQ_COMPLETION_SUSP, RQ_NET_QUEUED|RQ_NET_PENDING); in __req_mod()
862 if (req->w.cb) { in __req_mod()
865 &req->w); in __req_mod()
866 rv = req->rq_state & RQ_WRITE ? MR_WRITE : MR_READ; in __req_mod()
874 if (!(req->rq_state & RQ_WRITE)) in __req_mod()
877 if (req->rq_state & RQ_NET_PENDING) { in __req_mod()
887 mod_rq_state(req, m, RQ_COMPLETION_SUSP, in __req_mod()
888 (req->rq_state & RQ_NET_MASK) ? RQ_NET_DONE : 0); in __req_mod()
892 D_ASSERT(device, req->rq_state & RQ_NET_PENDING); in __req_mod()
893 mod_rq_state(req, m, RQ_NET_PENDING, RQ_NET_OK|RQ_NET_DONE); in __req_mod()
898 mod_rq_state(req, m, 0, RQ_NET_OK|RQ_NET_DONE); in __req_mod()
972 static void complete_conflicting_writes(struct drbd_request *req) in complete_conflicting_writes() argument
975 struct drbd_device *device = req->device; in complete_conflicting_writes()
977 sector_t sector = req->i.sector; in complete_conflicting_writes()
978 int size = req->i.size; in complete_conflicting_writes()
1056 static bool do_remote_read(struct drbd_request *req) in do_remote_read() argument
1058 struct drbd_device *device = req->device; in do_remote_read()
1061 if (req->private_bio) { in do_remote_read()
1063 req->i.sector, req->i.size)) { in do_remote_read()
1064 bio_put(req->private_bio); in do_remote_read()
1065 req->private_bio = NULL; in do_remote_read()
1073 if (req->private_bio == NULL) in do_remote_read()
1083 if (rbm == RB_PREFER_LOCAL && req->private_bio) in do_remote_read()
1086 if (remote_due_to_read_balancing(device, req->i.sector, rbm)) { in do_remote_read()
1087 if (req->private_bio) { in do_remote_read()
1088 bio_put(req->private_bio); in do_remote_read()
1089 req->private_bio = NULL; in do_remote_read()
1101 static int drbd_process_write_request(struct drbd_request *req) in drbd_process_write_request() argument
1103 struct drbd_device *device = req->device; in drbd_process_write_request()
1115 if (unlikely(req->i.size == 0)) { in drbd_process_write_request()
1117 D_ASSERT(device, req->master_bio->bi_rw & REQ_FLUSH); in drbd_process_write_request()
1119 _req_mod(req, QUEUE_AS_DRBD_BARRIER); in drbd_process_write_request()
1129 _req_mod(req, TO_BE_SENT); in drbd_process_write_request()
1130 _req_mod(req, QUEUE_FOR_NET_WRITE); in drbd_process_write_request()
1131 } else if (drbd_set_out_of_sync(device, req->i.sector, req->i.size)) in drbd_process_write_request()
1132 _req_mod(req, QUEUE_FOR_SEND_OOS); in drbd_process_write_request()
1138 drbd_submit_req_private_bio(struct drbd_request *req) in drbd_submit_req_private_bio() argument
1140 struct drbd_device *device = req->device; in drbd_submit_req_private_bio()
1141 struct bio *bio = req->private_bio; in drbd_submit_req_private_bio()
1152 req->pre_submit_jif = jiffies; in drbd_submit_req_private_bio()
1165 static void drbd_queue_write(struct drbd_device *device, struct drbd_request *req) in drbd_queue_write() argument
1168 list_add_tail(&req->tl_requests, &device->submit.writes); in drbd_queue_write()
1169 list_add_tail(&req->req_pending_master_completion, in drbd_queue_write()
1186 struct drbd_request *req; in drbd_request_prepare() local
1189 req = drbd_req_new(device, bio); in drbd_request_prepare()
1190 if (!req) { in drbd_request_prepare()
1199 req->start_jif = start_jif; in drbd_request_prepare()
1202 bio_put(req->private_bio); in drbd_request_prepare()
1203 req->private_bio = NULL; in drbd_request_prepare()
1207 _drbd_start_io_acct(device, req); in drbd_request_prepare()
1209 if (rw == WRITE && req->private_bio && req->i.size in drbd_request_prepare()
1211 if (!drbd_al_begin_io_fastpath(device, &req->i)) { in drbd_request_prepare()
1213 drbd_queue_write(device, req); in drbd_request_prepare()
1216 req->rq_state |= RQ_IN_ACT_LOG; in drbd_request_prepare()
1217 req->in_actlog_jif = jiffies; in drbd_request_prepare()
1220 return req; in drbd_request_prepare()
1223 static void drbd_send_and_submit(struct drbd_device *device, struct drbd_request *req) in drbd_send_and_submit() argument
1226 const int rw = bio_rw(req->master_bio); in drbd_send_and_submit()
1236 complete_conflicting_writes(req); in drbd_send_and_submit()
1247 req->rq_state |= RQ_POSTPONED; in drbd_send_and_submit()
1248 if (req->private_bio) { in drbd_send_and_submit()
1249 bio_put(req->private_bio); in drbd_send_and_submit()
1250 req->private_bio = NULL; in drbd_send_and_submit()
1260 if (!do_remote_read(req) && !req->private_bio) in drbd_send_and_submit()
1265 req->epoch = atomic_read(&first_peer_device(device)->connection->current_tle_nr); in drbd_send_and_submit()
1269 if (likely(req->i.size!=0)) { in drbd_send_and_submit()
1273 list_add_tail(&req->tl_requests, &first_peer_device(device)->connection->transfer_log); in drbd_send_and_submit()
1277 if (!drbd_process_write_request(req)) in drbd_send_and_submit()
1282 if (req->private_bio == NULL) { in drbd_send_and_submit()
1283 _req_mod(req, TO_BE_SENT); in drbd_send_and_submit()
1284 _req_mod(req, QUEUE_FOR_NET_READ); in drbd_send_and_submit()
1291 if (list_empty(&req->req_pending_master_completion)) in drbd_send_and_submit()
1292 list_add_tail(&req->req_pending_master_completion, in drbd_send_and_submit()
1294 if (req->private_bio) { in drbd_send_and_submit()
1296 list_add_tail(&req->req_pending_local, in drbd_send_and_submit()
1298 _req_mod(req, TO_BE_SUBMITTED); in drbd_send_and_submit()
1305 (unsigned long long)req->i.sector, req->i.size >> 9); in drbd_send_and_submit()
1311 if (drbd_req_put_completion_ref(req, &m, 1)) in drbd_send_and_submit()
1312 kref_put(&req->kref, drbd_req_destroy); in drbd_send_and_submit()
1322 drbd_submit_req_private_bio(req); in drbd_send_and_submit()
1329 struct drbd_request *req = drbd_request_prepare(device, bio, start_jif); in __drbd_make_request() local
1330 if (IS_ERR_OR_NULL(req)) in __drbd_make_request()
1332 drbd_send_and_submit(device, req); in __drbd_make_request()
1337 struct drbd_request *req, *tmp; in submit_fast_path() local
1338 list_for_each_entry_safe(req, tmp, incoming, tl_requests) { in submit_fast_path()
1339 const int rw = bio_data_dir(req->master_bio); in submit_fast_path()
1342 && req->private_bio && req->i.size in submit_fast_path()
1344 if (!drbd_al_begin_io_fastpath(device, &req->i)) in submit_fast_path()
1347 req->rq_state |= RQ_IN_ACT_LOG; in submit_fast_path()
1348 req->in_actlog_jif = jiffies; in submit_fast_path()
1352 list_del_init(&req->tl_requests); in submit_fast_path()
1353 drbd_send_and_submit(device, req); in submit_fast_path()
1362 struct drbd_request *req, *tmp; in prepare_al_transaction_nonblock() local
1367 list_for_each_entry_safe(req, tmp, incoming, tl_requests) { in prepare_al_transaction_nonblock()
1368 err = drbd_al_begin_io_nonblock(device, &req->i); in prepare_al_transaction_nonblock()
1374 list_move_tail(&req->tl_requests, later); in prepare_al_transaction_nonblock()
1376 list_move_tail(&req->tl_requests, pending); in prepare_al_transaction_nonblock()
1386 struct drbd_request *req, *tmp; in send_and_submit_pending() local
1388 list_for_each_entry_safe(req, tmp, pending, tl_requests) { in send_and_submit_pending()
1389 req->rq_state |= RQ_IN_ACT_LOG; in send_and_submit_pending()
1390 req->in_actlog_jif = jiffies; in send_and_submit_pending()
1392 list_del_init(&req->tl_requests); in send_and_submit_pending()
1393 drbd_send_and_submit(device, req); in send_and_submit_pending()