diff options
author | ermolovd <ermolovd@yandex-team.ru> | 2022-02-10 16:47:53 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:53 +0300 |
commit | b91bcef7c99a119b0846479ef71bfab4beec72ca (patch) | |
tree | be118d54d12a61bc4812ceb0a266a170a2fa3bc9 /util/network/socket.cpp | |
parent | f421873774cf0b71743afbe5f6677861e66601ea (diff) | |
download | ydb-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.cpp | 28 |
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) { |