[jgardou] 65362: [TCPIP] Start a new implementation using lwip *for real*. The goal being to let lwip do all the dirty work for us, taking the full power of it, including TCP, ICMP, SNMP, UDP, raw ...
Author: jgardou Date: Mon Nov 10 18:00:09 2014 New Revision: 65362
URL: http://svn.reactos.org/svn/reactos?rev=65362&view=rev Log: [TCPIP] Start a new implementation using lwip *for real*. The goal being to let lwip do all the dirty work for us, taking the full power of it, including TCP, ICMP, SNMP, UDP, raw IP, etc. Commmit what I got so far, including: - registering the tcp/ip protocol to NDIS - Creating the loopback/adapter interface as wrappers around lwip_netif structures. - Querying a few pieces of information from the said interface. - Sending and receiving raw/UDP diagrams through lwip (not quite working yet, but soon). - Registering entities "instances".
Added: branches/tcpip_revolution/drivers/network/tcpip/CMakeLists.txt (with props) branches/tcpip_revolution/drivers/network/tcpip/address.c (with props) branches/tcpip_revolution/drivers/network/tcpip/address.h (with props) branches/tcpip_revolution/drivers/network/tcpip/connection.c (with props) branches/tcpip_revolution/drivers/network/tcpip/entities.c (with props) branches/tcpip_revolution/drivers/network/tcpip/entities.h (with props) branches/tcpip_revolution/drivers/network/tcpip/information.c (with props) branches/tcpip_revolution/drivers/network/tcpip/information.h (with props) branches/tcpip_revolution/drivers/network/tcpip/interface.c (with props) branches/tcpip_revolution/drivers/network/tcpip/interface.h (with props) branches/tcpip_revolution/drivers/network/tcpip/main.c (with props) branches/tcpip_revolution/drivers/network/tcpip/ndis_lwip.c (with props) branches/tcpip_revolution/drivers/network/tcpip/ndis_lwip.h (with props) branches/tcpip_revolution/drivers/network/tcpip/precomp.h (with props) branches/tcpip_revolution/drivers/network/tcpip/stubs.c (with props) branches/tcpip_revolution/drivers/network/tcpip/tcp.c (with props) branches/tcpip_revolution/drivers/network/tcpip/tcp.h (with props) branches/tcpip_revolution/drivers/network/tcpip/tcpip.rc (with props) branches/tcpip_revolution/drivers/network/tcpip/tcpip.spec (with props)
Added: branches/tcpip_revolution/drivers/network/tcpip/CMakeLists.txt URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/CMakeLists.txt (added) +++ branches/tcpip_revolution/drivers/network/tcpip/CMakeLists.txt [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,31 @@ + +include_directories( + ${REACTOS_SOURCE_DIR}/lib/drivers/lwip/src/include + ${REACTOS_SOURCE_DIR}/lib/drivers/lwip/src/include/ipv4) + +add_definitions(-DNDIS51) + +spec2def(tcpip.sys tcpip.spec) + +list(APPEND SOURCE + address.c + entities.c + information.c + interface.c + main.c + ndis_lwip.c + tcp.c + stubs.c + precomp.h +) + +add_library(tcpip SHARED + ${SOURCE} + tcpip.rc + ${CMAKE_CURRENT_BINARY_DIR}/tcpip.def) + +target_link_libraries(tcpip lwip ${PSEH_LIB} libcntpr) +set_module_type(tcpip kernelmodedriver) +add_importlibs(tcpip ndis ntoskrnl hal) +add_pch(tcpip precomp.h SOURCE) +add_cd_file(TARGET tcpip DESTINATION reactos/system32/drivers FOR all)
Propchange: branches/tcpip_revolution/drivers/network/tcpip/CMakeLists.txt ------------------------------------------------------------------------------ svn:eol-style = native
Added: branches/tcpip_revolution/drivers/network/tcpip/address.c URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/address.c (added) +++ branches/tcpip_revolution/drivers/network/tcpip/address.c [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,584 @@ +/* + * PROJECT: ReactOS tcpip.sys + * COPYRIGHT: GPL - See COPYING in the top level directory + * FILE: drivers/network/tcpip/address.c + * PURPOSE: tcpip.sys: addresses abstraction + */ + +#include "precomp.h" + +#define NDEBUG +#include <debug.h> + +typedef struct +{ + LIST_ENTRY ListEntry; + TDI_ADDRESS_IP RemoteAddress; + PIRP Irp; + PVOID Buffer; + ULONG BufferLength; + PTDI_CONNECTION_INFORMATION ReturnInfo; +} RECEIVE_DATAGRAM_REQUEST; + +/* The pool tags we will use for all of our allocation */ +#define TAG_ADDRESS_FILE 'FrdA' + +/* The list of shared addresses */ +static KSPIN_LOCK AddressListLock; +static LIST_ENTRY AddressListHead; + +void +TcpIpInitializeAddresses(void) +{ + KeInitializeSpinLock(&AddressListLock); + InitializeListHead(&AddressListHead); +} + +static +BOOLEAN +AddrIsUnspecified( + _In_ PTDI_ADDRESS_IP Address) +{ + return ((Address->in_addr == 0) || (Address->in_addr == 0xFFFFFFFF)); +} + +static +BOOLEAN +ReceiveDatagram( + ADDRESS_FILE* AddressFile, + struct pbuf *p, + ip_addr_t *addr, + u16_t port, + BOOLEAN MustFree) +{ + KIRQL OldIrql; + LIST_ENTRY* ListEntry; + RECEIVE_DATAGRAM_REQUEST* Request; + ip_addr_t RequestAddr; + BOOLEAN Result = FALSE; + + /* Block any cancellation that could occur */ + IoAcquireCancelSpinLock(&OldIrql); + KeAcquireSpinLockAtDpcLevel(&AddressFile->RequestLock); + + ListEntry = AddressFile->RequestListHead.Flink; + while (ListEntry != &AddressFile->RequestListHead) + { + Request = CONTAINING_RECORD(ListEntry, RECEIVE_DATAGRAM_REQUEST, ListEntry); + ListEntry = ListEntry->Flink; + + ip4_addr_set_u32(&RequestAddr, Request->RemoteAddress.in_addr); + + if ((RequestAddr.addr == IPADDR_ANY) || + (ip_addr_cmp(&RequestAddr, addr) && + ((Request->RemoteAddress.sin_port == port) || !port))) + { + PTA_IP_ADDRESS ReturnAddress; + + /* We found a request for this one */ + IoSetCancelRoutine(Request->Irp, NULL); + RemoveEntryList(&Request->ListEntry); + + KeReleaseSpinLockFromDpcLevel(&AddressFile->RequestLock); + IoReleaseCancelSpinLock(OldIrql); + + /* Return what we have to */ + pbuf_copy_partial(p, Request->Buffer, Request->BufferLength, 0); + ReturnAddress = Request->ReturnInfo->RemoteAddress; + ReturnAddress->Address->AddressLength = TDI_ADDRESS_LENGTH_IP; + ReturnAddress->Address->AddressType = TDI_ADDRESS_TYPE_IP; + ReturnAddress->Address->Address->sin_port = port; + ReturnAddress->Address->Address->in_addr = ip4_addr_get_u32(addr); + RtlZeroMemory(ReturnAddress->Address->Address->sin_zero, + sizeof(ReturnAddress->Address->Address->sin_zero)); + + Request->Irp->IoStatus.Status = STATUS_SUCCESS; + + Result = TRUE; + + IoCompleteRequest(Request->Irp, IO_NETWORK_INCREMENT); + + ExFreePoolWithTag(Request, TAG_ADDRESS_FILE); + + /* Restart from the beginning of the list */ + IoAcquireCancelSpinLock(&OldIrql); + KeAcquireSpinLockAtDpcLevel(&AddressFile->RequestLock); + ListEntry = AddressFile->RequestListHead.Flink; + } + } + + KeReleaseSpinLockFromDpcLevel(&AddressFile->RequestLock); + IoReleaseCancelSpinLock(OldIrql); + if (Result || MustFree) + pbuf_free(p); + + return Result; +} + +static +void +lwip_udp_ReceiveDatagram_callback( + void *arg, + struct udp_pcb *pcb, + struct pbuf *p, + ip_addr_t *addr, + u16_t port) +{ + UNREFERENCED_PARAMETER(pcb); + + ReceiveDatagram(arg, p, addr, port, TRUE); +} + +static +u8_t +lwip_raw_ReceiveDatagram_callback( + void *arg, + struct raw_pcb *pcb, + struct pbuf *p, + ip_addr_t *addr) +{ + UNREFERENCED_PARAMETER(pcb); + + return ReceiveDatagram(arg, p, addr, 0, FALSE); +} + +NTSTATUS +TcpIpCreateAddress( + _Inout_ PIRP Irp, + _Inout_ PTDI_ADDRESS_IP Address, + _In_ IPPROTO Protocol +) +{ + PIO_STACK_LOCATION IrpSp = IoGetCurrentIrpStackLocation(Irp); + ADDRESS_FILE *AddressFile; + LIST_ENTRY* ListEntry; + KIRQL OldIrql; + USHORT Port = 1; + + /* See if this port is already taken, and find a free one if needed. */ + KeAcquireSpinLock(&AddressListLock, &OldIrql); + + ListEntry = AddressListHead.Flink; + while (ListEntry != &AddressListHead) + { + AddressFile = CONTAINING_RECORD(ListEntry, ADDRESS_FILE, ListEntry); + + if (Address->sin_port) + { + if ((AddressFile->Protocol == Protocol) && + (AddressFile->Address.sin_port == Address->sin_port)) + { + if (IrpSp->Parameters.Create.ShareAccess) + { + /* Good, we found the shared address we were looking for */ + InterlockedIncrement(&AddressFile->RefCount); + KeReleaseSpinLock(&AddressListLock, OldIrql); + goto Success; + } + + KeReleaseSpinLock(&AddressListLock, OldIrql); + return STATUS_ADDRESS_ALREADY_EXISTS; + } + } + else if ((AddressFile->Address.sin_port == Port) + && AddressFile->Protocol == Protocol) + { + Port++; + if (Port == 0) + { + /* Oh no. Already 65535 ports occupied! */ + DPRINT1("No more free ports for protocol %d!\n", Protocol); + KeReleaseSpinLock(&AddressListLock, OldIrql); + return STATUS_TOO_MANY_ADDRESSES; + } + + /* We must start anew to check again the previous entries in the list */ + ListEntry = &AddressListHead; + } + ListEntry = ListEntry->Flink; + } + + if (!AddrIsUnspecified(Address)) + { + /* Find the local interface for this address */ + struct netif* lwip_netif = netif_list; + ip_addr_t IpAddr; + + ip4_addr_set_u32(&IpAddr, AddressFile->Address.in_addr); + while (lwip_netif) + { + if (ip_addr_cmp(&IpAddr, &lwip_netif->ip_addr)) + { + break; + } + lwip_netif = lwip_netif->next; + } + + if (!lwip_netif) + { + DPRINT1("Cound not find an interface for address 0x08x\n", AddressFile->Address.in_addr); + KeReleaseSpinLock(&AddressListLock, OldIrql); + return STATUS_INVALID_ADDRESS; + } + } + + /* Allocate our new address file */ + AddressFile = ExAllocatePoolWithTag(NonPagedPool, sizeof(*AddressFile), TAG_ADDRESS_FILE); + if (!AddressFile) + { + return STATUS_NO_MEMORY; + } + + RtlZeroMemory(AddressFile, sizeof(*AddressFile)); + AddressFile->RefCount = 1; + RtlCopyMemory(&AddressFile->Address, Address, sizeof(*Address)); + AddressFile->Protocol = Protocol; + if (!Address->sin_port) + AddressFile->Address.sin_port = Port; + + /* Initialize the datagram request stuff */ + KeInitializeSpinLock(&AddressFile->RequestLock); + InitializeListHead(&AddressFile->RequestListHead); + + /* Give it an entity ID and open a PCB is needed. */ + switch (Protocol) + { + case IPPROTO_TCP: + InsertEntityInstance(CO_TL_ENTITY, &AddressFile->Instance); + break; + case IPPROTO_UDP: + { + ip_addr_t IpAddr; + ip4_addr_set_u32(&IpAddr, AddressFile->Address.in_addr); + InsertEntityInstance(CL_TL_ENTITY, &AddressFile->Instance); + AddressFile->lwip_udp_pcb = udp_new(); + udp_bind(AddressFile->lwip_udp_pcb, &IpAddr, AddressFile->Address.sin_port); + ip_set_option(AddressFile->lwip_udp_pcb, SOF_BROADCAST); + /* Register our recv handler to lwip */ + udp_recv( + AddressFile->lwip_udp_pcb, + lwip_udp_ReceiveDatagram_callback, + AddressFile); + break; + } + default: + { + ip_addr_t IpAddr; + ip4_addr_set_u32(&IpAddr, AddressFile->Address.in_addr); + if (Protocol == IPPROTO_ICMP) + InsertEntityInstance(ER_ENTITY, &AddressFile->Instance); + else + InsertEntityInstance(CL_TL_ENTITY, &AddressFile->Instance); + AddressFile->lwip_raw_pcb = raw_new(Protocol); + raw_bind(AddressFile->lwip_raw_pcb, &IpAddr); + ip_set_option(AddressFile->lwip_raw_pcb, SOF_BROADCAST); + /* Register our recv handler for lwip */ + raw_recv( + AddressFile->lwip_raw_pcb, + lwip_raw_ReceiveDatagram_callback, + AddressFile); + break; + } + } + + /* Insert it into the list. */ + InsertTailList(&AddressListHead, &AddressFile->ListEntry); + KeReleaseSpinLock(&AddressListLock, OldIrql); + +Success: + IrpSp->FileObject->FsContext = AddressFile; + IrpSp->FileObject->FsContext2 = (PVOID)TDI_TRANSPORT_ADDRESS_FILE; + return STATUS_SUCCESS; +} + +NTSTATUS +TcpIpCloseAddress( + _Inout_ ADDRESS_FILE* AddressFile +) +{ + KIRQL OldIrql; + + /* Lock the global address list */ + KeAcquireSpinLock(&AddressListLock, &OldIrql); + + if (InterlockedDecrement(&AddressFile->RefCount) != 0) + { + /* There are still some open handles for this address */ + KeReleaseSpinLock(&AddressListLock, OldIrql); + return STATUS_SUCCESS; + } + + /* Remove from the list and free the structure */ + RemoveEntryList(&AddressFile->ListEntry); + KeReleaseSpinLock(&AddressListLock, OldIrql); + + RemoveEntityInstance(&AddressFile->Instance); + ExFreePoolWithTag(AddressFile, TAG_ADDRESS_FILE); + + + return STATUS_SUCCESS; +} + +static +NTSTATUS +ExtractAddressFromList( + _In_ PTRANSPORT_ADDRESS AddressList, + _Out_ PTDI_ADDRESS_IP Address) +{ + PTA_ADDRESS CurrentAddress; + INT i; + + CurrentAddress = &AddressList->Address[0]; + + /* We can only use IP addresses. Search the list until we find one */ + for (i = 0; i < AddressList->TAAddressCount; i++) + { + if (CurrentAddress->AddressType == TDI_ADDRESS_TYPE_IP) + { + if (CurrentAddress->AddressLength == TDI_ADDRESS_LENGTH_IP) + { + /* This is an IPv4 address */ + RtlCopyMemory(Address, &CurrentAddress->Address[0], CurrentAddress->AddressLength); + return STATUS_SUCCESS; + } + } + CurrentAddress = (PTA_ADDRESS)&CurrentAddress->Address[CurrentAddress->AddressLength]; + } + return STATUS_INVALID_ADDRESS; +} + +static +VOID +NTAPI +CancelReceiveDatagram( + _Inout_ struct _DEVICE_OBJECT* DeviceObject, + _Inout_ _IRQL_uses_cancel_ struct _IRP *Irp) +{ + PIO_STACK_LOCATION IrpSp; + ADDRESS_FILE* AddressFile; + RECEIVE_DATAGRAM_REQUEST* Request; + KIRQL OldIrql; + LIST_ENTRY* ListEntry; + + IoReleaseCancelSpinLock(Irp->CancelIrql); + + IrpSp = IoGetCurrentIrpStackLocation(Irp); + AddressFile = IrpSp->FileObject->FsContext; + + /* Find this IRP in the list of requests */ + KeAcquireSpinLock(&AddressFile->RequestLock, &OldIrql); + ListEntry = AddressFile->RequestListHead.Flink; + while (ListEntry != &AddressFile->RequestListHead) + { + Request = CONTAINING_RECORD(ListEntry, RECEIVE_DATAGRAM_REQUEST, ListEntry); + if (Request->Irp == Irp) + break; + ListEntry = ListEntry->Flink; + } + + /* We must have found it */ + NT_ASSERT(ListEntry != &AddressFile->RequestListHead); + + RemoveEntryList(&Request->ListEntry); + KeReleaseSpinLock(&AddressFile->RequestLock, OldIrql); + + Irp->IoStatus.Status = STATUS_CANCELLED; + Irp->IoStatus.Information = 0; + + IoCompleteRequest(Irp, IO_NETWORK_INCREMENT); + + ExFreePoolWithTag(Request, TAG_ADDRESS_FILE); +} + + +NTSTATUS +TcpIpReceiveDatagram( + _Inout_ PIRP Irp) +{ + PIO_STACK_LOCATION IrpSp = IoGetCurrentIrpStackLocation(Irp); + ADDRESS_FILE *AddressFile; + RECEIVE_DATAGRAM_REQUEST* Request = NULL; + PTDI_REQUEST_KERNEL_RECEIVEDG RequestInfo; + NTSTATUS Status; + KIRQL OldIrql; + + /* Check this is really an address file */ + if ((ULONG_PTR)IrpSp->FileObject->FsContext2 != TDI_TRANSPORT_ADDRESS_FILE) + { + Status = STATUS_FILE_INVALID; + goto Failure; + } + + /* Get the address file */ + AddressFile = IrpSp->FileObject->FsContext; + + if (AddressFile->Protocol == IPPROTO_TCP) + { + /* TCP has no such thing as datagrams */ + DPRINT1("Received TDI_RECEIVE_DATAGRAM for a TCP adress file.\n"); + Status = STATUS_INVALID_ADDRESS; + goto Failure; + } + + /* Queue the request */ + Request = ExAllocatePoolWithTag(NonPagedPool, sizeof(*Request), TAG_ADDRESS_FILE); + if (!Request) + { + Status = STATUS_INSUFFICIENT_RESOURCES; + goto Failure; + } + RtlZeroMemory(Request, sizeof(*Request)); + Request->Irp = Irp; + + /* Get details about what we should be receiving */ + RequestInfo = (PTDI_REQUEST_KERNEL_RECEIVEDG)&IrpSp->Parameters; + + /* Get the address */ + if (RequestInfo->ReceiveDatagramInformation->RemoteAddressLength != 0) + { + Status = ExtractAddressFromList( + RequestInfo->ReceiveDatagramInformation->RemoteAddress, + &Request->RemoteAddress); + if (!NT_SUCCESS(Status)) + goto Failure; + } + + /* Get the buffer */ + Request->Buffer = MmGetSystemAddressForMdl(Irp->MdlAddress); + Request->BufferLength = MmGetMdlByteCount(Irp->MdlAddress); + + Request->ReturnInfo = RequestInfo->ReturnDatagramInformation; + + /* Prepare for potential cancellation */ + IoAcquireCancelSpinLock(&OldIrql); + IoSetCancelRoutine(Irp, CancelReceiveDatagram); + IoReleaseCancelSpinLock(OldIrql); + + /* Mark pending */ + Irp->IoStatus.Status = STATUS_PENDING; + IoMarkIrpPending(Irp); + + /* We're ready to go */ + ExInterlockedInsertTailList( + &AddressFile->RequestListHead, + &Request->ListEntry, + &AddressFile->RequestLock); + + return STATUS_PENDING; + +Failure: + if (Request) + ExFreePoolWithTag(Request, TAG_ADDRESS_FILE); + Irp->IoStatus.Status = Status; + IoCompleteRequest(Irp, IO_NETWORK_INCREMENT); + return Status; +} + + +NTSTATUS +TcpIpSendDatagram( + _Inout_ PIRP Irp) +{ + PIO_STACK_LOCATION IrpSp = IoGetCurrentIrpStackLocation(Irp); + ADDRESS_FILE *AddressFile; + PTDI_REQUEST_KERNEL_SENDDG RequestInfo; + NTSTATUS Status; + ip_addr_t IpAddr; + u16_t Port; + PVOID Buffer; + ULONG BufferLength; + struct pbuf* p = NULL; + err_t lwip_error; + + /* Check this is really an address file */ + if ((ULONG_PTR)IrpSp->FileObject->FsContext2 != TDI_TRANSPORT_ADDRESS_FILE) + { + Status = STATUS_FILE_INVALID; + goto Finish; + } + + /* Get the address file */ + AddressFile = IrpSp->FileObject->FsContext; + + if (AddressFile->Protocol == IPPROTO_TCP) + { + /* TCP has no such thing as datagrams */ + DPRINT1("Received TDI_SEND_DATAGRAM for a TCP adress file.\n"); + Status = STATUS_INVALID_ADDRESS; + goto Finish; + } + + /* Get details about what we should be receiving */ + RequestInfo = (PTDI_REQUEST_KERNEL_SENDDG)&IrpSp->Parameters; + + /* Get the address */ + if (RequestInfo->SendDatagramInformation->RemoteAddressLength != 0) + { + TDI_ADDRESS_IP Address; + Status = ExtractAddressFromList( + RequestInfo->SendDatagramInformation->RemoteAddress, + &Address); + if (!NT_SUCCESS(Status)) + goto Finish; + ip4_addr_set_u32(&IpAddr, Address.in_addr); + Port = Address.sin_port; + } + else + { + ip_addr_set_any(&IpAddr); + Port = 0; + } + + /* Get the buffer */ + Buffer = MmGetSystemAddressForMdl(Irp->MdlAddress); + BufferLength = MmGetMdlByteCount(Irp->MdlAddress); + p = pbuf_alloc(PBUF_RAW, BufferLength, PBUF_REF); + if (!p) + { + Status = STATUS_INSUFFICIENT_RESOURCES; + goto Finish; + } + p->payload = Buffer; + + /* Send it for real */ + switch (AddressFile->Protocol) + { + case IPPROTO_UDP: + lwip_error = udp_sendto(AddressFile->lwip_udp_pcb, p, &IpAddr, Port); + break; + default: + lwip_error = raw_sendto(AddressFile->lwip_raw_pcb, p, &IpAddr); + break; + } + + switch (lwip_error) + { + case ERR_OK: + Status = STATUS_SUCCESS; + Irp->IoStatus.Information = BufferLength; + break; + case ERR_MEM: + case ERR_BUF: + DPRINT1("Received ERR_MEM from lwip.\n"); + Status = STATUS_INSUFFICIENT_RESOURCES; + break; + case ERR_RTE: + DPRINT1("Received ERR_RTE from lwip.\n"); + Status = STATUS_INVALID_ADDRESS; + break; + case ERR_VAL: + DPRINT1("Received ERR_VAL from lwip.\n"); + Status = STATUS_INVALID_PARAMETER; + break; + default: + DPRINT1("Received error %d from lwip.\n", lwip_error); + Status = STATUS_UNEXPECTED_NETWORK_ERROR; + } + +Finish: + if (p) + pbuf_free(p); + Irp->IoStatus.Status = Status; + IoCompleteRequest(Irp, IO_NETWORK_INCREMENT); + return Status; +}
Propchange: branches/tcpip_revolution/drivers/network/tcpip/address.c ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/address.c ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/address.c ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/address.h URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/address.h (added) +++ branches/tcpip_revolution/drivers/network/tcpip/address.h [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,41 @@ + +#pragma once + +typedef struct +{ + LIST_ENTRY ListEntry; + LONG RefCount; + IPPROTO Protocol; + TDI_ADDRESS_IP Address; + TCPIP_INSTANCE Instance; + KSPIN_LOCK RequestLock; + LIST_ENTRY RequestListHead; + union + { + struct raw_pcb* lwip_raw_pcb; + struct udp_pcb* lwip_udp_pcb; + }; +} ADDRESS_FILE; + +void +TcpIpInitializeAddresses(void); + +NTSTATUS +TcpIpCreateAddress( + _Inout_ PIRP Irp, + _In_ PTDI_ADDRESS_IP Address, + _In_ IPPROTO Protocol +); + +NTSTATUS +TcpIpCloseAddress( + _Inout_ ADDRESS_FILE* AddressFile +); + +NTSTATUS +TcpIpReceiveDatagram( + _Inout_ PIRP Irp); + +NTSTATUS +TcpIpSendDatagram( + _Inout_ PIRP Irp);
Propchange: branches/tcpip_revolution/drivers/network/tcpip/address.h ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/address.h ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/address.h ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/connection.c URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/connection.c (added) +++ branches/tcpip_revolution/drivers/network/tcpip/connection.c [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,12 @@ +/* + * PROJECT: ReactOS tcpip.sys + * COPYRIGHT: GPL - See COPYING in the top level directory + * FILE: drivers/network/tcpip/address.c + * PURPOSE: tcpip.sys: addresses abstraction + */ + +#include "precomp.h" + +#define NDEBUG +#include <debug.h> +
Propchange: branches/tcpip_revolution/drivers/network/tcpip/connection.c ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/connection.c ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/connection.c ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/entities.c URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/entities.c (added) +++ branches/tcpip_revolution/drivers/network/tcpip/entities.c [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,322 @@ +/* + * PROJECT: ReactOS tcpip.sys + * COPYRIGHT: GPL - See COPYING in the top level directory + * FILE: drivers/network/tcpip/address.c + * PURPOSE: tcpip.sys: entity list implementation + */ + +#include "precomp.h" + +#define NDEBUG +#include <debug.h> + +#define TAG_ENTITIES 'nIpI' + +static const ULONG EntityList[] = { + AT_ENTITY, + CL_NL_ENTITY, + CO_NL_ENTITY, + CL_TL_ENTITY, + CO_TL_ENTITY, + ER_ENTITY, + IF_ENTITY +}; + +static LIST_ENTRY AtInstancesListHead; +static LIST_ENTRY ClNlInstancesListHead; +static LIST_ENTRY CoNlInstancesListHead; +static LIST_ENTRY ClTlInstancesListHead; +static LIST_ENTRY CoTlInstancesListHead; +static LIST_ENTRY ErInstancesListHead; +static LIST_ENTRY IfInstancesListHead; + +/* The corresponding locks */ +static KSPIN_LOCK AtInstanceLock; +static KSPIN_LOCK ClNlInstanceLock; +static KSPIN_LOCK CoNlInstanceLock; +static KSPIN_LOCK ClTlInstanceLock; +static KSPIN_LOCK CoTlInstanceLock; +static KSPIN_LOCK ErInstanceLock; +static KSPIN_LOCK IfInstanceLock; + +/* We keep track of those just for the sake of speed, + * as our network stack thinks it's clever to get the entity list often */ +static ULONG InstanceCount; + +static +PLIST_ENTRY +GetInstanceListHeadAcquireLock( + _In_ ULONG Entity, + _Out_ PKIRQL OldIrql +) +{ + switch (Entity) + { + case AT_ENTITY: + KeAcquireSpinLock(&AtInstanceLock, OldIrql); + return &AtInstancesListHead; + case CL_NL_ENTITY: + KeAcquireSpinLock(&ClNlInstanceLock, OldIrql); + return &ClNlInstancesListHead; + case CO_NL_ENTITY: + KeAcquireSpinLock(&CoNlInstanceLock, OldIrql); + return &CoNlInstancesListHead; + case CL_TL_ENTITY: + KeAcquireSpinLock(&ClTlInstanceLock, OldIrql); + return &ClTlInstancesListHead; + case CO_TL_ENTITY: + KeAcquireSpinLock(&CoTlInstanceLock, OldIrql); + return &CoTlInstancesListHead; + case ER_ENTITY: + KeAcquireSpinLock(&ErInstanceLock, OldIrql); + return &ErInstancesListHead; + case IF_ENTITY: + KeAcquireSpinLock(&IfInstanceLock, OldIrql); + return &IfInstancesListHead; + default: + DPRINT1("Got unknown entity ID %x\n", Entity); + return NULL; + } +} + +static +void +AcquireEntityLock( + _In_ ULONG Entity, + _Out_ KIRQL* OldIrql) +{ + switch (Entity) + { + case AT_ENTITY: + KeAcquireSpinLock(&AtInstanceLock, OldIrql); + return; + case CL_NL_ENTITY: + KeAcquireSpinLock(&ClNlInstanceLock, OldIrql); + return; + case CO_NL_ENTITY: + KeAcquireSpinLock(&CoNlInstanceLock, OldIrql); + return; + case CL_TL_ENTITY: + KeAcquireSpinLock(&ClTlInstanceLock, OldIrql); + return; + case CO_TL_ENTITY: + KeAcquireSpinLock(&CoTlInstanceLock, OldIrql); + return; + case ER_ENTITY: + KeAcquireSpinLock(&ErInstanceLock, OldIrql); + return; + case IF_ENTITY: + KeAcquireSpinLock(&IfInstanceLock, OldIrql); + return; + default: + DPRINT1("Got unknown entity ID %x\n", Entity); + ASSERT(FALSE); + } +} + +static +void +ReleaseEntityLock( + _In_ ULONG Entity, + _In_ KIRQL OldIrql) +{ + switch (Entity) + { + case AT_ENTITY: + KeReleaseSpinLock(&AtInstanceLock, OldIrql); + return; + case CL_NL_ENTITY: + KeReleaseSpinLock(&ClNlInstanceLock, OldIrql); + return; + case CO_NL_ENTITY: + KeReleaseSpinLock(&CoNlInstanceLock, OldIrql); + return; + case CL_TL_ENTITY: + KeReleaseSpinLock(&ClTlInstanceLock, OldIrql); + return; + case CO_TL_ENTITY: + KeReleaseSpinLock(&CoTlInstanceLock, OldIrql); + return; + case ER_ENTITY: + KeReleaseSpinLock(&ErInstanceLock, OldIrql); + return; + case IF_ENTITY: + KeReleaseSpinLock(&IfInstanceLock, OldIrql); + return; + default: + DPRINT1("Got unknown entity ID %x\n", Entity); + ASSERT(FALSE); + } +} + +VOID +TcpIpInitializeEntities(void) +{ + /* Initialize the locks */ + KeInitializeSpinLock(&AtInstanceLock); + KeInitializeSpinLock(&ClNlInstanceLock); + KeInitializeSpinLock(&CoNlInstanceLock); + KeInitializeSpinLock(&ClTlInstanceLock); + KeInitializeSpinLock(&CoTlInstanceLock); + KeInitializeSpinLock(&ErInstanceLock); + KeInitializeSpinLock(&IfInstanceLock); + + /* And the list heads */ + InitializeListHead(&AtInstancesListHead); + InitializeListHead(&ClNlInstancesListHead); + InitializeListHead(&CoNlInstancesListHead); + InitializeListHead(&ClTlInstancesListHead); + InitializeListHead(&CoTlInstancesListHead); + InitializeListHead(&ErInstancesListHead); + InitializeListHead(&IfInstancesListHead); + + /* We don't have anything for now */ + InstanceCount = 0; +} + +NTSTATUS +QueryEntityList( + _In_ TDIEntityID ID, + _In_ PVOID Context, + _Out_opt_ PVOID OutBuffer, + _Inout_ ULONG* BufferSize) +{ + KIRQL OldIrql; + TDIEntityID* Entity = OutBuffer; + ULONG RemainingSize = *BufferSize, TotalSize = 0; + TCPIP_INSTANCE* Instance; + LIST_ENTRY* ListHead; + LIST_ENTRY* ListEntry; + ULONG i; + + UNREFERENCED_PARAMETER(ID); + UNREFERENCED_PARAMETER(Context); + + DPRINT("Gathering the entity list.\n"); + + if (!OutBuffer) + { + *BufferSize = InstanceCount * sizeof(TDIEntityID); + return STATUS_SUCCESS; + } + + /* Go through the bitmaps */ + for (i = 0; i < sizeof(EntityList)/sizeof(EntityList[0]); i++) + { + ListHead = GetInstanceListHeadAcquireLock(EntityList[i], &OldIrql); + + ListEntry = ListHead->Flink; + while(ListEntry != ListHead) + { + if (RemainingSize < sizeof(TDIEntityID)) + { + *BufferSize = InstanceCount * sizeof(TDIEntityID); + ReleaseEntityLock(EntityList[i], OldIrql); + return STATUS_BUFFER_OVERFLOW; + } + + Instance = CONTAINING_RECORD(ListEntry, TCPIP_INSTANCE, ListEntry); + + *Entity++ = Instance->InstanceId; + RemainingSize -= sizeof(*Entity); + TotalSize += sizeof(*Entity); + + ListEntry = ListEntry->Flink; + } + + ReleaseEntityLock(EntityList[i], OldIrql); + } + + *BufferSize = TotalSize; + return STATUS_SUCCESS; +} + +VOID +InsertEntityInstance( + _In_ ULONG Entity, + _Out_ TCPIP_INSTANCE* OutInstance) +{ + KIRQL OldIrql; + LIST_ENTRY* ListHead; + LIST_ENTRY* ListEntry; + TCPIP_INSTANCE* Instance; + ULONG InstanceId = 1; + + ListHead = GetInstanceListHeadAcquireLock(Entity, &OldIrql); + NT_ASSERT(ListHead); + + ListEntry = ListHead->Flink; + + /* Find an instance number for this guy */ + while (ListEntry != ListHead) + { + Instance = CONTAINING_RECORD(ListEntry, TCPIP_INSTANCE, ListEntry); + + if (Instance->InstanceId.tei_instance != InstanceId) + break; + InstanceId++; + ListEntry = ListEntry->Flink; + } + + OutInstance->InstanceId.tei_entity = Entity; + OutInstance->InstanceId.tei_instance = InstanceId; + + /* Keep this list sorted */ + InsertHeadList(ListEntry, &OutInstance->ListEntry); + + ReleaseEntityLock(Entity, OldIrql); + + InterlockedIncrement((LONG*)&InstanceCount); +} + +void +RemoveEntityInstance( + _In_ TCPIP_INSTANCE* Instance) +{ + KIRQL OldIrql; + + AcquireEntityLock(Instance->InstanceId.tei_entity, &OldIrql); + + RemoveEntryList(&Instance->ListEntry); + + ReleaseEntityLock(Instance->InstanceId.tei_entity, OldIrql); + + InterlockedDecrement((LONG*)&InstanceCount); +} + +NTSTATUS +GetInstance( + _In_ TDIEntityID ID, + _Out_ TCPIP_INSTANCE** OutInstance) +{ + KIRQL OldIrql; + LIST_ENTRY *ListHead, *ListEntry; + TCPIP_INSTANCE* Instance; + + ListHead = GetInstanceListHeadAcquireLock(ID.tei_entity, &OldIrql); + NT_ASSERT(ListHead != NULL); + + ListEntry = ListHead->Flink; + while (ListEntry != ListHead) + { + Instance = CONTAINING_RECORD(ListEntry, TCPIP_INSTANCE, ListEntry); + + NT_ASSERT(Instance->InstanceId.tei_entity == ID.tei_entity); + if (Instance->InstanceId.tei_instance == ID.tei_instance) + { + *OutInstance = Instance; + ReleaseEntityLock(ID.tei_entity, OldIrql); + return STATUS_SUCCESS; + } + + /* The list is sorted, so we can cut the loop a bit */ + if (ID.tei_instance < Instance->InstanceId.tei_instance) + break; + + ListEntry = ListEntry->Flink; + } + + ReleaseEntityLock(ID.tei_entity, OldIrql); + /* Maybe we could find a more descriptive status */ + return STATUS_INVALID_PARAMETER; +}
Propchange: branches/tcpip_revolution/drivers/network/tcpip/entities.c ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/entities.c ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/entities.c ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/entities.h URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/entities.h (added) +++ branches/tcpip_revolution/drivers/network/tcpip/entities.h [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,33 @@ + +#pragma once + +typedef struct +{ + TDIEntityID InstanceId; + LIST_ENTRY ListEntry; +} TCPIP_INSTANCE; + +VOID +TcpIpInitializeEntities(void); + +VOID +InsertEntityInstance( + _In_ ULONG Entity, + _Out_ TCPIP_INSTANCE* OutInstance); + +void +RemoveEntityInstance( + _In_ TCPIP_INSTANCE* Instance); + +NTSTATUS +GetInstance( + _In_ TDIEntityID, + _Out_ TCPIP_INSTANCE** Instance); + +/* IOCTL_TCP_QUERY_INFORMATION_EX handler */ +NTSTATUS +QueryEntityList( + _In_ TDIEntityID ID, + _In_ PVOID Context, + _Out_opt_ PVOID OutBuffer, + _Inout_ ULONG* BufferSize);
Propchange: branches/tcpip_revolution/drivers/network/tcpip/entities.h ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/entities.h ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/entities.h ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/information.c URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/information.c (added) +++ branches/tcpip_revolution/drivers/network/tcpip/information.c [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,179 @@ +/* + * PROJECT: ReactOS tcpip.sys + * COPYRIGHT: GPL - See COPYING in the top level directory + * FILE: drivers/network/tcpip/address.c + * PURPOSE: tcpip.sys: TCP_QUERY_INFORMATION_EX and TCP_SET_INFORMATION_EX ioctls implementation + */ + +#include "precomp.h" + +#define NDEBUG +#include <debug.h> + +typedef NTSTATUS (*QUERY_INFO_HANDLER)( + _In_ TDIEntityID ID, + _In_ PVOID Context, + _Out_opt_ PVOID OutBuffer, + _Inout_ ULONG* BufferSize); + +static +struct +{ + ULONG Entity, Class, Type, Id; + QUERY_INFO_HANDLER Handler; + +} InfoHandlers[] = +{ + { GENERIC_ENTITY, INFO_CLASS_GENERIC, INFO_TYPE_PROVIDER, ENTITY_LIST_ID, QueryEntityList }, + { IF_ENTITY, INFO_CLASS_PROTOCOL, INFO_TYPE_PROVIDER, IP_MIB_STATS_ID, QueryInterfaceEntry}, + { CL_NL_ENTITY, INFO_CLASS_PROTOCOL, INFO_TYPE_PROVIDER, IP_MIB_ADDRTABLE_ENTRY_ID, QueryInterfaceAddrTable}, + { (ULONG)-1, (ULONG)-1, (ULONG)-1, (ULONG)-1, NULL } +}; + + +NTSTATUS +TcpIpQueryInformation( + _Inout_ PIRP Irp +) +{ + PIO_STACK_LOCATION IrpSp; + TCP_REQUEST_QUERY_INFORMATION_EX* Query; + QUERY_INFO_HANDLER Handler = NULL; + PMDL QueryMdl = NULL, OutputMdl = NULL; + BOOL QueryLocked = FALSE, OutputLocked = FALSE; + ULONG OutputBufferLength; + PVOID OutputBuffer = NULL; + NTSTATUS Status; + ULONG i; + + IrpSp = IoGetCurrentIrpStackLocation(Irp); + + /* Check input buffer size */ + if (IrpSp->Parameters.DeviceIoControl.InputBufferLength < sizeof(TCP_REQUEST_QUERY_INFORMATION_EX)) + return STATUS_INVALID_PARAMETER; + + /* Get the input buffer */ + Query = IrpSp->Parameters.DeviceIoControl.Type3InputBuffer; + QueryMdl = IoAllocateMdl(Query, sizeof(*Query), FALSE, TRUE, NULL); + if (!QueryMdl) + return STATUS_INSUFFICIENT_RESOURCES; + + _SEH2_TRY + { + MmProbeAndLockPages(QueryMdl, Irp->RequestorMode, IoReadAccess); + QueryLocked = TRUE; + } + _SEH2_EXCEPT(EXCEPTION_EXECUTE_HANDLER) + { + Status = _SEH2_GetExceptionCode(); + goto Cleanup; + } _SEH2_END + + /* Get the outputbuffer, if any */ + OutputBufferLength = IrpSp->Parameters.DeviceIoControl.OutputBufferLength; + if (OutputBufferLength) + { + OutputBuffer = Irp->UserBuffer; + OutputMdl = IoAllocateMdl(OutputBuffer, OutputBufferLength, FALSE, TRUE, NULL); + if (!OutputMdl) + { + Status = STATUS_INSUFFICIENT_RESOURCES; + goto Cleanup; + } + + _SEH2_TRY + { + MmProbeAndLockPages(OutputMdl, Irp->RequestorMode, IoWriteAccess); + OutputLocked = TRUE; + } + _SEH2_EXCEPT(EXCEPTION_EXECUTE_HANDLER) + { + Status = _SEH2_GetExceptionCode(); + goto Cleanup; + } + _SEH2_END + } + + /* Find the handler for this particular query */ + for (i = 0; InfoHandlers[i].Handler != NULL; i++) + { + if ((InfoHandlers[i].Entity == Query->ID.toi_entity.tei_entity) && + (InfoHandlers[i].Class == Query->ID.toi_class) && + (InfoHandlers[i].Type == Query->ID.toi_type) && + (InfoHandlers[i].Id == Query->ID.toi_id)) + { + Handler = InfoHandlers[i].Handler; + break; + } + } + + if (!Handler) + { + DPRINT1("TCPIP - Unknown query: entity 0x%x, class 0x%x, type 0x%x, Id 0x%x.\n", + Query->ID.toi_entity.tei_entity, Query->ID.toi_class, Query->ID.toi_type, Query->ID.toi_id); + Status = STATUS_NOT_IMPLEMENTED; + goto Cleanup; + } + + Status = Handler(Query->ID.toi_entity, Query->Context, OutputBuffer, &OutputBufferLength); + + Irp->IoStatus.Information = OutputBufferLength; + +Cleanup: + if (QueryMdl) + { + if (QueryLocked) + MmUnlockPages(QueryMdl); + IoFreeMdl(QueryMdl); + } + if (OutputMdl) + { + if (OutputLocked) + MmUnlockPages(OutputMdl); + IoFreeMdl(OutputMdl); + } + return Status; +} + +NTSTATUS +TcpIpQueryKernelInformation( + _Inout_ PIRP Irp +) +{ + PIO_STACK_LOCATION IrpSp; + PTDI_REQUEST_KERNEL_QUERY_INFORMATION Query; + NTSTATUS Status; + + IrpSp = IoGetCurrentIrpStackLocation(Irp); + Query = (PTDI_REQUEST_KERNEL_QUERY_INFORMATION)&IrpSp->Parameters; + + /* See what we are queried */ + switch (Query->QueryType) + { + case TDI_QUERY_MAX_DATAGRAM_INFO: + { + PTDI_MAX_DATAGRAM_INFO MaxDatagramInfo; + + if (MmGetMdlByteCount(Irp->MdlAddress) < sizeof(*MaxDatagramInfo)) + { + DPRINT1("MDL buffer too small.\n"); + Status = STATUS_BUFFER_TOO_SMALL; + break; + } + + MaxDatagramInfo = MmGetSystemAddressForMdl(Irp->MdlAddress); + + MaxDatagramInfo->MaxDatagramSize = 0xFFFF; + + Status = STATUS_SUCCESS; + break; + } + default: + DPRINT1("Unknown query: 0x%08x.\n", Query->QueryType); + return STATUS_NOT_IMPLEMENTED; + } + + Irp->IoStatus.Status = Status; + IoCompleteRequest(Irp, IO_NETWORK_INCREMENT); + return Status; +}
Propchange: branches/tcpip_revolution/drivers/network/tcpip/information.c ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/information.c ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/information.c ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/information.h URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/information.h (added) +++ branches/tcpip_revolution/drivers/network/tcpip/information.h [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,12 @@ + +#pragma once + +NTSTATUS +TcpIpQueryInformation( + _In_ PIRP Irp +); + +NTSTATUS +TcpIpQueryKernelInformation( + _In_ PIRP Irp +);
Propchange: branches/tcpip_revolution/drivers/network/tcpip/information.h ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/information.h ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/information.h ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/interface.c URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/interface.c (added) +++ branches/tcpip_revolution/drivers/network/tcpip/interface.c [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,230 @@ +/* + * PROJECT: ReactOS tcpip.sys + * COPYRIGHT: GPL - See COPYING in the top level directory + * FILE: drivers/network/tcpip/interface.c + * PURPOSE: tcpip.sys: ndis <-> lwip bridge implementation + */ + +#include "precomp.h" + +#define NDEBUG +#include <debug.h> + +TCPIP_INTERFACE* LoopbackInterface; + +static +VOID +GetInterfaceOperStatus( + _In_ TCPIP_INTERFACE* Interface, + _Out_ ULONG* OperStatus) +{ + NDIS_STATUS Status; + NDIS_REQUEST Request; + NDIS_MEDIA_STATE MediaState; + + if (Interface->NdisContext == NULL) + { + /* This is the looback interface */ + *OperStatus = MIB_IF_OPER_STATUS_CONNECTED; + return; + } + + /* Get the connection status from NDIS */ + Request.RequestType = NdisRequestQueryInformation; + Request.DATA.QUERY_INFORMATION.Oid = OID_GEN_MEDIA_CONNECT_STATUS; + Request.DATA.QUERY_INFORMATION.InformationBuffer = &MediaState; + Request.DATA.QUERY_INFORMATION.InformationBufferLength = sizeof(ULONG); + NdisRequest(&Status, Interface->NdisContext, &Request); + if (!NT_SUCCESS(Status)) + { + DPRINT1("Could not get connection status from the NIC driver. Status 0x%08x\n", Status); + *OperStatus = MIB_IF_OPER_STATUS_NON_OPERATIONAL; + return; + } + + switch(MediaState) + { + case NdisMediaStateConnected: + *OperStatus = MIB_IF_OPER_STATUS_CONNECTED; + break; + case NdisMediaStateDisconnected: + *OperStatus = MIB_IF_OPER_STATUS_DISCONNECTED; + break; + default: + DPRINT1("Got unknown media state from NIC driver: %d.\n", MediaState); + *OperStatus = MIB_IF_OPER_STATUS_NON_OPERATIONAL; + } +} + +NTSTATUS +QueryInterfaceEntry( + _In_ TDIEntityID ID, + _In_ PVOID Context, + _Out_opt_ PVOID OutBuffer, + _Inout_ ULONG* BufferSize) +{ + TCPIP_INSTANCE* Instance; + TCPIP_INTERFACE* Interface; + NTSTATUS Status; + IFEntry* IfEntry = OutBuffer; + ULONG NeededSize; + + NT_ASSERT(ID.tei_entity == IF_ENTITY); + + Status = GetInstance(ID, &Instance); + if (!NT_SUCCESS(Status)) + return Status; + + Interface = CONTAINING_RECORD(Instance, TCPIP_INTERFACE, IfInstance); + + NeededSize = FIELD_OFFSET(IFEntry, if_descr) + + RTL_FIELD_SIZE(IFEntry, if_descr[0]) * (Interface->DeviceName.Length / 2 + 1); + + if (!OutBuffer) + { + *BufferSize = NeededSize; + return STATUS_SUCCESS; + } + + if (*BufferSize < NeededSize) + { + *BufferSize = NeededSize; + return STATUS_BUFFER_OVERFLOW; + } + + /* Fill in the data from our interface */ + IfEntry->if_index = Interface->lwip_netif.num; + IfEntry->if_type = (Interface->lwip_netif.flags & NETIF_FLAG_ETHARP) ? + IF_TYPE_ETHERNET_CSMACD : IF_TYPE_SOFTWARE_LOOPBACK; + IfEntry->if_mtu = Interface->lwip_netif.mtu; + IfEntry->if_speed = Interface->Speed; + IfEntry->if_physaddrlen = Interface->lwip_netif.hwaddr_len; + RtlCopyMemory(IfEntry->if_physaddr, Interface->lwip_netif.hwaddr, IfEntry->if_physaddrlen); + IfEntry->if_adminstatus = MIB_IF_ADMIN_STATUS_UP; + GetInterfaceOperStatus(Interface, &IfEntry->if_operstatus); + + // FIXME: Fill those + IfEntry->if_lastchange = 0; + IfEntry->if_inoctets = 0; + IfEntry->if_inucastpkts = 0; + IfEntry->if_innucastpkts = 0; + IfEntry->if_inerrors = 0; + IfEntry->if_inunknownprotos = 0; + IfEntry->if_outoctets = 0; + IfEntry->if_outucastpkts = 0; + IfEntry->if_outnucastpkts = 0; + IfEntry->if_outdiscards = 0; + IfEntry->if_outerrors = 0; + IfEntry->if_outqlen = 0; + + /* Set name */ + RtlUnicodeToMultiByteN( + (PCHAR)&IfEntry->if_descr[0], + *BufferSize - FIELD_OFFSET(IFEntry, if_descr), + &IfEntry->if_descrlen, + Interface->DeviceName.Buffer, + Interface->DeviceName.Length); + + *BufferSize = NeededSize; + + return STATUS_SUCCESS; +} + +NTSTATUS +QueryInterfaceAddrTable( + _In_ TDIEntityID ID, + _In_ PVOID Context, + _Out_opt_ PVOID OutBuffer, + _Inout_ ULONG* BufferSize) +{ + TCPIP_INSTANCE* Instance; + TCPIP_INTERFACE* Interface; + NTSTATUS Status; + IPAddrEntry* AddrEntry = OutBuffer; + + NT_ASSERT(ID.tei_entity == CL_NL_ENTITY); + + Status = GetInstance(ID, &Instance); + if (!NT_SUCCESS(Status)) + return Status; + + Interface = CONTAINING_RECORD(Instance, TCPIP_INTERFACE, ClNlInstance); + + // FIXME: return more than 'one' address + if (!OutBuffer) + { + *BufferSize = sizeof(IPAddrEntry); + return STATUS_SUCCESS; + } + + if (*BufferSize < sizeof(IPAddrEntry)) + { + *BufferSize = sizeof(IPAddrEntry); + return STATUS_BUFFER_OVERFLOW; + } + + AddrEntry->iae_addr = Interface->lwip_netif.ip_addr.addr; + AddrEntry->iae_index = Interface->lwip_netif.num; + AddrEntry->iae_mask = Interface->lwip_netif.netmask.addr; + _BitScanReverse(&AddrEntry->iae_bcastaddr, AddrEntry->iae_addr | ~AddrEntry->iae_mask); + /* FIXME: set those */ + AddrEntry->iae_reasmsize = 0; + AddrEntry->iae_context = 0; + AddrEntry->iae_pad = 0; + + return STATUS_SUCCESS; +} + +/* callback provided to lwip for initializing the loopback interface */ +static +err_t +lwip_netif_loopback_init(struct netif *netif) +{ + NETIF_INIT_SNMP(netif, snmp_ifType_softwareLoopback, 0); + + netif->name[0] = 'l'; + netif->name[1] = 'o'; + netif->output = netif_loop_output; + return ERR_OK; +} + +NTSTATUS +TcpIpCreateLoopbackInterface(void) +{ + err_t lwip_error; + struct ip_addr IpAddr, SubnetMask, GatewayAddr; + + LoopbackInterface = ExAllocatePoolWithTag(NonPagedPool, sizeof(*LoopbackInterface), TAG_INTERFACE); + if (!LoopbackInterface) + return STATUS_INSUFFICIENT_RESOURCES; + RtlZeroMemory(LoopbackInterface, sizeof(*LoopbackInterface)); + + /* Add it to lwip stack */ + IP4_ADDR(&GatewayAddr, 127,0,0,1); + IP4_ADDR(&IpAddr, 127,0,0,1); + IP4_ADDR(&SubnetMask, 255,0,0,0); + lwip_error = netifapi_netif_add( + &LoopbackInterface->lwip_netif, + &IpAddr, + &SubnetMask, + &GatewayAddr, + LoopbackInterface, + lwip_netif_loopback_init, + tcpip_input); + if (lwip_error != ERR_OK) + { + ExFreePoolWithTag(LoopbackInterface, TAG_INTERFACE); + return STATUS_INSUFFICIENT_RESOURCES; + } + + netifapi_netif_set_up(&LoopbackInterface->lwip_netif); + + /* Add this interface into the entities DB */ + InsertEntityInstance(CL_NL_ENTITY, &LoopbackInterface->ClNlInstance); + InsertEntityInstance(IF_ENTITY, &LoopbackInterface->IfInstance); + InsertEntityInstance(AT_ENTITY, &LoopbackInterface->AtInstance); + + RtlInitUnicodeString(&LoopbackInterface->DeviceName, L"Loopback"); + + return STATUS_SUCCESS; +}
Propchange: branches/tcpip_revolution/drivers/network/tcpip/interface.c ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/interface.c ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/interface.c ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/interface.h URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/interface.h (added) +++ branches/tcpip_revolution/drivers/network/tcpip/interface.h [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,35 @@ + +#pragma once + +#define TAG_INTERFACE 'fIpI' + +typedef struct +{ + struct netif lwip_netif; + TCPIP_INSTANCE IfInstance; + TCPIP_INSTANCE AtInstance; + TCPIP_INSTANCE ClNlInstance; + UNICODE_STRING DeviceName; + NDIS_HANDLE NdisContext; + UINT MediumIndex; + ULONG Speed; +} TCPIP_INTERFACE; + +extern TCPIP_INTERFACE* LoopbackInterface; + +NTSTATUS +TcpIpCreateLoopbackInterface(void); + +NTSTATUS +QueryInterfaceEntry( + _In_ TDIEntityID ID, + _In_ PVOID Context, + _Out_opt_ PVOID OutBuffer, + _Inout_ ULONG* BufferSize); + +NTSTATUS +QueryInterfaceAddrTable( + _In_ TDIEntityID ID, + _In_ PVOID Context, + _Out_opt_ PVOID OutBuffer, + _Inout_ ULONG* BufferSize);
Propchange: branches/tcpip_revolution/drivers/network/tcpip/interface.h ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/interface.h ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/interface.h ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/main.c URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/main.c (added) +++ branches/tcpip_revolution/drivers/network/tcpip/main.c [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,505 @@ +/* + * PROJECT: ReactOS tcpip.sys + * COPYRIGHT: GPL - See COPYING in the top level directory + * FILE: drivers/network/tcpip/main.c + * PURPOSE: tcpip.sys driver entry + */ + +#include "precomp.h" + +#define NDEBUG +#include <debug.h> + +/* DriverEntry, DriverUnload and dispatch routines declaration */ +DRIVER_INITIALIZE DriverEntry; +static DRIVER_UNLOAD TcpIpUnload; +static DRIVER_DISPATCH TcpIpCreate; +static DRIVER_DISPATCH TcpIpClose; +static DRIVER_DISPATCH TcpIpDispatchInternal; +static DRIVER_DISPATCH TcpIpDispatch; +#ifdef ALLOC_PRAGMA +#pragma alloc_text(INIT, DriverEntry) +#pragma alloc_text(PAGE, TcpIpUnload) +#pragma alloc_text(PAGE, TcpIpCreate) +#pragma alloc_text(PAGE, TcpIpClose) +#pragma alloc_text(PAGE, TcpIpDispatchInternal) +#pragma alloc_text(PAGE, TcpIpDispatch) +#endif + +/* Our device objects. TCP, UPD, IP, and RAW */ +PDEVICE_OBJECT TcpDeviceObject = NULL; +PDEVICE_OBJECT UdpDeviceObject = NULL; +PDEVICE_OBJECT IpDeviceObject = NULL; +PDEVICE_OBJECT RawIpDeviceObject = NULL; + +/* And the corresponding device names */ +#define DD_TCP_DEVICE_NAME L"\Device\Tcp" +#define DD_UDP_DEVICE_NAME L"\Device\Udp" +#define DD_IP_DEVICE_NAME L"\Device\Ip" +#define DD_RAWIP_DEVICE_NAME L"\Device\RawIp" + +/* This is a small utility which get the IPPROTO_* constant from the device object this driver was passed */ +static +IPPROTO +ProtocolFromIrp( + _In_ PDEVICE_OBJECT DeviceObject, + _In_ PIO_STACK_LOCATION IrpSp) +{ + UNICODE_STRING ProtocolName; + PWCHAR Name; + ULONG Value; + NTSTATUS Status; + + if (DeviceObject == TcpDeviceObject) + return IPPROTO_TCP; + if (DeviceObject == UdpDeviceObject) + return IPPROTO_UDP; + if (DeviceObject == IpDeviceObject) + return IPPROTO_RAW; + + /* Get it from the IRP file object */ + Name = IrpSp->FileObject->FileName.Buffer; + + if (*Name++ != L'\') + { + DPRINT1("Could not deduce protocol from file name %wZ.\n", &IrpSp->FileObject->FileName); + return (IPPROTO)-1; + } + + RtlInitUnicodeString(&ProtocolName, Name); + Status = RtlUnicodeStringToInteger(&ProtocolName, 10, &Value); + if (!NT_SUCCESS(Status)) + { + DPRINT1("Could not deduce protocol from file name %wZ.\n", &IrpSp->FileObject->FileName); + return (IPPROTO)-1; + } + + if (Value >= IPPROTO_RESERVED_MAX) + { + DPRINT1("Could not deduce protocol from file name %wZ.\n", &IrpSp->FileObject->FileName); + return (IPPROTO)-1; + } + + return (IPPROTO)Value; +} + +NTSTATUS +NTAPI +DriverEntry( + _In_ struct _DRIVER_OBJECT *DriverObject, + _In_ PUNICODE_STRING RegistryPath +) +{ + UNICODE_STRING IpDeviceName = RTL_CONSTANT_STRING(DD_IP_DEVICE_NAME); + UNICODE_STRING RawIpDeviceName = RTL_CONSTANT_STRING(DD_RAWIP_DEVICE_NAME); + UNICODE_STRING UdpDeviceName = RTL_CONSTANT_STRING(DD_UDP_DEVICE_NAME); + UNICODE_STRING TcpDeviceName = RTL_CONSTANT_STRING(DD_TCP_DEVICE_NAME); + NTSTATUS Status; + + /* Initialize the lwip library */ + tcpip_init(NULL, NULL); + + /* Create the device objects */ + Status = IoCreateDevice( + DriverObject, + 0, + &IpDeviceName, + FILE_DEVICE_NETWORK, + 0, + FALSE, + &IpDeviceObject); + if (!NT_SUCCESS(Status)) + { + DPRINT1("Could not create device object. Status: 0x%08x\n", Status); + goto Failure; + } + + Status = IoCreateDevice( + DriverObject, + 0, + &UdpDeviceName, + FILE_DEVICE_NETWORK, + 0, + FALSE, + &UdpDeviceObject); + if (!NT_SUCCESS(Status)) + { + DPRINT1("Could not create device object. Status: 0x%08x\n", Status); + goto Failure; + } + + Status = IoCreateDevice( + DriverObject, + 0, + &TcpDeviceName, + FILE_DEVICE_NETWORK, + 0, + FALSE, + &TcpDeviceObject); + if (!NT_SUCCESS(Status)) + { + DPRINT1("Could not create device object. Status: 0x%08x\n", Status); + goto Failure; + } + + Status = IoCreateDevice( + DriverObject, + 0, + &RawIpDeviceName, + FILE_DEVICE_NETWORK, + 0, + FALSE, + &RawIpDeviceObject); + if (!NT_SUCCESS(Status)) + { + DPRINT1("Could not create device object. Status: 0x%08x\n", Status); + goto Failure; + } + + /* Use direct I/O with this devices */ + IpDeviceObject->Flags |= DO_DIRECT_IO; + RawIpDeviceObject->Flags |= DO_DIRECT_IO; + UdpDeviceObject->Flags |= DO_DIRECT_IO; + TcpDeviceObject->Flags |= DO_DIRECT_IO; + + /* Set driver object entry points */ + DriverObject->MajorFunction[IRP_MJ_CREATE] = TcpIpCreate; + DriverObject->MajorFunction[IRP_MJ_CLOSE] = TcpIpClose; + DriverObject->MajorFunction[IRP_MJ_INTERNAL_DEVICE_CONTROL] = TcpIpDispatchInternal; + DriverObject->MajorFunction[IRP_MJ_DEVICE_CONTROL] = TcpIpDispatch; + DriverObject->DriverUnload = TcpIpUnload; + + /* Initialize various parts of the driver */ + TcpIpInitializeAddresses(); + TcpIpInitializeTcp(); + TcpIpInitializeEntities(); + Status = TcpIpRegisterNdisProtocol(); + if (!NT_SUCCESS(Status)) + goto Failure; + + /* Create the loopback interface */ + Status = TcpIpCreateLoopbackInterface(); + if (!NT_SUCCESS(Status)) + goto Failure; + + return STATUS_SUCCESS; + +Failure: + TcpIpUnregisterNdisProtocol(); + + if (IpDeviceObject) + IoDeleteDevice(IpDeviceObject); + if (TcpDeviceObject) + IoDeleteDevice(TcpDeviceObject); + if (UdpDeviceObject) + IoDeleteDevice(UdpDeviceObject); + if (RawIpDeviceObject) + IoDeleteDevice(RawIpDeviceObject); + + return Status; +} + +static +NTSTATUS +NTAPI +TcpIpCreate( + _Inout_ struct _DEVICE_OBJECT *DeviceObject, + _Inout_ struct _IRP *Irp +) +{ + NTSTATUS Status; + PFILE_FULL_EA_INFORMATION FileInfo; + IPPROTO Protocol; + PIO_STACK_LOCATION IrpSp = IoGetCurrentIrpStackLocation(Irp); + + /* Grab the info describing the file */ + FileInfo = Irp->AssociatedIrp.SystemBuffer; + + if (!FileInfo) + { + /* Caller just wants a control channel. We don't need any structure for this kind of "file" */ + IrpSp->FileObject->FsContext = NULL; + IrpSp->FileObject->FsContext2 = (PVOID)TDI_CONTROL_CHANNEL_FILE; + Status = STATUS_SUCCESS; + goto Quickie; + } + + /* Validate it */ + switch (FileInfo->EaNameLength) + { + case TDI_TRANSPORT_ADDRESS_LENGTH: + { + PTA_IP_ADDRESS Address; + + if (strncmp(&FileInfo->EaName[0], TdiTransportAddress, TDI_TRANSPORT_ADDRESS_LENGTH) != 0) + { + DPRINT1("TCPIP: Should maybe open file %*s.\n", FileInfo->EaNameLength, &FileInfo->EaName[0]); + Status = STATUS_INVALID_PARAMETER; + goto Quickie; + } + /* Get the address info right after the file name info */ + Address = (PTA_IP_ADDRESS)(&FileInfo->EaName[FileInfo->EaNameLength + 1]); + + /* Validate it */ + if ((FileInfo->EaValueLength < sizeof(*Address)) || + (Address->TAAddressCount != 1) || + (Address->Address[0].AddressLength < TDI_ADDRESS_LENGTH_IP) || + (Address->Address[0].AddressType != TDI_ADDRESS_TYPE_IP)) + { + Status = STATUS_INVALID_PARAMETER; + goto Quickie; + } + + /* Get the protocol this address will be created for. */ + Protocol = ProtocolFromIrp(DeviceObject, IrpSp); + if (Protocol == (IPPROTO)-1) + { + Status = STATUS_INVALID_PARAMETER; + goto Quickie; + } + + /* All good. */ + Status = TcpIpCreateAddress(Irp, &Address->Address[0].Address[0], Protocol); + break; + } + + case TDI_CONNECTION_CONTEXT_LENGTH: + if (strncmp(&FileInfo->EaName[0], TdiConnectionContext, TDI_CONNECTION_CONTEXT_LENGTH) != 0) + { + DPRINT1("TCPIP: Should maybe open file %*s.\n", FileInfo->EaNameLength, &FileInfo->EaName[0]); + return STATUS_INVALID_PARAMETER; + } + DPRINT1("Should create a connection!\n"); + Status = STATUS_NOT_IMPLEMENTED; + break; + + default: + DPRINT1("TCPIP: Should open file %*s.\n", FileInfo->EaNameLength, &FileInfo->EaName[0]); + Status = STATUS_INVALID_PARAMETER; + } + +Quickie: + Irp->IoStatus.Status = Status; + if (Status == STATUS_PENDING) + { + IoMarkIrpPending(Irp); + } + else + { + IoCompleteRequest(Irp, IO_NETWORK_INCREMENT); + } + + return Status; +} + +static +NTSTATUS +NTAPI +TcpIpClose( + _Inout_ struct _DEVICE_OBJECT *DeviceObject, + _Inout_ struct _IRP *Irp +) +{ + PIO_STACK_LOCATION IrpSp; + NTSTATUS Status; + ULONG_PTR FileType; + + IrpSp = IoGetCurrentIrpStackLocation(Irp); + + FileType = (ULONG_PTR)IrpSp->FileObject->FsContext2; + + switch (FileType) + { + case TDI_TRANSPORT_ADDRESS_FILE: + if (!IrpSp->FileObject->FsContext) + { + DPRINT1("TCPIP: Got a close request without a file to close!\n"); + Status = STATUS_INVALID_PARAMETER; + goto Quickie; + } + Status = TcpIpCloseAddress(IrpSp->FileObject->FsContext); + break; + case TDI_CONTROL_CHANNEL_FILE: + /* We didn't allocate anything for this. */ + Status = STATUS_SUCCESS; + break; + default: + DPRINT1("TCPIP: Should close file %Iu.\n", FileType); + Status = STATUS_INVALID_PARAMETER; + break; + } + +Quickie: + Irp->IoStatus.Status = Status; + + return Irp->IoStatus.Status; +} + +static +NTSTATUS +NTAPI +TcpIpDispatchInternal( + _Inout_ struct _DEVICE_OBJECT *DeviceObject, + _Inout_ struct _IRP *Irp +) +{ + NTSTATUS Status; + PIO_STACK_LOCATION IrpSp; + + IrpSp = IoGetCurrentIrpStackLocation(Irp); + + switch (IrpSp->MinorFunction) + { + case TDI_RECEIVE: + DPRINT1("TCPIP: TDI_RECEIVE!\n"); + Status = STATUS_NOT_IMPLEMENTED; + break; + + case TDI_RECEIVE_DATAGRAM: + return TcpIpReceiveDatagram(Irp); + + case TDI_SEND: + DPRINT1("TCPIP: TDI_SEND!\n"); + Status = STATUS_NOT_IMPLEMENTED; + break; + + case TDI_SEND_DATAGRAM: + return TcpIpSendDatagram(Irp); + + case TDI_ACCEPT: + DPRINT1("TCPIP: TDI_ACCEPT!\n"); + Status = STATUS_NOT_IMPLEMENTED; + break; + + case TDI_LISTEN: + DPRINT1("TCPIP: TDI_LISTEN!\n"); + Status = STATUS_NOT_IMPLEMENTED; + break; + + case TDI_CONNECT: + DPRINT1("TCPIP: TDI_CONNECT!\n"); + Status = STATUS_NOT_IMPLEMENTED; + break; + + case TDI_DISCONNECT: + DPRINT1("TCPIP: TDI_DISCONNECT!\n"); + Status = STATUS_NOT_IMPLEMENTED; + break; + + case TDI_ASSOCIATE_ADDRESS: + DPRINT1("TCPIP: TDI_ASSOCIATE_ADDRESS!\n"); + Status = STATUS_NOT_IMPLEMENTED; + break; + + case TDI_DISASSOCIATE_ADDRESS: + DPRINT1("TCPIP: TDI_DISASSOCIATE_ADDRESS!\n"); + Status = STATUS_NOT_IMPLEMENTED; + break; + + case TDI_QUERY_INFORMATION: + return TcpIpQueryKernelInformation(Irp); + + case TDI_SET_INFORMATION: + DPRINT1("TCPIP: TDI_SET_INFORMATION!\n"); + Status = STATUS_NOT_IMPLEMENTED; + break; + + case TDI_SET_EVENT_HANDLER: + DPRINT1("TCPIP: TDI_SET_EVENT_HANDLER!\n"); + Status = STATUS_NOT_IMPLEMENTED; + break; + + case TDI_ACTION: + DPRINT1("TDI_ACTION!\n"); + Status = STATUS_NOT_IMPLEMENTED; + break; + + /* An unsupported IOCTL code was submitted */ + default: + DPRINT1("TCPIP: Unknown internal IOCTL: 0x%x.\n", IrpSp->MinorFunction); + Status = STATUS_NOT_IMPLEMENTED; + } + + Irp->IoStatus.Status = Status; + if (Status == STATUS_PENDING) + { + IoMarkIrpPending(Irp); + } + else + { + IoCompleteRequest(Irp, IO_NETWORK_INCREMENT); + } + + return Status; +} + +static +NTSTATUS +NTAPI +TcpIpDispatch( + _Inout_ struct _DEVICE_OBJECT *DeviceObject, + _Inout_ struct _IRP *Irp +) +{ + NTSTATUS Status; + PIO_STACK_LOCATION IrpSp; + + IrpSp = IoGetCurrentIrpStackLocation(Irp); + + Irp->IoStatus.Information = 0; + + switch (IrpSp->Parameters.DeviceIoControl.IoControlCode) + { + case IOCTL_TCP_QUERY_INFORMATION_EX: + Status = TcpIpQueryInformation(Irp); + break; + + case IOCTL_TCP_SET_INFORMATION_EX: + DPRINT1("TCPIP: Should handle IOCTL_TCP_SET_INFORMATION_EX.\n"); + Status = STATUS_NOT_IMPLEMENTED; + break; + + case IOCTL_SET_IP_ADDRESS: + DPRINT1("TCPIP: Should handle IOCTL_SET_IP_ADDRESS.\n"); + Status = STATUS_NOT_IMPLEMENTED; + break; + + case IOCTL_DELETE_IP_ADDRESS: + DPRINT1("TCPIP: Should handle IOCTL_DELETE_IP_ADDRESS.\n"); + Status = STATUS_NOT_IMPLEMENTED; + break; + + default: + DPRINT1("TCPIP: Unknown IOCTL 0x%#x\n", IrpSp->Parameters.DeviceIoControl.IoControlCode); + Status = STATUS_NOT_IMPLEMENTED; + break; + } + + DPRINT("TCPIP dispatched with status 0x%08x.\n", Status); + + Irp->IoStatus.Status = Status; + if (Status == STATUS_PENDING) + { + IoMarkIrpPending(Irp); + } + else + { + IoCompleteRequest(Irp, IO_NETWORK_INCREMENT); + } + + return Status; +} + +static +VOID +NTAPI +TcpIpUnload( + _In_ struct _DRIVER_OBJECT *DriverObject +) +{ + IoDeleteDevice(IpDeviceObject); + IoDeleteDevice(RawIpDeviceObject); + IoDeleteDevice(UdpDeviceObject); + IoDeleteDevice(TcpDeviceObject); + TcpIpUnregisterNdisProtocol(); +}
Propchange: branches/tcpip_revolution/drivers/network/tcpip/main.c ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/main.c ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/main.c ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/ndis_lwip.c URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/ndis_lwip.c (added) +++ branches/tcpip_revolution/drivers/network/tcpip/ndis_lwip.c [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,339 @@ +/* + * PROJECT: ReactOS tcpip.sys + * COPYRIGHT: GPL - See COPYING in the top level directory + * FILE: drivers/network/tcpip/ndis_proto.c + * PURPOSE: tcpip.sys: ndis protocol bindings + */ + +#include "precomp.h" + +#define NDEBUG +#include <debug.h> + +// FIXME: Maybe more in the future ? +static NDIS_MEDIUM NdisMediaArray[] = { NdisMedium802_3 }; + +/* The handle we got from NDIS for this protocol */ +static NDIS_HANDLE NdisHandle; + +/* Initializes the various values lwip will need */ +static +NDIS_STATUS +InitializeInterface( + _Inout_ TCPIP_INTERFACE* Interface) +{ + NDIS_STATUS Status; + NDIS_REQUEST Request; + UINT MTU; + NDIS_OID QueryAddrOid; + UINT PacketFilter; + + /* Add this interface into the entities DB */ + InsertEntityInstance(CL_NL_ENTITY, &Interface->ClNlInstance); + InsertEntityInstance(IF_ENTITY, &Interface->IfInstance); + InsertEntityInstance(AT_ENTITY, &Interface->AtInstance); + + /* Get the MTU from the NIC */ + Request.RequestType = NdisRequestQueryInformation; + Request.DATA.QUERY_INFORMATION.Oid = OID_GEN_MAXIMUM_FRAME_SIZE; + Request.DATA.QUERY_INFORMATION.InformationBuffer = &MTU; + Request.DATA.QUERY_INFORMATION.InformationBufferLength = sizeof(UINT); + NdisRequest(&Status, Interface->NdisContext, &Request); + if (!NT_SUCCESS(Status)) + { + DPRINT1("Could not get MTU from the NIC driver!\n"); + return Status; + } + Interface->lwip_netif.mtu = MTU; + + /* Setup media type related data. */ + switch (NdisMediaArray[Interface->MediumIndex]) + { + case NdisMedium802_3: + Interface->lwip_netif.hwaddr_len = ETHARP_HWADDR_LEN; + QueryAddrOid = OID_802_3_CURRENT_ADDRESS; + PacketFilter = NDIS_PACKET_TYPE_BROADCAST | NDIS_PACKET_TYPE_DIRECTED | NDIS_PACKET_TYPE_MULTICAST; + break; + default: + /* This is currently impossible */ + DPRINT1("Unknown medium!\n"); + NT_ASSERT(FALSE); + return NDIS_STATUS_UNSUPPORTED_MEDIA; + } + + /* Get the address */ + Request.RequestType = NdisRequestQueryInformation; + Request.DATA.QUERY_INFORMATION.Oid = QueryAddrOid; + Request.DATA.QUERY_INFORMATION.InformationBuffer = &Interface->lwip_netif.hwaddr[0]; + Request.DATA.QUERY_INFORMATION.InformationBufferLength = NETIF_MAX_HWADDR_LEN; + NdisRequest(&Status, Interface->NdisContext, &Request); + if (!NT_SUCCESS(Status)) + { + DPRINT1("Could not get HW address from the NIC driver!\n"); + return Status; + } + + /* Get the link speed */ + Request.RequestType = NdisRequestQueryInformation; + Request.DATA.QUERY_INFORMATION.Oid = OID_GEN_LINK_SPEED; + Request.DATA.QUERY_INFORMATION.InformationBuffer = &Interface->Speed; + Request.DATA.QUERY_INFORMATION.InformationBufferLength = sizeof(ULONG); + NdisRequest(&Status, Interface->NdisContext, &Request); + if (!NT_SUCCESS(Status)) + { + DPRINT1("Could not get link speed NIC driver!\n"); + /* Good old 10Mb/s as default */ + Interface->Speed = 100000; + } + /* NDIS drivers give it in 100bps unit */ + Interface->Speed *= 100; + + /* Set the packet filter */ + Request.RequestType = NdisRequestSetInformation; + Request.DATA.SET_INFORMATION.Oid = OID_GEN_CURRENT_PACKET_FILTER; + Request.DATA.SET_INFORMATION.InformationBuffer = &PacketFilter; + Request.DATA.SET_INFORMATION.InformationBufferLength = sizeof(PacketFilter); + NdisRequest(&Status, Interface->NdisContext, &Request); + if (!NT_SUCCESS(Status)) + { + DPRINT1("Could not get HW address from the NIC driver!\n"); + return Status; + } + + return NDIS_STATUS_SUCCESS; +} + +/* The various callbacks we will give to NDIS */ +static +VOID +NTAPI +ProtocolOpenAdapterComplete( + _In_ NDIS_HANDLE ProtocolBindingContext, + _In_ NDIS_STATUS Status, + _In_ NDIS_STATUS OpenErrorStatus) +{ + TCPIP_INTERFACE* Interface = (TCPIP_INTERFACE*)ProtocolBindingContext; + + if (!NT_SUCCESS(Status)) + { + ExFreePoolWithTag(Interface, TAG_INTERFACE); + return; + } + + Status = InitializeInterface(Interface); + if (!NT_SUCCESS(Status)) + { + /* Unbind the interface and that's all */ + NdisCloseAdapter(&Status, Interface->NdisContext); + } +} + +static +VOID +NTAPI +ProtocolCloseAdapterComplete( + _In_ NDIS_HANDLE ProtocolBindingContext, + _In_ NDIS_STATUS Status) +{ + UNIMPLEMENTED +} + +static +VOID +NTAPI +ProtocolResetComplete( + _In_ NDIS_HANDLE ProtocolBindingContext, + _In_ NDIS_STATUS Status) +{ + UNIMPLEMENTED +} + +static +VOID +NTAPI +ProtocolRequestComplete( + _In_ NDIS_HANDLE ProtocolBindingContext, + _In_ PNDIS_REQUEST NdisRequest, + _In_ NDIS_STATUS Status) +{ + UNIMPLEMENTED +} + +static +VOID +NTAPI +ProtocolReceiveComplete( + _In_ NDIS_HANDLE ProtocolBindingContext) +{ + UNIMPLEMENTED +} + +static +VOID +NTAPI +ProtocolStatusComplete( + _In_ NDIS_HANDLE ProtocolBindingContext) +{ + UNIMPLEMENTED +} + +/* bridge between NDIS and lwip: send data to the adapter */ +static +err_t +lwip_netif_linkoutput( + struct netif *netif, + struct pbuf *p) +{ + UNIMPLEMENTED + return ERR_OK; +} + +/* lwip interface initialisation function */ +static +err_t +lwip_netif_init( + struct netif* lwip_netif) +{ + /* Set output callbacks */ + lwip_netif->output = etharp_output; + lwip_netif->linkoutput = lwip_netif_linkoutput; + + /* We use ARP and broadcasting */ + lwip_netif->flags |= NETIF_FLAG_ETHARP | NETIF_FLAG_BROADCAST; + + /* Let's say we're ethernet */ + lwip_netif->name[0] = 'e'; + lwip_netif->name[1] = 'n'; + + return ERR_OK; +} + +static +VOID +NTAPI +ProtocolBindAdapter( + _Out_ PNDIS_STATUS Status, + _In_ NDIS_HANDLE BindContext, + _In_ PNDIS_STRING DeviceName, + _In_ PVOID SystemSpecific1, + _In_ PVOID SystemSpecific2) +{ + TCPIP_INTERFACE* Interface; + NDIS_STATUS OpenErrorStatus; + UNICODE_STRING RealDeviceName; + struct ip_addr IpAddr, SubnetMask, GatewayAddr; + err_t lwip_error; + + /* The device name comes in the \Device\AdapterName form */ + RealDeviceName.Buffer = DeviceName->Buffer + 8; + RealDeviceName.Length = DeviceName->Length - (8 * sizeof(WCHAR)); + RealDeviceName.MaximumLength = DeviceName->MaximumLength - (8 * sizeof(WCHAR)); + + /* Allocate an interface for this NIC */ + Interface = ExAllocatePoolWithTag(PagedPool, + sizeof(*Interface) + RealDeviceName.MaximumLength, + TAG_INTERFACE); + if (!Interface) + { + DPRINT1("Could not allocate an interface structure!\n"); + *Status = NDIS_STATUS_RESOURCES; + return; + } + + /* Copy the device name */ + RtlInitEmptyUnicodeString(&Interface->DeviceName, (PWSTR)(Interface + 1), RealDeviceName.MaximumLength); + RtlCopyUnicodeString(&Interface->DeviceName, &RealDeviceName); + + /* Add the interface to the lwip list */ + ip_addr_set_zero(&IpAddr); + ip_addr_set_zero(&SubnetMask); + ip_addr_set_zero(&GatewayAddr); + lwip_error = netifapi_netif_add( + &Interface->lwip_netif, + &IpAddr, + &SubnetMask, + &GatewayAddr, + Interface, + lwip_netif_init, + ethernet_input); + if (lwip_error != ERR_OK) + { + DPRINT1("netifapi_netif_add failed with error %d.\n", lwip_error); + *Status = NDIS_STATUS_RESOURCES; + return; + } + + /* Get a adapter handle from NDIS */ + NdisOpenAdapter( + Status, + &OpenErrorStatus, + &Interface->NdisContext, + &Interface->MediumIndex, + NdisMediaArray, + sizeof(NdisMediaArray) / sizeof(NdisMediaArray[0]), + NdisHandle, + Interface, + DeviceName, + 0, + NULL); + if (*Status == NDIS_STATUS_PENDING) + { + /* Silently return, as the binding will be finished in the async call */ + return; + } + + if (*Status != NDIS_STATUS_SUCCESS) + { + DPRINT1("NdisOpenAdapter failed with status 0x%08x.\n", *Status); + ExFreePoolWithTag(Interface, TAG_INTERFACE); + return; + } + + /* Finish the bind request in sync */ + *Status = InitializeInterface(Interface); +} + +static +VOID +NTAPI +ProtocolUnbindAdapter( + _Out_ PNDIS_STATUS Status, + _In_ NDIS_HANDLE ProtocolBindingContext, + _In_ NDIS_HANDLE UnbindContext) +{ + UNIMPLEMENTED +} + +NTSTATUS +TcpIpRegisterNdisProtocol(void) +{ + NDIS_STATUS Status; + NDIS_PROTOCOL_CHARACTERISTICS ProtocolCharacteristics; + + /* Simply fill in the structure and pass it to the NDIS driver. */ + RtlZeroMemory(&ProtocolCharacteristics, sizeof(ProtocolCharacteristics)); + ProtocolCharacteristics.MajorNdisVersion = NDIS_PROTOCOL_MAJOR_VERSION; + ProtocolCharacteristics.MinorNdisVersion = NDIS_PROTOCOL_MINOR_VERSION; + ProtocolCharacteristics.Reserved = 0; + ProtocolCharacteristics.OpenAdapterCompleteHandler = ProtocolOpenAdapterComplete; + ProtocolCharacteristics.CloseAdapterCompleteHandler = ProtocolCloseAdapterComplete; + ProtocolCharacteristics.ResetCompleteHandler = ProtocolResetComplete; + ProtocolCharacteristics.RequestCompleteHandler = ProtocolRequestComplete; + ProtocolCharacteristics.ReceiveCompleteHandler = ProtocolReceiveComplete; + ProtocolCharacteristics.StatusCompleteHandler = ProtocolStatusComplete; + ProtocolCharacteristics.BindAdapterHandler = ProtocolBindAdapter; + ProtocolCharacteristics.UnbindAdapterHandler = ProtocolUnbindAdapter; + RtlInitUnicodeString(&ProtocolCharacteristics.Name, L"TcpIp"); + + NdisRegisterProtocol(&Status, &NdisHandle, &ProtocolCharacteristics, sizeof(ProtocolCharacteristics)); + + return Status; +} + +void +TcpIpUnregisterNdisProtocol(void) +{ + NDIS_STATUS Status; + + NdisDeregisterProtocol(&Status, NdisHandle); +}
Propchange: branches/tcpip_revolution/drivers/network/tcpip/ndis_lwip.c ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/ndis_lwip.c ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/ndis_lwip.c ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/ndis_lwip.h URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/ndis_lwip.h (added) +++ branches/tcpip_revolution/drivers/network/tcpip/ndis_lwip.h [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,8 @@ + +#pragma once + +NTSTATUS +TcpIpRegisterNdisProtocol(void); + +void +TcpIpUnregisterNdisProtocol(void);
Propchange: branches/tcpip_revolution/drivers/network/tcpip/ndis_lwip.h ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/ndis_lwip.h ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/ndis_lwip.h ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/precomp.h URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/precomp.h (added) +++ branches/tcpip_revolution/drivers/network/tcpip/precomp.h [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,34 @@ + +#ifndef __TCPIP_PRECOMP_H__ +#define __TCPIP_PRECOMP_H__ + +#include <ntifs.h> +#include <windef.h> +#include <tdi.h> +#include <tdiinfo.h> +#include <tdikrnl.h> +#include <tcpioctl.h> +#include <ndis.h> +#include <ipifcons.h> + +typedef unsigned short u_short; +#include <ws2def.h> + +#include <rtlfuncs.h> + +#include <pseh/pseh2.h> + +#include <lwip/tcpip.h> +#include <lwip/snmp.h> +#include <lwip/raw.h> +#include <lwip/udp.h> +#include <netif/etharp.h> + +#include "entities.h" +#include "address.h" +#include "information.h" +#include "interface.h" +#include "ndis_lwip.h" +#include "tcp.h" + +#endif /* __TCPIP_PRECOMP_H__ */
Propchange: branches/tcpip_revolution/drivers/network/tcpip/precomp.h ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/precomp.h ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/precomp.h ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/stubs.c URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/stubs.c (added) +++ branches/tcpip_revolution/drivers/network/tcpip/stubs.c [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,42 @@ +/* + * PROJECT: ReactOS tcpip.sys + * COPYRIGHT: GPL - See COPYING in the top level directory + * FILE: drivers/network/tcpip/main.c + * PURPOSE: tcpip.sys unimplemented functions + */ + +#include "precomp.h" + +#define NDEBUG +#include <debug.h> + +VOID +NTAPI +IPAddInterface( + ULONG Unknown0, + ULONG Unknown1, + ULONG Unknown2, + ULONG Unknown3, + ULONG Unknown4) +{ + UNIMPLEMENTED +} + + +VOID +NTAPI +IPDelInterface( + ULONG Unknown0) +{ + UNIMPLEMENTED +} + + +VOID +NTAPI +LookupRoute( + ULONG Unknown0, + ULONG Unknown1) +{ + UNIMPLEMENTED +}
Propchange: branches/tcpip_revolution/drivers/network/tcpip/stubs.c ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/stubs.c ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/stubs.c ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/tcp.c URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/tcp.c (added) +++ branches/tcpip_revolution/drivers/network/tcpip/tcp.c [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,64 @@ +/* + * PROJECT: ReactOS tcpip.sys + * COPYRIGHT: GPL - See COPYING in the top level directory + * FILE: drivers/network/tcpip/main.c + * PURPOSE: tcpip.sys TCP functionality + */ + +#include "precomp.h" + +#include <intsafe.h> + +#define NDEBUG +#include <debug.h> + +static KSPIN_LOCK PortBitmapSpinlock; +static RTL_BITMAP PortBitmap; +static ULONG PortBitmapBuffer[(USHORT_MAX + 1) / 32]; +static USHORT PortNumberHint = 1; + +void +TcpIpInitializeTcp(void) +{ + /* Initialize the port stuff */ + KeInitializeSpinLock(&PortBitmapSpinlock); + RtlInitializeBitMap(&PortBitmap, PortBitmapBuffer, USHORT_MAX + 1); + RtlClearAllBits(&PortBitmap); + /* Reserve the port 0 */ + RtlSetBit(&PortBitmap, 0); +} + +BOOLEAN +AllocateTcpPort( + _Inout_ USHORT* PortNumber, + _In_ BOOLEAN Shared) +{ + KIRQL OldIrql; + ULONG_PTR Bit; + + KeAcquireSpinLock(&PortBitmapSpinlock, &OldIrql); + + if (*PortNumber) + { + if (RtlCheckBit(&PortBitmap, *PortNumber)) + { + if (!Shared) + *PortNumber = 0; + KeReleaseSpinLock(&PortBitmapSpinlock, OldIrql); + return TRUE; + } + + RtlSetBit(&PortBitmap, *PortNumber); + KeReleaseSpinLock(&PortBitmapSpinlock, OldIrql); + return FALSE; + } + + Bit = RtlFindClearBitsAndSet(&PortBitmap, 1, PortNumberHint); + if (Bit == ULONG_PTR_MAX) + *PortNumber = 0; + else + *PortNumber = Bit; + PortNumberHint = *PortNumber; + return FALSE; +} +
Propchange: branches/tcpip_revolution/drivers/network/tcpip/tcp.c ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/tcp.c ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/tcp.c ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/tcp.h URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/tcp.h (added) +++ branches/tcpip_revolution/drivers/network/tcpip/tcp.h [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,10 @@ + +#pragma once + +void +TcpIpInitializeTcp(void); + +BOOLEAN +AllocateTcpPort( + _Inout_ USHORT* PortNumber, + _In_ BOOLEAN Shared);
Propchange: branches/tcpip_revolution/drivers/network/tcpip/tcp.h ------------------------------------------------------------------------------ charset = UTF-8
Propchange: branches/tcpip_revolution/drivers/network/tcpip/tcp.h ------------------------------------------------------------------------------ svn:eol-style = native
Propchange: branches/tcpip_revolution/drivers/network/tcpip/tcp.h ------------------------------------------------------------------------------ svn:mime-type = text/plain
Added: branches/tcpip_revolution/drivers/network/tcpip/tcpip.rc URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/tcpip.rc (added) +++ branches/tcpip_revolution/drivers/network/tcpip/tcpip.rc [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,5 @@ +#define REACTOS_VERSION_DLL +#define REACTOS_STR_FILE_DESCRIPTION "TCP/IP protocol driver" +#define REACTOS_STR_INTERNAL_NAME "tcpip" +#define REACTOS_STR_ORIGINAL_FILENAME "tcpip.sys" +#include <reactos/version.rc>
Propchange: branches/tcpip_revolution/drivers/network/tcpip/tcpip.rc ------------------------------------------------------------------------------ svn:eol-style = native
Added: branches/tcpip_revolution/drivers/network/tcpip/tcpip.spec URL: http://svn.reactos.org/svn/reactos/branches/tcpip_revolution/drivers/network... ============================================================================== --- branches/tcpip_revolution/drivers/network/tcpip/tcpip.spec (added) +++ branches/tcpip_revolution/drivers/network/tcpip/tcpip.spec [iso-8859-1] Mon Nov 10 18:00:09 2014 @@ -0,0 +1,25 @@ +;FreeIprBuff +;GetIFAndLink +@ stdcall IPAddInterface(long long long long long) +;IPAllocBuff +@ stdcall IPDelInterface(long) +;IPDelayedNdisReEnumerateBindings +;IPDeregisterARP +;IPDisableSniffer +;IPEnableSniffer +;IPFreeBuff +;IPGetAddrType +;IPGetBestInterface +;IPGetInfo +;IPInjectPkt +;IPProxyNdisRequest +;IPRegisterARP +;IPRegisterProtocol +;IPSetIPSecStatus +;IPTransmit +@ stdcall LookupRoute(long long) +;LookupRouteInformation +;SendICMPErr +;SetIPSecPtr +;UnSetIPSecPtr +;UnSetIPSecSendPtr
Propchange: branches/tcpip_revolution/drivers/network/tcpip/tcpip.spec ------------------------------------------------------------------------------ svn:eol-style = native
-
jgardou＠svn.reactos.org