notify.c File Reference

#include "lsasrv.h"

Include dependency graph for notify.c:

Go to the source code of this file.

Classes
struct	_LSA_NOTIFICATION_ENTRY

Typedefs
typedef struct _LSA_NOTIFICATION_ENTRY	LSA_NOTIFICATION_ENTRY
typedef struct _LSA_NOTIFICATION_ENTRY *	PLSA_NOTIFICATION_ENTRY

Functions
VOID	LsapInitNotificationList (VOID)
static PLSA_NOTIFICATION_ENTRY	LsapGetNotificationEntry (PLSA_API_MSG pRequestMsg)
static NTSTATUS	LsapAddNotification (PLSA_API_MSG pRequestMsg)
static NTSTATUS	LsapRemoveNotification (PLSA_API_MSG pRequestMsg)
NTSTATUS	LsapRegisterNotification (PLSA_API_MSG pRequestMsg)
VOID	LsapNotifyPolicyChange (POLICY_NOTIFICATION_INFORMATION_CLASS InformationClass)

Variables
static LIST_ENTRY	NotificationListHead
static RTL_RESOURCE	NotificationListLock

Typedef Documentation

LSA_NOTIFICATION_ENTRY

typedef struct _LSA_NOTIFICATION_ENTRY LSA_NOTIFICATION_ENTRY

PLSA_NOTIFICATION_ENTRY

typedef struct _LSA_NOTIFICATION_ENTRY * PLSA_NOTIFICATION_ENTRY

Function Documentation

LsapAddNotification()

static NTSTATUS LsapAddNotification ( PLSA_API_MSG  pRequestMsg )

static

Definition at line 63 of file notify.c.

{
    PLSA_NOTIFICATION_ENTRY pEntry;
    HANDLE hProcess = NULL;
    NTSTATUS Status = STATUS_SUCCESS;

    TRACE("LsapAddNotification(%p)\n", pRequestMsg);

    /* Allocate a new notification list entry */
    pEntry = RtlAllocateHeap(RtlGetProcessHeap(),
                             HEAP_ZERO_MEMORY,
                             sizeof(LSA_NOTIFICATION_ENTRY));
    if (pEntry == NULL)
    {
        Status = STATUS_INSUFFICIENT_RESOURCES;
        goto done;
    }

    /* Copy the notification data */
    pEntry->InformationClass = pRequestMsg->PolicyChangeNotify.Request.InformationClass;
    pEntry->EventHandle = pRequestMsg->PolicyChangeNotify.Request.NotificationEventHandle;
    pEntry->ClientId = pRequestMsg->h.ClientId;

    /* Open the client process */
    Status = NtOpenProcess(&hProcess,
                           PROCESS_DUP_HANDLE,
                           NULL,
                           pEntry->ClientId.UniqueProcess);
    if (!NT_SUCCESS(Status))
    {
        ERR("NtOpenProcess() failed (Status 0x%08lx)\n", Status);
        goto done;
    }

    /* Duplicate the event handle into the current process */
    Status = NtDuplicateObject(hProcess,
                               pEntry->EventHandle,
                               NtCurrentProcess(),
                               &pEntry->MappedEventHandle,
                               0,
                               0,
                               DUPLICATE_SAME_ACCESS);
    if (!NT_SUCCESS(Status))
    {
        ERR("NtDuplicateObject() failed (Status 0x%08lx)\n", Status);
        goto done;
    }

    /* Insert the new entry into the notification list */
    InsertHeadList(&NotificationListHead,
                   &pEntry->Entry);

done:
    if (hProcess != NULL)
        NtClose(hProcess);

    if (!NT_SUCCESS(Status))
    {
        if (pEntry != NULL)
            RtlFreeHeap(RtlGetProcessHeap(), 0, pEntry);
    }

    return Status;
}

Referenced by LsapRegisterNotification().

LsapGetNotificationEntry()

static PLSA_NOTIFICATION_ENTRY LsapGetNotificationEntry ( PLSA_API_MSG  pRequestMsg )

static

Definition at line 37 of file notify.c.

{
    PLIST_ENTRY NotificationEntry;
    PLSA_NOTIFICATION_ENTRY CurrentNotification;

    NotificationEntry = NotificationListHead.Flink;
    while (NotificationEntry != &NotificationListHead)
    {
        CurrentNotification = CONTAINING_RECORD(NotificationEntry, LSA_NOTIFICATION_ENTRY, Entry);

        if ((CurrentNotification->ClientId.UniqueProcess == pRequestMsg->h.ClientId.UniqueProcess) &&
            (CurrentNotification->ClientId.UniqueThread == pRequestMsg->h.ClientId.UniqueThread) &&
            (CurrentNotification->InformationClass == pRequestMsg->PolicyChangeNotify.Request.InformationClass) &&
            (CurrentNotification->EventHandle == pRequestMsg->PolicyChangeNotify.Request.NotificationEventHandle))
            return CurrentNotification;

        NotificationEntry = NotificationEntry->Flink;
    }

    return NULL;
}

Referenced by LsapRemoveNotification().

LsapInitNotificationList()

VOID LsapInitNotificationList

(

VOID

)

Definition at line 28 of file notify.c.

{
    InitializeListHead(&NotificationListHead);
    RtlInitializeResource(&NotificationListLock);
}

Referenced by LsapInitLsa().

LsapNotifyPolicyChange()

VOID LsapNotifyPolicyChange

(

POLICY_NOTIFICATION_INFORMATION_CLASS

InformationClass

)

Definition at line 188 of file notify.c.

{
    PLIST_ENTRY NotificationEntry;
    PLSA_NOTIFICATION_ENTRY CurrentNotification;

    TRACE("LsapNotifyPolicyChange(%lu)\n", InformationClass);

    /* Acquire the notification list lock shared */
    RtlAcquireResourceShared(&NotificationListLock, TRUE);

    NotificationEntry = NotificationListHead.Flink;
    while (NotificationEntry != &NotificationListHead)
    {
        CurrentNotification = CONTAINING_RECORD(NotificationEntry, LSA_NOTIFICATION_ENTRY, Entry);

        if (CurrentNotification->InformationClass == InformationClass)
        {
            TRACE("Notify event %p\n", CurrentNotification->MappedEventHandle);
            NtSetEvent(CurrentNotification->MappedEventHandle, NULL);
        }

        NotificationEntry = NotificationEntry->Flink;
    }

    /* Release the notification list lock */
    RtlReleaseResource(&NotificationListLock);
}

Referenced by LsarSetInformationPolicy().

LsapRegisterNotification()

NTSTATUS LsapRegisterNotification

(

PLSA_API_MSG

pRequestMsg

)

Definition at line 159 of file notify.c.

{
    NTSTATUS Status;

    TRACE("LsapRegisterNotification(%p)\n", pRequestMsg);

    /* Acquire the notification list lock exclusively */
    RtlAcquireResourceExclusive(&NotificationListLock, TRUE);

    if (pRequestMsg->PolicyChangeNotify.Request.Register)
    {
        /* Register the notification event */
        Status = LsapAddNotification(pRequestMsg);
    }
    else
    {
        /* Unregister the notification event */
        Status = LsapRemoveNotification(pRequestMsg);
    }

    /* Release the notification list lock */
    RtlReleaseResource(&NotificationListLock);

    return Status;
}

Referenced by AuthPortThreadRoutine().

LsapRemoveNotification()

static NTSTATUS LsapRemoveNotification ( PLSA_API_MSG  pRequestMsg )

static

Definition at line 132 of file notify.c.

{
    PLSA_NOTIFICATION_ENTRY pEntry;

    TRACE("LsapRemoveNotification(%p)\n", pRequestMsg);

    pEntry = LsapGetNotificationEntry(pRequestMsg);
    if (pEntry == NULL)
    {
        return STATUS_INVALID_HANDLE;
    }

    /* Remove the  notification entry from the notification list */
    RemoveEntryList(&pEntry->Entry);

    /* Close the mapped event handle */
    NtClose(pEntry->MappedEventHandle);

    /* Release the notification entry */
    RtlFreeHeap(RtlGetProcessHeap(), 0, pEntry);

    return STATUS_SUCCESS;
}

Referenced by LsapRegisterNotification().

Variable Documentation

NotificationListHead

LIST_ENTRY NotificationListHead

static

Definition at line 21 of file notify.c.

Referenced by LsapAddNotification(), LsapGetNotificationEntry(), LsapInitNotificationList(), and LsapNotifyPolicyChange().

NotificationListLock

RTL_RESOURCE NotificationListLock

static

Definition at line 22 of file notify.c.

Referenced by LsapInitNotificationList(), LsapNotifyPolicyChange(), and LsapRegisterNotification().