Improvement in internal frame generator

Improve way how internal packet generator is executed (mostly in HLS simulation), allowing to make it more similar to "standard" network collection. This required to modify network stack cores, so they can be executed in parallel in HLS simulation.

acquisition_device/HLSSimulatedDevice.cpp

@@ -317,7 +317,6 @@ void HLSSimulatedDevice::HLSMainThread() {
                         cfg.nsummation);
 
     // here idle = 0 and run = 0
-
     if (data_source == STREAM_MERGE_SRC_FRAME_GEN) {
         while (!din_frame_generator.empty())
             stream_merge(din_eth, din_eth_4x10G, din_frame_generator, network0, data_source);
@@ -329,23 +328,53 @@ void HLSSimulatedDevice::HLSMainThread() {
             stream_merge(din_eth, din_eth_4x10G, din_frame_generator, network0, data_source);
     }
 
-    while(!network0.empty())
+    hls_cores.emplace_back([&] {
+        while ((idle_data_collection == 0) || (!network0.empty())) {
+            if (network0.empty())
+                std::this_thread::sleep_for(std::chrono::milliseconds(1));
         ethernet(network0, ip1, arp1, mac_addr, eth_packets, clear_counters);
+        }
+    });
 
-    while(!ip1.empty())
-        ipv4(ip1, udp1, icmp1, ipv4_addr);
+    hls_cores.emplace_back([&] {
+        while ((idle_data_collection == 0) || (!ip1.empty())) {
+            if (ip1.empty())
+                std::this_thread::sleep_for(std::chrono::milliseconds(1));
+            ipv4(ip1, udp1, icmp1, ipv4_addr);
+        }
+    });
 
-    while (!arp1.empty())
-        arp(arp1, dout_eth, mac_addr, ipv4_addr, 1, 0);
+    hls_cores.emplace_back([&] {
+        while ((idle_data_collection == 0) || (!arp1.empty())) {
+            if (arp1.empty())
+                std::this_thread::sleep_for(std::chrono::milliseconds(1));
+            arp(arp1, dout_eth, mac_addr, ipv4_addr, 0, 0);
+        }
+    });
 
-    while(!icmp1.empty())
+    hls_cores.emplace_back([&] {
+        while ((idle_data_collection == 0) || (!icmp1.empty())) {
+            if (icmp1.empty())
+                std::this_thread::sleep_for(std::chrono::milliseconds(1));
         icmp(icmp1, dout_eth, icmp_packets, clear_counters);
+        }
+    });
 
-    while (!udp1.empty())
+    hls_cores.emplace_back([&] {
+        while ((idle_data_collection == 0) || (!udp1.empty())) {
+            if (udp1.empty())
+                std::this_thread::sleep_for(std::chrono::milliseconds(1));
         udp(udp1, udp2, udp_metadata, udp_packets, clear_counters);
+        }
+    });
 
-    while (!udp2.empty())
-        sls_detector(udp2, udp_metadata, raw0, addr0, sls_packets, udp_eth_err, udp_len_err, clear_counters);
+    hls_cores.emplace_back([&] {
+        while ((idle_data_collection == 0) || (!udp2.empty())) {
+            if (udp2.empty())
+                std::this_thread::sleep_for(std::chrono::milliseconds(1));
+            sls_detector(udp2, udp_metadata, raw0, addr0, sls_packets, udp_eth_err, udp_len_err, clear_counters);
+        }
+    });
 
     // 1. Parse incoming UDP packets
     hls_cores.emplace_back([&] {