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

enh: async launch tasks

This commit is contained in:
dapan1121 2022-08-22 17:38:50 +08:00
parent f6555efd9c
commit 3e7699cc2f
2 changed files with 14 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/libs/scheduler/inc/schInt.h
View File

@ -60,8 +60,7 @@ typedef enum {
#define SCH_DEFAULT_TASK_TIMEOUT_USEC 10000000 #define SCH_DEFAULT_TASK_TIMEOUT_USEC 10000000
#define SCH_MAX_TASK_TIMEOUT_USEC 60000000 #define SCH_MAX_TASK_TIMEOUT_USEC 60000000
#define SCH_DEFAULT_MAX_RETRY_NUM 6 #define SCH_DEFAULT_MAX_RETRY_NUM 6
#define SCH_MIN_AYSNC_EXEC_NUM 3
#define SCH_ASYNC_LAUNCH_TASK 0
typedef struct SSchDebug { typedef struct SSchDebug {
bool lockEnable; bool lockEnable;

26
source/libs/scheduler/src/schTask.c
View File

@ -871,14 +871,14 @@ _return:
taosMemoryFree(param); taosMemoryFree(param);
#if SCH_ASYNC_LAUNCH_TASK if (pJob->taskNum >= SCH_MIN_AYSNC_EXEC_NUM) {
if (code) { if (code) {
code = schProcessOnTaskFailure(pJob, pTask, code); code = schProcessOnTaskFailure(pJob, pTask, code);
}
if (code) {
code = schHandleJobFailure(pJob, code);
}
} }
if (code) {
code = schHandleJobFailure(pJob, code);
}
#endif
SCH_RET(code); SCH_RET(code);
} }
@ -893,12 +893,12 @@ int32_t schAsyncLaunchTaskImpl(SSchJob *pJob, SSchTask *pTask) {
param->pJob = pJob; param->pJob = pJob;
param->pTask = pTask; param->pTask = pTask;
#if SCH_ASYNC_LAUNCH_TASK if (pJob->taskNum >= SCH_MIN_AYSNC_EXEC_NUM) {
taosAsyncExec(schLaunchTaskImpl, param, NULL); taosAsyncExec(schLaunchTaskImpl, param, NULL);
#else } else {
SCH_ERR_RET(schLaunchTaskImpl(param)); SCH_ERR_RET(schLaunchTaskImpl(param));
#endif }
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;
} }