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 #define COBJMACROS
  20
  21 #include "mfplat_private.h"
  22 #include "rtworkq.h"
  23
  24 WINE_DEFAULT_DEBUG_CHANNEL(mfplat);
  25
  26 /***********************************************************************
  27  *      MFAllocateWorkQueue (mfplat.@)
  28  */
  29 HRESULT WINAPI MFAllocateWorkQueue(DWORD *queue)
  30 {
  31     TRACE("%p.\n", queue);
  32
  33     return RtwqAllocateWorkQueue(RTWQ_STANDARD_WORKQUEUE, queue);
  34 }
  35
  36 /***********************************************************************
  37  *      MFPutWorkItem (mfplat.@)
  38  */
  39 HRESULT WINAPI MFPutWorkItem(DWORD queue, IMFAsyncCallback *callback, IUnknown *state)
  40 {
  41     IRtwqAsyncResult *result;
  42     HRESULT hr;
  43
  44     TRACE("%#lx, %p, %p.\n", queue, callback, state);
  45
  46     if (FAILED(hr = RtwqCreateAsyncResult(NULL, (IRtwqAsyncCallback *)callback, state, &result)))
  47         return hr;
  48
  49     hr = RtwqPutWorkItem(queue, 0, result);
  50
  51     IRtwqAsyncResult_Release(result);
  52
  53     return hr;
  54 }
  55
  56 /***********************************************************************
  57  *      MFPutWorkItem2 (mfplat.@)
  58  */
  59 HRESULT WINAPI MFPutWorkItem2(DWORD queue, LONG priority, IMFAsyncCallback *callback, IUnknown *state)
  60 {
  61     IRtwqAsyncResult *result;
  62     HRESULT hr;
  63
  64     TRACE("%#lx, %ld, %p, %p.\n", queue, priority, callback, state);
  65
  66     if (FAILED(hr = RtwqCreateAsyncResult(NULL, (IRtwqAsyncCallback *)callback, state, &result)))
  67         return hr;
  68
  69     hr = RtwqPutWorkItem(queue, priority, result);
  70
  71     IRtwqAsyncResult_Release(result);
  72
  73     return hr;
  74 }
  75
  76 /***********************************************************************
  77  *      MFPutWorkItemEx (mfplat.@)
  78  */
  79 HRESULT WINAPI MFPutWorkItemEx(DWORD queue, IMFAsyncResult *result)
  80 {
  81     TRACE("%#lx, %p\n", queue, result);
  82
  83     return RtwqPutWorkItem(queue, 0, (IRtwqAsyncResult *)result);
  84 }
  85
  86 /***********************************************************************
  87  *      MFPutWorkItemEx2 (mfplat.@)
  88  */
  89 HRESULT WINAPI MFPutWorkItemEx2(DWORD queue, LONG priority, IMFAsyncResult *result)
  90 {
  91     TRACE("%#lx, %ld, %p\n", queue, priority, result);
  92
  93     return RtwqPutWorkItem(queue, priority, (IRtwqAsyncResult *)result);
  94 }
  95
  96 /***********************************************************************
  97  *      MFScheduleWorkItem (mfplat.@)
  98  */
  99 HRESULT WINAPI MFScheduleWorkItem(IMFAsyncCallback *callback, IUnknown *state, INT64 timeout, MFWORKITEM_KEY *key)
 100 {
 101     IRtwqAsyncResult *result;
 102     HRESULT hr;
 103
 104     TRACE("%p, %p, %s, %p.\n", callback, state, wine_dbgstr_longlong(timeout), key);
 105
 106     if (FAILED(hr = RtwqCreateAsyncResult(NULL, (IRtwqAsyncCallback *)callback, state, &result)))
 107         return hr;
 108
 109     hr = RtwqScheduleWorkItem(result, timeout, key);
 110
 111     IRtwqAsyncResult_Release(result);
 112
 113     return hr;
 114 }
 115
 116 /***********************************************************************
 117  *      MFInvokeCallback (mfplat.@)
 118  */
 119 HRESULT WINAPI MFInvokeCallback(IMFAsyncResult *result)
 120 {
 121     TRACE("%p.\n", result);
 122
 123     return RtwqInvokeCallback((IRtwqAsyncResult *)result);
 124 }
 125
 126 /***********************************************************************
 127  *      MFGetTimerPeriodicity (mfplat.@)
 128  */
 129 HRESULT WINAPI MFGetTimerPeriodicity(DWORD *period)
 130 {
 131     TRACE("%p.\n", period);
 132
 133     *period = 10;
 134
 135     return S_OK;
 136 }
 137
 138 /***********************************************************************
 139  *      MFBeginRegisterWorkQueueWithMMCSS (mfplat.@)
 140  */
 141 HRESULT WINAPI MFBeginRegisterWorkQueueWithMMCSS(DWORD queue, const WCHAR *usage_class, DWORD taskid,
 142         IMFAsyncCallback *callback, IUnknown *state)
 143 {
 144     return RtwqBeginRegisterWorkQueueWithMMCSS(queue, usage_class, taskid, 0,
 145             (IRtwqAsyncCallback *)callback, state);
 146 }