Restoring authorship annotation for Alexander Rutkovsky <alexvru@mail.ru>. Commit 1 of 2.

1 files changed, 36 insertions, 36 deletions

diff --git a/library/cpp/actors/interconnect/poller_tcp_unit_select.cpp b/library/cpp/actors/interconnect/poller_tcp_unit_select.cpp
index ae7aaad566..c1b6ae59a1 100644
--- a/library/cpp/actors/interconnect/poller_tcp_unit_select.cpp
+++ b/library/cpp/actors/interconnect/poller_tcp_unit_select.cpp
@@ -1,67 +1,67 @@
-#include "poller_tcp_unit_select.h"
-
-#include <csignal>
-
-#if defined(_win_)
-#include <winsock2.h>
-#define SOCKET_ERROR_SOURCE ::WSAGetLastError()
-#elif defined(_darwin_)
-#include <cerrno>
-#define SOCKET_ERROR_SOURCE errno
-typedef timeval TIMEVAL;
-#else
-#include <cerrno>
-#define SOCKET_ERROR_SOURCE errno
-#endif
-
-namespace NInterconnect {
+#include "poller_tcp_unit_select.h" 
+ 
+#include <csignal> 
+ 
+#if defined(_win_) 
+#include <winsock2.h> 
+#define SOCKET_ERROR_SOURCE ::WSAGetLastError() 
+#elif defined(_darwin_) 
+#include <cerrno> 
+#define SOCKET_ERROR_SOURCE errno 
+typedef timeval TIMEVAL; 
+#else 
+#include <cerrno> 
+#define SOCKET_ERROR_SOURCE errno 
+#endif 
+ 
+namespace NInterconnect { 
     TPollerUnitSelect::TPollerUnitSelect() {
     }
-
+ 
     TPollerUnitSelect::~TPollerUnitSelect() {
     }
-
+ 
     template <bool IsWrite>
     void
     TPollerUnitSelect::Process() {
         auto& side = GetSide<IsWrite>();
         side.ProcessInput();
-
+ 
         enum : size_t { R,
                         W,
                         E };
         static const auto O = IsWrite ? W : R;
-
+ 
         ::fd_set sets[3];
-
+ 
         FD_ZERO(&sets[R]);
         FD_ZERO(&sets[W]);
         FD_ZERO(&sets[E]);
-
+ 
         for (const auto& operation : side.Operations) {
             FD_SET(operation.first, &sets[O]);
             FD_SET(operation.first, &sets[E]);
         }
-
-#if defined(_win_)
+ 
+#if defined(_win_) 
         ::TIMEVAL timeout = {0L, 99991L};
         const auto numberEvents = !side.Operations.empty() ? ::select(FD_SETSIZE, &sets[R], &sets[W], &sets[E], &timeout)
                                                            : (::Sleep(100), 0);
-#elif defined(_darwin_)
+#elif defined(_darwin_) 
         ::TIMEVAL timeout = {0L, 99991L};
         const auto numberEvents = ::select(FD_SETSIZE, &sets[R], &sets[W], &sets[E], &timeout);
-#else
+#else 
         ::sigset_t sigmask;
         ::sigemptyset(&sigmask);
         ::sigaddset(&sigmask, SIGPIPE);
         ::sigaddset(&sigmask, SIGTERM);
-
+ 
         struct ::timespec timeout = {0L, 99999989L};
         const auto numberEvents = ::pselect(FD_SETSIZE, &sets[R], &sets[W], &sets[E], &timeout, &sigmask);
-#endif
-
+#endif 
+ 
         Y_VERIFY_DEBUG(numberEvents >= 0);
-
+ 
         for (auto it = side.Operations.cbegin(); side.Operations.cend() != it;) {
             if (FD_ISSET(it->first, &sets[O]) || FD_ISSET(it->first, &sets[E]))
                 if (const auto& finalizer = it->second.second(it->second.first)) {
@@ -71,16 +71,16 @@ namespace NInterconnect {
                 }
             ++it;
         }
-    }
-
+    } 
+ 
     void
     TPollerUnitSelect::ProcessRead() {
         Process<false>();
     }
-
+ 
     void
     TPollerUnitSelect::ProcessWrite() {
         Process<true>();
     }
-
-}
+ 
+}