accept.c File Reference

#include "precomp.h"
#include <lwip_glue/lwip_glue.h>

Include dependency graph for accept.c:

Go to the source code of this file.

Functions
NTSTATUS	TCPCheckPeerForAccept (PVOID Context, PTDI_REQUEST_KERNEL Request)
NTSTATUS	TCPListen (PCONNECTION_ENDPOINT Connection, UINT Backlog)
BOOLEAN	TCPAbortListenForSocket (PCONNECTION_ENDPOINT Listener, PCONNECTION_ENDPOINT Connection)
NTSTATUS	TCPAccept (PTDI_REQUEST Request, PCONNECTION_ENDPOINT Listener, PCONNECTION_ENDPOINT Connection, PTCP_COMPLETION_ROUTINE Complete, PVOID Context)

Variables
NPAGED_LOOKASIDE_LIST	TdiBucketLookasideList

Function Documentation

TCPAbortListenForSocket()

BOOLEAN TCPAbortListenForSocket	(	PCONNECTION_ENDPOINT	Listener,
		PCONNECTION_ENDPOINT	Connection
	)

Definition at line 107 of file accept.c.

{
    PLIST_ENTRY ListEntry;
    PTDI_BUCKET Bucket;
    BOOLEAN Found = FALSE;
 
    LockObject(Listener);
 
    ListEntry = Listener->ListenRequest.Flink;
    while (ListEntry != &Listener->ListenRequest)
    {
        Bucket = CONTAINING_RECORD(ListEntry, TDI_BUCKET, Entry);
 
        if (Bucket->AssociatedEndpoint == Connection)
        {
            DereferenceObject(Bucket->AssociatedEndpoint);
            RemoveEntryList( &Bucket->Entry );
            ExFreeToNPagedLookasideList(&TdiBucketLookasideList, Bucket);
            Found = TRUE;
            break;
        }
 
        ListEntry = ListEntry->Flink;
    }
 
    UnlockObject(Listener);
 
    return Found;
}

Referenced by DispCancelListenRequest().

TCPAccept()

NTSTATUS TCPAccept	(	PTDI_REQUEST	Request,
		PCONNECTION_ENDPOINT	Listener,
		PCONNECTION_ENDPOINT	Connection,
		PTCP_COMPLETION_ROUTINE	Complete,
		PVOID	Context
	)

Definition at line 139 of file accept.c.

{
    NTSTATUS Status;
    PTDI_BUCKET Bucket;
 
    LockObject(Listener);
 
    Bucket = ExAllocateFromNPagedLookasideList(&TdiBucketLookasideList);
 
    if (Bucket)
    {
        Bucket->AssociatedEndpoint = Connection;
        ReferenceObject(Bucket->AssociatedEndpoint);
 
        Bucket->Request.RequestNotifyObject = Complete;
        Bucket->Request.RequestContext = Context;
        InsertTailList( &Listener->ListenRequest, &Bucket->Entry );
        Status = STATUS_PENDING;
    }
    else
        Status = STATUS_NO_MEMORY;
 
    UnlockObject(Listener);
 
    return Status;
}

Referenced by DispTdiListen().

TCPCheckPeerForAccept()

NTSTATUS TCPCheckPeerForAccept	(	PVOID	Context,
		PTDI_REQUEST_KERNEL	Request
	)

Definition at line 17 of file accept.c.

{
    struct tcp_pcb *newpcb = (struct tcp_pcb*)Context;
    NTSTATUS Status;
    PTDI_CONNECTION_INFORMATION WhoIsConnecting;
    PTA_IP_ADDRESS RemoteAddress;
    ip_addr_t ipaddr;
 
    if (Request->RequestFlags & TDI_QUERY_ACCEPT)
        DbgPrint("TDI_QUERY_ACCEPT NOT SUPPORTED!!!\n");
 
    WhoIsConnecting = (PTDI_CONNECTION_INFORMATION)Request->ReturnConnectionInformation;
    RemoteAddress = (PTA_IP_ADDRESS)WhoIsConnecting->RemoteAddress;
 
    RemoteAddress->TAAddressCount = 1;
    RemoteAddress->Address[0].AddressLength = TDI_ADDRESS_LENGTH_IP;
    RemoteAddress->Address[0].AddressType = TDI_ADDRESS_TYPE_IP;
 
    Status = TCPTranslateError(LibTCPGetPeerName(newpcb,
                                                 &ipaddr,
                                                 &RemoteAddress->Address[0].Address[0].sin_port));
 
    RemoteAddress->Address[0].Address[0].in_addr = ipaddr.addr;
 
    return Status;
}

Referenced by TCPAcceptEventHandler().

TCPListen()

NTSTATUS TCPListen	(	PCONNECTION_ENDPOINT	Connection,
		UINT	Backlog
	)

Definition at line 47 of file accept.c.

{
    NTSTATUS Status = STATUS_SUCCESS;
    ip_addr_t AddressToBind;
    TA_IP_ADDRESS LocalAddress;
 
    ASSERT(Connection);
 
    LockObject(Connection);
 
    ASSERT_KM_POINTER(Connection->AddressFile);
 
    TI_DbgPrint(DEBUG_TCP,("[IP, TCPListen] Called\n"));
 
    TI_DbgPrint(DEBUG_TCP, ("Connection->SocketContext %x\n",
        Connection->SocketContext));
 
    AddressToBind.addr = Connection->AddressFile->Address.Address.IPv4Address;
 
    Status = TCPTranslateError(LibTCPBind(Connection,
                                          &AddressToBind,
                                          Connection->AddressFile->Port));
 
    if (NT_SUCCESS(Status))
    {
        /* Check if we had an unspecified port */
        if (!Connection->AddressFile->Port)
        {
            /* We did, so we need to copy back the port */
            Status = TCPGetSockAddress(Connection, (PTRANSPORT_ADDRESS)&LocalAddress, FALSE);
            if (NT_SUCCESS(Status))
            {
                /* Allocate the port in the port bitmap */
                UINT AllocatedPort = TCPAllocatePort(LocalAddress.Address[0].Address[0].sin_port);
                /* This should never fail unless all ports are in use */
                if (AllocatedPort == (UINT) -1)
                {
                    DbgPrint("ERR: No more ports available.\n");
                    UnlockObject(Connection);
                    return STATUS_TOO_MANY_ADDRESSES;
                }
                Connection->AddressFile->Port = AllocatedPort;
            }
        }
    }
 
    if (NT_SUCCESS(Status))
    {
        Connection->SocketContext = LibTCPListen(Connection, Backlog);
        if (!Connection->SocketContext)
            Status = STATUS_UNSUCCESSFUL;
    }
 
    UnlockObject(Connection);
 
    TI_DbgPrint(DEBUG_TCP,("[IP, TCPListen] Leaving. Status = %x\n", Status));
 
    return Status;
}

Referenced by DispTdiListen().

Variable Documentation

TdiBucketLookasideList

NPAGED_LOOKASIDE_LIST TdiBucketLookasideList

extern

Definition at line 26 of file tcp.c.

Referenced by TCPAbortListenForSocket(), and TCPAccept().