Fix put deadlines

Author: serbel324

ydb/core/blobstorage/dsproxy/dsproxy_put.cpp

@@ -42,7 +42,7 @@ class TBlobStorageGroupPutRequest : public TBlobStorageGroupRequestActor {
     TErasureSplitContext ErasureSplitContext = TErasureSplitContext::Init(MaxBytesToSplitAtOnce);
     TBatchedVec<TStackVec<TRope, TypicalPartsInBlob>> PartSets;
 
-    std::set<TInstant> PutDeadlines;
+    std::set<TMonotonic> PutDeadlines;
     TStackVec<ui64, TypicalDisksInGroup> WaitingVDiskResponseCount;
     ui64 WaitingVDiskCount = 0;
 
@@ -796,15 +796,17 @@ class TBlobStorageGroupPutRequest : public TBlobStorageGroupRequestActor {
             << " State# " << PutImpl.DumpFullState());
     }
 
-    void ScheduleWakeup() {
-        TInstant deadline = TActivationContext::Now() + TDuration::MilliSeconds(DsPutWakeupMs);
-    
-        auto it = PutDeadlines.begin();
-        if (it != PutDeadlines.end() && *it <= deadline) {
-            deadline = *it;
-            PutDeadlines.erase(it);
+    void ScheduleWakeups() {
+        TMonotonic now = TActivationContext::Monotonic();
+        while (!PutDeadlines.empty()) {
+            TMonotonic deadline = *PutDeadlines.begin();
+            PutDeadlines.erase(PutDeadlines.begin());
+            if (deadline > now) {
+                Schedule(deadline, new TKikimrEvents::TEvWakeup);
+                return;
+            }
         }
-        Schedule(deadline, new TKikimrEvents::TEvWakeup);
+        Schedule(TDuration::MilliSeconds(DsPutWakeupMs), new TKikimrEvents::TEvWakeup);
     }
 
     STATEFN(StateWait) {