dlls/mfplat/queue.c

   1 /*
   2  * Copyright 2019 Nikolay Sivov for CodeWeavers
   3  *
   4  * This library is free software; you can redistribute it and/or
   5  * modify it under the terms of the GNU Lesser General Public
   6  * License as published by the Free Software Foundation; either
   7  * version 2.1 of the License, or (at your option) any later version.
   8  *
   9  * This library is distributed in the hope that it will be useful,
  10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12  * Lesser General Public License for more details.
  13  *
  14  * You should have received a copy of the GNU Lesser General Public
  15  * License along with this library; if not, write to the Free Software
  16  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
  17  */
  18
  19 #include <stdarg.h>
  20
  21 #define COBJMACROS
  22 #define NONAMELESSUNION
  23
  24 #include "wine/debug.h"
  25 #include "wine/list.h"
  26
  27 #include "mfplat_private.h"
  28 #include "rtworkq.h"
  29
  30 WINE_DEFAULT_DEBUG_CHANNEL(mfplat);
  31
  32 /***********************************************************************
  33  *      MFAllocateWorkQueue (mfplat.@)
  34  */
  35 HRESULT WINAPI MFAllocateWorkQueue(DWORD *queue)
  36 {
  37     TRACE("%p.\n", queue);
  38
  39     return RtwqAllocateWorkQueue(RTWQ_STANDARD_WORKQUEUE, queue);
  40 }
  41
  42 /***********************************************************************
  43  *      MFPutWorkItem (mfplat.@)
  44  */
  45 HRESULT WINAPI MFPutWorkItem(DWORD queue, IMFAsyncCallback *callback, IUnknown *state)
  46 {
  47     IRtwqAsyncResult *result;
  48     HRESULT hr;
  49
  50     TRACE("%#x, %p, %p.\n", queue, callback, state);
  51
  52     if (FAILED(hr = RtwqCreateAsyncResult(NULL, (IRtwqAsyncCallback *)callback, state, &result)))
  53         return hr;
  54
  55     hr = RtwqPutWorkItem(queue, 0, result);
  56
  57     IRtwqAsyncResult_Release(result);
  58
  59     return hr;
  60 }
  61
  62 /***********************************************************************
  63  *      MFPutWorkItem2 (mfplat.@)
  64  */
  65 HRESULT WINAPI MFPutWorkItem2(DWORD queue, LONG priority, IMFAsyncCallback *callback, IUnknown *state)
  66 {
  67     IRtwqAsyncResult *result;
  68     HRESULT hr;
  69
  70     TRACE("%#x, %d, %p, %p.\n", queue, priority, callback, state);
  71
  72     if (FAILED(hr = RtwqCreateAsyncResult(NULL, (IRtwqAsyncCallback *)callback, state, &result)))
  73         return hr;
  74
  75     hr = RtwqPutWorkItem(queue, priority, result);
  76
  77     IRtwqAsyncResult_Release(result);
  78
  79     return hr;
  80 }
  81
  82 /***********************************************************************
  83  *      MFPutWorkItemEx (mfplat.@)
  84  */
  85 HRESULT WINAPI MFPutWorkItemEx(DWORD queue, IMFAsyncResult *result)
  86 {
  87     TRACE("%#x, %p\n", queue, result);
  88
  89     return RtwqPutWorkItem(queue, 0, (IRtwqAsyncResult *)result);
  90 }
  91
  92 /***********************************************************************
  93  *      MFPutWorkItemEx2 (mfplat.@)
  94  */
  95 HRESULT WINAPI MFPutWorkItemEx2(DWORD queue, LONG priority, IMFAsyncResult *result)
  96 {
  97     TRACE("%#x, %d, %p\n", queue, priority, result);
  98
  99     return RtwqPutWorkItem(queue, priority, (IRtwqAsyncResult *)result);
 100 }
 101
 102 /***********************************************************************
 103  *      MFScheduleWorkItem (mfplat.@)
 104  */
 105 HRESULT WINAPI MFScheduleWorkItem(IMFAsyncCallback *callback, IUnknown *state, INT64 timeout, MFWORKITEM_KEY *key)
 106 {
 107     IRtwqAsyncResult *result;
 108     HRESULT hr;
 109
 110     TRACE("%p, %p, %s, %p.\n", callback, state, wine_dbgstr_longlong(timeout), key);
 111
 112     if (FAILED(hr = RtwqCreateAsyncResult(NULL, (IRtwqAsyncCallback *)callback, state, &result)))
 113         return hr;
 114
 115     hr = RtwqScheduleWorkItem(result, timeout, key);
 116
 117     IRtwqAsyncResult_Release(result);
 118
 119     return hr;
 120 }
 121
 122 /***********************************************************************
 123  *      MFInvokeCallback (mfplat.@)
 124  */
 125 HRESULT WINAPI MFInvokeCallback(IMFAsyncResult *result)
 126 {
 127     TRACE("%p.\n", result);
 128
 129     return RtwqInvokeCallback((IRtwqAsyncResult *)result);
 130 }
 131
 132 /***********************************************************************
 133  *      MFGetTimerPeriodicity (mfplat.@)
 134  */
 135 HRESULT WINAPI MFGetTimerPeriodicity(DWORD *period)
 136 {
 137     TRACE("%p.\n", period);
 138
 139     *period = 10;
 140
 141     return S_OK;
 142 }
 143
 144 /***********************************************************************
 145  *      MFBeginRegisterWorkQueueWithMMCSS (mfplat.@)
 146  */
 147 HRESULT WINAPI MFBeginRegisterWorkQueueWithMMCSS(DWORD queue, const WCHAR *usage_class, DWORD taskid,
 148         IMFAsyncCallback *callback, IUnknown *state)
 149 {
 150     return RtwqBeginRegisterWorkQueueWithMMCSS(queue, usage_class, taskid, 0,
 151             (IRtwqAsyncCallback *)callback, state);
 152 }