diff --git a/source/dnode/vnode/src/inc/vnodeInt.h b/source/dnode/vnode/src/inc/vnodeInt.h index dd5e6fc57525f5ef579db1b2dd027e04bc674a72..6fb680296616619a59b8c2dc883230c8569e43a2 100644 --- a/source/dnode/vnode/src/inc/vnodeInt.h +++ b/source/dnode/vnode/src/inc/vnodeInt.h @@ -341,7 +341,9 @@ struct SVnode { SVBufPool* aBufPool[VNODE_BUFPOOL_SEGMENTS]; SVBufPool* freeList; SVBufPool* inUse; - SVBufPool* recycling; + SVBufPool* onCommit; + SVBufPool* recycleHead; + SVBufPool* recycleTail; SMeta* pMeta; SSma* pSma; diff --git a/source/dnode/vnode/src/vnd/vnodeBufPool.c b/source/dnode/vnode/src/vnd/vnodeBufPool.c index 8b6247163a45338778c4ec92d123d83c51307119..3ae5755b4989cde2e40a4324ee9b886cdeb8b9dd 100644 --- a/source/dnode/vnode/src/vnd/vnodeBufPool.c +++ b/source/dnode/vnode/src/vnd/vnodeBufPool.c @@ -94,10 +94,6 @@ int vnodeCloseBufPool(SVnode *pVnode) { } } - pVnode->freeList = NULL; - ASSERT(pVnode->inUse == NULL); - ASSERT(pVnode->recycling == NULL); - vDebug("vgId:%d, vnode buffer pool is closed", TD_VID(pVnode)); return 0; } diff --git a/source/dnode/vnode/src/vnd/vnodeCommit.c b/source/dnode/vnode/src/vnd/vnodeCommit.c index 411465190471ce6137fbeded04072700f41eb2db..4f28199105e22560d3e4b4a7768b896907a03e6b 100644 --- a/source/dnode/vnode/src/vnd/vnodeCommit.c +++ b/source/dnode/vnode/src/vnd/vnodeCommit.c @@ -29,7 +29,7 @@ int vnodeBegin(SVnode *pVnode) { int32_t nTry = 0; for (;;) { - while (pVnode->freeList == NULL) { + while (pVnode->freeList == NULL) { // move here below vDebug("vgId:%d no free buffer pool, try to wait %d...", TD_VID(pVnode), ++nTry); struct timeval tv;