mirrors/scst
1
0
Fork 0
mirror of https://github.com/SCST-project/scst.git synced 2026-05-21 12:41:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Increased default send queue size from 2048 to 4096 and made the send queue

Browse Source 
size configurable via the kernel module parameter srpt_sq_size.


git-svn-id: http://svn.code.sf.net/p/scst/svn/trunk@1874 d57e44dd-8a1f-0410-8b47-8ef2f437770f
This commit is contained in:
Bart Van Assche
2010-07-25 09:15:10 +00:00
parent 95bba60a0a
commit 1c64261bec
2 changed files with 20 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
srpt/src/ib_srpt.c
View File

@@ -134,6 +134,11 @@ module_param(srpt_srq_size, int, 0444);
MODULE_PARM_DESC(srpt_srq_size,
"Shared receive queue (SRQ) size.");
static int srpt_sq_size = DEF_SRPT_SQ_SIZE;
module_param(srpt_sq_size, int, 0444);
MODULE_PARM_DESC(srpt_sq_size,
"Per-channel send queue (SQ) size.");
static int use_port_guid_in_session_name;
module_param(use_port_guid_in_session_name, bool, 0444);
MODULE_PARM_DESC(use_port_guid_in_session_name,
@@ -2030,17 +2035,17 @@ static int srpt_create_ch_ib(struct srpt_rdma_ch *ch)
ch->scq = ib_create_cq(sdev->device,
thread == MODE_SINGLE_THREADED
? srpt_send_completion_st : srpt_send_completion,
NULL, ch, SRPT_SQ_SIZE);
NULL, ch, srpt_sq_size);
#else
ch->scq = ib_create_cq(sdev->device,
thread == MODE_SINGLE_THREADED
? srpt_send_completion_st : srpt_send_completion,
NULL, ch, SRPT_SQ_SIZE, 0);
NULL, ch, srpt_sq_size, 0);
#endif
if (IS_ERR(ch->scq)) {
ret = PTR_ERR(ch->scq);
PRINT_ERROR("failed to create CQ cqe= %d ret= %d",
SRPT_SQ_SIZE, ret);
srpt_sq_size, ret);
goto out_destroy_rcq;
}
@@ -2059,7 +2064,7 @@ static int srpt_create_ch_ib(struct srpt_rdma_ch *ch)
qp_init->srq = sdev->srq;
qp_init->sq_sig_type = IB_SIGNAL_REQ_WR;
qp_init->qp_type = IB_QPT_RC;
qp_init->cap.max_send_wr = SRPT_SQ_SIZE;
qp_init->cap.max_send_wr = srpt_sq_size;
qp_init->cap.max_send_sge = SRPT_DEF_SG_PER_WQE;
ch->qp = ib_create_qp(sdev->pd, qp_init);
@@ -3200,6 +3205,8 @@ static int srpt_xmit_response(struct scst_cmd *scmnd)
scst_data_direction dir;
int resp_len;
ret = SCST_TGT_RES_SUCCESS;
ioctx = scst_cmd_get_tgt_priv(scmnd);
BUG_ON(!ioctx);
@@ -3213,7 +3220,6 @@ static int srpt_xmit_response(struct scst_cmd *scmnd)
if (unlikely(scst_cmd_aborted(scmnd))) {
srpt_abort_scst_cmd(ioctx, srpt_context);
ret = SCST_TGT_RES_SUCCESS;
goto out;
}
@@ -3221,8 +3227,6 @@ static int srpt_xmit_response(struct scst_cmd *scmnd)
dir = scst_cmd_get_data_direction(scmnd);
ret = SCST_TGT_RES_SUCCESS;
/* For read commands, transfer the data to the initiator. */
if (dir == SCST_DATA_READ && scst_cmd_get_resp_data_len(scmnd)) {
ret = srpt_xfer_data(ch, ioctx, scmnd);
@@ -3919,6 +3923,13 @@ static int __init srpt_init_module(void)
goto out;
}
if (srpt_sq_size < MIN_SRPT_SQ_SIZE) {
PRINT_ERROR("invalid value %d for kernel module parameter"
" srpt_sq_size -- must be at least %d.",
srpt_srq_size, MIN_SRPT_SQ_SIZE);
goto out;
}
ret = class_register(&srpt_class);
if (ret) {
PRINT_ERROR("%s", "couldn't register class ib_srpt");

3
srpt/src/ib_srpt.h
View File

@@ -109,7 +109,8 @@ enum {
SRPT_DEF_SG_TABLESIZE = 128,
SRPT_DEF_SG_PER_WQE = 16,
SRPT_SQ_SIZE = 128 * SRPT_DEF_SG_PER_WQE,
MIN_SRPT_SQ_SIZE = 16,
DEF_SRPT_SQ_SIZE = 4096,
SRPT_RQ_SIZE = 128,
MIN_SRPT_SRQ_SIZE = 4,
DEFAULT_SRPT_SRQ_SIZE = 4095,