aboutsummaryrefslogtreecommitdiffstats
path: root/util/network/socket_ut.cpp
diff options
context:
space:
mode:
authoraosipenko <aosipenko@yandex-team.ru>2022-02-10 16:48:08 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:48:08 +0300
commit69e3c43df1c96bc2ac8946bf4dfb1f5fc438ff7f (patch)
treeb222e5ac2e2e98872661c51ccceee5da0d291e13 /util/network/socket_ut.cpp
parent948fd24d47d4b3b7815aaef1686aea00ef3f4288 (diff)
downloadydb-69e3c43df1c96bc2ac8946bf4dfb1f5fc438ff7f.tar.gz
Restoring authorship annotation for <aosipenko@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'util/network/socket_ut.cpp')
-rw-r--r--util/network/socket_ut.cpp68
1 files changed, 34 insertions, 34 deletions
diff --git a/util/network/socket_ut.cpp b/util/network/socket_ut.cpp
index 4a826dc170..6b20e11f70 100644
--- a/util/network/socket_ut.cpp
+++ b/util/network/socket_ut.cpp
@@ -15,18 +15,18 @@
#endif
class TSockTest: public TTestBase {
- UNIT_TEST_SUITE(TSockTest);
+ UNIT_TEST_SUITE(TSockTest);
UNIT_TEST(TestSock);
UNIT_TEST(TestTimeout);
-#ifndef _win_ // Test hangs on Windows
+#ifndef _win_ // Test hangs on Windows
UNIT_TEST_EXCEPTION(TestConnectionRefused, yexception);
-#endif
+#endif
UNIT_TEST(TestNetworkResolutionError);
UNIT_TEST(TestNetworkResolutionErrorMessage);
UNIT_TEST(TestBrokenPipe);
UNIT_TEST(TestClose);
UNIT_TEST(TestReusePortAvailCheck);
- UNIT_TEST_SUITE_END();
+ UNIT_TEST_SUITE_END();
public:
void TestSock();
@@ -53,45 +53,45 @@ void TSockTest::TestSock() {
UNIT_ASSERT(!si.ReadLine().empty());
}
-void TSockTest::TestTimeout() {
- static const int timeout = 1000;
- i64 startTime = millisec();
- try {
- TNetworkAddress addr("localhost", 1313);
- TSocket s(addr, TDuration::MilliSeconds(timeout));
+void TSockTest::TestTimeout() {
+ static const int timeout = 1000;
+ i64 startTime = millisec();
+ try {
+ TNetworkAddress addr("localhost", 1313);
+ TSocket s(addr, TDuration::MilliSeconds(timeout));
} catch (const yexception&) {
- }
- int realTimeout = (int)(millisec() - startTime);
- if (realTimeout > timeout + 2000) {
+ }
+ int realTimeout = (int)(millisec() - startTime);
+ if (realTimeout > timeout + 2000) {
TString err = TStringBuilder() << "Timeout exceeded: " << realTimeout << " ms (expected " << timeout << " ms)";
- UNIT_FAIL(err);
- }
-}
-
-void TSockTest::TestConnectionRefused() {
- TNetworkAddress addr("localhost", 1313);
- TSocket s(addr);
-}
-
-void TSockTest::TestNetworkResolutionError() {
+ UNIT_FAIL(err);
+ }
+}
+
+void TSockTest::TestConnectionRefused() {
+ TNetworkAddress addr("localhost", 1313);
+ TSocket s(addr);
+}
+
+void TSockTest::TestNetworkResolutionError() {
TString errMsg;
- try {
- TNetworkAddress addr("", 0);
+ try {
+ TNetworkAddress addr("", 0);
} catch (const TNetworkResolutionError& e) {
- errMsg = e.what();
- }
-
+ errMsg = e.what();
+ }
+
if (errMsg.empty()) {
- return; // on Windows getaddrinfo("", 0, ...) returns "OK"
+ return; // on Windows getaddrinfo("", 0, ...) returns "OK"
}
-
- int expectedErr = EAI_NONAME;
+
+ int expectedErr = EAI_NONAME;
TString expectedErrMsg = gai_strerror(expectedErr);
if (errMsg.find(expectedErrMsg) == TString::npos) {
UNIT_FAIL("TNetworkResolutionError contains\nInvalid msg: " + errMsg + "\nExpected msg: " + expectedErrMsg + "\n");
- }
-}
-
+ }
+}
+
void TSockTest::TestNetworkResolutionErrorMessage() {
#ifdef _unix_
auto str = [](int code) -> TString {