mirrors/scst
1
0
Fork 0
mirror of https://github.com/SCST-project/scst.git synced 2026-05-29 09:50:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

Micro-optimized srpt_completion().

Browse Source 
git-svn-id: http://svn.code.sf.net/p/scst/svn/trunk@1792 d57e44dd-8a1f-0410-8b47-8ef2f437770f
This commit is contained in:
Bart Van Assche
2010-06-26 10:42:06 +00:00
parent 54c98834cd
commit c7369b432b
1 changed files with 7 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
srpt/src/ib_srpt.c
View File

@@ -1657,7 +1657,7 @@ static void srpt_completion(struct ib_cq *cq, void *ctx)
ib_req_notify_cq(ch->cq, IB_CQ_NEXT_COMP);
while (ib_poll_cq(ch->cq, 1, &wc) > 0) {
if (wc.status) {
if (unlikely(wc.status)) {
PRINT_INFO("%s for wr_id %u failed with status %d",
wc.wr_id & SRPT_OP_RECV
? "receiving"
@@ -1672,33 +1672,23 @@ static void srpt_completion(struct ib_cq *cq, void *ctx)
int req_lim;
req_lim = atomic_dec_return(&ch->req_lim);
if (req_lim < 0)
if (unlikely(req_lim < 0))
PRINT_ERROR("req_lim = %d < 0", req_lim);
ioctx = sdev->ioctx_ring[wc.wr_id & ~SRPT_OP_RECV];
srpt_handle_new_iu(ch, ioctx);
} else {
ioctx = sdev->ioctx_ring[wc.wr_id];
if (wc.opcode == IB_WC_SEND)
if (wc.opcode == IB_WC_SEND) {
atomic_inc(&ch->qp_wr_avail);
else {
srpt_handle_send_comp(ch, ioctx, context);
} else {
#if defined(CONFIG_SCST_DEBUG)
WARN_ON(wc.opcode != IB_WC_RDMA_READ);
WARN_ON(ioctx->n_rdma <= 0);
#endif
atomic_add(ioctx->n_rdma,
&ch->qp_wr_avail);
}
switch (wc.opcode) {
case IB_WC_SEND:
srpt_handle_send_comp(ch, ioctx, context);
break;
case IB_WC_RDMA_WRITE:
case IB_WC_RDMA_READ:
srpt_handle_rdma_comp(ch, ioctx, context);
break;
default:
PRINT_ERROR("received unrecognized"
" IB WC opcode %d",
wc.opcode);
break;
}
}