ipi.c File Reference

#include <ntoskrnl.h>
#include <debug.h>

Include dependency graph for ipi.c:

Go to the source code of this file.

Macros
#define	NDEBUG

Functions
VOID NTAPI	KiIpiGenericCallTarget (IN PKIPI_CONTEXT PacketContext, IN PVOID BroadcastFunction, IN PVOID Argument, IN PVOID Count)
VOID FASTCALL	KiIpiSend (IN KAFFINITY TargetProcessors, IN ULONG IpiRequest)
VOID NTAPI	KiIpiSendPacket (IN KAFFINITY TargetProcessors, IN PKIPI_WORKER WorkerFunction, IN PKIPI_BROADCAST_WORKER BroadcastFunction, IN ULONG_PTR Context, IN PULONG Count)
VOID FASTCALL	KiIpiSignalPacketDone (IN PKIPI_CONTEXT PacketContext)
VOID FASTCALL	KiIpiSignalPacketDoneAndStall (IN PKIPI_CONTEXT PacketContext, IN volatile PULONG ReverseStall)
BOOLEAN NTAPI	KiIpiServiceRoutine (IN PKTRAP_FRAME TrapFrame, IN PKEXCEPTION_FRAME ExceptionFrame)
ULONG_PTR NTAPI	KeIpiGenericCall (IN PKIPI_BROADCAST_WORKER Function, IN ULONG_PTR Argument)

Variables
KSPIN_LOCK	KiReverseStallIpiLock

Macro Definition Documentation

NDEBUG

#define NDEBUG

Definition at line 12 of file ipi.c.

Function Documentation

KeIpiGenericCall()

ULONG_PTR NTAPI KeIpiGenericCall	(	IN PKIPI_BROADCAST_WORKER	Function,
		IN ULONG_PTR	Argument
	)

Definition at line 198 of file ipi.c.

{
    ULONG_PTR Status;
    KIRQL OldIrql, OldIrql2;
#ifdef CONFIG_SMP
    KAFFINITY Affinity;
    ULONG Count;
    PKPRCB Prcb = KeGetCurrentPrcb();
#endif
 
    /* Raise to DPC level if required */
    OldIrql = KeGetCurrentIrql();
    if (OldIrql < DISPATCH_LEVEL) KeRaiseIrql(DISPATCH_LEVEL, &OldIrql);
 
#ifdef CONFIG_SMP
    /* Get current processor count and affinity */
    Count = KeNumberProcessors;
    Affinity = KeActiveProcessors;
 
    /* Exclude ourselves */
    Affinity &= ~Prcb->SetMember;
#endif
 
    /* Acquire the IPI lock */
    KeAcquireSpinLockAtDpcLevel(&KiReverseStallIpiLock);
 
#ifdef CONFIG_SMP
    /* Make sure this is MP */
    if (Affinity)
    {
        /* Send an IPI */
        KiIpiSendPacket(Affinity,
                        KiIpiGenericCallTarget,
                        Function,
                        Argument,
                        &Count);
 
        /* Spin until the other processors are ready */
        while (Count != 1)
        {
            YieldProcessor();
            KeMemoryBarrierWithoutFence();
        }
    }
#endif
 
    /* Raise to IPI level */
    KeRaiseIrql(IPI_LEVEL, &OldIrql2);
 
#ifdef CONFIG_SMP
    /* Let the other processors know it is time */
    Count = 0;
#endif
 
    /* Call the function */
    Status = Function(Argument);
 
#ifdef CONFIG_SMP
    /* If this is MP, wait for the other processors to finish */
    if (Affinity)
    {
        /* Sanity check */
        ASSERT(Prcb == KeGetCurrentPrcb());
 
        /* FIXME: TODO */
        ASSERTMSG("Not yet implemented\n", FALSE);
    }
#endif
 
    /* Release the lock */
    KeReleaseSpinLockFromDpcLevel(&KiReverseStallIpiLock);
 
    /* Lower IRQL back */
    KeLowerIrql(OldIrql);
    return Status;
}

KiIpiGenericCallTarget()

VOID NTAPI KiIpiGenericCallTarget	(	IN PKIPI_CONTEXT	PacketContext,
		IN PVOID	BroadcastFunction,
		IN PVOID	Argument,
		IN PVOID	Count
	)

Definition at line 25 of file ipi.c.

{
    /* FIXME: TODO */
    ASSERTMSG("Not yet implemented\n", FALSE);
}

Referenced by KeIpiGenericCall().

KiIpiSend()

VOID FASTCALL KiIpiSend	(	IN KAFFINITY	TargetProcessors,
		IN ULONG	IpiRequest
	)

Definition at line 36 of file ipi.c.

{
    /* FIXME: TODO */
    ASSERTMSG("Not yet implemented\n", FALSE);
}

KiIpiSendPacket()

VOID NTAPI KiIpiSendPacket	(	IN KAFFINITY	TargetProcessors,
		IN PKIPI_WORKER	WorkerFunction,
		IN PKIPI_BROADCAST_WORKER	BroadcastFunction,
		IN ULONG_PTR	Context,
		IN PULONG	Count
	)

Definition at line 45 of file ipi.c.

{
    /* FIXME: TODO */
    ASSERTMSG("Not yet implemented\n", FALSE);
}

Referenced by KeFlushEntireTb(), and KeIpiGenericCall().

KiIpiServiceRoutine()

BOOLEAN NTAPI KiIpiServiceRoutine	(	IN PKTRAP_FRAME	TrapFrame,
		IN PKEXCEPTION_FRAME	ExceptionFrame
	)

Definition at line 150 of file ipi.c.

{
#ifdef CONFIG_SMP
    PKPRCB Prcb;
    ASSERT(KeGetCurrentIrql() == IPI_LEVEL);
 
    Prcb = KeGetCurrentPrcb();
 
    if (InterlockedBitTestAndReset((PLONG)&Prcb->IpiFrozen, IPI_APC))
    {
        HalRequestSoftwareInterrupt(APC_LEVEL);
    }
 
    if (InterlockedBitTestAndReset((PLONG)&Prcb->IpiFrozen, IPI_DPC))
    {
        Prcb->DpcInterruptRequested = TRUE;
        HalRequestSoftwareInterrupt(DISPATCH_LEVEL);
    }
 
    if (InterlockedBitTestAndReset((PLONG)&Prcb->IpiFrozen, IPI_SYNCH_REQUEST))
    {
#if defined(_M_ARM) || defined(_M_AMD64)
        DbgBreakPoint();
#else
        (void)InterlockedDecrementUL(&Prcb->SignalDone->CurrentPacket[1]);
        if (InterlockedCompareExchangeUL(&Prcb->SignalDone->CurrentPacket[2], 0, 0))
        {
            while (0 != InterlockedCompareExchangeUL(&Prcb->SignalDone->CurrentPacket[1], 0, 0));
        }
        ((VOID (NTAPI*)(PVOID))(Prcb->SignalDone->WorkerRoutine))(Prcb->SignalDone->CurrentPacket[0]);
        InterlockedBitTestAndReset((PLONG)&Prcb->SignalDone->TargetSet, KeGetCurrentProcessorNumber());
        if (InterlockedCompareExchangeUL(&Prcb->SignalDone->CurrentPacket[2], 0, 0))
        {
            while (0 != InterlockedCompareExchangeUL(&Prcb->SignalDone->TargetSet, 0, 0));
        }
        (void)InterlockedExchangePointer((PVOID*)&Prcb->SignalDone, NULL);
#endif // _M_ARM
    }
#endif
   return TRUE;
}

KiIpiSignalPacketDone()

VOID FASTCALL KiIpiSignalPacketDone

(

IN PKIPI_CONTEXT

PacketContext

)

Definition at line 57 of file ipi.c.

{
    /* FIXME: TODO */
    ASSERTMSG("Not yet implemented\n", FALSE);
}

Referenced by KiFlushTargetEntireTb().

KiIpiSignalPacketDoneAndStall()

VOID FASTCALL KiIpiSignalPacketDoneAndStall	(	IN PKIPI_CONTEXT	PacketContext,
		IN volatile PULONG	ReverseStall
	)

Definition at line 65 of file ipi.c.

{
    /* FIXME: TODO */
    ASSERTMSG("Not yet implemented\n", FALSE);
}

Variable Documentation

KiReverseStallIpiLock

KSPIN_LOCK KiReverseStallIpiLock

extern

Definition at line 60 of file krnlinit.c.

Referenced by KeIpiGenericCall(), and KiInitSpinLocks().