From a06830b2f88a8d374c326a1191870cbc7cf7dac2 Mon Sep 17 00:00:00 2001 From: George Goldberg Date: Thu, 28 Sep 2017 17:11:13 +0100 Subject: PLT-7644: Improve job scheduler architecture. (#7532) --- jobs/testscheduler.go | 58 --------------------------------------------------- 1 file changed, 58 deletions(-) delete mode 100644 jobs/testscheduler.go (limited to 'jobs/testscheduler.go') diff --git a/jobs/testscheduler.go b/jobs/testscheduler.go deleted file mode 100644 index d7345f67f..000000000 --- a/jobs/testscheduler.go +++ /dev/null @@ -1,58 +0,0 @@ -// Copyright (c) 2017-present Mattermost, Inc. All Rights Reserved. -// See License.txt for license information. - -package jobs - -import ( - "time" - - l4g "github.com/alecthomas/log4go" -) - -type TestScheduler struct { - name string - jobType string - stop chan bool - stopped chan bool -} - -func MakeTestScheduler(name string, jobType string) *TestScheduler { - return &TestScheduler{ - name: name, - jobType: jobType, - stop: make(chan bool, 1), - stopped: make(chan bool, 1), - } -} - -func (scheduler *TestScheduler) Run() { - l4g.Debug("Scheduler %v: Started", scheduler.name) - - defer func() { - l4g.Debug("Scheduler %v: Finished", scheduler.name) - scheduler.stopped <- true - }() - - for { - select { - case <-scheduler.stop: - l4g.Debug("Scheduler %v: Received stop signal", scheduler.name) - return - case <-time.After(86400 * time.Second): - l4g.Debug("Scheduler: %v: Scheduling new job", scheduler.name) - scheduler.AddJob() - } - } -} - -func (scheduler *TestScheduler) AddJob() { - if _, err := CreateJob(scheduler.jobType, nil); err != nil { - l4g.Error("Scheduler %v: failed to create job: %v", scheduler.name, err) - } -} - -func (scheduler *TestScheduler) Stop() { - l4g.Debug("Scheduler %v: Stopping", scheduler.name) - scheduler.stop <- true - <-scheduler.stopped -} -- cgit v1.2.3-1-g7c22