From 80221d816eeb98f0df38e0243390033c614952f3 Mon Sep 17 00:00:00 2001 From: Kirill Volinsky Date: Tue, 28 Nov 2017 22:12:43 +0300 Subject: Source files converted to utf-8 --- protocols/MRA/src/MraFilesQueue.cpp | 44 ++++++++++++++++++------------------- 1 file changed, 22 insertions(+), 22 deletions(-) (limited to 'protocols/MRA/src/MraFilesQueue.cpp') diff --git a/protocols/MRA/src/MraFilesQueue.cpp b/protocols/MRA/src/MraFilesQueue.cpp index ae7938fe4b..cdf220ffc1 100644 --- a/protocols/MRA/src/MraFilesQueue.cpp +++ b/protocols/MRA/src/MraFilesQueue.cpp @@ -222,12 +222,12 @@ size_t CMraProto::MraFilesQueueGetLocalAddressesList(LPSTR lpszBuff, size_t dwBu { LPSTR lpszCurPos = lpszBuff; - if (getByte("FileSendHideMyAddresses", MRA_DEF_FS_HIDE_MY_ADDRESSES)) {// не выдаём врагу наш IP адрес!!! :) - if (getByte("FileSendAddExtraAddresses", MRA_DEF_FS_ADD_EXTRA_ADDRESSES) == FALSE) {// только если не добавляем адрес роутера + if (getByte("FileSendHideMyAddresses", MRA_DEF_FS_HIDE_MY_ADDRESSES)) {// РЅРµ выдаём врагу наш IP адрес!!! :) + if (getByte("FileSendAddExtraAddresses", MRA_DEF_FS_ADD_EXTRA_ADDRESSES) == FALSE) {// только если РЅРµ добавляем адрес роутера lpszCurPos += mir_snprintf(lpszCurPos, (dwBuffSize - ((size_t)lpszCurPos - (size_t)lpszBuff)), MRA_FILES_NULL_ADDRR); } } - else {// создаём список наших IP адресов + else {// создаём СЃРїРёСЃРѕРє наших IP адресов BYTE btAddress[32]; DWORD dwSelfExternalIP; size_t dwAdapter = 0; @@ -250,7 +250,7 @@ size_t CMraProto::MraFilesQueueGetLocalAddressesList(LPSTR lpszBuff, size_t dwBu } CMStringA szHostName; - if (getByte("FileSendAddExtraAddresses", MRA_DEF_FS_ADD_EXTRA_ADDRESSES))// добавляем произвольный адрес + if (getByte("FileSendAddExtraAddresses", MRA_DEF_FS_ADD_EXTRA_ADDRESSES))// добавляем произвольный адрес if (mraGetStringA(NULL, "FileSendExtraAddresses", szHostName)) lpszCurPos += mir_snprintf(lpszCurPos, (dwBuffSize - ((size_t)lpszCurPos - (size_t)lpszBuff)), "%s:%lu;", szHostName.c_str(), dwPort); @@ -435,7 +435,7 @@ HANDLE CMraProto::MraFilesQueueConnectOut(MRA_FILES_QUEUE_ITEM *dat) size_t dwAddrCount = 0; NETLIBOPENCONNECTION nloc = { 0 }; - if (getByte("FileSendIgnoryAdditionalPorts", MRA_DEF_FS_IGNORY_ADDITIONAL_PORTS) || bIsHTTPSProxyUsed) {// фильтруем порты для одного IP, вместо 3 будем коннектится только к одному + if (getByte("FileSendIgnoryAdditionalPorts", MRA_DEF_FS_IGNORY_ADDITIONAL_PORTS) || bIsHTTPSProxyUsed) {// фильтруем порты для РѕРґРЅРѕРіРѕ IP, вместо 3 будем коннектится только Рє РѕРґРЅРѕРјСѓ if (bIsHTTPSProxyUsed) dwLocalPort = MRA_SERVER_PORT_HTTPS; else if ((dwLocalPort = getWord("ServerPort", MRA_DEFAULT_SERVER_PORT)) == MRA_SERVER_PORT_STANDART_NLB) @@ -457,7 +457,7 @@ HANDLE CMraProto::MraFilesQueueConnectOut(MRA_FILES_QUEUE_ITEM *dat) dwConnectReTryCount = getDword("ConnectReTryCountFileSend", MRA_DEFAULT_CONN_RETRY_COUNT_FILES); nloc.cbSize = sizeof(nloc); nloc.flags = NLOCF_V2; - nloc.timeout = getDword("TimeOutConnectFileSend", (int)((MRA_TIMEOUT_DIRECT_CONN - 1) / (dwAddrCount*dwConnectReTryCount)));// -1 сек чтобы был запас + nloc.timeout = getDword("TimeOutConnectFileSend", (int)((MRA_TIMEOUT_DIRECT_CONN - 1) / (dwAddrCount*dwConnectReTryCount)));// -1 сек чтобы был запас if (nloc.timeout < MRA_TIMEOUT_CONN_MIN) nloc.timeout = MRA_TIMEOUT_CONN_MIN; if (nloc.timeout > MRA_TIMEOUT_CONN_MAX) nloc.timeout = MRA_TIMEOUT_CONN_MAX; @@ -478,12 +478,12 @@ HANDLE CMraProto::MraFilesQueueConnectOut(MRA_FILES_QUEUE_ITEM *dat) if (dat->hConnection) { ProtoBroadcastAck(dat->hContact, ACKTYPE_FILE, ACKRESULT_CONNECTED, (HANDLE)dat->dwIDRequest, 0); if (MraFilesQueueHandCheck(dat->hConnection, dat)) { - // связь установленная с тем кем нужно + // СЃРІСЏР·СЊ установленная СЃ тем кем РЅСѓР¶РЅРѕ setDword(dat->hContact, "OldIP", getDword(dat->hContact, "IP", 0)); setDword(dat->hContact, "IP", ntohl(dat->malAddrList.pMailAddress[i].dwAddr)); break; } - else // кажется не туда подключились :) + else // кажется РЅРµ туда подключились :) NETLIB_CLOSEHANDLE(dat->hConnection); } } @@ -519,7 +519,7 @@ HANDLE CMraProto::MraFilesQueueConnectIn(MRA_FILES_QUEUE_ITEM *dat) CHAR szAddrList[2048] = { 0 }; size_t dwAddrListSize; - // копируем адреса в соответствии с правилами и начинаем слушать порт + // копируем адреса РІ соответствии СЃ правилами Рё начинаем слушать РїРѕСЂС‚ if (getByte("FileSendEnableDirectConn", MRA_DEF_FS_ENABLE_DIRECT_CONN)) { NETLIBBIND nlbBind = {}; nlbBind.pfnNewConnectionV2 = MraFilesQueueConnectionReceived; @@ -531,7 +531,7 @@ HANDLE CMraProto::MraFilesQueueConnectIn(MRA_FILES_QUEUE_ITEM *dat) ProtoBroadcastAck(dat->hContact, ACKTYPE_FILE, ACKRESULT_LISTENING, (HANDLE)dat->dwIDRequest, 0); dwAddrListSize = MraFilesQueueGetLocalAddressesList(szAddrList, sizeof(szAddrList), nlbBind.wPort); } - // не смогли слушать порт, хз почему. + // РЅРµ смогли слушать РїРѕСЂС‚, С…Р· почему. else { ShowFormattedErrorMessage(L"Files exchange: cant create listen soscket, will try connect to remonte host. Error", GetLastError()); @@ -540,7 +540,7 @@ HANDLE CMraProto::MraFilesQueueConnectIn(MRA_FILES_QUEUE_ITEM *dat) dwAddrListSize = (sizeof(MRA_FILES_NULL_ADDRR)-1); } } - // подставляем ложный адрес, чтобы точно не подключились и не слушаем порт + // подставляем ложный адрес, чтобы точно РЅРµ подключились Рё РЅРµ слушаем РїРѕСЂС‚ else { memcpy(szAddrList, MRA_FILES_NULL_ADDRR, sizeof(MRA_FILES_NULL_ADDRR)); dwAddrListSize = (sizeof(MRA_FILES_NULL_ADDRR)-1); @@ -548,10 +548,10 @@ HANDLE CMraProto::MraFilesQueueConnectIn(MRA_FILES_QUEUE_ITEM *dat) if (dwAddrListSize) { dat->hWaitHandle = CreateEvent(nullptr, TRUE, FALSE, nullptr); - if (dat->bSending == FALSE) // запрашиваем зеркальное соединение, тк сами подключится не смогли + if (dat->bSending == FALSE) // запрашиваем зеркальное соединение, тк сами подключится РЅРµ смогли MraFileTransferAck(FILE_TRANSFER_MIRROR, szEmail, dat->dwIDRequest, szAddrList); - else { // здесь отправляем запрос на передачу(установление соединения) - // создаём текстовый список файлов для отправки другой стороне + else { // здесь отправляем запрос РЅР° передачу(установление соединения) + // создаём текстовый СЃРїРёСЃРѕРє файлов для отправки РґСЂСѓРіРѕР№ стороне LPWSTR lpwszFiles, lpwszCurPos; size_t dwFilesSize; @@ -567,7 +567,7 @@ HANDLE CMraProto::MraFilesQueueConnectIn(MRA_FILES_QUEUE_ITEM *dat) dwFilesSize = (lpwszCurPos - lpwszFiles);// size in WCHARs if (dat->hMraMrimProxyData) { - // устанавливаем данные для майловской прокси, если она разрешена + // устанавливаем данные для майловской РїСЂРѕРєСЃРё, если РѕРЅР° разрешена CMStringA lpszFiles = lpwszFiles; MraMrimProxySetData(dat->hMraMrimProxyData, szEmail, dat->dwIDRequest, MRIM_PROXY_TYPE_FILES, lpszFiles, "", nullptr); } @@ -592,14 +592,14 @@ void MraFilesQueueConnectionReceived(HNETLIBCONN hNewConnection, DWORD dwRemoteI MRA_FILES_QUEUE_ITEM *dat = (MRA_FILES_QUEUE_ITEM*)pExtra; ProtoBroadcastAck(dat->ppro->m_szModuleName, dat->hContact, ACKTYPE_FILE, ACKRESULT_CONNECTED, (HANDLE)dat->dwIDRequest, 0); - if (dat->ppro->MraFilesQueueHandCheck(hNewConnection, dat)) { // связь установленная с тем кем нужно + if (dat->ppro->MraFilesQueueHandCheck(hNewConnection, dat)) { // СЃРІСЏР·СЊ установленная СЃ тем кем РЅСѓР¶РЅРѕ dat->hConnection = hNewConnection; ProtoBroadcastAck(dat->ppro->m_szModuleName, dat->hContact, ACKTYPE_FILE, ACKRESULT_CONNECTED, (HANDLE)dat->dwIDRequest, 0); dat->ppro->setDword(dat->hContact, "OldIP", dat->ppro->getDword(dat->hContact, "IP", 0)); dat->ppro->setDword(dat->hContact, "IP", dwRemoteIP); SetEvent(dat->hWaitHandle); } - else {// кажется кто то не туда подключилися :) + else {// кажется кто то РЅРµ туда подключилися :) ProtoBroadcastAck(dat->ppro->m_szModuleName, dat->hContact, ACKTYPE_FILE, ACKRESULT_LISTENING, (HANDLE)dat->dwIDRequest, 0); Netlib_CloseHandle(hNewConnection); } @@ -752,8 +752,8 @@ void CMraProto::MraFilesQueueRecvThreadProc(LPVOID lpParameter) else { if (InterlockedExchangeAdd((volatile LONG*)&dat->bIsWorking, 0)) { ProtoBroadcastAck(dat->hContact, ACKRESULT_CONNECTPROXY, ACKRESULT_CONNECTED, (HANDLE)dat->dwIDRequest, 0); - if (MraMrimProxyConnect(dat->hMraMrimProxyData, &dat->hConnection) == NO_ERROR) {// подключились к прокси, проверяем та ли сессия (ещё раз, на этот раз сами) - if (MraFilesQueueHandCheck(dat->hConnection, dat)) {// связь установленная с тем кем нужно// dat->bSending + if (MraMrimProxyConnect(dat->hMraMrimProxyData, &dat->hConnection) == NO_ERROR) {// подключились Рє РїСЂРѕРєСЃРё, проверяем та ли сессия (ещё раз, РЅР° этот раз сами) + if (MraFilesQueueHandCheck(dat->hConnection, dat)) {// СЃРІСЏР·СЊ установленная СЃ тем кем РЅСѓР¶РЅРѕ// dat->bSending ProtoBroadcastAck(dat->hContact, ACKTYPE_FILE, ACKRESULT_CONNECTED, (HANDLE)dat->dwIDRequest, 0); bConnected = TRUE; } @@ -923,7 +923,7 @@ DWORD CMraProto::MraFilesQueueAddSend(HANDLE hQueue, DWORD dwFlags, MCONTACT hCo dat->ppro = this; dat->bIsWorking = TRUE; dat->dwSendTime = GetTickCount(); - dat->dwIDRequest = InterlockedIncrement((LONG volatile*)&dwCMDNum);// уникальный, рандомный идентификатор + dat->dwIDRequest = InterlockedIncrement((LONG volatile*)&dwCMDNum);// уникальный, рандомный идентификатор dat->dwFlags = dwFlags; dat->hContact = hContact; if (getByte("FileSendEnableMRIMProxyCons", MRA_DEF_FS_ENABLE_MRIM_PROXY_CONS)) dat->hMraMrimProxyData = MraMrimProxyCreate(); @@ -1001,9 +1001,9 @@ void CMraProto::MraFilesQueueSendThreadProc(LPVOID lpParameter) if (InterlockedExchangeAdd((volatile LONG*)&dat->bIsWorking, 0)) { ProtoBroadcastAck(dat->hContact, ACKRESULT_CONNECTPROXY, ACKRESULT_CONNECTED, (HANDLE)dat->dwIDRequest, 0); if (MraMrimProxyConnect(dat->hMraMrimProxyData, &dat->hConnection) == NO_ERROR) { - // подключились к прокси, проверяем та ли сессия (ещё раз, на этот раз сами) + // подключились Рє РїСЂРѕРєСЃРё, проверяем та ли сессия (ещё раз, РЅР° этот раз сами) if (MraFilesQueueHandCheck(dat->hConnection, dat)) { - // связь установленная с тем кем нужно// dat->bSending + // СЃРІСЏР·СЊ установленная СЃ тем кем РЅСѓР¶РЅРѕ// dat->bSending ProtoBroadcastAck(dat->hContact, ACKTYPE_FILE, ACKRESULT_CONNECTED, (HANDLE)dat->dwIDRequest, 0); bConnected = TRUE; } -- cgit v1.2.3