aboutsummaryrefslogtreecommitdiffstats
path: root/util/network/socket_ut.cpp
diff options
context:
space:
mode:
authorfeldsherov <feldsherov@yandex-team.ru>2022-02-10 16:49:29 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:29 +0300
commit077ab504815199e62ffc54daee873cf1d6b64297 (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /util/network/socket_ut.cpp
parente73723ec73b27276cd45b9b46b752138a51d669c (diff)
downloadydb-077ab504815199e62ffc54daee873cf1d6b64297.tar.gz
Restoring authorship annotation for <feldsherov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'util/network/socket_ut.cpp')
-rw-r--r--util/network/socket_ut.cpp40
1 files changed, 20 insertions, 20 deletions
diff --git a/util/network/socket_ut.cpp b/util/network/socket_ut.cpp
index d7f6123322..6b20e11f70 100644
--- a/util/network/socket_ut.cpp
+++ b/util/network/socket_ut.cpp
@@ -24,7 +24,7 @@ class TSockTest: public TTestBase {
UNIT_TEST(TestNetworkResolutionError);
UNIT_TEST(TestNetworkResolutionErrorMessage);
UNIT_TEST(TestBrokenPipe);
- UNIT_TEST(TestClose);
+ UNIT_TEST(TestClose);
UNIT_TEST(TestReusePortAvailCheck);
UNIT_TEST_SUITE_END();
@@ -35,7 +35,7 @@ public:
void TestNetworkResolutionError();
void TestNetworkResolutionErrorMessage();
void TestBrokenPipe();
- void TestClose();
+ void TestClose();
void TestReusePortAvailCheck();
};
@@ -166,25 +166,25 @@ void TSockTest::TestBrokenPipe() {
UNIT_ASSERT(sent < 0);
}
-void TSockTest::TestClose() {
- SOCKET socks[2];
-
+void TSockTest::TestClose() {
+ SOCKET socks[2];
+
UNIT_ASSERT_EQUAL(SocketPair(socks), 0);
- TSocket receiver(socks[1]);
-
- UNIT_ASSERT_EQUAL(static_cast<SOCKET>(receiver), socks[1]);
-
-#if defined _linux_
- UNIT_ASSERT_GE(fcntl(socks[1], F_GETFD), 0);
- receiver.Close();
- UNIT_ASSERT_EQUAL(fcntl(socks[1], F_GETFD), -1);
-#else
- receiver.Close();
-#endif
-
- UNIT_ASSERT_EQUAL(static_cast<SOCKET>(receiver), INVALID_SOCKET);
-}
-
+ TSocket receiver(socks[1]);
+
+ UNIT_ASSERT_EQUAL(static_cast<SOCKET>(receiver), socks[1]);
+
+#if defined _linux_
+ UNIT_ASSERT_GE(fcntl(socks[1], F_GETFD), 0);
+ receiver.Close();
+ UNIT_ASSERT_EQUAL(fcntl(socks[1], F_GETFD), -1);
+#else
+ receiver.Close();
+#endif
+
+ UNIT_ASSERT_EQUAL(static_cast<SOCKET>(receiver), INVALID_SOCKET);
+}
+
void TSockTest::TestReusePortAvailCheck() {
#if defined _linux_
utsname sysInfo;