From ee7687566ea99a19633c48a8f6e7a6de5707ad30 Mon Sep 17 00:00:00 2001 From: slzhou Date: Mon, 24 Oct 2022 15:13:42 +0800 Subject: [PATCH] fix: change blank lines --- src/vnode/src/vnodeWrite.c | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/vnode/src/vnodeWrite.c b/src/vnode/src/vnodeWrite.c index 08dd59907c..be5b43caf3 100644 --- a/src/vnode/src/vnodeWrite.c +++ b/src/vnode/src/vnodeWrite.c @@ -160,7 +160,9 @@ static int32_t vnodeProcessSubmitMsg(SVnodeObj *pVnode, void *pCont, SRspRet *pR int32_t code = TSDB_CODE_SUCCESS; vTrace("vgId:%d, submit msg is processed", pVnode->vgId); + int64_t submitStartUs = taosGetTimestampUs(); + if (pVnode->dbType == TSDB_DB_TYPE_TOPIC && pVnode->role == TAOS_SYNC_ROLE_MASTER) { tpUpdateTs(pVnode->vgId, &pVnode->sequence, pCont); } @@ -187,10 +189,10 @@ static int32_t vnodeProcessSubmitMsg(SVnodeObj *pVnode, void *pCont, SRspRet *pR } int64_t submitEndUs = taosGetTimestampUs(); - if (submitEndUs - submitStartUs > 10 * 1000000) { vWarn("vgId: %d, submit msg process takes more than 10s", pVnode->vgId); } + return code; } -- GitLab