rpcTransport.h

Go to the documentation of this file.

 
 
#pragma once
 
#include <asio.hpp>
#include <chrono>
#include <cstdint>
 
#include "profinet/IRpcTransport.h"
#include "profinet/protocol.h"
 
namespace profinet::rpc
{
 
class RpcTransport : public IRpcTransport
{
 public:
  explicit RpcTransport(asio::io_context& ioContext);
 
  void Open(const std::string& address, std::uint16_t port,
            bool isListener = false);
 
  Bytes Receive(
      std::chrono::milliseconds timeout,
      asio::ip::udp::endpoint& remoteEndpoint);
 
  void SendTo(
      const Bytes& data,
      const asio::ip::udp::endpoint& targetEndpoint);
 
  Bytes SendReceive(
      const Bytes& data,
      std::chrono::milliseconds timeout) override;
 
  void Send(const Bytes& data) override;
 
  void Close() noexcept;
 
  [[nodiscard]] bool IsOpen() const noexcept;
 
 private:
  asio::io_context& ioContext;
  asio::ip::udp::socket socket;
  asio::ip::udp::endpoint endpoint;
};
 
} // namespace profinet::rpc