Browse Source

Merge branch 'master' of https://github.com/PrivacySolutions/i2pd

pull/146/head
orignal 10 years ago
parent
commit
a85af553b8
  1. 7
      HTTPProxy.cpp
  2. 7
      SOCKS.cpp

7
HTTPProxy.cpp

@ -53,8 +53,9 @@ namespace proxy @@ -53,8 +53,9 @@ namespace proxy
public:
HTTPProxyHandler(HTTPProxyServer * parent, boost::asio::ip::tcp::socket * sock) :
I2PServiceHandler(parent), m_sock(sock)
{ AsyncSockRead(); EnterState(GET_METHOD); }
{ EnterState(GET_METHOD); }
~HTTPProxyHandler() { Terminate(); }
void Handle () { AsyncSockRead(); }
};
void HTTPProxyHandler::AsyncSockRead()
@ -255,7 +256,9 @@ namespace proxy @@ -255,7 +256,9 @@ namespace proxy
if (!ecode)
{
LogPrint(eLogDebug,"--- HTTP Proxy accepted");
AddHandler(std::make_shared<HTTPProxyHandler> (this, socket));
auto handler = std::make_shared<HTTPProxyHandler> (this, socket);
AddHandler(handler);
handler->Handle();
Accept();
}
else

7
SOCKS.cpp

@ -128,8 +128,9 @@ namespace proxy @@ -128,8 +128,9 @@ namespace proxy
SOCKSHandler(SOCKSServer * parent, boost::asio::ip::tcp::socket * sock) :
I2PServiceHandler(parent), m_sock(sock), m_stream(nullptr),
m_authchosen(AUTH_UNACCEPTABLE), m_addrtype(ADDR_IPV4)
{ m_address.ip = 0; EnterState(GET_SOCKSV); AsyncSockRead(); }
{ m_address.ip = 0; EnterState(GET_SOCKSV); }
~SOCKSHandler() { Terminate(); }
void Handle() { AsyncSockRead(); }
};
void SOCKSHandler::AsyncSockRead()
@ -538,7 +539,9 @@ namespace proxy @@ -538,7 +539,9 @@ namespace proxy
if (!ecode)
{
LogPrint(eLogDebug,"--- SOCKS accepted");
AddHandler(std::make_shared<SOCKSHandler> (this, socket));
auto handle = std::make_shared<SOCKSHandler> (this, socket);
AddHandler(handle);
handle->Handle();
Accept();
}
else

Loading…
Cancel
Save