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

Implement fix for fwv single file processing

Browse Source
This commit is contained in:
ionutboangiu
2023-01-16 18:37:43 +02:00
committed by Dan Christian Bogos
parent 07ff6e9c00
commit 637e0f935f
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
ers/filefwv.go
View File

@@ -176,6 +176,9 @@ func (rdr *FWVFileER) processFile(fPath, fName string) (err error) {
continue
}
}
if rdr.offset >= rdr.trailerOffset {
break
}
buf := make([]byte, rdr.lineLen)
if nRead, err := file.Read(buf); err != nil {
@@ -224,7 +227,7 @@ func (rdr *FWVFileER) processFile(fPath, fName string) (err error) {
return
}
}
rdr.offset = 0
utils.Logger.Info(
fmt.Sprintf("%s finished processing file <%s>. Total records processed: %d, events posted: %d, run duration: %s",
utils.ERs, absPath, rowNr, evsPosted, time.Now().Sub(timeStart)))