Function QueueDpc

Kernel-Bridge/API/Callable.cpp:102–131

    }

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

        constexpr ULONG DpcTag = 'CPDK';
        DPC_DATA* DpcData = reinterpret_cast<DPC_DATA*>(ExAllocatePoolWithTag(NonPagedPool, sizeof(*DpcData), DpcTag));
        memset(DpcData, 0, sizeof(*DpcData));
        DpcData->Callback = Callback;
        DpcData->Arg = Arg;

        KeInitializeDpc(&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 QueueWaitDpc(bool(*Callback)(void* Arg), void* Arg, unsigned char ProcessorNumber)
    {