not used file removed

git-svn-id: http://svn.miranda-ng.org/main/trunk@5936 1316c22d-e87f-b044-9b9b-93d7a3e3ba9c

2 files changed, 0 insertions, 1299 deletions

diff --git a/protocols/MRA/src/Mra.h b/protocols/MRA/src/Mra.h
index 6bf731966f..9805c91346 100644
--- a/protocols/MRA/src/Mra.h
+++ b/protocols/MRA/src/Mra.h
@@ -81,7 +81,6 @@
 #include "Sdk/MemoryFind.h"

 #include "Sdk/MemoryFindByte.h"

 #include "Sdk/BuffToLowerCase.h"

-#include "Sdk/StrToNum.h"

 #include "Sdk/StrHexToNum.h"

 #include "Sdk/timefuncs.h"

 #include "Sdk/InternetTime.h"

diff --git a/protocols/MRA/src/MraFilesQueue_mod.cpp b/protocols/MRA/src/MraFilesQueue_mod.cpp
deleted file mode 100644
index 41339a766b..0000000000
--- a/protocols/MRA/src/MraFilesQueue_mod.cpp
+++ /dev/null
@@ -1,1298 +0,0 @@
-#include <SystemHeaders.h>

-#include <MemoryFindByte.h>

-#include <MemoryCompare.h>

-#include <BuffToLowerCase.h>

-#include <ListMT.h>

-#include <StrToNum.h>

-#include "MraFilesQueue.h"

-#include "proto.h"

-#include "Mra.h"

-

-

-

-#define MRA_FT_HELLO	"MRA_FT_HELLO"

-#define MRA_FT_GET_FILE	"MRA_FT_GET_FILE"

-

-

-

-typedef struct

-{

-	LIST_MT			lmtListMT;

-	DWORD			dwSendTimeOutInterval;

-} MRA_FILES_QUEUE;

-

-

-

-struct MRA_FILES_QUEUE_FILE

-{

-	LPSTR	lpszName;

-	SIZE_T	dwNameLen;

-	SIZE_T	dwSize;

-};

-

-struct MRA_FILES_QUEUE_ADDR

-{

-	DWORD	dwIP;

-	DWORD	dwPort;

-};

-

-

-typedef struct

-{

-	// internal

-	LIST_MT_ITEM			lmtListMTItem;

-	DWORD					dwSendTime;

-	// external

-	DWORD					dwIDRequest;

-	DWORD					dwFlags;

-	HANDLE					hContact;

-	DWORD					dwFilesCount;

-	DWORD					dwFilesTotalSize;

-	DWORD					dwAddrCount;

-	LPSTR					lpszDescription;

-	SIZE_T					dwDescriptionSize;

-	MRA_FILES_QUEUE_FILE	*pmfqfFiles;

-	MRA_FILES_QUEUE_ADDR	*pmfqaAddreses;

-	LPSTR					lpszPath;

-	SIZE_T					dwPathSize;

-	BOOL					bSending;

-	HANDLE					hConnection;

-	HANDLE					hListen;

-	HANDLE					hThread;

-	HANDLE					hWaitHandle;

-

-} MRA_FILES_QUEUE_ITEM;

-

-

-

-struct MRA_FILES_THREADPROC_PARAMS

-{

-	HANDLE					hFilesQueueHandle;

-	MRA_FILES_QUEUE_ITEM	*pmrafqFilesQueueItem;

-};

-

-

-

-//#define MEMALLOC(Size)		HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY,(Size+sizeof(SIZE_T)))

-//#define MEMREALLOC(Mem,Size)	HeapReAlloc(GetProcessHeap(),(HEAP_ZERO_MEMORY),(LPVOID)Mem,(Size+sizeof(SIZE_T)))

-//#define MEMFREE(Mem)			if (Mem) {HeapFree(GetProcessHeap(),0,(LPVOID)Mem);Mem=NULL;}

-

-

-DWORD			MraFilesQueueItemFindByID			(HANDLE hFilesQueueHandle,DWORD dwIDRequest,MRA_FILES_QUEUE_ITEM **ppmrafqFilesQueueItem);

-DWORD			MraFilesQueueItemFindByEMail		(HANDLE hFilesQueueHandle,LPSTR lpszEMail,SIZE_T dwEMailSize,MRA_FILES_QUEUE_ITEM **ppmrafqFilesQueueItem);

-void			MraFilesQueueItemFree				(MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem);

-SIZE_T			MraFilesQueueGetLocalAddressesList	(LPSTR lpszBuff,SIZE_T dwBuffSize,DWORD dwPort);

-

-BOOL			MraFilesQueueHandCheck				(HANDLE hConnection,MRA_FILES_QUEUE_ITEM **ppmrafqFilesQueueItem);

-void			MraFilesQueueConnectionReceived		(HANDLE hNewConnection,DWORD dwRemoteIP,void *pExtra);

-

-DWORD WINAPI	MraFilesQueueRecvThreadProc			(LPVOID lpParameter);

-DWORD WINAPI	MraFilesQueueSendThreadProc			(LPVOID lpParameter);

-

-

-

-BOOL CALLBACK MraFilesQueueDlgProcOpts(HWND hWndDlg, UINT msg, WPARAM wParam, LPARAM lParam)

-{

-	switch(msg){

-	case WM_INITDIALOG:

-		{

-			DBVARIANT dbv;

-			TranslateDialogDefault(hWndDlg);

-

-			CheckDlgButton(hWndDlg,IDC_FILE_SEND_HIDE_MY_NOOUTCONNECTIONONRECEIVE,DB_Mra_GetByte(NULL,"FileSendNoOutConnOnRcv",MRA_DEF_FS_NO_OUT_CONN_ON_RCV));

-			CheckDlgButton(hWndDlg,IDC_FILE_SEND_HIDE_MY_NOOUTCONNECTIONONSEND,DB_Mra_GetByte(NULL,"FileSendNoOutConnOnSend",MRA_DEF_FS_NO_OUT_CONN_ON_SEND));

-			CheckDlgButton(hWndDlg,IDC_FILE_SEND_IGNORYADDITIONALPORTS,DB_Mra_GetByte(NULL,"FileSendIgnoryAdditionalPorts",MRA_DEF_FS_IGNORY_ADDITIONAL_PORTS));

-			CheckDlgButton(hWndDlg,IDC_FILE_SEND_HIDE_MY_ADDRESSES,DB_Mra_GetByte(NULL,"FileSendHideMyAddresses",MRA_DEF_FS_HIDE_MY_ADDRESSES));

-			CheckDlgButton(hWndDlg,IDC_FILE_SEND_ADD_EXTRA_ADDRESS,DB_Mra_GetByte(NULL,"FileSendAddExtraAddresses",MRA_DEF_FS_ADD_EXTRA_ADDRESSES));

-			if (!DBGetContactSetting(NULL,PROTOCOL_NAME,"FileSendExtraAddresses",&dbv)) {

-				//bit of a security hole here, since it's easy to extract a password from an edit box

-				SetDlgItemText(hWndDlg,IDC_FILE_SEND_EXTRA_ADDRESS,dbv.pszVal);

-				DBFreeVariant(&dbv);

-			}

-			EnableWindow(GetDlgItem(hWndDlg,IDC_FILE_SEND_EXTRA_ADDRESS),IsDlgButtonChecked(hWndDlg,IDC_FILE_SEND_ADD_EXTRA_ADDRESS));

-

-			SetDlgItemInt(hWndDlg,IDC_FILE_SEND_BLOCK_SIZE,DB_Mra_GetDword(NULL,"FileSendBlockSize",MRA_DEFAULT_FILE_SEND_BLOCK_SIZE),FALSE);

-		}

-		return(TRUE);

-	case WM_COMMAND:

-		if (LOWORD(wParam)==IDC_FILE_SEND_ADD_EXTRA_ADDRESS)

-		{

-			EnableWindow(GetDlgItem(hWndDlg,IDC_FILE_SEND_EXTRA_ADDRESS),IsDlgButtonChecked(hWndDlg,IDC_FILE_SEND_ADD_EXTRA_ADDRESS));

-		}

-

-		if ((LOWORD(wParam)==IDC_FILE_SEND_EXTRA_ADDRESS || LOWORD(wParam)==IDC_FILE_SEND_BLOCK_SIZE) && (HIWORD(wParam)!=EN_CHANGE || (HWND)lParam!=GetFocus()) ) return(0);

-		SendMessage(GetParent(hWndDlg),PSM_CHANGED,0,0);

-		break;

-	case WM_NOTIFY:

-		switch (((LPNMHDR)lParam)->code){

-		case PSN_APPLY:

-			{

-				char szBuff[MAX_PATH];

-

-				DB_Mra_SetByte(NULL,"FileSendNoOutConnOnRcv",IsDlgButtonChecked(hWndDlg,IDC_FILE_SEND_HIDE_MY_NOOUTCONNECTIONONRECEIVE));

-				DB_Mra_SetByte(NULL,"FileSendNoOutConnOnSend",IsDlgButtonChecked(hWndDlg,IDC_FILE_SEND_HIDE_MY_NOOUTCONNECTIONONSEND));

-				DB_Mra_SetByte(NULL,"FileSendIgnoryAdditionalPorts",IsDlgButtonChecked(hWndDlg,IDC_FILE_SEND_IGNORYADDITIONALPORTS));

-				DB_Mra_SetByte(NULL,"FileSendHideMyAddresses",IsDlgButtonChecked(hWndDlg,IDC_FILE_SEND_HIDE_MY_ADDRESSES));

-				DB_Mra_SetByte(NULL,"FileSendAddExtraAddresses",IsDlgButtonChecked(hWndDlg,IDC_FILE_SEND_ADD_EXTRA_ADDRESS));

-				GetDlgItemText(hWndDlg,IDC_FILE_SEND_EXTRA_ADDRESS,szBuff,sizeof(szBuff));

-				DBWriteContactSettingString(NULL,PROTOCOL_NAME,"FileSendExtraAddresses",szBuff);

-				DB_Mra_SetDword(NULL,"FileSendBlockSize",(DWORD)GetDlgItemInt(hWndDlg,IDC_FILE_SEND_BLOCK_SIZE,NULL,FALSE));

-			}

-			return(TRUE);

-		}

-		break;

-	}

-return(FALSE);

-}

-

-

-

-DWORD MraFilesQueueInitialize(DWORD dwSendTimeOutInterval,HANDLE *phFilesQueueHandle)

-{

-	DWORD dwRetErrorCode;

-

-	if (phFilesQueueHandle)

-	{

-		MRA_FILES_QUEUE *pmrafqFilesQueue;

-

-		pmrafqFilesQueue=(MRA_FILES_QUEUE*)MEMALLOC(sizeof(MRA_FILES_QUEUE));

-		if (pmrafqFilesQueue)

-		{

-			dwRetErrorCode=ListMTInitialize(&pmrafqFilesQueue->lmtListMT,0);

-			if (dwRetErrorCode==NO_ERROR)

-			{

-				pmrafqFilesQueue->dwSendTimeOutInterval=dwSendTimeOutInterval;

-				(*phFilesQueueHandle)=(HANDLE)pmrafqFilesQueue;

-			}else{

-				MEMFREE(pmrafqFilesQueue);

-			}

-		}else{

-			dwRetErrorCode=GetLastError();

-		}

-	}else{

-		dwRetErrorCode=ERROR_INVALID_HANDLE;

-	}

-return(dwRetErrorCode);

-}

-

-

-void MraFilesQueueDestroy(HANDLE hFilesQueueHandle)

-{

-	if (hFilesQueueHandle)

-	{

-		MRA_FILES_QUEUE *pmrafqFilesQueue=(MRA_FILES_QUEUE*)hFilesQueueHandle;

-		MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem;

-

-		ListMTLock(&pmrafqFilesQueue->lmtListMT);

-		while(ListMTItemGetFirst(&pmrafqFilesQueue->lmtListMT,NULL,(LPVOID*)&pmrafqFilesQueueItem)==NO_ERROR)

-		{

-			ListMTItemDelete(&pmrafqFilesQueue->lmtListMT,&pmrafqFilesQueueItem->lmtListMTItem);

-			MraFilesQueueItemFree(pmrafqFilesQueueItem);

-		}

-		ListMTUnLock(&pmrafqFilesQueue->lmtListMT);

-

-		ListMTDestroy(&pmrafqFilesQueue->lmtListMT);

-		MEMFREE(pmrafqFilesQueue);

-	}

-}

-

-

-DWORD MraFilesQueueItemFindByID(HANDLE hFilesQueueHandle,DWORD dwIDRequest,MRA_FILES_QUEUE_ITEM **ppmrafqFilesQueueItem)

-{

-	DWORD dwRetErrorCode;

-

-	if (hFilesQueueHandle)

-	{

-		MRA_FILES_QUEUE *pmrafqFilesQueue=(MRA_FILES_QUEUE*)hFilesQueueHandle;

-		MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem;

-		LIST_MT_ITERATOR lmtiIterator;

-

-		dwRetErrorCode=ERROR_NOT_FOUND;

-		ListMTLock(&pmrafqFilesQueue->lmtListMT);

-		ListMTIteratorMoveFirst(&pmrafqFilesQueue->lmtListMT,&lmtiIterator);

-		do

-		{// цикл

-			if (ListMTIteratorGet(&lmtiIterator,NULL,(LPVOID*)&pmrafqFilesQueueItem)==NO_ERROR)

-			if (pmrafqFilesQueueItem->dwIDRequest==dwIDRequest)

-			{

-				if (ppmrafqFilesQueueItem) (*ppmrafqFilesQueueItem)=pmrafqFilesQueueItem;

-				dwRetErrorCode=NO_ERROR;

-				break;

-			}

-		}while(ListMTIteratorMoveNext(&lmtiIterator));

-		ListMTUnLock(&pmrafqFilesQueue->lmtListMT);

-	}else{

-		dwRetErrorCode=ERROR_INVALID_HANDLE;

-	}

-return(dwRetErrorCode);

-}

-

-

-DWORD MraFilesQueueItemFindByEMail(HANDLE hFilesQueueHandle,LPSTR lpszEMail,SIZE_T dwEMailSize,MRA_FILES_QUEUE_ITEM **ppmrafqFilesQueueItem)

-{

-	DWORD dwRetErrorCode;

-

-	if (hFilesQueueHandle)

-	{

-		char szEMailLocal[MAX_EMAIL_LEN];

-		SIZE_T dwEMailLocalSize;

-		MRA_FILES_QUEUE *pmrafqFilesQueue=(MRA_FILES_QUEUE*)hFilesQueueHandle;

-		MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem;

-		LIST_MT_ITERATOR lmtiIterator;

-

-		dwRetErrorCode=ERROR_NOT_FOUND;

-		ListMTLock(&pmrafqFilesQueue->lmtListMT);

-		ListMTIteratorMoveFirst(&pmrafqFilesQueue->lmtListMT,&lmtiIterator);

-		do

-		{// цикл

-			if (ListMTIteratorGet(&lmtiIterator,NULL,(LPVOID*)&pmrafqFilesQueueItem)==NO_ERROR)

-			if (DB_Mra_GetStaticString(pmrafqFilesQueueItem->hContact,"e-mail",szEMailLocal,sizeof(szEMailLocal),&dwEMailLocalSize))

-			if (dwEMailSize==dwEMailLocalSize)

-			if (CompareStringA(MAKELANGID(LANG_ENGLISH,SUBLANG_ENGLISH_US),NORM_IGNORECASE,lpszEMail,dwEMailSize,szEMailLocal,dwEMailLocalSize)==CSTR_EQUAL)

-			{

-				if (ppmrafqFilesQueueItem) (*ppmrafqFilesQueueItem)=pmrafqFilesQueueItem;

-				dwRetErrorCode=NO_ERROR;

-				break;

-			}

-		}while(ListMTIteratorMoveNext(&lmtiIterator));

-		ListMTUnLock(&pmrafqFilesQueue->lmtListMT);

-	}else{

-		dwRetErrorCode=ERROR_INVALID_HANDLE;

-	}

-return(dwRetErrorCode);

-}

-

-

-void MraFilesQueueItemFree(MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem)

-{

-

-	for(SIZE_T i=0;i<pmrafqFilesQueueItem->dwFilesCount;i++)

-	{

-		MEMFREE(pmrafqFilesQueueItem->pmfqfFiles[i].lpszName);

-	}

-	MEMFREE(pmrafqFilesQueueItem->pmfqfFiles);

-	MEMFREE(pmrafqFilesQueueItem->pmfqaAddreses);

-	MEMFREE(pmrafqFilesQueueItem->lpszPath);

-	//MEMFREE(pmrafqFilesQueueItem->lpszDescription); //placed after pmrafqFilesQueueItem

-	MEMFREE(pmrafqFilesQueueItem);

-}

-

-

-

-

-

-SIZE_T MraFilesQueueGetLocalAddressesList(LPSTR lpszBuff,SIZE_T dwBuffSize,DWORD dwPort)

-{

-	char szHostName[MAX_PATH]={0};

-	LPSTR lpszCurPos=lpszBuff;

-	SIZE_T dwAdapter=0;

-	hostent *sh;

-

-	if (DB_Mra_GetByte(NULL,"FileSendHideMyAddresses",MRA_DEF_FS_HIDE_MY_ADDRESSES))

-	{// не выдаём врагу наш IP адрес!!! :)

-		lpszCurPos+=mir_snprintf(lpszCurPos,(dwBuffSize-(lpszCurPos-lpszBuff)),"192.168.0.1:26775;");

-	}else{// создаём список наших IP адресов

-		if (gethostname(szHostName,sizeof(szHostName))==0)

-		if ((sh=gethostbyname((LPSTR)&szHostName)))

-		{

-			while(sh->h_addr_list[dwAdapter])

-			{

-				lpszCurPos+=mir_snprintf(lpszCurPos,(dwBuffSize-(lpszCurPos-lpszBuff)),"%s:%ld;",inet_ntoa(*((struct in_addr*)sh->h_addr_list[dwAdapter])),dwPort);

-				dwAdapter++;

-			}

-		}

-	}

-

-	if (DB_Mra_GetByte(NULL,"FileSendAddExtraAddresses",MRA_DEF_FS_ADD_EXTRA_ADDRESSES))// добавляем произвольный адрес

-	if (DB_Mra_GetStaticString(NULL,"FileSendExtraAddresses",szHostName,sizeof(szHostName),NULL))

-	{

-		lpszCurPos+=mir_snprintf(lpszCurPos,(dwBuffSize-(lpszCurPos-lpszBuff)),"%s:%ld;",szHostName,dwPort);

-	}

-return((lpszCurPos-lpszBuff));

-}

-

-

-

-

-DWORD MraFilesQueueAddReceive(HANDLE hFilesQueueHandle,DWORD dwFlags,HANDLE hContact,DWORD dwIDRequest,DWORD dwFilesTotalSize,LPSTR lpszFiles,SIZE_T dwFilesSize,LPSTR lpszDescription,SIZE_T dwDescriptionSize,LPSTR lpszAddreses,SIZE_T dwAddresesSize)

-{

-	DWORD dwRetErrorCode;

-

-	if (hFilesQueueHandle && dwIDRequest)

-	{

-		MRA_FILES_QUEUE *pmrafqFilesQueue=(MRA_FILES_QUEUE*)hFilesQueueHandle;

-		MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem;

-

-		if (!lpszDescription || dwDescriptionSize==0)

-		{

-			lpszDescription=Translate("No description given");

-			dwDescriptionSize=lstrlenA(lpszDescription);

-		}

-

-		pmrafqFilesQueueItem=(MRA_FILES_QUEUE_ITEM*)MEMALLOC(sizeof(MRA_FILES_QUEUE_ITEM)+sizeof(LPSTR)+dwDescriptionSize+64);

-		if (pmrafqFilesQueueItem)

-		{

-			char szBuff[MAX_PATH];

-			LPSTR lpszCurrentItem,lpszDelimiter,lpszEndItem,lpszBlob;

-			SIZE_T dwMemSize,dwAllocatedCount;

-			CCSDATA ccs;

-			PROTORECVEVENT pre;

-

-			//pmrafqFilesQueueItem->lmtListMTItem;

-			pmrafqFilesQueueItem->dwSendTime=GetTickCount();

-			pmrafqFilesQueueItem->dwIDRequest=dwIDRequest;

-			pmrafqFilesQueueItem->dwFlags=dwFlags;

-			pmrafqFilesQueueItem->hContact=hContact;

-			pmrafqFilesQueueItem->lpszDescription=(LPSTR)(pmrafqFilesQueueItem+1);

-			pmrafqFilesQueueItem->dwDescriptionSize=dwDescriptionSize;

-			CopyMemory(pmrafqFilesQueueItem->lpszDescription,lpszDescription,dwDescriptionSize);

-

-

-			dwAllocatedCount=ALLOCATED_COUNT;

-			pmrafqFilesQueueItem->dwFilesCount=0;

-			pmrafqFilesQueueItem->dwFilesTotalSize=dwFilesTotalSize;

-			pmrafqFilesQueueItem->pmfqfFiles=(MRA_FILES_QUEUE_FILE*)MEMALLOC((sizeof(MRA_FILES_QUEUE_FILE)*dwAllocatedCount));

-			lpszCurrentItem=lpszFiles;

-			while(TRUE)

-			{

-				lpszDelimiter=(LPSTR)MemoryFindByte((lpszCurrentItem-lpszFiles),lpszFiles,dwFilesSize,';');

-				if (lpszDelimiter)

-				{

-					lpszEndItem=(LPSTR)MemoryFindByte(((lpszDelimiter+1)-lpszFiles),lpszFiles,dwFilesSize,';');

-					if (lpszEndItem)

-					{

-						if (pmrafqFilesQueueItem->dwFilesCount==dwAllocatedCount)

-						{

-							dwAllocatedCount*=2;

-							pmrafqFilesQueueItem->pmfqfFiles=(MRA_FILES_QUEUE_FILE*)MEMREALLOC(pmrafqFilesQueueItem->pmfqfFiles,(sizeof(MRA_FILES_QUEUE_FILE)*dwAllocatedCount));

-						}

-

-						dwMemSize=(lpszDelimiter-lpszCurrentItem);

-						pmrafqFilesQueueItem->pmfqfFiles[pmrafqFilesQueueItem->dwFilesCount].lpszName=(LPSTR)MEMALLOC(dwMemSize);

-						CopyMemory(pmrafqFilesQueueItem->pmfqfFiles[pmrafqFilesQueueItem->dwFilesCount].lpszName,lpszCurrentItem,dwMemSize);

-						pmrafqFilesQueueItem->pmfqfFiles[pmrafqFilesQueueItem->dwFilesCount].dwNameLen=dwMemSize;

-						pmrafqFilesQueueItem->pmfqfFiles[pmrafqFilesQueueItem->dwFilesCount].dwSize=StrToUNum32((lpszDelimiter+1),(lpszEndItem-(lpszDelimiter+1)));

-

-						pmrafqFilesQueueItem->dwFilesCount++;

-						lpszCurrentItem=(lpszEndItem+1);

-					}else{

-						break;

-					}

-				}else{

-					break;

-				}

-			}

-			pmrafqFilesQueueItem->pmfqfFiles=(MRA_FILES_QUEUE_FILE*)MEMREALLOC(pmrafqFilesQueueItem->pmfqfFiles,(sizeof(MRA_FILES_QUEUE_FILE)*pmrafqFilesQueueItem->dwFilesCount));

-

-

-			dwAllocatedCount=ALLOCATED_COUNT;

-			pmrafqFilesQueueItem->dwAddrCount=0;

-			pmrafqFilesQueueItem->pmfqaAddreses=(MRA_FILES_QUEUE_ADDR*)MEMALLOC(sizeof(MRA_FILES_QUEUE_ADDR)*dwAllocatedCount);

-			lpszCurrentItem=lpszAddreses;

-			while(TRUE)

-			{

-				lpszEndItem=(LPSTR)MemoryFindByte((lpszCurrentItem-lpszAddreses),lpszAddreses,dwAddresesSize,';');

-				if (lpszEndItem)

-				{

-					lpszDelimiter=(LPSTR)MemoryFindByte((lpszCurrentItem-lpszAddreses),lpszAddreses,dwAddresesSize,':');

-					if (lpszDelimiter)

-					{

-						if (pmrafqFilesQueueItem->dwAddrCount==dwAllocatedCount)

-						{

-							dwAllocatedCount*=2;

-							pmrafqFilesQueueItem->pmfqaAddreses=(MRA_FILES_QUEUE_ADDR*)MEMREALLOC(pmrafqFilesQueueItem->pmfqaAddreses,(sizeof(MRA_FILES_QUEUE_ADDR)*dwAllocatedCount));

-						}

-

-						(*lpszDelimiter)=0;

-						pmrafqFilesQueueItem->pmfqaAddreses[pmrafqFilesQueueItem->dwAddrCount].dwIP=inet_addr(lpszCurrentItem);

-						pmrafqFilesQueueItem->pmfqaAddreses[pmrafqFilesQueueItem->dwAddrCount].dwPort=StrToUNum32((lpszDelimiter+1),(lpszEndItem-(lpszDelimiter+1)));

-						(*lpszDelimiter)=':';

-

-						switch(pmrafqFilesQueueItem->dwAddrCount){

-						case 0:

-							DB_Mra_SetDword(pmrafqFilesQueueItem->hContact,"OldIP",DB_Mra_GetDword(pmrafqFilesQueueItem->hContact,"IP",0));DB_Mra_SetDword(pmrafqFilesQueueItem->hContact,"IP",htonl(pmrafqFilesQueueItem->pmfqaAddreses[pmrafqFilesQueueItem->dwAddrCount].dwIP));

-							break;

-						case 1:

-							DB_Mra_SetDword(pmrafqFilesQueueItem->hContact,"OldRealIP",DB_Mra_GetDword(pmrafqFilesQueueItem->hContact,"RealIP",0));DB_Mra_SetDword(pmrafqFilesQueueItem->hContact,"RealIP",htonl(pmrafqFilesQueueItem->pmfqaAddreses[pmrafqFilesQueueItem->dwAddrCount].dwIP));

-							break;

-						}

-						pmrafqFilesQueueItem->dwAddrCount++;

-						lpszCurrentItem=(lpszEndItem+1);

-					}else{

-						break;

-					}

-				}else{

-					break;

-				}

-			}

-			pmrafqFilesQueueItem->pmfqaAddreses=(MRA_FILES_QUEUE_ADDR*)MEMREALLOC(pmrafqFilesQueueItem->pmfqaAddreses,(sizeof(MRA_FILES_QUEUE_ADDR)*pmrafqFilesQueueItem->dwAddrCount));

-

-			ListMTLock(&pmrafqFilesQueue->lmtListMT);

-			ListMTItemAdd(&pmrafqFilesQueue->lmtListMT,&pmrafqFilesQueueItem->lmtListMTItem,pmrafqFilesQueueItem);

-			ListMTUnLock(&pmrafqFilesQueue->lmtListMT);

-

-

-			// Send chain event

-			dwMemSize=(sizeof(DWORD)+dwDescriptionSize+dwAddresesSize+sizeof(SIZE_T));

-			for(SIZE_T i=0;i<pmrafqFilesQueueItem->dwFilesCount;i++)

-			{

-				dwMemSize+=(pmrafqFilesQueueItem->pmfqfFiles[i].dwNameLen+64);

-			}

-			lpszBlob=(LPSTR)MEMALLOC(dwMemSize);

-			lpszCurrentItem=lpszBlob;

-			// user data

-            (*((DWORD*)lpszCurrentItem))=dwIDRequest;lpszCurrentItem+=sizeof(DWORD);

-			// file name

-			StrFormatByteSizeA(pmrafqFilesQueueItem->dwFilesTotalSize,szBuff,sizeof(szBuff));

-			lpszCurrentItem+=(mir_snprintf(lpszCurrentItem,(dwMemSize-(lpszCurrentItem-lpszBlob)),"%ld Files (%s)",pmrafqFilesQueueItem->dwFilesCount,szBuff)+1);

-			// description

-			for(SIZE_T i=0;i<pmrafqFilesQueueItem->dwFilesCount;i++)

-			{

-				StrFormatByteSizeA(pmrafqFilesQueueItem->pmfqfFiles[i].dwSize,szBuff,sizeof(szBuff));

-				lpszCurrentItem+=mir_snprintf(lpszCurrentItem,(dwMemSize-(lpszCurrentItem-lpszBlob)),"%s - %s\r\n",pmrafqFilesQueueItem->pmfqfFiles[i].lpszName,szBuff);

-			}

-			CopyMemory(lpszCurrentItem,lpszAddreses,dwAddresesSize);lpszCurrentItem+=dwAddresesSize;

-			lpszCurrentItem+=(mir_snprintf(lpszCurrentItem,(dwMemSize-(lpszCurrentItem-lpszBlob)),"\r\n%s",lpszDescription)+1);

-

-			ccs.szProtoService=PSR_FILE;

-			ccs.hContact=hContact;

-			ccs.wParam=0;

-			ccs.lParam=(LPARAM)&pre;

-			pre.flags=0;

-			pre.timestamp=time(NULL);

-			pre.szMessage=lpszBlob;

-			pre.lParam=(lpszCurrentItem-lpszBlob);

-

-			CallService(MS_PROTO_CHAINRECV,0,(LPARAM)&ccs);

-			MEMFREE(lpszBlob);

-

-			dwRetErrorCode=NO_ERROR;

-		}else{

-			dwRetErrorCode=GetLastError();

-		}

-	}else{

-		dwRetErrorCode=ERROR_INVALID_HANDLE;

-	}

-return(dwRetErrorCode);

-}

-

-

-

-DWORD MraFilesQueueAddSend(HANDLE hFilesQueueHandle,DWORD dwFlags,HANDLE hContact,LPSTR *plpszFiles,LPSTR lpszDescription,SIZE_T dwDescriptionSize,DWORD *pdwIDRequest)

-{

-	DWORD dwRetErrorCode;

-

-	if (hFilesQueueHandle)

-	{

-		MRA_FILES_QUEUE *pmrafqFilesQueue=(MRA_FILES_QUEUE*)hFilesQueueHandle;

-		MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem;

-

-

-		pmrafqFilesQueueItem=(MRA_FILES_QUEUE_ITEM*)MEMALLOC(sizeof(MRA_FILES_QUEUE_ITEM)+sizeof(LPSTR)+dwDescriptionSize+64);

-		if (pmrafqFilesQueueItem)

-		{

-			SIZE_T i;

-			WIN32_FILE_ATTRIBUTE_DATA wfad;

-

-			//pmrafqFilesQueueItem->lmtListMTItem;

-			pmrafqFilesQueueItem->dwSendTime=GetTickCount();

-			pmrafqFilesQueueItem->dwIDRequest=InterlockedIncrement((LONG volatile*)&masMraSettings.dwCMDNum);// уникальный, рандомный идентификатор

-			pmrafqFilesQueueItem->dwFlags=dwFlags;

-			pmrafqFilesQueueItem->hContact=hContact;

-			pmrafqFilesQueueItem->lpszDescription=(LPSTR)(pmrafqFilesQueueItem+1);

-			pmrafqFilesQueueItem->dwDescriptionSize=dwDescriptionSize;

-			CopyMemory(pmrafqFilesQueueItem->lpszDescription,lpszDescription,dwDescriptionSize);

-

-

-			for(pmrafqFilesQueueItem->dwFilesCount=0;plpszFiles[pmrafqFilesQueueItem->dwFilesCount];pmrafqFilesQueueItem->dwFilesCount++);

-			pmrafqFilesQueueItem->pmfqfFiles=(MRA_FILES_QUEUE_FILE*)MEMALLOC((sizeof(MRA_FILES_QUEUE_FILE)*(pmrafqFilesQueueItem->dwFilesCount+1)));

-			pmrafqFilesQueueItem->dwFilesTotalSize=0;

-

-			for(i=0;i<pmrafqFilesQueueItem->dwFilesCount;i++)

-			{

-				if (GetFileAttributesExA(plpszFiles[i],GetFileExInfoStandard,&wfad))

-				{

-					pmrafqFilesQueueItem->pmfqfFiles[i].dwSize=wfad.nFileSizeLow;

-					pmrafqFilesQueueItem->dwFilesTotalSize+=wfad.nFileSizeLow;

-				}else{

-					pmrafqFilesQueueItem->pmfqfFiles[i].dwSize=0;

-				}

-				pmrafqFilesQueueItem->pmfqfFiles[i].dwNameLen=lstrlenA(plpszFiles[i]);

-				pmrafqFilesQueueItem->pmfqfFiles[i].lpszName=(LPSTR)MEMALLOC(pmrafqFilesQueueItem->pmfqfFiles[i].dwNameLen);

-				CopyMemory(pmrafqFilesQueueItem->pmfqfFiles[i].lpszName,plpszFiles[i],pmrafqFilesQueueItem->pmfqfFiles[i].dwNameLen);

-			}

-			//pmrafqFilesQueueItem->dwAddrCount=0;

-			//pmrafqFilesQueueItem->pmfqaAddreses=NULL;

-			pmrafqFilesQueueItem->bSending=TRUE;

-			if (pdwIDRequest) (*pdwIDRequest)=pmrafqFilesQueueItem->dwIDRequest;

-

-			ListMTLock(&pmrafqFilesQueue->lmtListMT);

-			ListMTItemAdd(&pmrafqFilesQueue->lmtListMT,&pmrafqFilesQueueItem->lmtListMTItem,pmrafqFilesQueueItem);

-			ListMTUnLock(&pmrafqFilesQueue->lmtListMT);

-

-			{

-				MRA_FILES_THREADPROC_PARAMS *pmftpp=(MRA_FILES_THREADPROC_PARAMS*)MEMALLOC(sizeof(MRA_FILES_THREADPROC_PARAMS));

-				pmftpp->hFilesQueueHandle=hFilesQueueHandle;

-				pmftpp->pmrafqFilesQueueItem=pmrafqFilesQueueItem;

-

-				pmrafqFilesQueueItem->hThread=CreateThread(0,0,MraFilesQueueSendThreadProc,pmftpp,0,NULL);

-			}

-

-			dwRetErrorCode=NO_ERROR;

-		}else{

-			dwRetErrorCode=GetLastError();

-		}

-	}else{

-		dwRetErrorCode=ERROR_INVALID_HANDLE;

-	}

-return(dwRetErrorCode);

-}

-

-

-

-DWORD MraFilesQueueAccept(HANDLE hFilesQueueHandle,DWORD dwIDRequest,LPSTR lpszPath,SIZE_T dwPathSize)

-{

-	DWORD dwRetErrorCode;

-

-	if (hFilesQueueHandle)

-	{

-		MRA_FILES_QUEUE *pmrafqFilesQueue=(MRA_FILES_QUEUE*)hFilesQueueHandle;

-		MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem;

-

-		ListMTLock(&pmrafqFilesQueue->lmtListMT);

-		if ((dwRetErrorCode=MraFilesQueueItemFindByID(hFilesQueueHandle,dwIDRequest,&pmrafqFilesQueueItem))==NO_ERROR)

-		{

-			MRA_FILES_THREADPROC_PARAMS *pmftpp=(MRA_FILES_THREADPROC_PARAMS*)MEMALLOC(sizeof(MRA_FILES_THREADPROC_PARAMS));

-			pmrafqFilesQueueItem->lpszPath=(LPSTR)MEMALLOC(dwPathSize);

-			pmrafqFilesQueueItem->dwPathSize=dwPathSize;

-			CopyMemory(pmrafqFilesQueueItem->lpszPath,lpszPath,dwPathSize);

-

-			pmftpp->hFilesQueueHandle=hFilesQueueHandle;

-			pmftpp->pmrafqFilesQueueItem=pmrafqFilesQueueItem;

-

-			pmrafqFilesQueueItem->hThread=CreateThread(0,0,MraFilesQueueRecvThreadProc,pmftpp,0,NULL);

-		}

-		ListMTUnLock(&pmrafqFilesQueue->lmtListMT);

-	}else{

-		dwRetErrorCode=ERROR_INVALID_HANDLE;

-	}

-return(dwRetErrorCode);

-}

-

-

-DWORD MraFilesQueueDecline(HANDLE hFilesQueueHandle,DWORD dwIDRequest,LPSTR lpszDescription,SIZE_T dwDescriptionSize)

-{

-	DWORD dwRetErrorCode;

-

-	if (hFilesQueueHandle)

-	{

-		MRA_FILES_QUEUE *pmrafqFilesQueue=(MRA_FILES_QUEUE*)hFilesQueueHandle;

-		MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem;

-

-		ListMTLock(&pmrafqFilesQueue->lmtListMT);

-		if ((dwRetErrorCode=MraFilesQueueItemFindByID(hFilesQueueHandle,dwIDRequest,&pmrafqFilesQueueItem))==NO_ERROR)

-		{

-			char szEMail[MAX_EMAIL_LEN];

-			SIZE_T dwEMailSize;

-			if (DB_Mra_GetStaticString(pmrafqFilesQueueItem->hContact,"e-mail",szEMail,sizeof(szEMail),&dwEMailSize))

-			{

-				MraSendCommand_FileTransferAck(FILE_TRANSFER_STATUS_DECLINE,szEMail,dwEMailSize,dwIDRequest,lpszDescription,dwDescriptionSize);

-			}

-			ListMTItemDelete(&pmrafqFilesQueue->lmtListMT,&pmrafqFilesQueueItem->lmtListMTItem);

-			MraFilesQueueItemFree(pmrafqFilesQueueItem);

-		}

-		ListMTUnLock(&pmrafqFilesQueue->lmtListMT);

-	}else{

-		dwRetErrorCode=ERROR_INVALID_HANDLE;

-	}

-return(dwRetErrorCode);

-}

-

-

-DWORD MraFilesQueueCancel(HANDLE hFilesQueueHandle,DWORD dwIDRequest,BOOL bSendDecline)

-{

-	DWORD dwRetErrorCode;

-

-	if (hFilesQueueHandle)

-	{

-		MRA_FILES_QUEUE *pmrafqFilesQueue=(MRA_FILES_QUEUE*)hFilesQueueHandle;

-		MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem;

-

-		ListMTLock(&pmrafqFilesQueue->lmtListMT);

-		if ((dwRetErrorCode=MraFilesQueueItemFindByID(hFilesQueueHandle,dwIDRequest,&pmrafqFilesQueueItem))==NO_ERROR)

-		{//***deb closesocket, send message to thread

-			if (bSendDecline)

-			{

-				char szEMail[MAX_EMAIL_LEN];

-				SIZE_T dwEMailSize;

-				if (DB_Mra_GetStaticString(pmrafqFilesQueueItem->hContact,"e-mail",szEMail,sizeof(szEMail),&dwEMailSize))

-				{

-					MraSendCommand_FileTransferAck(FILE_TRANSFER_STATUS_DECLINE,szEMail,dwEMailSize,dwIDRequest,NULL,0);

-				}

-			}

-			Netlib_CloseHandle(pmrafqFilesQueueItem->hConnection);

-			pmrafqFilesQueueItem->hConnection=NULL;

-

-			Netlib_CloseHandle(pmrafqFilesQueueItem->hListen);

-			pmrafqFilesQueueItem->hListen=NULL;

-

-			SetEvent(pmrafqFilesQueueItem->hWaitHandle);

-

-			if (pmrafqFilesQueueItem->hThread==NULL)

-			{

-				ListMTItemDelete(&pmrafqFilesQueue->lmtListMT,&pmrafqFilesQueueItem->lmtListMTItem);

-				MraFilesQueueItemFree(pmrafqFilesQueueItem);

-			}

-		}

-		ListMTUnLock(&pmrafqFilesQueue->lmtListMT);

-	}else{

-		dwRetErrorCode=ERROR_INVALID_HANDLE;

-	}

-return(dwRetErrorCode);

-}

-

-

-DWORD MraFilesQueueFree(HANDLE hFilesQueueHandle,DWORD dwIDRequest)

-{

-	DWORD dwRetErrorCode;

-

-	if (hFilesQueueHandle)

-	{

-		MRA_FILES_QUEUE *pmrafqFilesQueue=(MRA_FILES_QUEUE*)hFilesQueueHandle;

-		MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem;

-		LIST_MT_ITERATOR lmtiIterator;

-

-		dwRetErrorCode=ERROR_NOT_FOUND;

-		ListMTLock(&pmrafqFilesQueue->lmtListMT);

-		ListMTIteratorMoveFirst(&pmrafqFilesQueue->lmtListMT,&lmtiIterator);

-		do

-		{// цикл

-			if (ListMTIteratorGet(&lmtiIterator,NULL,(LPVOID*)&pmrafqFilesQueueItem)==NO_ERROR)

-			if (pmrafqFilesQueueItem->dwIDRequest==dwIDRequest)

-			{

-				ListMTItemDelete(&pmrafqFilesQueue->lmtListMT,&pmrafqFilesQueueItem->lmtListMTItem);

-				MraFilesQueueItemFree(pmrafqFilesQueueItem);

-				dwRetErrorCode=NO_ERROR;

-				break;

-			}

-		}while(ListMTIteratorMoveNext(&lmtiIterator));

-		ListMTUnLock(&pmrafqFilesQueue->lmtListMT);

-	}else{

-		dwRetErrorCode=ERROR_INVALID_HANDLE;

-	}

-return(dwRetErrorCode);

-}

-

-

-DWORD MraFilesQueueSendMirror(HANDLE hFilesQueueHandle,DWORD dwIDRequest,LPSTR lpszAddreses,SIZE_T dwAddresesSize)

-{

-	DWORD dwRetErrorCode;

-

-	if (hFilesQueueHandle)

-	{

-		MRA_FILES_QUEUE *pmrafqFilesQueue=(MRA_FILES_QUEUE*)hFilesQueueHandle;

-		MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem;

-

-		ListMTLock(&pmrafqFilesQueue->lmtListMT);

-		if ((dwRetErrorCode=MraFilesQueueItemFindByID(hFilesQueueHandle,dwIDRequest,&pmrafqFilesQueueItem))==NO_ERROR)

-		{//

-			LPSTR lpszCurrentItem,lpszDelimiter,lpszEndItem;

-			SIZE_T dwAllocatedCount;

-

-			dwAllocatedCount=ALLOCATED_COUNT;

-			pmrafqFilesQueueItem->dwAddrCount=0;

-			pmrafqFilesQueueItem->pmfqaAddreses=(MRA_FILES_QUEUE_ADDR*)MEMALLOC(sizeof(MRA_FILES_QUEUE_ADDR)*dwAllocatedCount);

-			lpszCurrentItem=lpszAddreses;

-			while(TRUE)

-			{

-				lpszEndItem=(LPSTR)MemoryFindByte((lpszCurrentItem-lpszAddreses),lpszAddreses,dwAddresesSize,';');

-				if (lpszEndItem)

-				{

-					lpszDelimiter=(LPSTR)MemoryFindByte((lpszCurrentItem-lpszAddreses),lpszAddreses,dwAddresesSize,':');

-					if (lpszDelimiter)

-					{

-						if (pmrafqFilesQueueItem->dwAddrCount==dwAllocatedCount)

-						{

-							dwAllocatedCount*=2;

-							pmrafqFilesQueueItem->pmfqaAddreses=(MRA_FILES_QUEUE_ADDR*)MEMREALLOC(pmrafqFilesQueueItem->pmfqaAddreses,(sizeof(MRA_FILES_QUEUE_ADDR)*dwAllocatedCount));

-						}

-

-						(*lpszDelimiter)=0;

-						pmrafqFilesQueueItem->pmfqaAddreses[pmrafqFilesQueueItem->dwAddrCount].dwIP=inet_addr(lpszCurrentItem);

-						pmrafqFilesQueueItem->pmfqaAddreses[pmrafqFilesQueueItem->dwAddrCount].dwPort=StrToUNum32((lpszDelimiter+1),(lpszEndItem-(lpszDelimiter+1)));

-						(*lpszDelimiter)=':';

-

-						switch(pmrafqFilesQueueItem->dwAddrCount){

-						case 0:

-							DB_Mra_SetDword(pmrafqFilesQueueItem->hContact,"OldIP",DB_Mra_GetDword(pmrafqFilesQueueItem->hContact,"IP",0));

-							DB_Mra_SetDword(pmrafqFilesQueueItem->hContact,"IP",htonl(pmrafqFilesQueueItem->pmfqaAddreses[pmrafqFilesQueueItem->dwAddrCount].dwIP));

-							break;

-						case 1:

-							DB_Mra_SetDword(pmrafqFilesQueueItem->hContact,"OldRealIP",DB_Mra_GetDword(pmrafqFilesQueueItem->hContact,"RealIP",0));

-							DB_Mra_SetDword(pmrafqFilesQueueItem->hContact,"RealIP",htonl(pmrafqFilesQueueItem->pmfqaAddreses[pmrafqFilesQueueItem->dwAddrCount].dwIP));

-							break;

-						}

-						pmrafqFilesQueueItem->dwAddrCount++;

-						lpszCurrentItem=(lpszEndItem+1);

-					}else{

-						break;

-					}

-				}else{

-					break;

-				}

-			}

-			pmrafqFilesQueueItem->pmfqaAddreses=(MRA_FILES_QUEUE_ADDR*)MEMREALLOC(pmrafqFilesQueueItem->pmfqaAddreses,(sizeof(MRA_FILES_QUEUE_ADDR)*pmrafqFilesQueueItem->dwAddrCount));

-

-			pmrafqFilesQueueItem->hConnection=NULL;

-			SetEvent(pmrafqFilesQueueItem->hWaitHandle);

-		}

-		ListMTUnLock(&pmrafqFilesQueue->lmtListMT);

-	}else{

-		dwRetErrorCode=ERROR_INVALID_HANDLE;

-	}

-return(dwRetErrorCode);

-}

-

-

-

-BOOL MraFilesQueueHandCheck(HANDLE hConnection,MRA_FILES_QUEUE_ITEM **ppmrafqFilesQueueItem)

-{

-	BOOL bRet=FALSE;

-

-	if (hConnection)

-	{

-		char szEMail[MAX_EMAIL_LEN]={0},szEMailMy[MAX_EMAIL_LEN]={0};

-		BYTE btBuff[((MAX_EMAIL_LEN*2)+(sizeof(MRA_FT_HELLO)*2)+8)]={0};

-		SIZE_T dwEMailSize,dwEMailMySize,dwBuffSize;

-

-		DB_Mra_GetStaticString(NULL,"e-mail",szEMailMy,sizeof(szEMailMy),&dwEMailMySize);BuffToLowerCase(szEMailMy,szEMailMy,dwEMailMySize);

-

-		if (pmrafqFilesQueueItem->bSending==FALSE)

-		{

-			dwBuffSize=(mir_snprintf((LPSTR)btBuff,sizeof(btBuff),"%s %s",MRA_FT_HELLO,szEMailMy)+1);

-			if (dwBuffSize==Netlib_Send(hConnection,(LPSTR)btBuff,dwBuffSize,0))

-			{// my email sended

-				//ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_INITIALISING,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,0);

-				dwBuffSize=Netlib_Recv(hConnection,(LPSTR)btBuff,sizeof(btBuff),0);

-				if (ppmrafqFilesQueueItem && (*ppmrafqFilesQueueItem))

-				{// have context, connecting or some times in receive

-					DB_Mra_GetStaticString((*ppmrafqFilesQueueItem)->hContact,"e-mail",szEMail,sizeof(szEMail),&dwEMailSize);BuffToLowerCase(szEMail,szEMail,dwEMailSize);

-					if ((dwEMailSize+sizeof(MRA_FT_HELLO)+1)==dwBuffSize)

-					{// email received

-						mir_snprintf(((LPSTR)btBuff+dwBuffSize),(sizeof(btBuff)-dwBuffSize),"%s %s",MRA_FT_HELLO,szEMail);

-						if (CompareStringA(MAKELANGID(LANG_ENGLISH,SUBLANG_ENGLISH_US),NORM_IGNORECASE,(LPSTR)btBuff,dwBuffSize,((LPSTR)btBuff+dwBuffSize),dwBuffSize)==CSTR_EQUAL)

-						{// email verifyed

-							bRet=TRUE;

-						}

-					}

-				}else{// some times on receive pExtra=NULL, and we looking for context

-					if (dwBuffSize!=SOCKET_ERROR && dwBuffSize>sizeof(MRA_FT_HELLO))

-					{// readed

-						if (MraFilesQueueItemFindByEMail(HANDLE hFilesQueueHandle,((LPSTR)btBuff+sizeof(MRA_FT_HELLO)),(dwBuffSize-(sizeof(MRA_FT_HELLO)+1)),ppmrafqFilesQueueItem)==NO_ERROR)

-						{// email verifyed

-							bRet=TRUE;

-						}

-					}

-				}

-			}

-		}else{

-			dwBuffSize=Netlib_Recv(hConnection,(LPSTR)btBuff,sizeof(btBuff),0);

-			if (ppmrafqFilesQueueItem && (*ppmrafqFilesQueueItem))

-			{// have context, connecting or some times in receive

-				DB_Mra_GetStaticString((*ppmrafqFilesQueueItem)->hContact,"e-mail",szEMail,sizeof(szEMail),&dwEMailSize);BuffToLowerCase(szEMail,szEMail,dwEMailSize);

-				if ((dwEMailSize+sizeof(MRA_FT_HELLO)+1)==dwBuffSize)

-				{// email received

-					ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_INITIALISING,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,0);

-					mir_snprintf(((LPSTR)btBuff+dwBuffSize),(sizeof(btBuff)-dwBuffSize),"%s %s",MRA_FT_HELLO,szEMail);

-					if (CompareStringA(MAKELANGID(LANG_ENGLISH,SUBLANG_ENGLISH_US),NORM_IGNORECASE,(LPSTR)btBuff,dwBuffSize,((LPSTR)btBuff+dwBuffSize),dwBuffSize)==CSTR_EQUAL)

-					{// email verifyed

-						dwBuffSize=(mir_snprintf((LPSTR)btBuff,sizeof(btBuff),"%s %s",MRA_FT_HELLO,szEMailMy)+1);

-						if (dwBuffSize==Netlib_Send(hConnection,(LPSTR)btBuff,dwBuffSize,0))

-						{// my email sended

-							bRet=TRUE;

-						}

-					}

-				}

-			}else{// some times on receive pExtra=NULL, and we looking for context

-				if (dwBuffSize!=SOCKET_ERROR && dwBuffSize>sizeof(MRA_FT_HELLO))

-				{// readed

-					if (MraFilesQueueItemFindByEMail(HANDLE hFilesQueueHandle,((LPSTR)btBuff+sizeof(MRA_FT_HELLO)),(dwBuffSize-(sizeof(MRA_FT_HELLO)+1)),ppmrafqFilesQueueItem)==NO_ERROR)

-					{// email verifyed

-						ProtoBroadcastAck(PROTOCOL_NAME,(*ppmrafqFilesQueueItem)->hContact,ACKTYPE_FILE,ACKRESULT_INITIALISING,(HANDLE)(*ppmrafqFilesQueueItem)->dwIDRequest,0);

-						dwBuffSize=(mir_snprintf((LPSTR)btBuff,sizeof(btBuff),"%s %s",MRA_FT_HELLO,szEMailMy)+1);

-						if (dwBuffSize==Netlib_Send(hConnection,(LPSTR)btBuff,dwBuffSize,0))

-						{// my email sended

-							bRet=TRUE;

-						}

-					}

-				}

-			}

-		}

-	}

-return(bRet);

-}

-

-

-HANDLE MraFilesQueueConnectOut(MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem)

-{

-	if ((pmrafqFilesQueueItem->bSending==FALSE && DB_Mra_GetByte(NULL,"FileSendNoOutConnOnRcv",MRA_DEF_FS_NO_OUT_CONN_ON_RCV)==FALSE) || (pmrafqFilesQueueItem->bSending==TRUE && DB_Mra_GetByte(NULL,"FileSendNoOutConnOnSend",MRA_DEF_FS_NO_OUT_CONN_ON_SEND)==FALSE))

-	{

-		BOOL bFiltering=FALSE;

-		DWORD dwLocalPort=0;

-		SIZE_T i;

-		NETLIBOPENCONNECTION nloc={0};

-

-		nloc.cbSize=sizeof(nloc);

-		nloc.flags=NLOCF_V2;

-		if (DB_Mra_GetByte(NULL,"FileSendIgnoryAdditionalPorts",MRA_DEF_FS_IGNORY_ADDITIONAL_PORTS))

-		{// фильтруем порты для одного IP, вместо 3 будем коннектится только к одному

-			switch(DB_Mra_GetWord(NULL,"ServerPort",MRA_DEFAULT_SERVER_PORT)) {

-			case MRA_SERVER_PORT_STANDART_NLB:

-				dwLocalPort=MRA_SERVER_PORT_STANDART;

-				break;

-			case MRA_SERVER_PORT_HTTPS:

-				dwLocalPort=MRA_SERVER_PORT_HTTPS;

-				break;

-			default:

-				dwLocalPort=DB_Mra_GetWord(NULL,"ServerPort",MRA_DEFAULT_SERVER_PORT);

-				break;

-			}

-

-			for(i=0;i<pmrafqFilesQueueItem->dwAddrCount;i++)

-			{// Set up the sockaddr structure

-				if (dwLocalPort==pmrafqFilesQueueItem->pmfqaAddreses[i].dwPort)

-				{

-					bFiltering=TRUE;

-					break;

-				}

-			}

-		}

-

-		for(i=0;i<pmrafqFilesQueueItem->dwAddrCount;i++)

-		{// Set up the sockaddr structure

-			if (dwLocalPort==pmrafqFilesQueueItem->pmfqaAddreses[i].dwPort || bFiltering==FALSE)

-			{

-				nloc.szHost=inet_ntoa((*((in_addr*)&pmrafqFilesQueueItem->pmfqaAddreses[i].dwIP)));

-				nloc.wPort=(WORD)pmrafqFilesQueueItem->pmfqaAddreses[i].dwPort;

-

-				ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_CONNECTING,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,0);

-				if ((pmrafqFilesQueueItem->hConnection=(HANDLE)CallService(MS_NETLIB_OPENCONNECTION,(WPARAM)masMraSettings.hNetlibUser,(LPARAM)&nloc)))

-				{

-					ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_CONNECTED,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,0);

-					if (MraFilesQueueHandCheck(pmrafqFilesQueueItem->hConnection,&pmrafqFilesQueueItem))

-					{// связь установленная с тем кем нужно

-						break;

-					}else{// кажется не туда подключились :)

-						ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_CONNECTING,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,0);

-						Netlib_CloseHandle(pmrafqFilesQueueItem->hConnection);

-						pmrafqFilesQueueItem->hConnection=NULL;

-					}

-				}

-			}

-		}

-	}

-return(pmrafqFilesQueueItem->hConnection);

-}

-

-

-HANDLE MraFilesQueueConnectIn(MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem)

-{

-	char szEMail[MAX_EMAIL_LEN],szAddrList[2048]={0};

-	SIZE_T dwEMailSize,dwAddrListSize;

-	NETLIBBIND nlbBind={0};

-

-	nlbBind.cbSize=sizeof(nlbBind);

-	nlbBind.pfnNewConnectionV2=MraFilesQueueConnectionReceived;

-	nlbBind.wPort=0;

-	nlbBind.pExtra=(LPVOID)pmrafqFilesQueueItem;

-

-	if (DB_Mra_GetStaticString(pmrafqFilesQueueItem->hContact,"e-mail",szEMail,sizeof(szEMail),&dwEMailSize))

-	if ((pmrafqFilesQueueItem->hListen=(HANDLE)CallService(MS_NETLIB_BINDPORT,(WPARAM)masMraSettings.hNetlibUser,(LPARAM)&nlbBind)))

-	{

-		dwAddrListSize=MraFilesQueueGetLocalAddressesList(szAddrList,sizeof(szAddrList),nlbBind.wPort);

-		if (dwAddrListSize)

-		{

-			pmrafqFilesQueueItem->hWaitHandle=CreateEvent(NULL,TRUE,FALSE,NULL);

-			if (pmrafqFilesQueueItem->bSending==FALSE)

-			{// запрашиваем зеркальное соединение

-				MraSendCommand_FileTransferAck(FILE_TRANSFER_MIRROR,szEMail,dwEMailSize,pmrafqFilesQueueItem->dwIDRequest,szAddrList,dwAddrListSize);

-			}else{// здесь отправляем запрос на передачу(установление соединения)

-				LPSTR lpszFiles,lpszFileName,lpszCurPos;

-				SIZE_T i,dwFilesSize=((MAX_PATH*2)*pmrafqFilesQueueItem->dwFilesCount);

-

-				lpszFiles=(LPSTR)MEMALLOC(dwFilesSize);

-				if (lpszFiles)

-				{

-					lpszCurPos=lpszFiles;

-					for(i=0;i<pmrafqFilesQueueItem->dwFilesCount;i++)

-					{

-						GetFullPathName(pmrafqFilesQueueItem->pmfqfFiles[i].lpszName,MAX_PATH,pmrafqFilesQueueItem->pmfqfFiles[i].lpszName,&lpszFileName);

-						lpszCurPos+=mir_snprintf(lpszCurPos,(dwFilesSize-(lpszCurPos-lpszFiles)),"%s;%ld;",lpszFileName,pmrafqFilesQueueItem->pmfqfFiles[i].dwSize);

-					}

-					MraSendCommand_FileTransfer(szEMail,dwEMailSize,pmrafqFilesQueueItem->dwIDRequest,pmrafqFilesQueueItem->dwFilesTotalSize,lpszFiles,(lpszCurPos-lpszFiles),pmrafqFilesQueueItem->lpszDescription,pmrafqFilesQueueItem->dwDescriptionSize,szAddrList,dwAddrListSize);

-					MEMFREE(lpszFiles);

-				}

-			}

-

-			WaitForSingleObject(pmrafqFilesQueueItem->hWaitHandle,INFINITE);

-			CloseHandle(pmrafqFilesQueueItem->hWaitHandle);

-			pmrafqFilesQueueItem->hWaitHandle=NULL;

-			Netlib_CloseHandle(pmrafqFilesQueueItem->hListen);

-			pmrafqFilesQueueItem->hListen=NULL;

-		}

-	}

-return(pmrafqFilesQueueItem->hConnection);

-}

-

-// This function is called from the Netlib when someone is connecting to

-// one of our incomming DC ports

-void MraFilesQueueConnectionReceived(HANDLE hNewConnection,DWORD dwRemoteIP,void *pExtra)

-{

-	MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem=(MRA_FILES_QUEUE_ITEM*)pExtra;

-

-	if (MraFilesQueueHandCheck(hNewConnection,&pmrafqFilesQueueItem))

-	{// связь установленная с тем кем нужно

-		pmrafqFilesQueueItem->hConnection=hNewConnection;

-		ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_CONNECTED,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,0);

-		DB_Mra_SetDword(pmrafqFilesQueueItem->hContact,"OldIP",DB_Mra_GetDword(pmrafqFilesQueueItem->hContact,"IP",0));

-		DB_Mra_SetDword(pmrafqFilesQueueItem->hContact,"IP",dwRemoteIP);

-		SetEvent(pmrafqFilesQueueItem->hWaitHandle);

-	}else{// кажется кто то не туда подключилися :)

-		if (pmrafqFilesQueueItem) ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_CONNECTING,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,0);

-		Netlib_CloseHandle(hNewConnection);

-	}

-

-	if (pExtra==NULL)

-	{

-		MraPopupShowFromAgent(MRA_POPUP_TYPE_DEBUG,0,"MraFilesQueueConnectionReceived: connection accepted, but pExtra=NULL, this is miranda bug.");

-		DebugBreak();

-	}

-}

-

-

-

-DWORD WINAPI MraFilesQueueRecvThreadProc(LPVOID lpParameter)

-{

-	MRA_FILES_QUEUE *pmrafqFilesQueue=(MRA_FILES_QUEUE*)((MRA_FILES_THREADPROC_PARAMS*)lpParameter)->hFilesQueueHandle;

-	MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem=((MRA_FILES_THREADPROC_PARAMS*)lpParameter)->pmrafqFilesQueueItem;

-

-	char szFileName[MAX_FILEPATH]={0};

-	BYTE btBuff[65536];

-	BOOL bFailed=TRUE,bOK,bConnected=FALSE;

-	DWORD dwWritten,dwReceived,dwUpdateTimeNext,dwUpdateTimeCur;

-	HANDLE hFile;

-	SIZE_T i,dwBuffSize;

-	PROTOFILETRANSFERSTATUS pfts={0};

-

-

-	MEMFREE(lpParameter);

-	pfts.cbSize=sizeof(pfts);

-	pfts.hContact=pmrafqFilesQueueItem->hContact;

-	pfts.sending=pmrafqFilesQueueItem->bSending;	//true if sending, false if receiving

-	//pfts.files;

-	pfts.totalFiles=pmrafqFilesQueueItem->dwFilesCount;

-	pfts.currentFileNumber=0;

-	pfts.totalBytes=pmrafqFilesQueueItem->dwFilesTotalSize;

-	pfts.totalProgress=0;

-	pfts.workingDir=pmrafqFilesQueueItem->lpszPath;

-	//pfts.currentFile;

-	//pfts.currentFileSize;

-	//pfts.currentFileProgress;

-	//pfts.currentFileTime;  //as seconds since 1970

-

-

-	CallService(MS_SYSTEM_THREAD_PUSH,0,0);

-	//ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_CONNECTING,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,0);

-

-	if (MraFilesQueueConnectOut(pmrafqFilesQueueItem))

-	{

-		bConnected=TRUE;

-	}else{

-		if (MraFilesQueueConnectIn(pmrafqFilesQueueItem)) bConnected=TRUE;

-	}

-

-	if (bConnected)

-	{// email verifyed

-		bFailed=FALSE;

-		for(i=0;i<pmrafqFilesQueueItem->dwFilesCount;i++)

-		{// receiving files

-			ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_NEXTFILE,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,0);

-			dwBuffSize=(mir_snprintf((LPSTR)btBuff,sizeof(btBuff),"%s %s",MRA_FT_GET_FILE,pmrafqFilesQueueItem->pmfqfFiles[i].lpszName)+1);

-			if (dwBuffSize==Netlib_Send(pmrafqFilesQueueItem->hConnection,(LPSTR)btBuff,dwBuffSize,0))

-			{// file request sended

-				mir_snprintf(szFileName,sizeof(szFileName),"%s%s",pmrafqFilesQueueItem->lpszPath,pmrafqFilesQueueItem->pmfqfFiles[i].lpszName);

-				hFile=CreateFile(szFileName,GENERIC_WRITE,FILE_SHARE_READ,NULL,CREATE_ALWAYS,FILE_ATTRIBUTE_NORMAL,NULL);

-				if (hFile!=INVALID_HANDLE_VALUE)

-				{

-					bOK=FALSE;

-					dwWritten=0;

-					dwUpdateTimeNext=GetTickCount();

-					pfts.currentFileNumber=i;

-					pfts.currentFile=pmrafqFilesQueueItem->pmfqfFiles[i].lpszName;

-					pfts.currentFileSize=pmrafqFilesQueueItem->pmfqfFiles[i].dwSize;

-					pfts.currentFileProgress=0;

-					//pfts.currentFileTime;  //as seconds since 1970

-					ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_DATA,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,(LPARAM)&pfts);

-

-					// pre allocating disk space, best perfomance

-					SetFilePointer(hFile,pmrafqFilesQueueItem->pmfqfFiles[i].dwSize,NULL,FILE_BEGIN);

-					SetEndOfFile(hFile);

-					SetFilePointer(hFile,0,NULL,FILE_BEGIN);

-

-					while(TRUE)

-					{

-						dwReceived=Netlib_Recv(pmrafqFilesQueueItem->hConnection,(LPSTR)&btBuff,sizeof(btBuff),0);

-						if (dwReceived==0 || dwReceived==SOCKET_ERROR)

-						{

-							dwWritten=0;

-							break;

-						}else{

-							WriteFile(hFile,(LPVOID)&btBuff,dwReceived,&dwReceived,NULL);

-							dwWritten+=dwReceived;

-							pfts.totalProgress+=dwReceived;

-							if (dwWritten>=pmrafqFilesQueueItem->pmfqfFiles[i].dwSize)

-							{

-								dwUpdateTimeNext=GetTickCount();// force stat update

-								bOK=TRUE;

-								break;

-							}

-

-							// progress updates

-							dwUpdateTimeCur=GetTickCount();

-							if (dwUpdateTimeNext<=dwUpdateTimeCur)

-							{// we update it

-								dwUpdateTimeNext=dwUpdateTimeCur+MRA_FILES_QUEUE_PROGRESS_INTERVAL;

-								pfts.currentFileProgress=dwWritten;

-								ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_DATA,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,(LPARAM)&pfts);

-							}

-						}

-					}// end while

-					CloseHandle(hFile);

-

-					if (bOK==FALSE)

-					{// file recv failed

-						DeleteFile(szFileName);

-						bFailed=TRUE;

-						break;

-					}

-				}else{// err on write file

-					bFailed=TRUE;

-					break;

-				}

-			}else{//err

-				break;

-			}

-		}// end for

-

-		Netlib_CloseHandle(pmrafqFilesQueueItem->hConnection);

-		pmrafqFilesQueueItem->hConnection=NULL;

-	}

-

-	if (bFailed)

-	{

-		char szEMail[MAX_EMAIL_LEN];

-		SIZE_T dwEMailSize;

-		if (DB_Mra_GetStaticString(pmrafqFilesQueueItem->hContact,"e-mail",szEMail,sizeof(szEMail),&dwEMailSize))

-		{

-			MraSendCommand_FileTransferAck(FILE_TRANSFER_STATUS_DECLINE,szEMail,dwEMailSize,pmrafqFilesQueueItem->dwIDRequest,NULL,0);

-		}

-		ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_FAILED,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,0);

-	}else{

-		ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_SUCCESS,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,0);

-	}

-

-	ListMTLock(&pmrafqFilesQueue->lmtListMT);

-	ListMTItemDelete(&pmrafqFilesQueue->lmtListMT,&pmrafqFilesQueueItem->lmtListMTItem);

-	CloseHandle(pmrafqFilesQueueItem->hThread);

-	MraFilesQueueItemFree(pmrafqFilesQueueItem);

-	ListMTUnLock(&pmrafqFilesQueue->lmtListMT);

-

-	CallService(MS_SYSTEM_THREAD_POP,0,0);

-	ExitThread(NO_ERROR);

-return(0);

-}

-

-

-

-DWORD WINAPI MraFilesQueueSendThreadProc(LPVOID lpParameter)

-{

-	MRA_FILES_QUEUE *pmrafqFilesQueue=(MRA_FILES_QUEUE*)((MRA_FILES_THREADPROC_PARAMS*)lpParameter)->hFilesQueueHandle;

-	MRA_FILES_QUEUE_ITEM *pmrafqFilesQueueItem=((MRA_FILES_THREADPROC_PARAMS*)lpParameter)->pmrafqFilesQueueItem;

-

-	BYTE btBuff[65536];

-	BOOL bFailed=TRUE,bOK,bConnected=FALSE;

-	DWORD dwReceived,dwSended,dwSendBlockSize,dwUpdateTimeNext,dwUpdateTimeCur;

-	HANDLE hFile;

-	SIZE_T i,j,dwBuffSize=0;

-	LPSTR lpszFileName;

-	PROTOFILETRANSFERSTATUS pfts={0};

-

-

-	MEMFREE(lpParameter);

-	pfts.cbSize=sizeof(pfts);

-	pfts.hContact=pmrafqFilesQueueItem->hContact;

-	pfts.sending=pmrafqFilesQueueItem->bSending;	//true if sending, false if receiving

-	//pfts.files;

-	pfts.totalFiles=pmrafqFilesQueueItem->dwFilesCount;

-	pfts.currentFileNumber=0;

-	pfts.totalBytes=pmrafqFilesQueueItem->dwFilesTotalSize;

-	pfts.totalProgress=0;

-	pfts.workingDir=pmrafqFilesQueueItem->lpszPath;

-	//pfts.currentFile;

-	//pfts.currentFileSize;

-	//pfts.currentFileProgress;

-	//pfts.currentFileTime;  //as seconds since 1970

-	dwSendBlockSize=DB_Mra_GetDword(NULL,"FileSendBlockSize",MRA_DEFAULT_FILE_SEND_BLOCK_SIZE);

-	if (dwSendBlockSize>sizeof(btBuff)) dwSendBlockSize=sizeof(btBuff);

-	if (dwSendBlockSize<512) dwSendBlockSize=MRA_DEFAULT_FILE_SEND_BLOCK_SIZE;

-

-

-	CallService(MS_SYSTEM_THREAD_PUSH,0,0);

-	//ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_SENTREQUEST,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,0);

-

-	if (MraFilesQueueConnectIn(pmrafqFilesQueueItem))

-	{

-		bConnected=TRUE;

-	}else{

-		if (MraFilesQueueConnectOut(pmrafqFilesQueueItem)) bConnected=TRUE;

-	}

-

-	if (bConnected)

-	{// email verifyed

-		bFailed=FALSE;

-		for(i=0;i<pmrafqFilesQueueItem->dwFilesCount;i++)

-		{// seiding files

-			ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_NEXTFILE,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,0);

-

-			dwBuffSize=0;

-			while(TRUE)

-			{

-				dwReceived=Netlib_Recv(pmrafqFilesQueueItem->hConnection,((LPSTR)btBuff+dwBuffSize),(sizeof(btBuff)-dwBuffSize),0);

-				if (dwReceived==0 || dwReceived==SOCKET_ERROR)

-				{

-					bFailed=TRUE;

-					break;

-				}else{

-					dwBuffSize+=dwReceived;

-					if (MemoryFindByte((dwBuffSize-dwReceived),btBuff,dwBuffSize,0)) break;

-				}

-			}// end while (file name passible received)*/

-

-			if (bFailed==FALSE)

-			{// ...received

-				if (dwBuffSize>(sizeof(MRA_FT_GET_FILE)+1))

-				{// file name received

-					if (CompareStringA(MAKELANGID(LANG_ENGLISH,SUBLANG_ENGLISH_US),NORM_IGNORECASE,(LPSTR)btBuff,(sizeof(MRA_FT_GET_FILE)-1),MRA_FT_GET_FILE,(sizeof(MRA_FT_GET_FILE)-1))==CSTR_EQUAL)

-					{// MRA_FT_GET_FILE verifyed

-						bFailed=TRUE;

-						for(j=0;j<pmrafqFilesQueueItem->dwFilesCount;j++)

-						{

-							if (GetFullPathName(pmrafqFilesQueueItem->pmfqfFiles[j].lpszName,(pmrafqFilesQueueItem->pmfqfFiles[j].dwNameLen+1),pmrafqFilesQueueItem->pmfqfFiles[j].lpszName,&lpszFileName))

-							if (CompareStringA(MAKELANGID(LANG_ENGLISH,SUBLANG_ENGLISH_US),NORM_IGNORECASE,(((LPSTR)btBuff)+sizeof(MRA_FT_GET_FILE)),(dwBuffSize-(sizeof(MRA_FT_GET_FILE)+1)),lpszFileName,-1)==CSTR_EQUAL)

-							{

-								bFailed=FALSE;

-								break;

-							}

-						}

-

-						if (bFailed==FALSE)

-						{

-							hFile=CreateFile(pmrafqFilesQueueItem->pmfqfFiles[j].lpszName,GENERIC_READ,FILE_SHARE_READ,NULL,OPEN_EXISTING,(FILE_ATTRIBUTE_NORMAL|FILE_FLAG_SEQUENTIAL_SCAN),NULL);

-							if (hFile!=INVALID_HANDLE_VALUE)

-							{

-								bOK=FALSE;

-								dwUpdateTimeNext=GetTickCount();

-								pfts.currentFileNumber=i;

-								pfts.currentFile=pmrafqFilesQueueItem->pmfqfFiles[j].lpszName;

-								pfts.currentFileSize=pmrafqFilesQueueItem->pmfqfFiles[j].dwSize;

-								pfts.currentFileProgress=0;

-								//pfts.currentFileTime;  //as seconds since 1970

-								ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_DATA,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,(LPARAM)&pfts);

-

-								while(TRUE)

-								{// read and sending

-									if (ReadFile(hFile,btBuff,dwSendBlockSize,&dwBuffSize,NULL))

-									{

-										dwSended=Netlib_Send(pmrafqFilesQueueItem->hConnection,(LPSTR)btBuff,dwBuffSize,0);

-										if (dwSended==0 || dwSended==SOCKET_ERROR)

-										{

-											break;

-										}else{

-											pfts.currentFileProgress+=dwSended;

-											pfts.totalProgress+=dwSended;

-											if (pfts.currentFileProgress>=pmrafqFilesQueueItem->pmfqfFiles[j].dwSize)

-											{

-												dwUpdateTimeNext=GetTickCount();// force stat update

-												bOK=TRUE;

-												break;

-											}

-

-											// progress updates

-											dwUpdateTimeCur=GetTickCount();

-											if (dwUpdateTimeNext<=dwUpdateTimeCur)

-											{// we update it

-												dwUpdateTimeNext=dwUpdateTimeCur+MRA_FILES_QUEUE_PROGRESS_INTERVAL;

-												//pfts.currentFileProgress=dwSended;

-												ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_DATA,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,(LPARAM)&pfts);

-											}

-										}

-									}else{// read failure

-										break;

-									}

-								}// end while

-								CloseHandle(hFile);

-

-								if (bOK==FALSE)

-								{// file recv failed

-									bFailed=TRUE;

-									break;

-								}

-								ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_DATA,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,(LPARAM)&pfts);

-							}else{// err on read file

-								bFailed=TRUE;

-								break;

-							}

-						}else{

-							break;

-						}

-					}else{// err on receive, trash

-						bFailed=TRUE;

-						break;

-					}

-				}else{// bad file name or trash

-					bFailed=TRUE;

-					break;

-				}

-			}else{// err on receive

-				bFailed=TRUE;

-				break;

-			}

-		}// end for

-

-		Netlib_CloseHandle(pmrafqFilesQueueItem->hConnection);

-		pmrafqFilesQueueItem->hConnection=NULL;

-	}

-

-	if (bFailed)

-	{

-		char szEMail[MAX_EMAIL_LEN];

-		SIZE_T dwEMailSize;

-		if (DB_Mra_GetStaticString(pmrafqFilesQueueItem->hContact,"e-mail",szEMail,sizeof(szEMail),&dwEMailSize))

-		{

-			MraSendCommand_FileTransferAck(FILE_TRANSFER_STATUS_DECLINE,szEMail,dwEMailSize,pmrafqFilesQueueItem->dwIDRequest,NULL,0);

-		}

-		ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_FAILED,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,0);

-	}else{

-		ProtoBroadcastAck(PROTOCOL_NAME,pmrafqFilesQueueItem->hContact,ACKTYPE_FILE,ACKRESULT_SUCCESS,(HANDLE)pmrafqFilesQueueItem->dwIDRequest,0);

-	}

-

-	ListMTLock(&pmrafqFilesQueue->lmtListMT);

-	ListMTItemDelete(&pmrafqFilesQueue->lmtListMT,&pmrafqFilesQueueItem->lmtListMTItem);

-	CloseHandle(pmrafqFilesQueueItem->hThread);

-	MraFilesQueueItemFree(pmrafqFilesQueueItem);

-	ListMTUnLock(&pmrafqFilesQueue->lmtListMT);

-

-	CallService(MS_SYSTEM_THREAD_POP,0,0);

-	ExitThread(NO_ERROR);

-return(0);

-}