Home
last modified time | relevance | path

Searched refs:rq_state (Results 1 - 22 of 22) sorted by relevance

/kernel/linux/linux-5.10/drivers/block/drbd/
H A Ddrbd_req.c34 req->rq_state = (bio_data_dir(bio_src) == WRITE ? RQ_WRITE : 0) in drbd_req_new()
77 const unsigned s = req->rq_state; in drbd_req_destroy()
83 drbd_err(device, "drbd_req_destroy: Logic BUG rq_state = 0x%x, completion_ref = %d\n", in drbd_req_destroy()
109 drbd_err(device, "drbd_req_destroy: Logic BUG: interval empty, but: rq_state=0x%x, sect=%llu, size=%u\n", in drbd_req_destroy()
196 const unsigned s = req->rq_state; in drbd_req_complete()
212 drbd_err(device, "drbd_req_complete: Logic BUG rq_state = 0x%x\n", s); in drbd_req_complete()
269 req->rq_state |= RQ_POSTPONED; in drbd_req_complete()
271 if (!(req->rq_state & RQ_POSTPONED)) { in drbd_req_complete()
296 D_ASSERT(device, m || (req->rq_state & RQ_POSTPONED)); in drbd_req_put_completion_ref()
308 if (req->rq_state in drbd_req_put_completion_ref()
[all...]
H A Ddrbd_debugfs.c53 /* pretty print enum drbd_req_state_bits req->rq_state */
56 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()
330 s = req->rq_state; in seq_print_resource_transfer_log_summary()
H A Ddrbd_main.c196 const unsigned s = r->rq_state; in tl_release()
309 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()
1757 if (!(req->rq_state & (RQ_EXP_RECEIVE_ACK | RQ_EXP_WRITE_ACK)) || digest_size) in drbd_send_dblock()
2301 expect(req->rq_state & RQ_POSTPONED) && in do_retry()
2302 expect((req->rq_state & RQ_LOCAL_PENDING) == 0 || in do_retry()
2303 (req->rq_state & RQ_LOCAL_ABORTED) != 0); in do_retry()
2306 drbd_err(device, "req=%p completion_ref=%d rq_state=%x\n", in do_retry()
2308 req->rq_state); in do_retry()
[all...]
H A Ddrbd_worker.c242 if (unlikely(req->rq_state & RQ_LOCAL_ABORTED)) { in drbd_request_endio()
1461 bool do_send_unplug = req->rq_state & RQ_UNPLUG; in w_send_dblock()
1494 bool do_send_unplug = req->rq_state & RQ_UNPLUG; in w_send_read_req()
1523 if (bio_data_dir(req->master_bio) == WRITE && req->rq_state & RQ_IN_ACT_LOG) in w_restart_disk_io()
H A Ddrbd_receiver.c2223 if (req->rq_state & RQ_LOCAL_PENDING || in restart_conflicting_writes()
2224 !(req->rq_state & RQ_POSTPONED)) in restart_conflicting_writes()
2465 if (!(req->rq_state & RQ_POSTPONED)) in fail_postponed_requests()
2467 req->rq_state &= ~RQ_POSTPONED; in fail_postponed_requests()
2549 if (req->rq_state & RQ_LOCAL_PENDING || in handle_write_conflicts()
2550 !(req->rq_state & RQ_POSTPONED)) { in handle_write_conflicts()
H A Ddrbd_int.h361 unsigned rq_state; /* see comments above _req_mod() */ member
/kernel/linux/linux-6.6/drivers/block/drbd/
H A Ddrbd_req.c33 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()
81 drbd_err(device, "drbd_req_destroy: Logic BUG rq_state = 0x%x, completion_ref = %d\n", in drbd_req_destroy()
107 drbd_err(device, "drbd_req_destroy: Logic BUG: interval empty, but: rq_state=0x%x, sect=%llu, size=%u\n", in drbd_req_destroy()
195 const unsigned s = req->rq_state; in drbd_req_complete()
211 drbd_err(device, "drbd_req_complete: Logic BUG rq_state = 0x%x\n", s); 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 in drbd_req_put_completion_ref()
[all...]
H A Ddrbd_debugfs.c53 /* pretty print enum drbd_req_state_bits req->rq_state */
56 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()
330 s = req->rq_state; in seq_print_resource_transfer_log_summary()
H A Ddrbd_main.c182 const unsigned s = r->rq_state; in tl_release()
300 if (!(req->rq_state & RQ_LOCAL_PENDING)) in tl_abort_disk_io()
1690 if (req->rq_state & RQ_EXP_RECEIVE_ACK) in drbd_send_dblock()
1694 if (req->rq_state & RQ_EXP_WRITE_ACK in drbd_send_dblock()
1727 if (!(req->rq_state & (RQ_EXP_RECEIVE_ACK | RQ_EXP_WRITE_ACK)) || digest_size) in drbd_send_dblock()
2266 expect(device, req->rq_state & RQ_POSTPONED) && in do_retry()
2267 expect(device, (req->rq_state & RQ_LOCAL_PENDING) == 0 || in do_retry()
2268 (req->rq_state & RQ_LOCAL_ABORTED) != 0); in do_retry()
2271 drbd_err(device, "req=%p completion_ref=%d rq_state=%x\n", in do_retry()
2273 req->rq_state); in do_retry()
[all...]
H A Ddrbd_worker.c242 if (unlikely(req->rq_state & RQ_LOCAL_ABORTED)) { in drbd_request_endio()
1461 bool do_send_unplug = req->rq_state & RQ_UNPLUG; in w_send_dblock()
1494 bool do_send_unplug = req->rq_state & RQ_UNPLUG; in w_send_read_req()
1523 if (bio_data_dir(req->master_bio) == WRITE && req->rq_state & RQ_IN_ACT_LOG) in w_restart_disk_io()
H A Ddrbd_receiver.c2193 if (req->rq_state & RQ_LOCAL_PENDING || in restart_conflicting_writes()
2194 !(req->rq_state & RQ_POSTPONED)) in restart_conflicting_writes()
2433 if (!(req->rq_state & RQ_POSTPONED)) in fail_postponed_requests()
2435 req->rq_state &= ~RQ_POSTPONED; in fail_postponed_requests()
2517 if (req->rq_state & RQ_LOCAL_PENDING || in handle_write_conflicts()
2518 !(req->rq_state & RQ_POSTPONED)) { in handle_write_conflicts()
H A Ddrbd_int.h288 unsigned rq_state; /* see comments above _req_mod() */ member
/kernel/linux/linux-5.10/block/
H A Dblk-mq-debugfs.c323 static const char *blk_mq_rq_state_name(enum mq_rq_state rq_state) in blk_mq_rq_state_name() argument
325 if (WARN_ON_ONCE((unsigned int)rq_state >= in blk_mq_rq_state_name()
328 return blk_mq_rq_state_name_array[rq_state]; in blk_mq_rq_state_name()
/kernel/linux/linux-6.6/block/
H A Dblk-mq-debugfs.c272 static const char *blk_mq_rq_state_name(enum mq_rq_state rq_state) in blk_mq_rq_state_name() argument
274 if (WARN_ON_ONCE((unsigned int)rq_state >= in blk_mq_rq_state_name()
277 return blk_mq_rq_state_name_array[rq_state]; in blk_mq_rq_state_name()
/kernel/linux/linux-5.10/drivers/infiniband/hw/mlx5/
H A Dqp.c3463 MLX5_SET(modify_rq_in, in, rq_state, rq->state); in modify_raw_packet_qp_rq()
3576 int rq_state; in modify_raw_packet_qp() local
3582 rq_state = MLX5_RQC_STATE_RDY; in modify_raw_packet_qp()
3586 rq_state = MLX5_RQC_STATE_ERR; in modify_raw_packet_qp()
3590 rq_state = MLX5_RQC_STATE_RST; in modify_raw_packet_qp()
3613 err = modify_raw_packet_qp_rq(dev, rq, rq_state, raw_qp_param, in modify_raw_packet_qp()
3728 MLX5_SET(modify_rq_in, in, rq_state, rq->state); in __mlx5_ib_qp_set_raw_qp_counter()
4511 u8 *rq_state) in query_raw_packet_qp_rq_state()
4528 *rq_state = MLX5_GET(rqc, rqc, state); in query_raw_packet_qp_rq_state()
4529 rq->state = *rq_state; in query_raw_packet_qp_rq_state()
4509 query_raw_packet_qp_rq_state(struct mlx5_ib_dev *dev, struct mlx5_ib_rq *rq, u8 *rq_state) query_raw_packet_qp_rq_state() argument
4536 sqrq_state_to_qp_state(u8 sq_state, u8 rq_state, struct mlx5_ib_qp *qp, u8 *qp_state) sqrq_state_to_qp_state() argument
4590 u8 rq_state = MLX5_RQ_STATE_NA; query_raw_packet_qp_state() local
[all...]
/kernel/linux/linux-6.6/drivers/infiniband/hw/mlx5/
H A Dqp.c3794 MLX5_SET(modify_rq_in, in, rq_state, rq->state); in modify_raw_packet_qp_rq()
3907 int rq_state; in modify_raw_packet_qp() local
3913 rq_state = MLX5_RQC_STATE_RDY; in modify_raw_packet_qp()
3917 rq_state = MLX5_RQC_STATE_ERR; in modify_raw_packet_qp()
3921 rq_state = MLX5_RQC_STATE_RST; in modify_raw_packet_qp()
3944 err = modify_raw_packet_qp_rq(dev, rq, rq_state, raw_qp_param, in modify_raw_packet_qp()
4059 MLX5_SET(modify_rq_in, in, rq_state, rq->state); in __mlx5_ib_qp_set_raw_qp_counter()
4836 u8 *rq_state) in query_raw_packet_qp_rq_state()
4853 *rq_state = MLX5_GET(rqc, rqc, state); in query_raw_packet_qp_rq_state()
4854 rq->state = *rq_state; in query_raw_packet_qp_rq_state()
4834 query_raw_packet_qp_rq_state(struct mlx5_ib_dev *dev, struct mlx5_ib_rq *rq, u8 *rq_state) query_raw_packet_qp_rq_state() argument
4861 sqrq_state_to_qp_state(u8 sq_state, u8 rq_state, struct mlx5_ib_qp *qp, u8 *qp_state) sqrq_state_to_qp_state() argument
4915 u8 rq_state = MLX5_RQ_STATE_NA; query_raw_packet_qp_state() local
[all...]
/kernel/linux/linux-5.10/drivers/net/ethernet/mellanox/mlx5/core/
H A Dtransobj.c365 MLX5_SET(modify_rq_in, in, rq_state, curr_state); in mlx5_hairpin_modify_rq()
H A Den_main.c711 MLX5_SET(modify_rq_in, in, rq_state, curr_state); in mlx5e_modify_rq_state()
739 MLX5_SET(modify_rq_in, in, rq_state, MLX5_RQC_STATE_RDY); in mlx5e_modify_rq_scatter_fcs()
768 MLX5_SET(modify_rq_in, in, rq_state, MLX5_RQC_STATE_RDY); in mlx5e_modify_rq_vsd()
/kernel/linux/linux-6.6/drivers/net/ethernet/mellanox/mlx5/core/
H A Dtransobj.c365 MLX5_SET(modify_rq_in, in, rq_state, curr_state); in mlx5_hairpin_modify_rq()
H A Den_main.c1029 MLX5_SET(modify_rq_in, in, rq_state, curr_state); in mlx5e_modify_rq_state()
1093 MLX5_SET(modify_rq_in, in, rq_state, MLX5_RQC_STATE_RDY); in mlx5e_modify_rq_vsd()
/kernel/linux/linux-5.10/include/linux/mlx5/
H A Dmlx5_ifc.h6349 u8 rq_state[0x4]; member
/kernel/linux/linux-6.6/include/linux/mlx5/
H A Dmlx5_ifc.h7312 u8 rq_state[0x4]; member

Completed in 131 milliseconds