Module: wine Branch: master Commit: b600c85dae420b36695a02327b45e87747873842 URL: https://gitlab.winehq.org/wine/wine/-/commit/b600c85dae420b36695a02327b45e87... Author: Rémi Bernon <rbernon(a)codeweavers.com> Date: Mon Aug 22 19:19:38 2022 +0200 winegstreamer: Move open_stream / close_stream helpers around. --- dlls/winegstreamer/wm_asyncreader.c | 46 ++++++++++++++++++------------------- 1 file changed, 23 insertions(+), 23 deletions(-) diff --git a/dlls/winegstreamer/wm_asyncreader.c b/dlls/winegstreamer/wm_asyncreader.c index 1be7e493f99..bd7e58713f4 100644 --- a/dlls/winegstreamer/wm_asyncreader.c +++ b/dlls/winegstreamer/wm_asyncreader.c @@ -247,25 +247,7 @@ static DWORD WINAPI async_reader_callback_thread(void *arg) return 0; } -static HRESULT open_stream(struct async_reader *reader, IWMReaderCallback *callback, void *context) -{ - IWMReaderCallback_AddRef((reader->callback = callback)); - reader->context = context; - - reader->running = true; - if (!(reader->callback_thread = CreateThread(NULL, 0, async_reader_callback_thread, reader, 0, NULL))) - { - IWMReaderCallback_Release(reader->callback); - reader->running = false; - reader->callback = NULL; - reader->context = NULL; - return E_OUTOFMEMORY; - } - - return S_OK; -} - -static void close_stream(struct async_reader *reader) +static void async_reader_close(struct async_reader *reader) { struct async_op *op, *next; @@ -283,6 +265,24 @@ static void close_stream(struct async_reader *reader) } } +static HRESULT async_reader_open(struct async_reader *reader, IWMReaderCallback *callback, void *context) +{ + IWMReaderCallback_AddRef((reader->callback = callback)); + reader->context = context; + + reader->running = true; + if (!(reader->callback_thread = CreateThread(NULL, 0, async_reader_callback_thread, reader, 0, NULL))) + { + IWMReaderCallback_Release(reader->callback); + reader->running = false; + reader->callback = NULL; + reader->context = NULL; + return E_OUTOFMEMORY; + } + + return S_OK; +} + static HRESULT async_reader_queue_op(struct async_reader *reader, enum async_op_type type, void *context) { struct async_op *op; @@ -345,7 +345,7 @@ static HRESULT WINAPI WMReader_Open(IWMReader *iface, const WCHAR *url, } if (SUCCEEDED(hr = wm_reader_open_file(&reader->reader, url)) - && FAILED(hr = open_stream(reader, callback, context))) + && FAILED(hr = async_reader_open(reader, callback, context))) wm_reader_close(&reader->reader); LeaveCriticalSection(&reader->reader.cs); @@ -362,7 +362,7 @@ static HRESULT WINAPI WMReader_Close(IWMReader *iface) EnterCriticalSection(&reader->reader.cs); async_reader_queue_op(reader, ASYNC_OP_CLOSE, NULL); - close_stream(reader); + async_reader_close(reader); hr = wm_reader_close(&reader->reader); if (reader->callback) @@ -825,7 +825,7 @@ static HRESULT WINAPI WMReaderAdvanced2_OpenStream(IWMReaderAdvanced6 *iface, } if (SUCCEEDED(hr = wm_reader_open_stream(&reader->reader, stream)) - && FAILED(hr = open_stream(reader, callback, context))) + && FAILED(hr = async_reader_open(reader, callback, context))) wm_reader_close(&reader->reader); LeaveCriticalSection(&reader->reader.cs); @@ -1686,7 +1686,7 @@ static void async_reader_destroy(struct wm_reader *iface) LeaveCriticalSection(&reader->callback_cs); WakeConditionVariable(&reader->callback_cv); - close_stream(reader); + async_reader_close(reader); reader->callback_cs.DebugInfo->Spare[0] = 0; DeleteCriticalSection(&reader->callback_cs);