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

#include "StdAfx.h"
#include "hash_thread.h"
#include "misc\md5.h"
#include "ServerThread.h"

#define SHA512_STANDALONE
typedef unsigned int uint32;
#include "hash_algorithms/int64.h"
#include "hash_algorithms/sshsh512.c"
#include "hash_algorithms/sshsha.c"

CHashThread::CHashThread()
{
	m_filename = 0;
	m_quit = false;
	m_id = 0;
	m_active_id = 0;
	m_result = OK;
	m_hash = 0;
	m_server_thread = 0;
	m_algorithm = SHA512;

m_hThread = CreateThread(0, 0, &CHashThread::ThreadFunc, this, 0, 0);

}

CHashThread::~CHashThread()
{
	m_sync.Lock();
	m_quit = true;
	m_server_thread = 0;
	delete [] m_filename;
	delete [] m_hash;
	m_sync.Unlock();

WaitForSingleObject(m_hThread, INFINITE);

CloseHandle(m_hThread);
}

DWORD CHashThread::ThreadFunc(LPVOID pThis)
{
	((CHashThread*)pThis)->Loop();

return 0;
}

namespace {
char* toHex(unsigned char* buffer, unsigned int len)
{
	char* hex = new char[len * 2 + 1];
	hex[len * 2] = 0;

for (unsigned int i = 0; i < len; i++)
	{
		unsigned char l = buffer[i] >> 4;
		unsigned char r = buffer[i] & 0x0F;

if (l > 9)
			hex[i * 2] = 'a' + l - 10;
		else
			hex[i * 2] = '0' + l;

if (r > 9)
			hex[i * 2 + 1] = 'a' + r - 10;
		else
			hex[i * 2 + 1] = '0' + r;
	}

return hex;
}
}

void CHashThread::DoHash()
{
	if (!m_filename)
		return;

LPCTSTR file = m_filename;
	m_filename = 0;

m_sync.Unlock();

int shareMode = FILE_SHARE_READ;
	HANDLE hFile = CreateFile(file, GENERIC_READ, shareMode, 0, OPEN_EXISTING, FILE_FLAG_BACKUP_SEMANTICS, 0);
	delete [] file;
	
	if (hFile == INVALID_HANDLE_VALUE)
	{
		m_sync.Lock();
		m_result = FAILURE_OPEN;
		if (m_server_thread)
			m_server_thread->PostThreadMessage(WM_FILEZILLA_THREADMSG, FTM_HASHRESULT, m_active_id);
		return;
	}

const enum _algorithm alg = m_algorithm;

void* data;
	switch (alg)
	{
	case MD5:
		data = new ::MD5;
		break;
	case SHA512:
		data = new SHA512_State;
		SHA512_Init((SHA512_State*)data);
		break;
	case SHA1:
		data = new SHA_State;
		SHA_Init((SHA_State*)data);
		break;
	}

unsigned char buffer[262144];
	DWORD read = 0;
	BOOL res = 0;
	while ((res = ReadFile(hFile, buffer, 262144, &read, 0) != 0) && read > 0)
	{
		switch (alg)
		{
		case MD5:
			((::MD5*)data)->update(buffer, read);
			break;
		case SHA512:
			SHA512_Bytes((SHA512_State*)data, buffer, read);
			break;
		case SHA1:
			SHA_Bytes((SHA_State*)data, buffer, read);
			break;
		}

m_sync.Lock();
		if (!m_server_thread)
		{
			CloseHandle(hFile);
			return;
		}
		m_sync.Unlock();
	}

CloseHandle(hFile);

if (!res)
	{
		m_sync.Lock();
		m_result = FAILURE_READ;
		if (m_server_thread)
			m_server_thread->PostThreadMessage(WM_FILEZILLA_THREADMSG, FTM_HASHRESULT, m_active_id);
		return;
	}

m_sync.Lock();

switch (alg)
	{
	case MD5:
		((::MD5*)data)->finalize();
		m_hash = ((::MD5*)data)->hex_digest();
		break;
	case SHA512:
		{
			unsigned char digest[64];
			SHA512_Final((SHA512_State*)data, digest);
			m_hash = toHex(digest, 64);
		}
		break;
	case SHA1:
		{
			unsigned char digest[20];
			SHA_Final((SHA_State*)data, digest);
			m_hash = toHex(digest, 20);
		}
		break;
	}
	m_result = m_hash ? OK : FAILURE_READ;
	if (m_server_thread)
		m_server_thread->PostThreadMessage(WM_FILEZILLA_THREADMSG, FTM_HASHRESULT, m_active_id);
}

void CHashThread::Loop()
{
	m_sync.Lock();
	while (!m_quit)
	{
		DoHash();
		m_sync.Unlock();
		Sleep(100);
		m_sync.Lock();
	}
}

enum CHashThread::_result CHashThread::Hash(LPCTSTR file, enum _algorithm algorithm, int& id, CServerThread* server_thread)
{
	m_sync.Lock();
	if (m_active_id)
	{
		m_sync.Unlock();
		return BUSY;
	}

++m_id;
	if (m_id > 1000000)
		m_id = 1;
	id = m_id;
	m_active_id = id;

delete [] m_hash;
	m_hash = 0;

delete [] m_filename;
	m_filename = new TCHAR[_tcslen(file) + 1];
	_tcscpy(m_filename, file);

m_server_thread = server_thread;
	m_algorithm = algorithm;

m_result = PENDING;

m_sync.Unlock();

return PENDING;
}

enum CHashThread::_result CHashThread::GetResult(int id, CHashThread::_algorithm& alg, CStdString& hash, CStdString& file)
{
	if (id <= 0)
		return FAILURE_MASK;
	
	m_sync.Lock();
	
	if (id != m_active_id)
	{
		m_sync.Unlock();
		return BUSY;
	}

if (m_result == PENDING) 
	{
		m_sync.Unlock();
		return PENDING;
	}

alg = m_algorithm;
	file = m_filename;

delete [] m_filename;
	m_filename = 0;

m_active_id = 0;

if (m_result == OK)
	{
		hash = m_hash;
		delete [] m_hash;
		m_hash = 0;
		m_sync.Unlock();
		return OK;
	}

m_sync.Unlock();

return m_result;
}

void CHashThread::Stop(CServerThread* server_thread)
{
	m_sync.Lock();
	if (m_server_thread == server_thread)
		m_server_thread = 0;
	m_sync.Unlock();
}