提交 fda6fcca 编写于 作者: H Hongze Cheng

more code

上级 c4b6a99c
...@@ -341,7 +341,9 @@ struct SVnode { ...@@ -341,7 +341,9 @@ struct SVnode {
SVBufPool* aBufPool[VNODE_BUFPOOL_SEGMENTS]; SVBufPool* aBufPool[VNODE_BUFPOOL_SEGMENTS];
SVBufPool* freeList; SVBufPool* freeList;
SVBufPool* inUse; SVBufPool* inUse;
SVBufPool* recycling; SVBufPool* onCommit;
SVBufPool* recycleHead;
SVBufPool* recycleTail;
SMeta* pMeta; SMeta* pMeta;
SSma* pSma; SSma* pSma;
......
...@@ -94,10 +94,6 @@ int vnodeCloseBufPool(SVnode *pVnode) { ...@@ -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)); vDebug("vgId:%d, vnode buffer pool is closed", TD_VID(pVnode));
return 0; return 0;
} }
......
...@@ -29,7 +29,7 @@ int vnodeBegin(SVnode *pVnode) { ...@@ -29,7 +29,7 @@ int vnodeBegin(SVnode *pVnode) {
int32_t nTry = 0; int32_t nTry = 0;
for (;;) { 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); vDebug("vgId:%d no free buffer pool, try to wait %d...", TD_VID(pVnode), ++nTry);
struct timeval tv; struct timeval tv;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册