Путаница с ключом порта завершения ввода-вывода

В повседневной практике я обнаружил, что лучше просто сосредоточиться на OVERLAPPED результате, так как он не изменится. Один из способов его эффективного использования - это иметь что-то вроде следующего:

struct CompletionHandler
{
    OVERLAPPED dummy_ovl;
    /* Stuff that actually means something to you here */
};

Когда вы публикуете что-то в IOCP (через вызов ввода-вывода или просто сообщение через Win32 API), вы сначала создаете объект CompletionHandler, который будете использовать для отслеживания вызова, и приводите адрес этого объекта к OVERLAPPED*.

CompletionHander my_handler;
// Fill in whatever you need to in my_handler
// Don't forget to keep the original my_handler!

// I/O call goes here, and for OVERLAPPED* give: (OVERLAPPED*)&my_handler

Таким образом, когда вы получите результат OVERLAPPED, все, что вам нужно сделать, это вернуть его к CompletionHandler и вуаля! У вас есть исходный контекст вашего звонка.

OVERLAPPED* from_queued_completion_status;
// Actually get a value into from_queued_completion_status

CompletionHandler* handler_for_this_completion = (CompletionHandler*)from_queued_completion_status;
// Have fun!

Для получения дополнительных сведений о реальных настройках ознакомьтесь с реализацией ASIO для Windows в Boost (заголовок версии 1.42 здесь). Есть некоторые детали, такие как проверка указателя OVERLAPPED, который вы получаете от GetQueuedCompletionStatus, но, опять же, посмотрите ссылку, чтобы найти хороший способ реализации.

GetQueuedCompletionStatus возвращает две вещи: OVERLAPPED структуру и ключ завершения. Ключ завершения представляет информацию об устройстве, а структура OVERLAPPED представляет информацию о каждом вызове. Ключ завершения должен соответствовать тому, что было дано при вызове CreateIoCompletionPort. Обычно в качестве ключа завершения используется указатель на структуру, содержащую информацию о соединении.

Похоже, вы ничего не делаете с completionKey, возвращенным GetQueuedCompletionStatus.

Я предполагаю, что вы хотите:

if completionKey != acceptKey:
    Cleanup()
    ...

редактировать:

Знает ли Python каким-то образом, что структура OVERLAPPED, созданная в CreateAcceptSocket, используется Win32 API асинхронно и предотвращает ее сборку мусора?

Вы должны думать о ключе завершения как о данных «для каждого соединения» и о (расширенной) перекрывающейся структуре как о «операции ввода-вывода».

Некоторые люди используют расширенную перекрывающуюся структуру ОБЕИХ и хранят всю необходимую информацию в расширенной перекрывающейся структуре. Я всегда хранил объект с подсчетом ссылок, который заключает мой сокет в ключ завершения, и буфер данных с подсчетом ссылок в виде расширенной перекрывающейся структуры. Если вам интересно, вы можете увидеть пример кода IOCP на C ++ здесь .

Проблема в том, как я передаю ключи завершения. Аргумент ключа завершения - это указатель, но он возвращает указатель, а не указанное значение - по крайней мере, меня это немного сбивает с толку.

Также ключ завершения, переданный для принятого перекрывающегося пакета соединения, является ключом прослушивающего сокета, а не принятым сокетом.

Ключ завершения не является указателем - это число типа ULONG_PTR, что означает просто «целое число, равное размеру указателя», поэтому он является 32-битным для x86 и 64-битным для x64. Имя типа сбивает с толку, но когда имена типов win32 ссылаются на указатель, они делают это, ставя P перед именем, а не в конце.

Если ваше приложение является многопоточным, убедитесь, что переданный вами CompletionKey является либо константой, либо значением указателя на объект в куче, а не в стеке. В вашем примере, где 100 передается как константа, вы, должно быть, ошиблись, сказав какое-либо изменение. Но что касается проблемы, возможно, вы передаете дескриптор сокета в CreateIoCompletionPort, но не ссылку для обработки в GetQueuedCompletionStatus, чтобы получить его. Ты можешь сделать

HANDLE socket;
CreateIoCompletionPort((HANDLE)socket, existed_io_completion_port, (ULONG_PTR)socket, 0);
/*some I/Os*/
...

и

HANDLE socket;
GetQueuedCompletionStatus(existed_io_completion_port, &io_bytes_done, (PULONG_PTR)&socket, &overlapped);

и обратите внимание на тип в скобках.