srm.c File Reference

#include "lsasrv.h"
#include <ndk/ntndk.h>

Include dependency graph for srm.c:

Go to the source code of this file.

Functions
static VOID	LsapComponentTest (PLSAP_RM_API_MESSAGE Message)
static VOID	LsapAdtWriteLog (PLSAP_RM_API_MESSAGE Message)
static VOID	LsapAsync (PLSAP_RM_API_MESSAGE Message)
static DWORD WINAPI	LsapRmServerThread (PVOID StartContext)
NTSTATUS	LsapRmInitializeServer (VOID)
NTSTATUS	LsapRmCreateLogonSession (PLUID LogonId)
NTSTATUS	LsapRmDeleteLogonSession (PLUID LogonId)

Variables
HANDLE	SeLsaCommandPort
HANDLE	SeRmCommandPort

Function Documentation

LsapAdtWriteLog()

static VOID LsapAdtWriteLog ( PLSAP_RM_API_MESSAGE  Message )

static

Definition at line 32 of file srm.c.

{
    ERR("LsapAdtWriteLog\n");
}

Referenced by LsapRmServerThread().

LsapAsync()

static VOID LsapAsync ( PLSAP_RM_API_MESSAGE  Message )

static

Definition at line 40 of file srm.c.

{
    ERR("LsapAsync\n");
}

Referenced by LsapRmServerThread().

LsapComponentTest()

static VOID LsapComponentTest ( PLSAP_RM_API_MESSAGE  Message )

static

Definition at line 24 of file srm.c.

{
    ERR("Security: LSA Component Test Command Received\n");
}

Referenced by LsapRmServerThread().

LsapRmCreateLogonSession()

NTSTATUS LsapRmCreateLogonSession

(

PLUID

LogonId

)

Definition at line 245 of file srm.c.

{
    SEP_RM_API_MESSAGE RequestMessage;
    SEP_RM_API_MESSAGE ReplyMessage;
    NTSTATUS Status;
 
    TRACE("LsapRmCreateLogonSession(%p)\n", LogonId);
 
    RequestMessage.Header.u2.ZeroInit = 0;
    RequestMessage.Header.u1.s1.TotalLength =
        (CSHORT)(sizeof(PORT_MESSAGE) + sizeof(ULONG) + sizeof(LUID));
    RequestMessage.Header.u1.s1.DataLength =
        RequestMessage.Header.u1.s1.TotalLength -
        (CSHORT)sizeof(PORT_MESSAGE);
 
    RequestMessage.ApiNumber = (ULONG)RmCreateLogonSession;
    RtlCopyLuid(&RequestMessage.u.LogonLuid, LogonId);
 
    ReplyMessage.Header.u2.ZeroInit = 0;
    ReplyMessage.Header.u1.s1.TotalLength =
        (CSHORT)(sizeof(PORT_MESSAGE) + sizeof(ULONG) + sizeof(NTSTATUS));
    ReplyMessage.Header.u1.s1.DataLength =
        ReplyMessage.Header.u1.s1.TotalLength -
        (CSHORT)sizeof(PORT_MESSAGE);
 
    ReplyMessage.u.ResultStatus = STATUS_SUCCESS;
 
    Status = NtRequestWaitReplyPort(SeRmCommandPort,
                                    (PPORT_MESSAGE)&RequestMessage,
                                    (PPORT_MESSAGE)&ReplyMessage);
    if (NT_SUCCESS(Status))
    {
        Status = ReplyMessage.u.ResultStatus;
    }
 
    return Status;
}

Referenced by LsapCreateLogonSession().

LsapRmDeleteLogonSession()

NTSTATUS LsapRmDeleteLogonSession

(

PLUID

LogonId

)

Definition at line 285 of file srm.c.

{
    SEP_RM_API_MESSAGE RequestMessage;
    SEP_RM_API_MESSAGE ReplyMessage;
    NTSTATUS Status;
 
    TRACE("LsapRmDeleteLogonSession(%p)\n", LogonId);
 
    RequestMessage.Header.u2.ZeroInit = 0;
    RequestMessage.Header.u1.s1.TotalLength =
        (CSHORT)(sizeof(PORT_MESSAGE) + sizeof(ULONG) + sizeof(LUID));
    RequestMessage.Header.u1.s1.DataLength =
        RequestMessage.Header.u1.s1.TotalLength -
        (CSHORT)sizeof(PORT_MESSAGE);
 
    RequestMessage.ApiNumber = (ULONG)RmDeleteLogonSession;
    RtlCopyLuid(&RequestMessage.u.LogonLuid, LogonId);
 
    ReplyMessage.Header.u2.ZeroInit = 0;
    ReplyMessage.Header.u1.s1.TotalLength =
        (CSHORT)(sizeof(PORT_MESSAGE) + sizeof(ULONG) + sizeof(NTSTATUS));
    ReplyMessage.Header.u1.s1.DataLength =
        ReplyMessage.Header.u1.s1.TotalLength -
        (CSHORT)sizeof(PORT_MESSAGE);
 
    ReplyMessage.u.ResultStatus = STATUS_SUCCESS;
 
    Status = NtRequestWaitReplyPort(SeRmCommandPort,
                                    (PPORT_MESSAGE)&RequestMessage,
                                    (PPORT_MESSAGE)&ReplyMessage);
    if (NT_SUCCESS(Status))
    {
        Status = ReplyMessage.u.ResultStatus;
    }
 
    return Status;
}

Referenced by LsapDeleteLogonSession().

LsapRmInitializeServer()

NTSTATUS LsapRmInitializeServer

(

VOID

)

Definition at line 167 of file srm.c.

{
    UNICODE_STRING Name;
    OBJECT_ATTRIBUTES ObjectAttributes;
    SECURITY_QUALITY_OF_SERVICE SecurityQos;
    HANDLE InitEvent;
    HANDLE ThreadHandle;
    DWORD ThreadId;
    NTSTATUS Status;
 
    /* Create the LSA command port */
    RtlInitUnicodeString(&Name, L"\\SeLsaCommandPort");
    InitializeObjectAttributes(&ObjectAttributes, &Name, 0, NULL, NULL);
    Status = NtCreatePort(&SeLsaCommandPort,
                          &ObjectAttributes,
                          0,
                          PORT_MAXIMUM_MESSAGE_LENGTH,
                          2 * PAGE_SIZE);
    if (!NT_SUCCESS(Status))
    {
        ERR("LsapRmInitializeServer - Port Create failed 0x%lx\n", Status);
        return Status;
    }
 
    /* Open the LSA init event */
    RtlInitUnicodeString(&Name, L"\\SeLsaInitEvent");
    InitializeObjectAttributes(&ObjectAttributes, &Name, 0, NULL, NULL);
    Status = NtOpenEvent(&InitEvent, 2, &ObjectAttributes);
    if (!NT_SUCCESS(Status))
    {
        ERR("LsapRmInitializeServer - Lsa Init Event Open failed 0x%lx\n", Status);
        return Status;
    }
 
    /* Signal the kernel, that we are ready */
    Status = NtSetEvent(InitEvent, 0);
    if (!NT_SUCCESS(Status))
    {
        ERR("LsapRmInitializeServer - Set Init Event failed 0x%lx\n", Status);
        return Status;
    }
 
    /* Setup the QoS structure */
    SecurityQos.ImpersonationLevel = SecurityIdentification;
    SecurityQos.ContextTrackingMode = SECURITY_DYNAMIC_TRACKING;
    SecurityQos.EffectiveOnly = TRUE;
 
    /* Connect to the kernel server */
    RtlInitUnicodeString(&Name, L"\\SeRmCommandPort");
    Status = NtConnectPort(&SeRmCommandPort,
                           &Name,
                           &SecurityQos,
                           NULL,
                           NULL,
                           NULL,
                           NULL,
                           NULL);
    if (!NT_SUCCESS(Status))
    {
        ERR("LsapRmInitializeServer - Connect to Rm Command Port failed 0x%lx\n", Status);
        return Status;
    }
 
    /* Create the server thread */
    ThreadHandle = CreateThread(NULL, 0, LsapRmServerThread, NULL, 0, &ThreadId);
    if (ThreadHandle == NULL)
    {
        ERR("LsapRmInitializeServer - Create Thread  failed 0x%lx\n", Status);
        return STATUS_INSUFFICIENT_RESOURCES;
    }
 
    /* Close the server thread handle */
    CloseHandle(ThreadHandle);
 
    return STATUS_SUCCESS;
}

Referenced by LsapInitLsa().

LsapRmServerThread()

static DWORD WINAPI LsapRmServerThread ( PVOID  StartContext )

static

Definition at line 49 of file srm.c.

{
    LSAP_RM_API_MESSAGE Message;
    PPORT_MESSAGE ReplyMessage;
    REMOTE_PORT_VIEW RemotePortView;
    HANDLE MessagePort, DummyPortHandle;
    NTSTATUS Status;
 
    /* Initialize the port message */
    Message.Header.u1.s1.TotalLength = sizeof(Message);
    Message.Header.u1.s1.DataLength = 0;
 
    /* Listen on the LSA command port */
    Status = NtListenPort(SeLsaCommandPort, &Message.Header);
    if (!NT_SUCCESS(Status))
    {
        ERR("LsapRmServerThread - Port Listen failed 0x%lx\n", Status);
        return Status;
    }
 
    /* Setup the Port View Structure */
    RemotePortView.Length = sizeof(REMOTE_PORT_VIEW);
    RemotePortView.ViewSize = 0;
    RemotePortView.ViewBase = NULL;
 
    /* Accept the connection */
    Status = NtAcceptConnectPort(&MessagePort,
                                 0,
                                 &Message.Header,
                                 TRUE,
                                 NULL,
                                 &RemotePortView);
    if (!NT_SUCCESS(Status))
    {
        ERR("LsapRmServerThread - Port Accept Connect failed 0x%lx\n", Status);
        return Status;
    }
 
    /* Complete the connection */
    Status = NtCompleteConnectPort(MessagePort);
    if (!NT_SUCCESS(Status))
    {
        ERR("LsapRmServerThread - Port Complete Connect failed 0x%lx\n", Status);
        return Status;
    }
 
    /* No reply yet */
    ReplyMessage = NULL;
 
    /* Start looping */
    while (TRUE)
    {
        /* Wait for a message */
        Status = NtReplyWaitReceivePort(MessagePort,
                                        NULL,
                                        ReplyMessage,
                                        &Message.Header);
        if (!NT_SUCCESS(Status))
        {
            ERR("LsapRmServerThread - Failed to get message: 0x%lx\n", Status);
            ReplyMessage = NULL;
            continue;
        }
 
        /* Check if this is a connection request */
        if (Message.Header.u2.s2.Type == LPC_CONNECTION_REQUEST)
        {
            /* Reject connection request */
            NtAcceptConnectPort(&DummyPortHandle,
                                NULL,
                                &Message.Header,
                                FALSE,
                                NULL,
                                NULL);
 
            /* Start over */
            ReplyMessage = NULL;
            continue;
        }
 
        /* Check if this is an actual request */
        if (Message.Header.u2.s2.Type == LPC_REQUEST)
        {
            ReplyMessage = &Message.Header;
 
            switch (Message.ApiNumber)
            {
                case LsapAdtWriteLogApi:
                    LsapAdtWriteLog(&Message);
                    break;
 
                case LsapAsyncApi:
                    LsapAsync(&Message);
                    break;
 
                case LsapComponentTestApi:
                    LsapComponentTest(&Message);
                    break;
 
                default:
                    ERR("LsapRmServerThread - invalid API number: 0x%lx\n",
                        Message.ApiNumber);
                    ReplyMessage = NULL;
            }
 
            continue;
        }
 
        ERR("LsapRmServerThread - unexpected message type: 0x%lx\n",
            Message.Header.u2.s2.Type);
 
        /* Start over */
        ReplyMessage = NULL;
    }
}

Referenced by LsapRmInitializeServer().

Variable Documentation

SeLsaCommandPort

HANDLE SeLsaCommandPort

Definition at line 17 of file srm.c.

Referenced by LsapRmInitializeServer(), and LsapRmServerThread().

SeRmCommandPort

HANDLE SeRmCommandPort

Definition at line 18 of file srm.c.

Referenced by LsapRmCreateLogonSession(), LsapRmDeleteLogonSession(), LsapRmInitializeServer(), SepRmCommandServerThread(), SepRmCommandServerThreadInit(), and SeRmInitPhase1().