b2ether/nt5/b2ether.c

/*
 *  b2ether driver -- derived from DDK packet driver sample
 *
 *  Basilisk II (C) 1997-1999 Christian Bauer
 *
 *  Windows platform specific code copyright (C) Lauri Pesonen
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */


#include "ntddk.h"
#include "ndis.h"
#include "ntddpack.h"
#include "b2ether.h"
#include "stdio.h"


NTSTATUS
DriverEntry(
        IN PDRIVER_OBJECT DriverObject,
        IN PUNICODE_STRING RegistryPath
)
{
        NDIS_PROTOCOL_CHARACTERISTICS   protocolChar;
        NTSTATUS                        status = STATUS_SUCCESS;
        NDIS_STRING                     protoName = NDIS_STRING_CONST("B2ether");
        UNICODE_STRING                  ntDeviceName;
        UNICODE_STRING                  win32DeviceName;
        BOOLEAN                         fSymbolicLink = FALSE;
        PDEVICE_OBJECT                  deviceObject;

        // DebugPrint(("\n\nDriverEntry\n"));

        Globals.DriverObject = DriverObject;
        Globals.RegistryPath.MaximumLength = RegistryPath->Length + sizeof(UNICODE_NULL);
        Globals.RegistryPath.Length = RegistryPath->Length;
        Globals.RegistryPath.Buffer = ExAllocatePool( PagedPool, Globals.RegistryPath.MaximumLength );
        if (!Globals.RegistryPath.Buffer) {
                // DebugPrint (("Couldn't allocate pool for registry path."));
                return STATUS_INSUFFICIENT_RESOURCES;
        }

        RtlCopyUnicodeString(&Globals.RegistryPath, RegistryPath);
        RtlInitUnicodeString(&ntDeviceName, NT_DEVICE_NAME);

        status = IoCreateDevice (DriverObject,
                                                                                                         0,
                                                                                                         &ntDeviceName,
                                                                                                         FILE_DEVICE_UNKNOWN,
                                                                                                         0,
                                                                                                         FALSE,
                                                                                                         &deviceObject);


        if (!NT_SUCCESS (status)) {
                // Either not enough memory to create a deviceobject or another
                // deviceobject with the same name exits. This could happen
                // if you install another instance of this device.
                goto ERROR;
        }

        RtlInitUnicodeString(&win32DeviceName, DOS_DEVICE_NAME);

        status = IoCreateSymbolicLink( &win32DeviceName, &ntDeviceName );
        if (!NT_SUCCESS(status)) goto ERROR;

        fSymbolicLink = TRUE;

        deviceObject->Flags |= DO_BUFFERED_IO;
        Globals.ControlDeviceObject = deviceObject;

        InitializeListHead(&Globals.AdapterList);
        KeInitializeSpinLock(&Globals.GlobalLock);

        NdisZeroMemory(&protocolChar,sizeof(NDIS_PROTOCOL_CHARACTERISTICS));

        protocolChar.MajorNdisVersion            = 5;
        protocolChar.MinorNdisVersion            = 0;
        protocolChar.Name                        = protoName;
        protocolChar.OpenAdapterCompleteHandler  = PacketOpenAdapterComplete;
        protocolChar.CloseAdapterCompleteHandler = PacketCloseAdapterComplete;
        protocolChar.SendCompleteHandler         = PacketSendComplete;
        protocolChar.TransferDataCompleteHandler = PacketTransferDataComplete;
        protocolChar.ResetCompleteHandler        = PacketResetComplete;
        protocolChar.RequestCompleteHandler      = PacketRequestComplete;
        protocolChar.ReceiveHandler              = PacketReceiveIndicate;
        protocolChar.ReceiveCompleteHandler      = PacketReceiveComplete;
        protocolChar.StatusHandler               = PacketStatus;
        protocolChar.StatusCompleteHandler       = PacketStatusComplete;
        protocolChar.BindAdapterHandler          = PacketBindAdapter;
        protocolChar.UnbindAdapterHandler        = PacketUnbindAdapter;
        protocolChar.UnloadHandler               = NULL;
        protocolChar.ReceivePacketHandler        = PacketReceivePacket;
        protocolChar.PnPEventHandler             = PacketPNPHandler;

        NdisRegisterProtocol(
                        &status,
                        &Globals.NdisProtocolHandle,
                        &protocolChar,
                        sizeof(NDIS_PROTOCOL_CHARACTERISTICS));

        if (status != NDIS_STATUS_SUCCESS) {
                // DebugPrint(("Failed to register protocol with NDIS\n"));
                status = STATUS_UNSUCCESSFUL;
                goto ERROR;
        }

        DriverObject->MajorFunction[IRP_MJ_CREATE] = PacketOpen;
        DriverObject->MajorFunction[IRP_MJ_CLOSE]  = PacketClose;
        DriverObject->MajorFunction[IRP_MJ_READ]   = PacketRead;
        DriverObject->MajorFunction[IRP_MJ_WRITE]  = PacketWrite;
        DriverObject->MajorFunction[IRP_MJ_CLEANUP]  = PacketCleanup;
        DriverObject->MajorFunction[IRP_MJ_DEVICE_CONTROL]  = PacketIoControl;
        DriverObject->DriverUnload = PacketUnload;

        return(STATUS_SUCCESS);

ERROR:
        if(deviceObject)
                        IoDeleteDevice(deviceObject);
        if(fSymbolicLink)
                        IoDeleteSymbolicLink(&win32DeviceName);
        if(Globals.RegistryPath.Buffer)
                        ExFreePool(Globals.RegistryPath.Buffer);
        return status;
}


VOID PacketUnload( IN PDRIVER_OBJECT DriverObject )
{
        NDIS_STATUS        status;
        UNICODE_STRING     win32DeviceName;

        // DebugPrint(("Unload Enter\n"));

        RtlInitUnicodeString(&win32DeviceName, DOS_DEVICE_NAME);
        IoDeleteSymbolicLink(&win32DeviceName);

        if(Globals.ControlDeviceObject)
                        IoDeleteDevice(Globals.ControlDeviceObject);

        // Unbind from all the adapters. The system removes the driver code
        // pages from the memory as soon as the unload returns. So you
        // must wait for all the CloseAdapterCompleteHandler to finish
        // before returning from the unload routine. You don't any callbacks
        // to trigger after the driver is unloaded.

        while(DriverObject->DeviceObject) {
                PacketUnbindAdapter(&status, DriverObject->DeviceObject->DeviceExtension,NULL);
        }

        if(Globals.RegistryPath.Buffer)
                ExFreePool(Globals.RegistryPath.Buffer);

        // DebugPrint(("Deregister\n"));

        NdisDeregisterProtocol( &status, Globals.NdisProtocolHandle );
        // DebugPrint(("Unload Exit\n"));
}


NTSTATUS PacketIoControl( IN PDEVICE_OBJECT DeviceObject, IN PIRP Irp )
{
        POPEN_INSTANCE      open;
        PIO_STACK_LOCATION  irpSp;
        PINTERNAL_REQUEST   pRequest;
        ULONG               functionCode;
        NDIS_STATUS         status;
        ULONG               dataLength =0;

        // DebugPrint(("IoControl\n"));

        irpSp = IoGetCurrentIrpStackLocation(Irp);

        functionCode=irpSp->Parameters.DeviceIoControl.IoControlCode;

        if (functionCode == IOCTL_ENUM_ADAPTERS) {
                // If the request is not made to the controlobject, fail the request.

                if(DeviceObject != Globals.ControlDeviceObject) {
                        status = STATUS_INVALID_DEVICE_REQUEST;
                } else {
                        status = PacketGetAdapterList(
                                                                                        Irp->AssociatedIrp.SystemBuffer,
                                                                                        irpSp->Parameters.DeviceIoControl.OutputBufferLength,
                                                                                        &dataLength
                                                                                        );
                }
                Irp->IoStatus.Status = status;
                Irp->IoStatus.Information = dataLength;
                IoCompleteRequest(Irp, IO_NO_INCREMENT);
                return status;
        }

        open =  DeviceObject->DeviceExtension;
        IoIncrement(open);

        if(!open->Bound) {
                Irp->IoStatus.Status = status = STATUS_UNSUCCESSFUL;
                IoCompleteRequest(Irp, IO_NO_INCREMENT);
                IoDecrement(open);
                return status;
        }

        // DebugPrint(("Function code is %08lx  buff size=%08lx  %08lx\n",
        //                              functionCode,irpSp->Parameters.DeviceIoControl.InputBufferLength,
        //                              irpSp->Parameters.DeviceIoControl.OutputBufferLength));

        // Important: Since we have marked the IRP pending, we must return
        // STATUS_PENDING even we happen to complete the IRP synchronously.

        IoMarkIrpPending(Irp);

        if (functionCode == IOCTL_PROTOCOL_RESET) {
                // DebugPrint(("IoControl - Reset request\n"));

                //
                // Since NDIS doesn't have an interface to cancel a request
                // pending at miniport, we cannot set a cancel routine.
                // As a result if the application that made the request
                // terminates, we wait in the Cleanup routine for all pending
                // NDIS requests to complete.

                ExInterlockedInsertTailList(
                                                &open->ResetIrpList,
                                                &Irp->Tail.Overlay.ListEntry,
                                                &open->ResetQueueLock);

                NdisReset( &status, open->AdapterHandle );

                if (status != NDIS_STATUS_PENDING) {
                        // DebugPrint(("IoControl - ResetComplete being called\n"));
                        PacketResetComplete( open, status );
                }
        } else {
                //  See if it is an Ndis request
                PPACKET_OID_DATA    OidData=Irp->AssociatedIrp.SystemBuffer;

                pRequest = ExAllocatePool(NonPagedPool, sizeof(INTERNAL_REQUEST));

                if(!pRequest) {
                        Irp->IoStatus.Status = STATUS_INSUFFICIENT_RESOURCES;
                        IoCompleteRequest (Irp, IO_NO_INCREMENT);
                        IoDecrement(open);
                        return STATUS_PENDING;
                }
                pRequest->Irp=Irp;

                if (((functionCode == IOCTL_PROTOCOL_SET_OID) || (functionCode == IOCTL_PROTOCOL_QUERY_OID))
                                &&
                                (irpSp->Parameters.DeviceIoControl.InputBufferLength == irpSp->Parameters.DeviceIoControl.OutputBufferLength)
                                &&
                                (irpSp->Parameters.DeviceIoControl.InputBufferLength >= sizeof(PACKET_OID_DATA))
                                &&
                                (irpSp->Parameters.DeviceIoControl.InputBufferLength >= sizeof(PACKET_OID_DATA)-1+OidData->Length))
                {
                                // DebugPrint(("IoControl: Request: Oid=%08lx, Length=%08lx\n", OidData->Oid,OidData->Length));

                                if (functionCode == IOCTL_PROTOCOL_SET_OID) {
                                                pRequest->Request.RequestType = NdisRequestSetInformation;
                                                pRequest->Request.DATA.SET_INFORMATION.Oid = OidData->Oid;
                                                pRequest->Request.DATA.SET_INFORMATION.InformationBuffer = OidData->Data;
                                                pRequest->Request.DATA.SET_INFORMATION.InformationBufferLength = OidData->Length;
                                } else {
                                                pRequest->Request.RequestType=NdisRequestQueryInformation;
                                                pRequest->Request.DATA.QUERY_INFORMATION.Oid = OidData->Oid;
                                                pRequest->Request.DATA.QUERY_INFORMATION.InformationBuffer = OidData->Data;
                                                pRequest->Request.DATA.QUERY_INFORMATION.InformationBufferLength = OidData->Length;
                                }
                                NdisRequest( &status, open->AdapterHandle, &pRequest->Request );
                } else {
                        status=NDIS_STATUS_FAILURE;
                        pRequest->Request.DATA.SET_INFORMATION.BytesRead=0;
                        pRequest->Request.DATA.QUERY_INFORMATION.BytesWritten=0;
                }

                if (status != NDIS_STATUS_PENDING) {
                                // DebugPrint(("Calling RequestCompleteHandler\n"));
                                PacketRequestComplete( open, &pRequest->Request, status );
                }
        }
        return STATUS_PENDING;
}


VOID
PacketRequestComplete(
    IN NDIS_HANDLE   ProtocolBindingContext,
    IN PNDIS_REQUEST NdisRequest,
    IN NDIS_STATUS   Status
    )
{
        POPEN_INSTANCE      open;
        PIO_STACK_LOCATION  irpSp;
        PIRP                irp;
        PINTERNAL_REQUEST   pRequest;
        UINT                functionCode;

        PPACKET_OID_DATA    OidData;

        // DebugPrint(("RequestComplete\n"));

        open = (POPEN_INSTANCE)ProtocolBindingContext;

        pRequest=CONTAINING_RECORD(NdisRequest,INTERNAL_REQUEST,Request);
        irp = pRequest->Irp;

        if(Status == NDIS_STATUS_SUCCESS) {
                irpSp = IoGetCurrentIrpStackLocation(irp);
                functionCode=irpSp->Parameters.DeviceIoControl.IoControlCode;
                OidData = irp->AssociatedIrp.SystemBuffer;
                if (functionCode == IOCTL_PROTOCOL_SET_OID) {
                        OidData->Length=pRequest->Request.DATA.SET_INFORMATION.BytesRead;
                } else {
                        if (functionCode == IOCTL_PROTOCOL_QUERY_OID) {
                                OidData->Length=pRequest->Request.DATA.QUERY_INFORMATION.BytesWritten;
                        }
                }
                irp->IoStatus.Status = STATUS_SUCCESS;
                irp->IoStatus.Information=irpSp->Parameters.DeviceIoControl.InputBufferLength;
        } else {
                irp->IoStatus.Status = STATUS_UNSUCCESSFUL;
                irp->IoStatus.Information = 0;
        }

        ExFreePool(pRequest);
        IoCompleteRequest(irp, IO_NO_INCREMENT);
        IoDecrement(open);
}


VOID
PacketStatus(
    IN NDIS_HANDLE   ProtocolBindingContext,
    IN NDIS_STATUS   Status,
    IN PVOID         StatusBuffer,
    IN UINT          StatusBufferSize
)
{
  // DebugPrint(("Indication Status: %0x, StatusBufferSize: %d\n", Status, StatusBufferSize));
}


VOID PacketStatusComplete( IN NDIS_HANDLE  ProtocolBindingContext )
{
  // DebugPrint(("StatusIndicationComplete\n"));
}


NTSTATUS
PacketGetAdapterList(
        IN  PVOID              Buffer,
        IN  ULONG              Length,
        IN  OUT PULONG         DataLength
)
{
        ULONG               requiredLength = 0, numOfAdapters = 0;
        KIRQL               oldIrql;
        PLIST_ENTRY         thisEntry, listHead;
        POPEN_INSTANCE      open;

        // DebugPrint(("Enter PacketGetAdapterList\n"));

        KeAcquireSpinLock(&Globals.GlobalLock, &oldIrql);

        // Walks the list to find out total space required for AdapterName and Symbolic Link.

        listHead = &Globals.AdapterList;

        for( thisEntry = listHead->Flink; thisEntry != listHead; thisEntry = thisEntry->Flink) {
                open = CONTAINING_RECORD(thisEntry, OPEN_INSTANCE, AdapterListEntry);
                requiredLength += open->AdapterName.Length + sizeof(UNICODE_NULL);
                requiredLength += open->SymbolicLink.Length + sizeof(UNICODE_NULL);
                numOfAdapters++;
        }

        //
        // We will return the data in the following format:
        // numOfAdapters + One_Or_More("AdapterName\0" + "SymbolicLink\0") + UNICODE_NULL
        // So let's include the numOfAdapters and UNICODE_NULL size
        // to the total length.
        //

        requiredLength += sizeof(ULONG) + sizeof(UNICODE_NULL);
        *DataLength = requiredLength;

        if(requiredLength > Length) {
                KeReleaseSpinLock(&Globals.GlobalLock, oldIrql);
                return STATUS_BUFFER_TOO_SMALL;
        }

        *(PULONG)Buffer = numOfAdapters;
        (PCHAR)Buffer += sizeof(ULONG);

        for( thisEntry = listHead->Flink; thisEntry != listHead; thisEntry = thisEntry->Flink ) {
                open = CONTAINING_RECORD(thisEntry, OPEN_INSTANCE, AdapterListEntry);
                RtlCopyMemory( Buffer, open->AdapterName.Buffer, open->AdapterName.Length+sizeof(WCHAR) );
                (PCHAR)Buffer += open->AdapterName.Length+sizeof(WCHAR);
                RtlCopyMemory( Buffer, open->SymbolicLink.Buffer, open->SymbolicLink.Length+sizeof(WCHAR) );
                (PCHAR)Buffer += open->SymbolicLink.Length+sizeof(WCHAR);
        }

        *(PWCHAR)Buffer = UNICODE_NULL;
        KeReleaseSpinLock(&Globals.GlobalLock, oldIrql);
        return STATUS_SUCCESS;
}

VOID
PacketBindAdapter(
        OUT PNDIS_STATUS            Status,
        IN  NDIS_HANDLE             BindContext,
        IN  PNDIS_STRING            DeviceName,
        IN  PVOID                   SystemSpecific1,
        IN  PVOID                   SystemSpecific2
)
{
        NDIS_STATUS         status;
        UINT                mediumIndex;
        USHORT              length;
        POPEN_INSTANCE      open = NULL;
        UNICODE_STRING      unicodeDeviceName;
        PDEVICE_OBJECT      deviceObject = NULL;
        PWSTR               symbolicLink = NULL, deviceNameStr = NULL;
        NDIS_MEDIUM         mediumArray = NdisMedium802_3; // Ethernet medium

        // DebugPrint(("Binding DeviceName %ws\n", DeviceName->Buffer));

        do {
                // Create a deviceobject for every adapter we bind to.
                // To make a name for the deviceObject, we will append Packet_
                // to the name portion of the input DeviceName.

                unicodeDeviceName.Buffer = NULL;
                length = DeviceName->Length + 7 * sizeof(WCHAR) + sizeof(UNICODE_NULL);

                deviceNameStr = ExAllocatePool(NonPagedPool, length);
                if (!deviceNameStr) {
                        // DebugPrint(("Memory allocation for create symbolic failed\n"));
                        *Status = NDIS_STATUS_FAILURE;
                        break;
                }
                swprintf(deviceNameStr, L"\\Device\\B2ether_%ws", &DeviceName->Buffer[8]);
                RtlInitUnicodeString(&unicodeDeviceName, deviceNameStr);

                // DebugPrint(("Exported DeviceName %ws\n", unicodeDeviceName.Buffer));

                status = IoCreateDevice(
                                                                Globals.DriverObject,
                                                                sizeof(OPEN_INSTANCE),
                                                                &unicodeDeviceName,
                                                                FILE_DEVICE_PROTOCOL,
                                                                0,
                                                                TRUE, // only one handle to the device at a time.
                                                                &deviceObject
                                                                );

                if (status != STATUS_SUCCESS) {
                        // DebugPrint(("CreateDevice Failed: %x\n", status));
                        *Status = NDIS_STATUS_FAILURE;
                        break;
                }

                deviceObject->Flags |= DO_DIRECT_IO;
                open  =  (POPEN_INSTANCE) deviceObject->DeviceExtension;
                open->DeviceObject = deviceObject;

                // Create a symbolic link.
                // We need to replace Device from \Device\Packet_{GUID} with DosDevices
                // to create a symbolic link of the form \DosDevices\Packet_{GUID}
                // There is a four character difference between these two
                // strings.

                length = unicodeDeviceName.Length + sizeof(UNICODE_NULL) +  (4 * sizeof(WCHAR));

                symbolicLink = ExAllocatePool(NonPagedPool, length);
                if (!symbolicLink) {
                        // DebugPrint(("Memory allocation for create symbolic failed\n"));
                        *Status = NDIS_STATUS_FAILURE;
                        break;
                }

                swprintf( symbolicLink, L"\\DosDevices\\%ws", &unicodeDeviceName.Buffer[8]);

                RtlInitUnicodeString(&open->SymbolicLink,symbolicLink);

                // DebugPrint(("Symbolic Link: %ws\n", open->SymbolicLink.Buffer));

                status = IoCreateSymbolicLink(
                                                (PUNICODE_STRING) &open->SymbolicLink,
                                                (PUNICODE_STRING) &unicodeDeviceName
                                                );
                if (status != STATUS_SUCCESS) {
                        // DebugPrint(("Create symbolic failed\n"));
                        *Status = NDIS_STATUS_FAILURE;
                        break;
                }

                ExFreePool(unicodeDeviceName.Buffer);
                unicodeDeviceName.Buffer = NULL;

                NdisAllocatePacketPool(
                                &status,
                                &open->PacketPool,
                                TRANSMIT_PACKETS,
                                sizeof(PACKET_RESERVED));

                if (status != NDIS_STATUS_SUCCESS) {
                        // DebugPrint(("B2ether: Failed to allocate packet pool\n"));
                        break;
                }

                NdisInitializeEvent(&open->Event);
                InitializeListHead(&open->ResetIrpList);
                KeInitializeSpinLock(&open->ResetQueueLock);
                KeInitializeSpinLock(&open->RcvQSpinLock);
                InitializeListHead(&open->RcvList);

                NdisOpenAdapter(Status,
                                                                                        &status,
                                                                                        &open->AdapterHandle,
                                                                                        &mediumIndex,
                                                                                        &mediumArray,
                                                                                        sizeof(mediumArray)/sizeof(NDIS_MEDIUM),
                                                                                        Globals.NdisProtocolHandle,
                                                                                        open,
                                                                                        DeviceName,
                                                                                        0,
                                                                                        NULL);

                if(*Status == NDIS_STATUS_PENDING) {
                        NdisWaitEvent(&open->Event, 0);
                        *Status = open->Status;
                }
                if(*Status != NDIS_STATUS_SUCCESS) {
                        // DebugPrint(("Failed to openAdapter\n"));
                        break;
                }

                open->IrpCount = 0;
                InterlockedExchange( (PLONG)&open->Bound, TRUE );
                NdisInitializeEvent(&open->CleanupEvent);

                NdisSetEvent(&open->CleanupEvent);

                NdisQueryAdapterInstanceName( &open->AdapterName, open->AdapterHandle );
                // DebugPrint(("Bound AdapterName %ws\n", open->AdapterName.Buffer));

                open->Medium = mediumArray;

                InitializeListHead(&open->AdapterListEntry);

                ExInterlockedInsertTailList(&Globals.AdapterList,
                                                                                                                                &open->AdapterListEntry,
                                                                                                                                &Globals.GlobalLock);

                // Clear the DO_DEVICE_INITIALIZING flag. This is required
                // if you create deviceobjects outside of DriverEntry.
                // Untill you do this, application cannot send I/O request.

                deviceObject->Flags &= ~DO_DEVICE_INITIALIZING;
        } while (FALSE);

        if (*Status != NDIS_STATUS_SUCCESS) {
                if (open && open->PacketPool) NdisFreePacketPool(open->PacketPool);
                if (deviceObject) IoDeleteDevice(deviceObject);
                if(unicodeDeviceName.Buffer) ExFreePool(unicodeDeviceName.Buffer);
                if(symbolicLink) {
                        IoDeleteSymbolicLink(&open->SymbolicLink);
                        ExFreePool(open->SymbolicLink.Buffer);
                }
        }
        // DebugPrint(("Return BindAdapter :0x%x\n", *Status));
}


VOID
PacketUnbindAdapter(
        OUT PNDIS_STATUS        Status,
        IN  NDIS_HANDLE         ProtocolBindingContext,
        IN  NDIS_HANDLE         UnbindContext
)
{
        POPEN_INSTANCE   open =(POPEN_INSTANCE)ProtocolBindingContext;
        KIRQL            oldIrql;

        // DebugPrint(("PacketUnbindAdapter :%ws\n", open->AdapterName.Buffer));

        if(open->AdapterHandle) {
                NdisResetEvent(&open->Event);
                InterlockedExchange( (PLONG) &open->Bound, FALSE );
                PacketCancelReadIrps(open->DeviceObject);

                // DebugPrint(("Waiting on CleanupEvent\n"));
                NdisWaitEvent(&open->CleanupEvent, 0);

                NdisCloseAdapter(Status, open->AdapterHandle);

                // Wait for it to complete
                if(*Status == NDIS_STATUS_PENDING) {
                        NdisWaitEvent(&open->Event, 0);
                        *Status = open->Status;
                } else {
                        *Status = NDIS_STATUS_FAILURE;
                        // ASSERT(0);
                }

                KeAcquireSpinLock(&Globals.GlobalLock, &oldIrql);
                RemoveEntryList(&open->AdapterListEntry);
                KeReleaseSpinLock(&Globals.GlobalLock, oldIrql);

                NdisFreePacketPool(open->PacketPool);

                NdisFreeMemory(open->AdapterName.Buffer, open->AdapterName.Length, 0);

                IoDeleteSymbolicLink(&open->SymbolicLink);
                ExFreePool(open->SymbolicLink.Buffer);

                IoDeleteDevice(open->DeviceObject);
        }

        // DebugPrint(("Exit PacketUnbindAdapter\n"));
}

VOID
PacketOpenAdapterComplete(
        IN NDIS_HANDLE  ProtocolBindingContext,
        IN NDIS_STATUS  Status,
        IN NDIS_STATUS  OpenErrorStatus
)
{
        POPEN_INSTANCE    open = ProtocolBindingContext;

        // DebugPrint(("B2ether: OpenAdapterComplete\n"));

        open->Status = Status;
        NdisSetEvent(&open->Event);
}

VOID
PacketCloseAdapterComplete(
        IN NDIS_HANDLE  ProtocolBindingContext,
        IN NDIS_STATUS  Status
)
{
        POPEN_INSTANCE    open = ProtocolBindingContext;

        // DebugPrint(("CloseAdapterComplete\n"));

        open->Status = Status;
        NdisSetEvent(&open->Event);
}


NDIS_STATUS
PacketPNPHandler(
        IN    NDIS_HANDLE        ProtocolBindingContext,
        IN    PNET_PNP_EVENT     NetPnPEvent
)
{
        POPEN_INSTANCE              open  =(POPEN_INSTANCE)ProtocolBindingContext;
        NDIS_STATUS                 Status  = NDIS_STATUS_SUCCESS;
        PNET_DEVICE_POWER_STATE     powerState;

        // DebugPrint(("PacketPNPHandler\n"));

        powerState = (PNET_DEVICE_POWER_STATE)NetPnPEvent->Buffer;

        // This will happen when all entities in the system need to be notified
        //
        //if(open == NULL)
        //{
        //  return Status;
        //}

        switch(NetPnPEvent->NetEvent) {
                case  NetEventSetPower :
                                // DebugPrint(("NetEventSetPower\n"));
                                switch (*powerState) {
                                                case NetDeviceStateD0:
                                                                Status = NDIS_STATUS_SUCCESS;
                                                                break;
                                                default:
                                                                // We can't suspend, so we ask NDIS to Unbind us by
                                                                // returning this status:
                                                                Status = NDIS_STATUS_NOT_SUPPORTED;
                                                                break;
                                }
                                break;
                case NetEventQueryPower :
                                // DebugPrint(("NetEventQueryPower\n"));
                                break;
                case NetEventQueryRemoveDevice  :
                                // DebugPrint(("NetEventQueryRemoveDevice \n"));
                                break;
                case NetEventCancelRemoveDevice  :
                                // DebugPrint(("NetEventCancelRemoveDevice \n"));
                                break;
                case NetEventReconfigure :
                                // The protocol should always succeed this event by returning NDIS_STATUS_SUCCESS
                                // DebugPrint(("NetEventReconfigure\n"));
                                break;
                case NetEventBindsComplete  :
                                // DebugPrint(("NetEventBindsComplete \n"));
                                break;
                case NetEventPnPCapabilities  :
                                // DebugPrint(("NetEventPnPCapabilities \n"));
                case NetEventBindList:
                                // DebugPrint(("NetEventBindList \n"));
                default:
                                Status = NDIS_STATUS_NOT_SUPPORTED;
                                break;
        }
        return Status;
}


VOID IoIncrement( IN OUT POPEN_INSTANCE Open )
{
        LONG result = InterlockedIncrement(&Open->IrpCount);

        //DebugPrint(("IoIncrement %d\n", result));

        // Need to clear event (when IrpCount bumps from 0 to 1)
        if (result == 1) {
                        NdisResetEvent(&Open->CleanupEvent);
        }
}


VOID IoDecrement ( IN OUT POPEN_INSTANCE Open )
{
        LONG result = InterlockedDecrement(&Open->IrpCount);

        //DebugPrint(("IoDecrement %d\n", result));

        if (result == 0) {
                // Set the event when the count transition from 1 to 0.
                NdisSetEvent (&Open->CleanupEvent);
        }
}
Revision:	1.1
Committed:	2012-04-22T03:13:32Z (12 years, 7 months ago) by asvitkine
Content type:	text/plain
Branch:	MAIN
CVS Tags:	HEAD
Log Message:	Import nt5 version of the ethernet driver from 2001 sources.