Gecko [ www.vortexaion.com ]

Name	Size	Permission	Date
hash_algorithms	[ DIR ]	drwxrwxrwx	2024-07-26 17:37
includes	[ DIR ]	drwxrwxrwx	2024-07-26 17:37
install	[ DIR ]	drwxrwxrwx	2024-07-26 17:37
interface	[ DIR ]	drwxrwxrwx	2024-07-26 17:37
misc	[ DIR ]	drwxrwxrwx	2024-07-26 17:37
res	[ DIR ]	drwxrwxrwx	2024-07-26 17:37
tinyxml	[ DIR ]	drwxrwxrwx	2024-07-26 17:37
Accounts.cpp	12.2 KB	-rw-rw-rw-	2012-04-16 19:30
Accounts.h	2.12 KB	-rw-rw-rw-	2012-04-16 19:30
AdminInterface.cpp	3.1 KB	-rw-rw-rw-	2012-04-16 19:30
AdminInterface.h	1.77 KB	-rw-rw-rw-	2012-04-16 19:30
AdminListenSocket.cpp	1.64 KB	-rw-rw-rw-	2012-04-16 19:30
AdminListenSocket.h	1.58 KB	-rw-rw-rw-	2012-04-16 19:30
AdminSocket.cpp	9.85 KB	-rw-rw-rw-	2012-04-16 19:30
AdminSocket.h	2.1 KB	-rw-rw-rw-	2012-04-16 19:30
AsyncGssSocketLayer.cpp	30.35 KB	-rw-rw-rw-	2012-04-16 19:30
AsyncGssSocketLayer.h	4.76 KB	-rw-rw-rw-	2012-04-16 19:30
AsyncSocketEx.cpp	51.94 KB	-rw-rw-rw-	2012-04-16 19:30
AsyncSocketEx.h	11.75 KB	-rw-rw-rw-	2012-04-16 19:30
AsyncSocketExLayer.cpp	26.22 KB	-rw-rw-rw-	2012-04-16 19:30
AsyncSocketExLayer.h	7 KB	-rw-rw-rw-	2012-04-16 19:30
AsyncSslSocketLayer.cpp	60.12 KB	-rw-rw-rw-	2012-04-16 19:30
AsyncSslSocketLayer.h	8.94 KB	-rw-rw-rw-	2012-04-16 19:30
ControlSocket.cpp	96.33 KB	-rw-rw-rw-	2012-04-16 19:30
ControlSocket.h	4.74 KB	-rw-rw-rw-	2012-04-16 19:30
ExternalIpCheck.cpp	7.82 KB	-rw-rw-rw-	2012-04-16 19:30
ExternalIpCheck.h	1.85 KB	-rw-rw-rw-	2012-04-16 19:30
FileLogger.cpp	6.68 KB	-rw-rw-rw-	2012-04-16 19:30
FileLogger.h	1.35 KB	-rw-rw-rw-	2012-04-16 19:30
FileZilla server.rc	2.65 KB	-rw-rw-rw-	2012-04-16 19:30
FileZilla server.sln	2.75 KB	-rw-rw-rw-	2012-04-16 19:30
FileZilla server.vcproj	39.95 KB	-rw-rw-rw-	2012-04-16 19:30
ListenSocket.cpp	4.23 KB	-rw-rw-rw-	2012-04-16 19:30
ListenSocket.h	2.29 KB	-rw-rw-rw-	2012-04-16 19:30
MFC64bitFix.cpp	2.56 KB	-rw-rw-rw-	2012-04-16 19:30
MFC64bitFix.h	1.45 KB	-rw-rw-rw-	2012-04-16 19:30
OptionLimits.h	1022 B	-rw-rw-rw-	2012-04-16 19:30
OptionTypes.h	6.46 KB	-rw-rw-rw-	2012-04-16 19:30
Options.cpp	31.81 KB	-rw-rw-rw-	2012-04-16 19:30
Options.h	2.59 KB	-rw-rw-rw-	2012-04-16 19:30
Permissions.cpp	61.53 KB	-rw-rw-rw-	2012-04-16 19:30
Permissions.h	6.82 KB	-rw-rw-rw-	2012-04-16 19:30
Server.cpp	42.34 KB	-rw-rw-rw-	2012-04-16 19:30
Server.h	2.05 KB	-rw-rw-rw-	2012-04-16 19:30
ServerThread.cpp	26.13 KB	-rw-rw-rw-	2012-04-16 19:30
ServerThread.h	4.21 KB	-rw-rw-rw-	2012-04-16 19:30
Service.cpp	15.23 KB	-rw-rw-rw-	2012-04-16 19:30
SpeedLimit.cpp	6.87 KB	-rw-rw-rw-	2012-04-16 19:30
SpeedLimit.h	1.96 KB	-rw-rw-rw-	2012-04-16 19:30
StdAfx.cpp	4.41 KB	-rw-rw-rw-	2012-04-16 19:30
StdAfx.h	4.93 KB	-rw-rw-rw-	2012-04-16 19:30
Thread.cpp	2.85 KB	-rw-rw-rw-	2012-04-16 19:30
Thread.h	1.87 KB	-rw-rw-rw-	2012-04-16 19:30
TransferSocket.cpp	28.72 KB	-rw-rw-rw-	2012-04-16 19:30
TransferSocket.h	3.62 KB	-rw-rw-rw-	2012-04-16 19:30
autobanmanager.cpp	3.44 KB	-rw-rw-rw-	2012-04-16 19:30
autobanmanager.h	1.46 KB	-rw-rw-rw-	2012-04-16 19:30
config.h	1.52 KB	-rw-rw-rw-	2012-04-16 19:30
conversion.cpp	1.95 KB	-rw-rw-rw-	2012-04-16 19:30
conversion.h	435 B	-rw-rw-rw-	2012-04-16 19:30
defs.h	1.03 KB	-rw-rw-rw-	2012-04-16 19:30
hash_thread.cpp	4.79 KB	-rw-rw-rw-	2012-04-16 19:30
hash_thread.h	930 B	-rw-rw-rw-	2012-04-16 19:30
iputils.cpp	10.87 KB	-rw-rw-rw-	2012-04-16 19:30
iputils.h	1.32 KB	-rw-rw-rw-	2012-04-16 19:30
platform.h	1.43 KB	-rw-rw-rw-	2012-04-16 19:30
resource.h	515 B	-rw-rw-rw-	2012-04-16 19:30
version.cpp	4.32 KB	-rw-rw-rw-	2012-04-16 19:30
version.h	881 B	-rw-rw-rw-	2012-04-16 19:30
xml_utils.cpp	487 B	-rw-rw-rw-	2012-04-16 19:30
xml_utils.h	236 B	-rw-rw-rw-	2012-04-16 19:30

Rename

// FileZilla Server - a Windows ftp server

// This program is free software; you can redistribute it and/or
// modify it under the terms of the GNU General Public License
// as published by the Free Software Foundation; either version 2
// of the License, or (at your option) any later version.

// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.

// You should have received a copy of the GNU General Public License
// along with this program; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.

#include "stdafx.h"
#include "ExternalIpCheck.h"
#include "ServerThread.h"
#include "Options.h"

//////////////////////////////////////////////////////////////////////
// Konstruktion/Destruktion
//////////////////////////////////////////////////////////////////////

#define TIMERINTERVAL 30

CExternalIpCheck::CExternalIpCheck(CServerThread *pOwner)
{
	ASSERT(pOwner);
	m_pOwner = pOwner;

m_bActive = FALSE;
	m_nRetryCount = 0;
	m_nTimerID = SetTimer(0, 0, TIMERINTERVAL * 1000, 0);
	m_bTriggerUpdateCalled = FALSE;
	m_nFailedConnections = 0;
	m_nElapsedSeconds = 0;
	
	if (!m_pOwner->m_pOptions->GetOptionVal(OPTION_CUSTOMPASVIPTYPE))
		return;
	
	if (m_pOwner->m_pOptions->GetOptionVal(OPTION_CUSTOMPASVIPTYPE) == 2)
		Start();
	else if (m_pOwner->m_pOptions->GetOptionVal(OPTION_CUSTOMPASVIPTYPE) == 1)
	{
		CStdString hostname = m_pOwner->m_pOptions->GetOption(OPTION_CUSTOMPASVIP);
		SOCKADDR_IN sockAddr;
		memset(&sockAddr, 0, sizeof(sockAddr));
		
		sockAddr.sin_family = AF_INET;
#ifdef _UNICODE
		sockAddr.sin_addr.s_addr = inet_addr(ConvToLocal(hostname));
#else
		sockAddr.sin_addr.s_addr = inet_addr(hostname);
#endif
		
		if (sockAddr.sin_addr.s_addr == INADDR_NONE)
		{
			LPHOSTENT lphost;
#ifdef _UNICODE
			lphost = gethostbyname(ConvToLocal(hostname));
#else
			lphost = gethostbyname(hostname);
#endif
			if (lphost != NULL)

sockAddr.sin_addr.s_addr = ((LPIN_ADDR)lphost->h_addr)->s_addr;
			else
			{
				Close();
				m_nRetryCount++;
				m_bActive = FALSE;
				return;
			}
		}
		
		const char *ip = inet_ntoa(sockAddr.sin_addr);
		
		if (!ip)
			return;
		
#ifdef _UNICODE
		m_IP = ConvFromLocal(ip);
#else
		m_IP = ip;
#endif
	}
}

CExternalIpCheck::~CExternalIpCheck()
{
	Close();
}

void CExternalIpCheck::OnReceive(int nErrorCode)
{
	if (!m_bActive)
		return;

if (nErrorCode)
	{
		m_bActive = FALSE;
		Close();
		m_nRetryCount++;
		return;
	}
	char buffer[1000];
	int len = Receive(buffer, 999);

if (len == SOCKET_ERROR)
	{
		if (GetLastError() == WSAEWOULDBLOCK)
			return;
	
		Close();
		m_nRetryCount++;
		m_bActive = FALSE;
		return;
	}

buffer[len] = 0;
	char *p = strstr(buffer, "\r\n\r\n");
	if (!p)
		p = strstr(buffer, "\n\n");

if (!p)
	{
		Close();
		m_nRetryCount++;
		m_bActive = FALSE;
		return;
	}
	
	
	while (*p && (*p == '\n' || *p == '\r'))
		p++;

if (!*p)
	{
		Close();
		m_nRetryCount++;
		m_bActive = FALSE;
		return;
	}

char * ip = p;
	while (*p && *p != '\n' && *p != '\r')
		p++;
	*p = 0;
	
	SOCKADDR_IN sockAddr;
	memset(&sockAddr,0,sizeof(sockAddr));
	
	sockAddr.sin_family = AF_INET;
	sockAddr.sin_addr.s_addr = inet_addr(ip);
	
	if (sockAddr.sin_addr.s_addr == INADDR_NONE)
	{
		LPHOSTENT lphost;
		lphost = gethostbyname(ip);
		if (lphost != NULL)
			sockAddr.sin_addr.s_addr = ((LPIN_ADDR)lphost->h_addr)->s_addr;
		else
		{
			Close();
			m_nRetryCount++;
			m_bActive = FALSE;
			return;
		}
	}
	
	ip = inet_ntoa(sockAddr.sin_addr);

if (!ip)
	{		
		Close();
		m_nRetryCount++;
		m_bActive = FALSE;
		return;
	}
	
#ifdef _UNICODE
	m_IP = ConvFromLocal(ip);
#else
	m_IP = ip;
#endif

m_nFailedConnections = 0;

Close();
	m_nRetryCount = 0;
	m_bActive = FALSE;
}

void CExternalIpCheck::OnConnect(int nErrorCode)
{
	if (!m_bActive)
		return;

if (nErrorCode)
	{
		m_bActive = FALSE;
		Close();
		m_nRetryCount++;
		return;
	}
	
	CStdStringA address = "GET " + m_pOwner->m_pOptions->GetOption(OPTION_CUSTOMPASVIPSERVER) + " HTTP/1.0\r\nUser-Agent: FileZilla Server\r\n\r\n";
	const char *buffer = address;
	int len = strlen(buffer);
	if (Send(buffer, len) != len)
	{
		m_bActive = FALSE;
		Close();
		m_nRetryCount++;
	}

OnReceive(0);
}

void CExternalIpCheck::OnTimer()
{
	if (m_nElapsedSeconds <= 1000000)
		m_nElapsedSeconds += TIMERINTERVAL;

if (!m_pOwner->m_pOptions->GetOptionVal(OPTION_CUSTOMPASVIPTYPE))
	{
		m_nRetryCount = 0;
		Close();
		m_bActive = FALSE;
		return;
	}
	else if (m_pOwner->m_pOptions->GetOptionVal(OPTION_CUSTOMPASVIPTYPE) == 1)
	{
		m_nRetryCount = 0;
		Close();
		m_bActive = FALSE;

CStdString hostname = m_pOwner->m_pOptions->GetOption(OPTION_CUSTOMPASVIP);
		SOCKADDR_IN sockAddr;
		memset(&sockAddr,0,sizeof(sockAddr));
		
		sockAddr.sin_family = AF_INET;
#ifdef _UNICODE
		sockAddr.sin_addr.s_addr = inet_addr(ConvToLocal(hostname));
#else
		sockAddr.sin_addr.s_addr = inet_addr(hostname);
#endif
		
		if (sockAddr.sin_addr.s_addr == INADDR_NONE)
		{
			LPHOSTENT lphost;
#ifdef _UNICODE
			lphost = gethostbyname(ConvToLocal(hostname));
#else
			lphost = gethostbyname(hostname);
#endif
			if (lphost != NULL)
				sockAddr.sin_addr.s_addr = ((LPIN_ADDR)lphost->h_addr)->s_addr;
			else
			{
				Close();
				m_nRetryCount++;
				m_bActive = FALSE;
				return;
			}
		}
		
		const char *ip = inet_ntoa(sockAddr.sin_addr);
		
		if (!ip)
			return;
	
#ifdef _UNICODE
		m_IP = ConvFromLocal(ip);
#else
		m_IP = ip;
#endif
		m_nFailedConnections = 0;
		return;
	}

if (!m_bActive && m_nRetryCount)
	{
		if (m_nElapsedSeconds > 60 && m_nRetryCount < 5)
		{
			Start();
			return;
		}
		else if (m_nElapsedSeconds > 300 && m_nRetryCount < 10)
		{
			Start();
			return;
		}
		else if (m_nElapsedSeconds > 900 && m_nRetryCount < 20)
		{
			Start();
			return;
		}
		else if (m_nElapsedSeconds > 3600)
		{
			Start();
			return;
		}
	}
	else if (m_bActive)
	{
		if (m_nElapsedSeconds > 30)
		{
			m_bActive = FALSE;
			Close();
			m_nRetryCount++;
			m_nElapsedSeconds = 0;
		}
	}
	else
	{
		if (m_nElapsedSeconds > 300 && m_bTriggerUpdateCalled)
			Start();
		else if (m_nElapsedSeconds > 3600)
			Start();
	}
}

void CExternalIpCheck::OnClose(int nErrorCode)
{
	if (m_bActive)
	{
		m_bActive = FALSE;
		Close();
		m_nRetryCount++;
	}
}

void CExternalIpCheck::Start()
{
	if (m_bActive)
		return;

CStdString address = m_pOwner->m_pOptions->GetOption(OPTION_CUSTOMPASVIPSERVER);
	if (address.Left(7) == _T("http://"))
		address = address.Mid(7);
	int pos = address.Find('/');
	if (pos != -1)
		address = address.Left(pos);
	if (address == _T(""))
		return;

m_bTriggerUpdateCalled = FALSE;

m_nElapsedSeconds = 0;
	Create();

BOOL res = Connect(address, 80);
	if (res == SOCKET_ERROR && GetLastError() != WSAEWOULDBLOCK)
		m_nRetryCount++;
	else
		m_bActive = TRUE;
}

void CExternalIpCheck::TriggerUpdate()
{
	if (m_bActive)
		return;

m_bTriggerUpdateCalled = TRUE;
	if (m_nFailedConnections < 100000)
		m_nFailedConnections++;
}

CStdString CExternalIpCheck::GetIP(const CStdString& localIP)
{
	if (!m_pOwner->m_pOptions->GetOptionVal(OPTION_CUSTOMPASVIPTYPE))
		return _T("");

CStdString ip;
	switch (m_pOwner->m_pOptions->GetOptionVal(OPTION_CUSTOMPASVIPTYPE))
	{
	case 0:
		return _T("");
	case 2:
		if (!m_bActive && !m_nRetryCount && localIP != _T(""))
		{
			if (localIP == m_IP)
				m_nElapsedSeconds = 0;
		}
	case 1:
		ip = m_IP;
		
		break;
	}
	
	return ip;
}