Browse Source

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

cepera 3 years ago
parent
commit
70cc862712

+ 1 - 1
library/cpp/http/misc/httpcodes.h

@@ -72,7 +72,7 @@ enum HttpCodes {
     HTTP_NETWORK_AUTHENTICATION_REQUIRED = 511,
     HTTP_UNASSIGNED_512 = 512,
 
-    HTTP_CODE_MAX 
+    HTTP_CODE_MAX
 };
 
 TStringBuf HttpCodeStrEx(int code) noexcept;

+ 3 - 3
library/cpp/ipv6_address/ipv6_address.h

@@ -6,11 +6,11 @@
 
 #include <library/cpp/int128/int128.h>
 
-#if defined(_freebsd_) 
+#if defined(_freebsd_)
 // #include required to avoid problem with undefined 'socklen_t' on FreeBSD
 #include <sys/socket.h>
-#endif 
- 
+#endif
+
 #if defined(_win_)
 // #include required to avoid problem with undefined 'socklen_t' on Windows
 #include <util/network/socket.h>

+ 5 - 5
library/cpp/messagebus/locator.cpp

@@ -93,7 +93,7 @@ namespace NBus {
             } else {
                 return memcmp(&SockAddrIpV6(a1)->sin6_addr, &SockAddrIpV6(a2)->sin6_addr, sizeof(in6_addr)) == 0;
             }
-        } 
+        }
         return false;
     }
 
@@ -104,13 +104,13 @@ namespace NBus {
 
     bool TBusLocator::TItem::operator<(const TItem& y) const {
         const TItem& x = *this;
- 
+
         if (x.ServiceId == y.ServiceId) {
             return (x.End < y.End) || ((x.End == y.End) && CompareByHost(x.Addr, y.Addr) < 0);
-        } 
+        }
         return x.ServiceId < y.ServiceId;
-    } 
- 
+    }
+
     bool TBusLocator::TItem::operator==(const TItem& y) const {
         return ServiceId == y.ServiceId && Start == y.Start && End == y.End && Addr == y.Addr;
     }

+ 1 - 1
library/cpp/messagebus/locator.h

@@ -6,7 +6,7 @@
 #include <util/generic/map.h>
 #include <util/generic/set.h>
 #include <util/generic/string.h>
-#include <util/network/interface.h> 
+#include <util/network/interface.h>
 #include <util/system/mutex.h>
 
 namespace NBus {

+ 6 - 6
library/cpp/messagebus/rain_check/test/TestRainCheck.py

@@ -1,8 +1,8 @@
 from devtools.fleur.ytest import group, constraint
 from devtools.fleur.ytest.integration import UnitTestGroup
- 
-@group 
-@constraint('library.messagebus') 
-class TestMessageBus3(UnitTestGroup): 
-    def __init__(self, context): 
-        UnitTestGroup.__init__(self, context, 'MessageBus', 'library-messagebus-rain_check-test-ut') 
+
+@group
+@constraint('library.messagebus')
+class TestMessageBus3(UnitTestGroup):
+    def __init__(self, context):
+        UnitTestGroup.__init__(self, context, 'MessageBus', 'library-messagebus-rain_check-test-ut')

+ 13 - 13
library/cpp/messagebus/session.cpp

@@ -61,16 +61,16 @@ namespace NBus {
             }
 
             *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) {
@@ -78,22 +78,22 @@ namespace NBus {
                     // Treat ':<port>' as errors but allow or '<host>:' for compatibility.
                     return false;
                 }
- 
+
                 *portNum = host.substr(pos + 1);
-            } 
- 
+            }
+
             *hostName = host.substr(0, pos);
-        } 
- 
+        }
+
         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;
- 
+
         if (!SplitHost(host, &hostName, &port)) {
             hostName = host;
         }
@@ -113,8 +113,8 @@ namespace NBus {
     }
 
     TBusSession::~TBusSession() {
-    } 
- 
+    }
+
 }
 
 TBusClientSessionPtr TBusClientSession::Create(TBusProtocol* proto, IBusClientHandler* handler, const TBusClientSessionConfig& config, TBusMessageQueuePtr queue) {

+ 4 - 4
library/cpp/messagebus/test/TestMessageBus.py

@@ -1,8 +1,8 @@
 from devtools.fleur.ytest import group, constraint
 from devtools.fleur.ytest.integration import UnitTestGroup
- 
-@group 
-@constraint('library.messagebus') 
+
+@group
+@constraint('library.messagebus')
 class TestMessageBus(UnitTestGroup):
-    def __init__(self, context): 
+    def __init__(self, context):
         UnitTestGroup.__init__(self, context, 'MessageBus', 'library-messagebus-test-ut')

+ 2 - 2
library/cpp/messagebus/test/perftest/perftest.cpp

@@ -212,7 +212,7 @@ struct TTestStats {
         return AtomicGet(Replies);
     }
 
-    double GetThroughput() { 
+    double GetThroughput() {
         return NumReplies() * 1000000.0 / (TInstant::Now() - Start).MicroSeconds();
     }
 
@@ -491,7 +491,7 @@ TPerftestConfig::TPerftestConfig() {
 
     ServerPort = DEFAULT_PORT;
     Delay = 0; // artificial delay inside server OnMessage()
-    MessageSize = 200; 
+    MessageSize = 200;
     Failure = 0.00;
     Run = 60; // in seconds
     Nodes = "localhost";

+ 1 - 1
library/cpp/monlib/encode/legacy_protobuf/protos/python/ya.make

@@ -1,3 +1,3 @@
 OWNER(g:solomon)
- 
+
 PY_PROTOS_FOR(library/cpp/monlib/encode/legacy_protobuf/protos)

+ 2 - 2
library/cpp/testing/unittest/registar.h

@@ -364,7 +364,7 @@ public:                       \
 #define UNIT_FAIL_IMPL(R, M)                                                                                                                     \
     do {                                                                                                                                         \
         ::NUnitTest::NPrivate::RaiseError(R, ::TStringBuilder() << R << " at " << __LOCATION__ << ", " << __PRETTY_FUNCTION__ << ": " << M, true); \
-    } while (false) 
+    } while (false)
 
 #define UNIT_FAIL_NONFATAL_IMPL(R, M)                                                                                                             \
     do {                                                                                                                                          \
@@ -1027,4 +1027,4 @@ public:                       \
     TString RandomString(size_t len, ui32 seed = 0);
 }
 
-using ::NUnitTest::TTestBase; 
+using ::NUnitTest::TTestBase;

Some files were not shown because too many files changed in this diff