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

reset default cfg

This commit is contained in:
Liu Jicong 2023-02-13 10:12:49 +08:00
parent 0cd6bd3d86
commit 7a4c8f30db
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
source/libs/stream/src/streamState.c
View File

@ -127,7 +127,7 @@ SStreamState* streamStateOpen(char* path, SStreamTask* pTask, bool specPath, int
tstrncpy(statePath, path, 1024); tstrncpy(statePath, path, 1024);
} }
char cfgPath[1024]; char cfgPath[1030];
sprintf(cfgPath, "%s/cfg", statePath); sprintf(cfgPath, "%s/cfg", statePath);
char cfg[1024]; char cfg[1024];
@ -141,10 +141,8 @@ SStreamState* streamStateOpen(char* path, SStreamTask* pTask, bool specPath, int
} else { } else {
taosMulModeMkDir(statePath, 0755); taosMulModeMkDir(statePath, 0755);
pCfgFile = taosOpenFile(cfgPath, TD_FILE_WRITE | TD_FILE_CREATE); pCfgFile = taosOpenFile(cfgPath, TD_FILE_WRITE | TD_FILE_CREATE);
szPage = szPage < 0 ? 4096 * 8 : szPage; szPage = szPage < 0 ? 4096 : szPage;
pages = pages < 0 ? 256 * 32 : pages; pages = pages < 0 ? 256 : pages;
/*szPage = szPage < 0 ? 4096 : szPage;*/
/*pages = pages < 0 ? 256 : pages;*/
sprintf(cfg, "%d\n%d\n", szPage, pages); sprintf(cfg, "%d\n%d\n", szPage, pages);
taosWriteFile(pCfgFile, cfg, strlen(cfg)); taosWriteFile(pCfgFile, cfg, strlen(cfg));
} }