ip.c File Reference

#include "precomp.h"
#include "lwip/netifapi.h"

Include dependency graph for ip.c:

Go to the source code of this file.

Macros
#define	__LWIP_INET_H__

Functions
VOID	TCPRegisterInterface (PIP_INTERFACE IF)
VOID	TCPUnregisterInterface (PIP_INTERFACE IF)
VOID	DeinitializePacket (PVOID Object)
VOID	FreeIF (PVOID Object)
PIP_PACKET	IPInitializePacket (PIP_PACKET IPPacket, ULONG Type)
VOID NTAPI	IPTimeoutDpcFn (PKDPC Dpc, PVOID DeferredContext, PVOID SystemArgument1, PVOID SystemArgument2)
VOID	IPDispatchProtocol (PIP_INTERFACE Interface, PIP_PACKET IPPacket)
PIP_INTERFACE	IPCreateInterface (PLLIP_BIND_INFO BindInfo)
VOID	IPDestroyInterface (PIP_INTERFACE IF)
VOID	IPAddInterfaceRoute (PIP_INTERFACE IF)
BOOLEAN	IPRegisterInterface (PIP_INTERFACE IF)
VOID	IPRemoveInterfaceRoute (PIP_INTERFACE IF)
VOID	IPUnregisterInterface (PIP_INTERFACE IF)
VOID	DefaultProtocolHandler (PIP_INTERFACE Interface, PIP_PACKET IPPacket)
VOID	IPRegisterProtocol (UINT ProtocolNumber, IP_PROTOCOL_HANDLER Handler)
NTSTATUS	IPStartup (PUNICODE_STRING RegistryPath)
NTSTATUS	IPShutdown (VOID)

Variables
LIST_ENTRY	InterfaceListHead
KSPIN_LOCK	InterfaceListLock
LIST_ENTRY	NetTableListHead
KSPIN_LOCK	NetTableListLock
BOOLEAN	IPInitialized = FALSE
BOOLEAN	IpWorkItemQueued = FALSE
IP_PROTOCOL_HANDLER	ProtocolTable [IP_PROTOCOL_TABLE_SIZE]
ULONG	IpTimerExpirations

Macro Definition Documentation

__LWIP_INET_H__

#define __LWIP_INET_H__

Definition at line 13 of file ip.c.

Function Documentation

DefaultProtocolHandler()

VOID DefaultProtocolHandler	(	PIP_INTERFACE	Interface,
		PIP_PACKET	IPPacket
	)

Definition at line 369 of file ip.c.

{
    TI_DbgPrint(MID_TRACE, ("[IF %x] Packet of unknown Internet protocol "
                "discarded.\n", Interface));
 
    Interface->Stats.InDiscardedUnknownProto++;
}

Referenced by IPRegisterProtocol(), and IPStartup().

DeinitializePacket()

VOID DeinitializePacket

(

PVOID

Object

)

Definition at line 35 of file ip.c.

{
    PIP_PACKET IPPacket = Object;
 
    TI_DbgPrint(MAX_TRACE, ("Freeing object: 0x%p\n", Object));
 
    /* Detect double free */
    ASSERT(IPPacket->Type != 0xFF);
    IPPacket->Type = 0xFF;
 
    /* Check if there's a packet to free */
    if (IPPacket->NdisPacket != NULL)
    {
        if (IPPacket->ReturnPacket)
        {
            /* Return the packet to the miniport driver */
            TI_DbgPrint(MAX_TRACE, ("Returning packet 0x%p\n",
                                    IPPacket->NdisPacket));
            NdisReturnPackets(&IPPacket->NdisPacket, 1);
        }
        else
        {
            /* Free it the conventional way */
            TI_DbgPrint(MAX_TRACE, ("Freeing packet 0x%p\n",
                                    IPPacket->NdisPacket));
            FreeNdisPacket(IPPacket->NdisPacket);
        }
    }
 
    /* Check if we have a pool-allocated header */
    if (!IPPacket->MappedHeader && IPPacket->Header)
    {
        /* Free it */
        TI_DbgPrint(MAX_TRACE, ("Freeing header: 0x%p\n",
                                IPPacket->Header));
        ExFreePoolWithTag(IPPacket->Header,
                          PACKET_BUFFER_TAG);
    }
}

Referenced by IPInitializePacket().

FreeIF()

VOID FreeIF

(

PVOID

Object

)

Definition at line 81 of file ip.c.

{
    ExFreePoolWithTag(Object, IP_INTERFACE_TAG);
}

Referenced by IPCreateInterface().

IPAddInterfaceRoute()

VOID IPAddInterfaceRoute

(

PIP_INTERFACE

IF

)

Definition at line 262 of file ip.c.

                                             {
    PNEIGHBOR_CACHE_ENTRY NCE;
    IP_ADDRESS NetworkAddress;
 
    /* Add a permanent neighbor for this NTE */
    NCE = NBAddNeighbor(IF, &IF->Unicast,
            IF->Address, IF->AddressLength,
            NUD_PERMANENT, 0);
    if (!NCE) {
    TI_DbgPrint(MIN_TRACE, ("Could not create NCE.\n"));
        return;
    }
 
    AddrWidenAddress( &NetworkAddress, &IF->Unicast, &IF->Netmask );
 
    if (!RouterAddRoute(&NetworkAddress, &IF->Netmask, NCE, 1)) {
    TI_DbgPrint(MIN_TRACE, ("Could not add route due to insufficient resources.\n"));
    }
 
    /* Send a gratuitous ARP packet to update the route caches of
     * other computers */
    if (IF != Loopback)
       ARPTransmit(NULL, NULL, IF);
 
    TCPUpdateInterfaceIPInformation(IF);
}

Referenced by DispTdiSetIPAddress(), LoopRegisterAdapter(), and ReadIpConfiguration().

IPCreateInterface()

PIP_INTERFACE IPCreateInterface

(

PLLIP_BIND_INFO

BindInfo

)

Definition at line 182 of file ip.c.

{
    PIP_INTERFACE IF;
 
    TI_DbgPrint(DEBUG_IP, ("Called. BindInfo (0x%X).\n", BindInfo));
 
#if DBG
    if (BindInfo->Address) {
        PUCHAR A = BindInfo->Address;
        TI_DbgPrint(DEBUG_IP, ("Interface address (%02X %02X %02X %02X %02X %02X).\n",
            A[0], A[1], A[2], A[3], A[4], A[5]));
    }
#endif
 
    IF = ExAllocatePoolWithTag(NonPagedPool, sizeof(IP_INTERFACE),
                               IP_INTERFACE_TAG);
    if (!IF) {
        TI_DbgPrint(MIN_TRACE, ("Insufficient resources.\n"));
        return NULL;
    }
 
    RtlZeroMemory(IF, sizeof(IP_INTERFACE));
 
    IF->Free       = FreeIF;
    IF->Context    = BindInfo->Context;
    IF->HeaderSize = BindInfo->HeaderSize;
    IF->MinFrameSize = BindInfo->MinFrameSize;
    IF->Address       = BindInfo->Address;
    IF->AddressLength = BindInfo->AddressLength;
    IF->Transmit      = BindInfo->Transmit;
 
    IF->Unicast.Type = IP_ADDRESS_V4;
    IF->PointToPoint.Type = IP_ADDRESS_V4;
    IF->Netmask.Type = IP_ADDRESS_V4;
    IF->Broadcast.Type = IP_ADDRESS_V4;
 
    TcpipInitializeSpinLock(&IF->Lock);
 
    IF->TCPContext = ExAllocatePool
    ( NonPagedPool, sizeof(struct netif));
    if (!IF->TCPContext) {
        ExFreePoolWithTag(IF, IP_INTERFACE_TAG);
        return NULL;
    }
 
    TCPRegisterInterface(IF);
 
    InsertTDIInterfaceEntity( IF );
 
    return IF;
}

Referenced by BindAdapter(), LoopRegisterAdapter(), and main().

IPDestroyInterface()

VOID IPDestroyInterface

(

PIP_INTERFACE

IF

)

Definition at line 244 of file ip.c.

{
    TI_DbgPrint(DEBUG_IP, ("Called. IF (0x%X).\n", IF));
 
    RemoveTDIInterfaceEntity( IF );
 
    TCPUnregisterInterface(IF);
 
    ExFreePool(IF->TCPContext);
    ExFreePoolWithTag(IF, IP_INTERFACE_TAG);
}

Referenced by BindAdapter(), LoopUnregisterAdapter(), and UnbindAdapter().

IPDispatchProtocol()

VOID IPDispatchProtocol	(	PIP_INTERFACE	Interface,
		PIP_PACKET	IPPacket
	)

Definition at line 142 of file ip.c.

{
    UINT Protocol;
    IP_ADDRESS SrcAddress;
 
    switch (IPPacket->Type) {
    case IP_ADDRESS_V4:
        Protocol = ((PIPv4_HEADER)(IPPacket->Header))->Protocol;
        AddrInitIPv4(&SrcAddress, ((PIPv4_HEADER)(IPPacket->Header))->SrcAddr);
        break;
    case IP_ADDRESS_V6:
        /* FIXME: IPv6 addresses not supported */
        TI_DbgPrint(MIN_TRACE, ("IPv6 datagram discarded.\n"));
        return;
    default:
        TI_DbgPrint(MIN_TRACE, ("Unrecognized datagram discarded.\n"));
        return;
    }
 
    NBResetNeighborTimeout(&SrcAddress);
 
    if (Protocol < IP_PROTOCOL_TABLE_SIZE)
    {
       /* Call the appropriate protocol handler */
       (*ProtocolTable[Protocol])(Interface, IPPacket);
    }
}

Referenced by ProcessFragment().

IPInitializePacket()

PIP_PACKET IPInitializePacket	(	PIP_PACKET	IPPacket,
		ULONG	Type
	)

Definition at line 92 of file ip.c.

{
    RtlZeroMemory(IPPacket, sizeof(IP_PACKET));
 
    IPPacket->Free     = DeinitializePacket;
    IPPacket->Type     = Type;
 
    return IPPacket;
}

Referenced by BuildRawIpPacket(), BuildUDPPacket(), LanReceiveWorker(), LoopTransmit(), ProcessFragment(), and TCPSendDataCallback().

IPRegisterInterface()

BOOLEAN IPRegisterInterface

(

PIP_INTERFACE

IF

)

Definition at line 289 of file ip.c.

{
    KIRQL OldIrql;
    UINT ChosenIndex = 0;
    BOOLEAN IndexHasBeenChosen;
    IF_LIST_ITER(Interface);
 
    TI_DbgPrint(MID_TRACE, ("Called. IF (0x%X).\n", IF));
 
    TcpipAcquireSpinLock(&IF->Lock, &OldIrql);
 
    /* Choose an index */
    do {
        IndexHasBeenChosen = TRUE;
        ForEachInterface(Interface) {
            if( Interface->Index == ChosenIndex ) {
                ChosenIndex++;
                IndexHasBeenChosen = FALSE;
            }
        } EndFor(Interface);
    } while( !IndexHasBeenChosen );
 
    IF->Index = ChosenIndex;
 
    /* Add interface to the global interface list */
    TcpipInterlockedInsertTailList(&InterfaceListHead,
                   &IF->ListEntry,
                   &InterfaceListLock);
 
    TcpipReleaseSpinLock(&IF->Lock, OldIrql);
 
    return TRUE;
}

Referenced by BindAdapter(), and LoopRegisterAdapter().

IPRegisterProtocol()

VOID IPRegisterProtocol	(	UINT	ProtocolNumber,
		IP_PROTOCOL_HANDLER	Handler
	)

Definition at line 386 of file ip.c.

{
    if (ProtocolNumber >= IP_PROTOCOL_TABLE_SIZE) {
        TI_DbgPrint(MIN_TRACE, ("Protocol number is out of range (%d).\n", ProtocolNumber));
        return;
    }
 
    ProtocolTable[ProtocolNumber] = Handler ? Handler : DefaultProtocolHandler;
}

Referenced by ICMPShutdown(), ICMPStartup(), IPStartup(), RawIPShutdown(), RawIPStartup(), TCPShutdown(), TCPStartup(), UDPShutdown(), and UDPStartup().

IPRemoveInterfaceRoute()

VOID IPRemoveInterfaceRoute

(

PIP_INTERFACE

IF

)

Definition at line 331 of file ip.c.

                                                {
    PNEIGHBOR_CACHE_ENTRY NCE;
    IP_ADDRESS GeneralRoute;
 
    NCE = NBLocateNeighbor(&IF->Unicast, IF);
    if (NCE)
    {
       TI_DbgPrint(DEBUG_IP,("Removing interface Addr %s\n", A2S(&IF->Unicast)));
       TI_DbgPrint(DEBUG_IP,("                   Mask %s\n", A2S(&IF->Netmask)));
 
       AddrWidenAddress(&GeneralRoute,&IF->Unicast,&IF->Netmask);
 
       RouterRemoveRoute(&GeneralRoute, &IF->Unicast);
 
       NBRemoveNeighbor(NCE);
    }
}

Referenced by DispTdiDeleteIPAddress(), DispTdiSetIPAddress(), and IPUnregisterInterface().

IPShutdown()

NTSTATUS IPShutdown

(

VOID

)

Definition at line 473 of file ip.c.

{
    TI_DbgPrint(MAX_TRACE, ("Called.\n"));
 
    if (!IPInitialized)
        return STATUS_SUCCESS;
 
    /* Shutdown neighbor cache subsystem */
    NBShutdown();
 
    /* Shutdown routing subsystem */
    RouterShutdown();
 
    IPFreeReassemblyList();
 
    /* Destroy lookaside lists */
    ExDeleteNPagedLookasideList(&IPHoleList);
    ExDeleteNPagedLookasideList(&IPDRList);
    ExDeleteNPagedLookasideList(&IPFragmentList);
 
    IPInitialized = FALSE;
 
    return STATUS_SUCCESS;
}

Referenced by TiUnload().

IPStartup()

NTSTATUS IPStartup

(

PUNICODE_STRING

RegistryPath

)

Definition at line 407 of file ip.c.

{
    UINT i;
 
    TI_DbgPrint(MAX_TRACE, ("Called.\n"));
 
    /* Initialize lookaside lists */
    ExInitializeNPagedLookasideList(
      &IPDRList,                      /* Lookaside list */
        NULL,                           /* Allocate routine */
        NULL,                           /* Free routine */
        0,                              /* Flags */
        sizeof(IPDATAGRAM_REASSEMBLY),  /* Size of each entry */
        DATAGRAM_REASSEMBLY_TAG,        /* Tag */
        0);                             /* Depth */
 
    ExInitializeNPagedLookasideList(
      &IPFragmentList,                /* Lookaside list */
        NULL,                           /* Allocate routine */
        NULL,                           /* Free routine */
        0,                              /* Flags */
        sizeof(IP_FRAGMENT),            /* Size of each entry */
        DATAGRAM_FRAGMENT_TAG,          /* Tag */
        0);                             /* Depth */
 
    ExInitializeNPagedLookasideList(
      &IPHoleList,                    /* Lookaside list */
        NULL,                           /* Allocate routine */
        NULL,                           /* Free routine */
        0,                              /* Flags */
        sizeof(IPDATAGRAM_HOLE),        /* Size of each entry */
        DATAGRAM_HOLE_TAG,              /* Tag */
        0);                             /* Depth */
 
    /* Start routing subsystem */
    RouterStartup();
 
    /* Start neighbor cache subsystem */
    NBStartup();
 
    /* Fill the protocol dispatch table with pointers
       to the default protocol handler */
    for (i = 0; i < IP_PROTOCOL_TABLE_SIZE; i++)
        IPRegisterProtocol(i, DefaultProtocolHandler);
 
    /* Initialize NTE list and protecting lock */
    InitializeListHead(&NetTableListHead);
    TcpipInitializeSpinLock(&NetTableListLock);
 
    /* Initialize reassembly list and protecting lock */
    InitializeListHead(&ReassemblyListHead);
    TcpipInitializeSpinLock(&ReassemblyListLock);
 
    IPInitialized = TRUE;
 
    return STATUS_SUCCESS;
}

Referenced by DriverEntry(), and main().

IPTimeoutDpcFn()

VOID NTAPI IPTimeoutDpcFn	(	PKDPC	Dpc,
		PVOID	DeferredContext,
		PVOID	SystemArgument1,
		PVOID	SystemArgument2
	)

Definition at line 112 of file ip.c.

{
    IpTimerExpirations++;
 
    if ((IpTimerExpirations % 10) == 0)
    {
        LogActiveObjects();
    }
 
    /* Check if datagram fragments have taken too long to assemble */
    IPDatagramReassemblyTimeout();
 
    /* Clean possible outdated cached neighbor addresses */
    NBTimeout();
}

Referenced by DriverEntry().

IPUnregisterInterface()

VOID IPUnregisterInterface

(

PIP_INTERFACE

IF

)

Definition at line 349 of file ip.c.

{
    KIRQL OldIrql3;
 
    TI_DbgPrint(DEBUG_IP, ("Called. IF (0x%X).\n", IF));
 
    IPRemoveInterfaceRoute( IF );
 
    TcpipAcquireSpinLock(&InterfaceListLock, &OldIrql3);
    RemoveEntryList(&IF->ListEntry);
    TcpipReleaseSpinLock(&InterfaceListLock, OldIrql3);
}

Referenced by BindAdapter(), LoopUnregisterAdapter(), and UnbindAdapter().

TCPRegisterInterface()

VOID TCPRegisterInterface

(

PIP_INTERFACE

IF

)

Definition at line 118 of file if.c.

{
    ip_addr_t ipaddr;
    ip_addr_t netmask;
    ip_addr_t gw;
 
    gw.addr = 0;
    ipaddr.addr = 0;
    netmask.addr = 0;
 
    IF->TCPContext = netif_add(IF->TCPContext,
                               &ipaddr,
                               &netmask,
                               &gw,
                               IF,
                               TCPInterfaceInit,
                               tcpip_input);
}

Referenced by IPCreateInterface().

TCPUnregisterInterface()

VOID TCPUnregisterInterface

(

PIP_INTERFACE

IF

)

Definition at line 138 of file if.c.

{
    netif_remove(IF->TCPContext);
}

Referenced by IPDestroyInterface().

Variable Documentation

InterfaceListHead

LIST_ENTRY InterfaceListHead

Definition at line 17 of file ip.c.

Referenced by DriverEntry(), and IPRegisterInterface().

InterfaceListLock

KSPIN_LOCK InterfaceListLock

Definition at line 18 of file ip.c.

Referenced by AddrLocateInterface(), CountInterfaces(), DriverEntry(), FindOnLinkInterface(), GetDefaultInterface(), IPRegisterInterface(), and IPUnregisterInterface().

IPInitialized

BOOLEAN IPInitialized = FALSE

Definition at line 21 of file ip.c.

Referenced by IPShutdown(), and IPStartup().

IpTimerExpirations

ULONG IpTimerExpirations

Definition at line 27 of file ip.c.

Referenced by IPTimeoutDpcFn().

IpWorkItemQueued

BOOLEAN IpWorkItemQueued = FALSE

Definition at line 22 of file ip.c.

NetTableListHead

LIST_ENTRY NetTableListHead

Definition at line 19 of file ip.c.

Referenced by IPStartup().

NetTableListLock

KSPIN_LOCK NetTableListLock

Definition at line 20 of file ip.c.

Referenced by IPStartup().

ProtocolTable

IP_PROTOCOL_HANDLER ProtocolTable[IP_PROTOCOL_TABLE_SIZE]

Definition at line 25 of file ip.c.

Referenced by IPDispatchProtocol(), and IPRegisterProtocol().