ReactOS 0.4.15-dev-7704-gc07eb9f
notify.c
Go to the documentation of this file.
1/*
2 * COPYRIGHT: See COPYING in the top level directory
3 * PROJECT: ReactOS Configuration of network devices
4 * FILE: dll/directx/dsound_new/notify.c
5 * PURPOSE: IDirectSoundNotify implementation
6 *
7 * PROGRAMMERS: Johannes Anderwald (johannes.anderwald@reactos.org)
8 */
9
10
11#include "precomp.h"
12
13typedef struct tagNOTIFYEVENT
14{
19
20typedef struct
21{
22 IDirectSoundNotifyVtbl * lpVtbl;
24
30
32
33static
38{
39 ULONG ref;
41
42 /* increment reference count */
44
45 return ref;
46}
47
48static
53{
54 ULONG ref;
56
57 ref = InterlockedDecrement(&(This->ref));
58
59 if (!ref)
60 {
62 }
63
64 return ref;
65}
66
72 LPVOID* ppobj)
73{
75
76 /* check if the interface is supported */
77 if (IsEqualIID(riid, &IID_IDirectSoundNotify) || IsEqualIID(riid, &IID_IUnknown))
78 {
79 *ppobj = (LPVOID)&This->lpVtbl;
81 return S_OK;
82 }
83
84 return E_NOINTERFACE;
85}
86
91 DWORD dwPositionNotifies,
92 LPCDSBPOSITIONNOTIFY pcPositionNotifies)
93{
98
100
101 if (dwPositionNotifies > DSBNOTIFICATIONS_MAX)
102 {
103 /* invalid param */
104 return DSERR_INVALIDPARAM;
105 }
106
107 /* verify notification event handles */
108 for(Index = 0; Index < dwPositionNotifies; Index++)
109 {
110 ASSERT(pcPositionNotifies[Index].hEventNotify);
111 ASSERT(pcPositionNotifies[Index].dwOffset < This->BufferSize || pcPositionNotifies[Index].dwOffset != DSBPN_OFFSETSTOP);
112
113 if (pcPositionNotifies[Index].hEventNotify == NULL)
114 return DSERR_INVALIDPARAM;
115
116 if (pcPositionNotifies[Index].dwOffset > This->BufferSize && pcPositionNotifies[Index].dwOffset != DSBPN_OFFSETSTOP)
117 return DSERR_INVALIDPARAM;
118 }
119
120 /* allocate new array */
122 if (!Notify)
123 {
124 /* not enough memory */
125 return DSERR_OUTOFMEMORY;
126 }
127
128 /* allocate new array */
129 Notify->Notify = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, dwPositionNotifies * sizeof(LOOPEDSTREAMING_POSITION_EVENT_DATA));
130 if (!Notify->Notify)
131 {
132 /* not enough memory */
134 return DSERR_OUTOFMEMORY;
135 }
136
137 /* FIXME support non-looped streaming */
138 ASSERT(This->bLoop);
139
140 /* prepare request */
144
145 for(Index = 0; Index < dwPositionNotifies; Index++)
146 {
147 /* initialize event entries */
148 Notify->Notify[Index].Position = pcPositionNotifies[Index].dwOffset;
149 Notify->Notify[Index].KsEventData.EventHandle.Event = pcPositionNotifies[Index].hEventNotify;
150 Notify->Notify[Index].KsEventData.NotificationType = KSEVENTF_EVENT_HANDLE;
151
152 if (This->bMix == FALSE)
153 {
154 /* format is supported natively */
156
157 if (Result != ERROR_SUCCESS)
158 {
159 DPRINT1("Failed to enable event %p Position %u\n", pcPositionNotifies[Index].hEventNotify, pcPositionNotifies[Index].dwOffset);
160 }
161 }
162 }
163
164 /* enlarge notify count */
165 Notify->NotifyCount = dwPositionNotifies;
166
167 if (This->EventListHead)
168 {
169 Notify->lpNext = This->EventListHead;
170 }
171
172 /* insert at front */
173 (void)InterlockedExchangePointer((LPVOID*)&This->EventListHead, Notify);
174
175 return DS_OK;
176}
177
178static IDirectSoundNotifyVtbl vt_DirectSoundNotify =
179{
180 /* IUnknown methods */
184 /* IDirectSoundNotify */
186};
187
188
189VOID
192 DWORD OldPosition,
193 DWORD NewPosition)
194{
195 DWORD Index;
196 LPNOTIFYEVENT CurEventList;
197
199
200 CurEventList = This->EventListHead;
201
202 while(CurEventList)
203 {
204 for(Index = 0; Index < CurEventList->NotifyCount; Index++)
205 {
206 if (NewPosition > OldPosition)
207 {
208 /* buffer progress no overlap */
209 if (OldPosition < CurEventList->Notify[Index].Position && CurEventList->Notify[Index].Position <= NewPosition)
210 {
211 /* process event */
212 SetEvent(CurEventList->Notify[Index].KsEventData.EventHandle.Event);
213 }
214 }
215 else
216 {
217 /* buffer wrap-arround */
218 if (OldPosition < CurEventList->Notify[Index].Position || NewPosition > CurEventList->Notify[Index].Position)
219 {
220 /* process event */
221 SetEvent(CurEventList->Notify[Index].KsEventData.EventHandle.Event);
222 }
223 }
224 }
225
226 /* iterate to next event list */
227 CurEventList = CurEventList->lpNext;
228 }
229}
230
234 BOOL bLoop,
235 BOOL bMix,
236 HANDLE hPin,
238{
240
241 if (!This)
242 return DSERR_OUTOFMEMORY;
243
244 This->lpVtbl = &vt_DirectSoundNotify;
245 This->bLoop = bLoop;
246 This->bMix = bMix;
247 This->hPin = hPin;
248 This->ref = 1;
249 This->EventListHead = NULL;
250 This->BufferSize = BufferSize;
251
252 *Notify = (LPDIRECTSOUNDNOTIFY)&This->lpVtbl;
253 return DS_OK;
254
255}
#define InterlockedIncrement
Definition: armddk.h:53
#define InterlockedDecrement
Definition: armddk.h:52
#define DPRINT1
Definition: precomp.h:8
const GUID IID_IUnknown
#define BufferSize
Definition: mmc.h:75
#define ERROR_SUCCESS
Definition: deptool.c:10
#define NULL
Definition: types.h:112
#define FALSE
Definition: types.h:117
BOOL WINAPI SHIM_OBJ_NAME() Notify(DWORD fdwReason, PVOID ptr)
DWORD SyncOverlappedDeviceIoControl(IN HANDLE Handle, IN DWORD IoControlCode, IN LPVOID InBuffer, IN DWORD InBufferSize, OUT LPVOID OutBuffer, IN DWORD OutBufferSize, OUT LPDWORD BytesTransferred OPTIONAL)
Definition: misc.c:298
static ULONG WINAPI IDirectSoundNotify_fnRelease(LPDIRECTSOUNDNOTIFY iface)
Definition: notify.c:51
struct CDirectSoundNotifyImpl * LPCDirectSoundNotifyImpl
static IDirectSoundNotifyVtbl vt_DirectSoundNotify
Definition: notify.c:178
struct tagNOTIFYEVENT NOTIFYEVENT
VOID DoNotifyPositionEvents(LPDIRECTSOUNDNOTIFY iface, DWORD OldPosition, DWORD NewPosition)
Definition: notify.c:190
static ULONG WINAPI IDirectSoundNotify_fnAddRef(LPDIRECTSOUNDNOTIFY iface)
Definition: notify.c:36
HRESULT WINAPI IDirectSoundNotify_fnSetNotificationPositions(LPDIRECTSOUNDNOTIFY iface, DWORD dwPositionNotifies, LPCDSBPOSITIONNOTIFY pcPositionNotifies)
Definition: notify.c:89
struct tagNOTIFYEVENT * LPNOTIFYEVENT
HRESULT WINAPI IDirectSoundNotify_fnQueryInterface(LPDIRECTSOUNDNOTIFY iface, IN REFIID riid, LPVOID *ppobj)
Definition: notify.c:69
HRESULT NewDirectSoundNotify(LPDIRECTSOUNDNOTIFY *Notify, BOOL bLoop, BOOL bMix, HANDLE hPin, DWORD BufferSize)
Definition: notify.c:232
#define GetProcessHeap()
Definition: compat.h:736
#define HeapAlloc
Definition: compat.h:733
#define HeapFree(x, y, z)
Definition: compat.h:735
#define HEAP_ZERO_MEMORY
Definition: compat.h:134
#define InterlockedExchangePointer(Target, Value)
Definition: dshow.h:45
#define DSBNOTIFICATIONS_MAX
Definition: dsound.h:235
#define DSERR_OUTOFMEMORY
Definition: dsound.h:125
#define DSBPN_OFFSETSTOP
Definition: dsound.h:876
#define DS_OK
Definition: dsound.h:116
#define DSERR_INVALIDPARAM
Definition: dsound.h:121
struct IDirectSoundNotify * LPDIRECTSOUNDNOTIFY
Definition: dsound.h:82
unsigned int BOOL
Definition: ntddk_ex.h:94
unsigned long DWORD
Definition: ntddk_ex.h:95
REFIID riid
Definition: atlbase.h:39
#define S_OK
Definition: intsafe.h:52
#define KSEVENTF_EVENT_HANDLE
Definition: ks.h:1778
#define KSEVENT_TYPE_ENABLE
Definition: ks.h:1789
#define IOCTL_KS_ENABLE_EVENT
Definition: ks.h:130
#define KSEVENTSETID_LoopedStreaming
Definition: ksmedia.h:1127
@ KSEVENT_LOOPEDSTREAMING_POSITION
Definition: ksmedia.h:1130
#define ASSERT(a)
Definition: mode.c:44
#define LPVOID
Definition: nt_native.h:45
_In_ DWORD _In_ DWORD dwOffset
Definition: ntgdi.h:2033
long LONG
Definition: pedump.c:60
#define IsEqualIID(riid1, riid2)
Definition: guiddef.h:95
#define REFIID
Definition: guiddef.h:118
LPNOTIFYEVENT EventListHead
Definition: notify.c:25
IDirectSoundNotifyVtbl * lpVtbl
Definition: notify.c:22
struct KSEVENTDATA::@3018::@3020 EventHandle
HANDLE hEventNotify
Definition: dsound.h:300
Definition: send.c:48
PLOOPEDSTREAMING_POSITION_EVENT_DATA Notify
Definition: notify.c:16
DWORD NotifyCount
Definition: notify.c:15
struct tagNOTIFYEVENT * lpNext
Definition: notify.c:17
static COORD Position
Definition: mouse.c:34
BOOL WINAPI DECLSPEC_HOTPATCH SetEvent(IN HANDLE hEvent)
Definition: synch.c:733
#define IN
Definition: typedefs.h:39
#define CONTAINING_RECORD(address, type, field)
Definition: typedefs.h:260
uint32_t ULONG
Definition: typedefs.h:59
_In_ WDFCOLLECTION _In_ ULONG Index
_In_ WDFREQUEST Request
Definition: wdfdevice.h:547
_In_ WDFMEMORY _Out_opt_ size_t * BufferSize
Definition: wdfmemory.h:254
#define WINAPI
Definition: msvc.h:6
#define E_NOINTERFACE
Definition: winerror.h:2364
_At_(*)(_In_ PWSK_CLIENT Client, _In_opt_ PUNICODE_STRING NodeName, _In_opt_ PUNICODE_STRING ServiceName, _In_opt_ ULONG NameSpace, _In_opt_ GUID *Provider, _In_opt_ PADDRINFOEXW Hints, _Outptr_ PADDRINFOEXW *Result, _In_opt_ PEPROCESS OwningProcess, _In_opt_ PETHREAD OwningThread, _Inout_ PIRP Irp Result)(Mem)) NTSTATUS(WSKAPI *PFN_WSK_GET_ADDRESS_INFO
Definition: wsk.h:409