xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

[TD-860]

This commit is contained in:
Shengliang Guan 2020-07-07 03:54:18 +00:00
parent a2e97d8ec2
commit 94e50c413e
1 changed files with 15 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/mnode/src/mnodeSdb.c
View File

@ -244,19 +244,26 @@ static void sdbNotifyRole(void *ahandle, int8_t role) {
FORCE_INLINE
static void sdbConfirmForward(void *ahandle, void *param, int32_t code) {
if (code > 0) return;
assert(param);
SSdbOper * pOper = param;
SMnodeMsg *pMsg = pOper->pMsg;
if (pOper->cb != NULL) {
sdbDebug("app:%p:%p, is confirmed and will do callback func", pMsg->rpcMsg.ahandle, pMsg);
pOper->retCode = (*pOper->cb)(pMsg, code);
if (code > 0) {
if (pMsg != NULL) {
sdbDebug("app:%p:%p, waiting for slave to confirm this operation", pMsg->rpcMsg.ahandle, pMsg);
}
return;
}
dnodeSendRpcMnodeWriteRsp(pMsg, pOper->retCode);
if (pMsg != NULL) {
sdbDebug("app:%p:%p, is confirmed and will do callback func, code:%s", pMsg->rpcMsg.ahandle, pMsg, tstrerror(code));
}
if (pOper->cb != NULL) {
code = (*pOper->cb)(pMsg, code);
}
dnodeSendRpcMnodeWriteRsp(pMsg, code);
taosFreeQitem(pOper);
}
@ -538,9 +545,7 @@ static int sdbWrite(void *param, void *data, int type) {
}
// forward to peers, even it is WAL/FWD, it shall be called to update version in sync
void *mhandle = NULL;
if (pOper != NULL) mhandle = pOper->pMsg;
int32_t syncCode = syncForwardToPeer(tsSdbObj.sync, pHead, mhandle, TAOS_QTYPE_RPC);
int32_t syncCode = syncForwardToPeer(tsSdbObj.sync, pHead, pOper, TAOS_QTYPE_RPC);
pthread_mutex_unlock(&tsSdbObj.mutex);
if (syncCode < 0) {