Method HandleSockRecv

libi2pd_client/SOCKS.cpp:624–677

	}

	void SOCKSHandler::HandleSockRecv(const boost::system::error_code & ecode, std::size_t len)
	{
		LogPrint(eLogDebug, "SOCKS: Received ", len, " bytes");
		if(ecode)
		{
			LogPrint(eLogWarning, "SOCKS: Recv got error: ", ecode);
			Terminate();
			return;
		}

		if (HandleData(m_sock_buff, len))
		{
			if (m_state == READY)
			{
				const std::string addr = m_address.dns.ToString();
				LogPrint(eLogInfo, "SOCKS: Requested ", addr, ":" , m_port);
				const size_t addrlen = addr.size();
				// does it end with .i2p?
				if (addr.rfind(".i2p") == addrlen - 4)
				{
					// yes it does
					switch (m_cmd)
					{
						case CMD_CONNECT:
							//make an i2p session
							GetOwner ()->UpdateLastActivityTime ();
							GetOwner()->CreateStream ( std::bind (&SOCKSHandler::HandleStreamRequestComplete,
								shared_from_this(), std::placeholders::_1), m_address.dns.ToString(), m_port);
						break;
						case CMD_UDP:
							// create UDP client tunnel
							LogPrint (eLogInfo, "SOCKS: New UDP associate connection");
							m_UDPTunnel = std::make_unique<i2p::client::I2PUDPClientTunnel>("", addr,
								GetServer ()->GetNextLocalUDPEndpoint (),
							    GetOwner ()->GetLocalDestination (), m_port, false, i2p::datagram::eDatagramV3);
							boost::asio::post (GetOwner ()->GetService (), [this](void)
								{
									SocksRequestSuccess();
								});
							break;
						default: ;
					}
				}
				else if (m_UseUpstreamProxy)
					// forward it to upstream proxy
					ForwardSOCKS();
				else
					// no upstream proxy
					SocksRequestFailed(SOCKS5_ADDR_UNSUP);
			}
			else
				AsyncSockRead();
		}
	}

	void SOCKSHandler::SentSocksFailed(const boost::system::error_code & ecode)
	{