WIP TESTS

cloud/blockstore/libs/storage/volume/ut/ya.make

@@ -4,6 +4,7 @@ INCLUDE(${ARCADIA_ROOT}/cloud/storage/core/tests/recipes/medium.inc)
 
 SRCS(
     volume_database_ut.cpp
+    volume_lagging_agent_ut.cpp
     volume_state_ut.cpp
     volume_ut.cpp
     volume_ut_checkpoint.cpp

cloud/blockstore/libs/storage/volume/volume_lagging_agent_ut.cpp

@@ -0,0 +1,34 @@
+#include <cloud/blockstore/libs/storage/volume/testlib/test_env.h>
+#include <cloud/blockstore/libs/storage/api/volume_proxy.h>
+#include <cloud/blockstore/libs/storage/partition_common/events_private.h>
+#include <cloud/blockstore/libs/storage/partition_nonrepl/model/processing_blocks.h>
+#include <cloud/blockstore/libs/storage/stats_service/stats_service_events_private.h>
+
+#include <util/system/hostname.h>
+
+namespace NCloud::NBlockStore::NStorage {
+
+using namespace NActors;
+
+using namespace NKikimr;
+
+using namespace NCloud::NBlockStore::NStorage::NPartition;
+
+using namespace NCloud::NStorage;
+
+using namespace NTestVolume;
+
+
+////////////////////////////////////////////////////////////////////////////////
+
+Y_UNIT_TEST_SUITE(TLaggingAgentVolumeTest) {
+    Y_UNIT_TEST(ShouldUpdateVolumeConfig)
+    {
+        auto runtime = PrepareTestActorRuntime();
+
+        TVolumeClient volume(*runtime);
+        volume.UpdateVolumeConfig();
+    }
+}
+
+}   // namespace NCloud::NBlockStore::NStorage

cloud/blockstore/libs/storage/volume/volume_state.cpp

@@ -195,6 +195,28 @@ TRuntimeVolumeParams& TVolumeState::GetVolumeParams()
     return VolumeParams;
 }
 
+void TVolumeState::AddLaggingAgent(NProto::TLaggingAgent agent)
+{
+    Meta.MutableLaggingAgentsInfo()->MutableAgents()->Add(std::move(agent));
+}
+
+void TVolumeState::RemoveLaggingAgent(const TString& agentId)
+{
+    const auto& laggingAgents = Meta.GetLaggingAgentsInfo().GetAgents();
+    auto it = FindIf(
+        laggingAgents,
+        [&agentId](const auto& agent)
+        { return agent.GetAgentId() == agentId; });
+    if (it != laggingAgents.end()) {
+        Meta.MutableLaggingAgentsInfo()->MutableAgents()->erase(it);
+    }
+}
+
+void TVolumeState::SetNeedToSyncFreshDevicesWithDR(bool value)
+{
+    Meta.MutableLaggingAgentsInfo()->SetNeedToSyncFreshDevicesWithDR(value);
+}
+
 void TVolumeState::ResetMeta(NProto::TVolumeMeta meta)
 {
     Meta = std::move(meta);

cloud/blockstore/libs/storage/volume/volume_state.h

@@ -305,26 +305,9 @@ class TVolumeState
         Meta.SetFillSeqNumber(fillSeqNumber);
     }
 
-    void AddLaggingAgent(NProto::TLaggingAgent agent)
-    {
-        Meta.MutableLaggingAgentsInfo()->MutableAgents()->Add(std::move(agent));
-    }
-
-    void RemoveLaggingAgent(const TString& agentId)
-    {
-        const auto& laggingAgents = Meta.GetLaggingAgentsInfo().GetAgents();
-        auto it = FindIf(
-            laggingAgents,
-            [&agentId](const auto& agent)
-            { return agent.GetAgentId() == agentId; });
-        if (it != laggingAgents.end()) {
-            Meta.MutableLaggingAgentsInfo()->MutableAgents()->erase(it);
-        }
-    }
-
-    void SetNeedToSyncFreshDevicesWithDR(bool value) {
-        Meta.MutableLaggingAgentsInfo()->SetNeedToSyncFreshDevicesWithDR(value);
-    }
+    void AddLaggingAgent(NProto::TLaggingAgent agent);
+    void RemoveLaggingAgent(const TString& agentId);
+    void SetNeedToSyncFreshDevicesWithDR(bool value);
 
     void SetStartPartitionsNeeded(bool startPartitionsNeeded)
     {