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

1 files changed, 21 insertions, 21 deletions

diff --git a/util/thread/pool.cpp b/util/thread/pool.cpp
index 05fad02e9b..e8420eb3c8 100644
--- a/util/thread/pool.cpp
+++ b/util/thread/pool.cpp
@@ -67,7 +67,7 @@ TThreadFactoryHolder::TThreadFactoryHolder() noexcept
 
 class TThreadPool::TImpl: public TIntrusiveListItem<TImpl>, public IThreadFactory::IThreadAble {
     using TTsr = IThreadPool::TTsr;
-    using TJobQueue = TFastQueue<IObjectInQueue*>;
+    using TJobQueue = TFastQueue<IObjectInQueue*>; 
     using TThreadRef = THolder<IThreadFactory::IThread>;
 
 public:
@@ -643,20 +643,20 @@ size_t TSimpleThreadPool::Size() const noexcept {
 
 namespace {
     class TOwnedObjectInQueue: public IObjectInQueue {
-    private:
-        THolder<IObjectInQueue> Owned;
-
-    public:
+    private: 
+        THolder<IObjectInQueue> Owned; 
+ 
+    public: 
         TOwnedObjectInQueue(THolder<IObjectInQueue> owned)
             : Owned(std::move(owned))
-        {
-        }
-
+        { 
+        } 
+ 
         void Process(void* data) override {
-            THolder<TOwnedObjectInQueue> self(this);
-            Owned->Process(data);
-        }
-    };
+            THolder<TOwnedObjectInQueue> self(this); 
+            Owned->Process(data); 
+        } 
+    }; 
 }
 
 void IThreadPool::SafeAdd(IObjectInQueue* obj) {
@@ -665,17 +665,17 @@ void IThreadPool::SafeAdd(IObjectInQueue* obj) {
 
 void IThreadPool::SafeAddAndOwn(THolder<IObjectInQueue> obj) {
     Y_ENSURE_EX(AddAndOwn(std::move(obj)), TThreadPoolException() << TStringBuf("can not add to queue and own"));
-}
-
+} 
+ 
 bool IThreadPool::AddAndOwn(THolder<IObjectInQueue> obj) {
     auto owner = MakeHolder<TOwnedObjectInQueue>(std::move(obj));
-    bool added = Add(owner.Get());
-    if (added) {
+    bool added = Add(owner.Get()); 
+    if (added) { 
         Y_UNUSED(owner.Release());
-    }
-    return added;
-}
-
+    } 
+    return added; 
+} 
+ 
 using IThread = IThreadFactory::IThread;
 using IThreadAble = IThreadFactory::IThreadAble;
 
@@ -721,7 +721,7 @@ namespace {
             TSystemEvent StartEvent_;
         };
 
-        using TThreadImplRef = TIntrusivePtr<TThreadImpl>;
+        using TThreadImplRef = TIntrusivePtr<TThreadImpl>; 
 
     public:
         inline TPoolThread(IThreadPool* parent)