[ros-diffs] [janderwald] 41371: - Check in wdmaud if a pin with the specified filter id and pin id has been opened - Partly rewrite SysAudio as it is no longer required to store client specific information per connection since wdmaud just opens one connection - Verify all audio handles at incoming irp

Author: janderwald
Date: Wed Jun 10 22:28:15 2009
New Revision: 41371

URL: http://svn.reactos.org/svn/reactos?rev=41371&view=rev
Log:
- Check in wdmaud if a pin with the specified filter id and pin id has been opened
- Partly rewrite SysAudio as it is no longer required to store client specific information
per connection since wdmaud just opens one connection
- Verify all audio handles at incoming irp

Modified:
    trunk/reactos/drivers/wdm/audio/legacy/wdmaud/control.c
    trunk/reactos/drivers/wdm/audio/legacy/wdmaud/wdmaud.h
    trunk/reactos/drivers/wdm/audio/sysaudio/control.c
    trunk/reactos/drivers/wdm/audio/sysaudio/dispatcher.c
    trunk/reactos/drivers/wdm/audio/sysaudio/pin.c
    trunk/reactos/drivers/wdm/audio/sysaudio/sysaudio.h

Modified: trunk/reactos/drivers/wdm/audio/legacy/wdmaud/control.c
URL:
http://svn.reactos.org/svn/reactos/trunk/reactos/drivers/wdm/audio/legacy/w…
==============================================================================
--- trunk/reactos/drivers/wdm/audio/legacy/wdmaud/control.c [iso-8859-1] (original)
+++ trunk/reactos/drivers/wdm/audio/legacy/wdmaud/control.c [iso-8859-1] Wed Jun 10
22:28:15 2009
@@ -165,6 +165,17 @@
         return SetIrpIoStatus(Irp, STATUS_UNSUCCESSFUL, 0);
     }
 
+    /* close pin handle which uses same virtual audio device id and pin id */
+    for(Index = 0; Index < ClientInfo->NumPins; Index++)
+    {
+        if (ClientInfo->hPins[Index].FilterId == FilterId &&
ClientInfo->hPins[Index].PinId == PinId && ClientInfo->hPins[Index].Handle)
+        {
+            ZwClose(ClientInfo->hPins[Index].Handle);
+            ClientInfo->hPins[Index].Handle = NULL;
+        }
+    }
+
+
     Length = sizeof(KSDATAFORMAT_WAVEFORMATEX) + sizeof(KSPIN_CONNECT) +
sizeof(SYSAUDIO_INSTANCE_INFO);
     InstanceInfo = ExAllocatePool(NonPagedPool, Length);
     if (!InstanceInfo)
@@ -272,6 +283,8 @@
             ClientInfo->hPins = Handels;
             ClientInfo->hPins[ClientInfo->NumPins].Handle = PinHandle;
             ClientInfo->hPins[ClientInfo->NumPins].Type =
DeviceInfo->DeviceType;
+            ClientInfo->hPins[ClientInfo->NumPins].FilterId = FilterId;
+            ClientInfo->hPins[ClientInfo->NumPins].PinId = PinId;
             ClientInfo->NumPins++;
         }
         DeviceInfo->hDevice = PinHandle;

Modified: trunk/reactos/drivers/wdm/audio/legacy/wdmaud/wdmaud.h
URL:
http://svn.reactos.org/svn/reactos/trunk/reactos/drivers/wdm/audio/legacy/w…
==============================================================================
--- trunk/reactos/drivers/wdm/audio/legacy/wdmaud/wdmaud.h [iso-8859-1] (original)
+++ trunk/reactos/drivers/wdm/audio/legacy/wdmaud/wdmaud.h [iso-8859-1] Wed Jun 10
22:28:15 2009
@@ -16,6 +16,8 @@
 {
     HANDLE Handle;
     SOUND_DEVICE_TYPE Type;
+    ULONG FilterId;
+    ULONG PinId;
 }WDMAUD_HANDLE, *PWDMAUD_HANDLE;
 
 

Modified: trunk/reactos/drivers/wdm/audio/sysaudio/control.c
URL:
http://svn.reactos.org/svn/reactos/trunk/reactos/drivers/wdm/audio/sysaudio…
==============================================================================
--- trunk/reactos/drivers/wdm/audio/sysaudio/control.c [iso-8859-1] (original)
+++ trunk/reactos/drivers/wdm/audio/sysaudio/control.c [iso-8859-1] Wed Jun 10 22:28:15
2009
@@ -169,7 +169,6 @@
     IN ULONG DeviceNumber,
     PSYSAUDIODEVEXT DeviceExtension)
 {
-    PSYSAUDIO_CLIENT ClientInfo;
     PKSAUDIO_SUBDEVICE_ENTRY Entry;
     PKSOBJECT_CREATE_ITEM CreateItem;
 
@@ -178,19 +177,6 @@
     ASSERT(CreateItem);
 
     if (DeviceNumber >= DeviceExtension->NumberOfKsAudioDevices)
-    {
-        /* invalid device index */
-        return SetIrpIoStatus(Irp, STATUS_INVALID_PARAMETER, 0);
-    }
-
-    /* get client context */
-    ClientInfo = (PSYSAUDIO_CLIENT)CreateItem->Context;
-
-    /* sanity check */
-    ASSERT(ClientInfo);
-
-    /* check for valid device index */
-    if (DeviceNumber >= ClientInfo->NumDevices)
     {
         /* invalid device index */
         return SetIrpIoStatus(Irp, STATUS_INVALID_PARAMETER, 0);
@@ -249,8 +235,7 @@
     IN KSPIN_CONNECT *PinConnect,
     IN PKSDATAFORMAT InputFormat,
     IN PKSDATAFORMAT OutputFormat,
-    OUT PHANDLE MixerPinHandle,
-    OUT PFILE_OBJECT *MixerFileObject)
+    OUT PHANDLE MixerPinHandle)
 {
     NTSTATUS Status;
     HANDLE PinHandle;
@@ -281,8 +266,9 @@
         ZwClose(PinHandle);
     }
 
+    ObDereferenceObject(FileObject);
+
     *MixerPinHandle = PinHandle;
-    *MixerFileObject = FileObject;
      return Status;
 }
 
@@ -294,11 +280,8 @@
     IN PVOID  Context)
 {
     NTSTATUS Status;
-    ULONG NumHandels;
     HANDLE RealPinHandle = NULL, VirtualPinHandle = NULL, Filter;
-    PFILE_OBJECT RealFileObject = NULL, VirtualFileObject = NULL;
-    PSYSAUDIO_CLIENT AudioClient;
-    PSYSAUDIO_PIN_HANDLE ClientPinHandle;
+    PFILE_OBJECT VirtualFileObject = NULL;
     PKSDATAFORMAT_WAVEFORMATEX InputFormat;
     PKSDATAFORMAT_WAVEFORMATEX OutputFormat = NULL;
     PKSPIN_CONNECT MixerPinConnect = NULL;
@@ -374,28 +357,12 @@
         }
     }
 
-    /* get pin file object */
-    Status = ObReferenceObjectByHandle(RealPinHandle,
-                                       GENERIC_READ | GENERIC_WRITE, 
-                                       IoFileObjectType, KernelMode,
(PVOID*)&RealFileObject, NULL);
-
-    if (!NT_SUCCESS(Status))
-    {
-        DPRINT1("Failed to get file object with %x\n", Status);
-        goto cleanup;
-    }
-
-    if
(WorkerContext->Entry->Pins[WorkerContext->PinConnect->PinId].MaxPinInstanceCount
== 1)
-    {
-        /* store the pin handle there if the pin can only be instantiated once*/
-       
WorkerContext->Entry->Pins[WorkerContext->PinConnect->PinId].PinHandle =
RealPinHandle;
-    }
+   
ASSERT(WorkerContext->Entry->Pins[WorkerContext->PinConnect->PinId].MaxPinInstanceCount);
 
     WorkerContext->Entry->Pins[WorkerContext->PinConnect->PinId].References =
0;
     WorkerContext->DispatchContext->Handle = RealPinHandle;
     WorkerContext->DispatchContext->PinId =
WorkerContext->PinConnect->PinId;
     WorkerContext->DispatchContext->AudioEntry = WorkerContext->Entry;
-    WorkerContext->DispatchContext->FileObject = RealFileObject;
 
     /* Do we need to transform the audio stream */
     if (OutputFormat != NULL)
@@ -405,8 +372,7 @@
                                             MixerPinConnect,
                                             (PKSDATAFORMAT)InputFormat,
                                             (PKSDATAFORMAT)OutputFormat,
-                                           
&WorkerContext->DispatchContext->hMixerPin,
-                                           
&WorkerContext->DispatchContext->MixerFileObject);
+                                           
&WorkerContext->DispatchContext->hMixerPin);
 
 
         if (!NT_SUCCESS(Status))
@@ -438,60 +404,20 @@
         goto cleanup;
     }
 
-    ASSERT(WorkerContext->AudioClient);
-    ASSERT(WorkerContext->AudioClient->NumDevices > 0);
-    ASSERT(WorkerContext->AudioClient->Devs != NULL);
     ASSERT(WorkerContext->Entry->Pins != NULL);
-
-    AudioClient = WorkerContext->AudioClient;
-    NumHandels = AudioClient->Devs[AudioClient->NumDevices -1].ClientHandlesCount;
-
-    ClientPinHandle = ExAllocatePool(NonPagedPool, sizeof(SYSAUDIO_PIN_HANDLE) *
(NumHandels+1));
-    if (ClientPinHandle)
-    {
-        if (NumHandels)
-        {
-            ASSERT(AudioClient->Devs[AudioClient->NumDevices -1].ClientHandles !=
NULL);
-            RtlMoveMemory(ClientPinHandle,
-                          AudioClient->Devs[AudioClient->NumDevices
-1].ClientHandles,
-                          sizeof(SYSAUDIO_PIN_HANDLE) * NumHandels);
-            ExFreePool(AudioClient->Devs[AudioClient->NumDevices
-1].ClientHandles);
-        }
-
-        AudioClient->Devs[AudioClient->NumDevices -1].ClientHandles =
ClientPinHandle;
-
-        /// if the pin can be instantiated more than once
-        /// then store the real pin handle in the client context
-        /// otherwise just the pin id of the available pin
-        if
(WorkerContext->Entry->Pins[WorkerContext->PinConnect->PinId].MaxPinInstanceCount
> 1)
-        {
-            AudioClient->Devs[AudioClient->NumDevices
-1].ClientHandles[NumHandels].bHandle = TRUE;
-            AudioClient->Devs[AudioClient->NumDevices
-1].ClientHandles[NumHandels].hPin = RealPinHandle;
-            AudioClient->Devs[AudioClient->NumDevices
-1].ClientHandles[NumHandels].PinId = WorkerContext->PinConnect->PinId;
-            AudioClient->Devs[AudioClient->NumDevices
-1].ClientHandles[NumHandels].hMixer = WorkerContext->DispatchContext->hMixerPin;
-            AudioClient->Devs[AudioClient->NumDevices
-1].ClientHandles[NumHandels].DispatchContext = WorkerContext->DispatchContext;
-        }
-        else
-        {
-            AudioClient->Devs[AudioClient->NumDevices
-1].ClientHandles[NumHandels].bHandle = FALSE;
-            AudioClient->Devs[AudioClient->NumDevices
-1].ClientHandles[NumHandels].hPin = VirtualPinHandle;
-            AudioClient->Devs[AudioClient->NumDevices
-1].ClientHandles[NumHandels].PinId = WorkerContext->PinConnect->PinId;
-            AudioClient->Devs[AudioClient->NumDevices
-1].ClientHandles[NumHandels].hMixer = WorkerContext->DispatchContext->hMixerPin;
-            AudioClient->Devs[AudioClient->NumDevices
-1].ClientHandles[NumHandels].DispatchContext = WorkerContext->DispatchContext;
-        }
-
-        /// increase reference count
-        AudioClient->Devs[AudioClient->NumDevices -1].ClientHandlesCount++;
-       
WorkerContext->Entry->Pins[WorkerContext->PinConnect->PinId].References++;
-    }
-    else
-    {
-        /* no memory */
-        goto cleanup;
-    }
+    ASSERT(WorkerContext->Entry->NumberOfPins >
WorkerContext->PinConnect->PinId);
+
+    /* increment reference count */
+   
WorkerContext->Entry->Pins[WorkerContext->PinConnect->PinId].References++;
+
+    /* store the pin handle there if the pin can only be instantiated once*/
+    WorkerContext->Entry->Pins[WorkerContext->PinConnect->PinId].PinHandle =
VirtualPinHandle;
 
     /* store pin context */
     VirtualFileObject->FsContext2 = (PVOID)WorkerContext->DispatchContext;
+
+    /* release virtual file object */
+    ObDereferenceObject(VirtualFileObject);
 
     DPRINT("Successfully created virtual pin %p\n", VirtualPinHandle);
     *((PHANDLE)WorkerContext->Irp->UserBuffer) = VirtualPinHandle;
@@ -502,14 +428,8 @@
     return;
 
 cleanup:
-    if (RealFileObject)
-        ObDereferenceObject(RealFileObject);
-
     if (RealPinHandle)
         ZwClose(RealPinHandle);
-
-    if (WorkerContext->DispatchContext->MixerFileObject)
-        ObDereferenceObject(WorkerContext->DispatchContext->MixerFileObject);
 
     if (WorkerContext->DispatchContext->hMixerPin)
         ZwClose(WorkerContext->DispatchContext->hMixerPin);
@@ -767,51 +687,6 @@
 
 }
 
-VOID
-CloseExistingPin(
-    PSYSAUDIO_CLIENT ClientInfo,
-    PSYSAUDIO_INSTANCE_INFO InstanceInfo,
-    PKSPIN_CONNECT PinConnect)
-{
-    ULONG Index, SubIndex;
-    PDISPATCH_CONTEXT DispatchContext;
-
-    /* scan the clientinfo if the client has already opened device with the specified pin
*/
-    for (Index = 0; Index < ClientInfo->NumDevices; Index++)
-    {
-        if (ClientInfo->Devs[Index].DeviceId == InstanceInfo->DeviceNumber)
-        {
-            if (ClientInfo->Devs[Index].ClientHandlesCount)
-            {
-                for(SubIndex = 0; SubIndex <
ClientInfo->Devs[Index].ClientHandlesCount; SubIndex++)
-                {
-                    if (ClientInfo->Devs[Index].ClientHandles[SubIndex].PinId ==
PinConnect->PinId)
-                    {
-                        /* the pin has been already opened by the client, re-use it */
-                        ASSERT(ClientInfo->Devs[Index].ClientHandles[SubIndex].bHandle
== FALSE);
-
-                        DispatchContext =
ClientInfo->Devs[Index].ClientHandles[SubIndex].DispatchContext;
-
-                        if (DispatchContext->MixerFileObject)
-                            ObDereferenceObject(DispatchContext->MixerFileObject);
-
-                        if (DispatchContext->hMixerPin)
-                            ZwClose(DispatchContext->hMixerPin);
-
-                        if (DispatchContext->FileObject)
-                            ObDereferenceObject(DispatchContext->FileObject);
-
-                        if (DispatchContext->Handle)
-                            ZwClose(DispatchContext->Handle);
-                        ClientInfo->Devs[Index].ClientHandles[SubIndex].PinId =
(ULONG)-1;
-                    }
-                }
-            }
-        }
-    }
-
-}
-
 NTSTATUS
 HandleSysAudioFilterPinCreation(
     PIRP Irp,
@@ -824,7 +699,6 @@
     KSPIN_CONNECT * PinConnect;
     PIO_STACK_LOCATION IoStack;
     PSYSAUDIO_INSTANCE_INFO InstanceInfo;
-    PSYSAUDIO_CLIENT ClientInfo;
     PKSOBJECT_CREATE_ITEM CreateItem;
     NTSTATUS Status;
     KSPIN_CINSTANCES PinInstances;
@@ -853,14 +727,6 @@
         return SetIrpIoStatus(Irp, STATUS_INVALID_PARAMETER, 0);
     }
 
-    /* get client context */
-    ClientInfo = (PSYSAUDIO_CLIENT)CreateItem->Context;
-    if (!ClientInfo || !ClientInfo->NumDevices || !ClientInfo->Devs)
-    {
-        /* we have a problem */
-        KeBugCheckEx(0, 0, 0, 0, 0);
-    }
-
     /* get sysaudio entry */
     Entry = GetListEntry(&DeviceExtension->KsAudioDeviceList,
InstanceInfo->DeviceNumber);
     if (!Entry)
@@ -884,9 +750,6 @@
         return SetIrpIoStatus(Irp, STATUS_INVALID_PARAMETER, 0);
     }
 
-    /* close existing pin first */
-    CloseExistingPin(ClientInfo, InstanceInfo, PinConnect);
-
     /* query instance count */
     Status = GetPinInstanceCount(Entry, &PinInstances, PinConnect);
     if (!NT_SUCCESS(Status))
@@ -905,14 +768,11 @@
     {
         /* pin already exists */
         ASSERT(Entry->Pins[PinConnect->PinId].PinHandle != NULL);
-        if (Entry->Pins[PinConnect->PinId].References)
-        {
-            /* FIXME need ksmixer */
-            DPRINT1("Device %u Pin %u References %u is already occupied, try
later\n", InstanceInfo->DeviceNumber, PinConnect->PinId,
Entry->Pins[PinConnect->PinId].References);
-            return SetIrpIoStatus(Irp, STATUS_UNSUCCESSFUL, 0);
-        }
-    }
-
+        ASSERT(Entry->Pins[PinConnect->PinId].References);
+
+        DPRINT1("Device %u Pin %u References %u is already occupied, try
later\n", InstanceInfo->DeviceNumber, PinConnect->PinId,
Entry->Pins[PinConnect->PinId].References);
+        return SetIrpIoStatus(Irp, STATUS_UNSUCCESSFUL, 0);
+    }
     /* create dispatch pin context */
     DispatchContext = ExAllocatePool(NonPagedPool, sizeof(DISPATCH_CONTEXT));
     if (!DispatchContext)
@@ -956,7 +816,6 @@
     WorkerContext->Entry = Entry;
     WorkerContext->Irp = Irp;
     WorkerContext->PinConnect = PinConnect;
-    WorkerContext->AudioClient = ClientInfo;
     WorkerContext->DeviceExtension = DeviceExtension;
     WorkerContext->WorkItem = WorkItem;
 

Modified: trunk/reactos/drivers/wdm/audio/sysaudio/dispatcher.c
URL:
http://svn.reactos.org/svn/reactos/trunk/reactos/drivers/wdm/audio/sysaudio…
==============================================================================
--- trunk/reactos/drivers/wdm/audio/sysaudio/dispatcher.c [iso-8859-1] (original)
+++ trunk/reactos/drivers/wdm/audio/sysaudio/dispatcher.c [iso-8859-1] Wed Jun 10 22:28:15
2009
@@ -73,79 +73,7 @@
     PDEVICE_OBJECT DeviceObject,
     PIRP Irp)
 {
-    PSYSAUDIO_CLIENT Client;
-    PKSAUDIO_SUBDEVICE_ENTRY Entry;
-    PIO_STACK_LOCATION IoStatus;
-    ULONG Index, SubIndex;
-    PSYSAUDIODEVEXT DeviceExtension;
-    PDISPATCH_CONTEXT DispatchContext;
-
-
-    IoStatus = IoGetCurrentIrpStackLocation(Irp);
-
-    Client = (PSYSAUDIO_CLIENT)IoStatus->FileObject->FsContext2;
-    DeviceExtension = (PSYSAUDIODEVEXT)DeviceObject->DeviceExtension;
-
-
-    DPRINT("Client %p NumDevices %u\n", Client, Client->NumDevices);
-    for(Index = 0; Index < Client->NumDevices; Index++)
-    {
-        DPRINT("Index %u Device %u Handels Count %u\n", Index,
Client->Devs[Index].DeviceId, Client->Devs[Index].ClientHandlesCount);
-        if (Client->Devs[Index].ClientHandlesCount)
-        {
-            Entry = GetListEntry(&DeviceExtension->KsAudioDeviceList,
Client->Devs[Index].DeviceId);
-            ASSERT(Entry != NULL);
-
-            for(SubIndex = 0; SubIndex < Client->Devs[Index].ClientHandlesCount;
SubIndex++)
-            {
-                if (Client->Devs[Index].ClientHandles[SubIndex].PinId == (ULONG)-1)
-                    continue;
-
-                if (Client->Devs[Index].ClientHandles[SubIndex].bHandle)
-                {
-                    DPRINT("Closing handle %p\n",
Client->Devs[Index].ClientHandles[SubIndex].hPin);
-
-                    ZwClose(Client->Devs[Index].ClientHandles[SubIndex].hPin);
-                   
Entry->Pins[Client->Devs[Index].ClientHandles[SubIndex].PinId].References--;
-                }
-                else
-                {
-                    /* this is a pin which can only be instantiated once
-                     * so we just need to release the reference count on that pin
-                     */
-                   
Entry->Pins[Client->Devs[Index].ClientHandles[SubIndex].PinId].References--;
-
-                    DispatchContext =
(PDISPATCH_CONTEXT)Client->Devs[Index].ClientHandles[SubIndex].DispatchContext;
-
-                    if (DispatchContext->MixerFileObject)
-                        ObDereferenceObject(DispatchContext->MixerFileObject);
-
-                    if (DispatchContext->hMixerPin)
-                        ZwClose(DispatchContext->hMixerPin);
-
-                    if (DispatchContext->FileObject)
-                        ObDereferenceObject(DispatchContext->FileObject);
-
-                    ExFreePool(DispatchContext);
-
-                    DPRINT("Index %u DeviceIndex %u Pin %u References %u\n",
Index, Client->Devs[Index].DeviceId, SubIndex,
Entry->Pins[Client->Devs[Index].ClientHandles[SubIndex].PinId].References);
-                    if
(!Entry->Pins[Client->Devs[Index].ClientHandles[SubIndex].PinId].References)
-                    {
-                        DPRINT("Closing pin %p\n",
Entry->Pins[Client->Devs[Index].ClientHandles[SubIndex].PinId].PinHandle);
-
-                       
ZwClose(Entry->Pins[Client->Devs[Index].ClientHandles[SubIndex].PinId].PinHandle);
-                       
Entry->Pins[Client->Devs[Index].ClientHandles[SubIndex].PinId].PinHandle = NULL;
-                    }
-                }
-            }
-            ExFreePool(Client->Devs[Index].ClientHandles);
-        }
-    }
-
-    if (Client->Devs)
-        ExFreePool(Client->Devs);
-
-    ExFreePool(Client);
+    DPRINT("Dispatch_fnClose called DeviceObject %p Irp %p\n", DeviceObject);
 
     Irp->IoStatus.Status = STATUS_SUCCESS;
     Irp->IoStatus.Information = 0;
@@ -259,13 +187,10 @@
 {
     NTSTATUS Status;
     KSOBJECT_HEADER ObjectHeader;
-    PSYSAUDIO_CLIENT Client;
     PKSOBJECT_CREATE_ITEM CreateItem;
     PIO_STACK_LOCATION IoStatus;
     LPWSTR Buffer;
     PSYSAUDIODEVEXT DeviceExtension;
-    ULONG Index;
-
     static LPWSTR KS_NAME_PIN = L"{146F1A80-4791-11D0-A5D6-28DB04C10000}";
 
     IoStatus = IoGetCurrentIrpStackLocation(Irp);
@@ -298,58 +223,14 @@
         return STATUS_INSUFFICIENT_RESOURCES;
     }
 
-    Client = ExAllocatePool(NonPagedPool, sizeof(SYSAUDIO_CLIENT));
-    if (!Client)
-    {
-        ExFreePool(CreateItem);
-
-        Irp->IoStatus.Information = 0;
-        Irp->IoStatus.Status = STATUS_INSUFFICIENT_RESOURCES;
-        IoCompleteRequest(Irp, IO_NO_INCREMENT);
-        return STATUS_INSUFFICIENT_RESOURCES;
-    }
-
     /* get device extension */
     DeviceExtension = (PSYSAUDIODEVEXT) DeviceObject->DeviceExtension;
 
-    Client->NumDevices = DeviceExtension->NumberOfKsAudioDevices;
-    /* has sysaudio found any devices */
-    if (Client->NumDevices)
-    {
-        Client->Devs = ExAllocatePool(NonPagedPool, sizeof(SYSAUDIO_CLIENT_HANDELS) *
Client->NumDevices);
-        if (!Client->Devs)
-        {
-            ExFreePool(CreateItem);
-            ExFreePool(Client);
-            Irp->IoStatus.Information = 0;
-            Irp->IoStatus.Status = STATUS_INSUFFICIENT_RESOURCES;
-            IoCompleteRequest(Irp, IO_NO_INCREMENT);
-            return STATUS_INSUFFICIENT_RESOURCES;
-        }
-    }
-    else
-    {
-        /* no devices yet available */
-        Client->Devs = NULL;
-    }
-
-    /* Initialize devs array */
-    for(Index = 0; Index < Client->NumDevices; Index++)
-    {
-        Client->Devs[Index].DeviceId = Index;
-        Client->Devs[Index].ClientHandles = NULL;
-        Client->Devs[Index].ClientHandlesCount = 0;
-    }
-
     /* zero create struct */
     RtlZeroMemory(CreateItem, sizeof(KSOBJECT_CREATE_ITEM));
 
     /* store create context */
-    CreateItem->Context = (PVOID)Client;
     RtlInitUnicodeString(&CreateItem->ObjectClass, L"SysAudio");
-
-    /* store the object in FsContext */
-    IoStatus->FileObject->FsContext2 = (PVOID)Client;
 
     /* allocate object header */
     Status = KsAllocateObjectHeader(&ObjectHeader, 1, CreateItem, Irp,
&DispatchTable);

Modified: trunk/reactos/drivers/wdm/audio/sysaudio/pin.c
URL:
http://svn.reactos.org/svn/reactos/trunk/reactos/drivers/wdm/audio/sysaudio…
==============================================================================
--- trunk/reactos/drivers/wdm/audio/sysaudio/pin.c [iso-8859-1] (original)
+++ trunk/reactos/drivers/wdm/audio/sysaudio/pin.c [iso-8859-1] Wed Jun 10 22:28:15 2009
@@ -17,6 +17,7 @@
     PDISPATCH_CONTEXT Context;
     NTSTATUS Status;
     ULONG BytesReturned;
+    PFILE_OBJECT FileObject;
     PIO_STACK_LOCATION IoStack;
 
     DPRINT("Pin_fnDeviceIoControl called DeviceObject %p Irp %p\n",
DeviceObject);
@@ -29,15 +30,27 @@
 
     /* Sanity check */
     ASSERT(Context);
-    ASSERT(Context->FileObject != NULL);
+
+    /* acquire real pin file object */
+    Status = ObReferenceObjectByHandle(Context->Handle, GENERIC_WRITE,
IoFileObjectType, KernelMode, (PVOID*)&FileObject, NULL);
+    if (!NT_SUCCESS(Status))
+    {
+        Irp->IoStatus.Information = 0;
+        Irp->IoStatus.Status = Status;
+        /* Complete the irp */
+        IoCompleteRequest(Irp, IO_NO_INCREMENT);
+        return Status;
+    }
 
     /* Re-dispatch the request to the real target pin */
-    Status = KsSynchronousIoControlDevice(Context->FileObject, KernelMode,
IoStack->Parameters.DeviceIoControl.IoControlCode,
+    Status = KsSynchronousIoControlDevice(FileObject, KernelMode,
IoStack->Parameters.DeviceIoControl.IoControlCode,
                                          
IoStack->Parameters.DeviceIoControl.Type3InputBuffer,
                                          
IoStack->Parameters.DeviceIoControl.InputBufferLength,
                                           Irp->UserBuffer,
                                          
IoStack->Parameters.DeviceIoControl.OutputBufferLength,
                                           &BytesReturned);
+    /* release file object */
+    ObDereferenceObject(FileObject);
 
     /* Save status and information */
     Irp->IoStatus.Information = BytesReturned;
@@ -57,6 +70,7 @@
     PDISPATCH_CONTEXT Context;
     PIO_STACK_LOCATION IoStack;
     ULONG BytesReturned;
+    PFILE_OBJECT FileObject;
     NTSTATUS Status;
 
     /* Get current stack location */
@@ -67,17 +81,30 @@
 
     /* Sanity check */
     ASSERT(Context);
-    ASSERT(Context->FileObject != NULL);
+
+    /* acquire real pin file object */
+    Status = ObReferenceObjectByHandle(Context->Handle, GENERIC_WRITE,
IoFileObjectType, KernelMode, (PVOID*)&FileObject, NULL);
+    if (!NT_SUCCESS(Status))
+    {
+        Irp->IoStatus.Information = 0;
+        Irp->IoStatus.Status = Status;
+        /* Complete the irp */
+        IoCompleteRequest(Irp, IO_NO_INCREMENT);
+        return Status;
+    }
 
     /* Re-dispatch the request to the real target pin */
-    Status = KsSynchronousIoControlDevice(Context->FileObject, KernelMode,
IOCTL_KS_READ_STREAM,
+    Status = KsSynchronousIoControlDevice(FileObject, KernelMode, IOCTL_KS_READ_STREAM,
                                           MmGetMdlVirtualAddress(Irp->MdlAddress),
                                           IoStack->Parameters.Read.Length,
                                           NULL,
                                           0,
                                           &BytesReturned);
 
-    if (Context->hMixerPin && Context->MixerFileObject)
+    /* release file object */
+    ObDereferenceObject(FileObject);
+
+    if (Context->hMixerPin)
     {
         // FIXME
         // call kmixer to convert stream
@@ -102,6 +129,7 @@
     PDISPATCH_CONTEXT Context;
     PIO_STACK_LOCATION IoStack;
     ULONG BytesReturned;
+    PFILE_OBJECT FileObject;
     NTSTATUS Status;
 
     /* Get current stack location */
@@ -112,24 +140,36 @@
 
     /* Sanity check */
     ASSERT(Context);
-    ASSERT(Context->FileObject != NULL);
-
-    if (Context->hMixerPin && Context->MixerFileObject)
+
+    if (Context->hMixerPin)
     {
         // FIXME
         // call kmixer to convert stream
         UNIMPLEMENTED
     }
 
+    /* acquire real pin file object */
+    Status = ObReferenceObjectByHandle(Context->Handle, GENERIC_WRITE,
IoFileObjectType, KernelMode, (PVOID*)&FileObject, NULL);
+    if (!NT_SUCCESS(Status))
+    {
+        Irp->IoStatus.Information = 0;
+        Irp->IoStatus.Status = Status;
+        /* Complete the irp */
+        IoCompleteRequest(Irp, IO_NO_INCREMENT);
+        return Status;
+    }
 
     /* Re-dispatch the request to the real target pin */
-    Status = KsSynchronousIoControlDevice(Context->FileObject, KernelMode,
IOCTL_KS_WRITE_STREAM,
+    Status = KsSynchronousIoControlDevice(FileObject, KernelMode, IOCTL_KS_WRITE_STREAM,
                                           MmGetMdlVirtualAddress(Irp->MdlAddress),
                                           IoStack->Parameters.Read.Length,
                                           NULL,
                                           0,
                                           &BytesReturned);
 
+    /* release file object */
+    ObDereferenceObject(FileObject);
+
     /* Save status and information */
     Irp->IoStatus.Status = Status;
     Irp->IoStatus.Information = 0;
@@ -149,6 +189,7 @@
     PIO_STACK_LOCATION IoStack;
     PDEVICE_OBJECT PinDeviceObject;
     PIRP PinIrp;
+    PFILE_OBJECT FileObject;
     IO_STATUS_BLOCK IoStatus;
     KEVENT Event;
     NTSTATUS Status = STATUS_UNSUCCESSFUL;
@@ -161,10 +202,24 @@
 
     /* Sanity check */
     ASSERT(Context);
-    ASSERT(Context->FileObject != NULL);
+
+
+    /* acquire real pin file object */
+    Status = ObReferenceObjectByHandle(Context->Handle, GENERIC_WRITE,
IoFileObjectType, KernelMode, (PVOID*)&FileObject, NULL);
+    if (!NT_SUCCESS(Status))
+    {
+        Irp->IoStatus.Information = 0;
+        Irp->IoStatus.Status = Status;
+        /* Complete the irp */
+        IoCompleteRequest(Irp, IO_NO_INCREMENT);
+        return Status;
+    }
 
     /* Get Pin's device object */
-    PinDeviceObject = IoGetRelatedDeviceObject(Context->FileObject);
+    PinDeviceObject = IoGetRelatedDeviceObject(FileObject);
+
+    /* release file object */
+    ObDereferenceObject(FileObject);
 
     /* Initialize notification event */
     KeInitializeEvent(&Event, NotificationEvent, FALSE);
@@ -177,7 +232,7 @@
         /* Get the next stack location */
         IoStack = IoGetNextIrpStackLocation(PinIrp);
         /* The file object must be present in the irp as it contains the KSOBJECT_HEADER
*/
-        IoStack->FileObject = Context->FileObject;
+        IoStack->FileObject = FileObject;
 
         /* call the driver */
         Status = IoCallDriver(PinDeviceObject, PinIrp);
@@ -206,7 +261,24 @@
     PDEVICE_OBJECT DeviceObject,
     PIRP Irp)
 {
+    PDISPATCH_CONTEXT Context;
+    PIO_STACK_LOCATION IoStack;
+
     DPRINT("Pin_fnClose called DeviceObject %p Irp %p\n", DeviceObject);
+
+    /* Get current stack location */
+    IoStack = IoGetCurrentIrpStackLocation(Irp);
+
+    /* The dispatch context is stored in the FsContext2 member */
+    Context = (PDISPATCH_CONTEXT)IoStack->FileObject->FsContext2;
+
+    if (Context->Handle)
+    {
+        ZwClose(Context->Handle);
+    }
+    ZwClose(Context->hMixerPin);
+
+    ExFreePool(Context);
 
     Irp->IoStatus.Status = STATUS_SUCCESS;
     Irp->IoStatus.Information = 0;
@@ -294,15 +366,22 @@
     PDEVICE_OBJECT DeviceObject)
 {
     PDISPATCH_CONTEXT Context;
+    PFILE_OBJECT RealFileObject;
     NTSTATUS Status;
 
     DPRINT("Pin_fnFastWrite called DeviceObject %p Irp %p\n", DeviceObject);
 
     Context = (PDISPATCH_CONTEXT)FileObject->FsContext2;
 
-    if (Context->hMixerPin && Context->MixerFileObject)
-    {
-        Status = KsStreamIo(Context->MixerFileObject, NULL, NULL, NULL, NULL, 0,
IoStatus, Buffer, Length, KSSTREAM_WRITE, KernelMode);
+    if (Context->hMixerPin)
+    {
+        Status = ObReferenceObjectByHandle(Context->hMixerPin, GENERIC_WRITE,
IoFileObjectType, KernelMode, (PVOID*)&RealFileObject, NULL);
+        if (NT_SUCCESS(Status))
+        {
+            Status = KsStreamIo(RealFileObject, NULL, NULL, NULL, NULL, 0, IoStatus,
Buffer, Length, KSSTREAM_WRITE, KernelMode);
+            ObDereferenceObject(RealFileObject);
+        }
+
         if (!NT_SUCCESS(Status))
         {
             DPRINT1("Mixing stream failed with %lx\n", Status);
@@ -310,7 +389,14 @@
         }
     }
 
-    Status = KsStreamIo(Context->FileObject, NULL, NULL, NULL, NULL, 0, IoStatus,
Buffer, Length, KSSTREAM_WRITE, KernelMode);
+    Status = ObReferenceObjectByHandle(Context->Handle, GENERIC_WRITE,
IoFileObjectType, KernelMode, (PVOID*)&RealFileObject, NULL);
+    if (!NT_SUCCESS(Status))
+        return FALSE;
+
+    Status = KsStreamIo(RealFileObject, NULL, NULL, NULL, NULL, 0, IoStatus, Buffer,
Length, KSSTREAM_WRITE, KernelMode);
+
+    ObDereferenceObject(RealFileObject);
+
     if (Status == STATUS_SUCCESS)
         return TRUE;
     else

Modified: trunk/reactos/drivers/wdm/audio/sysaudio/sysaudio.h
URL:
http://svn.reactos.org/svn/reactos/trunk/reactos/drivers/wdm/audio/sysaudio…
==============================================================================
--- trunk/reactos/drivers/wdm/audio/sysaudio/sysaudio.h [iso-8859-1] (original)
+++ trunk/reactos/drivers/wdm/audio/sysaudio/sysaudio.h [iso-8859-1] Wed Jun 10 22:28:15
2009
@@ -10,30 +10,6 @@
 #define NDEBUG
 #include <debug.h>
 #include <stdio.h>
-
-typedef struct
-{
-    BOOL bHandle;                    // indicates if an audio pin can be instantated more
than once
-    ULONG PinId;                     // specifies the pin id
-    HANDLE hPin;                     // handle to audio irp pin
-    HANDLE hMixer;                   // handle to mixer pin
-    PVOID DispatchContext;           // pointer to dispatch context
-}SYSAUDIO_PIN_HANDLE, *PSYSAUDIO_PIN_HANDLE;
-
-
-typedef struct
-{
-    ULONG DeviceId;                         //specifies the device id
-    ULONG ClientHandlesCount;               // number of client handles
-    PSYSAUDIO_PIN_HANDLE ClientHandles;     // array of client handles
-}SYSAUDIO_CLIENT_HANDELS, *PSYSAUDIO_CLIENT_HANDELS;
-
-typedef struct
-{
-    ULONG NumDevices;                       // number of devices in Devs array
-    PSYSAUDIO_CLIENT_HANDELS Devs;          // array of client handles
-
-}SYSAUDIO_CLIENT, *PSYSAUDIO_CLIENT;
 
 typedef struct
 {
@@ -94,12 +70,10 @@
 typedef struct
 {
     HANDLE Handle;                                       // audio irp pin handle
-    PFILE_OBJECT FileObject;                             // audio irp pin file object
     ULONG PinId;                                         // pin id of device
     PKSAUDIO_SUBDEVICE_ENTRY AudioEntry;                 // pointer to audio device
entry
 
     HANDLE hMixerPin;                                    // handle to mixer pin
-    PFILE_OBJECT MixerFileObject;                        // mixer file object
 }DISPATCH_CONTEXT, *PDISPATCH_CONTEXT;
 
 // struct PIN_WORKER_CONTEXT
@@ -115,7 +89,6 @@
     PKSAUDIO_SUBDEVICE_ENTRY Entry;
     KSPIN_CONNECT * PinConnect;
     PDISPATCH_CONTEXT DispatchContext;
-    PSYSAUDIO_CLIENT AudioClient;
     PSYSAUDIODEVEXT DeviceExtension;
     PKSDATAFORMAT_WAVEFORMATEX MixerFormat;
     PIO_WORKITEM WorkItem;