diff --git a/src/inc/vnode.h b/src/inc/vnode.h index 2cc56af9de3208788376b30f4ff313817fecbadb..b3291645c00be17283f7d078acb2d4c9a2629ece 100644 --- a/src/inc/vnode.h +++ b/src/inc/vnode.h @@ -88,9 +88,6 @@ int32_t vnodeWriteToRQueue(void *pVnode, void *pCont, int32_t contLen, int8_t qt void vnodeFreeFromRQueue(void *pVnode, SVReadMsg *pRead); int32_t vnodeProcessRead(void *pVnode, SVReadMsg *pRead); -// util -void* vnodeGetqMgmt(void* pVnode); - #ifdef __cplusplus } #endif diff --git a/src/tsdb/src/tsdbHealth.c b/src/tsdb/src/tsdbHealth.c index 7cd6672e9399ef684abbb5b5f57a5688b217afd2..1c1c45c9ae98499edae5c6542194e743986562e1 100644 --- a/src/tsdb/src/tsdbHealth.c +++ b/src/tsdb/src/tsdbHealth.c @@ -22,10 +22,14 @@ #include "tsdbBuffer.h" #include "tsdbLog.h" #include "tsdbHealth.h" -#include "tsdbint.h" #include "ttimer.h" -#include "vnode.h" +#include "../../vnode/inc/vnodeInt.h" +// get qmgmt +void* vnodeGetqMgmt(void* pVnode){ + if(pVnode == NULL) return NULL; + return ((SVnodeObj*)pVnode)->qMgmt; +} // return malloc new block count int32_t tsdbInsertNewBlock(STsdbRepo * pRepo) { diff --git a/src/vnode/src/vnodeMain.c b/src/vnode/src/vnodeMain.c index 7802d2a081d1b221966fa3294bd727c541533c26..f826c1aecd336a0eedeb3f02df0a7acc61895bb2 100644 --- a/src/vnode/src/vnodeMain.c +++ b/src/vnode/src/vnodeMain.c @@ -562,9 +562,3 @@ static int32_t vnodeProcessTsdbStatus(void *arg, int32_t status, int32_t eno) { return 0; } - -// get qmgmt -void* vnodeGetqMgmt(void* pVnode){ - if(pVnode == NULL) return NULL; - return ((SVnodeObj*)pVnode)->qMgmt; -} diff --git a/src/vnode/src/vnodeSync.c b/src/vnode/src/vnodeSync.c index 2bdfd2ead3a31d8c2cba94d93239de965d2e07dc..7a886cf758b3fcdf9cf21f8749188cf69ae5746d 100644 --- a/src/vnode/src/vnodeSync.c +++ b/src/vnode/src/vnodeSync.c @@ -178,3 +178,4 @@ void vnodeConfirmForward(void *vparam, uint64_t version, int32_t code, bool forc SVnodeObj *pVnode = vparam; syncConfirmForward(pVnode->sync, version, code, force); } +