sync integration

source/dnode/mgmt/mgmt_vnode/src/vmWorker.c

@@ -186,7 +186,10 @@ static void vmProcessApplyQueue(SQueueInfo *pInfo, STaosQall *qall, int32_t numO
     (void)vnodeProcessWriteReq(pVnode->pImpl, &pMsg->rpcMsg, &pRsp);
 
     // sync integration response
-    // if leader send response
+    // leader
+    // if (pMsg->rpcMsg.handle != NULL && pMsg->rpcMsg.ahandle !-NULL) {
+    // send response;
+    //}
   }
 }
 

source/dnode/vnode/src/vnd/vnodeSync.c

@@ -117,9 +117,12 @@ void vnodeSyncCommitCb(struct SSyncFSM *pFsm, const SRpcMsg *pMsg, SFsmCbMeta cb
     SVnode *pVnode = (SVnode *)(pFsm->data);
     SRpcMsg saveRpcMsg;
     int32_t ret = syncGetAndDelRespRpc(pVnode->sync, cbMeta.seqNum, &saveRpcMsg);
-    if (ret == 1) {
+    if (ret == 1 && cbMeta.state == TAOS_SYNC_STATE_LEADER) {
       applyMsg.handle = saveRpcMsg.handle;
       applyMsg.ahandle = saveRpcMsg.ahandle;
+    } else {
+      applyMsg.handle = NULL;
+      applyMsg.ahandle = NULL;
     }
 
     // put to applyQ