Skip to content

Commit

Permalink
xio: refactor release_xio_req -> release_xio_msg
Browse files Browse the repository at this point in the history
avoid names that are misleading with accelio's terminology
(msg - is one way notification, req - is 2 ways notification)

Signed-off-by: Avner BenHanoch <[email protected]>
  • Loading branch information
avnerbh committed Apr 12, 2016
1 parent 262d85c commit d5bc886
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion src/msg/xio/XioConnection.cc
Original file line number Diff line number Diff line change
Expand Up @@ -542,7 +542,7 @@ int XioConnection::discard_input_queue(uint32_t flags)
break;
case XioSubmit::INCOMING_MSG_RELEASE:
deferred_q.erase(q_iter);
portal->release_xio_rsp(static_cast<XioRsp*>(xs));
portal->release_xio_msg(static_cast<XioRsp*>(xs));
break;
default:
ldout(msgr->cct,0) << __func__ << ": Unknown Msg type " << xs->type << dendl;
Expand Down
6 changes: 3 additions & 3 deletions src/msg/xio/XioPortal.h
Original file line number Diff line number Diff line change
Expand Up @@ -157,7 +157,7 @@ class XioPortal : public Thread
int bind(struct xio_session_ops *ops, const string &base_uri,
uint16_t port, uint16_t *assigned_port);

inline void release_xio_rsp(XioRsp* xrsp) {
inline void release_xio_msg(XioRsp* xrsp) {
struct xio_msg *msg = xrsp->dequeue();
struct xio_msg *next_msg = NULL;
int code;
Expand Down Expand Up @@ -193,7 +193,7 @@ class XioPortal : public Thread
break;
default:
/* INCOMING_MSG_RELEASE */
release_xio_rsp(static_cast<XioRsp*>(xs));
release_xio_msg(static_cast<XioRsp*>(xs));
break;
};
}
Expand Down Expand Up @@ -321,7 +321,7 @@ class XioPortal : public Thread
default:
/* INCOMING_MSG_RELEASE */
q_iter = send_q.erase(q_iter);
release_xio_rsp(static_cast<XioRsp*>(xs));
release_xio_msg(static_cast<XioRsp*>(xs));
continue;
} /* switch (xs->type) */
q_iter = send_q.erase(q_iter);
Expand Down

0 comments on commit d5bc886

Please sign in to comment.