wip

ecmwf · Oct 1, 2024 · 4c1ac8d · 4c1ac8d
1 parent 2d3ce4d
commit 4c1ac8d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/src/fdb5/remote/server/ServerConnection.cc b/src/fdb5/remote/server/ServerConnection.cc
@@ -168,6 +168,8 @@ void ServerConnection::initialiseConnections() {
         errorMsg = "Error retrieving client protocol version";
     }
 
+    std::cout << "Connection from: " << endpointFromClient << "  sessionId" << clientSession << std::endl;
+
     if (errorMsg.empty() && !LibFdb5::instance().remoteProtocolVersion().check(remoteProtocolVersion, false)) {
         std::stringstream ss;
         ss << "FDB server version " << fdb5_version_str() << " - remote protocol version not supported:" << std::endl;
@@ -234,6 +236,7 @@ void ServerConnection::initialiseConnections() {
     if (single_) {
         dataEndpoint = endpointFromClient;
     } else {
+        std::lock_guard<std::mutex> lock(dataPortMutex_);
         dataSocket_.reset(new eckit::net::EphemeralTCPServer(selectDataPort()));
         ASSERT(dataSocket_->socket() != -1);
 

diff --git a/src/fdb5/remote/server/ServerConnection.h b/src/fdb5/remote/server/ServerConnection.h
@@ -156,6 +156,8 @@ class ServerConnection : public Connection, public Handler {
 
 private:
 
+    std::mutex dataPortMutex_;
+
     // data connection
     std::unique_ptr<eckit::net::EphemeralTCPServer> dataSocket_;
     size_t dataListener_;