mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-12 18:46:24 +05:00
Removing some Debug messages
This commit is contained in:
@@ -957,7 +957,6 @@ func (self *SQLStorage) GetCDRs(qryFltr *utils.CDRsFilter, remove bool) ([]*CDR,
|
||||
extraFieldsMp := make(map[string]string)
|
||||
if result.ExtraFields != "" {
|
||||
if err := json.Unmarshal([]byte(result.ExtraFields), &extraFieldsMp); err != nil {
|
||||
utils.Logger.Debug(fmt.Sprintf("Unmarshall json for result: %+v, error: %v", result.ExtraFields, err))
|
||||
return nil, 0, fmt.Errorf("JSON unmarshal error for cgrid: %s, runid: %v, error: %s", result.Cgrid, result.RunID, err.Error())
|
||||
}
|
||||
}
|
||||
|
||||
@@ -111,7 +111,7 @@ func (self *SMGSession) debit(dur time.Duration, lastUsed time.Duration) (time.D
|
||||
self.cd.TimeEnd = cc.GetEndTime() // set debited timeEnd
|
||||
// update call duration with real debited duration
|
||||
ccDuration := cc.GetDuration()
|
||||
utils.Logger.Debug(fmt.Sprintf("CCDur: %f", ccDuration.Seconds()))
|
||||
//utils.Logger.Debug(fmt.Sprintf("CCDur: %f", ccDuration.Seconds()))
|
||||
if ccDuration != dur {
|
||||
self.extraDuration = ccDuration - dur
|
||||
}
|
||||
|
||||
@@ -208,7 +208,6 @@ func (self *SMGeneric) GetLcrSuppliers(gev SMGenericEvent, clnt *rpc2.Client) ([
|
||||
|
||||
// Called on session start
|
||||
func (self *SMGeneric) SessionStart(gev SMGenericEvent, clnt *rpc2.Client) (time.Duration, error) {
|
||||
utils.Logger.Debug(fmt.Sprintf("### SessionStart, gev: %+v, sessions: %+v", gev, self.getSessions()))
|
||||
if err := self.sessionStart(gev, getClientConnId(clnt)); err != nil {
|
||||
self.sessionEnd(gev.GetUUID(), 0)
|
||||
return nilDuration, err
|
||||
@@ -222,7 +221,6 @@ func (self *SMGeneric) SessionStart(gev SMGenericEvent, clnt *rpc2.Client) (time
|
||||
|
||||
// Execute debits for usage/maxUsage
|
||||
func (self *SMGeneric) SessionUpdate(gev SMGenericEvent, clnt *rpc2.Client) (time.Duration, error) {
|
||||
utils.Logger.Debug(fmt.Sprintf("### SessionUpdate, gev: %+v, sessions: %+v", gev, self.getSessions()))
|
||||
if initialID, err := gev.GetFieldAsString(utils.InitialOriginID); err == nil {
|
||||
err := self.sessionRelocate(gev.GetUUID(), initialID)
|
||||
if err == utils.ErrNotFound { // Session was already relocated, create a new session with this update
|
||||
@@ -255,7 +253,6 @@ func (self *SMGeneric) SessionUpdate(gev SMGenericEvent, clnt *rpc2.Client) (tim
|
||||
|
||||
// Called on session end, should stop debit loop
|
||||
func (self *SMGeneric) SessionEnd(gev SMGenericEvent, clnt *rpc2.Client) error {
|
||||
utils.Logger.Debug(fmt.Sprintf("### SessionEnd, gev: %+v, sessions: %+v", gev, self.getSessions()))
|
||||
if initialID, err := gev.GetFieldAsString(utils.InitialOriginID); err == nil {
|
||||
err := self.sessionRelocate(gev.GetUUID(), initialID)
|
||||
if err == utils.ErrNotFound { // Session was already relocated, create a new session with this update
|
||||
@@ -408,7 +405,6 @@ func (self *SMGeneric) ChargeEvent(gev SMGenericEvent, clnt *rpc2.Client) (maxDu
|
||||
}
|
||||
|
||||
func (self *SMGeneric) ProcessCdr(gev SMGenericEvent) error {
|
||||
utils.Logger.Debug(fmt.Sprintf("### ProcessCdr, gev: %+v, sessions: %+v", gev, self.getSessions()))
|
||||
var reply string
|
||||
if err := self.cdrsrv.ProcessCdr(gev.AsStoredCdr(self.cgrCfg, self.timezone), &reply); err != nil {
|
||||
return err
|
||||
|
||||
Reference in New Issue
Block a user