ChronosXYZ/nesca
1
0
Fork 0
mirror of https://github.com/ChronosX88/nesca.git synced 2024-11-23 10:42:21 +00:00
Code Issues Projects Releases Wiki Activity

Попытка убрать ошибки 10038

Browse Source
This commit is contained in:
cora32 2014-11-24 02:22:45 +03:00
parent 09220cde34
commit 575a1c5b79
1 changed files with 19 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
connector.cpp
View File

@ -1467,17 +1467,10 @@ int Connector::_EstablishConnection(char *ip, int port, char *request, conSTR *C
stt->doEmitionRedFoundData("[Cannot create socket]"); stt->doEmitionRedFoundData("[Cannot create socket]");
CSSOCKET(sock); CSSOCKET(sock);
Sleep(500); Sleep(100);
sock = socket( AF_INET, SOCK_STREAM, IPPROTO_TCP ); sock = socket( AF_INET, SOCK_STREAM, IPPROTO_TCP );
}; };
while(WSAGetLastError() == 10038)
{
if(gDebugMode) stt->doEmitionDebugFoundData("10038 occured - [" + QString(ip) + ":" + QString::number(port) + "]");
CSSOCKET(sock);
sock = socket( AF_INET, SOCK_STREAM, IPPROTO_TCP );
};
#if defined(WIN32) #if defined(WIN32)
u_long FAR cmd = 1; u_long FAR cmd = 1;
if( ioctlsocket( sock , FIONBIO, &cmd ) != 0 ) if( ioctlsocket( sock , FIONBIO, &cmd ) != 0 )
@ -1494,38 +1487,37 @@ int Connector::_EstablishConnection(char *ip, int port, char *request, conSTR *C
linger.l_linger = 10; linger.l_linger = 10;
setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (const char *) &on, sizeof(on)); setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (const char *) &on, sizeof(on));
setsockopt(sock, SOL_SOCKET, SO_LINGER, (const char *) &linger, sizeof(linger)); setsockopt(sock, SOL_SOCKET, SO_LINGER, (const char *) &linger, sizeof(linger));
fd_set read_fs;
FD_ZERO(&read_fs);
FD_SET(sock, &read_fs);
int iError, iResult = connect(sock, (sockaddr*)&sockAddr, sizeof(sockAddr)); int iError, iResult = connect(sock, (sockaddr*)&sockAddr, sizeof(sockAddr));
while(sock == INVALID_SOCKET)
{
if(gDebugMode) stt->doEmitionDebugFoundData("[Invalid socket]: " + QString::number(WSAGetLastError()));
CSSOCKET(sock);
Sleep(100);
sock = socket( AF_INET, SOCK_STREAM, IPPROTO_TCP );
setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (const char *) &on, sizeof(on));
setsockopt(sock, SOL_SOCKET, SO_LINGER, (const char *) &linger, sizeof(linger));
iResult = connect(sock, (sockaddr*)&sockAddr, sizeof(sockAddr));
};
if(iResult == SOCKET_ERROR) if(iResult == SOCKET_ERROR)
{ {
iError = WSAGetLastError(); iError = WSAGetLastError();
while(iError == 10038)
{
if(gDebugMode) stt->doEmitionDebugFoundData("10038 occured - [" + QString(ip) + ":" + QString::number(port) + "]");
CSSOCKET(sock);
sock = socket( AF_INET, SOCK_STREAM, IPPROTO_TCP );
iResult = connect(sock, (sockaddr*)&sockAddr, sizeof(sockAddr));
iError = WSAGetLastError();
};
if(iError == 10035) if(iError == 10035)
{ {
fd_set read_fs;
FD_ZERO(&read_fs);
FD_SET(sock, &read_fs);
timeval tv = { gTimeOut, 0 }; timeval tv = { gTimeOut, 0 };
iResult = select(sock + 1, NULL, &read_fs, NULL, &tv);
int cErrCode; iResult = select(sock + 1, NULL, &read_fs, NULL, &tv);
if (iResult == SOCKET_ERROR) if (iResult == SOCKET_ERROR)
{ {
++offlines; ++offlines;
stt->doEmitionRedFoundData("[Omitting IP] Select error - " + stt->doEmitionRedFoundData("[Omitting IP] Select error - " +
QString::number(cErrCode) + QString::number(WSAGetLastError()) +
" - " + QString(ip) + ":" + QString::number(port)); " - " + QString(ip) + ":" + QString::number(port));
} }
else else