diff options
Diffstat (limited to 'pcap_importer.go')
| -rw-r--r-- | pcap_importer.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/pcap_importer.go b/pcap_importer.go index 1c80b3f..476d8d7 100644 --- a/pcap_importer.go +++ b/pcap_importer.go @@ -204,7 +204,8 @@ func (pi *PcapImporter) parsePcap(session ImportingSession, fileName string, flu case packet := <-packets: if packet == nil { // completed if flushAll { - assembler.FlushAll() + connectionsClosed := assembler.FlushAll() + log.Debugf("connections closed after flush: %v", connectionsClosed) } handle.Close() pi.releaseAssembler(assembler) |