[12/18] winecoreaudio: Add widHelper_NotifyCompletions.

[Ken Thomases]

It scans for completed input wavehdrs, removes them from the queue, and
notifies the application that they're done.
---
  dlls/winmm/winecoreaudio/audio.c |   50 ++++++++++++++++++++++++++++++++++++++
  1 files changed, 50 insertions(+), 0 deletions(-)
-------------- next part --------------
diff --git a/dlls/winmm/winecoreaudio/audio.c b/dlls/winmm/winecoreaudio/audio.c
index 7d9aa38..ab9163f 100644
--- a/dlls/winmm/winecoreaudio/audio.c
+++ b/dlls/winmm/winecoreaudio/audio.c
@@ -202,6 +202,7 @@ static CFMessagePortRef Port_SendToMessa
 
 static void wodHelper_PlayPtrNext(WINE_WAVEOUT* wwo);
 static void wodHelper_NotifyCompletions(WINE_WAVEOUT* wwo, BOOL force);
+static void widHelper_NotifyCompletions(WINE_WAVEIN* wwi);
 
 extern int AudioUnit_CreateDefaultAudioUnit(void *wwo, AudioUnit *au);
 extern int AudioUnit_CloseAudioUnit(AudioUnit au);
@@ -1504,6 +1505,55 @@ static DWORD widNotifyClient(WINE_WAVEIN
 
 
 /**************************************************************************
+ *                      widHelper_NotifyCompletions              [internal]
+ */
+static void widHelper_NotifyCompletions(WINE_WAVEIN* wwi)
+{
+    LPWAVEHDR       lpWaveHdr;
+    LPWAVEHDR       lpFirstDoneWaveHdr = NULL;
+    LPWAVEHDR       lpLastDoneWaveHdr = NULL;
+
+    OSSpinLockLock(&wwi->lock);
+
+    /* First, excise all of the done headers from the queue into
+     * a free-standing list. */
+
+    /* Start from lpQueuePtr and keep notifying until:
+        * - we hit an unfilled wavehdr
+        * - we hit the end of the list
+        */
+    for (
+        lpWaveHdr = wwi->lpQueuePtr;
+        lpWaveHdr &&
+            lpWaveHdr->dwBytesRecorded >= lpWaveHdr->dwBufferLength;
+        lpWaveHdr = lpWaveHdr->lpNext
+        )
+    {
+        if (!lpFirstDoneWaveHdr)
+            lpFirstDoneWaveHdr = lpWaveHdr;
+        lpLastDoneWaveHdr = lpWaveHdr;
+    }
+
+    if (lpLastDoneWaveHdr)
+    {
+        wwi->lpQueuePtr = lpLastDoneWaveHdr->lpNext;
+        lpLastDoneWaveHdr->lpNext = NULL;
+    }
+
+    OSSpinLockUnlock(&wwi->lock);
+
+    /* Now, send the "done" notification for each header in our list. */
+    for (lpWaveHdr = lpFirstDoneWaveHdr; lpWaveHdr; lpWaveHdr = lpWaveHdr->lpNext)
+    {
+        lpWaveHdr->dwFlags &= ~WHDR_INQUEUE;
+        lpWaveHdr->dwFlags |= WHDR_DONE;
+
+        widNotifyClient(wwi, WIM_DATA, (DWORD)lpWaveHdr, 0);
+    }
+}
+
+
+/**************************************************************************
  *                      widGetDevCaps                           [internal]
  */
 static DWORD widGetDevCaps(WORD wDevID, LPWAVEINCAPSW lpCaps, DWORD dwSize)