From f22014ee2159dc7b00d71a2455c9e18f15b44102 Mon Sep 17 00:00:00 2001 From: Trial97 Date: Mon, 15 Jul 2019 15:01:05 +0300 Subject: [PATCH] Updated debitLoop --- sessions/sessions.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/sessions/sessions.go b/sessions/sessions.go index 2d85b2090..75921e554 100644 --- a/sessions/sessions.go +++ b/sessions/sessions.go @@ -528,7 +528,7 @@ func (sS *SessionS) debitLoopSession(s *Session, sRunIdx int, return } - for { + for i := 0; i < 3; { var maxDebit time.Duration if maxDebit, err = sS.debitSession(s, sRunIdx, dbtIvl, nil); err != nil { utils.Logger.Warning( @@ -545,6 +545,7 @@ func (sS *SessionS) debitLoopSession(s *Session, sRunIdx int, } return } else if maxDebit < dbtIvl { + i++ go func() { // schedule sending disconnect command select { case <-s.debitStop: // call was disconnected already @@ -1434,6 +1435,7 @@ func (sS *SessionS) endSession(s *Session, tUsage, lastUsage *time.Duration, aTi } if s.debitStop != nil { close(s.debitStop) // Stop automatic debits + time.Sleep(1) s.debitStop = nil } if sr.EventCost != nil {