refact code
This commit is contained in:
parent
f2a3951c23
commit
f90438a56a
|
@ -167,7 +167,7 @@ int32_t rpcSendRequest(void* shandle, const SEpSet* pEpSet, SRpcMsg* pMsg, int64
|
||||||
return transSendRequest(shandle, pEpSet, pMsg, NULL);
|
return transSendRequest(shandle, pEpSet, pMsg, NULL);
|
||||||
}
|
}
|
||||||
int32_t rpcSendRequestWithCtx(void* shandle, const SEpSet* pEpSet, SRpcMsg* pMsg, int64_t* pRid, SRpcCtx* pCtx) {
|
int32_t rpcSendRequestWithCtx(void* shandle, const SEpSet* pEpSet, SRpcMsg* pMsg, int64_t* pRid, SRpcCtx* pCtx) {
|
||||||
if (pCtx != NULL) {
|
if (pCtx != NULL || pMsg->info.handle != 0) {
|
||||||
return transSendRequest(shandle, pEpSet, pMsg, pCtx);
|
return transSendRequest(shandle, pEpSet, pMsg, pCtx);
|
||||||
} else {
|
} else {
|
||||||
return transSendRequestWithId(shandle, pEpSet, pMsg, pRid);
|
return transSendRequestWithId(shandle, pEpSet, pMsg, pRid);
|
||||||
|
|
Loading…
Reference in New Issue