rpcsrv.c File Reference

#include "svchost.h"

Include dependency graph for rpcsrv.c:

Go to the source code of this file.

Functions
NTSTATUS NTAPI	RpcpInitRpcServer (VOID)
NTSTATUS NTAPI	RpcpStopRpcServer (_In_ RPC_IF_HANDLE IfSpec)
NTSTATUS NTAPI	RpcpStopRpcServerEx (_In_ RPC_IF_HANDLE IfSpec)
NTSTATUS NTAPI	RpcpAddInterface (_In_ PCWSTR IfName, _In_ RPC_IF_HANDLE IfSpec)
NTSTATUS NTAPI	RpcpStartRpcServer (_In_ PCWSTR IfName, _In_ RPC_IF_HANDLE IfSpec)

Variables
LONG	RpcpNumInstances
CRITICAL_SECTION	RpcpCriticalSection

Function Documentation

RpcpAddInterface()

NTSTATUS NTAPI RpcpAddInterface	(	_In_ PCWSTR	IfName,
		_In_ RPC_IF_HANDLE	IfSpec
	)

Definition at line 83 of file rpcsrv.c.

{
    PWCHAR endpointName;
    NTSTATUS ntStatus;
    RPC_STATUS rpcStatus;
 
    /* Allocate space for the interface name and the \\PIPE\\ prefix */
    endpointName = LocalAlloc(0, sizeof(WCHAR) * wcslen(IfName) + 16);
    if (endpointName)
    {
        /* Copy the prefix, and then the interface name */
        wcscpy(endpointName, L"\\PIPE\\");
        wcscat(endpointName, IfName);
 
        /* Create a named pipe endpoint with this name */
        rpcStatus = RpcServerUseProtseqEpW(L"ncacn_np",
                                           RPC_C_PROTSEQ_MAX_REQS_DEFAULT,
                                           endpointName, NULL);
        if ((rpcStatus != RPC_S_OK) && (rpcStatus != RPC_S_DUPLICATE_ENDPOINT))
        {
            /* We couldn't create it, or it already existed... */
            DbgPrint("RpcServerUseProtseqW failed! rpcstatus = %u\n", rpcStatus);
        }
        else
        {
            /* It worked, register an interface on this endpoint now */
            rpcStatus = RpcServerRegisterIf(IfSpec, 0, 0);
        }
 
        /* In both success and failure, free the name, and convert the status */
        LocalFree(endpointName);
        ntStatus = I_RpcMapWin32Status(rpcStatus);
    }
    else
    {
        /* No memory, bail out */
        ntStatus = STATUS_NO_MEMORY;
    }
 
    /* Return back to the caller */
    return ntStatus;
}

Referenced by RpcpStartRpcServer().

RpcpInitRpcServer()

NTSTATUS NTAPI RpcpInitRpcServer

(

VOID

)

Definition at line 22 of file rpcsrv.c.

{
    /* Clear the reference count and initialize the critical section */
    RpcpNumInstances = 0;
    return RtlInitializeCriticalSection((PVOID)&RpcpCriticalSection);
}

Referenced by SvchostBuildSharedGlobals().

RpcpStartRpcServer()

NTSTATUS NTAPI RpcpStartRpcServer	(	_In_ PCWSTR	IfName,
		_In_ RPC_IF_HANDLE	IfSpec
	)

Definition at line 131 of file rpcsrv.c.

{
    NTSTATUS ntStatus;
 
    /* Acquire the lock while we instantiate a new interface */
    EnterCriticalSection(&RpcpCriticalSection);
 
    /* Add this interface to the service */
    ntStatus = RpcpAddInterface(IfName, IfSpec);
    if (!ntStatus)
    {
        /* Increment the reference count to see if this was the first interface */
        if (++RpcpNumInstances == 1)
        {
            /* It was, so put the server into listening mode now */
            ntStatus = RpcServerListen(1, 12345, TRUE);
            if (ntStatus == RPC_S_ALREADY_LISTENING) ntStatus = STATUS_SUCCESS;
        }
    }
 
    /* Release the lock and return back the result to the caller */
    LeaveCriticalSection(&RpcpCriticalSection);
    return I_RpcMapWin32Status(ntStatus);
}

Referenced by SvchostBuildSharedGlobals().

RpcpStopRpcServer()

NTSTATUS NTAPI RpcpStopRpcServer

(

_In_ RPC_IF_HANDLE

IfSpec

)

Definition at line 33 of file rpcsrv.c.

{
    RPC_STATUS rpcStatus;
 
    /* Unregister the interface */
    rpcStatus = RpcServerUnregisterIf(IfSpec, NULL, TRUE);
 
    /* Acquire the lock while we dereference the RPC services */
    EnterCriticalSection(&RpcpCriticalSection);
    if (--RpcpNumInstances == 0)
    {
        /* All RPC services stopped, rundown the server */
        RpcMgmtStopServerListening(NULL);
        RpcMgmtWaitServerListen();
    }
 
    /* Release the lock and return the unregister result */
    LeaveCriticalSection(&RpcpCriticalSection);
    return I_RpcMapWin32Status(rpcStatus);
}

Referenced by SvchostBuildSharedGlobals().

RpcpStopRpcServerEx()

NTSTATUS NTAPI RpcpStopRpcServerEx

(

_In_ RPC_IF_HANDLE

IfSpec

)

Definition at line 58 of file rpcsrv.c.

{
    RPC_STATUS rpcStatus;
 
    /* Unregister the interface */
    rpcStatus = RpcServerUnregisterIfEx(IfSpec, NULL, TRUE);
 
    /* Acquire the lock while we dereference the RPC services */
    EnterCriticalSection(&RpcpCriticalSection);
    if (--RpcpNumInstances == 0)
    {
        /* All RPC services stopped, rundown the server */
        RpcMgmtStopServerListening(NULL);
        RpcMgmtWaitServerListen();
    }
 
    /* Release the lock and return the unregister result */
    LeaveCriticalSection(&RpcpCriticalSection);
    return I_RpcMapWin32Status(rpcStatus);
}

Referenced by SvchostBuildSharedGlobals().

Variable Documentation

RpcpCriticalSection

CRITICAL_SECTION RpcpCriticalSection

Definition at line 16 of file rpcsrv.c.

Referenced by RpcpInitRpcServer(), RpcpStartRpcServer(), RpcpStopRpcServer(), and RpcpStopRpcServerEx().

RpcpNumInstances

LONG RpcpNumInstances

Definition at line 15 of file rpcsrv.c.

Referenced by RpcpInitRpcServer(), RpcpStartRpcServer(), RpcpStopRpcServer(), and RpcpStopRpcServerEx().