Restoring authorship annotation for Vasily Ershov <vasilij.ershov@gmail.com>. Commit 2 of 2.

1 files changed, 16 insertions, 16 deletions

diff --git a/library/cpp/threading/local_executor/local_executor.h b/library/cpp/threading/local_executor/local_executor.h
index 8376a3cc95..c1c824f67c 100644
--- a/library/cpp/threading/local_executor/local_executor.h
+++ b/library/cpp/threading/local_executor/local_executor.h
@@ -149,8 +149,8 @@ namespace NPar {
         template <typename TBody>
         inline void ExecRange(TBody&& body, TExecRangeParams params, int flags) {
             if (TryExecRangeSequentially(body, params.FirstId, params.LastId, flags)) {
-                return; 
-            } 
+                return;
+            }
             if (params.GetBlockEqualToThreads()) {
                 params.SetBlockCount(GetThreadCount() + ((flags & WAIT_COMPLETE) != 0)); // ThreadCount or ThreadCount+1 depending on WaitFlag
             }
@@ -272,23 +272,23 @@ namespace NPar {
     static inline TLocalExecutor& LocalExecutor() {
         return *Singleton<TLocalExecutor>();
     }
- 
-    template <typename TBody> 
+
+    template <typename TBody>
     inline void ParallelFor(ILocalExecutor& executor, ui32 from, ui32 to, TBody&& body) {
         ILocalExecutor::TExecRangeParams params(from, to);
-        params.SetBlockCountToThreadCount(); 
+        params.SetBlockCountToThreadCount();
         executor.ExecRange(std::forward<TBody>(body), params, TLocalExecutor::WAIT_COMPLETE);
-    } 
- 
-    template <typename TBody> 
-    inline void ParallelFor(ui32 from, ui32 to, TBody&& body) { 
-        ParallelFor(LocalExecutor(), from, to, std::forward<TBody>(body)); 
-    } 
- 
-    template <typename TBody> 
-    inline void AsyncParallelFor(ui32 from, ui32 to, TBody&& body) { 
+    }
+
+    template <typename TBody>
+    inline void ParallelFor(ui32 from, ui32 to, TBody&& body) {
+        ParallelFor(LocalExecutor(), from, to, std::forward<TBody>(body));
+    }
+
+    template <typename TBody>
+    inline void AsyncParallelFor(ui32 from, ui32 to, TBody&& body) {
         ILocalExecutor::TExecRangeParams params(from, to);
-        params.SetBlockCountToThreadCount(); 
+        params.SetBlockCountToThreadCount();
         LocalExecutor().ExecRange(std::forward<TBody>(body), params, 0);
-    } 
+    }
 }