From 7ca6cfdc328ff6fb576f69c9c4c92b114f49055d Mon Sep 17 00:00:00 2001 From: slguan Date: Tue, 5 May 2020 12:26:49 +0800 Subject: [PATCH] a sdb confirm issue --- src/mnode/src/mgmtSdb.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/mnode/src/mgmtSdb.c b/src/mnode/src/mgmtSdb.c index e8e805b10b..3717277992 100644 --- a/src/mnode/src/mgmtSdb.c +++ b/src/mnode/src/mgmtSdb.c @@ -458,6 +458,10 @@ static int sdbWrite(void *param, void *data, int type) { // for data from WAL or forward, version may be smaller if (pHead->version <= tsSdbObj.version) { pthread_mutex_unlock(&tsSdbObj.mutex); + if (type == TAOS_QTYPE_FWD && tsSdbObj.sync != NULL) { + sdbTrace("forward request is received, version:%" PRIu64 " confirm it", pHead->version); + syncConfirmForward(tsSdbObj.sync, pHead->version, TSDB_CODE_SUCCESS); + } return TSDB_CODE_SUCCESS; } else if (pHead->version != tsSdbObj.version + 1) { pthread_mutex_unlock(&tsSdbObj.mutex); -- GitLab