Add new state pcap_dump_processing_done

Author: cardigliano

include/NetworkInterface.h

@@ -1193,8 +1193,12 @@ class NetworkInterface : public NetworkInterfaceAlertableEntity {
 
   virtual bool read_from_stdin() const { return (false); };
   virtual bool read_from_pcap_dump() const { return (false); };
+
   virtual bool read_from_pcap_dump_done() const { return (false); };
   virtual void set_read_from_pcap_dump_done() { ; };
+
+  virtual bool pcap_dump_processing_done() const { return (false); };
+  virtual void set_pcap_dump_processing_done() { ; };
   /*
     Issue a request for user scripts reload. This is called by ntopng when user
     scripts should be reloaded, e.g., after a configuration change.

include/PcapInterface.h

@@ -34,7 +34,7 @@ class PcapInterface : public NetworkInterface {
   unsigned int ifname_indexes[MAX_NUM_PCAP_INTERFACES];
   int iface_datalink[MAX_NUM_PCAP_INTERFACES];
   char *pcap_path;
-  bool read_pkts_from_pcap_dump, read_pkts_from_pcap_dump_done,
+  bool read_pkts_from_pcap_dump, read_pkts_from_pcap_dump_done, processing_from_pcap_dump_done,
     read_pkts_from_directory, emulate_traffic_directions, read_from_stdin_pipe,
     delete_pcap_when_done;
   ProtoStats prev_stats_in, prev_stats_out;
@@ -85,6 +85,10 @@ class PcapInterface : public NetworkInterface {
     return (read_pkts_from_pcap_dump_done);
   };
   void set_read_from_pcap_dump_done() { read_pkts_from_pcap_dump_done = true; };
+  bool pcap_dump_processing_done() const {
+    return (processing_from_pcap_dump_done);
+  };
+  void set_pcap_dump_processing_done() { processing_from_pcap_dump_done = true; };
   void sendTermination();
   bool reproducePcapOriginalSpeed() const;
   virtual void updateDirectionStats();

src/PcapInterface.cpp

@@ -45,7 +45,7 @@ PcapInterface::PcapInterface(const char *name, u_int8_t ifIdx,
   num_ifaces = 0, pcap_list = NULL;
   memset(&last_pcap_stat, 0, sizeof(last_pcap_stat));
   emulate_traffic_directions = false;
-  read_pkts_from_pcap_dump = read_pkts_from_pcap_dump_done = false,
+  read_pkts_from_pcap_dump = read_pkts_from_pcap_dump_done = false, processing_from_pcap_dump_done = false,
     read_pkts_from_directory = false, read_from_stdin_pipe = false;
 
   firstPktTS.tv_sec = 0;
@@ -448,6 +448,8 @@ static void *packetPollLoop(void *ptr) {
   for (int i = 0; i < 2; i++)
     iface->purgeIdle(time(NULL), false, true /* Full scan */);
 
+  iface->set_pcap_dump_processing_done();
+
   ntop->getTrace()->traceEvent(TRACE_NORMAL, "Terminated packet polling for %s",
                                iface->get_description());