Function QueueThreadedDpc

Kernel-Bridge/API/Callable.cpp:168–197

    }

    void QueueThreadedDpc(bool(*Callback)(void* Arg), void* Arg, unsigned char ProcessorNumber)
    {
        struct DPC_DATA
        {
            KDPC Dpc;
            decltype(Callback) Callback;
            void* Arg;
        };

        constexpr ULONG DpcTag = 'CPDT'; // TDPC = Threaded DPC
        DPC_DATA* DpcData = reinterpret_cast<DPC_DATA*>(ExAllocatePoolWithTag(NonPagedPool, sizeof(*DpcData), DpcTag));
        memset(DpcData, 0, sizeof(*DpcData));
        DpcData->Callback = Callback;
        DpcData->Arg = Arg;

        KeInitializeThreadedDpc(&DpcData->Dpc, [](PKDPC Dpc, PVOID Arg, PVOID SystemArgument1, PVOID SystemArgument2)
        {
            UNREFERENCED_PARAMETER(Dpc);
            UNREFERENCED_PARAMETER(SystemArgument1);
            UNREFERENCED_PARAMETER(SystemArgument2);
            DPC_DATA* DpcData = reinterpret_cast<DPC_DATA*>(Arg);
            DpcData->Callback(DpcData->Arg);
            ExFreePoolWithTag(Dpc, DpcTag);
        }, DpcData);

        KeSetImportanceDpc(&DpcData->Dpc, HighImportance);
        KeSetTargetProcessorDpc(&DpcData->Dpc, ProcessorNumber);

        KeInsertQueueDpc(&DpcData->Dpc, NULL, NULL);
    }

    void QueueWaitThreadedDpc(bool(*Callback)(void* Arg), void* Arg, unsigned char ProcessorNumber)
    {