uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

fix for scheduler multiple execution

Browse Source 
fixes #175
This commit is contained in:
Radu Ioan Fericean
2015-09-14 21:21:07 +03:00
parent fd63470916
commit 46176699e2
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
scheduler/scheduler.go
View File

@@ -46,22 +46,27 @@ func (s *Scheduler) Loop() {
}
s.Lock()
a0 := s.queue[0]
//engine.Logger.Info(fmt.Sprintf("Scheduler qeue length: %v", len(s.qeue)))
now := time.Now()
if a0.GetNextStartTime(now).Equal(now) || a0.GetNextStartTime(now).Before(now) {
start := a0.GetNextStartTime(now)
if start.Equal(now) || start.Before(now) {
go a0.Execute()
// if after execute the next start time is in the past then
// do not add it to the queue
now = time.Now()
if !a0.GetNextStartTime(now).Before(now) {
now = time.Now().Add(time.Second)
start = a0.GetNextStartTime(now)
if !start.Before(now) {
s.queue = append(s.queue, a0)
s.queue = s.queue[1:]
sort.Sort(s.queue)
} else {
s.queue = s.queue[1:]
}
s.Unlock()
} else {
s.Unlock()
d := a0.GetNextStartTime(now).Sub(now)
// engine.Logger.Info(fmt.Sprintf("Timer set to wait for %v", d))
//engine.Logger.Info(fmt.Sprintf("Timer set to wait for %v", d))
s.timer = time.NewTimer(d)
select {
case <-s.timer.C: