TD-2299
This commit is contained in:
parent
f5afd5763d
commit
573fcb4e9c
|
@ -182,6 +182,8 @@ void dnodeSendMsgToDnode(SRpcEpSet *epSet, SRpcMsg *rpcMsg) {
|
||||||
void dnodeSendMsgToMnodeRecv(SRpcMsg *rpcMsg, SRpcMsg *rpcRsp) {
|
void dnodeSendMsgToMnodeRecv(SRpcMsg *rpcMsg, SRpcMsg *rpcRsp) {
|
||||||
SRpcEpSet epSet = {0};
|
SRpcEpSet epSet = {0};
|
||||||
dnodeGetEpSetForPeer(&epSet);
|
dnodeGetEpSetForPeer(&epSet);
|
||||||
|
|
||||||
|
assert(tsClientRpc != 0);
|
||||||
rpcSendRecv(tsClientRpc, &epSet, rpcMsg, rpcRsp);
|
rpcSendRecv(tsClientRpc, &epSet, rpcMsg, rpcRsp);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue