lpc_x.h File Reference

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Macros
#define	LpcpGetMessageType(x)    ((x)->u2.s2.Type &~ LPC_KERNELMODE_MESSAGE)
#define	LpcpReceiveWait(s, w)
#define	LpcpReplyWait(s, w)
#define	LpcpConnectWait(s, w)
#define	LpcpCompleteWait(s)

Functions
static __inline PLPCP_MESSAGE	LpcpAllocateFromPortZone (VOID)
FORCEINLINE PLPCP_MESSAGE	LpcpGetMessageFromThread (IN PETHREAD Thread)
FORCEINLINE PLPCP_PORT_OBJECT	LpcpGetPortFromThread (IN PETHREAD Thread)
FORCEINLINE VOID	LpcpSetPortToThread (IN PETHREAD Thread, IN PLPCP_PORT_OBJECT Port)
FORCEINLINE PLPCP_DATA_INFO	LpcpGetDataInfoFromMessage (PPORT_MESSAGE Message)

Macro Definition Documentation

LpcpCompleteWait

#define LpcpCompleteWait

(

s

)

Value:

{                                                           \
    /* Release the semaphore */                             \
    LPCTRACE(LPC_SEND_DEBUG, "Release: %p\n", s);           \
    KeReleaseSemaphore(s, 1, 1, FALSE);                     \
}

Definition at line 88 of file lpc_x.h.

LpcpConnectWait

#define LpcpConnectWait	(		s,
			w
	)

Value:

{                                                           \
    LPCTRACE(LPC_CONNECT_DEBUG, "Wait: %p\n", s);           \
    Status = KeWaitForSingleObject(s,                       \
                                   Executive,               \
                                   w,                       \
                                   FALSE,                   \
                                   NULL);                   \
    LPCTRACE(LPC_CONNECT_DEBUG, "Wait done: %lx\n", Status);\
    if (Status == STATUS_USER_APC)                          \
    {                                                       \
        /* We were preempted by an APC */                   \
        if (KeReadStateSemaphore(s))                        \
        {                                                   \
            /* It's still signaled, so wait on it */        \
            KeWaitForSingleObject(s,                        \
                                  WrExecutive,              \
                                  KernelMode,               \
                                  FALSE,                    \
                                  NULL);                    \
            Status = STATUS_SUCCESS;                        \
        }                                                   \
    }                                                       \
}

Definition at line 60 of file lpc_x.h.

LpcpGetMessageType

#define LpcpGetMessageType

(

x

)

((x)->u2.s2.Type &~ LPC_KERNELMODE_MESSAGE)

Definition at line 12 of file lpc_x.h.

LpcpReceiveWait

#define LpcpReceiveWait	(		s,
			w
	)

Value:

{                                                           \
    LPCTRACE(LPC_REPLY_DEBUG, "Wait: %p\n", s);             \
    Status = KeWaitForSingleObject(s,                       \
                                   WrLpcReceive,            \
                                   w,                       \
                                   FALSE,                   \
                                   NULL);                   \
    LPCTRACE(LPC_REPLY_DEBUG, "Wait done: %lx\n", Status);  \
}

Definition at line 18 of file lpc_x.h.

LpcpReplyWait

#define LpcpReplyWait	(		s,
			w
	)

Value:

{                                                           \
    LPCTRACE(LPC_SEND_DEBUG, "Wait: %p\n", s);              \
    Status = KeWaitForSingleObject(s,                       \
                                   WrLpcReply,              \
                                   w,                       \
                                   FALSE,                   \
                                   NULL);                   \
    LPCTRACE(LPC_SEND_DEBUG, "Wait done: %lx\n", Status);   \
    if (Status == STATUS_USER_APC)                          \
    {                                                       \
        /* We were preempted by an APC */                   \
        if (KeReadStateSemaphore(s))                        \
        {                                                   \
            /* It's still signaled, so wait on it */        \
            KeWaitForSingleObject(s,                        \
                                  WrExecutive,              \
                                  KernelMode,               \
                                  FALSE,                    \
                                  NULL);                    \
            Status = STATUS_SUCCESS;                        \
        }                                                   \
    }                                                       \
}

Definition at line 32 of file lpc_x.h.

Function Documentation

LpcpAllocateFromPortZone()

static __inline PLPCP_MESSAGE LpcpAllocateFromPortZone ( VOID  )

static

Definition at line 100 of file lpc_x.h.

{
    PLPCP_MESSAGE Message;
 
    /* Allocate a message from the port zone while holding the lock */
    KeAcquireGuardedMutex(&LpcpLock);
    Message = (PLPCP_MESSAGE)ExAllocateFromPagedLookasideList(&LpcpMessagesLookaside);
    if (!Message)
    {
        /* Fail, and let caller cleanup */
        KeReleaseGuardedMutex(&LpcpLock);
        return NULL;
    }
 
    /* Initialize it */
    InitializeListHead(&Message->Entry);
    Message->RepliedToThread = NULL;
    Message->Request.u2.ZeroInit = 0;
 
    /* Release the lock */
    KeReleaseGuardedMutex(&LpcpLock);
    return Message;
}

Referenced by LpcRequestPort(), LpcRequestWaitReplyPort(), NtReplyPort(), NtReplyWaitReceivePortEx(), NtRequestPort(), NtRequestWaitReplyPort(), and NtSecureConnectPort().

LpcpGetDataInfoFromMessage()

FORCEINLINE PLPCP_DATA_INFO LpcpGetDataInfoFromMessage

(

PPORT_MESSAGE

Message

)

Definition at line 170 of file lpc_x.h.

{
    return (PLPCP_DATA_INFO)((PUCHAR)Message + Message->u2.s2.DataInfoOffset);
}

Referenced by LpcpCopyRequestData(), LpcpVerifyMessageDataInfo(), and NtRequestWaitReplyPort().

LpcpGetMessageFromThread()

FORCEINLINE PLPCP_MESSAGE LpcpGetMessageFromThread

(

IN PETHREAD

Thread

)

Definition at line 129 of file lpc_x.h.

{
    /* Check if the port flag is set */
    if (((ULONG_PTR)Thread->LpcReplyMessage) & LPCP_THREAD_FLAG_IS_PORT)
    {
        /* The pointer is actually a port, not a message, so return NULL */
        return NULL;
    }
 
    /* Otherwise, this is a message. Return the pointer */
    return (PLPCP_MESSAGE)((ULONG_PTR)Thread->LpcReplyMessage & ~LPCP_THREAD_FLAGS);
}

Referenced by LpcExitThread(), LpcpDestroyPortQueue(), LpcpFreeConMsg(), LpcRequestWaitReplyPort(), NtAcceptConnectPort(), NtCompleteConnectPort(), NtReplyPort(), NtReplyWaitReceivePortEx(), and NtRequestWaitReplyPort().

LpcpGetPortFromThread()

FORCEINLINE PLPCP_PORT_OBJECT LpcpGetPortFromThread

(

IN PETHREAD

Thread

)

Definition at line 144 of file lpc_x.h.

{
    /* Check if the port flag is set */
    if (((ULONG_PTR)Thread->LpcReplyMessage) & LPCP_THREAD_FLAG_IS_PORT)
    {
        /* The pointer is actually a port, return it */
        return (PLPCP_PORT_OBJECT)((ULONG_PTR)Thread->LpcWaitingOnPort &
                       ~LPCP_THREAD_FLAGS);
    }
 
    /* Otherwise, this is a message. There is nothing to return */
    return NULL;
}

Referenced by LpcpValidateClientPort().

LpcpSetPortToThread()

FORCEINLINE VOID LpcpSetPortToThread	(	IN PETHREAD	Thread,
		IN PLPCP_PORT_OBJECT	Port
	)

Definition at line 160 of file lpc_x.h.

{
    /* Set the port object */
    Thread->LpcWaitingOnPort = (PVOID)(((ULONG_PTR)Port) |
                                       LPCP_THREAD_FLAG_IS_PORT);
}

Referenced by LpcRequestWaitReplyPort(), and NtRequestWaitReplyPort().