disable vpatch

Author: kruall

ydb/core/blobstorage/dsproxy/dsproxy_patch.cpp

@@ -591,7 +591,7 @@ class TBlobStorageGroupPatchRequest : public TBlobStorageGroupRequestActor {
     void StartMovedPatch() {
         PATCH_LOG(PRI_DEBUG, BS_PROXY_PATCH, BPPA09, "Start Moved strategy",
                 (SentStarts, SentStarts));
-        ScheduleWakeUp(StartTime, MovedPatchTag);
+        // ScheduleWakeUp(StartTime, MovedPatchTag);
         Become(&TBlobStorageGroupPatchRequest::MovedPatchState);
         IsMovedPatch = true;
         ui32 subgroupIdx = 0;
@@ -600,6 +600,14 @@ class TBlobStorageGroupPatchRequest : public TBlobStorageGroupRequestActor {
             ui32 okVDiskIdx = RandomNumber<ui32>(OkVDisksWithParts.size());
             subgroupIdx = OkVDisksWithParts[okVDiskIdx];
         } else {
+            ui64 worstNs = 0;
+            ui64 nextToWorstNs = 0;
+            i32 worstSubGroubIdx = -1;
+            GetWorstPredictedDelaysNs(NKikimrBlobStorage::EVDiskQueueId::PutAsyncBlob, &worstNs, &nextToWorstNs, &worstSubGroubIdx);
+            if (worstNs > nextToWorstNs * 2) {
+                SlowFlags[worstSubGroubIdx] = true;
+                HasSlowVDisk = true;
+            }
             if (HasSlowVDisk) {
                 TStackVec<ui32, TypicalDisksInSubring> goodDisks;
                 for (ui32 idx = 0; idx < VDisks.size(); ++idx) {
@@ -659,13 +667,21 @@ class TBlobStorageGroupPatchRequest : public TBlobStorageGroupRequestActor {
     void StartVPatch() {
         StageStart = TActivationContext::Now();
         Become(&TBlobStorageGroupPatchRequest::VPatchState);
-        Info->PickSubgroup(OriginalId.Hash(), &VDisks, nullptr);
         ReceivedResponseFlags.assign(VDisks.size(), false);
         ErrorResponseFlags.assign(VDisks.size(), false);
         EmptyResponseFlags.assign(VDisks.size(), false);
         ForceStopFlags.assign(VDisks.size(), false);
         SlowFlags.assign(VDisks.size(), false);
 
+        ui64 worstNs = 0;
+        ui64 nextToWorstNs = 0;
+        i32 worstSubGroubIdx = -1;
+        GetWorstPredictedDelaysNs(NKikimrBlobStorage::EVDiskQueueId::GetFastRead, &worstNs, &nextToWorstNs, &worstSubGroubIdx);
+        if (worstNs > nextToWorstNs * 2) {
+            SlowFlags[worstSubGroubIdx] = true;
+            HasSlowVDisk = true;
+        }
+
         TDeque<std::unique_ptr<TEvBlobStorage::TEvVPatchStart>> events;
         for (ui32 idx = 0; idx < VDisks.size(); ++idx) {
             if (!SlowFlags[idx]) {
@@ -780,6 +796,15 @@ class TBlobStorageGroupPatchRequest : public TBlobStorageGroupRequestActor {
         StageStart = TActivationContext::Now();
         IsContinuedVPatch = true;
 
+        ui64 worstNs = 0;
+        ui64 nextToWorstNs = 0;
+        i32 worstSubGroubIdx = -1;
+        GetWorstPredictedDelaysNs(NKikimrBlobStorage::EVDiskQueueId::GetFastRead, &worstNs, &nextToWorstNs, &worstSubGroubIdx);
+        if (worstNs > nextToWorstNs * 2) {
+            SlowFlags[worstSubGroubIdx] = true;
+            HasSlowVDisk = true;
+        }
+
         if (Info->Type.GetErasure() == TErasureType::ErasureMirror3dc) {
             return ContinueVPatchForMirror3dc();
         }
@@ -894,7 +919,7 @@ class TBlobStorageGroupPatchRequest : public TBlobStorageGroupRequestActor {
         IsAllowedErasure = Info->Type.ErasureFamily() == TErasureType::ErasureParityBlock
                 || Info->Type.GetErasure() == TErasureType::ErasureNone
                 || Info->Type.GetErasure() == TErasureType::ErasureMirror3dc;
-        if (IsGoodPatchedBlobId && IsAllowedErasure && UseVPatch && OriginalGroupId == Info->GroupID && !IsSecured) {
+        if (false && IsGoodPatchedBlobId && IsAllowedErasure && UseVPatch && OriginalGroupId == Info->GroupID && !IsSecured) {
             PATCH_LOG(PRI_DEBUG, BS_PROXY_PATCH, BPPA03, "Start VPatch strategy from bootstrap");
             StartVPatch();
         } else {
@@ -908,6 +933,24 @@ class TBlobStorageGroupPatchRequest : public TBlobStorageGroupRequestActor {
         }
     }
 
+    void GetWorstPredictedDelaysNs(NKikimrBlobStorage::EVDiskQueueId queueId,
+            ui64 *outWorstNs, ui64 *outNextToWorstNs, i32 *outWorstSubgroupIdx) const
+    {
+        *outWorstSubgroupIdx = -1;
+        *outWorstNs = 0;
+        *outNextToWorstNs = 0;
+        for (ui32 diskIdx = 0; diskIdx < VDisks.size(); ++diskIdx) {
+            ui64 predictedNs = GroupQueues->GetPredictedDelayNsByOrderNumber(diskIdx, queueId);;
+            if (predictedNs > *outWorstNs) {
+                *outNextToWorstNs = *outWorstNs;
+                *outWorstNs = predictedNs;
+                *outWorstSubgroupIdx = diskIdx;
+            } else if (predictedNs > *outNextToWorstNs) {
+                *outNextToWorstNs = predictedNs;
+            }
+        }
+    }
+
     void SetSlowDisks() {
         for (ui32 idx = 0; idx < SlowFlags.size(); ++idx) {
             SlowFlags[idx] = !ReceivedResponseFlags[idx] && !EmptyResponseFlags[idx] && !ErrorResponseFlags[idx];