Lines Matching refs:r_req_flags
1235 test_bit(CEPH_MDS_R_GOT_UNSAFE, &req->r_req_flags)) { in __unregister_request()
1292 bool is_hash = test_bit(CEPH_MDS_R_DIRECT_IS_HASH, &req->r_req_flags); in __choose_mds()
2928 if (test_bit(CEPH_MDS_R_FSCRYPT_FILE, &req->r_req_flags)) { in encode_mclientrequest_tail()
2990 &req->r_req_flags)); in create_request_message()
3064 if (test_bit(CEPH_MDS_R_FSCRYPT_FILE, &req->r_req_flags)) in create_request_message()
3295 if (test_bit(CEPH_MDS_R_GOT_UNSAFE, &req->r_req_flags)) { in __prepare_send_request()
3346 if (test_bit(CEPH_MDS_R_GOT_UNSAFE, &req->r_req_flags)) in __prepare_send_request()
3348 if (test_bit(CEPH_MDS_R_ASYNC, &req->r_req_flags)) in __prepare_send_request()
3395 if (req->r_err || test_bit(CEPH_MDS_R_GOT_RESULT, &req->r_req_flags)) { in __do_request()
3396 if (test_bit(CEPH_MDS_R_ABORTED, &req->r_req_flags)) in __do_request()
3441 if (test_bit(CEPH_MDS_R_ASYNC, &req->r_req_flags)) { in __do_request()
3480 if (test_bit(CEPH_MDS_R_ASYNC, &req->r_req_flags)) { in __do_request()
3525 if (test_bit(CEPH_MDS_R_ASYNC, &req->r_req_flags) && req->r_num_fwd) { in __do_request()
3542 set_bit(CEPH_MDS_R_ABORTED, &req->r_req_flags); in __do_request()
3625 if (test_bit(CEPH_MDS_R_GOT_UNSAFE, &req->r_req_flags)) in kick_requests()
3711 if (test_bit(CEPH_MDS_R_GOT_RESULT, &req->r_req_flags)) { in ceph_mdsc_wait_request()
3723 set_bit(CEPH_MDS_R_ABORTED, &req->r_req_flags); in ceph_mdsc_wait_request()
3827 if ((test_bit(CEPH_MDS_R_GOT_UNSAFE, &req->r_req_flags) && !head->safe) || in handle_reply()
3828 (test_bit(CEPH_MDS_R_GOT_SAFE, &req->r_req_flags) && head->safe)) { in handle_reply()
3834 if (test_bit(CEPH_MDS_R_GOT_SAFE, &req->r_req_flags)) { in handle_reply()
3844 set_bit(CEPH_MDS_R_GOT_SAFE, &req->r_req_flags); in handle_reply()
3851 if (test_bit(CEPH_MDS_R_GOT_UNSAFE, &req->r_req_flags)) { in handle_reply()
3865 set_bit(CEPH_MDS_R_GOT_UNSAFE, &req->r_req_flags); in handle_reply()
3953 test_bit(CEPH_MDS_R_GOT_UNSAFE, &req->r_req_flags)) { in handle_reply()
3966 if (!test_bit(CEPH_MDS_R_ABORTED, &req->r_req_flags)) { in handle_reply()
3971 set_bit(CEPH_MDS_R_GOT_RESULT, &req->r_req_flags); in handle_reply()
4025 if (test_bit(CEPH_MDS_R_ABORTED, &req->r_req_flags)) { in handle_forward()
4039 set_bit(CEPH_MDS_R_ABORTED, &req->r_req_flags); in handle_forward()
4048 BUG_ON(test_bit(CEPH_MDS_R_GOT_RESULT, &req->r_req_flags)); in handle_forward()
4441 if (test_bit(CEPH_MDS_R_GOT_UNSAFE, &req->r_req_flags)) in replay_unsafe_requests()