Restoring authorship annotation for <orivej@yandex-team.ru>. Commit 1 of 2.

1 files changed, 261 insertions, 261 deletions

diff --git a/contrib/libs/poco/Net/src/HTTPSession.cpp b/contrib/libs/poco/Net/src/HTTPSession.cpp
index cb6fdc25e9..eaf1e9188d 100644
--- a/contrib/libs/poco/Net/src/HTTPSession.cpp
+++ b/contrib/libs/poco/Net/src/HTTPSession.cpp
@@ -1,261 +1,261 @@
-//
-// HTTPSession.cpp
-//
-// Library: Net
-// Package: HTTP
-// Module:  HTTPSession
-//
-// Copyright (c) 2005-2006, Applied Informatics Software Engineering GmbH.
-// and Contributors.
-//
-// SPDX-License-Identifier:	BSL-1.0
-//
-
-
-#include "Poco/Net/HTTPSession.h"
-#include "Poco/Net/HTTPBufferAllocator.h"
-#include "Poco/Net/NetException.h"
-#include <cstring>
-
-
-using Poco::TimeoutException;
-
-
-namespace Poco {
-namespace Net {
-
-
-HTTPSession::HTTPSession():
-	_pBuffer(0),
-	_pCurrent(0),
-	_pEnd(0),
-	_keepAlive(false),
-	_connectionTimeout(HTTP_DEFAULT_CONNECTION_TIMEOUT),
-	_receiveTimeout(HTTP_DEFAULT_TIMEOUT),
-	_sendTimeout(HTTP_DEFAULT_TIMEOUT),
-	_pException(0)
-{
-}
-
-
-HTTPSession::HTTPSession(const StreamSocket& socket):
-	_socket(socket),
-	_pBuffer(0),
-	_pCurrent(0),
-	_pEnd(0),
-	_keepAlive(false),
-	_connectionTimeout(HTTP_DEFAULT_CONNECTION_TIMEOUT),
-	_receiveTimeout(HTTP_DEFAULT_TIMEOUT),
-	_sendTimeout(HTTP_DEFAULT_TIMEOUT),
-	_pException(0)
-{
-}
-
-
-HTTPSession::HTTPSession(const StreamSocket& socket, bool keepAlive):
-	_socket(socket),
-	_pBuffer(0),
-	_pCurrent(0),
-	_pEnd(0),
-	_keepAlive(keepAlive),
-	_connectionTimeout(HTTP_DEFAULT_CONNECTION_TIMEOUT),
-	_receiveTimeout(HTTP_DEFAULT_TIMEOUT),
-	_sendTimeout(HTTP_DEFAULT_TIMEOUT),
-	_pException(0)
-{
-}
-
-
-HTTPSession::~HTTPSession()
-{
-	try
-	{
-		if (_pBuffer) HTTPBufferAllocator::deallocate(_pBuffer, HTTPBufferAllocator::BUFFER_SIZE);
-	}
-	catch (...)
-	{
-		poco_unexpected();
-	}
-	try
-	{
-		close();
-	}
-	catch (...)
-	{
-	}
-	delete _pException;
-}
-
-
-void HTTPSession::setKeepAlive(bool keepAlive)
-{
-	_keepAlive = keepAlive;
-}
-
-
-void HTTPSession::setTimeout(const Poco::Timespan& timeout)
-{
-	setTimeout(timeout, timeout, timeout);
-}
-
-
-void HTTPSession::setTimeout(const Poco::Timespan& connectionTimeout, const Poco::Timespan& sendTimeout, const Poco::Timespan& receiveTimeout)
-{
-	 _connectionTimeout = connectionTimeout;
-	 _sendTimeout = sendTimeout;
-	 _receiveTimeout = receiveTimeout;
-}
-
-
-int HTTPSession::get()
-{
-	if (_pCurrent == _pEnd)
-		refill();
-	
-	if (_pCurrent < _pEnd)
-		return *_pCurrent++;
-	else
-		return std::char_traits<char>::eof();
-}
-
-	
-int HTTPSession::peek()
-{
-	if (_pCurrent == _pEnd)
-		refill();
-
-	if (_pCurrent < _pEnd)
-		return *_pCurrent;
-	else
-		return std::char_traits<char>::eof();
-}
-
-	
-int HTTPSession::read(char* buffer, std::streamsize length)
-{
-	if (_pCurrent < _pEnd)
-	{
-		int n = (int) (_pEnd - _pCurrent);
-		if (n > length) n = (int) length;
-		std::memcpy(buffer, _pCurrent, n);
-		_pCurrent += n;
-		return n;
-	}
-	else return receive(buffer, (int) length);
-}
-
-
-int HTTPSession::write(const char* buffer, std::streamsize length)
-{
-	try
-	{
-		return _socket.sendBytes(buffer, (int) length);
-	}
-	catch (Poco::Exception& exc)
-	{
-		setException(exc);
-		throw;
-	}
-}
-
-
-int HTTPSession::receive(char* buffer, int length)
-{
-	try
-	{
-		return _socket.receiveBytes(buffer, length);
-	}
-	catch (Poco::Exception& exc)
-	{
-		setException(exc);
-		throw;
-	}
-}
-
-
-void HTTPSession::refill()
-{
-	if (!_pBuffer)
-	{
-		_pBuffer = HTTPBufferAllocator::allocate(HTTPBufferAllocator::BUFFER_SIZE);
-	}
-	_pCurrent = _pEnd = _pBuffer;
-	int n = receive(_pBuffer, HTTPBufferAllocator::BUFFER_SIZE);
-	_pEnd += n;
-}
-
-
-bool HTTPSession::connected() const
-{
-	return _socket.impl()->initialized();
-}
-
-
-void HTTPSession::connect(const SocketAddress& address)
-{
-	_socket.connect(address, _connectionTimeout);
-	_socket.setReceiveTimeout(_receiveTimeout);
-	_socket.setSendTimeout(_sendTimeout);
-	_socket.setNoDelay(true);
-	// There may be leftover data from a previous (failed) request in the buffer,
-	// so we clear it.
-	_pCurrent = _pEnd = _pBuffer;
-}
-
-
-void HTTPSession::abort()
-{
-	_socket.shutdown();
-	close();
-}
-
-
-void HTTPSession::close()
-{
-	_socket.close();
-}
-
-
-void HTTPSession::setException(const Poco::Exception& exc)
-{
-	delete _pException;
-	_pException = exc.clone();
-}
-
-
-void HTTPSession::clearException()
-{
-	delete _pException;
-	_pException = 0;
-}
-
-
-StreamSocket HTTPSession::detachSocket()
-{
-	StreamSocket oldSocket(_socket);
-	StreamSocket newSocket;
-	_socket = newSocket;
-	return oldSocket;
-}
-
-
-void HTTPSession::attachSocket(const StreamSocket& socket)
-{
-	_socket = socket;
-}
-
-
-void HTTPSession::attachSessionData(const Poco::Any& data)
-{
-	_data = data;
-}
-
-
-void HTTPSession::drainBuffer(Poco::Buffer<char>& buffer)
-{
-	buffer.assign(_pCurrent, static_cast<std::size_t>(_pEnd - _pCurrent));
-	_pCurrent = _pEnd;
-}
-
-
-} } // namespace Poco::Net
+// 
+// HTTPSession.cpp 
+// 
+// Library: Net 
+// Package: HTTP 
+// Module:  HTTPSession 
+// 
+// Copyright (c) 2005-2006, Applied Informatics Software Engineering GmbH. 
+// and Contributors. 
+// 
+// SPDX-License-Identifier:	BSL-1.0 
+// 
+ 
+ 
+#include "Poco/Net/HTTPSession.h" 
+#include "Poco/Net/HTTPBufferAllocator.h" 
+#include "Poco/Net/NetException.h" 
+#include <cstring> 
+ 
+ 
+using Poco::TimeoutException; 
+ 
+ 
+namespace Poco { 
+namespace Net { 
+ 
+ 
+HTTPSession::HTTPSession(): 
+	_pBuffer(0), 
+	_pCurrent(0), 
+	_pEnd(0), 
+	_keepAlive(false), 
+	_connectionTimeout(HTTP_DEFAULT_CONNECTION_TIMEOUT), 
+	_receiveTimeout(HTTP_DEFAULT_TIMEOUT), 
+	_sendTimeout(HTTP_DEFAULT_TIMEOUT), 
+	_pException(0) 
+{ 
+} 
+ 
+ 
+HTTPSession::HTTPSession(const StreamSocket& socket): 
+	_socket(socket), 
+	_pBuffer(0), 
+	_pCurrent(0), 
+	_pEnd(0), 
+	_keepAlive(false), 
+	_connectionTimeout(HTTP_DEFAULT_CONNECTION_TIMEOUT), 
+	_receiveTimeout(HTTP_DEFAULT_TIMEOUT), 
+	_sendTimeout(HTTP_DEFAULT_TIMEOUT), 
+	_pException(0) 
+{ 
+} 
+ 
+ 
+HTTPSession::HTTPSession(const StreamSocket& socket, bool keepAlive): 
+	_socket(socket), 
+	_pBuffer(0), 
+	_pCurrent(0), 
+	_pEnd(0), 
+	_keepAlive(keepAlive), 
+	_connectionTimeout(HTTP_DEFAULT_CONNECTION_TIMEOUT), 
+	_receiveTimeout(HTTP_DEFAULT_TIMEOUT), 
+	_sendTimeout(HTTP_DEFAULT_TIMEOUT), 
+	_pException(0) 
+{ 
+} 
+ 
+ 
+HTTPSession::~HTTPSession() 
+{ 
+	try 
+	{ 
+		if (_pBuffer) HTTPBufferAllocator::deallocate(_pBuffer, HTTPBufferAllocator::BUFFER_SIZE); 
+	} 
+	catch (...) 
+	{ 
+		poco_unexpected(); 
+	} 
+	try 
+	{ 
+		close(); 
+	} 
+	catch (...) 
+	{ 
+	} 
+	delete _pException; 
+} 
+ 
+ 
+void HTTPSession::setKeepAlive(bool keepAlive) 
+{ 
+	_keepAlive = keepAlive; 
+} 
+ 
+ 
+void HTTPSession::setTimeout(const Poco::Timespan& timeout) 
+{ 
+	setTimeout(timeout, timeout, timeout); 
+} 
+ 
+ 
+void HTTPSession::setTimeout(const Poco::Timespan& connectionTimeout, const Poco::Timespan& sendTimeout, const Poco::Timespan& receiveTimeout) 
+{ 
+	 _connectionTimeout = connectionTimeout; 
+	 _sendTimeout = sendTimeout; 
+	 _receiveTimeout = receiveTimeout; 
+} 
+ 
+ 
+int HTTPSession::get() 
+{ 
+	if (_pCurrent == _pEnd) 
+		refill(); 
+	 
+	if (_pCurrent < _pEnd) 
+		return *_pCurrent++; 
+	else 
+		return std::char_traits<char>::eof(); 
+} 
+ 
+	 
+int HTTPSession::peek() 
+{ 
+	if (_pCurrent == _pEnd) 
+		refill(); 
+ 
+	if (_pCurrent < _pEnd) 
+		return *_pCurrent; 
+	else 
+		return std::char_traits<char>::eof(); 
+} 
+ 
+	 
+int HTTPSession::read(char* buffer, std::streamsize length) 
+{ 
+	if (_pCurrent < _pEnd) 
+	{ 
+		int n = (int) (_pEnd - _pCurrent); 
+		if (n > length) n = (int) length; 
+		std::memcpy(buffer, _pCurrent, n); 
+		_pCurrent += n; 
+		return n; 
+	} 
+	else return receive(buffer, (int) length); 
+} 
+ 
+ 
+int HTTPSession::write(const char* buffer, std::streamsize length) 
+{ 
+	try 
+	{ 
+		return _socket.sendBytes(buffer, (int) length); 
+	} 
+	catch (Poco::Exception& exc) 
+	{ 
+		setException(exc); 
+		throw; 
+	} 
+} 
+ 
+ 
+int HTTPSession::receive(char* buffer, int length) 
+{ 
+	try 
+	{ 
+		return _socket.receiveBytes(buffer, length); 
+	} 
+	catch (Poco::Exception& exc) 
+	{ 
+		setException(exc); 
+		throw; 
+	} 
+} 
+ 
+ 
+void HTTPSession::refill() 
+{ 
+	if (!_pBuffer) 
+	{ 
+		_pBuffer = HTTPBufferAllocator::allocate(HTTPBufferAllocator::BUFFER_SIZE); 
+	} 
+	_pCurrent = _pEnd = _pBuffer; 
+	int n = receive(_pBuffer, HTTPBufferAllocator::BUFFER_SIZE); 
+	_pEnd += n; 
+} 
+ 
+ 
+bool HTTPSession::connected() const 
+{ 
+	return _socket.impl()->initialized(); 
+} 
+ 
+ 
+void HTTPSession::connect(const SocketAddress& address) 
+{ 
+	_socket.connect(address, _connectionTimeout); 
+	_socket.setReceiveTimeout(_receiveTimeout); 
+	_socket.setSendTimeout(_sendTimeout); 
+	_socket.setNoDelay(true); 
+	// There may be leftover data from a previous (failed) request in the buffer, 
+	// so we clear it. 
+	_pCurrent = _pEnd = _pBuffer; 
+} 
+ 
+ 
+void HTTPSession::abort() 
+{ 
+	_socket.shutdown(); 
+	close(); 
+} 
+ 
+ 
+void HTTPSession::close() 
+{ 
+	_socket.close(); 
+} 
+ 
+ 
+void HTTPSession::setException(const Poco::Exception& exc) 
+{ 
+	delete _pException; 
+	_pException = exc.clone(); 
+} 
+ 
+ 
+void HTTPSession::clearException() 
+{ 
+	delete _pException; 
+	_pException = 0; 
+} 
+ 
+ 
+StreamSocket HTTPSession::detachSocket() 
+{ 
+	StreamSocket oldSocket(_socket); 
+	StreamSocket newSocket; 
+	_socket = newSocket; 
+	return oldSocket; 
+} 
+ 
+ 
+void HTTPSession::attachSocket(const StreamSocket& socket) 
+{ 
+	_socket = socket; 
+} 
+ 
+ 
+void HTTPSession::attachSessionData(const Poco::Any& data) 
+{ 
+	_data = data; 
+} 
+ 
+ 
+void HTTPSession::drainBuffer(Poco::Buffer<char>& buffer) 
+{ 
+	buffer.assign(_pCurrent, static_cast<std::size_t>(_pEnd - _pCurrent)); 
+	_pCurrent = _pEnd; 
+} 
+ 
+ 
+} } // namespace Poco::Net