opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-09-21 14:19:49 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(baremetal): TaskWorkerCount options not init

Browse Source
This commit is contained in:
Zexi Li
2021-10-25 11:55:43 +08:00
parent f7406fad88
commit b3d3c8de66
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/baremetal/tasks/worker.go
+5 -5
View File
@@ -24,16 +24,16 @@ import (
"yunion.io/x/log"
"yunion.io/x/onecloud/pkg/appsrv"
"yunion.io/x/onecloud/pkg/baremetal/options"
"yunion.io/x/onecloud/pkg/mcclient/modules"
)
var baremetalTaskWorkerMan *appsrv.SWorkerManager
func init() {
baremetalTaskWorkerMan = appsrv.NewWorkerManager("BaremetalTaskWorkerManager", 4, 1024, false)
}
func GetWorkManager() *appsrv.SWorkerManager {
if baremetalTaskWorkerMan == nil {
baremetalTaskWorkerMan = appsrv.NewWorkerManager("BaremetalTaskWorkerManager", options.Options.TaskWorkerCount, 1024, false)
}
return baremetalTaskWorkerMan
}
@@ -62,7 +62,7 @@ func ExecuteTask(task ITask, args interface{}) {
task: task,
args: args,
}
baremetalTaskWorkerMan.Run(t, nil, nil)
GetWorkManager().Run(t, nil, nil)
}
func executeTask(task ITask, args interface{}) {