aboutsummaryrefslogtreecommitdiffstats
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
commit99e67b1db27953625d41d1f3eb45ff2517b4d697 (patch)
treee54d1799e55c6a3c58feb227f2a1f22aa07912c0
parent28045de07753ee182fc8e5ca778469d7a7c5bb20 (diff)
downloadydb-99e67b1db27953625d41d1f3eb45ff2517b4d697.tar.gz
Restoring authorship annotation for <cepera@yandex-team.ru>. Commit 1 of 2.
-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
-rw-r--r--util/network/address.h18
-rw-r--r--util/network/interface.cpp50
-rw-r--r--util/network/interface.h26
-rw-r--r--util/system/fs_ut.cpp4
-rw-r--r--util/system/thread.cpp20
-rw-r--r--ydb/public/api/protos/ya.make2
16 files changed, 98 insertions, 98 deletions
diff --git a/library/cpp/http/misc/httpcodes.h b/library/cpp/http/misc/httpcodes.h
index cbfbaa1188..1603ba0179 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 1d7eb0b65f..641beac67e 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 e38a35c426..f95d8e9d85 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 f8556a3fce..0cd2d31fee 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 92ed727b62..c73a735ae1 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 46a7ece6a8..323c72bbb1 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 0bbaa0a313..057e1cde46 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 8489319278..8350a6b01b 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 095b307b01..12f375b966 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 44517a0092..6aafd2d499 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;
diff --git a/util/network/address.h b/util/network/address.h
index 448fcac0c9..5b1cf10cd4 100644
--- a/util/network/address.h
+++ b/util/network/address.h
@@ -40,13 +40,13 @@ namespace NAddr {
}
inline TOpaqueAddr(const IRemoteAddr* addr) noexcept {
- Assign(addr->Addr(), addr->Len());
+ Assign(addr->Addr(), addr->Len());
}
- inline TOpaqueAddr(const sockaddr* addr) {
+ inline TOpaqueAddr(const sockaddr* addr) {
Assign(addr, SockAddrLength(addr));
- }
-
+ }
+
const sockaddr* Addr() const override {
return MutableAddr();
}
@@ -65,11 +65,11 @@ namespace NAddr {
private:
inline void Assign(const sockaddr* addr, socklen_t len) noexcept {
- L_ = len;
- memcpy(MutableAddr(), addr, L_);
- }
-
- private:
+ L_ = len;
+ memcpy(MutableAddr(), addr, L_);
+ }
+
+ private:
sockaddr_storage S_;
socklen_t L_;
};
diff --git a/util/network/interface.cpp b/util/network/interface.cpp
index 256776c6d3..c207523181 100644
--- a/util/network/interface.cpp
+++ b/util/network/interface.cpp
@@ -1,28 +1,28 @@
-#include "interface.h"
-
+#include "interface.h"
+
#if defined(_unix_)
#include <ifaddrs.h>
-#endif
-
-#ifdef _win_
+#endif
+
+#ifdef _win_
#include <iphlpapi.h>
#pragma comment(lib, "Iphlpapi.lib")
-#endif
-
-namespace NAddr {
+#endif
+
+namespace NAddr {
static bool IsInetAddress(sockaddr* addr) {
return (addr != nullptr) && ((addr->sa_family == AF_INET) || (addr->sa_family == AF_INET6));
}
-
+
TNetworkInterfaceList GetNetworkInterfaces() {
TNetworkInterfaceList result;
-
-#ifdef _win_
+
+#ifdef _win_
TVector<char> buf;
buf.resize(1000000);
PIP_ADAPTER_ADDRESSES adapterBuf = (PIP_ADAPTER_ADDRESSES)&buf[0];
ULONG bufSize = buf.ysize();
-
+
if (GetAdaptersAddresses(AF_UNSPEC, 0, nullptr, adapterBuf, &bufSize) == ERROR_SUCCESS) {
for (PIP_ADAPTER_ADDRESSES ptr = adapterBuf; ptr != 0; ptr = ptr->Next) {
// The check below makes code working on Vista+
@@ -37,12 +37,12 @@ namespace NAddr {
// ignore disable adapters
continue;
}
-
+
for (IP_ADAPTER_UNICAST_ADDRESS* addr = ptr->FirstUnicastAddress; addr != 0; addr = addr->Next) {
sockaddr* a = (sockaddr*)addr->Address.lpSockaddr;
if (IsInetAddress(a)) {
TNetworkInterface networkInterface;
-
+
// Not very efficient but straightforward
for (size_t i = 0; ptr->FriendlyName[i] != 0; i++) {
CHAR w = ptr->FriendlyName[i];
@@ -52,11 +52,11 @@ namespace NAddr {
networkInterface.Address = new TOpaqueAddr(a);
result.push_back(networkInterface);
- }
- }
- }
- }
-#else
+ }
+ }
+ }
+ }
+#else
ifaddrs* ifap;
if (getifaddrs(&ifap) != -1) {
for (ifaddrs* ifa = ifap; ifa != nullptr; ifa = ifa->ifa_next) {
@@ -68,12 +68,12 @@ namespace NAddr {
interface.Mask = new TOpaqueAddr(ifa->ifa_netmask);
}
result.push_back(interface);
- }
- }
+ }
+ }
freeifaddrs(ifap);
- }
-#endif
-
+ }
+#endif
+
return result;
}
-}
+}
diff --git a/util/network/interface.h b/util/network/interface.h
index dda4555021..7bee4f492b 100644
--- a/util/network/interface.h
+++ b/util/network/interface.h
@@ -1,17 +1,17 @@
-#pragma once
-
-#include "address.h"
-
-#include <util/generic/vector.h>
-
-namespace NAddr {
- struct TNetworkInterface {
+#pragma once
+
+#include "address.h"
+
+#include <util/generic/vector.h>
+
+namespace NAddr {
+ struct TNetworkInterface {
TString Name;
IRemoteAddrRef Address;
IRemoteAddrRef Mask;
- };
-
+ };
+
using TNetworkInterfaceList = TVector<TNetworkInterface>;
-
- TNetworkInterfaceList GetNetworkInterfaces();
-}
+
+ TNetworkInterfaceList GetNetworkInterfaces();
+}
diff --git a/util/system/fs_ut.cpp b/util/system/fs_ut.cpp
index de071ebf55..b921714de7 100644
--- a/util/system/fs_ut.cpp
+++ b/util/system/fs_ut.cpp
@@ -250,12 +250,12 @@ static void RunSymLinkTest(TString fileLocalName, TString symLinkName) {
UNIT_ASSERT(fs.IsFile());
UNIT_ASSERT(!fs.IsDir());
UNIT_ASSERT(!fs.IsSymlink());
- UNIT_ASSERT_VALUES_EQUAL(fs.Size, 7u);
+ UNIT_ASSERT_VALUES_EQUAL(fs.Size, 7u);
}
{
TFileStat fs(symLinkName, true);
- //UNIT_ASSERT(fs.IsFile()); // no evidence that symlink has to be a file as well
+ //UNIT_ASSERT(fs.IsFile()); // no evidence that symlink has to be a file as well
UNIT_ASSERT(!fs.IsDir());
UNIT_ASSERT(fs.IsSymlink());
}
diff --git a/util/system/thread.cpp b/util/system/thread.cpp
index 6236746c2d..32cdf8b8db 100644
--- a/util/system/thread.cpp
+++ b/util/system/thread.cpp
@@ -286,7 +286,7 @@ TThread::TThread(TPrivateCtor, THolder<TCallableBase> callable)
}
TThread::~TThread() {
- Join();
+ Join();
}
void TThread::Start() {
@@ -294,17 +294,17 @@ void TThread::Start() {
}
void* TThread::Join() {
- if (Running()) {
- void* ret = Impl_->Join();
-
- Impl_.Destroy();
-
- return ret;
- }
+ if (Running()) {
+ void* ret = Impl_->Join();
+
+ Impl_.Destroy();
+
+ return ret;
+ }
return nullptr;
-}
-
+}
+
void TThread::Detach() {
if (Running()) {
Impl_->Detach();
diff --git a/ydb/public/api/protos/ya.make b/ydb/public/api/protos/ya.make
index 8a156403a3..088478e640 100644
--- a/ydb/public/api/protos/ya.make
+++ b/ydb/public/api/protos/ya.make
@@ -54,7 +54,7 @@ IF (MODULE_TAG == "CPP_PROTO")
GENERATE_ENUM_SERIALIZATION(draft/persqueue_common.pb.h)
GENERATE_ENUM_SERIALIZATION(ydb_persqueue_cluster_discovery.pb.h)
GENERATE_ENUM_SERIALIZATION(draft/datastreams.pb.h)
-ENDIF()
+ENDIF()
EXCLUDE_TAGS(GO_PROTO)