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
commit2a4a975b112fa0fa138abc7457fe67e0e1e7fd02 (patch)
treec0748b5dcbade83af788c0abfa89c0383d6b779c /util/network/socket.cpp
parentb91bcef7c99a119b0846479ef71bfab4beec72ca (diff)
downloadydb-2a4a975b112fa0fa138abc7457fe67e0e1e7fd02.tar.gz
Restoring authorship annotation for <ermolovd@yandex-team.ru>. Commit 2 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 cec676b032f..4f6e8043462 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) {