|
@@ -150,20 +150,25 @@ void pcap_processor::collect_statistics() {
|
|
|
|
|
|
std::chrono::microseconds currentCaptureDuration = lastPktTimestamp - firstTimestamp;
|
|
std::chrono::microseconds currentCaptureDuration = lastPktTimestamp - firstTimestamp;
|
|
std::chrono::microseconds barrier = timeIntervalCounter*timeInterval;
|
|
std::chrono::microseconds barrier = timeIntervalCounter*timeInterval;
|
|
- if(currentCaptureDuration>barrier){
|
|
+ if(currentCaptureDuration>barrier){
|
|
-
|
|
|
|
stats.addIntervalStat(timeInterval, intervalStartTimestamp, lastPktTimestamp, previousPacketCount);
|
|
stats.addIntervalStat(timeInterval, intervalStartTimestamp, lastPktTimestamp, previousPacketCount);
|
|
timeIntervalCounter++;
|
|
timeIntervalCounter++;
|
|
intervalStartTimestamp = lastPktTimestamp;
|
|
intervalStartTimestamp = lastPktTimestamp;
|
|
previousPacketCount = stats.getPacketCount();
|
|
previousPacketCount = stats.getPacketCount();
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ std::cout << "Aidmar: addIntervalStat + getPacketCount" << std::endl;
|
|
|
|
+
|
|
stats.incrementPacketCount();
|
|
stats.incrementPacketCount();
|
|
this->process_packets(*i);
|
|
this->process_packets(*i);
|
|
|
|
+
|
|
|
|
+ std::cout << "Aidmar: process_packets + incrementPacketCount" << std::endl;
|
|
|
|
+
|
|
lastProcessedPacket = i->timestamp();
|
|
lastProcessedPacket = i->timestamp();
|
|
counter++;
|
|
counter++;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ std::cout << "Aidmar: Done with packets" << std::endl;
|
|
|
|
|
|
stats.setTimestampLastPacket(lastProcessedPacket);
|
|
stats.setTimestampLastPacket(lastProcessedPacket);
|
|
|
|
|