[nifi-minifi-cpp] branch main updated: MINIFICPP-1542 fix race condition in Connection::isWorkAvailable

[adebreceni]

This is an automated email from the ASF dual-hosted git repository.

adebreceni pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git


The following commit(s) were added to refs/heads/main by this push:
     new 4891f28  MINIFICPP-1542 fix race condition in 
Connection::isWorkAvailable
4891f28 is described below

commit 4891f287bba73145450496feacbeb87d0ad46ff1
Author: Marton Szasz <szasz...@gmail.com>
AuthorDate: Mon Apr 19 08:40:39 2021 +0200

    MINIFICPP-1542 fix race condition in Connection::isWorkAvailable
    
    Signed-off-by: Adam Debreceni <adebrec...@apache.org>
    
    This closes #1050
---
 libminifi/include/Connection.h | 1 +
 1 file changed, 1 insertion(+)

diff --git a/libminifi/include/Connection.h b/libminifi/include/Connection.h
index e3e50ac..888fcc0 100644
--- a/libminifi/include/Connection.h
+++ b/libminifi/include/Connection.h
@@ -167,6 +167,7 @@ class Connection : public core::Connectable, public 
std::enable_shared_from_this
   void yield() override {}
 
   bool isWorkAvailable() override {
+    const std::lock_guard<std::mutex> lock{mutex_};
     return queue_.isWorkAvailable();
   }