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

Set the CGRid in the EventStart on rename so we can properly have it in TTLTerminate

Browse Source
This commit is contained in:
DanB
2018-08-19 19:21:26 +02:00
parent 4e3254ba53
commit db0a03572f
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
sessions/sessions.go
View File

@@ -573,6 +573,7 @@ func (smg *SMGeneric) sessionRelocate(initialID, cgrID, newOriginID string) erro
for i, s := range ss[initialID] {
s.mux.Lock()
s.CGRID = cgrID // Overwrite initial CGRID with new one
s.EventStart.Set(utils.CGRID, cgrID) // Overwrite CGRID for final CDR
s.EventStart.Set(utils.OriginID, newOriginID) // Overwrite OriginID for session indexing
s.mux.Unlock()
smg.recordASession(s)
@@ -841,7 +842,6 @@ func (smg *SMGeneric) UpdateSession(gev *engine.SafEvent,
if gev.HasField(utils.InitialOriginID) {
initialCGRID := utils.Sha1(gev.GetStringIgnoreErrors(utils.InitialOriginID),
gev.GetStringIgnoreErrors(utils.OriginHost))
fmt.Printf("InitialOriginID: %s, initialCGRId: %s, cgrID: %s\n", gev.GetStringIgnoreErrors(utils.InitialOriginID), initialCGRID, cgrID)
err = smg.sessionRelocate(initialCGRID,
cgrID, gev.GetStringIgnoreErrors(utils.OriginID))
if err == utils.ErrNotFound { // Session was already relocated, create a new session with this update