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

SMGenericV.SetPassiveSession

Browse Source
This commit is contained in:
DanB
2016-10-27 12:26:25 +02:00
parent 551f9ea69d
commit 010ab252df
1 changed files with 28 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
sessionmanager/smgeneric.go
View File

@@ -659,6 +659,27 @@ func (smg *SMGeneric) ActiveSessions(fltrs map[string]string, count bool) (aSess
return
}
// SetPassiveSession will add or set a previously found session in passive session list
func (smg *SMGeneric) setPassiveSession(s *SMGSession) {
smg.pSessionsMux.Lock()
if ss, hasID := smg.passiveSessions[s.EventStart.GetUUID()]; !hasID {
smg.passiveSessions[s.EventStart.GetUUID()] = []*SMGSession{s}
} else {
var exists bool
for i, oldS := range ss {
if oldS.RunID == s.RunID {
smg.passiveSessions[s.EventStart.GetUUID()][i] = s
exists = true
break
}
}
if !exists {
smg.passiveSessions[s.EventStart.GetUUID()] = append(smg.passiveSessions[s.EventStart.GetUUID()], s)
}
}
smg.pSessionsMux.Unlock()
}
func (smg *SMGeneric) Timezone() string {
return smg.timezone
}
@@ -797,3 +818,10 @@ func (smg *SMGeneric) BiRPCV1ActiveSessionsCount(attrs utils.AttrSMGGetActiveSes
}
return nil
}
// BiRPCV1SetPassiveSession used for replicating SMGSessions
func (smg *SMGeneric) BiRPCV1SetPassiveSession(s SMGSession, reply *string) error {
smg.setPassiveSession(&s)
*reply = utils.OK
return nil
}