udpSocket.h

Go to the documentation of this file.

 
 
#pragma once
 
#include <asio.hpp>
#include <chrono>
#include <cstddef>
#include <cstdint>
#include <memory>
#include <string>
#include <vector>
 
#include "profinet/IUdpSocket.h"
 
namespace profinet
{
 
class UdpSocket final : public IUdpSocket
{
 public:
  static constexpr double defaultTimeout = 5.0;
 
  static constexpr int defaultReceiveBufferSize = 65536;
 
  UdpSocket(
      const std::string& host,
      std::uint16_t port,
      std::chrono::duration<double> timeout =
          std::chrono::duration<double>(defaultTimeout));
 
  explicit UdpSocket(
      std::uint16_t localPort,
      std::chrono::duration<double> timeout =
          std::chrono::duration<double>(defaultTimeout));
 
  ~UdpSocket() override;
 
  UdpSocket(const UdpSocket&) = delete;
 
  UdpSocket& operator=(const UdpSocket&) = delete;
 
  UdpSocket(UdpSocket&& other) noexcept;
 
  UdpSocket& operator=(UdpSocket&& other) noexcept;
 
  void Send(const std::vector<std::uint8_t>& data) const;
 
  [[nodiscard]] std::vector<std::uint8_t> Recv(
      std::size_t maxLen = defaultReceiveBufferSize) const;
 
  [[nodiscard]] UdpDatagram RecvFrom(std::size_t maxLen) override;
 
  void SendTo(const std::vector<std::uint8_t>& data, const UdpEndpoint&) override;
 
  void SetTimeout(std::chrono::milliseconds timeout) override;
 
  [[nodiscard]] UdpEndpoint LocalEndpoint() const;
 
 private:
  std::unique_ptr<asio::io_context> ioContext;
 
  std::unique_ptr<asio::ip::udp::socket> socket;
 
  std::chrono::milliseconds receiveTimeout{
      std::chrono::duration_cast<std::chrono::milliseconds>(
          std::chrono::duration<double>(defaultTimeout))};
};
 
} // namespace profinet