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

Adding CDRs posted information to CDRC, fixes #132

Browse Source
This commit is contained in:
DanB
2015-07-31 09:12:25 +02:00
parent 8a19b2736c
commit ab2b05dbde
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
cdrc/cdrc.go
View File

@@ -258,6 +258,7 @@ func (self *Cdrc) processFile(filePath string) error {
return fmt.Errorf("Unsupported CDR format: %s", self.cdrFormat)
}
procRowNr := 0
cdrsPosted := 0
timeStart := time.Now()
for {
cdrs, err := recordsProcessor.ProcessNextRecord()
@@ -279,6 +280,8 @@ func (self *Cdrc) processFile(filePath string) error {
engine.Logger.Err(fmt.Sprintf("<Cdrc> Failed sending CDR, %+v, error: %s", storedCdr, err.Error()))
} else if reply != "OK" {
engine.Logger.Err(fmt.Sprintf("<Cdrc> Received unexpected reply for CDR, %+v, reply: %s", storedCdr, reply))
} else {
cdrsPosted += 1
}
}
}
@@ -288,7 +291,7 @@ func (self *Cdrc) processFile(filePath string) error {
engine.Logger.Err(err.Error())
return err
}
engine.Logger.Info(fmt.Sprintf("Finished processing %s, moved to %s. Total records processed: %d, run duration: %s",
fn, newPath, procRowNr, time.Now().Sub(timeStart)))
engine.Logger.Info(fmt.Sprintf("Finished processing %s, moved to %s. Total records processed: %d, CDRs posted: %d, run duration: %s",
fn, newPath, procRowNr, cdrsPosted, time.Now().Sub(timeStart)))
return nil
}