api.c File Reference

#include <rosdhcp.h>
#include <reactos/debug.h>

Include dependency graph for api.c:

Go to the source code of this file.

Macros
#define	NDEBUG

Functions
VOID	ApiInit ()
VOID	ApiLock ()
VOID	ApiUnlock ()
VOID	ApiFree ()
DWORD WINAPI	RpcThreadRoutine (LPVOID lpParameter)
HANDLE	InitRpc (VOID)
VOID	ShutdownRpc (VOID)
static PBYTE	GetVendorOption (_In_ PBYTE Data, _In_ ULONG Length, _In_ ULONG OptionId)
DWORD __stdcall	Server_EnableDhcp (_In_ PDHCP_SERVER_NAME ServerName, _In_ LPWSTR AdapterName, _In_ BOOL Enable)
DWORD __stdcall	Server_AcquireParameters (_In_ PDHCP_SERVER_NAME ServerName, _In_ LPWSTR AdapterName)
DWORD __stdcall	Server_AcquireParametersByBroadcast (_In_ PDHCP_SERVER_NAME ServerName, _In_ LPWSTR AdapterName)
DWORD __stdcall	Server_ReleaseParameters (_In_ PDHCP_SERVER_NAME ServerName, _In_ LPWSTR AdapterName)
DWORD __stdcall	Server_FallbackRefreshParams (_In_ PDHCP_SERVER_NAME ServerName, _In_ LPWSTR AdapterName)
DWORD __stdcall	Server_StaticRefreshParams (_In_ PDHCP_SERVER_NAME ServerName, _In_ DWORD AdapterIndex, _In_ DWORD Address, _In_ DWORD Netmask)
DWORD __stdcall	Server_RemoveDNSRegistrations (_In_ PDHCP_SERVER_NAME ServerName)
DWORD __stdcall	Server_RequestParams (_In_ PDHCP_SERVER_NAME ServerName, _In_ LPWSTR AdapterName, _In_ DHCPCAPI_CLASSID *ClassId, _In_ DHCPCAPI_PARAMS_ARRAY *SendParams, _In_ DHCPCAPI_PARAMS_ARRAY *RecdParams, _Inout_ LPDHCPCAPI_RESULT_ARRAY *RecdResults)

Variables
static CRITICAL_SECTION	ApiCriticalSection
HANDLE	hAdapterStateChangedEvent

Macro Definition Documentation

NDEBUG

#define NDEBUG

Definition at line 11 of file api.c.

Function Documentation

ApiFree()

VOID ApiFree

(

)

Definition at line 30 of file api.c.

               {
    DeleteCriticalSection( &ApiCriticalSection );
}

ApiInit()

VOID ApiInit

(

)

Definition at line 18 of file api.c.

               {
    InitializeCriticalSection( &ApiCriticalSection );
}

Referenced by init_client().

ApiLock()

VOID ApiLock

(

)

Definition at line 22 of file api.c.

               {
    EnterCriticalSection( &ApiCriticalSection );
}

Referenced by AdapterDiscoveryThread(), AdapterStop(), dispatch(), IsReconnectHackNeeded(), Server_AcquireParameters(), Server_EnableDhcp(), Server_FallbackRefreshParams(), Server_ReleaseParameters(), Server_RequestParams(), and Server_StaticRefreshParams().

ApiUnlock()

VOID ApiUnlock

(

)

Definition at line 26 of file api.c.

                 {
    LeaveCriticalSection( &ApiCriticalSection );
}

Referenced by AdapterDiscoveryThread(), AdapterStop(), dispatch(), IsReconnectHackNeeded(), Server_AcquireParameters(), Server_EnableDhcp(), Server_FallbackRefreshParams(), Server_ReleaseParameters(), Server_RequestParams(), and Server_StaticRefreshParams().

GetVendorOption()

static PBYTE GetVendorOption ( _In_ PBYTE  Data, _In_ ULONG  Length, _In_ ULONG  OptionId  )

static

Definition at line 78 of file api.c.

{
    DWORD Offset, OptionLength;
    PBYTE Ptr;
 
    Ptr = Data;
    Offset = 0;
    while (Offset < Length)
    {
        if ((DWORD)*Ptr == OptionId)
            return Ptr;
 
        OptionLength = (DWORD)*(Ptr + 1);
        Offset += (OptionLength + 2);
        Ptr += (OptionLength + 2);
    }
 
    return NULL;
}

Referenced by Server_RequestParams().

InitRpc()

HANDLE InitRpc

(

VOID

)

Definition at line 65 of file api.c.

{
    return CreateThread( NULL, 0, RpcThreadRoutine, (LPVOID)NULL, 0, NULL);
}

Referenced by ServiceMain().

RpcThreadRoutine()

DWORD WINAPI RpcThreadRoutine

(

LPVOID

lpParameter

)

Definition at line 36 of file api.c.

{
    RPC_STATUS Status;
 
    Status = RpcServerUseProtseqEpW(L"ncacn_np", 20, L"\\pipe\\dhcpcsvc", NULL);
    if (Status != RPC_S_OK)
    {
        DPRINT1("RpcServerUseProtseqEpW() failed (Status %lx)\n", Status);
        return 0;
    }
 
    Status = RpcServerRegisterIf(Server_dhcpcsvc_v0_0_s_ifspec, NULL, NULL);
    if (Status != RPC_S_OK)
    {
        DPRINT1("RpcServerRegisterIf() failed (Status %lx)\n", Status);
        return 0;
    }
 
    Status = RpcServerListen(1, RPC_C_LISTEN_MAX_CALLS_DEFAULT, FALSE);
    if (Status != RPC_S_OK)
    {
        DPRINT1("RpcServerListen() failed (Status %lx)\n", Status);
    }
 
    return 0;
}

Referenced by InitRpc().

Server_AcquireParameters()

DWORD __stdcall Server_AcquireParameters	(	_In_ PDHCP_SERVER_NAME	ServerName,
		_In_ LPWSTR	AdapterName
	)

Definition at line 173 of file api.c.

{
    PDHCP_ADAPTER Adapter;
    struct protocol* proto;
    DWORD ret = ERROR_SUCCESS;
 
    DPRINT("Server_AcquireParameters(%S)\n", AdapterName);
 
    ApiLock();
 
    Adapter = AdapterFindName(AdapterName);
    if (Adapter == NULL || Adapter->DhclientState.state == S_STATIC)
    {
        ret = ERROR_FILE_NOT_FOUND;
        goto done;
    }
 
    DPRINT("Adapter: %p\n", Adapter);
 
    proto = find_protocol_by_adapter(&Adapter->DhclientInfo);
    if (proto)
        remove_protocol(proto);
 
    add_protocol(Adapter->DhclientInfo.name,
                 Adapter->DhclientInfo.rfdesc, got_one,
                 &Adapter->DhclientInfo);
 
    Adapter->DhclientInfo.client->state = S_INIT;
    state_reboot(&Adapter->DhclientInfo);
 
    if (hAdapterStateChangedEvent != NULL)
        SetEvent(hAdapterStateChangedEvent);
 
done:
    ApiUnlock();
 
    return ret;
}

Server_AcquireParametersByBroadcast()

DWORD __stdcall Server_AcquireParametersByBroadcast	(	_In_ PDHCP_SERVER_NAME	ServerName,
		_In_ LPWSTR	AdapterName
	)

Definition at line 217 of file api.c.

{
    DPRINT1("Server_AcquireParametersByBroadcast(%S) is unimplemented!\n", AdapterName);
    return ERROR_SUCCESS;
}

Server_EnableDhcp()

DWORD __stdcall Server_EnableDhcp	(	_In_ PDHCP_SERVER_NAME	ServerName,
		_In_ LPWSTR	AdapterName,
		_In_ BOOL	Enable
	)

Definition at line 106 of file api.c.

{
    PDHCP_ADAPTER Adapter;
    struct protocol* proto;
    DWORD ret = ERROR_SUCCESS;
 
    DPRINT1("Server_EnableDhcp(%S %u)\n", AdapterName, Enable);
 
    ApiLock();
 
    Adapter = AdapterFindName(AdapterName);
    if (Adapter == NULL)
    {
        ret = ERROR_FILE_NOT_FOUND;
        goto done;
    }
 
    DPRINT1("Adapter: %p\n", Adapter);
 
    if (Enable)
    {
        DPRINT1("Enable DHCP for Adapter: %p\n", Adapter);
 
        if (Adapter->DhclientState.state != S_STATIC)
        {
            DPRINT1("The Adapter is already enabled!\n");
            goto done;
        }
 
        add_protocol(Adapter->DhclientInfo.name,
                     Adapter->DhclientInfo.rfdesc, got_one,
                     &Adapter->DhclientInfo);
 
        Adapter->DhclientInfo.client->state = S_INIT;
        state_reboot(&Adapter->DhclientInfo);
    }
    else
    {
        DPRINT1("Disable DHCP for Adapter: %p\n", Adapter);
 
        if (Adapter->DhclientState.state == S_STATIC)
        {
            DPRINT1("The Adapter is already disabled!\n");
            goto done;
        }
 
        Adapter->DhclientState.state = S_STATIC;
        proto = find_protocol_by_adapter(&Adapter->DhclientInfo);
        if (proto)
            remove_protocol(proto);
    }
 
    if (hAdapterStateChangedEvent != NULL)
        SetEvent(hAdapterStateChangedEvent);
 
done:
    ApiUnlock();
 
    return ret;
}

Server_FallbackRefreshParams()

DWORD __stdcall Server_FallbackRefreshParams	(	_In_ PDHCP_SERVER_NAME	ServerName,
		_In_ LPWSTR	AdapterName
	)

Definition at line 267 of file api.c.

{
    PDHCP_ADAPTER Adapter;
    HKEY hAdapterKey;
    DWORD ret = ERROR_SUCCESS;
 
    DPRINT("Server_FallbackRefreshParams(%S)\n", AdapterName);
 
    ApiLock();
 
    Adapter = AdapterFindName(AdapterName);
    if (Adapter == NULL)
    {
        ret = ERROR_FILE_NOT_FOUND;
        goto done;
    }
 
    DPRINT("Adapter: %p\n", Adapter);
 
    if (Adapter->AlternateConfiguration)
    {
        free(Adapter->AlternateConfiguration);
        Adapter->AlternateConfiguration = NULL;
    }
 
    hAdapterKey = FindAdapterKey(Adapter);
    if (hAdapterKey)
    {
        ret = LoadAlternateConfiguration(Adapter, hAdapterKey);
        RegCloseKey(hAdapterKey);
    }
 
done:
    ApiUnlock();
 
    return ret;
}

Server_ReleaseParameters()

DWORD __stdcall Server_ReleaseParameters	(	_In_ PDHCP_SERVER_NAME	ServerName,
		_In_ LPWSTR	AdapterName
	)

Definition at line 228 of file api.c.

{
    PDHCP_ADAPTER Adapter;
    struct protocol* proto;
    DWORD ret = ERROR_SUCCESS;
 
    DPRINT("Server_ReleaseParameters(%S)\n", AdapterName);
 
    ApiLock();
 
    Adapter = AdapterFindName(AdapterName);
    if (Adapter == NULL)
    {
        ret = ERROR_FILE_NOT_FOUND;
        goto done;
    }
 
    DPRINT("Adapter: %p\n", Adapter);
 
    state_release(&Adapter->DhclientInfo);
 
    proto = find_protocol_by_adapter(&Adapter->DhclientInfo);
    if (proto)
        remove_protocol(proto);
 
    if (hAdapterStateChangedEvent != NULL)
        SetEvent(hAdapterStateChangedEvent);
 
done:
    ApiUnlock();
 
    return ret;
}

Server_RemoveDNSRegistrations()

DWORD __stdcall Server_RemoveDNSRegistrations

(

_In_ PDHCP_SERVER_NAME

ServerName

)

Definition at line 368 of file api.c.

{
    DPRINT1("Server_RemoveDNSRegistrations()\n");
    /* FIXME: Call dnsapi.DnsRemoveRegistrations() */
    return ERROR_SUCCESS;
}

Server_RequestParams()

DWORD __stdcall Server_RequestParams	(	_In_ PDHCP_SERVER_NAME	ServerName,
		_In_ LPWSTR	AdapterName,
		_In_ DHCPCAPI_CLASSID *	ClassId,
		_In_ DHCPCAPI_PARAMS_ARRAY *	SendParams,
		_In_ DHCPCAPI_PARAMS_ARRAY *	RecdParams,
		_Inout_ LPDHCPCAPI_RESULT_ARRAY *	RecdResults
	)

Definition at line 379 of file api.c.

{
    PDHCP_ADAPTER Adapter;
    DHCPCAPI_RESULT_ARRAY *Results = NULL;
    DWORD i, dwReturnCount, dwReturnLength;
    DWORD OptionId, DataSize, Offset, Index;
    PBYTE Data, OptionPtr;
    struct option_data *Options;
    DWORD ret = ERROR_SUCCESS;
 
    DPRINT("Server_RequestParams(%S %p %p %p %p)\n",
           AdapterName, ClassId, SendParams, RecdParams, RecdResults);
 
#if 0
    if (SendParams != NULL)
    {
        DPRINT1("SendParams nParams %lu  Params %p\n", SendParams->nParams, SendParams->Params);
        for (i = 0; i < SendParams->nParams; i++)
        {
            DPRINT1("SendParam %lu: Option %lu  Vendor %u\n", i, SendParams->Params[i].OptionId, SendParams->Params[i].IsVendor);
        }
    }
 
    if (RecdParams != NULL)
    {
        DPRINT1("RecdParams nParams %lu  Params %p\n", RecdParams->nParams, RecdParams->Params);
        for (i = 0; i < RecdParams->nParams; i++)
        {
            DPRINT1("RecdParam %lu: Option %lu  Vendor %u\n", i, RecdParams->Params[i].OptionId, RecdParams->Params[i].IsVendor);
        }
    }
#endif
 
    ApiLock();
 
    Adapter = AdapterFindName(AdapterName);
    if (Adapter == NULL)
    {
        DPRINT1("Adapter not found\n");
        ret = ERROR_FILE_NOT_FOUND;
        goto done;
    }
 
    DPRINT("Adapter: %p\n", Adapter);
 
    if (Adapter->DhclientState.state != S_BOUND)
    {
        DPRINT1("Adapter is not in S_BOUND state!\n");
        ret = ERROR_FILE_NOT_FOUND;
        goto done;
    }
 
    dwReturnCount = 0;
    dwReturnLength = 0;
 
    DPRINT("ActiveLease: %p \n", Adapter->DhclientState.active);
    if (Adapter->DhclientState.active)
    {
        Options = Adapter->DhclientState.active->options;
        for (i = 0; i < RecdParams->nParams; i++)
        {
            OptionId = RecdParams->Params[i].OptionId;
            if (RecdParams->Params[i].IsVendor == FALSE)
            {
                DPRINT("Option %u: Length %d \n", OptionId, Options[OptionId].len);
                if (Options[OptionId].len != 0)
                {
                    dwReturnLength += Options[OptionId].len;
                    dwReturnCount++;
                }
            }
            else
            {
                if (Options[DHO_VENDOR_ENCAPSULATED_OPTIONS].len != 0)
                {
                    DPRINT("Have vendor options!\n");
                    OptionPtr = GetVendorOption(Options[DHO_VENDOR_ENCAPSULATED_OPTIONS].data,
                                                Options[DHO_VENDOR_ENCAPSULATED_OPTIONS].len,
                                                OptionId);
                    if (OptionPtr)
                    {
                        DPRINT("Vendor option %lu: Length %lu\n", OptionId, (DWORD)*(OptionPtr + 1));
                        dwReturnLength += (DWORD)*(OptionPtr + 1);
                        dwReturnCount++;
                    }
                }
            }
        }
 
        DPRINT("Return count: %lu  Return length: %lu\n", dwReturnCount, dwReturnLength);
 
        Results = MIDL_user_allocate(sizeof(DHCPCAPI_RESULT_ARRAY));
        if (Results == NULL)
        {
            DPRINT1("Result allocation failed!\n");
            ret = ERROR_NOT_ENOUGH_MEMORY;
            goto done;
        }
 
        Results->ResultsCount = dwReturnCount;
        Results->Results = MIDL_user_allocate(dwReturnCount * sizeof(DHCPCAPI_RESULTS));
        if (Results->Results == NULL)
        {
            DPRINT1("Results allocation failed!\n");
            ret = ERROR_NOT_ENOUGH_MEMORY;
            goto done;
        }
 
        Results->DataSize = dwReturnLength;
        Results->Data = MIDL_user_allocate(dwReturnLength);
        if (Results->Data == NULL)
        {
            DPRINT1("Data allocation failed!\n");
            ret = ERROR_NOT_ENOUGH_MEMORY;
            goto done;
        }
 
        Offset = 0;
        Index = 0;
        for (i = 0; i < RecdParams->nParams; i++)
        {
            OptionId = RecdParams->Params[i].OptionId;
 
            if (RecdParams->Params[i].IsVendor == FALSE)
            {
                DataSize = Options[OptionId].len;
                Data = Options[OptionId].data;
 
                DPRINT("Option %u: Length %d \n", OptionId, DataSize);
 
                if (DataSize != 0)
                {
                    Results->Results[Index].OptionId = OptionId;
                    Results->Results[Index].IsVendor = FALSE;
                    Results->Results[Index].DataSize = DataSize;
                    Results->Results[Index].DataOffset = Offset;
 
                    CopyMemory(&Results->Data[Offset], Data, DataSize);
 
                    Index++;
                    Offset += DataSize;
                }
            }
            else
            {
                if (Options[DHO_VENDOR_ENCAPSULATED_OPTIONS].len != 0)
                {
                    DPRINT1("Have vendor options!\n");
                    OptionPtr = GetVendorOption(Options[DHO_VENDOR_ENCAPSULATED_OPTIONS].data,
                                                Options[DHO_VENDOR_ENCAPSULATED_OPTIONS].len,
                                                OptionId);
                    if (OptionPtr)
                    {
                        DataSize = (DWORD)*(OptionPtr + 1);
                        Data = (OptionPtr + 2);
 
                        DPRINT1("Vendor option %u: Length %d\n", OptionId, DataSize);
 
                        Results->Results[Index].OptionId = OptionId;
                        Results->Results[Index].IsVendor = TRUE;
                        Results->Results[Index].DataSize = DataSize;
                        Results->Results[Index].DataOffset = Offset;
 
                        CopyMemory(&Results->Data[Offset], Data, DataSize);
 
                        Index++;
                        Offset += DataSize;
                    }
                }
            }
        }
 
        *RecdResults = Results;
    }
 
done:
    ApiUnlock();
 
    return ret;
}

Server_StaticRefreshParams()

DWORD __stdcall Server_StaticRefreshParams	(	_In_ PDHCP_SERVER_NAME	ServerName,
		_In_ DWORD	AdapterIndex,
		_In_ DWORD	Address,
		_In_ DWORD	Netmask
	)

Definition at line 311 of file api.c.

{
    PDHCP_ADAPTER Adapter;
    struct protocol* proto;
    DWORD ret = ERROR_SUCCESS;
 
    DPRINT("Server_StaticRefreshParams()\n");
 
    ApiLock();
 
    Adapter = AdapterFindIndex(AdapterIndex);
    if (Adapter == NULL)
    {
        ret = ERROR_FILE_NOT_FOUND;
        goto done;
    }
 
    DPRINT("Adapter: %p\n", Adapter);
 
    if (Adapter->NteContext)
    {
        DeleteIPAddress(Adapter->NteContext);
        Adapter->NteContext = 0;
    }
    if (Adapter->RouterMib.dwForwardNextHop)
    {
        DeleteIpForwardEntry(&Adapter->RouterMib);
        Adapter->RouterMib.dwForwardNextHop = 0;
    }
 
    Adapter->DhclientState.state = S_STATIC;
    proto = find_protocol_by_adapter(&Adapter->DhclientInfo);
    if (proto)
        remove_protocol(proto);
 
    ret = AddIPAddress(Address,
                       Netmask,
                       AdapterIndex,
                       &Adapter->NteContext,
                       &Adapter->NteInstance);
 
    if (hAdapterStateChangedEvent != NULL)
        SetEvent(hAdapterStateChangedEvent);
 
done:
    ApiUnlock();
 
    return ret;
}

ShutdownRpc()

VOID ShutdownRpc

(

VOID

)

Definition at line 71 of file api.c.

{
    RpcMgmtStopServerListening(NULL);
}

Referenced by ServiceMain().

Variable Documentation

ApiCriticalSection

CRITICAL_SECTION ApiCriticalSection

static

Definition at line 14 of file api.c.

Referenced by ApiFree(), ApiInit(), ApiLock(), and ApiUnlock().

hAdapterStateChangedEvent

HANDLE hAdapterStateChangedEvent

extern

Definition at line 21 of file dhcpcsvc.c.

Referenced by Server_AcquireParameters(), Server_EnableDhcp(), Server_ReleaseParameters(), and Server_StaticRefreshParams().