From 7c79a7c82ec6e515f6c944b32c2675138115af3d Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 13 Aug 2020 20:44:32 +0800 Subject: [PATCH] [bugfix] preempt --- src/scheduler_FCFS.go | 4 ++-- src/scheduler_priority.go | 1 + 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/src/scheduler_FCFS.go b/src/scheduler_FCFS.go index 07cbd09..1d3cb72 100644 --- a/src/scheduler_FCFS.go +++ b/src/scheduler_FCFS.go @@ -11,7 +11,7 @@ type SchedulerFCFS struct { mu sync.Mutex scheduling sync.Mutex - jobMasters map[string]*JobManager + jobMasters map[string]*JobManager enabled bool parallelism int } @@ -23,7 +23,7 @@ func (scheduler *SchedulerFCFS) Start() { go func() { for { - log.Info("Scheduling") + log.Debug("Scheduling") time.Sleep(time.Second * 5) scheduler.scheduling.Lock() scheduler.mu.Lock() diff --git a/src/scheduler_priority.go b/src/scheduler_priority.go index 763af34..ea00a95 100644 --- a/src/scheduler_priority.go +++ b/src/scheduler_priority.go @@ -143,6 +143,7 @@ func (scheduler *SchedulerPriority) Start() { if after != before { break } + log.Info("before=", before, " after=", after) time.Sleep(time.Millisecond * 100) } }