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

1 files changed, 29 insertions, 29 deletions

diff --git a/library/cpp/messagebus/coreconn.h b/library/cpp/messagebus/coreconn.h
index 4d50e0b5fb..fca228d82e 100644
--- a/library/cpp/messagebus/coreconn.h
+++ b/library/cpp/messagebus/coreconn.h
@@ -3,65 +3,65 @@
 //////////////////////////////////////////////////////////////
 /// \file
 /// \brief Definitions for asynchonous connection queue
- 
+
 #include "base.h"
 #include "event_loop.h"
 #include "netaddr.h"
 
 #include <util/datetime/base.h>
-#include <util/generic/algorithm.h> 
+#include <util/generic/algorithm.h>
 #include <util/generic/list.h>
 #include <util/generic/map.h>
 #include <util/generic/set.h>
 #include <util/generic/string.h>
 #include <util/generic/vector.h>
 #include <util/network/address.h>
-#include <util/network/ip.h> 
+#include <util/network/ip.h>
 #include <util/network/poller.h>
 #include <util/string/util.h>
 #include <util/system/condvar.h>
-#include <util/system/mutex.h> 
+#include <util/system/mutex.h>
 #include <util/system/thread.h>
 #include <util/thread/lfqueue.h>
- 
+
 #include <deque>
 #include <utility>
 
 #ifdef NO_ERROR
-#undef NO_ERROR 
+#undef NO_ERROR
 #endif
 
 #define BUS_WORKER_CONDVAR
 //#define BUS_WORKER_MIXED
 
-namespace NBus { 
-    class TBusConnection; 
-    class TBusConnectionFactory; 
-    class TBusServerFactory; 
+namespace NBus {
+    class TBusConnection;
+    class TBusConnectionFactory;
+    class TBusServerFactory;
+
+    using TBusConnectionList = TList<TBusConnection*>;
 
-    using TBusConnectionList = TList<TBusConnection*>; 
+    /// @throw yexception
+    EIpVersion MakeIpVersion(bool allowIpv4, bool allowIpv6);
 
-    /// @throw yexception 
-    EIpVersion MakeIpVersion(bool allowIpv4, bool allowIpv6); 
+    inline bool WouldBlock() {
+        int syserr = LastSystemError();
+        return syserr == EAGAIN || syserr == EINPROGRESS || syserr == EWOULDBLOCK || syserr == EINTR;
+    }
 
-    inline bool WouldBlock() { 
-        int syserr = LastSystemError(); 
-        return syserr == EAGAIN || syserr == EINPROGRESS || syserr == EWOULDBLOCK || syserr == EINTR; 
-    } 
+    class TBusSession;
 
-    class TBusSession; 
- 
-    struct TMaxConnectedException: public yexception { 
-        TMaxConnectedException(unsigned maxConnect) { 
-            yexception& exc = *this; 
+    struct TMaxConnectedException: public yexception {
+        TMaxConnectedException(unsigned maxConnect) {
+            yexception& exc = *this;
             exc << TStringBuf("Exceeded maximum number of outstanding connections: ");
-            exc << maxConnect; 
-        } 
-    }; 
+            exc << maxConnect;
+        }
+    };
 
-    enum EPollType { 
-        POLL_READ, 
-        POLL_WRITE 
-    }; 
+    enum EPollType {
+        POLL_READ,
+        POLL_WRITE
+    };
 
 }