ethernetPacketBackendWindows.cpp

Go to the documentation of this file.

 
 
#ifndef NOMINMAX
#define NOMINMAX
#endif
#ifndef WIN32_LEAN_AND_MEAN
#define WIN32_LEAN_AND_MEAN
#endif
#include <winsock2.h>
#include <windows.h>
 
#include <asio/windows/object_handle.hpp>
 
#include "profinet/ethernetPacketBackend.h"
#include "profinet/exceptions.h"
 
namespace profinet
{
void AsioEthernetSocket::EthernetPacketBackend::InitializePacketWait()
{
  const HANDLE captureEvent = pcap_getevent(capture);
 
  if (captureEvent == nullptr || captureEvent == INVALID_HANDLE_VALUE)
  {
    usePolling = true;
    return;
  }
 
  HANDLE duplicatedEvent = nullptr;
 
  if (!DuplicateHandle(GetCurrentProcess(), captureEvent, GetCurrentProcess(), &duplicatedEvent, 0, FALSE, DUPLICATE_SAME_ACCESS))
  {
    throw SocketError("Failed to duplicate libpcap packet event: error " + std::to_string(GetLastError()));
  }
 
  asio::error_code error;
 
  packetWait.assign(duplicatedEvent, error);
 
  if (error)
  {
    CloseHandle(duplicatedEvent);
 
    throw SocketError("Failed to assign libpcap event to Asio: " + error.message());
  }
 
  usePolling = false;
}
 
void AsioEthernetSocket::EthernetPacketBackend::AsyncWaitForPacket(const std::shared_ptr<ReceiveOperation>& operation)
{
  if (usePolling)
  {
    operation->pollTimer.expires_after(std::chrono::milliseconds(1));
 
    operation->pollTimer.async_wait([this, operation](const asio::error_code& error)
    {
      HandlePacketReady(operation, error);
    });
 
    return;
  }
 
  packetWait.async_wait([this, operation](const asio::error_code& error)
  {
    HandlePacketReady(operation, error);
  });
}
 
void AsioEthernetSocket::EthernetPacketBackend::CancelPacketWait(const std::shared_ptr<ReceiveOperation>& operation, asio::error_code& error)
{
  if (usePolling)
  {
    operation->pollTimer.cancel(error);
  }
  else
  {
    packetWait.cancel(error);
  }
}
 
} // namespace profinet