aboutsummaryrefslogtreecommitdiffstats
path: root/util/network/pair.cpp
diff options
context:
space:
mode:
authornae202 <nae202@yandex-team.com>2024-11-20 12:52:01 +0300
committernae202 <nae202@yandex-team.com>2024-11-20 13:14:09 +0300
commit0b9d91e900b52bccd6eabd033acbb57c4ee173fc (patch)
tree6839ed69fbda4d5214eb418acc4554924bc64160 /util/network/pair.cpp
parent878e26057d11cce46b7bc3a6c838209d4686e28b (diff)
downloadydb-0b9d91e900b52bccd6eabd033acbb57c4ee173fc.tar.gz
Part of PR. Style
Часть большого ПР REVIEW:7264088 commit_hash:0f5b03fbbed0ac30f734943309e3ef5cd4d7a30e
Diffstat (limited to 'util/network/pair.cpp')
-rw-r--r--util/network/pair.cpp12
1 files changed, 8 insertions, 4 deletions
diff --git a/util/network/pair.cpp b/util/network/pair.cpp
index 9751ef5c96..de07d5f35c 100644
--- a/util/network/pair.cpp
+++ b/util/network/pair.cpp
@@ -47,17 +47,21 @@ int SocketPair(SOCKET socks[2], bool overlapped, bool cloexec) {
}
do {
- if (listen(listener, 1) == SOCKET_ERROR)
+ if (listen(listener, 1) == SOCKET_ERROR) {
break;
+ }
- if ((socks[0] = WSASocket(AF_INET, SOCK_STREAM, 0, nullptr, 0, flags)) == INVALID_SOCKET)
+ if ((socks[0] = WSASocket(AF_INET, SOCK_STREAM, 0, nullptr, 0, flags)) == INVALID_SOCKET) {
break;
+ }
- if (connect(socks[0], (const struct sockaddr*)&addr, sizeof(addr)) == SOCKET_ERROR)
+ if (connect(socks[0], (const struct sockaddr*)&addr, sizeof(addr)) == SOCKET_ERROR) {
break;
+ }
- if ((socks[1] = accept(listener, nullptr, nullptr)) == INVALID_SOCKET)
+ if ((socks[1] = accept(listener, nullptr, nullptr)) == INVALID_SOCKET) {
break;
+ }
closesocket(listener);