3 #ifndef VISR_LIBRCL_UDP_RECEIVER_HPP_INCLUDED 4 #define VISR_LIBRCL_UDP_RECEIVER_HPP_INCLUDED 15 #include <boost/array.hpp> 16 #include <boost/asio/io_service.hpp> 17 #include <boost/asio/ip/udp.hpp> 18 #include <boost/thread/thread.hpp> 48 static std::size_t
const cMaxMessageLength = 65536;
73 void setup( std::size_t port,
Mode mode, boost::asio::io_service* externalIoService =
nullptr );
78 void process()
override;
81 void handleReceiveData(
const boost::system::error_code& error,
82 std::size_t numBytesTransferred );
89 boost::asio::io_service* mIoService;
95 std::unique_ptr<boost::asio::io_service> mIoServiceInstance;
98 std::unique_ptr<boost::asio::ip::udp::socket> mSocket;
100 boost::asio::ip::udp::endpoint mRemoteEndpoint;
102 boost::array<char, cMaxMessageLength> mReceiveBuffer;
104 std::unique_ptr<boost::asio::io_service::work> mIoServiceWork;
110 std::deque< pml::StringParameter > mInternalMessageBuffer;
112 std::unique_ptr< boost::thread > mServiceThread;
122 #endif // #ifndef VISR_LIBRCL_UDP_RECEIVER_HPP_INCLUDED Definition: udp_receiver.hpp:35
Definition: options.cpp:10
Definition: atomic_component.hpp:21
Definition: composite_component.hpp:29
Definition: signal_flow_context.hpp:15
Mode
Definition: udp_receiver.hpp:38