issue-463: start nbd-endpoint with any connected nbd-device

ydb-platform · Mar 19, 2024 · fd74c64 · fd74c64
1 parent ad0d642
commit fd74c64
Show file tree

Hide file tree

Showing 9 changed files with 894 additions and 231 deletions.
diff --git a/cloud/blockstore/libs/daemon/common/bootstrap.cpp b/cloud/blockstore/libs/daemon/common/bootstrap.cpp
@@ -39,6 +39,7 @@
 #include <cloud/blockstore/libs/endpoints_spdk/spdk_server.h>
 #include <cloud/blockstore/libs/endpoints_vhost/external_vhost_server.h>
 #include <cloud/blockstore/libs/endpoints_vhost/vhost_server.h>
+#include <cloud/blockstore/libs/nbd/device.h>
 #include <cloud/blockstore/libs/nbd/server.h>
 #include <cloud/blockstore/libs/nvme/nvme.h>
 #include <cloud/blockstore/libs/rdma/iface/client.h>
@@ -496,6 +497,11 @@ void TBootstrapBase::Init()
     }
     STORAGE_INFO("EndpointStorage initialized");
 
+    TEndpointManagerOptions endpointManagerOptions = {
+        .ClientConfig = Configs->EndpointConfig->GetClientConfig(),
+        .NbdSocketSuffix = Configs->ServerConfig->GetNbdSocketSuffix(),
+    };
+
     EndpointManager = CreateEndpointManager(
         Timer,
         Scheduler,
@@ -508,8 +514,8 @@ void TBootstrapBase::Init()
         std::move(sessionManager),
         std::move(endpointStorage),
         std::move(endpointListeners),
-        Configs->EndpointConfig->GetClientConfig(),
-        Configs->ServerConfig->GetNbdSocketSuffix());
+        NBD::CreateDeviceConnectionFactory(Logging, TDuration::Days(1)),
+        std::move(endpointManagerOptions));
 
     STORAGE_INFO("EndpointManager initialized");