xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix(stream): init rwlock.

This commit is contained in:
Haojun Liao 2023-12-22 23:31:51 +08:00
parent b175a4b7b3
commit 80604ec8e2
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/libs/stream/src/streamMeta.c
View File

@ -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));