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

Updated scheduler

Browse Source
This commit is contained in:
Trial97
2020-06-22 12:14:12 +03:00
parent 53d14aa7f8
commit aec2096010
2 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
engine/action_plan.go
View File

@@ -48,11 +48,10 @@ type ActionTiming struct {
// Tasks converts an ActionTiming into multiple Tasks // Tasks converts an ActionTiming into multiple Tasks
func (at *ActionTiming) Tasks() (tsks []*Task) { func (at *ActionTiming) Tasks() (tsks []*Task) {
if len(at.accountIDs) == 0 { if len(at.accountIDs) == 0 {
return []*Task{ return []*Task{{
&Task{ Uuid: at.Uuid,
Uuid: at.Uuid, ActionsID: at.ActionsID,
ActionsID: at.ActionsID, }}
}}
} }
tsks = make([]*Task, len(at.accountIDs)) tsks = make([]*Task, len(at.accountIDs))
i := 0 i := 0

4
scheduler/scheduler.go
View File

@@ -58,10 +58,10 @@ func NewScheduler(dm *engine.DataManager, cfg *config.CGRConfig,
} }
func (s *Scheduler) updateActStats(act *engine.Action, isFailed bool) { func (s *Scheduler) updateActStats(act *engine.Action, isFailed bool) {
mux := s.aSMux mux := &s.aSMux
statsMp := s.actSuccessStats statsMp := s.actSuccessStats
if isFailed { if isFailed {
mux = s.aFMux mux = &s.aFMux
statsMp = s.actFailedStats statsMp = s.actFailedStats
} }
now := time.Now() now := time.Now()