Searched refs:rq_state (Results 1 – 8 of 8) sorted by relevance
61 req->rq_state = bio_data_dir(bio_src) == WRITE ? RQ_WRITE : 0; in drbd_req_new()101 const unsigned s = req->rq_state; in drbd_req_destroy()219 const unsigned s = req->rq_state; 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()319 D_ASSERT(device, m || (req->rq_state & RQ_POSTPONED)); in drbd_req_put_completion_ref()326 if (req->rq_state & RQ_POSTPONED) { in drbd_req_put_completion_ref()353 const unsigned s = req->rq_state; in advance_conn_req_next()379 const unsigned s = req->rq_state; in advance_conn_req_ack_pending()405 const unsigned s = req->rq_state; in advance_conn_req_not_net_done()[all …]
55 unsigned int s = req->rq_state; in seq_print_request_state()98 unsigned int s = req->rq_state; in seq_print_one_request()172 if (req && !(req->rq_state & RQ_IN_ACT_LOG)) in seq_print_waiting_for_AL()335 s = req->rq_state; in seq_print_resource_transfer_log_summary()
204 const unsigned s = r->rq_state; in tl_release()314 if (!(req->rq_state & RQ_LOCAL_PENDING)) in tl_abort_disk_io()1644 if (req->rq_state & RQ_EXP_RECEIVE_ACK) in drbd_send_dblock()1648 if (req->rq_state & RQ_EXP_WRITE_ACK in drbd_send_dblock()1678 if (!(req->rq_state & (RQ_EXP_RECEIVE_ACK | RQ_EXP_WRITE_ACK)) || digest_size) in drbd_send_dblock()2242 expect(req->rq_state & RQ_POSTPONED) && in do_retry()2243 expect((req->rq_state & RQ_LOCAL_PENDING) == 0 || in do_retry()2244 (req->rq_state & RQ_LOCAL_ABORTED) != 0); in do_retry()2249 req->rq_state); in do_retry()
1919 if (req->rq_state & RQ_LOCAL_PENDING || in restart_conflicting_writes()1920 !(req->rq_state & RQ_POSTPONED)) in restart_conflicting_writes()2150 if (!(req->rq_state & RQ_POSTPONED)) in fail_postponed_requests()2152 req->rq_state &= ~RQ_POSTPONED; in fail_postponed_requests()2234 if (req->rq_state & RQ_LOCAL_PENDING || in handle_write_conflicts()2235 !(req->rq_state & RQ_POSTPONED)) { in handle_write_conflicts()
236 if (unlikely(req->rq_state & RQ_LOCAL_ABORTED)) { in drbd_request_endio()1424 if (bio_data_dir(req->master_bio) == WRITE && req->rq_state & RQ_IN_ACT_LOG) in w_restart_disk_io()
382 unsigned rq_state; /* see comments above _req_mod() */ member
476 static int rq_state; variable514 rq_state |= RQ_RUNNING; in mgc_requeue_thread()519 int stopped = !!(rq_state & RQ_STOP); in mgc_requeue_thread()523 rq_state &= ~(RQ_NOW | RQ_LATER); in mgc_requeue_thread()537 l_wait_event(rq_waitq, rq_state & (RQ_STOP | RQ_PRECLEANUP), in mgc_requeue_thread()551 rq_state &= ~RQ_PRECLEANUP; in mgc_requeue_thread()586 l_wait_event(rq_waitq, rq_state & (RQ_NOW | RQ_STOP), in mgc_requeue_thread()591 rq_state &= ~RQ_RUNNING; in mgc_requeue_thread()606 cld->cld_stopping, rq_state); in mgc_requeue_add()621 if (rq_state & RQ_STOP) { in mgc_requeue_add()[all …]
428 MLX5_SET(modify_rq_in, in, rq_state, curr_state); in mlx5e_modify_rq()