Restoring authorship annotation for <nga@yandex-team.ru>. Commit 2 of 2.

1 files changed, 123 insertions, 123 deletions

diff --git a/library/cpp/messagebus/rain_check/core/task.h b/library/cpp/messagebus/rain_check/core/task.h
index b84e62a1eb..7d8778bcda 100644
--- a/library/cpp/messagebus/rain_check/core/task.h
+++ b/library/cpp/messagebus/rain_check/core/task.h
@@ -1,5 +1,5 @@
-#pragma once 
- 
+#pragma once
+
 #include "fwd.h"
 
 #include <library/cpp/messagebus/actor/actor.h>
@@ -7,55 +7,55 @@
 
 #include <library/cpp/deprecated/enum_codegen/enum_codegen.h>
 
-#include <util/generic/noncopyable.h> 
-#include <util/generic/ptr.h> 
-#include <util/thread/lfstack.h> 
- 
-namespace NRainCheck { 
-    struct ISubtaskListener { 
-        virtual void SetDone() = 0; 
+#include <util/generic/noncopyable.h>
+#include <util/generic/ptr.h>
+#include <util/thread/lfstack.h>
+
+namespace NRainCheck {
+    struct ISubtaskListener {
+        virtual void SetDone() = 0;
         virtual ~ISubtaskListener() {
         }
-    }; 
- 
-    struct TNopSubtaskListener: public ISubtaskListener { 
+    };
+
+    struct TNopSubtaskListener: public ISubtaskListener {
         void SetDone() override;
- 
-        static TNopSubtaskListener Instance; 
-    }; 
- 
-    class TSubtaskCompletionFunc { 
-        friend class TSubtaskCompletion; 
- 
-        typedef void (ITaskBase::*TFunc)(TSubtaskCompletion*); 
-        TFunc Func; 
- 
-    public: 
-        TSubtaskCompletionFunc() 
+
+        static TNopSubtaskListener Instance;
+    };
+
+    class TSubtaskCompletionFunc {
+        friend class TSubtaskCompletion;
+
+        typedef void (ITaskBase::*TFunc)(TSubtaskCompletion*);
+        TFunc Func;
+
+    public:
+        TSubtaskCompletionFunc()
             : Func(nullptr)
         {
         }
- 
-        TSubtaskCompletionFunc(void*) 
+
+        TSubtaskCompletionFunc(void*)
             : Func(nullptr)
         {
         }
- 
-        template <typename TTask> 
-        TSubtaskCompletionFunc(void (TTask::*func)(TSubtaskCompletion*)) 
+
+        template <typename TTask>
+        TSubtaskCompletionFunc(void (TTask::*func)(TSubtaskCompletion*))
             : Func((TFunc)func)
-        { 
+        {
             static_assert((std::is_base_of<ITaskBase, TTask>::value), "expect (std::is_base_of<ITaskBase, TTask>::value)");
-        } 
- 
-        bool operator!() const { 
-            return !Func; 
-        } 
-    }; 
- 
-    template <typename T> 
-    class TTaskFuture; 
- 
+        }
+
+        bool operator!() const {
+            return !Func;
+        }
+    };
+
+    template <typename T>
+    class TTaskFuture;
+
 #define SUBTASK_STATE_MAP(XX)                                     \
     XX(CREATED, "Initial")                                        \
     XX(RUNNING, "Running")                                        \
@@ -63,33 +63,33 @@ namespace NRainCheck {
     XX(CANCEL_REQUESTED, "Cancel requested, but still executing") \
     XX(CANCELED, "Canceled")                                      \
     /**/
- 
-    enum ESubtaskState { 
-        SUBTASK_STATE_MAP(ENUM_VALUE_GEN_NO_VALUE) 
-    }; 
- 
-    ENUM_TO_STRING(ESubtaskState, SUBTASK_STATE_MAP) 
- 
+
+    enum ESubtaskState {
+        SUBTASK_STATE_MAP(ENUM_VALUE_GEN_NO_VALUE)
+    };
+
+    ENUM_TO_STRING(ESubtaskState, SUBTASK_STATE_MAP)
+
     class TSubtaskCompletion : TNonCopyable, public ISubtaskListener {
-        friend struct TTaskAccessor; 
+        friend struct TTaskAccessor;
 
-    private: 
-        TAtomicBox<ESubtaskState> State; 
-        TTaskRunnerBase* volatile TaskRunner; 
-        TSubtaskCompletionFunc CompletionFunc; 
+    private:
+        TAtomicBox<ESubtaskState> State;
+        TTaskRunnerBase* volatile TaskRunner;
+        TSubtaskCompletionFunc CompletionFunc;
 
-    public: 
+    public:
         TSubtaskCompletion()
             : State(CREATED)
             , TaskRunner()
         {
         }
         ~TSubtaskCompletion() override;
- 
-        // Either done or cancel requested or cancelled 
-        bool IsComplete() const { 
-            ESubtaskState state = State.Get(); 
-            switch (state) { 
+
+        // Either done or cancel requested or cancelled
+        bool IsComplete() const {
+            ESubtaskState state = State.Get();
+            switch (state) {
                 case RUNNING:
                     return false;
                 case DONE:
@@ -102,82 +102,82 @@ namespace NRainCheck {
                     Y_FAIL("not started");
                 default:
                     Y_FAIL("unknown value: %u", (unsigned)state);
-            } 
-        } 
- 
-        void FireCompletionCallback(ITaskBase*); 
- 
-        void SetCompletionCallback(TSubtaskCompletionFunc func) { 
-            CompletionFunc = func; 
-        } 
- 
-        // Completed, but not cancelled 
-        bool IsDone() const { 
-            return State.Get() == DONE; 
-        } 
- 
-        // Request cancel by actor 
-        // Does nothing but marks task cancelled, 
-        // and allows proceeding to next callback 
-        void Cancel(); 
- 
-        // called by service provider implementations 
-        // must not be called by actor 
-        void SetRunning(TTaskRunnerBase* parent); 
+            }
+        }
+
+        void FireCompletionCallback(ITaskBase*);
+
+        void SetCompletionCallback(TSubtaskCompletionFunc func) {
+            CompletionFunc = func;
+        }
+
+        // Completed, but not cancelled
+        bool IsDone() const {
+            return State.Get() == DONE;
+        }
+
+        // Request cancel by actor
+        // Does nothing but marks task cancelled,
+        // and allows proceeding to next callback
+        void Cancel();
+
+        // called by service provider implementations
+        // must not be called by actor
+        void SetRunning(TTaskRunnerBase* parent);
         void SetDone() override;
-    }; 
- 
-    // See ISimpleTask, ICoroTask 
+    };
+
+    // See ISimpleTask, ICoroTask
     class TTaskRunnerBase: public TAtomicRefCount<TTaskRunnerBase>, public NActor::TActor<TTaskRunnerBase> {
-        friend class NActor::TActor<TTaskRunnerBase>; 
-        friend class TContinueFunc; 
-        friend struct TTaskAccessor; 
-        friend class TSubtaskCompletion; 
- 
-    private: 
-        THolder<ITaskBase> Impl; 
- 
-        ISubtaskListener* const ParentTask; 
-        // While task is running, it holds extra reference to self. 
-        //bool HoldsSelfReference; 
-        bool Done; 
-        bool SetDoneCalled; 
- 
-        // Subtasks currently executed. 
+        friend class NActor::TActor<TTaskRunnerBase>;
+        friend class TContinueFunc;
+        friend struct TTaskAccessor;
+        friend class TSubtaskCompletion;
+
+    private:
+        THolder<ITaskBase> Impl;
+
+        ISubtaskListener* const ParentTask;
+        // While task is running, it holds extra reference to self.
+        //bool HoldsSelfReference;
+        bool Done;
+        bool SetDoneCalled;
+
+        // Subtasks currently executed.
         TVector<TSubtaskCompletion*> Pending;
- 
-        void Act(NActor::TDefaultTag); 
- 
-    public: 
-        // Construct task. Task is not automatically started. 
-        TTaskRunnerBase(IEnv*, ISubtaskListener* parent, TAutoPtr<ITaskBase> impl); 
+
+        void Act(NActor::TDefaultTag);
+
+    public:
+        // Construct task. Task is not automatically started.
+        TTaskRunnerBase(IEnv*, ISubtaskListener* parent, TAutoPtr<ITaskBase> impl);
         ~TTaskRunnerBase() override;
- 
-        bool IsRunningInThisThread() const; 
-        void AssertInThisThread() const; 
-        static TTaskRunnerBase* CurrentTask(); 
+
+        bool IsRunningInThisThread() const;
+        void AssertInThisThread() const;
+        static TTaskRunnerBase* CurrentTask();
         static ITaskBase* CurrentTaskImpl();
- 
+
         TString GetStatusSingleLine();
- 
-    protected: 
-        //void RetainRef(); 
-        //void ReleaseRef(); 
+
+    protected:
+        //void RetainRef();
+        //void ReleaseRef();
         ITaskBase* GetImplBase() {
             return Impl.Get();
         }
- 
-    private: 
-        // true if need to call again 
-        virtual bool ReplyReceived() = 0; 
-    }; 
- 
-    class ITaskBase { 
-    public: 
+
+    private:
+        // true if need to call again
+        virtual bool ReplyReceived() = 0;
+    };
+
+    class ITaskBase {
+    public:
         virtual ~ITaskBase() {
         }
-    }; 
- 
+    };
+
     // Check that current method executed inside some task.
     bool AreWeInsideTask();