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

1 files changed, 80 insertions, 80 deletions

diff --git a/util/network/poller_ut.cpp b/util/network/poller_ut.cpp
index 6df0dda8ec..1d542f8c67 100644
--- a/util/network/poller_ut.cpp
+++ b/util/network/poller_ut.cpp
@@ -1,105 +1,105 @@
 #include <library/cpp/testing/unittest/registar.h>
 #include <util/system/error.h>
-
+ 
 #include "pair.h"
-#include "poller.h"
+#include "poller.h" 
 #include "pollerimpl.h"
-
+ 
 Y_UNIT_TEST_SUITE(TSocketPollerTest) {
     Y_UNIT_TEST(TestSimple) {
-        SOCKET sockets[2];
-        UNIT_ASSERT(SocketPair(sockets) == 0);
-
-        TSocketHolder s1(sockets[0]);
-        TSocketHolder s2(sockets[1]);
-
-        TSocketPoller poller;
+        SOCKET sockets[2]; 
+        UNIT_ASSERT(SocketPair(sockets) == 0); 
+ 
+        TSocketHolder s1(sockets[0]); 
+        TSocketHolder s2(sockets[1]); 
+ 
+        TSocketPoller poller; 
         poller.WaitRead(sockets[1], (void*)17);
-
+ 
         UNIT_ASSERT_VALUES_EQUAL(nullptr, poller.WaitT(TDuration::Zero()));
         UNIT_ASSERT_VALUES_EQUAL(nullptr, poller.WaitT(TDuration::Zero()));
-
-        for (ui32 i = 0; i < 3; ++i) {
+ 
+        for (ui32 i = 0; i < 3; ++i) { 
             char buf[] = {18};
-            UNIT_ASSERT_VALUES_EQUAL(1, send(sockets[0], buf, 1, 0));
-
+            UNIT_ASSERT_VALUES_EQUAL(1, send(sockets[0], buf, 1, 0)); 
+ 
             UNIT_ASSERT_VALUES_EQUAL((void*)17, poller.WaitT(TDuration::Zero()));
-
-            UNIT_ASSERT_VALUES_EQUAL(1, recv(sockets[1], buf, 1, 0));
-            UNIT_ASSERT_VALUES_EQUAL(18, buf[0]);
-
+ 
+            UNIT_ASSERT_VALUES_EQUAL(1, recv(sockets[1], buf, 1, 0)); 
+            UNIT_ASSERT_VALUES_EQUAL(18, buf[0]); 
+ 
             UNIT_ASSERT_VALUES_EQUAL(nullptr, poller.WaitT(TDuration::Zero()));
             UNIT_ASSERT_VALUES_EQUAL(nullptr, poller.WaitT(TDuration::Zero()));
-        }
-    }
-
+        } 
+    } 
+ 
     Y_UNIT_TEST(TestSimpleOneShot) {
-        SOCKET sockets[2];
-        UNIT_ASSERT(SocketPair(sockets) == 0);
-
-        TSocketHolder s1(sockets[0]);
-        TSocketHolder s2(sockets[1]);
-
-        TSocketPoller poller;
-
+        SOCKET sockets[2]; 
+        UNIT_ASSERT(SocketPair(sockets) == 0); 
+ 
+        TSocketHolder s1(sockets[0]); 
+        TSocketHolder s2(sockets[1]); 
+ 
+        TSocketPoller poller; 
+ 
         UNIT_ASSERT_VALUES_EQUAL(nullptr, poller.WaitT(TDuration::Zero()));
         UNIT_ASSERT_VALUES_EQUAL(nullptr, poller.WaitT(TDuration::Zero()));
-
-        for (ui32 i = 0; i < 3; ++i) {
+ 
+        for (ui32 i = 0; i < 3; ++i) { 
             poller.WaitReadOneShot(sockets[1], (void*)17);
-
-            char buf[1];
-
-            buf[0] = i + 20;
-
-            UNIT_ASSERT_VALUES_EQUAL(1, send(sockets[0], buf, 1, 0));
-
+ 
+            char buf[1]; 
+ 
+            buf[0] = i + 20; 
+ 
+            UNIT_ASSERT_VALUES_EQUAL(1, send(sockets[0], buf, 1, 0)); 
+ 
             UNIT_ASSERT_VALUES_EQUAL((void*)17, poller.WaitT(TDuration::Zero()));
-
-            UNIT_ASSERT_VALUES_EQUAL(1, recv(sockets[1], buf, 1, 0));
-            UNIT_ASSERT_VALUES_EQUAL(char(i + 20), buf[0]);
-
-            UNIT_ASSERT_VALUES_EQUAL(nullptr, poller.WaitT(TDuration::Zero()));
-            UNIT_ASSERT_VALUES_EQUAL(nullptr, poller.WaitT(TDuration::Zero()));
-
-            buf[0] = i + 21;
-
-            UNIT_ASSERT_VALUES_EQUAL(1, send(sockets[0], buf, 1, 0));
-
-            // this fails if socket is not oneshot
-            UNIT_ASSERT_VALUES_EQUAL(nullptr, poller.WaitT(TDuration::Zero()));
-            UNIT_ASSERT_VALUES_EQUAL(nullptr, poller.WaitT(TDuration::Zero()));
-
-            UNIT_ASSERT_VALUES_EQUAL(1, recv(sockets[1], buf, 1, 0));
-            UNIT_ASSERT_VALUES_EQUAL(char(i + 21), buf[0]);
-        }
-    }
-
+ 
+            UNIT_ASSERT_VALUES_EQUAL(1, recv(sockets[1], buf, 1, 0)); 
+            UNIT_ASSERT_VALUES_EQUAL(char(i + 20), buf[0]); 
+ 
+            UNIT_ASSERT_VALUES_EQUAL(nullptr, poller.WaitT(TDuration::Zero()));
+            UNIT_ASSERT_VALUES_EQUAL(nullptr, poller.WaitT(TDuration::Zero()));
+ 
+            buf[0] = i + 21; 
+ 
+            UNIT_ASSERT_VALUES_EQUAL(1, send(sockets[0], buf, 1, 0)); 
+ 
+            // this fails if socket is not oneshot 
+            UNIT_ASSERT_VALUES_EQUAL(nullptr, poller.WaitT(TDuration::Zero()));
+            UNIT_ASSERT_VALUES_EQUAL(nullptr, poller.WaitT(TDuration::Zero()));
+ 
+            UNIT_ASSERT_VALUES_EQUAL(1, recv(sockets[1], buf, 1, 0)); 
+            UNIT_ASSERT_VALUES_EQUAL(char(i + 21), buf[0]); 
+        } 
+    } 
+ 
     Y_UNIT_TEST(TestItIsSafeToUnregisterUnregisteredDescriptor) {
-        SOCKET sockets[2];
-        UNIT_ASSERT(SocketPair(sockets) == 0);
-
-        TSocketHolder s1(sockets[0]);
-        TSocketHolder s2(sockets[1]);
-
-        TSocketPoller poller;
-
-        poller.Unwait(s1);
-    }
-
+        SOCKET sockets[2]; 
+        UNIT_ASSERT(SocketPair(sockets) == 0); 
+ 
+        TSocketHolder s1(sockets[0]); 
+        TSocketHolder s2(sockets[1]); 
+ 
+        TSocketPoller poller; 
+ 
+        poller.Unwait(s1); 
+    } 
+ 
     Y_UNIT_TEST(TestItIsSafeToReregisterDescriptor) {
-        SOCKET sockets[2];
-        UNIT_ASSERT(SocketPair(sockets) == 0);
-
-        TSocketHolder s1(sockets[0]);
-        TSocketHolder s2(sockets[1]);
-
-        TSocketPoller poller;
-
+        SOCKET sockets[2]; 
+        UNIT_ASSERT(SocketPair(sockets) == 0); 
+ 
+        TSocketHolder s1(sockets[0]); 
+        TSocketHolder s2(sockets[1]); 
+ 
+        TSocketPoller poller; 
+ 
         poller.WaitRead(s1, nullptr);
         poller.WaitRead(s1, nullptr);
         poller.WaitWrite(s1, nullptr);
-    }
+    } 
 
     Y_UNIT_TEST(TestSimpleEdgeTriggered) {
         SOCKET sockets[2];
@@ -233,4 +233,4 @@ Y_UNIT_TEST_SUITE(TSocketPollerTest) {
         UNIT_ASSERT_EQUAL(TPoller::ExtractEvent(&e), (void*)17);
     }
 #endif
-}
+}