Home
last modified time | relevance | path

Searched refs:rq_state (Results 1 – 9 of 9) sorted by relevance

/drivers/block/drbd/
Ddrbd_req.c64 req->rq_state = (bio_data_dir(bio_src) == WRITE ? RQ_WRITE : 0) in drbd_req_new()
107 const unsigned s = req->rq_state; in drbd_req_destroy()
225 const unsigned s = req->rq_state; in drbd_req_complete()
298 req->rq_state |= RQ_POSTPONED; in drbd_req_complete()
300 if (!(req->rq_state & RQ_POSTPONED)) { in drbd_req_complete()
325 D_ASSERT(device, m || (req->rq_state & RQ_POSTPONED)); in drbd_req_put_completion_ref()
337 if (req->rq_state & RQ_LOCAL_ABORTED) in drbd_req_put_completion_ref()
340 if (req->rq_state & RQ_POSTPONED) { in drbd_req_put_completion_ref()
367 const unsigned s = req->rq_state; in advance_conn_req_next()
393 const unsigned s = req->rq_state; in advance_conn_req_ack_pending()
[all …]
Ddrbd_debugfs.c56 unsigned int s = req->rq_state; in seq_print_request_state()
99 unsigned int s = req->rq_state; in seq_print_one_request()
173 if (req && !(req->rq_state & RQ_IN_ACT_LOG)) in seq_print_waiting_for_AL()
328 s = req->rq_state; in seq_print_resource_transfer_log_summary()
Ddrbd_main.c207 const unsigned s = r->rq_state; in tl_release()
317 if (!(req->rq_state & RQ_LOCAL_PENDING)) in tl_abort_disk_io()
1705 if (req->rq_state & RQ_EXP_RECEIVE_ACK) in drbd_send_dblock()
1709 if (req->rq_state & RQ_EXP_WRITE_ACK in drbd_send_dblock()
1756 if (!(req->rq_state & (RQ_EXP_RECEIVE_ACK | RQ_EXP_WRITE_ACK)) || digest_size) in drbd_send_dblock()
2326 expect(req->rq_state & RQ_POSTPONED) && in do_retry()
2327 expect((req->rq_state & RQ_LOCAL_PENDING) == 0 || in do_retry()
2328 (req->rq_state & RQ_LOCAL_ABORTED) != 0); in do_retry()
2333 req->rq_state); in do_retry()
Ddrbd_worker.c253 if (unlikely(req->rq_state & RQ_LOCAL_ABORTED)) { in drbd_request_endio()
1473 bool do_send_unplug = req->rq_state & RQ_UNPLUG; in w_send_dblock()
1506 bool do_send_unplug = req->rq_state & RQ_UNPLUG; in w_send_read_req()
1535 if (bio_data_dir(req->master_bio) == WRITE && req->rq_state & RQ_IN_ACT_LOG) in w_restart_disk_io()
Ddrbd_receiver.c2109 if (req->rq_state & RQ_LOCAL_PENDING || in restart_conflicting_writes()
2110 !(req->rq_state & RQ_POSTPONED)) in restart_conflicting_writes()
2347 if (!(req->rq_state & RQ_POSTPONED)) in fail_postponed_requests()
2349 req->rq_state &= ~RQ_POSTPONED; in fail_postponed_requests()
2431 if (req->rq_state & RQ_LOCAL_PENDING || in handle_write_conflicts()
2432 !(req->rq_state & RQ_POSTPONED)) { in handle_write_conflicts()
Ddrbd_int.h375 unsigned rq_state; /* see comments above _req_mod() */ member
/drivers/staging/lustre/lustre/mgc/
Dmgc_request.c490 static int rq_state; variable
535 rq_state |= RQ_RUNNING; in mgc_requeue_thread()
536 while (!(rq_state & RQ_STOP)) { in mgc_requeue_thread()
543 rq_state &= ~(RQ_NOW | RQ_LATER); in mgc_requeue_thread()
559 l_wait_event(rq_waitq, rq_state & (RQ_STOP | RQ_PRECLEANUP), in mgc_requeue_thread()
573 rq_state &= ~RQ_PRECLEANUP; in mgc_requeue_thread()
590 if (likely(!(rq_state & RQ_STOP))) { in mgc_requeue_thread()
604 l_wait_event(rq_waitq, rq_state & (RQ_NOW | RQ_STOP), in mgc_requeue_thread()
610 rq_state &= ~RQ_RUNNING; in mgc_requeue_thread()
628 cld->cld_stopping, rq_state); in mgc_requeue_add()
[all …]
/drivers/infiniband/hw/mlx5/
Dqp.c2524 MLX5_SET(modify_rq_in, in, rq_state, rq->state); in modify_raw_packet_qp_rq()
2628 int rq_state; in modify_raw_packet_qp() local
2634 rq_state = MLX5_RQC_STATE_RDY; in modify_raw_packet_qp()
2638 rq_state = MLX5_RQC_STATE_ERR; in modify_raw_packet_qp()
2642 rq_state = MLX5_RQC_STATE_RST; in modify_raw_packet_qp()
2667 err = modify_raw_packet_qp_rq(dev, rq, rq_state, raw_qp_param); in modify_raw_packet_qp()
4406 u8 *rq_state) in query_raw_packet_qp_rq_state() argument
4423 *rq_state = MLX5_GET(rqc, rqc, state); in query_raw_packet_qp_rq_state()
4424 rq->state = *rq_state; in query_raw_packet_qp_rq_state()
4431 static int sqrq_state_to_qp_state(u8 sq_state, u8 rq_state, in sqrq_state_to_qp_state() argument
[all …]
/drivers/net/ethernet/mellanox/mlx5/core/
Den_main.c784 MLX5_SET(modify_rq_in, in, rq_state, curr_state); in mlx5e_modify_rq_state()
812 MLX5_SET(modify_rq_in, in, rq_state, MLX5_RQC_STATE_RDY); in mlx5e_modify_rq_scatter_fcs()
841 MLX5_SET(modify_rq_in, in, rq_state, MLX5_RQC_STATE_RDY); in mlx5e_modify_rq_vsd()