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

sync integration

This commit is contained in:
Minghao Li 2022-04-19 16:16:02 +08:00
parent 9a7924049f
commit 785f25c49d
1 changed files with 33 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
source/dnode/mgmt/mgmt_vnode/src/vmWorker.c
View File

@ -117,6 +117,36 @@ static void vmProcessWriteQueue(SQueueInfo *pInfo, STaosQall *qall, int32_t numO
vnodePreprocessWriteReqs(pVnode->pImpl, pArray);
// sync integration response
/*
for (int i = 0; i < taosArrayGetSize(pArray); i++) {
SNodeMsg *pMsg;
SRpcMsg *pRpc;
pMsg = *(SNodeMsg **)taosArrayGet(pArray, i);
pRpc = &pMsg->rpcMsg;
// set request version
void *pBuf = POINTER_SHIFT(pRpc->pCont, sizeof(SMsgHead));
// int64_t ver = pVnode->pImpl->state.processed++; // ???????
int64_t ver;
taosEncodeFixedI64(&pBuf, ver);
int32_t ret = syncPropose(pVnode->pImpl->sync, pRpc, false);
if (ret == TAOS_SYNC_PROPOSE_NOT_LEADER) {
// not leader
// send response
} else if (ret == TAOS_SYNC_PROPOSE_OTHER_ERROR) {
// send response
} else if (ret == TAOS_SYNC_PROPOSE_SUCCESS) {
// ok
// send response in applyQ
} else {
assert(0);
}
}
*/
numOfMsgs = taosArrayGetSize(pArray);
for (int32_t i = 0; i < numOfMsgs; i++) {
SNodeMsg *pMsg = *(SNodeMsg **)taosArrayGet(pArray, i);
@ -154,6 +184,9 @@ static void vmProcessApplyQueue(SQueueInfo *pInfo, STaosQall *qall, int32_t numO
// todo
SRpcMsg *pRsp = NULL;
(void)vnodeProcessWriteReq(pVnode->pImpl, &pMsg->rpcMsg, &pRsp);
// sync integration response
// send response
}
}