diff --git a/rai/node/node.cpp b/rai/node/node.cpp index c719f336..49e859c9 100644 --- a/rai/node/node.cpp +++ b/rai/node/node.cpp @@ -3699,7 +3699,7 @@ void rai::udp_buffer::enqueue (rai::udp_data * data_a) std::lock_guard lock (mutex); full.push_back (data_a); } - condition.notify_one (); + condition.notify_all (); } rai::udp_data * rai::udp_buffer::dequeue () { @@ -3723,7 +3723,7 @@ void rai::udp_buffer::release (rai::udp_data * data_a) std::lock_guard lock (mutex); free.push_back (data_a); } - condition.notify_one (); + condition.notify_all (); } void rai::udp_buffer::stop () { diff --git a/rai/node/node.hpp b/rai/node/node.hpp index 42155b53..924846a4 100644 --- a/rai/node/node.hpp +++ b/rai/node/node.hpp @@ -256,9 +256,9 @@ public: class udp_buffer { public: + // Stats - Statistics // Size - Size of each individual buffer // Count - Number of buffers to allocate - // Stats - Statistics udp_buffer (rai::stat & stats, size_t, size_t); // Return a buffer where UDP data can be put // Method will attempt to return the first free buffer