precomp.h File Reference

#include <ntddk.h>
#include <portcls.h>
#include <ks.h>
#include <ksmedia.h>
#include <debug.h>

Include dependency graph for precomp.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	PIN_CONTEXT

Typedefs
typedef struct PIN_CONTEXT *	PPIN_CONTEXT

Functions
NTSTATUS NTAPI	FilterProcess (IN PKSFILTER Filter, IN PKSPROCESSPIN_INDEXENTRY ProcessPinsIndex)
NTSTATUS NTAPI	PinCreate (IN PKSPIN Pin, IN PIRP Irp)
NTSTATUS NTAPI	PinClose (IN PKSPIN Pin, IN PIRP Irp)
VOID NTAPI	PinReset (IN PKSPIN Pin)
NTSTATUS NTAPI	PinState (IN PKSPIN Pin, IN KSSTATE ToState, IN KSSTATE FromState)
NTSTATUS NTAPI	AudioPositionPropertyHandler (IN PIRP Irp, IN PKSIDENTIFIER Request, IN OUT PVOID Data)
NTSTATUS NTAPI	PinIntersectHandler (IN PVOID Context, IN PIRP Irp, IN PKSP_PIN Pin, IN PKSDATARANGE DataRange, IN PKSDATARANGE MatchingDataRange, IN ULONG DataBufferSize, OUT PVOID Data OPTIONAL, OUT PULONG DataSize)

Typedef Documentation

PPIN_CONTEXT

typedef struct PIN_CONTEXT * PPIN_CONTEXT

Function Documentation

AudioPositionPropertyHandler()

NTSTATUS NTAPI AudioPositionPropertyHandler	(	IN PIRP	Irp,
		IN PKSIDENTIFIER	Request,
		IN OUT PVOID	Data
	)

Definition at line 127 of file pin.c.

{
    PKSFILTER Filter;
    PKSPIN Pin, FirstPin;
    PFILE_OBJECT FileObject;
    NTSTATUS Status;
    ULONG BytesReturned;

    /* first get the pin */
    Pin = KsGetPinFromIrp(Irp);

    /* sanity check */
    ASSERT(Pin);

    /* get parent filter */
    Filter = KsPinGetParentFilter(Pin);

    /* acquire filter control mutex */
    KsFilterAcquireControl(Filter);

    /* get first pin */
    FirstPin = KsFilterGetFirstChildPin(Filter, Pin->Id);

    /* get connected pin of first pin */
    FileObject = KsPinGetConnectedPinFileObject(FirstPin);

    if (!FileObject)
    {
        /* no pin connected */
        Status = STATUS_INVALID_PARAMETER;
    }
    else
    {
        /* perform request */
        Status = KsSynchronousIoControlDevice(FileObject, KernelMode, IOCTL_KS_PROPERTY, (PVOID)Request, sizeof(KSPROPERTY), Data, sizeof(KSAUDIO_POSITION), &BytesReturned);

        /* store result size */
        Irp->IoStatus.Information = sizeof(KSAUDIO_POSITION);
    }

    /* release control */
    KsFilterReleaseControl(Filter);

    /* done */
    return Status;
}

FilterProcess()

NTSTATUS NTAPI FilterProcess	(	IN PKSFILTER	Filter,
		IN PKSPROCESSPIN_INDEXENTRY	ProcessPinsIndex
	)

Definition at line 13 of file filter.c.

{
    ULONG Index;
    PKSPROCESSPIN CurPin, Pin;
    BOOLEAN PendingFrames = FALSE;

    if (ProcessPinsIndex->Count)
    {
        /* check if there are outstanding frames */
        for(Index = 1; Index < ProcessPinsIndex->Count; Index++)
        {
            /* get current pin */
            CurPin = ProcessPinsIndex->Pins[Index];

            if (CurPin->BytesAvailable && CurPin->Pin->DeviceState == KSSTATE_RUN)
            {
                /* pin has pending frames 
                 * to keep all pins synchronized, every pin has to wait untill each chained pin has send its frames downwards
                 */
                PendingFrames = TRUE;
            }
        }
    }

    if (!PendingFrames && ProcessPinsIndex->Count)
    {
        /* get first pin */
        Pin = ProcessPinsIndex->Pins[0];

        /* check if there is new data available */
        if (Pin->BytesAvailable)
        {
            for(Index = 1; Index < ProcessPinsIndex->Count; Index++)
            {
                /* get current pin */
                CurPin = ProcessPinsIndex->Pins[Index];

                /* copy the frame to pin */
                RtlMoveMemory(CurPin->Data, Pin->Data, Pin->BytesAvailable);
                CurPin->BytesUsed = Pin->BytesAvailable;
            }
        }
    }
    /* done */
    return STATUS_SUCCESS;
}

PinClose()

NTSTATUS NTAPI PinClose	(	IN PKSPIN	Pin,
		IN PIRP	Irp
	)

Definition at line 60 of file pin.c.

{
    /* is there a context */
    if (Pin->Context)
    {
        /* free pin context */
        ExFreePool(Pin->Context);
    }

    return STATUS_SUCCESS;
}

PinCreate()

NTSTATUS NTAPI PinCreate	(	IN PKSPIN	Pin,
		IN PIRP	Irp
	)

Definition at line 13 of file pin.c.

{
    PKSFILTER Filter;
    PKSPIN FirstPin;
    PPIN_CONTEXT PinContext;

    /* first get the parent filter */
    Filter = KsPinGetParentFilter(Pin);

    /* now get first child pin */
    FirstPin = KsFilterGetFirstChildPin(Filter, Pin->Id);

    /* sanity check */
    ASSERT(FirstPin);

    if (FirstPin != Pin)
    {
        /* a previous pin already exists */
        if (RtlCompareMemory(FirstPin->ConnectionFormat, Pin->ConnectionFormat, Pin->ConnectionFormat->FormatSize) != Pin->ConnectionFormat->FormatSize)
        {
            /* each instantiated pin must have the same connection format */
            return STATUS_INVALID_PARAMETER;
        }
    }

    /* allocate pin context */
    PinContext = ExAllocatePool(NonPagedPool, sizeof(PIN_CONTEXT));
    if (!PinContext)
        return STATUS_INSUFFICIENT_RESOURCES;

    /* store pin context */
    Pin->Context = PinContext;

    /* clear pin context */
    RtlZeroMemory(PinContext, sizeof(PIN_CONTEXT));

    /* FIXME
     * check allocator framing and apply to all pins 
     */

    return STATUS_SUCCESS;
}

PinIntersectHandler()

NTSTATUS NTAPI PinIntersectHandler	(	IN PVOID	Context,
		IN PIRP	Irp,
		IN PKSP_PIN	Pin,
		IN PKSDATARANGE	DataRange,
		IN PKSDATARANGE	MatchingDataRange,
		IN ULONG	DataBufferSize,
		OUT PVOID Data	OPTIONAL,
		OUT PULONG	DataSize
	)

Definition at line 179 of file pin.c.

{
    PKSPIN FirstPin;
    NTSTATUS Status;

    /* get first pin */
    FirstPin = KsFilterGetFirstChildPin((PKSFILTER)Context, Pin->PinId);

    /* sanity check */
    ASSERT(FirstPin);

    /* check for matching dataformat */
    if (!IsEqualGUIDAligned(&FirstPin->ConnectionFormat->SubFormat, &DataRange->SubFormat) ||
        !IsEqualGUIDAligned(&FirstPin->ConnectionFormat->Specifier, &DataRange->Specifier) ||
        !IsEqualGUIDAligned(&GUID_NULL, &DataRange->SubFormat) ||
        !IsEqualGUIDAligned(&GUID_NULL, &DataRange->Specifier))
    {
        /* no match */
        return STATUS_NO_MATCH;
    }


    if (DataBufferSize)
    {
        /* there is output buffer */
        if (DataBufferSize >= FirstPin->ConnectionFormat->FormatSize)
        {
            /* copy dataformat */
            RtlMoveMemory(Data, FirstPin->ConnectionFormat, FirstPin->ConnectionFormat->FormatSize);

            /* store output length */
            *DataSize = FirstPin->ConnectionFormat->FormatSize;

            Status = STATUS_SUCCESS;
        }
        else
        {
            /* buffer too small */
            Status = STATUS_BUFFER_TOO_SMALL;
        }
    }
    else
    {
        /* store output length */
        *DataSize = FirstPin->ConnectionFormat->FormatSize;

        Status = STATUS_BUFFER_OVERFLOW;
    }

    /* done */
    return Status;
}

PinReset()

VOID NTAPI PinReset

(

IN PKSPIN

Pin

)

Definition at line 76 of file pin.c.

{
    PKSFILTER Filter;

    /* sanity check */
    ASSERT(Pin->Context);

    /* clear pin context */
    RtlZeroMemory(Pin->Context, sizeof(PIN_CONTEXT));

    /* get parent filter */
    Filter = KsPinGetParentFilter(Pin);

    /* sanity check */
    ASSERT(Filter);

    /* attempt processing */
    KsFilterAttemptProcessing(Filter, TRUE);
}

PinState()

NTSTATUS NTAPI PinState	(	IN PKSPIN	Pin,
		IN KSSTATE	ToState,
		IN KSSTATE	FromState
	)

Definition at line 99 of file pin.c.

{
    PKSFILTER Filter;

    /* should the pin stop */
    if (ToState == KSSTATE_STOP)
    {
        /* clear pin context */
        RtlZeroMemory(Pin->Context, sizeof(PIN_CONTEXT));
    }

    /* get parent filter */
    Filter = KsPinGetParentFilter(Pin);

    /* sanity check */
    ASSERT(Filter);

    /* attempt processing */
    KsFilterAttemptProcessing(Filter, TRUE);

    return STATUS_SUCCESS;
}