lpc.h

winNT技术操作系统,国外开放的原代码和LIUX一样

#ifndef __INCLUDE_INTERNAL_PORT_H
#define __INCLUDE_INTERNAL_PORT_H

/* EPORT.Type */

#define EPORT_TYPE_SERVER_RQST_PORT   (0)
#define EPORT_TYPE_SERVER_COMM_PORT   (1)
#define EPORT_TYPE_CLIENT_COMM_PORT   (2)

/* EPORT.State */

#define EPORT_INACTIVE                (0)
#define EPORT_WAIT_FOR_CONNECT        (1)
#define EPORT_WAIT_FOR_ACCEPT         (2)
#define EPORT_WAIT_FOR_COMPLETE_SRV   (3)
#define EPORT_WAIT_FOR_COMPLETE_CLT   (4)
#define EPORT_CONNECTED_CLIENT        (5)
#define EPORT_CONNECTED_SERVER        (6)
#define EPORT_DISCONNECTED            (7)

extern POBJECT_TYPE LpcPortObjectType;
extern ULONG        LpcpNextMessageId;
#ifndef NTLPC
extern FAST_MUTEX   LpcpLock;
#endif

typedef struct _EPORT_LISTENER
{
    HANDLE ListenerPid;
    LIST_ENTRY ListenerListEntry;
} EPORT_LISTENER, *PEPORT_LISTENER;

typedef struct _EPORT
{
    KSPIN_LOCK Lock;
    KSEMAPHORE Semaphore;
    USHORT Type;
    USHORT State;
    struct _EPORT *RequestPort;
    struct _EPORT *OtherPort;
    ULONG QueueLength;
    LIST_ENTRY QueueListHead;
    ULONG ConnectQueueLength;
    LIST_ENTRY ConnectQueueListHead;
    ULONG MaxDataLength;
    ULONG MaxConnectInfoLength;
    ULONG MaxPoolUsage; /* size of NP zone */
} EPORT, *PEPORT;

typedef struct _EPORT_CONNECT_REQUEST_MESSAGE
{
    PORT_MESSAGE MessageHeader;
    PEPROCESS ConnectingProcess;
    struct _SECTION_OBJECT* SendSectionObject;
    LARGE_INTEGER SendSectionOffset;
    ULONG SendViewSize;
    ULONG ConnectDataLength;
    UCHAR ConnectData[0];
} EPORT_CONNECT_REQUEST_MESSAGE, *PEPORT_CONNECT_REQUEST_MESSAGE;

typedef struct _EPORT_CONNECT_REPLY_MESSAGE
{
    PORT_MESSAGE MessageHeader;
    PVOID SendServerViewBase;
    ULONG ReceiveClientViewSize;
    PVOID ReceiveClientViewBase;
    ULONG MaximumMessageSize;
    ULONG ConnectDataLength;
    UCHAR ConnectData[0];
} EPORT_CONNECT_REPLY_MESSAGE, *PEPORT_CONNECT_REPLY_MESSAGE;

typedef struct _QUEUEDMESSAGE
{
    PEPORT Sender;
    LIST_ENTRY QueueListEntry;
    PORT_MESSAGE Message;
} QUEUEDMESSAGE, *PQUEUEDMESSAGE;

NTSTATUS
NTAPI
LpcSendTerminationPort(
    PEPORT Port,
    LARGE_INTEGER CreationTime
);

/* Code in ntoskrnl/lpc/close.c */

VOID 
NTAPI
LpcpClosePort(
    IN PEPROCESS Process OPTIONAL,
    IN PVOID Object,
    IN ACCESS_MASK GrantedAccess,
    IN ULONG ProcessHandleCount,
    IN ULONG SystemHandleCount
);

VOID
NTAPI
LpcpDeletePort(IN PVOID ObjectBody);

VOID
NTAPI
LpcExitThread(IN PETHREAD Thread);

/* Code in ntoskrnl/lpc/queue.c */

VOID
NTAPI
EiEnqueueConnectMessagePort(
    IN OUT PEPORT Port,
    IN PQUEUEDMESSAGE Message
);

VOID
NTAPI
EiEnqueueMessagePort(
    IN OUT PEPORT Port,
    IN PQUEUEDMESSAGE Message
);

VOID
NTAPI
EiEnqueueMessageAtHeadPort(
    IN OUT PEPORT Port,
    IN PQUEUEDMESSAGE Message
);

PQUEUEDMESSAGE
NTAPI
EiDequeueConnectMessagePort(IN OUT PEPORT Port);

PQUEUEDMESSAGE
NTAPI
EiDequeueMessagePort(IN OUT PEPORT Port);

/* Code in ntoskrnl/lpc/port.c */

NTSTATUS
NTAPI
LpcpInitializePort(
    IN OUT PEPORT Port,
    IN USHORT Type,
    IN PEPORT Parent OPTIONAL
);

NTSTATUS
NTAPI
LpcpInitSystem (VOID);

/* Code in ntoskrnl/lpc/reply.c */

NTSTATUS
NTAPI
EiReplyOrRequestPort(
    IN PEPORT Port,
    IN PPORT_MESSAGE LpcReply,
    IN ULONG MessageType,
    IN PEPORT Sender
);

#endif /* __INCLUDE_INTERNAL_PORT_H */