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

refactor backend

This commit is contained in:
yihaoDeng 2023-10-11 20:02:40 +08:00
parent 031506aef8
commit 83b52a4c1d
1 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -759,18 +759,17 @@ static void doClear(void* pKey, void* pVal, TBC* pCur, SArray* pRecycleList) {
int32_t streamMetaReloadAllTasks(SStreamMeta* pMeta) { int32_t streamMetaReloadAllTasks(SStreamMeta* pMeta) {
if (pMeta == NULL) return 0; if (pMeta == NULL) return 0;
void* pIter = taosHashIterate(pMeta->pTaskBackendUnique, NULL); // void* pIter = taosHashIterate(pMeta->pTaskBackendUnique, NULL);
while (pIter) { // while (pIter) {
STaskBackendWrapper* taskBackend = *(STaskBackendWrapper**)pIter; // STaskBackendWrapper* taskBackend = *(STaskBackendWrapper**)pIter;
if (taskBackend != NULL) { // if (taskBackend != NULL) {
taskBackendRemoveRef(taskBackend); // taskBackendRemoveRef(taskBackend);
} // }
pIter = taosHashIterate(pMeta->pTaskBackendUnique, pIter); // pIter = taosHashIterate(pMeta->pTaskBackendUnique, pIter);
} // }
taosHashClear(pMeta->pTaskBackendUnique); // taosHashClear(pMeta->pTaskBackendUnique);
return streamMetaLoadAllTasks(pMeta);
return 0;
} }
int32_t streamMetaLoadAllTasks(SStreamMeta* pMeta) { int32_t streamMetaLoadAllTasks(SStreamMeta* pMeta) {
TBC* pCur = NULL; TBC* pCur = NULL;