notify.c File Reference

#include "precomp.h"

Include dependency graph for notify.c:

Go to the source code of this file.

Classes
struct	tagNOTIFYEVENT
struct	CDirectSoundNotifyImpl

Typedefs
typedef struct tagNOTIFYEVENT	NOTIFYEVENT
typedef struct tagNOTIFYEVENT *	LPNOTIFYEVENT
typedef struct CDirectSoundNotifyImpl *	LPCDirectSoundNotifyImpl

Functions
static ULONG WINAPI	IDirectSoundNotify_fnAddRef (LPDIRECTSOUNDNOTIFY iface)
static ULONG WINAPI	IDirectSoundNotify_fnRelease (LPDIRECTSOUNDNOTIFY iface)
HRESULT WINAPI	IDirectSoundNotify_fnQueryInterface (LPDIRECTSOUNDNOTIFY iface, IN REFIID riid, LPVOID *ppobj)
HRESULT WINAPI	IDirectSoundNotify_fnSetNotificationPositions (LPDIRECTSOUNDNOTIFY iface, DWORD dwPositionNotifies, LPCDSBPOSITIONNOTIFY pcPositionNotifies)
VOID	DoNotifyPositionEvents (LPDIRECTSOUNDNOTIFY iface, DWORD OldPosition, DWORD NewPosition)
HRESULT	NewDirectSoundNotify (LPDIRECTSOUNDNOTIFY *Notify, BOOL bLoop, BOOL bMix, HANDLE hPin, DWORD BufferSize)

Variables
static IDirectSoundNotifyVtbl	vt_DirectSoundNotify

Typedef Documentation

LPCDirectSoundNotifyImpl

typedef struct CDirectSoundNotifyImpl * LPCDirectSoundNotifyImpl

LPNOTIFYEVENT

typedef struct tagNOTIFYEVENT * LPNOTIFYEVENT

NOTIFYEVENT

typedef struct tagNOTIFYEVENT NOTIFYEVENT

Function Documentation

DoNotifyPositionEvents()

VOID DoNotifyPositionEvents	(	LPDIRECTSOUNDNOTIFY	iface,
		DWORD	OldPosition,
		DWORD	NewPosition
	)

Definition at line 190 of file notify.c.

{
    DWORD Index;
    LPNOTIFYEVENT CurEventList;

    LPCDirectSoundNotifyImpl This = (LPCDirectSoundNotifyImpl)CONTAINING_RECORD(iface, CDirectSoundNotifyImpl, lpVtbl);

    CurEventList = This->EventListHead;

    while(CurEventList)
    {
        for(Index = 0; Index < CurEventList->NotifyCount; Index++)
        {
            if (NewPosition > OldPosition)
            {
                /* buffer progress no overlap */
                if (OldPosition < CurEventList->Notify[Index].Position && CurEventList->Notify[Index].Position <= NewPosition)
                {
                    /* process event */
                    SetEvent(CurEventList->Notify[Index].KsEventData.EventHandle.Event);
                }
            }
            else
            {
                /* buffer wrap-arround */
                if (OldPosition < CurEventList->Notify[Index].Position || NewPosition > CurEventList->Notify[Index].Position)
                {
                    /* process event */
                    SetEvent(CurEventList->Notify[Index].KsEventData.EventHandle.Event);
                }
            }
        }

        /* iterate to next event list */
        CurEventList = CurEventList->lpNext;
    }
}

Referenced by MixerThreadRoutine().

IDirectSoundNotify_fnAddRef()

static ULONG WINAPI IDirectSoundNotify_fnAddRef ( LPDIRECTSOUNDNOTIFY  iface )

static

Definition at line 36 of file notify.c.

{
    ULONG ref;
    LPCDirectSoundNotifyImpl This = (LPCDirectSoundNotifyImpl)CONTAINING_RECORD(iface, CDirectSoundNotifyImpl, lpVtbl);

    /* increment reference count */
    ref = InterlockedIncrement(&This->ref);

    return ref;
}

IDirectSoundNotify_fnQueryInterface()

HRESULT WINAPI IDirectSoundNotify_fnQueryInterface	(	LPDIRECTSOUNDNOTIFY	iface,
		IN REFIID	riid,
		LPVOID *	ppobj
	)

Definition at line 69 of file notify.c.

{
    LPCDirectSoundNotifyImpl This = (LPCDirectSoundNotifyImpl)CONTAINING_RECORD(iface, CDirectSoundNotifyImpl, lpVtbl);

    /* check if the interface is supported */
    if (IsEqualIID(riid, &IID_IDirectSoundNotify) || IsEqualIID(riid, &IID_IUnknown))
    {
        *ppobj = (LPVOID)&This->lpVtbl;
        InterlockedIncrement(&This->ref);
        return S_OK;
    }

    return E_NOINTERFACE;
}

IDirectSoundNotify_fnRelease()

static ULONG WINAPI IDirectSoundNotify_fnRelease ( LPDIRECTSOUNDNOTIFY  iface )

static

Definition at line 51 of file notify.c.

{
    ULONG ref;
    LPCDirectSoundNotifyImpl This = (LPCDirectSoundNotifyImpl)CONTAINING_RECORD(iface, CDirectSoundNotifyImpl, lpVtbl);

    ref = InterlockedDecrement(&(This->ref));

    if (!ref)
    {
        HeapFree(GetProcessHeap(), 0, This);
    }

    return ref;
}

IDirectSoundNotify_fnSetNotificationPositions()

HRESULT WINAPI IDirectSoundNotify_fnSetNotificationPositions	(	LPDIRECTSOUNDNOTIFY	iface,
		DWORD	dwPositionNotifies,
		LPCDSBPOSITIONNOTIFY	pcPositionNotifies
	)

Definition at line 89 of file notify.c.

{
    DWORD Index;
    LPNOTIFYEVENT Notify;
    DWORD Result;
    KSEVENT Request;

    LPCDirectSoundNotifyImpl This = (LPCDirectSoundNotifyImpl)CONTAINING_RECORD(iface, CDirectSoundNotifyImpl, lpVtbl);

    if (dwPositionNotifies > DSBNOTIFICATIONS_MAX)
    {
        /* invalid param */
        return DSERR_INVALIDPARAM;
    }

    /* verify notification event handles */
    for(Index = 0; Index < dwPositionNotifies; Index++)
    {
        ASSERT(pcPositionNotifies[Index].hEventNotify);
        ASSERT(pcPositionNotifies[Index].dwOffset < This->BufferSize || pcPositionNotifies[Index].dwOffset != DSBPN_OFFSETSTOP);

        if (pcPositionNotifies[Index].hEventNotify == NULL)
            return DSERR_INVALIDPARAM;

        if (pcPositionNotifies[Index].dwOffset > This->BufferSize && pcPositionNotifies[Index].dwOffset != DSBPN_OFFSETSTOP)
            return DSERR_INVALIDPARAM;
    }

    /* allocate new array */
    Notify = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(NOTIFYEVENT));
    if (!Notify)
    {
        /* not enough memory */
        return DSERR_OUTOFMEMORY;
    }

    /* allocate new array */
    Notify->Notify = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, dwPositionNotifies * sizeof(LOOPEDSTREAMING_POSITION_EVENT_DATA));
    if (!Notify->Notify)
    {
        /* not enough memory */
        HeapFree(GetProcessHeap(), 0, Notify);
        return DSERR_OUTOFMEMORY;
    }

    /* FIXME support non-looped streaming */
    ASSERT(This->bLoop);

    /* prepare request */
    Request.Set = KSEVENTSETID_LoopedStreaming;
    Request.Id = KSEVENT_LOOPEDSTREAMING_POSITION;
    Request.Flags = KSEVENT_TYPE_ENABLE;

    for(Index = 0; Index < dwPositionNotifies; Index++)
    {
        /* initialize event entries */
        Notify->Notify[Index].Position = pcPositionNotifies[Index].dwOffset;
        Notify->Notify[Index].KsEventData.EventHandle.Event = pcPositionNotifies[Index].hEventNotify;
        Notify->Notify[Index].KsEventData.NotificationType = KSEVENTF_EVENT_HANDLE;

        if (This->bMix == FALSE)
        {
            /* format is supported natively */
            Result = SyncOverlappedDeviceIoControl(This->hPin, IOCTL_KS_ENABLE_EVENT, (PVOID)&Request, sizeof(KSEVENT), (PVOID)&Notify->Notify[Index], sizeof(LOOPEDSTREAMING_POSITION_EVENT_DATA), NULL);

            if (Result != ERROR_SUCCESS)
            {
                DPRINT1("Failed to enable event %p Position %u\n", pcPositionNotifies[Index].hEventNotify, pcPositionNotifies[Index].dwOffset);
            }
        }
    }

    /* enlarge notify count */
    Notify->NotifyCount = dwPositionNotifies;

    if (This->EventListHead)
    {
        Notify->lpNext = This->EventListHead;
    }

    /* insert at front */
    (void)InterlockedExchangePointer((LPVOID*)&This->EventListHead, Notify);

    return DS_OK;
}

NewDirectSoundNotify()

HRESULT NewDirectSoundNotify	(	LPDIRECTSOUNDNOTIFY *	Notify,
		BOOL	bLoop,
		BOOL	bMix,
		HANDLE	hPin,
		DWORD	BufferSize
	)

Definition at line 232 of file notify.c.

{
    LPCDirectSoundNotifyImpl This = HeapAlloc(GetProcessHeap(), 0, sizeof(CDirectSoundNotifyImpl));

    if (!This)
        return DSERR_OUTOFMEMORY;

    This->lpVtbl = &vt_DirectSoundNotify;
    This->bLoop = bLoop;
    This->bMix = bMix;
    This->hPin = hPin;
    This->ref = 1;
    This->EventListHead = NULL;
    This->BufferSize = BufferSize;

    *Notify = (LPDIRECTSOUNDNOTIFY)&This->lpVtbl;
    return DS_OK;

}

Referenced by IDirectSoundCaptureBufferImpl_QueryInterface().

Variable Documentation

vt_DirectSoundNotify

IDirectSoundNotifyVtbl vt_DirectSoundNotify

static

Initial value:

=
{
    
    IDirectSoundNotify_fnQueryInterface,
    IDirectSoundNotify_fnAddRef,
    IDirectSoundNotify_fnRelease,
    
    IDirectSoundNotify_fnSetNotificationPositions
}

Definition at line 178 of file notify.c.

Referenced by NewDirectSoundNotify().