Lines Matching refs:rq_state
33 req->rq_state = (bio_data_dir(bio_src) == WRITE ? RQ_WRITE : 0) in drbd_req_new()
75 const unsigned s = req->rq_state; in drbd_req_destroy()
195 const unsigned s = req->rq_state; in drbd_req_complete()
268 req->rq_state |= RQ_POSTPONED; in drbd_req_complete()
270 if (!(req->rq_state & RQ_POSTPONED)) { in drbd_req_complete()
295 D_ASSERT(device, m || (req->rq_state & RQ_POSTPONED)); in drbd_req_put_completion_ref()
307 if (req->rq_state & RQ_LOCAL_ABORTED) in drbd_req_put_completion_ref()
310 if (req->rq_state & RQ_POSTPONED) { in drbd_req_put_completion_ref()
340 const unsigned int s = iter->rq_state; in advance_conn_req_next()
370 const unsigned int s = iter->rq_state; in advance_conn_req_ack_pending()
400 const unsigned int s = iter->rq_state; in advance_conn_req_not_net_done()
417 unsigned s = req->rq_state; in mod_rq_state()
425 req->rq_state &= ~clear; in mod_rq_state()
426 req->rq_state |= set; in mod_rq_state()
429 if (req->rq_state == s) in mod_rq_state()
458 if (req->rq_state & RQ_NET_PENDING) in mod_rq_state()
471 D_ASSERT(device, req->rq_state & RQ_LOCAL_PENDING); in mod_rq_state()
476 if (req->rq_state & RQ_LOCAL_ABORTED) in mod_rq_state()
526 (req->rq_state & RQ_WRITE) ? "WRITE" : "READ", in drbd_report_io_error()
540 return (req->rq_state & in is_pending_write_protocol_A()
586 D_ASSERT(device, !(req->rq_state & RQ_NET_MASK)); in __req_mod()
591 req->rq_state |= in __req_mod()
599 D_ASSERT(device, !(req->rq_state & RQ_LOCAL_MASK)); in __req_mod()
604 if (req->rq_state & RQ_WRITE) in __req_mod()
656 D_ASSERT(device, req->rq_state & RQ_NET_PENDING); in __req_mod()
657 D_ASSERT(device, (req->rq_state & RQ_LOCAL_MASK) == 0); in __req_mod()
693 D_ASSERT(device, req->rq_state & RQ_NET_PENDING); in __req_mod()
759 D_ASSERT(device, req->rq_state & RQ_NET_PENDING); in __req_mod()
760 D_ASSERT(device, req->rq_state & RQ_EXP_WRITE_ACK); in __req_mod()
765 req->rq_state |= RQ_NET_SIS; in __req_mod()
777 D_ASSERT(device, req->rq_state & RQ_EXP_RECEIVE_ACK); in __req_mod()
786 D_ASSERT(device, req->rq_state & RQ_EXP_WRITE_ACK); in __req_mod()
791 D_ASSERT(device, req->rq_state & RQ_NET_PENDING); in __req_mod()
792 req->rq_state |= RQ_POSTPONED; in __req_mod()
805 if (!(req->rq_state & RQ_LOCAL_COMPLETED)) in __req_mod()
811 if (!(req->rq_state & RQ_LOCAL_COMPLETED)) in __req_mod()
830 if (!(req->rq_state & RQ_WRITE) && !req->w.cb) { in __req_mod()
840 if (!(req->rq_state & RQ_NET_OK)) { in __req_mod()
849 rv = req->rq_state & RQ_WRITE ? MR_WRITE : MR_READ; in __req_mod()
857 if (!(req->rq_state & RQ_WRITE)) in __req_mod()
860 if (req->rq_state & RQ_NET_PENDING) { in __req_mod()
871 (req->rq_state & RQ_NET_MASK) ? RQ_NET_DONE : 0); in __req_mod()
875 D_ASSERT(device, req->rq_state & RQ_NET_PENDING); in __req_mod()
1239 req->rq_state |= RQ_IN_ACT_LOG; in drbd_request_prepare()
1285 req->rq_state |= RQ_UNPLUG; in drbd_unplug()
1342 req->rq_state |= RQ_POSTPONED; in drbd_send_and_submit()
1457 req->rq_state |= RQ_IN_ACT_LOG; in submit_fast_path()
1502 req->rq_state |= RQ_IN_ACT_LOG; in send_and_submit_pending()
1641 if (net_req->rq_state & RQ_NET_PENDING) { in net_timeout_reached()