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

fix(stream): remove invalid memset.

This commit is contained in:
Haojun Liao 2023-08-30 16:58:22 +08:00
parent d26e5373b9
commit 997d247aa6
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -165,7 +165,6 @@ SStreamMeta* streamMetaOpen(const char* path, void* ahandle, FTaskExpand expandF
int64_t* pRid = taosMemoryMalloc(sizeof(int64_t)); int64_t* pRid = taosMemoryMalloc(sizeof(int64_t));
*pRid = pMeta->rid; *pRid = pMeta->rid;
memset(tpath, 0, len);
sprintf(tpath, "%s/%s", pMeta->path, "state"); sprintf(tpath, "%s/%s", pMeta->path, "state");
code = taosMulModeMkDir(tpath, 0755, false); code = taosMulModeMkDir(tpath, 0755, false);
if (code != 0) { if (code != 0) {
@ -298,6 +297,10 @@ void streamMetaClear(SStreamMeta* pMeta) {
void streamMetaClose(SStreamMeta* pMeta) { void streamMetaClose(SStreamMeta* pMeta) {
qDebug("start to close stream meta"); qDebug("start to close stream meta");
if (pMeta == NULL) {
return;
}
// int64_t rid = *(int64_t*)pMeta->pRid; // int64_t rid = *(int64_t*)pMeta->pRid;
// if (taosTmrStop(pMeta->hbInfo.hbTmr)) { // if (taosTmrStop(pMeta->hbInfo.hbTmr)) {
// taosMemoryFree(pMeta->pRid); // taosMemoryFree(pMeta->pRid);