implemented multicast in npcap

samples/ecaludp_perftool/src/receiver_async.cpp

@@ -16,6 +16,7 @@
 
 #include "receiver_async.h"
 
+#include <cstdlib>
 #include <exception>
 #include <iostream>
 #include <memory>
@@ -62,7 +63,7 @@ void ReceiverAsync::start()
   catch (const std::exception& e)
   {
     std::cerr << "Error creating socket: " << e.what() << '\n';
-    exit(1);
+    std::exit(1);
   }
 
   auto endpoint = asio::ip::udp::endpoint(asio::ip::make_address(parameters_.ip), parameters_.port);

samples/ecaludp_perftool/src/receiver_npcap_async.cpp

@@ -16,15 +16,17 @@
 
 #include "receiver_npcap_async.h"
 
+#include <cstdlib>
+#include <exception>
 #include <iostream>
 #include <memory>
 #include <mutex>
-#include <thread>
 
 #include <asio.hpp>
 
 #include "ecaludp/socket.h"
 #include "receiver.h"
+#include "receiver_parameters.h"
 #include "socket_builder_npcap.h"
 
 ReceiverNpcapAsync::ReceiverNpcapAsync(const ReceiverParameters& parameters)
@@ -50,7 +52,7 @@ void ReceiverNpcapAsync::start()
   catch (const std::exception& e)
   {
     std::cerr << "Error creating socket: " << e.what()<< '\n';
-    exit(1);
+    std::exit(1);
   }
 
   receive_message();

samples/ecaludp_perftool/src/receiver_npcap_sync.cpp

@@ -16,6 +16,8 @@
 
 #include "receiver_npcap_sync.h"
 
+#include <cstdlib>
+#include <exception>
 #include <iostream>
 #include <memory>
 #include <mutex>
@@ -25,6 +27,7 @@
 
 #include "ecaludp/socket_npcap.h"
 #include "receiver.h"
+#include "receiver_parameters.h"
 #include "socket_builder_npcap.h"
 
 ReceiverNpcapSync::ReceiverNpcapSync(const ReceiverParameters& parameters)
@@ -56,7 +59,7 @@ void ReceiverNpcapSync::receive_loop()
   catch (const std::exception& e)
   {
     std::cerr << "Error creating socket: " << e.what()<< '\n';
-    exit(1);
+    std::exit(1);
   }
 
   asio::ip::udp::endpoint destination(asio::ip::address::from_string(parameters_.ip), parameters_.port);

samples/ecaludp_perftool/src/receiver_sync.cpp

@@ -16,6 +16,7 @@
 
 #include "receiver_sync.h"
 
+#include <cstdlib>
 #include <exception>
 #include <iostream>
 #include <memory>
@@ -60,7 +61,7 @@ void ReceiverSync::receive_loop()
   catch (const std::exception& e)
   {
     std::cerr << "Error creating socket: " << e.what() << '\n';
-    exit(1);
+    std::exit(1);
   }
 
   asio::ip::udp::endpoint destination;

samples/ecaludp_perftool/src/socket_builder_npcap.cpp

@@ -41,6 +41,12 @@ namespace SocketBuilderNpcap
       }
     }
 
+    // only v4 is supported right now
+    if (!ip_address.is_v4())
+    {
+      throw std::runtime_error("Only IPv4 is supported");
+    }
+
     // Set receive buffer size
     if (parameters.buffer_size > 0)
     {
@@ -51,9 +57,32 @@ namespace SocketBuilderNpcap
       }
     }
 
-    const asio::ip::udp::endpoint destination(ip_address, parameters.port);
 
+    if (ip_address.is_multicast())
+    {
+      socket->set_multicast_loopback_enabled(true);
+
+      // "Bind" multicast address
+      {
+        const asio::ip::udp::endpoint bind_endpoint = asio::ip::udp::endpoint(asio::ip::address_v4(), parameters.port);
+        const bool success = socket->bind(bind_endpoint);
+        if (!success)
+        {
+          throw std::runtime_error("Failed to bind socket");
+        }
+      }
+
+      {
+        const bool success = socket->join_multicast_group(ip_address.to_v4());
+        if (!success)
+        {
+          throw std::runtime_error("Failed to join multicast group");
+        }
+      }
+    }
+    else
     {
+      const asio::ip::udp::endpoint destination(ip_address, parameters.port);
       const bool success = socket->bind(destination);
       if (!success)
       {