From 92e5e239f653e6b467949e318db6bf8c88efc809 Mon Sep 17 00:00:00 2001 From: Hongze Cheng Date: Fri, 29 Nov 2019 15:15:28 +0800 Subject: [PATCH] refact more --- src/system/detail/src/vnodeImport.c | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/system/detail/src/vnodeImport.c b/src/system/detail/src/vnodeImport.c index 1fff201eb5..7b53aaed06 100644 --- a/src/system/detail/src/vnodeImport.c +++ b/src/system/detail/src/vnodeImport.c @@ -192,6 +192,11 @@ int vnodeImportPoints(SMeterObj *pObj, char *cont, int contLen, char source, voi pObj->vnode, pObj->sid, pObj->meterId, rows, firstKey, lastKey, minKey, maxKey); return TSDB_CODE_TIMESTAMP_OUT_OF_RANGE; } + // forward to peers + if (pShell && pVnode->cfg.replications > 1) { + code = vnodeForwardToPeer(pObj, cont, contLen, TSDB_ACTION_IMPORT, sversion); + if (code != 0) return code; + } if (pVnode->cfg.commitLog && source != TSDB_DATA_SOURCE_LOG) { if (pVnode->logFd < 0) return TSDB_CODE_INVALID_COMMIT_LOG;