aboutsummaryrefslogtreecommitdiffstats
path: root/util/network/socket.cpp
diff options
context:
space:
mode:
authorermolovd <ermolovd@yandex-team.ru>2022-02-10 16:47:53 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:53 +0300
commitb91bcef7c99a119b0846479ef71bfab4beec72ca (patch)
treebe118d54d12a61bc4812ceb0a266a170a2fa3bc9 /util/network/socket.cpp
parentf421873774cf0b71743afbe5f6677861e66601ea (diff)
downloadydb-b91bcef7c99a119b0846479ef71bfab4beec72ca.tar.gz
Restoring authorship annotation for <ermolovd@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'util/network/socket.cpp')
-rw-r--r--util/network/socket.cpp28
1 files changed, 14 insertions, 14 deletions
diff --git a/util/network/socket.cpp b/util/network/socket.cpp
index 4f6e8043462..cec676b032f 100644
--- a/util/network/socket.cpp
+++ b/util/network/socket.cpp
@@ -538,19 +538,19 @@ ESocketReadStatus HasSocketDataToRead(SOCKET s) {
}
#if defined(_win_)
-static ssize_t DoSendMsg(SOCKET sock, const struct iovec* iov, int iovcnt) {
+static ssize_t DoSendMsg(SOCKET sock, const struct iovec* iov, int iovcnt) {
return writev(sock, iov, iovcnt);
-}
-#else
-static ssize_t DoSendMsg(SOCKET sock, const struct iovec* iov, int iovcnt) {
- struct msghdr message;
-
- Zero(message);
- message.msg_iov = const_cast<struct iovec*>(iov);
- message.msg_iovlen = iovcnt;
-
- return sendmsg(sock, &message, MSG_NOSIGNAL);
-}
+}
+#else
+static ssize_t DoSendMsg(SOCKET sock, const struct iovec* iov, int iovcnt) {
+ struct msghdr message;
+
+ Zero(message);
+ message.msg_iov = const_cast<struct iovec*>(iov);
+ message.msg_iovlen = iovcnt;
+
+ return sendmsg(sock, &message, MSG_NOSIGNAL);
+}
#endif
void TSocketHolder::Close() noexcept {
@@ -709,7 +709,7 @@ static inline SOCKET DoConnect(const struct addrinfo* res, const TInstant& deadL
static inline ssize_t DoSendV(SOCKET fd, const struct iovec* iov, size_t count) {
ssize_t ret = -1;
do {
- ret = DoSendMsg(fd, iov, (int)count);
+ ret = DoSendMsg(fd, iov, (int)count);
} while (ret == -1 && errno == EINTR);
if (ret < 0) {
@@ -760,7 +760,7 @@ public:
ssize_t Send(SOCKET fd, const void* data, size_t len) override {
ssize_t ret = -1;
do {
- ret = send(fd, (const char*)data, (int)len, MSG_NOSIGNAL);
+ ret = send(fd, (const char*)data, (int)len, MSG_NOSIGNAL);
} while (ret == -1 && errno == EINTR);
if (ret < 0) {