Protecting peer list with mutex

Signed-off-by: Gautam Venkataramanan <gautam.chennai@gmail.com>
noironetworks · Jun 24, 2020 · 67802ee · 67802ee
1 parent 6dcf182
commit 67802ee
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/libopflex/comms/loopdata.cpp b/libopflex/comms/loopdata.cpp
@@ -128,6 +128,7 @@ void internal::Peer::LoopData::destroy(bool now) {
     destroying_ = true;
     down();
 
+    opflex::util::LockGuard guard(&peerMutex);
     for (size_t i=0; i < Peer::LoopData::TOTAL_STATES; ++i) {
         peers[Peer::LoopData::PeerState(i)]
             .clear_and_dispose(PeerDisposer(now));