Fix a possible thread stall resulting in processing delay or OS udp b…

…uffer overflow. (#1494)
nanocurrency · Dec 28, 2018 · 34926f8 · 34926f8
1 parent 074ba48
commit 34926f8
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git 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<std::mutex> 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<std::mutex> 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
@@ -256,9 +256,9 @@ class udp_data
 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