aboutsummaryrefslogtreecommitdiffstats
path: root/util/network/socket_ut.cpp
diff options
context:
space:
mode:
authorVlad Yaroslavlev <vladon@vladon.com>2022-02-10 16:46:25 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:25 +0300
commit344ea37b4a345701ab0e67de2266a1c1bd7baf2d (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /util/network/socket_ut.cpp
parent706b83ed7de5a473436620367af31fc0ceecde07 (diff)
downloadydb-344ea37b4a345701ab0e67de2266a1c1bd7baf2d.tar.gz
Restoring authorship annotation for Vlad Yaroslavlev <vladon@vladon.com>. Commit 2 of 2.
Diffstat (limited to 'util/network/socket_ut.cpp')
-rw-r--r--util/network/socket_ut.cpp14
1 files changed, 7 insertions, 7 deletions
diff --git a/util/network/socket_ut.cpp b/util/network/socket_ut.cpp
index 6d700ac8af..6b20e11f70 100644
--- a/util/network/socket_ut.cpp
+++ b/util/network/socket_ut.cpp
@@ -63,7 +63,7 @@ void TSockTest::TestTimeout() {
}
int realTimeout = (int)(millisec() - startTime);
if (realTimeout > timeout + 2000) {
- TString err = TStringBuilder() << "Timeout exceeded: " << realTimeout << " ms (expected " << timeout << " ms)";
+ TString err = TStringBuilder() << "Timeout exceeded: " << realTimeout << " ms (expected " << timeout << " ms)";
UNIT_FAIL(err);
}
}
@@ -74,7 +74,7 @@ void TSockTest::TestConnectionRefused() {
}
void TSockTest::TestNetworkResolutionError() {
- TString errMsg;
+ TString errMsg;
try {
TNetworkAddress addr("", 0);
} catch (const TNetworkResolutionError& e) {
@@ -86,8 +86,8 @@ void TSockTest::TestNetworkResolutionError() {
}
int expectedErr = EAI_NONAME;
- TString expectedErrMsg = gai_strerror(expectedErr);
- if (errMsg.find(expectedErrMsg) == TString::npos) {
+ TString expectedErrMsg = gai_strerror(expectedErr);
+ if (errMsg.find(expectedErrMsg) == TString::npos) {
UNIT_FAIL("TNetworkResolutionError contains\nInvalid msg: " + errMsg + "\nExpected msg: " + expectedErrMsg + "\n");
}
}
@@ -289,9 +289,9 @@ void TPollTest::TestPollInOut() {
ui32 localIp = ntohl(inet_addr("127.0.0.1"));
- TVector<TSimpleSharedPtr<TSocketHolder>> clientSockets;
- TVector<TSimpleSharedPtr<TSocketHolder>> connectedSockets;
- TVector<pollfd> fds;
+ TVector<TSimpleSharedPtr<TSocketHolder>> clientSockets;
+ TVector<TSimpleSharedPtr<TSocketHolder>> connectedSockets;
+ TVector<pollfd> fds;
for (size_t i = 0; i < socketCount; ++i) {
TSimpleSharedPtr<TSocketHolder> clientSocket(new TSocketHolder(StartClientSocket(localIp, port)));