#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);
}