Merge c6028fd into 9d0310a

Author: serbel324

.github/config/muted_ya.txt

@@ -4,7 +4,6 @@ ydb/core/client/ut TClientTest.PromoteFollower
 ydb/core/client/ut TClientTest.ReadFromFollower
 ydb/core/client/ut TFlatTest.AutoSplitMergeQueue
 ydb/core/cms/ut_sentinel TSentinelTests.BSControllerCantChangeStatus
-ydb/core/debug_tools/ut OperationLog.ConcurrentWrites
 ydb/core/quoter/ut QuoterWithKesusTest.PrefetchCoefficient
 ydb/core/kafka_proxy/ut KafkaProtocol.CreatePartitionsScenario
 ydb/core/kafka_proxy/ut KafkaProtocol.ProduceScenario

ydb/core/debug_tools/operation_log.h

@@ -27,14 +27,15 @@ class TOperationLog {
 private:
     constexpr static ui32 Capacity = S;
     std::array<std::atomic<TString*>, S> Records;
-    // RecordIdx is shifted to prevent underflow on decrement
+    // RecordPosition is shifted to prevent underflow on decrement
     std::atomic<ui64> NextRecordPosition = Capacity;
 
 public:
-    TOperationLog() = default;
-
-    TOperationLog(const TOperationLog& other) = delete;
-    TOperationLog& operator=(const TOperationLog& other) = delete;
+    TOperationLog(bool initializeRecords = true, TString defaultValue = "Race occured, try again") {
+        if (initializeRecords) {
+            InitializeRecords(defaultValue);
+        }
+    };
 
     TOperationLog(TOperationLog&& other) = default;
     TOperationLog& operator=(TOperationLog&& other) = default;
@@ -45,6 +46,12 @@ class TOperationLog {
         }
     }
 
+    bool InitializeRecords(TString value = "Race occured, try again") {
+        for (auto& record : Records) {
+            record.store(new TString(value))
+        }
+    }
+
     BorrowedRecord BorrowByIdx(ui32 idx) {
         ui32 position = (NextRecordPosition.load() - 1 - idx) % Capacity;
         if (idx >= Size()) {