aboutsummaryrefslogtreecommitdiffstats
path: root/library
diff options
context:
space:
mode:
authorcepera <cepera@yandex-team.ru>2022-02-10 16:49:45 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:45 +0300
commit70cc862712bf4b7db64c26723d862268e0011e05 (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library
parent99e67b1db27953625d41d1f3eb45ff2517b4d697 (diff)
downloadydb-70cc862712bf4b7db64c26723d862268e0011e05.tar.gz
Restoring authorship annotation for <cepera@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library')
-rw-r--r--library/cpp/http/misc/httpcodes.h2
-rw-r--r--library/cpp/ipv6_address/ipv6_address.h6
-rw-r--r--library/cpp/messagebus/locator.cpp10
-rw-r--r--library/cpp/messagebus/locator.h2
-rw-r--r--library/cpp/messagebus/rain_check/test/TestRainCheck.py12
-rw-r--r--library/cpp/messagebus/session.cpp26
-rw-r--r--library/cpp/messagebus/test/TestMessageBus.py8
-rw-r--r--library/cpp/messagebus/test/perftest/perftest.cpp4
-rw-r--r--library/cpp/monlib/encode/legacy_protobuf/protos/python/ya.make2
-rw-r--r--library/cpp/testing/unittest/registar.h4
10 files changed, 38 insertions, 38 deletions
diff --git a/library/cpp/http/misc/httpcodes.h b/library/cpp/http/misc/httpcodes.h
index 1603ba0179..cbfbaa1188 100644
--- a/library/cpp/http/misc/httpcodes.h
+++ b/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;
diff --git a/library/cpp/ipv6_address/ipv6_address.h b/library/cpp/ipv6_address/ipv6_address.h
index 641beac67e..1d7eb0b65f 100644
--- a/library/cpp/ipv6_address/ipv6_address.h
+++ b/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>
diff --git a/library/cpp/messagebus/locator.cpp b/library/cpp/messagebus/locator.cpp
index f95d8e9d85..e38a35c426 100644
--- a/library/cpp/messagebus/locator.cpp
+++ b/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;
}
diff --git a/library/cpp/messagebus/locator.h b/library/cpp/messagebus/locator.h
index 0cd2d31fee..f8556a3fce 100644
--- a/library/cpp/messagebus/locator.h
+++ b/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 {
diff --git a/library/cpp/messagebus/rain_check/test/TestRainCheck.py b/library/cpp/messagebus/rain_check/test/TestRainCheck.py
index c73a735ae1..92ed727b62 100644
--- a/library/cpp/messagebus/rain_check/test/TestRainCheck.py
+++ b/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')
diff --git a/library/cpp/messagebus/session.cpp b/library/cpp/messagebus/session.cpp
index 323c72bbb1..46a7ece6a8 100644
--- a/library/cpp/messagebus/session.cpp
+++ b/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) {
diff --git a/library/cpp/messagebus/test/TestMessageBus.py b/library/cpp/messagebus/test/TestMessageBus.py
index 057e1cde46..0bbaa0a313 100644
--- a/library/cpp/messagebus/test/TestMessageBus.py
+++ b/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')
diff --git a/library/cpp/messagebus/test/perftest/perftest.cpp b/library/cpp/messagebus/test/perftest/perftest.cpp
index 8350a6b01b..8489319278 100644
--- a/library/cpp/messagebus/test/perftest/perftest.cpp
+++ b/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";
diff --git a/library/cpp/monlib/encode/legacy_protobuf/protos/python/ya.make b/library/cpp/monlib/encode/legacy_protobuf/protos/python/ya.make
index 12f375b966..095b307b01 100644
--- a/library/cpp/monlib/encode/legacy_protobuf/protos/python/ya.make
+++ b/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)
diff --git a/library/cpp/testing/unittest/registar.h b/library/cpp/testing/unittest/registar.h
index 6aafd2d499..44517a0092 100644
--- a/library/cpp/testing/unittest/registar.h
+++ b/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;