Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 1 of 2.

1 files changed, 25 insertions, 25 deletions

diff --git a/library/cpp/actors/interconnect/poller_tcp.cpp b/library/cpp/actors/interconnect/poller_tcp.cpp
index 8267df31ea..456bca8b98 100644
--- a/library/cpp/actors/interconnect/poller_tcp.cpp
+++ b/library/cpp/actors/interconnect/poller_tcp.cpp
@@ -1,35 +1,35 @@
 #include "poller_tcp.h"
 
 namespace NInterconnect {
-    TPollerThreads::TPollerThreads(size_t units, bool useSelect)
-        : Units(units)
-    {
-        Y_VERIFY_DEBUG(!Units.empty());
-        for (auto& unit : Units)
-            unit = TPollerUnit::Make(useSelect);
-    }
+    TPollerThreads::TPollerThreads(size_t units, bool useSelect) 
+        : Units(units) 
+    { 
+        Y_VERIFY_DEBUG(!Units.empty()); 
+        for (auto& unit : Units) 
+            unit = TPollerUnit::Make(useSelect); 
+    } 
 
-    TPollerThreads::~TPollerThreads() {
-    }
+    TPollerThreads::~TPollerThreads() { 
+    } 
 
-    void TPollerThreads::Start() {
-        for (const auto& unit : Units)
-            unit->Start();
-    }
+    void TPollerThreads::Start() { 
+        for (const auto& unit : Units) 
+            unit->Start(); 
+    } 
 
-    void TPollerThreads::Stop() {
-        for (const auto& unit : Units)
-            unit->Stop();
-    }
+    void TPollerThreads::Stop() { 
+        for (const auto& unit : Units) 
+            unit->Stop(); 
+    } 
 
-    void TPollerThreads::StartRead(const TIntrusivePtr<TSharedDescriptor>& s, TFDDelegate&& operation) {
-        auto& unit = Units[THash<SOCKET>()(s->GetDescriptor()) % Units.size()];
-        unit->StartReadOperation(s, std::move(operation));
-    }
+    void TPollerThreads::StartRead(const TIntrusivePtr<TSharedDescriptor>& s, TFDDelegate&& operation) { 
+        auto& unit = Units[THash<SOCKET>()(s->GetDescriptor()) % Units.size()]; 
+        unit->StartReadOperation(s, std::move(operation)); 
+    } 
 
-    void TPollerThreads::StartWrite(const TIntrusivePtr<TSharedDescriptor>& s, TFDDelegate&& operation) {
-        auto& unit = Units[THash<SOCKET>()(s->GetDescriptor()) % Units.size()];
-        unit->StartWriteOperation(s, std::move(operation));
-    }
+    void TPollerThreads::StartWrite(const TIntrusivePtr<TSharedDescriptor>& s, TFDDelegate&& operation) { 
+        auto& unit = Units[THash<SOCKET>()(s->GetDescriptor()) % Units.size()]; 
+        unit->StartWriteOperation(s, std::move(operation)); 
+    } 
 
 }