Issue 2725: mv acquire/release disk actors from DR to libs/storage/core

cloud/blockstore/libs/storage/core/acquire_release_devices.h

@@ -0,0 +1,105 @@
+#pragma once
+
+#include <cloud/blockstore/libs/kikimr/events.h>
+#include <cloud/blockstore/libs/storage/api/disk_agent.h>
+
+#include <contrib/ydb/library/actors/core/actor.h>
+#include <contrib/ydb/library/actors/interconnect/types.h>
+
+namespace NCloud::NBlockStore::NStorage::NAcquireReleaseDevices {
+
+struct TAgentAcquireDevicesCachedRequest
+{
+    TString AgentId;
+    NProto::TAcquireDevicesRequest Request;
+    TInstant RequestTime;
+};
+
+struct TAgentReleaseDevicesCachedRequest
+{
+    TString AgentId;
+    NProto::TReleaseDevicesRequest Request;
+};
+
+struct TDevicesAcquireFinished
+{
+    TString DiskId;
+    TString ClientId;
+    TVector<TAgentAcquireDevicesCachedRequest> SentRequests;
+    TVector<NProto::TDeviceConfig> Devices;
+    NProto::TError Error;
+
+    TDevicesAcquireFinished(
+            TString diskId,
+            TString clientId,
+            TVector<TAgentAcquireDevicesCachedRequest> sentRequests,
+            TVector<NProto::TDeviceConfig> devices,
+            NProto::TError error)
+        : DiskId(std::move(diskId))
+        , ClientId(std::move(clientId))
+        , SentRequests(std::move(sentRequests))
+        , Devices(std::move(devices))
+        , Error(std::move(error))
+    {}
+};
+
+struct TDevicesReleaseFinished
+{
+    TString DiskId;
+    TString ClientId;
+    TVector<TAgentReleaseDevicesCachedRequest> SentRequests;
+    NProto::TError Error;
+
+    TDevicesReleaseFinished(
+            TString diskId,
+            TString clientId,
+            TVector<TAgentReleaseDevicesCachedRequest> sentRequests,
+            NProto::TError error)
+        : DiskId(std::move(diskId))
+        , ClientId(std::move(clientId))
+        , SentRequests(std::move(sentRequests))
+        , Error(std::move(error))
+    {}
+};
+
+enum EEvents
+{
+    EvBegin,
+
+    EvDevicesAcquireFinished,
+    EvDevicesReleaseFinished,
+
+    EvEnd
+};
+
+using TEvDevicesAcquireFinished =
+    TRequestEvent<TDevicesAcquireFinished, EvDevicesAcquireFinished>;
+
+using TEvDevicesReleaseFinished =
+    TRequestEvent<TDevicesReleaseFinished, EvDevicesReleaseFinished>;
+
+TActorId CreateAcquireDevicesActor(
+    const NActors::TActorContext& ctx,
+    const TActorId& owner,
+    TVector<NProto::TDeviceConfig> devices,
+    TString diskId,
+    TString clientId,
+    NProto::EVolumeAccessMode accessMode,
+    ui64 mountSeqNumber,
+    ui32 volumeGeneration,
+    TDuration requestTimeout,
+    bool muteIOErrors,
+    NActors::NLog::EComponent component);
+
+TActorId CreateReleaseDevicesActor(
+    const NActors::TActorContext& ctx,
+    const TActorId& owner,
+    TString diskId,
+    TString clientId,
+    ui32 volumeGeneration,
+    TDuration requestTimeout,
+    TVector<NProto::TDeviceConfig> devices,
+    bool muteIOErrors,
+    NActors::NLog::EComponent component);
+
+}   // namespace NCloud::NBlockStore::NStorage::NAcquireReleaseDevices

cloud/blockstore/libs/storage/core/proto_helpers.cpp

@@ -444,4 +444,15 @@ ui64 GetVolumeRequestId(const TEvDiskAgent::TEvZeroDeviceBlocksRequest& request)
     return request.Record.GetVolumeRequestId();
 }
 
+TString LogDevices(const TVector<NProto::TDeviceConfig>& devices)
+{
+    TStringBuilder sb;
+    sb << "( ";
+    for (const auto& d: devices) {
+        sb << d.GetDeviceUUID() << "@" << d.GetAgentId() << " ";
+    }
+    sb << ")";
+    return sb;
+}
+
 }   // namespace NCloud::NBlockStore::NStorage

cloud/blockstore/libs/storage/core/proto_helpers.h

@@ -223,4 +223,5 @@ TBlockRange64 BuildRequestBlockRange(
 ui64 GetVolumeRequestId(const TEvDiskAgent::TEvWriteDeviceBlocksRequest& request);
 ui64 GetVolumeRequestId(const TEvDiskAgent::TEvZeroDeviceBlocksRequest& request);
 
+TString LogDevices(const TVector<NProto::TDeviceConfig>& devices);
 }   // namespace NCloud::NBlockStore::NStorage