#include <ip.h>

Include dependency graph for receive.h:

This graph shows which files directly or indirectly include this file:

Classes
struct	IP_FRAGMENT

struct	IPDATAGRAM_HOLE

struct	IPDATAGRAM_REASSEMBLY

Macros
#define	MAX_TIMEOUT_COUNT 3

Typedefs
typedef struct IP_FRAGMENT	IP_FRAGMENT

typedef struct IP_FRAGMENT *	PIP_FRAGMENT

typedef struct IPDATAGRAM_HOLE	IPDATAGRAM_HOLE

typedef struct IPDATAGRAM_HOLE *	PIPDATAGRAM_HOLE

typedef struct IPDATAGRAM_REASSEMBLY	IPDATAGRAM_REASSEMBLY

typedef struct IPDATAGRAM_REASSEMBLY *	PIPDATAGRAM_REASSEMBLY

Functions
VOID	IPFreeReassemblyList (VOID)

VOID	IPDatagramReassemblyTimeout (VOID)

VOID	IPReceive (PIP_INTERFACE IF, PIP_PACKET IPPacket)

Variables
LIST_ENTRY	ReassemblyListHead

KSPIN_LOCK	ReassemblyListLock

NPAGED_LOOKASIDE_LIST	IPDRList

NPAGED_LOOKASIDE_LIST	IPFragmentList

NPAGED_LOOKASIDE_LIST	IPHoleList

Macro Definition Documentation

◆ MAX_TIMEOUT_COUNT

#define MAX_TIMEOUT_COUNT 3

Definition at line 13 of file receive.h.

Typedef Documentation

◆ IP_FRAGMENT

typedef struct IP_FRAGMENT IP_FRAGMENT

◆ IPDATAGRAM_HOLE

typedef struct IPDATAGRAM_HOLE IPDATAGRAM_HOLE

◆ IPDATAGRAM_REASSEMBLY

typedef struct IPDATAGRAM_REASSEMBLY IPDATAGRAM_REASSEMBLY

◆ PIP_FRAGMENT

typedef struct IP_FRAGMENT * PIP_FRAGMENT

◆ PIPDATAGRAM_HOLE

typedef struct IPDATAGRAM_HOLE * PIPDATAGRAM_HOLE

◆ PIPDATAGRAM_REASSEMBLY

typedef struct IPDATAGRAM_REASSEMBLY * PIPDATAGRAM_REASSEMBLY

Function Documentation

◆ IPDatagramReassemblyTimeout()

VOID IPDatagramReassemblyTimeout ( VOID )

Definition at line 515 of file receive.c.

 {
     PLIST_ENTRY CurrentEntry, NextEntry;
     PIPDATAGRAM_REASSEMBLY CurrentIPDR;
 
     TcpipAcquireSpinLockAtDpcLevel(&ReassemblyListLock);
 
     CurrentEntry = ReassemblyListHead.Flink;
     while (CurrentEntry != &ReassemblyListHead)
     {
        NextEntry = CurrentEntry->Flink;
        CurrentIPDR = CONTAINING_RECORD(CurrentEntry, IPDATAGRAM_REASSEMBLY, ListEntry);
 
        TcpipAcquireSpinLockAtDpcLevel(&CurrentIPDR->Lock);
 
        if (++CurrentIPDR->TimeoutCount == MAX_TIMEOUT_COUNT)
        {
            TcpipReleaseSpinLockFromDpcLevel(&CurrentIPDR->Lock);
            RemoveEntryList(CurrentEntry);
            FreeIPDR(CurrentIPDR);
        } 
        else
        {
            ASSERT(CurrentIPDR->TimeoutCount < MAX_TIMEOUT_COUNT);
            TcpipReleaseSpinLockFromDpcLevel(&CurrentIPDR->Lock);
        }
 
        CurrentEntry = NextEntry;
     }
 
     TcpipReleaseSpinLockFromDpcLevel(&ReassemblyListLock);
 }

Referenced by IPTimeoutDpcFn().

◆ IPFreeReassemblyList()

VOID IPFreeReassemblyList ( VOID )

Definition at line 485 of file receive.c.

 {
   KIRQL OldIrql;
   PLIST_ENTRY CurrentEntry, NextEntry;
   PIPDATAGRAM_REASSEMBLY Current;
 
   TcpipAcquireSpinLock(&ReassemblyListLock, &OldIrql);
 
   CurrentEntry = ReassemblyListHead.Flink;
   while (CurrentEntry != &ReassemblyListHead) {
     NextEntry = CurrentEntry->Flink;
     Current = CONTAINING_RECORD(CurrentEntry, IPDATAGRAM_REASSEMBLY, ListEntry);
 
     /* Unlink it from the list */
     RemoveEntryList(CurrentEntry);
 
     /* And free the descriptor */
     FreeIPDR(Current);
 
     CurrentEntry = NextEntry;
   }
 
   TcpipReleaseSpinLock(&ReassemblyListLock, OldIrql);
 }

Referenced by IPShutdown().

◆ IPReceive()

VOID IPReceive	(	PIP_INTERFACE	IF,
		PIP_PACKET	IPPacket
	)

Definition at line 638 of file receive.c.

 {
     UCHAR FirstByte;
     UINT Version, BytesCopied;
 
     /* Read in the first IP header byte for version information */
     BytesCopied = CopyPacketToBuffer((PCHAR)&FirstByte,
                                      IPPacket->NdisPacket,
                                      IPPacket->Position,
                                      sizeof(UCHAR));
     if (BytesCopied != sizeof(UCHAR))
     {
         TI_DbgPrint(MIN_TRACE, ("Failed to copy in first byte\n"));
         IPPacket->Free(IPPacket);
         return;
     }
 
     /* Check that IP header has a supported version */
     Version = (FirstByte >> 4);
 
     switch (Version) {
         case 4:
             IPPacket->Type = IP_ADDRESS_V4;
             IPv4Receive(IF, IPPacket);
             break;
         case 6:
             IPPacket->Type = IP_ADDRESS_V6;
             TI_DbgPrint(MAX_TRACE, ("Datagram of type IPv6 discarded.\n"));
             break;
         default:
             TI_DbgPrint(MIN_TRACE, ("Datagram has an unsupported IP version %d.\n", Version));
             break;
     }
 
     IPPacket->Free(IPPacket);
 }