Windows - Подождите, когда событие и гнездо будут симулированы

Question

Я пишу код Win32-API C, которому нужно дождаться новых TCP-соединений, а с другой стороны можно в любой момент закрыть любым другим процессом/потоком.

Поэтому мне нужно как-то WaitForSingleObject в событии остановки и ждать соединений, используя WSAAccept одновременно.

Я пробовал WaitForMultipleObjects как в сокете, так и в дескрипторе, но новое соединение не вызывает функцию (также WaitForSingleObject в сокете не будет запускаться при новом соединении).

Есть идеи?

Answer 1

Вам необходимо использовать WSAWaitForMultipleEvents. Для розеток, вот некоторые псевдо-код:

HANDLE hEvent[1]; 
hEvent[0] = WSACreateEvent(); 
WSAEventSelect(hSocket, hEvent[0], FD_READ | FD_WRITE); 

while (WSAWaitForMultipleEvents(...)) { 
    if (WSAEnumNetworkEvents(...)) { // Multiple events max exist 
     if (... & FD_ACCEPT) { 
     } 
     if (... & FD_WRITE) { 
     } 
     .... 
    } 
} 

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

Answer 2

Вы не можете ждать непосредственно на ручках сокетов.

WSAAccept() является синхронным, единственный способ прервать его - закрыть гнездо для прослушивания.

Для того, что вы пытаетесь сделать, вместо этого используйте AcceptEx(), который является асинхронным и поддерживает операции перекрытия ввода-вывода и ввода-вывода ввода-вывода.

Если вы используете Overlapped I/O, вы можете связать стандартный объект события Win32 для каждого Overlapped I/O способны гнезда (AcceptEx(), WSARecv(), WSASend() и т.д.), а также использовать стандартный объект события Win32 для остановки события , И затем вы можете использовать цикл WaitForMultipleObjects(), чтобы узнать, какое событие (ы) сигнализируется и действует соответствующим образом.

Если вы используете порт завершения ввода-вывода, вам вообще не нужны объекты событий. Вы можете связать каждый сокет с одной очередью IOCP, и ваш обработчик IOCP (либо вызов GetQueuedCompletionStatus(), либо функция обратного вызова) будет уведомляться всякий раз, когда завершается каждая операция сокета IOCP. Затем вы можете использовать PostQueuedCompletionStatus() для отправки пользовательского сообщения остановки в очередь IOCP. Ваш обработчик IOCP может действовать соответствующим образом, исходя из того, какое событие он получает.