Restoring authorship annotation for Dmitry Baksheev <[email protected]>. Commit 1 of 2.

1 files changed, 45 insertions, 45 deletions

diff --git a/library/cpp/threading/local_executor/ut/local_executor_ut.cpp b/library/cpp/threading/local_executor/ut/local_executor_ut.cpp
index ac5737717cd..a169edc2ec9 100644
--- a/library/cpp/threading/local_executor/ut/local_executor_ut.cpp
+++ b/library/cpp/threading/local_executor/ut/local_executor_ut.cpp
@@ -324,48 +324,48 @@ Y_UNIT_TEST(NestedParallelExceptionsDoNotLeak) {
 }
 }
 ;
-
-Y_UNIT_TEST_SUITE(ExecLargeRangeWithThrow){
-
-    constexpr int LARGE_COUNT = 128 * (1 << 20);
-
-    static auto IsValue(char v) {
-        return [=](char c) { return c == v; };
-    }
-
-    Y_UNIT_TEST(ExecLargeRangeNoExceptions) {
-        TVector<char> tasks(LARGE_COUNT);
-
-        TLocalExecutor localExecutor;
-        localExecutor.RunAdditionalThreads(DefaultThreadsCount);
-
-        localExecutor.ExecRangeBlockedWithThrow([&tasks](int i) {
-            tasks[i] = 1;
-        }, 0, tasks.size(), 0, TLocalExecutor::EFlags::WAIT_COMPLETE);
-        UNIT_ASSERT(AllOf(tasks, IsValue(1)));
-
-
-        localExecutor.ExecRangeBlockedWithThrow([&tasks](int i) {
-            tasks[i] += 1;
-        }, 0, tasks.size(), 128, TLocalExecutor::EFlags::WAIT_COMPLETE);
-        UNIT_ASSERT(AllOf(tasks, IsValue(2)));
-    }
-
-    Y_UNIT_TEST(ExecLargeRangeWithException) {
-        TVector<char> tasks(LARGE_COUNT);
-
-        TLocalExecutor localExecutor;
-        localExecutor.RunAdditionalThreads(DefaultThreadsCount);
-
-        Fill(tasks.begin(), tasks.end(), 0);
-        UNIT_ASSERT_EXCEPTION(
-            localExecutor.ExecRangeBlockedWithThrow([&tasks](int i) {
-                tasks[i] += 1;
-                if (i == LARGE_COUNT / 2) {
-                    throw TTestException();
-                }
-            }, 0, tasks.size(), 0, TLocalExecutor::EFlags::WAIT_COMPLETE),
-            TTestException
-        );
-    }
-};
+ 
+Y_UNIT_TEST_SUITE(ExecLargeRangeWithThrow){ 
+ 
+    constexpr int LARGE_COUNT = 128 * (1 << 20); 
+ 
+    static auto IsValue(char v) { 
+        return [=](char c) { return c == v; }; 
+    } 
+ 
+    Y_UNIT_TEST(ExecLargeRangeNoExceptions) { 
+        TVector<char> tasks(LARGE_COUNT); 
+ 
+        TLocalExecutor localExecutor; 
+        localExecutor.RunAdditionalThreads(DefaultThreadsCount); 
+ 
+        localExecutor.ExecRangeBlockedWithThrow([&tasks](int i) { 
+            tasks[i] = 1; 
+        }, 0, tasks.size(), 0, TLocalExecutor::EFlags::WAIT_COMPLETE); 
+        UNIT_ASSERT(AllOf(tasks, IsValue(1))); 
+ 
+ 
+        localExecutor.ExecRangeBlockedWithThrow([&tasks](int i) { 
+            tasks[i] += 1; 
+        }, 0, tasks.size(), 128, TLocalExecutor::EFlags::WAIT_COMPLETE); 
+        UNIT_ASSERT(AllOf(tasks, IsValue(2))); 
+    } 
+ 
+    Y_UNIT_TEST(ExecLargeRangeWithException) { 
+        TVector<char> tasks(LARGE_COUNT); 
+ 
+        TLocalExecutor localExecutor; 
+        localExecutor.RunAdditionalThreads(DefaultThreadsCount); 
+ 
+        Fill(tasks.begin(), tasks.end(), 0); 
+        UNIT_ASSERT_EXCEPTION( 
+            localExecutor.ExecRangeBlockedWithThrow([&tasks](int i) { 
+                tasks[i] += 1; 
+                if (i == LARGE_COUNT / 2) { 
+                    throw TTestException(); 
+                } 
+            }, 0, tasks.size(), 0, TLocalExecutor::EFlags::WAIT_COMPLETE), 
+            TTestException 
+        ); 
+    } 
+};