Function QueueWaitThreadedDpc

Kernel-Bridge/API/Callable.cpp:199–232

    }

    void QueueWaitThreadedDpc(bool(*Callback)(void* Arg), void* Arg, unsigned char ProcessorNumber)
    {
        struct DPC_DATA
        {
            decltype(Callback) Callback;
            void* Arg;
            volatile LONG Finished;
        };

        DPC_DATA DpcData = { Callback, Arg, 0 };

        constexpr ULONG DpcTag = 'CPDT'; // TDPC = Threaded DPC

        KDPC Dpc;
        KeInitializeThreadedDpc(&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);
            InterlockedExchange(&DpcData->Finished, TRUE);
        }, &DpcData);

        KeSetImportanceDpc(&Dpc, HighImportance);
        KeSetTargetProcessorDpc(&Dpc, ProcessorNumber);

        KeInsertQueueDpc(&Dpc, NULL, NULL);

        while (InterlockedCompareExchange(&DpcData.Finished, TRUE, TRUE) != TRUE)
        {
            _mm_pause();
        }
    }

    struct STOP_PROCESSORS_DATA
    {