[PATCH v4 4/7] sapi: Implement ISpVoice::Speak SPF_PURGEBEFORESPEAK.

[Shaun Ren]

From: Shaun Ren

Also introduce an async task queue.
---
 dlls/sapi/tests/tts.c |  9 +++++++++
 dlls/sapi/tts.c       | 38 ++++++++++++++++++++++++++++++++++++--
 2 files changed, 45 insertions(+), 2 deletions(-)

diff --git a/dlls/sapi/tests/tts.c b/dlls/sapi/tests/tts.c
index 534e5842f39..586869aa33e 100644
--- a/dlls/sapi/tests/tts.c
+++ b/dlls/sapi/tests/tts.c
@@ -102,6 +102,7 @@ static void test_spvoice(void)
     WCHAR *token_id = NULL, *default_token_id = NULL;
     LONG rate;
     USHORT volume;
+    ULONG stream_num;
     HRESULT hr;

if (waveOutGetNumDevs() == 0) {
@@ -204,6 +205,14 @@ static void test_spvoice(void)
     hr = ISpVoice_SetVolume(voice, 101);
     ok(hr == E_INVALIDARG, "got %#lx.\n", hr);

+    hr = ISpVoice_Speak(voice, NULL, SPF_PURGEBEFORESPEAK, NULL);
+    ok(hr == S_OK, "got %#lx.\n", hr);
+
+    stream_num = 0xdeadbeef;
+    hr = ISpVoice_Speak(voice, NULL, SPF_PURGEBEFORESPEAK, &stream_num);
+    ok(hr == S_OK, "got %#lx.\n", hr);
+    ok(stream_num == 0xdeadbeef, "got %lu.\n", stream_num);
+
     ISpVoice_Release(voice);
     ISpMMSysAudio_Release(audio_out);
 }
diff --git a/dlls/sapi/tts.c b/dlls/sapi/tts.c
index b0b3bbd2eff..fda3f08d0da 100644
--- a/dlls/sapi/tts.c
+++ b/dlls/sapi/tts.c
@@ -45,6 +45,7 @@ struct speech_voice
     ISpTTSEngine *engine;
     USHORT volume;
     LONG rate;
+    struct async_queue queue;
     CRITICAL_SECTION cs;
 };

@@ -143,6 +144,7 @@ static ULONG WINAPI speech_voice_Release(ISpeechVoice *iface)

if (!ref)
     {
+        async_cancel_queue(&This->queue);
         if (This->output) ISpStreamFormat_Release(This->output);
         if (This->engine) ISpTTSEngine_Release(This->engine);
         DeleteCriticalSection(&This->cs);
@@ -697,9 +699,40 @@ static HRESULT WINAPI spvoice_GetVoice(ISpVoice *iface, ISpObjectToken **token)
     return hr;
 }

-static HRESULT WINAPI spvoice_Speak(ISpVoice *iface, const WCHAR *contents, DWORD flags, ULONG *number)
+static HRESULT WINAPI spvoice_Speak(ISpVoice *iface, const WCHAR *contents, DWORD flags, ULONG *stream_num_out)
 {
-    FIXME("(%p, %p, %#lx, %p): stub.\n", iface, contents, flags, number);
+    struct speech_voice *This = impl_from_ISpVoice(iface);
+    HRESULT hr;
+
+    FIXME("(%p, %p, %#lx, %p): semi-stub.\n", iface, contents, flags, stream_num_out);
+
+    if (flags & ~SPF_PURGEBEFORESPEAK)
+    {
+        FIXME("flags %#lx not implemented.\n", flags & ~SPF_PURGEBEFORESPEAK);
+        return E_NOTIMPL;
+    }
+
+    if (flags & SPF_PURGEBEFORESPEAK)
+    {
+        ISpAudio *audio;
+
+        EnterCriticalSection(&This->cs);
+
+        if (This->output && SUCCEEDED(ISpStreamFormat_QueryInterface(This->output, &IID_ISpAudio, (void **)&audio)))
+        {
+            ISpAudio_SetState(audio, SPAS_CLOSED, 0);
+            ISpAudio_Release(audio);
+        }
+
+        LeaveCriticalSection(&This->cs);
+
+        async_empty_queue(&This->queue);
+
+        if (!contents || !*contents)
+            return S_OK;
+    }
+    else if (!contents)
+        return E_POINTER;

return E_NOTIMPL;
 }
@@ -962,6 +995,7 @@ HRESULT speech_voice_create(IUnknown *outer, REFIID iid, void **obj)
     This->engine = NULL;
     This->volume = 100;
     This->rate = 0;
+    memset(&This->queue, 0, sizeof(This->queue));

InitializeCriticalSection(&This->cs);