diff --git a/core-writer/include/UdpRecvModule.hpp b/core-writer/include/UdpRecvModule.hpp index af53abc..e884cc0 100644 --- a/core-writer/include/UdpRecvModule.hpp +++ b/core-writer/include/UdpRecvModule.hpp @@ -14,7 +14,7 @@ class UdpRecvModule { protected: void receive_thread( const uint16_t udp_port, - const size_t udp_buffer_n_bytes); + const size_t frame_size); public: UdpRecvModule(RingBuffer& ring_buffer); @@ -23,7 +23,7 @@ class UdpRecvModule { void start_recv( const uint16_t udp_port, - const size_t udp_buffer_n_bytes); + const size_t frame_n_bytes); void stop_recv(); bool is_receiving(); }; diff --git a/core-writer/src/module/UdpRecvModule.cpp b/core-writer/src/module/UdpRecvModule.cpp index 52f07ea..dbaf1a4 100644 --- a/core-writer/src/module/UdpRecvModule.cpp +++ b/core-writer/src/module/UdpRecvModule.cpp @@ -19,7 +19,7 @@ UdpRecvModule::~UdpRecvModule() void UdpRecvModule::start_recv( const uint16_t udp_port, - const size_t udp_buffer_n_bytes) + const size_t frame_n_bytes) { if (is_receiving_ == true) { std::stringstream err_msg; @@ -73,10 +73,10 @@ void UdpRecvModule::stop_recv() void UdpRecvModule::receive_thread( const uint16_t udp_port, - const size_t udp_buffer_n_bytes) + const size_t frame_size) { try { - ring_buffer_.initialize(udp_buffer_n_bytes); + ring_buffer_.initialize(frame_size); UdpReceiver udp_receiver; udp_receiver.bind(udp_port);