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) override;
 
  Bytes Receive(std::chrono::milliseconds timeout, asio::ip::udp::endpoint& remoteEndpoint) override;
 
  void SendTo(const Bytes& data, const asio::ip::udp::endpoint& targetEndpoint) override;
 
  Bytes SendReceive(const Bytes& data, std::chrono::milliseconds timeout) override;
 
  void Send(const Bytes& data) override;
 
  void Close() noexcept override;
 
  [[nodiscard]] bool IsOpen() const noexcept;
 
 private:
  asio::io_context& ioContext;
  asio::ip::udp::socket socket;
  asio::ip::udp::endpoint endpoint;
};
 
} // namespace profinet::rpc