Lines Matching refs:queue_depth

63 	size_t max_depth = clt->queue_depth;  in __rtrs_get_permit()
474 flags = atomic_inc_return(&con->io_cnt) % sess->queue_depth ? in rtrs_post_send_rdma()
490 if (WARN_ON(msg_id >= sess->queue_depth)) in process_io_rsp()
543 if (WARN_ON(buf_id >= sess->queue_depth)) in rtrs_clt_rkey_rsp_done()
713 q_size = sess->queue_depth; in post_recv_sess()
973 flags = atomic_inc_return(&con->io_cnt) % sess->queue_depth ? in rtrs_post_rdma_write_sg()
1212 for (i = 0; i < sess->queue_depth; ++i) { in fail_all_outstanding_reqs()
1238 for (i = 0; i < sess->queue_depth; ++i) { in free_sess_reqs()
1255 sess->reqs = kcalloc(sess->queue_depth, sizeof(*sess->reqs), in alloc_sess_reqs()
1260 for (i = 0; i < sess->queue_depth; ++i) { in alloc_sess_reqs()
1300 clt->permits_map = kcalloc(BITS_TO_LONGS(clt->queue_depth), in alloc_permits()
1306 clt->permits = kcalloc(clt->queue_depth, permit_size(clt), GFP_KERNEL); in alloc_permits()
1311 chunk_bits = ilog2(clt->queue_depth - 1) + 1; in alloc_permits()
1312 for (i = 0; i < clt->queue_depth; i++) { in alloc_permits()
1332 size_t sz = clt->queue_depth; in free_permits()
1576 if (WARN_ON(!sess->queue_depth)) in create_con_cq_qp()
1584 sess->queue_depth * 3 + 1); in create_con_cq_qp()
1587 sess->queue_depth * 3 + 1); in create_con_cq_qp()
1702 u16 version, queue_depth; in rtrs_rdma_conn_established() local
1729 queue_depth = le16_to_cpu(msg->queue_depth); in rtrs_rdma_conn_established()
1731 if (sess->queue_depth > 0 && queue_depth != sess->queue_depth) { in rtrs_rdma_conn_established()
1745 sess->rbufs = kcalloc(queue_depth, sizeof(*sess->rbufs), in rtrs_rdma_conn_established()
1750 sess->queue_depth = queue_depth; in rtrs_rdma_conn_established()
1765 clt->queue_depth = sess->queue_depth; in rtrs_rdma_conn_established()
2301 if (unlikely(!sg_cnt || (sess->queue_depth % sg_cnt))) { in process_info_rsp()
2307 for (sgi = 0, i = 0; sgi < sg_cnt && i < sess->queue_depth; sgi++) { in process_info_rsp()
2323 for ( ; len && i < sess->queue_depth; i++) { in process_info_rsp()
2332 if (unlikely(sgi != sg_cnt || i != sess->queue_depth)) { in process_info_rsp()
2336 if (unlikely(total_len != sess->chunk_size * sess->queue_depth)) { in process_info_rsp()
2933 attr->queue_depth = clt->queue_depth; in rtrs_clt_query()