aboutsummaryrefslogtreecommitdiffstats
path: root/util/network
diff options
context:
space:
mode:
authortobo <tobo@yandex-team.ru>2022-02-10 16:47:27 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:27 +0300
commit7fe839092527589b38f014d854c51565b3c1adfa (patch)
tree309e97022d3530044b712b8f71318c78faf7856e /util/network
parentd0d68c395c10da4cb56a1c845504570a04d7893e (diff)
downloadydb-7fe839092527589b38f014d854c51565b3c1adfa.tar.gz
Restoring authorship annotation for <tobo@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'util/network')
-rw-r--r--util/network/endpoint.cpp2
-rw-r--r--util/network/endpoint_ut.cpp4
-rw-r--r--util/network/init.h4
-rw-r--r--util/network/socket.cpp4
-rw-r--r--util/network/socket_ut.cpp2
5 files changed, 8 insertions, 8 deletions
diff --git a/util/network/endpoint.cpp b/util/network/endpoint.cpp
index 9acdd06940..d6b8aa6035 100644
--- a/util/network/endpoint.cpp
+++ b/util/network/endpoint.cpp
@@ -7,7 +7,7 @@ TEndpoint::TEndpoint(const TEndpoint::TAddrRef& addr)
const sockaddr* sa = Addr_->Addr();
if (sa->sa_family != AF_INET && sa->sa_family != AF_INET6 && sa->sa_family != AF_UNIX) {
- ythrow yexception() << TStringBuf("endpoint can contain only ipv4, ipv6 or unix address");
+ ythrow yexception() << TStringBuf("endpoint can contain only ipv4, ipv6 or unix address");
}
}
diff --git a/util/network/endpoint_ut.cpp b/util/network/endpoint_ut.cpp
index d5e40dd6e1..1adcf95148 100644
--- a/util/network/endpoint_ut.cpp
+++ b/util/network/endpoint_ut.cpp
@@ -53,8 +53,8 @@ Y_UNIT_TEST_SUITE(TEndpointTest) {
TEndpoint ep3(new NAddr::TAddrInfo(&*na3.Begin()));
UNIT_ASSERT(ep3.IsIpV6());
- UNIT_ASSERT(ep3.IpToString().StartsWith(TStringBuf("2a02:6b8:0:1410:")));
- UNIT_ASSERT(ep3.IpToString().EndsWith(TStringBuf(":5f6c:f3c2")));
+ UNIT_ASSERT(ep3.IpToString().StartsWith(TStringBuf("2a02:6b8:0:1410:")));
+ UNIT_ASSERT(ep3.IpToString().EndsWith(TStringBuf(":5f6c:f3c2")));
UNIT_ASSERT_VALUES_EQUAL(54321, ep3.Port());
TNetworkAddress na4("2a02:6b8:0:1410:0::5f6c:f3c2", 1);
diff --git a/util/network/init.h b/util/network/init.h
index 08a79c0fca..ea7e2898d7 100644
--- a/util/network/init.h
+++ b/util/network/init.h
@@ -18,7 +18,7 @@
#include <netinet/tcp.h>
#include <arpa/inet.h>
-using SOCKET = int;
+using SOCKET = int;
#define closesocket(s) close(s)
#define SOCKET_ERROR -1
@@ -30,7 +30,7 @@ using SOCKET = int;
#include <winsock2.h>
#include <ws2tcpip.h>
-using nfds_t = ULONG;
+using nfds_t = ULONG;
#undef Yield
diff --git a/util/network/socket.cpp b/util/network/socket.cpp
index 4f6e804346..c392d20dd3 100644
--- a/util/network/socket.cpp
+++ b/util/network/socket.cpp
@@ -163,7 +163,7 @@ int poll(struct pollfd fds[], nfds_t nfds, int timeout) noexcept {
int error = WSAGetLastError();
if (error == WSAEINVAL || error == WSAENOTSOCK) {
fd->revents = POLLNVAL;
- ++checked_sockets;
+ ++checked_sockets;
} else {
errno = EIO;
return -1;
@@ -188,7 +188,7 @@ int poll(struct pollfd fds[], nfds_t nfds, int timeout) noexcept {
if (FD_ISSET(fd->fd, &writefds)) {
fd->revents |= POLLOUT;
}
- ++checked_sockets;
+ ++checked_sockets;
}
}
diff --git a/util/network/socket_ut.cpp b/util/network/socket_ut.cpp
index 6b20e11f70..78bc5b12e8 100644
--- a/util/network/socket_ut.cpp
+++ b/util/network/socket_ut.cpp
@@ -46,7 +46,7 @@ void TSockTest::TestSock() {
TSocket s(addr);
TSocketOutput so(s);
TSocketInput si(s);
- const TStringBuf req = "GET / HTTP/1.1\r\nHost: yandex.ru\r\n\r\n";
+ const TStringBuf req = "GET / HTTP/1.1\r\nHost: yandex.ru\r\n\r\n";
so.Write(req.data(), req.size());