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

fix(stream): update the function signature.

This commit is contained in:
Haojun Liao 2024-12-12 09:23:34 +08:00
parent fa591f4667
commit a9d288f2d2
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/stream/src/streamHb.c
View File

@ -152,7 +152,7 @@ static int32_t streamTaskGetMndEpset(SStreamMeta* pMeta, SEpSet* pEpSet) {
return TSDB_CODE_FAILED; return TSDB_CODE_FAILED;
} }
static int32_t streamTaskUpdateMndEpset(SStreamMeta* pMeta, SEpSet* pEpSet) { static void streamTaskUpdateMndEpset(SStreamMeta* pMeta, SEpSet* pEpSet) {
int32_t numOfTasks = streamMetaGetNumOfTasks(pMeta); int32_t numOfTasks = streamMetaGetNumOfTasks(pMeta);
for (int32_t i = 0; i < numOfTasks; ++i) { for (int32_t i = 0; i < numOfTasks; ++i) {
@ -185,7 +185,7 @@ static int32_t streamTaskUpdateMndEpset(SStreamMeta* pMeta, SEpSet* pEpSet) {
streamMetaReleaseTask(pMeta, pTask); streamMetaReleaseTask(pMeta, pTask);
} }
return TSDB_CODE_SUCCESS; stDebug("vgId:%d update mnd epset for %d tasks completed", pMeta->vgId, numOfTasks);
} }
// NOTE: this task should be executed within the SStreamMeta lock region. // NOTE: this task should be executed within the SStreamMeta lock region.