threadpool.c File Reference

#include <stdarg.h>
#include "windef.h"
#include "winbase.h"
#include "wingdi.h"
#include "winuser.h"
#include "objbase.h"
#include "wine/debug.h"
#include "dpnet_private.h"

Include dependency graph for threadpool.c:

Go to the source code of this file.

Macros
#define	COBJMACROS

Functions
	WINE_DEFAULT_DEBUG_CHANNEL (dpnet)
static IDirectPlay8ThreadPoolImpl *	impl_from_IDirectPlay8ThreadPool (IDirectPlay8ThreadPool *iface)
static HRESULT WINAPI	IDirectPlay8ThreadPoolImpl_QueryInterface (IDirectPlay8ThreadPool *iface, REFIID riid, void **ret_iface)
static ULONG WINAPI	IDirectPlay8ThreadPoolImpl_AddRef (IDirectPlay8ThreadPool *iface)
static ULONG WINAPI	IDirectPlay8ThreadPoolImpl_Release (IDirectPlay8ThreadPool *iface)
static HRESULT WINAPI	IDirectPlay8ThreadPoolImpl_Initialize (IDirectPlay8ThreadPool *iface, void *const pvUserContext, const PFNDPNMESSAGEHANDLER pfn, const DWORD dwFlags)
static HRESULT WINAPI	IDirectPlay8ThreadPoolImpl_Close (IDirectPlay8ThreadPool *iface, const DWORD dwFlags)
static HRESULT WINAPI	IDirectPlay8ThreadPoolImpl_GetThreadCount (IDirectPlay8ThreadPool *iface, const DWORD dwProcessorNum, DWORD *const pdwNumThreads, const DWORD dwFlags)
static HRESULT WINAPI	IDirectPlay8ThreadPoolImpl_SetThreadCount (IDirectPlay8ThreadPool *iface, const DWORD dwProcessorNum, const DWORD dwNumThreads, const DWORD dwFlags)
static HRESULT WINAPI	IDirectPlay8ThreadPoolImpl_DoWork (IDirectPlay8ThreadPool *iface, const DWORD dwAllowedTimeSlice, const DWORD dwFlags)
HRESULT	DPNET_CreateDirectPlay8ThreadPool (LPCLASSFACTORY iface, LPUNKNOWN punkOuter, REFIID riid, LPVOID *ppobj)

Variables
static PFNDPNMESSAGEHANDLER	threadpool_msghandler = NULL
static DWORD	threadpool_flags = 0
static void *	threadpool_usercontext = NULL
static const IDirectPlay8ThreadPoolVtbl	DirectPlay8ThreadPool_Vtbl

Macro Definition Documentation

COBJMACROS

#define COBJMACROS

Definition at line 26 of file threadpool.c.

Function Documentation

DPNET_CreateDirectPlay8ThreadPool()

HRESULT DPNET_CreateDirectPlay8ThreadPool	(	LPCLASSFACTORY	iface,
		LPUNKNOWN	punkOuter,
		REFIID	riid,
		LPVOID *	ppobj
	)

Definition at line 157 of file threadpool.c.

{
    IDirectPlay8ThreadPoolImpl* Client;
 
    Client = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(IDirectPlay8ThreadPoolImpl));
 
    if(Client == NULL)
    {
        *ppobj = NULL;
        WARN("Not enough memory\n");
        return E_OUTOFMEMORY;
    }
 
    Client->IDirectPlay8ThreadPool_iface.lpVtbl = &DirectPlay8ThreadPool_Vtbl;
    Client->ref = 0;
 
    return IDirectPlay8ThreadPoolImpl_QueryInterface(&Client->IDirectPlay8ThreadPool_iface, riid,
            ppobj);
}

IDirectPlay8ThreadPoolImpl_AddRef()

static ULONG WINAPI IDirectPlay8ThreadPoolImpl_AddRef ( IDirectPlay8ThreadPool *  iface )

static

Definition at line 62 of file threadpool.c.

{
    IDirectPlay8ThreadPoolImpl* This = impl_from_IDirectPlay8ThreadPool(iface);
    ULONG RefCount = InterlockedIncrement(&This->ref);
 
    return RefCount;
}

IDirectPlay8ThreadPoolImpl_Close()

static HRESULT WINAPI IDirectPlay8ThreadPoolImpl_Close ( IDirectPlay8ThreadPool *  iface, const DWORD  dwFlags  )

static

Definition at line 102 of file threadpool.c.

{
    IDirectPlay8ThreadPoolImpl *This = impl_from_IDirectPlay8ThreadPool(iface);
 
    FIXME("(%p)->(%lx)\n", This, dwFlags);
 
    if(!threadpool_msghandler)
        return DPNERR_UNINITIALIZED;
 
    threadpool_msghandler = NULL;
 
    return DPN_OK;
}

IDirectPlay8ThreadPoolImpl_DoWork()

static HRESULT WINAPI IDirectPlay8ThreadPoolImpl_DoWork ( IDirectPlay8ThreadPool *  iface, const DWORD  dwAllowedTimeSlice, const DWORD  dwFlags  )

static

Definition at line 132 of file threadpool.c.

{
    static BOOL Run = FALSE;
 
    if(!Run)
        FIXME("(%p)->(%lx,%lx): stub\n", iface, dwAllowedTimeSlice, dwFlags);
 
    Run = TRUE;
 
    return DPN_OK;
}

IDirectPlay8ThreadPoolImpl_GetThreadCount()

static HRESULT WINAPI IDirectPlay8ThreadPoolImpl_GetThreadCount ( IDirectPlay8ThreadPool *  iface, const DWORD  dwProcessorNum, DWORD *const  pdwNumThreads, const DWORD  dwFlags  )

static

Definition at line 117 of file threadpool.c.

{
    FIXME("(%p)->(%lx,%p,%lx): stub\n", iface, dwProcessorNum, pdwNumThreads, dwFlags);
    *pdwNumThreads = 0;
    return DPN_OK;
}

IDirectPlay8ThreadPoolImpl_Initialize()

static HRESULT WINAPI IDirectPlay8ThreadPoolImpl_Initialize ( IDirectPlay8ThreadPool *  iface, void *const  pvUserContext, const PFNDPNMESSAGEHANDLER  pfn, const DWORD  dwFlags  )

static

Definition at line 82 of file threadpool.c.

{
    IDirectPlay8ThreadPoolImpl *This = impl_from_IDirectPlay8ThreadPool(iface);
 
    TRACE("(%p)->(%p,%p,%lx)\n", This, pvUserContext, pfn, dwFlags);
 
    if(!pfn)
        return DPNERR_INVALIDPARAM;
 
    if(threadpool_msghandler)
        return DPNERR_ALREADYINITIALIZED;
 
    threadpool_msghandler  = pfn;
    threadpool_flags       = dwFlags;
    threadpool_usercontext = pvUserContext;
 
    return DPN_OK;
}

IDirectPlay8ThreadPoolImpl_QueryInterface()

static HRESULT WINAPI IDirectPlay8ThreadPoolImpl_QueryInterface ( IDirectPlay8ThreadPool *  iface, REFIID  riid, void **  ret_iface  )

static

Definition at line 48 of file threadpool.c.

{
    if(IsEqualGUID(riid, &IID_IUnknown) || IsEqualGUID(riid, &IID_IDirectPlay8ThreadPool))
    {
        IDirectPlay8ThreadPool_AddRef(iface);
        *ret_iface = iface;
        return S_OK;
    }
 
    WARN("(%p)->(%s,%p): not found\n", iface, debugstr_guid(riid), ret_iface);
    return E_NOINTERFACE;
}

Referenced by DPNET_CreateDirectPlay8ThreadPool().

IDirectPlay8ThreadPoolImpl_Release()

static ULONG WINAPI IDirectPlay8ThreadPoolImpl_Release ( IDirectPlay8ThreadPool *  iface )

static

Definition at line 70 of file threadpool.c.

{
    IDirectPlay8ThreadPoolImpl* This = impl_from_IDirectPlay8ThreadPool(iface);
    ULONG RefCount = InterlockedDecrement(&This->ref);
 
    if(!RefCount)
        HeapFree(GetProcessHeap(), 0, This);
 
    return RefCount;
}

IDirectPlay8ThreadPoolImpl_SetThreadCount()

static HRESULT WINAPI IDirectPlay8ThreadPoolImpl_SetThreadCount ( IDirectPlay8ThreadPool *  iface, const DWORD  dwProcessorNum, const DWORD  dwNumThreads, const DWORD  dwFlags  )

static

Definition at line 125 of file threadpool.c.

{
    FIXME("(%p)->(%lx,%lx,%lx): stub\n", iface, dwProcessorNum, dwNumThreads, dwFlags);
    return DPN_OK;
}

impl_from_IDirectPlay8ThreadPool()

static IDirectPlay8ThreadPoolImpl * impl_from_IDirectPlay8ThreadPool ( IDirectPlay8ThreadPool *  iface )

inlinestatic

Definition at line 42 of file threadpool.c.

{
    return CONTAINING_RECORD(iface, IDirectPlay8ThreadPoolImpl, IDirectPlay8ThreadPool_iface);
}

Referenced by IDirectPlay8ThreadPoolImpl_AddRef(), IDirectPlay8ThreadPoolImpl_Close(), IDirectPlay8ThreadPoolImpl_Initialize(), and IDirectPlay8ThreadPoolImpl_Release().

WINE_DEFAULT_DEBUG_CHANNEL()

WINE_DEFAULT_DEBUG_CHANNEL

(

dpnet

)

Variable Documentation

DirectPlay8ThreadPool_Vtbl

const IDirectPlay8ThreadPoolVtbl DirectPlay8ThreadPool_Vtbl

static

Initial value:

=
{
    IDirectPlay8ThreadPoolImpl_QueryInterface,
    IDirectPlay8ThreadPoolImpl_AddRef,
    IDirectPlay8ThreadPoolImpl_Release,
    IDirectPlay8ThreadPoolImpl_Initialize,
    IDirectPlay8ThreadPoolImpl_Close,
    IDirectPlay8ThreadPoolImpl_GetThreadCount,
    IDirectPlay8ThreadPoolImpl_SetThreadCount,
    IDirectPlay8ThreadPoolImpl_DoWork
}

Definition at line 145 of file threadpool.c.

Referenced by DPNET_CreateDirectPlay8ThreadPool().

threadpool_flags

DWORD threadpool_flags = 0

static

Definition at line 39 of file threadpool.c.

Referenced by IDirectPlay8ThreadPoolImpl_Initialize().

threadpool_msghandler

PFNDPNMESSAGEHANDLER threadpool_msghandler = NULL

static

Definition at line 38 of file threadpool.c.

Referenced by IDirectPlay8ThreadPoolImpl_Close(), and IDirectPlay8ThreadPoolImpl_Initialize().

threadpool_usercontext

void* threadpool_usercontext = NULL

static

Definition at line 40 of file threadpool.c.

Referenced by IDirectPlay8ThreadPoolImpl_Initialize().