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) } }