+++ /dev/null
-/*
- * COPYRIGHT: See COPYING in the top level directory
- * PROJECT: ReactOS Ancillary Function Driver
- * FILE: afd/event.c
- * PURPOSE: TDI event handlers
- * PROGRAMMERS: Casper S. Hornstrup (chorns@users.sourceforge.net)
- * REVISIONS:
- * CSH 01/09-2000 Created
- */
-
-#include <afd.h>
-
-NTSTATUS AfdEventError(
- IN PVOID TdiEventContext,
- IN NTSTATUS Status)
-{
- AFD_DbgPrint(MAX_TRACE, ("Called.\n"));
-
- return STATUS_SUCCESS;
-}
-
-
-NTSTATUS AfdEventDisconnect(
- IN PVOID TdiEventContext,
- IN CONNECTION_CONTEXT ConnectionContext,
- IN LONG DisconnectDataLength,
- IN PVOID DisconnectData,
- IN LONG DisconnectInformationLength,
- IN PVOID DisconnectInformation,
- IN ULONG DisconnectFlags)
-{
- AFD_DbgPrint(MAX_TRACE, ("Called.\n"));
-
- return STATUS_SUCCESS;
-}
-
-
-NTSTATUS AfdEventReceive(
- IN PVOID TdiEventContext,
- IN CONNECTION_CONTEXT ConnectionContext,
- IN ULONG ReceiveFlags,
- IN ULONG BytesIndicated,
- IN ULONG BytesAvailable,
- OUT ULONG *BytesTaken,
- IN PVOID Tsdu,
- OUT PIRP *IoRequestPacket)
-{
- PAFDFCB FCB = (PAFDFCB)TdiEventContext;
- PVOID ReceiveBuffer;
- PAFD_BUFFER Buffer;
- KIRQL OldIrql;
-
- AFD_DbgPrint(MAX_TRACE, ("Called.\n"));
-
- AFD_DbgPrint(MID_TRACE, ("Receiving (%d) bytes on socket\n",
- BytesAvailable));
-
- ReceiveBuffer = ExAllocatePool(NonPagedPool, BytesAvailable);
- if (!ReceiveBuffer)
- return STATUS_INSUFFICIENT_RESOURCES;
-
- /*Buffer = (PAFD_BUFFER)ExAllocateFromNPagedLookasideList(
- &BufferLookasideList);*/
- Buffer = (PAFD_BUFFER)ExAllocatePool(NonPagedPool, sizeof(AFD_BUFFER));
- if (!Buffer) {
- ExFreePool(ReceiveBuffer);
- return STATUS_INSUFFICIENT_RESOURCES;
- }
-
- /* Copy the data to a local buffer */
- RtlCopyMemory(ReceiveBuffer, Tsdu, BytesAvailable);
-
- Buffer->Buffer.len = BytesAvailable;
- Buffer->Buffer.buf = ReceiveBuffer;
- Buffer->Offset = 0;
-
- KeAcquireSpinLock(&FCB->ReceiveQueueLock, &OldIrql);
-
- InsertTailList( &FCB->ReceiveQueue, &Buffer->ListEntry );
-
- TryToSatisfyRecvRequest( FCB, TRUE );
-
- KeReleaseSpinLock(&FCB->ReceiveQueueLock, OldIrql);
-
- *BytesTaken = BytesAvailable;
-
- AFD_DbgPrint(MAX_TRACE, ("Leaving.\n"));
-
- return STATUS_SUCCESS;
-}
-
-
-TDI_STATUS ClientEventReceiveExpedited(
- IN PVOID TdiEventContext,
- IN CONNECTION_CONTEXT ConnectionContext,
- IN ULONG ReceiveFlags,
- IN ULONG BytesIndicated,
- IN ULONG BytesAvailable,
- OUT ULONG *BytesTaken,
- IN PVOID Tsdu,
- OUT PIRP *IoRequestPacket)
-{
- AFD_DbgPrint(MAX_TRACE, ("Called.\n"));
-
- return STATUS_SUCCESS;
-}
-
-
-NTSTATUS ClientEventChainedReceive(
- IN PVOID TdiEventContext,
- IN CONNECTION_CONTEXT ConnectionContext,
- IN ULONG ReceiveFlags,
- IN ULONG ReceiveLength,
- IN ULONG StartingOffset,
- IN PMDL Tsdu,
- IN PVOID TsduDescriptor)
-{
- AFD_DbgPrint(MAX_TRACE, ("Called.\n"));
-
- return STATUS_SUCCESS;
-}
-
-
-NTSTATUS AfdEventReceiveDatagramHandler(
- IN PVOID TdiEventContext,
- IN LONG SourceAddressLength,
- IN PVOID SourceAddress,
- IN LONG OptionsLength,
- IN PVOID Options,
- IN ULONG ReceiveDatagramFlags,
- IN ULONG BytesIndicated,
- IN ULONG BytesAvailable,
- OUT ULONG *BytesTaken,
- IN PVOID Tsdu,
- OUT PIRP *IoRequestPacket)
-{
- PAFDFCB FCB = (PAFDFCB)TdiEventContext;
- PAFD_READ_REQUEST ReadRequest;
- PVOID ReceiveBuffer;
- PAFD_BUFFER Buffer;
- PLIST_ENTRY Entry;
- NTSTATUS Status;
- KIRQL OldIrql;
- ULONG Count;
- BOOLEAN CompleteIrp;
-
- AFD_DbgPrint(MAX_TRACE, ("Called.\n"));
-
- AFD_DbgPrint(MID_TRACE, ("Receiving (%d) bytes from (0x%X).\n",
- BytesAvailable, *(PULONG)SourceAddress));
-
- ReceiveBuffer = ExAllocatePool(NonPagedPool, BytesAvailable);
- if (!ReceiveBuffer)
- return STATUS_INSUFFICIENT_RESOURCES;
-
- /*Buffer = (PAFD_BUFFER)ExAllocateFromNPagedLookasideList(
- &BufferLookasideList);*/
- Buffer = (PAFD_BUFFER)ExAllocatePool(NonPagedPool, sizeof(AFD_BUFFER));
- if (!Buffer) {
- ExFreePool(ReceiveBuffer);
- return STATUS_INSUFFICIENT_RESOURCES;
- }
-
- /* Copy the data to a local buffer */
- RtlCopyMemory(ReceiveBuffer, Tsdu, BytesAvailable);
-
- Buffer->Buffer.len = BytesAvailable;
- Buffer->Buffer.buf = ReceiveBuffer;
- Buffer->Offset = 0;
-
- ExInterlockedInsertTailList(&FCB->ReceiveQueue,
- &Buffer->ListEntry,
- &FCB->ReceiveQueueLock);
-
- KeAcquireSpinLock(&FCB->ReceiveQueueLock, &OldIrql);
-
- if (CompleteIrp = !IsListEmpty(&FCB->ReadRequestQueue)) {
- AFD_DbgPrint(MAX_TRACE, ("Satisfying read request.\n"));
-
- Entry = RemoveHeadList(&FCB->ReceiveQueue);
- ReadRequest = CONTAINING_RECORD(Entry, AFD_READ_REQUEST, ListEntry);
-
- Status = FillWSABuffers(FCB,
- ReadRequest->RecvFromRequest->Buffers,
- ReadRequest->RecvFromRequest->BufferCount,
- &Count,
- FALSE); /* Packet oriented */
- ReadRequest->RecvFromReply->NumberOfBytesRecvd = Count;
- ReadRequest->RecvFromReply->Status = NO_ERROR;
-
- ReadRequest->Irp->IoStatus.Information = 0;
- ReadRequest->Irp->IoStatus.Status = Status;
- }
-
- KeReleaseSpinLock(&FCB->ReceiveQueueLock, OldIrql);
-
- if (CompleteIrp) {
- AFD_DbgPrint(MAX_TRACE, ("Completing IRP at (0x%X).\n", ReadRequest->Irp));
- IoCompleteRequest(ReadRequest->Irp, IO_NETWORK_INCREMENT);
- *BytesTaken = BytesAvailable;
- }
-
- AFD_DbgPrint(MAX_TRACE, ("Leaving.\n"));
-
- return STATUS_SUCCESS;
-}
-
-
-NTSTATUS AfdRegisterEventHandlers(
- PAFDFCB FCB)
-{
- NTSTATUS Status;
-
- assert(FCB->TdiAddressObject);
-
- /* Report errors for all types of sockets */
- Status = TdiSetEventHandler(FCB->TdiAddressObject,
- TDI_EVENT_ERROR,
- (PVOID)AfdEventError,
- (PVOID)FCB);
- if (!NT_SUCCESS(Status)) { return Status; }
-
- switch (FCB->SocketType) {
- case SOCK_STREAM:
- Status = TdiSetEventHandler(FCB->TdiAddressObject,
- TDI_EVENT_DISCONNECT,
- (PVOID)AfdEventDisconnect,
- (PVOID)FCB);
- if (!NT_SUCCESS(Status)) { return Status; }
-
- Status = TdiSetEventHandler(FCB->TdiAddressObject,
- TDI_EVENT_RECEIVE,
- (PVOID)AfdEventReceive,
- (PVOID)FCB);
- if (!NT_SUCCESS(Status)) { return Status; }
-
- Status = TdiSetEventHandler(FCB->TdiAddressObject,
- TDI_EVENT_RECEIVE_EXPEDITED,
- (PVOID)ClientEventReceiveExpedited,
- (PVOID)FCB);
- if (!NT_SUCCESS(Status)) { return Status; }
-
- Status = TdiSetEventHandler(FCB->TdiAddressObject,
- TDI_EVENT_CHAINED_RECEIVE,
- (PVOID)ClientEventChainedReceive,
- (PVOID)FCB);
- if (!NT_SUCCESS(Status)) { return Status; }
- break;
-
- case SOCK_DGRAM:
- case SOCK_RAW:
- Status = TdiSetEventHandler(FCB->TdiAddressObject,
- TDI_EVENT_RECEIVE_DATAGRAM,
- (PVOID)AfdEventReceiveDatagramHandler,
- (PVOID)FCB);
- if (!NT_SUCCESS(Status)) { return Status; }
- }
- return STATUS_SUCCESS;
-}
-
-
-NTSTATUS AfdDeregisterEventHandlers(
- PAFDFCB FCB)
-{
- NTSTATUS Status;
-
- Status = TdiSetEventHandler(FCB->TdiAddressObject,
- TDI_EVENT_ERROR,
- NULL,
- NULL);
- if (!NT_SUCCESS(Status)) { return Status; }
-
- switch (FCB->SocketType) {
- case SOCK_STREAM:
- Status = TdiSetEventHandler(FCB->TdiAddressObject,
- TDI_EVENT_DISCONNECT,
- NULL,
- NULL);
- if (!NT_SUCCESS(Status)) { return Status; }
-
- Status = TdiSetEventHandler(FCB->TdiAddressObject,
- TDI_EVENT_RECEIVE,
- NULL,
- NULL);
- if (!NT_SUCCESS(Status)) { return Status; }
-
- Status = TdiSetEventHandler(FCB->TdiAddressObject,
- TDI_EVENT_RECEIVE_EXPEDITED,
- NULL,
- NULL);
- if (!NT_SUCCESS(Status)) { return Status; }
-
- Status = TdiSetEventHandler(FCB->TdiAddressObject,
- TDI_EVENT_CHAINED_RECEIVE,
- NULL,
- NULL);
- if (!NT_SUCCESS(Status)) { return Status; }
- break;
-
- case SOCK_DGRAM:
- case SOCK_RAW:
- Status = TdiSetEventHandler(FCB->TdiAddressObject,
- TDI_EVENT_RECEIVE_DATAGRAM,
- NULL,
- NULL);
- if (!NT_SUCCESS(Status)) { return Status; }
- }
- return STATUS_SUCCESS;
-}
-
-/* EOF */
projects / reactos.git / blobdiff