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

1 files changed, 93 insertions, 93 deletions

diff --git a/library/cpp/messagebus/session.cpp b/library/cpp/messagebus/session.cpp
index 772984a086..46a7ece6a8 100644
--- a/library/cpp/messagebus/session.cpp
+++ b/library/cpp/messagebus/session.cpp
@@ -5,126 +5,126 @@
 using namespace NBus;
 
 namespace NBus {
-    TBusSession::TBusSession() { 
-    } 
-
-    //////////////////////////////////////////////////////////////////// 
-    /// \brief Adds peer of connection into connection list 
-
-    int CompareByHost(const IRemoteAddr& l, const IRemoteAddr& r) noexcept { 
-        if (l.Addr()->sa_family != r.Addr()->sa_family) { 
-            return l.Addr()->sa_family < r.Addr()->sa_family ? -1 : +1; 
-        } 
- 
-        switch (l.Addr()->sa_family) { 
-            case AF_INET: { 
-                return memcmp(&(((const sockaddr_in*)l.Addr())->sin_addr), &(((const sockaddr_in*)r.Addr())->sin_addr), sizeof(in_addr)); 
-            } 
-
-            case AF_INET6: { 
-                return memcmp(&(((const sockaddr_in6*)l.Addr())->sin6_addr), &(((const sockaddr_in6*)r.Addr())->sin6_addr), sizeof(in6_addr)); 
-            } 
+    TBusSession::TBusSession() {
+    }
+
+    ////////////////////////////////////////////////////////////////////
+    /// \brief Adds peer of connection into connection list
+
+    int CompareByHost(const IRemoteAddr& l, const IRemoteAddr& r) noexcept {
+        if (l.Addr()->sa_family != r.Addr()->sa_family) {
+            return l.Addr()->sa_family < r.Addr()->sa_family ? -1 : +1;
+        }
+
+        switch (l.Addr()->sa_family) {
+            case AF_INET: {
+                return memcmp(&(((const sockaddr_in*)l.Addr())->sin_addr), &(((const sockaddr_in*)r.Addr())->sin_addr), sizeof(in_addr));
+            }
+
+            case AF_INET6: {
+                return memcmp(&(((const sockaddr_in6*)l.Addr())->sin6_addr), &(((const sockaddr_in6*)r.Addr())->sin6_addr), sizeof(in6_addr));
+            }
         }
 
-        return memcmp(l.Addr(), r.Addr(), Min<size_t>(l.Len(), r.Len())); 
+        return memcmp(l.Addr(), r.Addr(), Min<size_t>(l.Len(), r.Len()));
+    }
+
+    bool operator<(const TNetAddr& a1, const TNetAddr& a2) {
+        return CompareByHost(a1, a2) < 0;
+    }
+
+    size_t TBusSession::GetInFlight(const TNetAddr& addr) const {
+        size_t r;
+        GetInFlightBulk({addr}, MakeArrayRef(&r, 1));
+        return r;
     }
 
-    bool operator<(const TNetAddr& a1, const TNetAddr& a2) { 
-        return CompareByHost(a1, a2) < 0; 
-    } 
-
-    size_t TBusSession::GetInFlight(const TNetAddr& addr) const { 
-        size_t r; 
-        GetInFlightBulk({addr}, MakeArrayRef(&r, 1)); 
-        return r; 
-    } 
-
-    size_t TBusSession::GetConnectSyscallsNumForTest(const TNetAddr& addr) const { 
-        size_t r; 
-        GetConnectSyscallsNumBulkForTest({addr}, MakeArrayRef(&r, 1)); 
-        return r; 
-    } 
-
-    // Split 'host' into name and port taking into account that host can be specified 
-    // as ipv6 address ('[<ipv6 address]:port' notion). 
-    bool SplitHost(const TString& host, TString* hostName, TString* portNum) { 
-        hostName->clear(); 
-        portNum->clear(); 
-
-        // Simple check that we have to deal with ipv6 address specification or 
-        // just host name or ipv4 address. 
+    size_t TBusSession::GetConnectSyscallsNumForTest(const TNetAddr& addr) const {
+        size_t r;
+        GetConnectSyscallsNumBulkForTest({addr}, MakeArrayRef(&r, 1));
+        return r;
+    }
+
+    // Split 'host' into name and port taking into account that host can be specified
+    // as ipv6 address ('[<ipv6 address]:port' notion).
+    bool SplitHost(const TString& host, TString* hostName, TString* portNum) {
+        hostName->clear();
+        portNum->clear();
+
+        // Simple check that we have to deal with ipv6 address specification or
+        // just host name or ipv4 address.
         if (!host.empty() && (host[0] == '[')) {
-            size_t pos = host.find(']'); 
-            if (pos < 2 || pos == TString::npos) { 
-                // '[]' and '[<address>' are errors. 
-                return false; 
-            } 
-
-            *hostName = host.substr(1, pos - 1); 
-
-            pos++; 
-            if (pos != host.length()) { 
-                if (host[pos] != ':') { 
-                    // Do not allow '[...]a' but '[...]:' is ok (as for ipv4 before 
-                    return false; 
-                } 
-
-                *portNum = host.substr(pos + 1); 
+            size_t pos = host.find(']');
+            if (pos < 2 || pos == TString::npos) {
+                // '[]' and '[<address>' are errors.
+                return false;
             }
-        } else { 
-            size_t pos = host.find(':'); 
-            if (pos != TString::npos) { 
-                if (pos == 0) { 
-                    // Treat ':<port>' as errors but allow or '<host>:' for compatibility. 
-                    return false; 
-                } 
-
-                *portNum = host.substr(pos + 1); 
+
+            *hostName = host.substr(1, pos - 1);
+
+            pos++;
+            if (pos != host.length()) {
+                if (host[pos] != ':') {
+                    // Do not allow '[...]a' but '[...]:' is ok (as for ipv4 before
+                    return false;
+                }
+
+                *portNum = host.substr(pos + 1);
+            }
+        } else {
+            size_t pos = host.find(':');
+            if (pos != TString::npos) {
+                if (pos == 0) {
+                    // Treat ':<port>' as errors but allow or '<host>:' for compatibility.
+                    return false;
+                }
+
+                *portNum = host.substr(pos + 1);
             }
 
-            *hostName = host.substr(0, pos); 
+            *hostName = host.substr(0, pos);
         }
 
-        return true; 
+        return true;
     }
 
-    /// registers external session on host:port with locator service 
-    int TBusSession::RegisterService(const char* host, TBusKey start /*= YBUS_KEYMIN*/, TBusKey end /*= YBUS_KEYMAX*/, EIpVersion ipVersion) { 
-        TString hostName; 
-        TString port; 
-        int portNum; 
+    /// registers external session on host:port with locator service
+    int TBusSession::RegisterService(const char* host, TBusKey start /*= YBUS_KEYMIN*/, TBusKey end /*= YBUS_KEYMAX*/, EIpVersion ipVersion) {
+        TString hostName;
+        TString port;
+        int portNum;
 
-        if (!SplitHost(host, &hostName, &port)) { 
-            hostName = host; 
-        } 
+        if (!SplitHost(host, &hostName, &port)) {
+            hostName = host;
+        }
 
         if (port.empty()) {
-            portNum = GetProto()->GetPort(); 
-        } else { 
-            try { 
-                portNum = FromString<int>(port); 
-            } catch (const TFromStringException&) { 
-                return -1; 
-            } 
-        } 
-
-        TBusService service = GetProto()->GetService(); 
+            portNum = GetProto()->GetPort();
+        } else {
+            try {
+                portNum = FromString<int>(port);
+            } catch (const TFromStringException&) {
+                return -1;
+            }
+        }
+
+        TBusService service = GetProto()->GetService();
         return GetQueue()->GetLocator()->Register(service, hostName.data(), portNum, start, end, ipVersion);
     }
 
-    TBusSession::~TBusSession() { 
+    TBusSession::~TBusSession() {
     }
 
 }
 
-TBusClientSessionPtr TBusClientSession::Create(TBusProtocol* proto, IBusClientHandler* handler, const TBusClientSessionConfig& config, TBusMessageQueuePtr queue) { 
+TBusClientSessionPtr TBusClientSession::Create(TBusProtocol* proto, IBusClientHandler* handler, const TBusClientSessionConfig& config, TBusMessageQueuePtr queue) {
     return queue->CreateSource(proto, handler, config);
 }
 
-TBusServerSessionPtr TBusServerSession::Create(TBusProtocol* proto, IBusServerHandler* handler, const TBusServerSessionConfig& config, TBusMessageQueuePtr queue) { 
+TBusServerSessionPtr TBusServerSession::Create(TBusProtocol* proto, IBusServerHandler* handler, const TBusServerSessionConfig& config, TBusMessageQueuePtr queue) {
     return queue->CreateDestination(proto, handler, config);
 }
 
-TBusServerSessionPtr TBusServerSession::Create(TBusProtocol* proto, IBusServerHandler* handler, const TBusServerSessionConfig& config, TBusMessageQueuePtr queue, const TVector<TBindResult>& bindTo) { 
+TBusServerSessionPtr TBusServerSession::Create(TBusProtocol* proto, IBusServerHandler* handler, const TBusServerSessionConfig& config, TBusMessageQueuePtr queue, const TVector<TBindResult>& bindTo) {
     return queue->CreateDestination(proto, handler, config, bindTo);
 }