wip

ecmwf · Oct 1, 2024 · 0bf4d56 · 0bf4d56
1 parent f118ce4
commit 0bf4d56
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/src/eckit/net/TCPServer.cc b/src/eckit/net/TCPServer.cc
@@ -36,6 +36,8 @@ TCPServer::~TCPServer() {
 
 TCPSocket& TCPServer::accept(const std::string& message, int timeout, bool* connected) {
 
+    std::lock_guard<std::recursive_mutex> lock(acceptMutex_);
+
     bind();
 
     sockaddr_in from;

diff --git a/src/eckit/net/TCPServer.h b/src/eckit/net/TCPServer.h
@@ -58,6 +58,7 @@ class TCPServer : public TCPSocket, private NonCopyable {
 private:  // members
     bool closeExec_;
     Mutex mutex_;
+    std::recursive_mutex acceptMutex_;
 };
 
 //----------------------------------------------------------------------------------------------------------------------