Restoring authorship annotation for Dmitry Baksheev <[email protected]>. Commit 2 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 a169edc2ec9..ac5737717cd 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
+        );
+    }
+};