fix(stream): access value after null ptr check.

This commit is contained in:
Haojun Liao 2025-02-14 14:34:08 +08:00
parent 1aa9564333
commit 297f248203
1 changed files with 1 additions and 1 deletions

View File

@ -572,11 +572,11 @@ void streamMetaClear(SStreamMeta* pMeta) {
} }
void streamMetaClose(SStreamMeta* pMeta) { void streamMetaClose(SStreamMeta* pMeta) {
stDebug("vgId:%d start to close stream meta", pMeta->vgId);
if (pMeta == NULL) { if (pMeta == NULL) {
return; return;
} }
stDebug("vgId:%d start to close stream meta", pMeta->vgId);
int32_t code = taosRemoveRef(streamMetaRefPool, pMeta->rid); int32_t code = taosRemoveRef(streamMetaRefPool, pMeta->rid);
if (code) { if (code) {
stError("vgId:%d failed to remove meta ref:%" PRId64 ", code:%s", pMeta->vgId, pMeta->rid, tstrerror(code)); stError("vgId:%d failed to remove meta ref:%" PRId64 ", code:%s", pMeta->vgId, pMeta->rid, tstrerror(code));