From 80604ec8e29c83313da061d9b2d868d558158aaa Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 22 Dec 2023 23:31:51 +0800 Subject: [PATCH] fix(stream): init rwlock. --- source/libs/stream/src/streamMeta.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c index 0702a908ab..292bd8cb38 100644 --- a/source/libs/stream/src/streamMeta.c +++ b/source/libs/stream/src/streamMeta.c @@ -375,6 +375,7 @@ SStreamMeta* streamMetaOpen(const char* path, void* ahandle, FTaskExpand expandF stage); pMeta->rid = taosAddRef(streamMetaId, pMeta); + taosThreadRwlockInit(&pMeta->lock, NULL); int64_t* pRid = taosMemoryMalloc(sizeof(int64_t)); memcpy(pRid, &pMeta->rid, sizeof(pMeta->rid));