WSAConnectByName timeout

Question

Я пытаюсь использовать WSAConnectByName() для подключения к адресу. Однако, похоже, что он игнорирует параметр timeout.

Здесь (только слегка модифицированный код), полученный в примере МС:

SOCKET ConnSocket = INVALID_SOCKET; 
int iResult; 
BOOL bSuccess; 
SOCKADDR_STORAGE LocalAddr = {0}; 
SOCKADDR_STORAGE RemoteAddr = {0}; 
DWORD dwLocalAddr = sizeof(LocalAddr); 
DWORD dwRemoteAddr = sizeof(RemoteAddr); 

ConnSocket = socket(AF_INET, SOCK_STREAM, 0); 
if (ConnSocket == INVALID_SOCKET){ 
    wprintf(L"socket failed with error: %d\n", WSAGetLastError()); 
    return INVALID_SOCKET; 
} 

struct timeval tv; 
tv.tv_sec = 1; 
tv.tv_usec = 0; 

bSuccess = WSAConnectByName(ConnSocket, NodeName, 
     PortName, &dwLocalAddr, 
     (SOCKADDR*)&LocalAddr, 
     &dwRemoteAddr, 
     (SOCKADDR*)&RemoteAddr, 
     (struct timeval *)&tv, 
     NULL); 
if (!bSuccess){ 
    wprintf(L"WsaConnectByName failed with error: %d\n", WSAGetLastError()); 
    closesocket(ConnSocket); 
    return INVALID_SOCKET;  
} 

Когда я использовать адрес, который не существует (например, локальный IP-адрес), вместо того, чтобы не суметь с тайм-аута, то код останавливается, пока не произойдет какой-либо другой тайм-аут.

Любая идея, что здесь происходит?

Answer 1

Это связано с плохой документацией.

Параметр timeout только частично используется. WSAConnectByName - сложная функция, которая выполняет множество операций внутри.

В начале существует такой код:

ULONG time, ms; 
if (timeout) 
{ 
    time = GetTickCount(); 
    ms = timeout->tv_sec * 1000 + timeout->tv_usec/1000; 
} 

, а затем несколько раз он вызывает такой код:

if (timeout && GetTickCount() - time > ms) return WSAETIMEDOUT; 

но сердце функции вызовов ConnectEx как это:

if (!ConnectEx(*)) 
{ 
    if (GetLastError() == ERROR_IO_PENDING) 
    { 
    WSAGetOverlappedResult(*); // you wait here and the timeout is not used! 
    } 
} 

И ConnectEx (что является асинхронная функция) и GetOverlappedResult не имеют параметров для указания таймаута. Вы в конечном итоге ожидаете в GetOverlappedResult после ConnectEx выходов, но вы не можете установить для него таймаут.

Существует только одно приятное решение - используйте ConnectEx напрямую и не используйте никаких таймаутов.

еще одна проблема проблема - GetAddrInfoEx используется для перевода nodename на ip-адрес. эта функция вызвана с timeout=0, lpOverlapped=0, lpCompletionRoutine = 0 - так что здесь также можно подождать по запросу DNS. Асинхронный запрос поддерживается только начинается с Windows 8

EDIT

если прямое использование ConnectEx мы можем использовать тайм-аут (спасибо Remy Lebeau за идею) - создать/использовать OVERLAPPED.hEvent и

OVERLAPPED Overlapped = {}; 
Overlapped.hEvent = CreateEvent(0, 0, 0, 0); 
//... ConnectEx ... 
ULONG NumberOfBytesTransferred = 0; 
ULONG err = GetLastError(); 
if (err == ERROR_IO_PENDING) 
{ 
    switch (WaitForSingleObject(Overlapped.hEvent, ms)) 
    { 
    case STATUS_TIMEOUT: 
     CancelIoEx((HANDLE)s, &Overlapped); 
     err = WSAETIMEDOUT; 
     break; 
    case WAIT_OBJECT_0: 
     // really final NT status of operation is Internal and NumberOfBytesTransferred == InternalHigh 
     // GetOverlappedResult set LastError by translating (NTSTATUS)Internal to win32 error 
     // with the loss of accuracy, especially if status > 0 
     GetOverlappedResult((HANDLE)s, &Overlapped, &NumberOfBytesTransferred, TRUE); 
     err = GetLastError(); 

     // code of GetOverlappedResult in this case for clarity 
     //if ((NTSTATUS)Overlapped.InternalHigh == STATUS_PENDING) 
     //{ 
     // WaitForSingleObject(Overlapped.hEvent, INFINITE); 
     //} 
     //NumberOfBytesTransferred = (ULONG)Overlapped.InternalHigh; 
     //if (0 > (NTSTATUS)Overlapped.Internal) 
     //{ 
     // SetLastError(RtlNtStatusToDosError((NTSTATUS)Overlapped.Internal)); 
     //} 

     break; 
    default: __debugbreak(); 
    } 
} 

или для альтернативного использования GetOverlappedResultEx с нашим таймаутом (но нужны окна 8+)

или лучший выбор (для моего просмотра) - используйте BindIoCompletionCallback((HANDLE)s,) или напрямую привязать IOCP для сокета, а не ждать после вызова вообще.