cl_flag = true;
/* queue for release */
- xrsp = static_cast<XioRsp *>(rsp_pool.alloc(sizeof(XioRsp)));
- new (xrsp) XioRsp(xcon, this);
+ xcmp = static_cast<XioCompletion *>(rsp_pool.alloc(sizeof(XioCompletion)));
+ new (xcmp) XioCompletion(xcon, this);
/* merge with portal traffic */
- xcon->portal->enqueue(xcon, xrsp);
- xcon->portal->enqueue_for_send(xcon, xcmp);
++ xcon->portal->enqueue(xcon, xcmp);
assert(r);
return r;
next_msg = static_cast<struct xio_msg *>(msg->user_context);
code = xio_release_msg(msg);
if (unlikely(code)) /* very unlikely, so log it */
- xrsp->xcon->msg_release_fail(msg, code);
+ xcmp->xcon->msg_release_fail(msg, code);
msg = next_msg;
}
- xrsp->finalize(); /* unconditional finalize */
+ xcmp->finalize(); /* unconditional finalize */
}
- void enqueue_for_send(XioConnection *xcon, XioSubmit *xs)
+ void enqueue(XioConnection *xcon, XioSubmit *xs)
{
if (! _shutdown) {
submit_q.enq(xcon, xs);