From 72cb0693a547bcb6ed0173c50df0bdb734ca642d Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 13 Aug 2020 19:41:05 +0800 Subject: [PATCH] [bugfix] support switch scheduler.strategy --- src/main.go | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/src/main.go b/src/main.go index b5065ab..24e648c 100644 --- a/src/main.go +++ b/src/main.go @@ -321,6 +321,14 @@ func serverAPI(w http.ResponseWriter, r *http.Request) { } break + /* scheduler.strategy */ + /* TODO: move jobs */ + case "scheduler.strategy": + ok = InstanceOfConfiguration().SetSchedulePolicy(value) + scheduler = InstanceOfConfiguration().GetScheduler() + scheduler.Start() + break + /* scheduler.mock */ case "scheduler.mock.enabled": ok = InstanceOfConfiguration().SetMockEnabled(value == "true") @@ -344,11 +352,8 @@ func serverAPI(w http.ResponseWriter, r *http.Request) { break /* allocator.strategy */ - /* TODO: move jobs */ case "allocator.strategy": ok = InstanceOfAllocator().updateStrategy(value) - scheduler = InstanceOfConfiguration().GetScheduler() - scheduler.Start() break /* logger */