[janderwald] 42337: - Implement KsStreamPointerDelete, KsStreamPointerScheduleTimeout, KsStreamPointerCancelTimeout, KsPinGetFirstCloneStreamPointer, KsStreamPointerGetNextClone - Partly Implement IKsPin_DispatchDeviceIoControl, IKsPin_Close
Author: janderwald Date: Sun Aug 2 16:40:15 2009 New Revision: 42337
URL: http://svn.reactos.org/svn/reactos?rev=42337&view=rev Log: - Implement KsStreamPointerDelete, KsStreamPointerScheduleTimeout, KsStreamPointerCancelTimeout, KsPinGetFirstCloneStreamPointer, KsStreamPointerGetNextClone - Partly Implement IKsPin_DispatchDeviceIoControl, IKsPin_Close
Modified: trunk/reactos/drivers/ksfilter/ks/pin.c
Modified: trunk/reactos/drivers/ksfilter/ks/pin.c URL: http://svn.reactos.org/svn/reactos/trunk/reactos/drivers/ksfilter/ks/pin.c?r... ============================================================================== --- trunk/reactos/drivers/ksfilter/ks/pin.c [iso-8859-1] (original) +++ trunk/reactos/drivers/ksfilter/ks/pin.c [iso-8859-1] Sun Aug 2 16:40:15 2009 @@ -9,6 +9,17 @@
#include "priv.h"
+typedef struct _KSISTREAM_POINTER +{ + KSSTREAM_POINTER StreamPointer; + PFNKSSTREAMPOINTER Callback; + PIRP Irp; + KTIMER Timer; + KDPC TimerDpc; + struct _KSISTREAM_POINTER *Next; + +}KSISTREAM_POINTER, *PKSISTREAM_POINTER; + typedef struct { KSBASIC_HEADER BasicHeader; @@ -24,6 +35,13 @@
PKSGATE AttachedGate; BOOL OrGate; + + LIST_ENTRY IrpList; + KSPIN_LOCK IrpListLock; + + PKSISTREAM_POINTER ClonedStreamPointer; + PKSISTREAM_POINTER LeadingEdgeStreamPointer; + PKSISTREAM_POINTER TrailingStreamPointer;
PFNKSPINPOWER Sleep; PFNKSPINPOWER Wake; @@ -687,7 +705,7 @@ }
/* - @unimplemented + @implemented */ KSDDKAPI VOID @@ -695,7 +713,41 @@ KsStreamPointerDelete( IN PKSSTREAM_POINTER StreamPointer) { - UNIMPLEMENTED + IKsPinImpl * This; + PKSISTREAM_POINTER Cur, Last; + PKSISTREAM_POINTER Pointer = (PKSISTREAM_POINTER)StreamPointer; + + This = (IKsPinImpl*)CONTAINING_RECORD(Pointer->StreamPointer.Pin, IKsPinImpl, Pin); + + /* point to first stream pointer */ + Last = NULL; + Cur = This->ClonedStreamPointer; + + while(Cur != Pointer && Cur) + { + Last = Cur; + /* iterate to next cloned pointer */ + Cur = Cur->Next; + } + + if (!Cur) + { + /* you naughty driver */ + return; + } + + if (!Last) + { + /* remove first cloned pointer */ + This->ClonedStreamPointer = Pointer->Next; + } + else + { + Last->Next = Pointer->Next; + } + + /* FIXME make sure no timeouts are pending */ + FreeItem(Pointer); }
/* @@ -772,7 +824,7 @@ }
/* - @unimplemented + @implemented */ KSDDKAPI VOID @@ -782,11 +834,22 @@ IN PFNKSSTREAMPOINTER Callback, IN ULONGLONG Interval) { - UNIMPLEMENTED -} - -/* - @unimplemented + LARGE_INTEGER DueTime; + PKSISTREAM_POINTER Pointer = (PKSISTREAM_POINTER)StreamPointer; + + /* setup timer callback */ + Pointer->Callback = Callback; + + /* setup expiration */ + DueTime.QuadPart = (LONGLONG)Interval; + + /* setup the timer */ + KeSetTimer(&Pointer->Timer, DueTime, &Pointer->TimerDpc); + +} + +/* + @implemented */ KSDDKAPI VOID @@ -794,11 +857,14 @@ KsStreamPointerCancelTimeout( IN PKSSTREAM_POINTER StreamPointer) { - UNIMPLEMENTED -} - -/* - @unimplemented + PKSISTREAM_POINTER Pointer = (PKSISTREAM_POINTER)StreamPointer; + + KeCancelTimer(&Pointer->Timer); + +} + +/* + @implemented */ KSDDKAPI PKSSTREAM_POINTER @@ -806,12 +872,13 @@ KsPinGetFirstCloneStreamPointer( IN PKSPIN Pin) { - UNIMPLEMENTED - return NULL; -} - -/* - @unimplemented + IKsPinImpl * This = (IKsPinImpl*)CONTAINING_RECORD(Pin, IKsPinImpl, Pin); + /* return first cloned stream pointer */ + return &This->ClonedStreamPointer->StreamPointer; +} + +/* + @implemented */ KSDDKAPI PKSSTREAM_POINTER @@ -819,8 +886,14 @@ KsStreamPointerGetNextClone( IN PKSSTREAM_POINTER StreamPointer) { - UNIMPLEMENTED - return NULL; + PKSISTREAM_POINTER Pointer = (PKSISTREAM_POINTER)StreamPointer; + + /* is there a another cloned stream pointer */ + if (!Pointer->Next) + return NULL; + + /* return next stream pointer */ + return &Pointer->Next->StreamPointer; }
NTSTATUS @@ -829,11 +902,55 @@ IN PDEVICE_OBJECT DeviceObject, IN PIRP Irp) { - UNIMPLEMENTED; - - Irp->IoStatus.Status = STATUS_NOT_IMPLEMENTED; - IoCompleteRequest(Irp, IO_NO_INCREMENT); - return STATUS_NOT_IMPLEMENTED; + PIO_STACK_LOCATION IoStack; + PKSIOBJECT_HEADER ObjectHeader; + IKsPinImpl * This; + NTSTATUS Status = STATUS_SUCCESS; + + /* get current irp stack */ + IoStack = IoGetCurrentIrpStackLocation(Irp); + + /* sanity check */ + ASSERT(IoStack->FileObject); + ASSERT(IoStack->FileObject->FsContext); + + /* get the object header */ + ObjectHeader = (PKSIOBJECT_HEADER)IoStack->FileObject->FsContext; + + /* locate ks pin implemention fro KSPIN offset */ + This = (IKsPinImpl*)CONTAINING_RECORD(ObjectHeader->ObjectType, IKsPinImpl, Pin); + + if (IoStack->Parameters.DeviceIoControl.IoControlCode != IOCTL_KS_WRITE_STREAM && IoStack->Parameters.DeviceIoControl.IoControlCode == IOCTL_KS_READ_STREAM) + { + UNIMPLEMENTED; + Irp->IoStatus.Status = STATUS_NOT_IMPLEMENTED; + Irp->IoStatus.Information = 0; + IoCompleteRequest(Irp, IO_NO_INCREMENT); + return STATUS_NOT_IMPLEMENTED; + } + + /* mark irp as pending */ + IoMarkIrpPending(Irp); + + /* add irp to cancelable queue */ + KsAddIrpToCancelableQueue(&This->IrpList, &This->IrpListLock, Irp, KsListEntryTail, NULL /* FIXME */); + + if (This->Pin.Descriptor->Dispatch->Process) + { + /* it is a pin centric avstream */ + Status = This->Pin.Descriptor->Dispatch->Process(&This->Pin); + + /* TODO */ + } + else + { + /* TODO + * filter-centric avstream + */ + UNIMPLEMENTED + } + + return Status; }
NTSTATUS @@ -842,11 +959,51 @@ IN PDEVICE_OBJECT DeviceObject, IN PIRP Irp) { - UNIMPLEMENTED; - - Irp->IoStatus.Status = STATUS_NOT_IMPLEMENTED; - IoCompleteRequest(Irp, IO_NO_INCREMENT); - return STATUS_NOT_IMPLEMENTED; + PIO_STACK_LOCATION IoStack; + PKSIOBJECT_HEADER ObjectHeader; + IKsPinImpl * This; + NTSTATUS Status = STATUS_SUCCESS; + + /* get current irp stack */ + IoStack = IoGetCurrentIrpStackLocation(Irp); + + /* sanity check */ + ASSERT(IoStack->FileObject); + ASSERT(IoStack->FileObject->FsContext); + + /* get the object header */ + ObjectHeader = (PKSIOBJECT_HEADER)IoStack->FileObject->FsContext; + + /* locate ks pin implemention fro KSPIN offset */ + This = (IKsPinImpl*)CONTAINING_RECORD(ObjectHeader->ObjectType, IKsPinImpl, Pin); + + /* acquire filter control mutex */ + KsFilterAcquireControl(This->BasicHeader.Parent.KsFilter); + + if (This->Pin.Descriptor->Dispatch->Close) + { + /* call pin close routine */ + Status = This->Pin.Descriptor->Dispatch->Close(&This->Pin, Irp); + + if (!NT_SUCCESS(Status)) + { + /* abort closing */ + Irp->IoStatus.Status = Status; + IoCompleteRequest(Irp, IO_NO_INCREMENT); + return Status; + } + + /* FIXME remove pin from filter pin list and decrement reference count */ + + if (Status != STATUS_PENDING) + { + Irp->IoStatus.Status = Status; + IoCompleteRequest(Irp, IO_NO_INCREMENT); + return Status; + } + } + + return Status; }
NTSTATUS @@ -962,6 +1119,8 @@ This->ref = 1; This->FileObject = IoStack->FileObject; KeInitializeMutex(&This->ProcessingMutex, 0); + InitializeListHead(&This->IrpList); + KeInitializeSpinLock(&This->IrpListLock);
/* initialize ks pin descriptor */ This->Pin.Descriptor = Descriptor;
-
janderwald＠svn.reactos.org