bugfix
This commit is contained in:
parent
e6f8101908
commit
fbf91959d1
|
@ -137,6 +137,7 @@ static int32_t vnodeProcessQueryMsg(SVnodeObj *pVnode, SReadMsg *pReadMsg) {
|
||||||
}
|
}
|
||||||
if (handle != NULL) {
|
if (handle != NULL) {
|
||||||
dnodePutItemIntoReadQueue(pVnode, handle);
|
dnodePutItemIntoReadQueue(pVnode, handle);
|
||||||
|
qReleaseQInfo(pVnode->qMgmt, (void**) &handle, false);
|
||||||
}
|
}
|
||||||
vDebug("vgId:%d, QInfo:%p, dnode query msg disposed", vgId, pQInfo);
|
vDebug("vgId:%d, QInfo:%p, dnode query msg disposed", vgId, pQInfo);
|
||||||
} else {
|
} else {
|
||||||
|
|
Loading…
Reference in New Issue