diff options
| author | becks <becks@yandex-team.ru> | 2022-02-10 16:47:57 +0300 |
|---|---|---|
| committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:57 +0300 |
| commit | 86d17ce35561f39e8fb1dcf1b3340a48db69dfae (patch) | |
| tree | c0748b5dcbade83af788c0abfa89c0383d6b779c /contrib/libs/poco/Net/src | |
| parent | dab0ded2f3bec93f337adc3dd3e17edf64b6da09 (diff) | |
| download | ydb-86d17ce35561f39e8fb1dcf1b3340a48db69dfae.tar.gz | |
Restoring authorship annotation for <becks@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'contrib/libs/poco/Net/src')
| -rw-r--r-- | contrib/libs/poco/Net/src/HTTPHeaderStream.cpp | 8 | ||||
| -rw-r--r-- | contrib/libs/poco/Net/src/SocketImpl.cpp | 20 |
2 files changed, 14 insertions, 14 deletions
diff --git a/contrib/libs/poco/Net/src/HTTPHeaderStream.cpp b/contrib/libs/poco/Net/src/HTTPHeaderStream.cpp index 8f3956ce6c..7d8279bc80 100644 --- a/contrib/libs/poco/Net/src/HTTPHeaderStream.cpp +++ b/contrib/libs/poco/Net/src/HTTPHeaderStream.cpp @@ -28,8 +28,8 @@ namespace Net { HTTPHeaderStreamBuf::HTTPHeaderStreamBuf(HTTPSession& session, openmode mode): HTTPBasicStreamBuf(HTTPBufferAllocator::BUFFER_SIZE, mode), _session(session), - _end(false), - _line_ended(true) + _end(false), + _line_ended(true) { } @@ -56,9 +56,9 @@ int HTTPHeaderStreamBuf::readFromDevice(char* buffer, std::streamsize length) if (ch != eof) { *buffer++ = (char) ch; ++n; - if (n == 2) _end = _line_ended; + if (n == 2) _end = _line_ended; } - _line_ended = (ch == '\n'); + _line_ended = (ch == '\n'); return n; } diff --git a/contrib/libs/poco/Net/src/SocketImpl.cpp b/contrib/libs/poco/Net/src/SocketImpl.cpp index be45597754..92c664ec82 100644 --- a/contrib/libs/poco/Net/src/SocketImpl.cpp +++ b/contrib/libs/poco/Net/src/SocketImpl.cpp @@ -449,7 +449,7 @@ bool SocketImpl::secure() const } -bool SocketImpl::pollImpl(Poco::Timespan& remainingTime, int mode) +bool SocketImpl::pollImpl(Poco::Timespan& remainingTime, int mode) { poco_socket_t sockfd = _sockfd; if (sockfd == POCO_INVALID_SOCKET) throw InvalidSocketException(); @@ -580,11 +580,11 @@ bool SocketImpl::pollImpl(Poco::Timespan& remainingTime, int mode) #endif // POCO_HAVE_FD_EPOLL } -bool SocketImpl::poll(const Poco::Timespan& timeout, int mode) -{ - Poco::Timespan remainingTime(timeout); - return pollImpl(remainingTime, mode); -} +bool SocketImpl::poll(const Poco::Timespan& timeout, int mode) +{ + Poco::Timespan remainingTime(timeout); + return pollImpl(remainingTime, mode); +} void SocketImpl::setSendBufferSize(int size) { @@ -616,13 +616,13 @@ int SocketImpl::getReceiveBufferSize() void SocketImpl::setSendTimeout(const Poco::Timespan& timeout) { -#if defined(_WIN32) +#if defined(_WIN32) int value = (int) timeout.totalMilliseconds(); setOption(SOL_SOCKET, SO_SNDTIMEO, value); -#else +#else setOption(SOL_SOCKET, SO_SNDTIMEO, timeout); #endif - _sndTimeout = timeout; + _sndTimeout = timeout; } @@ -650,7 +650,7 @@ void SocketImpl::setReceiveTimeout(const Poco::Timespan& timeout) #else setOption(SOL_SOCKET, SO_RCVTIMEO, timeout); #endif - _recvTimeout = timeout; + _recvTimeout = timeout; } |