Shaun Ren : sapi: Implement ISpVoice::Speak SPF_PURGEBEFORESPEAK.

[Alexandre Julliard]

Module: wine
Branch: master
Commit: f9dff8a6fa759cd1a2d9f32dcafe9588e80a5469
URL:    https://gitlab.winehq.org/wine/wine/-/commit/f9dff8a6fa759cd1a2d9f32dcafe958...

Author: Shaun Ren <sren(a)codeweavers.com>
Date:   Wed Jul 19 12:57:49 2023 -0400

sapi: Implement ISpVoice::Speak SPF_PURGEBEFORESPEAK.

Also introduce an async task queue.

---

 dlls/sapi/tests/tts.c |  9 +++++++++
 dlls/sapi/tts.c       | 37 +++++++++++++++++++++++++++++++++++--
 2 files changed, 44 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..98d74a11f2d 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,39 @@ 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);
+
+    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 +994,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);