async.c File Reference

#include "d3d10_1.h"
#include "d3dx10.h"
#include "d3dcompiler.h"
#include "dxhelpers.h"
#include "winternl.h"
#include "wine/debug.h"
#include "wine/list.h"

Include dependency graph for async.c:

Go to the source code of this file.

Classes
struct	asyncdataloader
struct	texture_info_processor
struct	texture_processor
struct	work_item
struct	thread_pump

Macros
#define	COBJMACROS
#define	THREAD_PUMP_EXITING   UINT_MAX

Functions
	WINE_DEFAULT_DEBUG_CHANNEL (d3dx)
static struct asyncdataloader *	impl_from_ID3DX10DataLoader (ID3DX10DataLoader *iface)
static HRESULT WINAPI	memorydataloader_Load (ID3DX10DataLoader *iface)
static HRESULT WINAPI	memorydataloader_Decompress (ID3DX10DataLoader *iface, void **data, SIZE_T *size)
static HRESULT WINAPI	memorydataloader_Destroy (ID3DX10DataLoader *iface)
HRESULT	load_file (const WCHAR *path, void **data, DWORD *size)
static HRESULT WINAPI	filedataloader_Load (ID3DX10DataLoader *iface)
static HRESULT WINAPI	filedataloader_Decompress (ID3DX10DataLoader *iface, void **data, SIZE_T *size)
static HRESULT WINAPI	filedataloader_Destroy (ID3DX10DataLoader *iface)
static HRESULT	load_resource_initA (HMODULE module, const char *resource, HRSRC *rsrc)
static HRESULT	load_resource_initW (HMODULE module, const WCHAR *resource, HRSRC *rsrc)
static HRESULT	load_resource (HMODULE module, HRSRC rsrc, void **data, DWORD *size)
HRESULT	load_resourceA (HMODULE module, const char *resource, void **data, DWORD *size)
HRESULT	load_resourceW (HMODULE module, const WCHAR *resource, void **data, DWORD *size)
static HRESULT WINAPI	resourcedataloader_Load (ID3DX10DataLoader *iface)
static HRESULT WINAPI	resourcedataloader_Decompress (ID3DX10DataLoader *iface, void **data, SIZE_T *size)
static HRESULT WINAPI	resourcedataloader_Destroy (ID3DX10DataLoader *iface)
static struct texture_info_processor *	impl_from_ID3DX10DataProcessor (ID3DX10DataProcessor *iface)
static HRESULT WINAPI	texture_info_processor_Process (ID3DX10DataProcessor *iface, void *data, SIZE_T size)
static HRESULT WINAPI	texture_info_processor_CreateDeviceObject (ID3DX10DataProcessor *iface, void **object)
static HRESULT WINAPI	texture_info_processor_Destroy (ID3DX10DataProcessor *iface)
static struct texture_processor *	texture_processor_from_ID3DX10DataProcessor (ID3DX10DataProcessor *iface)
static HRESULT WINAPI	texture_processor_Process (ID3DX10DataProcessor *iface, void *data, SIZE_T size)
static HRESULT WINAPI	texture_processor_CreateDeviceObject (ID3DX10DataProcessor *iface, void **object)
static HRESULT WINAPI	texture_processor_Destroy (ID3DX10DataProcessor *iface)
HRESULT WINAPI	D3DX10CompileFromMemory (const char *data, SIZE_T data_size, const char *filename, const D3D10_SHADER_MACRO *defines, ID3D10Include *include, const char *entry_point, const char *target, UINT sflags, UINT eflags, ID3DX10ThreadPump *pump, ID3D10Blob **shader, ID3D10Blob **error_messages, HRESULT *hresult)
HRESULT WINAPI	D3DX10CreateEffectPoolFromFileA (const char *filename, const D3D10_SHADER_MACRO *defines, ID3D10Include *include, const char *profile, UINT hlslflags, UINT fxflags, ID3D10Device *device, ID3DX10ThreadPump *pump, ID3D10EffectPool **effectpool, ID3D10Blob **errors, HRESULT *hresult)
HRESULT WINAPI	D3DX10CreateEffectPoolFromFileW (const WCHAR *filename, const D3D10_SHADER_MACRO *defines, ID3D10Include *include, const char *profile, UINT hlslflags, UINT fxflags, ID3D10Device *device, ID3DX10ThreadPump *pump, ID3D10EffectPool **effectpool, ID3D10Blob **errors, HRESULT *hresult)
HRESULT WINAPI	D3DX10CreateAsyncMemoryLoader (const void *data, SIZE_T data_size, ID3DX10DataLoader **loader)
HRESULT WINAPI	D3DX10CreateAsyncFileLoaderA (const char *filename, ID3DX10DataLoader **loader)
HRESULT WINAPI	D3DX10CreateAsyncFileLoaderW (const WCHAR *filename, ID3DX10DataLoader **loader)
HRESULT WINAPI	D3DX10CreateAsyncResourceLoaderA (HMODULE module, const char *resource, ID3DX10DataLoader **loader)
HRESULT WINAPI	D3DX10CreateAsyncResourceLoaderW (HMODULE module, const WCHAR *resource, ID3DX10DataLoader **loader)
HRESULT WINAPI	D3DX10CreateAsyncTextureInfoProcessor (D3DX10_IMAGE_INFO *info, ID3DX10DataProcessor **processor)
HRESULT WINAPI	D3DX10CreateAsyncTextureProcessor (ID3D10Device *device, D3DX10_IMAGE_LOAD_INFO *load_info, ID3DX10DataProcessor **processor)
static void	work_item_free (struct work_item *work_item, BOOL cancel)
static struct thread_pump *	impl_from_ID3DX10ThreadPump (ID3DX10ThreadPump *iface)
static HRESULT WINAPI	thread_pump_QueryInterface (ID3DX10ThreadPump *iface, REFIID riid, void **out)
static ULONG WINAPI	thread_pump_AddRef (ID3DX10ThreadPump *iface)
static ULONG WINAPI	thread_pump_Release (ID3DX10ThreadPump *iface)
static HRESULT WINAPI	thread_pump_AddWorkItem (ID3DX10ThreadPump *iface, ID3DX10DataLoader *loader, ID3DX10DataProcessor *processor, HRESULT *result, void **object)
static UINT WINAPI	thread_pump_GetWorkItemCount (ID3DX10ThreadPump *iface)
static HRESULT WINAPI	thread_pump_WaitForAllItems (ID3DX10ThreadPump *iface)
static HRESULT WINAPI	thread_pump_ProcessDeviceWorkItems (ID3DX10ThreadPump *iface, UINT count)
static void	purge_list (struct list *list, LONG *count)
static HRESULT WINAPI	thread_pump_PurgeAllItems (ID3DX10ThreadPump *iface)
static HRESULT WINAPI	thread_pump_GetQueueStatus (ID3DX10ThreadPump *iface, UINT *io_queue, UINT *process_queue, UINT *device_queue)
static DWORD WINAPI	io_thread (void *arg)
static DWORD WINAPI	proc_thread (void *arg)
HRESULT WINAPI	D3DX10CreateThreadPump (UINT io_threads, UINT proc_threads, ID3DX10ThreadPump **pump)

Variables
static const ID3DX10DataLoaderVtbl	memorydataloadervtbl
static const ID3DX10DataLoaderVtbl	filedataloadervtbl
static const ID3DX10DataLoaderVtbl	resourcedataloadervtbl
static ID3DX10DataProcessorVtbl	texture_info_processor_vtbl
static ID3DX10DataProcessorVtbl	texture_processor_vtbl
static const ID3DX10ThreadPumpVtbl	thread_pump_vtbl

Macro Definition Documentation

COBJMACROS

#define COBJMACROS

Definition at line 19 of file async.c.

THREAD_PUMP_EXITING

#define THREAD_PUMP_EXITING   UINT_MAX

Definition at line 622 of file async.c.

Function Documentation

D3DX10CompileFromMemory()

HRESULT WINAPI D3DX10CompileFromMemory	(	const char *	data,
		SIZE_T	data_size,
		const char *	filename,
		const D3D10_SHADER_MACRO *	defines,
		ID3D10Include *	include,
		const char *	entry_point,
		const char *	target,
		UINT	sflags,
		UINT	eflags,
		ID3DX10ThreadPump *	pump,
		ID3D10Blob **	shader,
		ID3D10Blob **	error_messages,
		HRESULT *	hresult
	)

Definition at line 381 of file async.c.

{
    TRACE("data %s, data_size %Iu, filename %s, defines %p, include %p, entry_point %s, target %s, "
            "sflags %#x, eflags %#x, pump %p, shader %p, error_messages %p, hresult %p.\n",
            debugstr_an(data, data_size), data_size, debugstr_a(filename), defines, include,
            debugstr_a(entry_point), debugstr_a(target), sflags, eflags, pump, shader,
            error_messages, hresult);
 
    if (pump)
        FIXME("Unimplemented ID3DX10ThreadPump handling.\n");
 
    return D3DCompile(data, data_size, filename, defines, include, entry_point, target,
            sflags, eflags, shader, error_messages);
}

D3DX10CreateAsyncFileLoaderA()

HRESULT WINAPI D3DX10CreateAsyncFileLoaderA	(	const char *	filename,
		ID3DX10DataLoader **	loader
	)

Definition at line 445 of file async.c.

{
    WCHAR *filename_w;
    HRESULT hr;
    int len;
 
    TRACE("filename %s, loader %p.\n", debugstr_a(filename), loader);
 
    if (!filename || !loader)
        return E_FAIL;
 
    len = MultiByteToWideChar(CP_ACP, 0, filename, -1, NULL, 0);
    filename_w = malloc(len * sizeof(*filename_w));
    MultiByteToWideChar(CP_ACP, 0, filename, -1, filename_w, len);
 
    hr = D3DX10CreateAsyncFileLoaderW(filename_w, loader);
 
    free(filename_w);
 
    return hr;
}

D3DX10CreateAsyncFileLoaderW()

HRESULT WINAPI D3DX10CreateAsyncFileLoaderW	(	const WCHAR *	filename,
		ID3DX10DataLoader **	loader
	)

Definition at line 467 of file async.c.

{
    struct asyncdataloader *object;
 
    TRACE("filename %s, loader %p.\n", debugstr_w(filename), loader);
 
    if (!filename || !loader)
        return E_FAIL;
 
    object = calloc(1, sizeof(*object));
    if (!object)
        return E_OUTOFMEMORY;
 
    object->ID3DX10DataLoader_iface.lpVtbl = &filedataloadervtbl;
    object->u.file.path = malloc((lstrlenW(filename) + 1) * sizeof(WCHAR));
    if (!object->u.file.path)
    {
        free(object);
        return E_OUTOFMEMORY;
    }
    lstrcpyW(object->u.file.path, filename);
    object->data = NULL;
    object->size = 0;
 
    *loader = &object->ID3DX10DataLoader_iface;
 
    return S_OK;
}

Referenced by D3DX10CreateAsyncFileLoaderA(), D3DX10CreateTextureFromFileW(), and D3DX10GetImageInfoFromFileW().

D3DX10CreateAsyncMemoryLoader()

HRESULT WINAPI D3DX10CreateAsyncMemoryLoader	(	const void *	data,
		SIZE_T	data_size,
		ID3DX10DataLoader **	loader
	)

Definition at line 423 of file async.c.

{
    struct asyncdataloader *object;
 
    TRACE("data %p, data_size %Iu, loader %p.\n", data, data_size, loader);
 
    if (!data || !loader)
        return E_FAIL;
 
    object = calloc(1, sizeof(*object));
    if (!object)
        return E_OUTOFMEMORY;
 
    object->ID3DX10DataLoader_iface.lpVtbl = &memorydataloadervtbl;
    object->data = (void *)data;
    object->size = data_size;
 
    *loader = &object->ID3DX10DataLoader_iface;
 
    return S_OK;
}

Referenced by D3DX10CreateTextureFromMemory(), and D3DX10GetImageInfoFromMemory().

D3DX10CreateAsyncResourceLoaderA()

HRESULT WINAPI D3DX10CreateAsyncResourceLoaderA	(	HMODULE	module,
		const char *	resource,
		ID3DX10DataLoader **	loader
	)

Definition at line 496 of file async.c.

{
    struct asyncdataloader *object;
    HRSRC rsrc;
    HRESULT hr;
 
    TRACE("module %p, resource %s, loader %p.\n", module, debugstr_a(resource), loader);
 
    if (!loader)
        return E_FAIL;
 
    object = calloc(1, sizeof(*object));
    if (!object)
        return E_OUTOFMEMORY;
 
    if (FAILED((hr = load_resource_initA(module, resource, &rsrc))))
    {
        free(object);
        return hr;
    }
 
    object->ID3DX10DataLoader_iface.lpVtbl = &resourcedataloadervtbl;
    object->u.resource.module = module;
    object->u.resource.rsrc = rsrc;
    object->data = NULL;
    object->size = 0;
 
    *loader = &object->ID3DX10DataLoader_iface;
 
    return S_OK;
}

Referenced by D3DX10CreateTextureFromResourceA(), and D3DX10GetImageInfoFromResourceA().

D3DX10CreateAsyncResourceLoaderW()

HRESULT WINAPI D3DX10CreateAsyncResourceLoaderW	(	HMODULE	module,
		const WCHAR *	resource,
		ID3DX10DataLoader **	loader
	)

Definition at line 528 of file async.c.

{
    struct asyncdataloader *object;
    HRSRC rsrc;
    HRESULT hr;
 
    TRACE("module %p, resource %s, loader %p.\n", module, debugstr_w(resource), loader);
 
    if (!loader)
        return E_FAIL;
 
    object = calloc(1, sizeof(*object));
    if (!object)
        return E_OUTOFMEMORY;
 
    if (FAILED((hr = load_resource_initW(module, resource, &rsrc))))
    {
        free(object);
        return hr;
    }
 
    object->ID3DX10DataLoader_iface.lpVtbl = &resourcedataloadervtbl;
    object->u.resource.module = module;
    object->u.resource.rsrc = rsrc;
    object->data = NULL;
    object->size = 0;
 
    *loader = &object->ID3DX10DataLoader_iface;
 
    return S_OK;
}

Referenced by D3DX10CreateTextureFromResourceW(), and D3DX10GetImageInfoFromResourceW().

D3DX10CreateAsyncTextureInfoProcessor()

HRESULT WINAPI D3DX10CreateAsyncTextureInfoProcessor	(	D3DX10_IMAGE_INFO *	info,
		ID3DX10DataProcessor **	processor
	)

Definition at line 560 of file async.c.

{
    struct texture_info_processor *object;
 
    TRACE("info %p, processor %p.\n", info, processor);
 
    if (!processor)
        return E_INVALIDARG;
 
    object = malloc(sizeof(*object));
    if (!object)
        return E_OUTOFMEMORY;
 
    object->ID3DX10DataProcessor_iface.lpVtbl = &texture_info_processor_vtbl;
    object->info = info;
 
    *processor = &object->ID3DX10DataProcessor_iface;
    return S_OK;
}

Referenced by D3DX10GetImageInfoFromFileW(), D3DX10GetImageInfoFromMemory(), D3DX10GetImageInfoFromResourceA(), and D3DX10GetImageInfoFromResourceW().

D3DX10CreateAsyncTextureProcessor()

HRESULT WINAPI D3DX10CreateAsyncTextureProcessor	(	ID3D10Device *	device,
		D3DX10_IMAGE_LOAD_INFO *	load_info,
		ID3DX10DataProcessor **	processor
	)

Definition at line 580 of file async.c.

{
    struct texture_processor *object;
 
    TRACE("device %p, load_info %p, processor %p.\n", device, load_info, processor);
 
    if (!device || !processor)
        return E_INVALIDARG;
 
    object = calloc(1, sizeof(*object));
    if (!object)
        return E_OUTOFMEMORY;
 
    object->ID3DX10DataProcessor_iface.lpVtbl = &texture_processor_vtbl;
    object->device = device;
    ID3D10Device_AddRef(device);
    init_load_info(load_info, &object->load_info);
 
    *processor = &object->ID3DX10DataProcessor_iface;
    return S_OK;
}

Referenced by D3DX10CreateTextureFromFileW(), D3DX10CreateTextureFromMemory(), D3DX10CreateTextureFromResourceA(), and D3DX10CreateTextureFromResourceW().

D3DX10CreateEffectPoolFromFileA()

HRESULT WINAPI D3DX10CreateEffectPoolFromFileA	(	const char *	filename,
		const D3D10_SHADER_MACRO *	defines,
		ID3D10Include *	include,
		const char *	profile,
		UINT	hlslflags,
		UINT	fxflags,
		ID3D10Device *	device,
		ID3DX10ThreadPump *	pump,
		ID3D10EffectPool **	effectpool,
		ID3D10Blob **	errors,
		HRESULT *	hresult
	)

Definition at line 399 of file async.c.

{
    FIXME("filename %s, defines %p, include %p, profile %s, hlslflags %#x, fxflags %#x, device %p, "
            "pump %p, effectpool %p, errors %p, hresult %p, stub!\n",
            debugstr_a(filename), defines, include, debugstr_a(profile), hlslflags, fxflags, device,
            pump, effectpool, errors, hresult);
 
    return E_NOTIMPL;
}

D3DX10CreateEffectPoolFromFileW()

HRESULT WINAPI D3DX10CreateEffectPoolFromFileW	(	const WCHAR *	filename,
		const D3D10_SHADER_MACRO *	defines,
		ID3D10Include *	include,
		const char *	profile,
		UINT	hlslflags,
		UINT	fxflags,
		ID3D10Device *	device,
		ID3DX10ThreadPump *	pump,
		ID3D10EffectPool **	effectpool,
		ID3D10Blob **	errors,
		HRESULT *	hresult
	)

Definition at line 411 of file async.c.

{
    FIXME("filename %s, defines %p, include %p, profile %s, hlslflags %#x, fxflags %#x, device %p, "
            "pump %p, effectpool %p, errors %p, hresult %p, stub!\n",
            debugstr_w(filename), defines, include, debugstr_a(profile), hlslflags, fxflags, device,
            pump, effectpool, errors, hresult);
 
    return E_NOTIMPL;
}

D3DX10CreateThreadPump()

HRESULT WINAPI D3DX10CreateThreadPump	(	UINT	io_threads,
		UINT	proc_threads,
		ID3DX10ThreadPump **	pump
	)

Definition at line 1034 of file async.c.

{
    struct thread_pump *object;
    unsigned int i;
 
    TRACE("io_threads %u, proc_threads %u, pump %p.\n", io_threads, proc_threads, pump);
 
    if (io_threads >= 1024 || proc_threads >= 1024)
        return E_FAIL;
 
    if (!io_threads)
        io_threads = 1;
    if (!proc_threads)
    {
        SYSTEM_INFO info;
 
        GetSystemInfo(&info);
        proc_threads = info.dwNumberOfProcessors;
    }
 
    if (!(object = calloc(1, FIELD_OFFSET(struct thread_pump, threads[io_threads + proc_threads]))))
        return E_OUTOFMEMORY;
 
    object->ID3DX10ThreadPump_iface.lpVtbl = &thread_pump_vtbl;
    object->refcount = 1;
    InitializeSRWLock(&object->io_lock);
    InitializeConditionVariable(&object->io_cv);
    list_init(&object->io_queue);
    InitializeSRWLock(&object->proc_lock);
    InitializeConditionVariable(&object->proc_cv);
    list_init(&object->proc_queue);
    InitializeSRWLock(&object->device_lock);
    list_init(&object->device_queue);
    object->thread_count = io_threads + proc_threads;
 
    for (i = 0; i < object->thread_count; ++i)
    {
        object->threads[i] = CreateThread(NULL, 0, i < io_threads ? io_thread : proc_thread, object, 0, NULL);
        if (!object->threads[i])
        {
            ID3DX10ThreadPump_Release(&object->ID3DX10ThreadPump_iface);
            return E_FAIL;
        }
    }
 
    *pump = &object->ID3DX10ThreadPump_iface;
    return S_OK;
}

filedataloader_Decompress()

static HRESULT WINAPI filedataloader_Decompress ( ID3DX10DataLoader *  iface, void **  data, SIZE_T *  size  )

static

Definition at line 141 of file async.c.

{
    struct asyncdataloader *loader = impl_from_ID3DX10DataLoader(iface);
 
    TRACE("iface %p, data %p, size %p.\n", iface, data, size);
 
    if (!loader->data)
        return E_FAIL;
 
    *data = loader->data;
    *size = loader->size;
 
    return S_OK;
}

filedataloader_Destroy()

static HRESULT WINAPI filedataloader_Destroy ( ID3DX10DataLoader *  iface )

static

Definition at line 156 of file async.c.

{
    struct asyncdataloader *loader = impl_from_ID3DX10DataLoader(iface);
 
    TRACE("iface %p.\n", iface);
 
    free(loader->u.file.path);
    free(loader->data);
    free(loader);
 
    return S_OK;
}

filedataloader_Load()

static HRESULT WINAPI filedataloader_Load ( ID3DX10DataLoader *  iface )

static

Definition at line 121 of file async.c.

{
    struct asyncdataloader *loader = impl_from_ID3DX10DataLoader(iface);
    void *data;
    DWORD size;
    HRESULT hr;
 
    TRACE("iface %p.\n", iface);
 
    /* Always buffer file contents, even if Load() was already called. */
    if (FAILED((hr = load_file(loader->u.file.path, &data, &size))))
        return hr;
 
    free(loader->data);
    loader->data = data;
    loader->size = size;
 
    return S_OK;
}

impl_from_ID3DX10DataLoader()

static struct asyncdataloader * impl_from_ID3DX10DataLoader ( ID3DX10DataLoader *  iface )

inlinestatic

Definition at line 51 of file async.c.

{
    return CONTAINING_RECORD(iface, struct asyncdataloader, ID3DX10DataLoader_iface);
}

Referenced by filedataloader_Decompress(), filedataloader_Destroy(), filedataloader_Load(), memorydataloader_Decompress(), memorydataloader_Destroy(), resourcedataloader_Decompress(), resourcedataloader_Destroy(), and resourcedataloader_Load().

impl_from_ID3DX10DataProcessor()

static struct texture_info_processor * impl_from_ID3DX10DataProcessor ( ID3DX10DataProcessor *  iface )

inlinestatic

Definition at line 285 of file async.c.

{
    return CONTAINING_RECORD(iface, struct texture_info_processor, ID3DX10DataProcessor_iface);
}

Referenced by texture_info_processor_Destroy(), and texture_info_processor_Process().

impl_from_ID3DX10ThreadPump()

static struct thread_pump * impl_from_ID3DX10ThreadPump ( ID3DX10ThreadPump *  iface )

inlinestatic

Definition at line 648 of file async.c.

{
    return CONTAINING_RECORD(iface, struct thread_pump, ID3DX10ThreadPump_iface);
}

Referenced by thread_pump_AddRef(), thread_pump_AddWorkItem(), thread_pump_GetQueueStatus(), thread_pump_GetWorkItemCount(), thread_pump_ProcessDeviceWorkItems(), thread_pump_PurgeAllItems(), thread_pump_Release(), and thread_pump_WaitForAllItems().

io_thread()

static DWORD WINAPI io_thread ( void *  arg )

static

Definition at line 911 of file async.c.

{
    struct thread_pump *thread_pump = arg;
    struct work_item *work_item;
    HRESULT hr;
 
    TRACE("%p thread started.\n", thread_pump);
 
    for (;;)
    {
        AcquireSRWLockExclusive(&thread_pump->io_lock);
 
        while (!thread_pump->io_count)
            SleepConditionVariableSRW(&thread_pump->io_cv, &thread_pump->io_lock, INFINITE, 0);
 
        if (thread_pump->io_count == THREAD_PUMP_EXITING)
        {
            ReleaseSRWLockExclusive(&thread_pump->io_lock);
            return 0;
        }
 
        --thread_pump->io_count;
        work_item = LIST_ENTRY(list_head(&thread_pump->io_queue), struct work_item, entry);
        list_remove(&work_item->entry);
        ReleaseSRWLockExclusive(&thread_pump->io_lock);
 
        if (FAILED(hr = ID3DX10DataLoader_Load(work_item->loader)))
        {
            if (work_item->result)
                *work_item->result = hr;
            work_item_free(work_item, FALSE);
            if (!InterlockedDecrement(&thread_pump->processing_count))
                RtlWakeAddressAll(&thread_pump->processing_count);
            continue;
        }
 
        AcquireSRWLockExclusive(&thread_pump->proc_lock);
        if (thread_pump->proc_count == THREAD_PUMP_EXITING)
        {
            ReleaseSRWLockExclusive(&thread_pump->proc_lock);
            work_item_free(work_item, TRUE);
            return 0;
        }
 
        list_add_tail(&thread_pump->proc_queue, &work_item->entry);
        ++thread_pump->proc_count;
        ReleaseSRWLockExclusive(&thread_pump->proc_lock);
        WakeConditionVariable(&thread_pump->proc_cv);
    }
    return 0;
}

Referenced by D3DX10CreateThreadPump().

load_file()

HRESULT load_file	(	const WCHAR *	path,
		void **	data,
		DWORD *	size
	)

Definition at line 91 of file async.c.

{
    DWORD read_len;
    HANDLE file;
    BOOL ret;
 
    file = CreateFileW(path, GENERIC_READ, FILE_SHARE_READ | FILE_SHARE_WRITE,
            NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL);
    if (file == INVALID_HANDLE_VALUE)
        return D3D10_ERROR_FILE_NOT_FOUND;
 
    *size = GetFileSize(file, NULL);
    *data = malloc(*size);
    if (!*data)
    {
        CloseHandle(file);
        return E_OUTOFMEMORY;
    }
 
    ret = ReadFile(file, *data, *size, &read_len, NULL);
    CloseHandle(file);
    if (!ret || read_len != *size)
    {
        WARN("Failed to read file contents.\n");
        free(*data);
        return E_FAIL;
    }
    return S_OK;
}

Referenced by D3DX10CreateEffectFromFileW(), D3DX10CreateTextureFromFileW(), D3DX10GetImageInfoFromFileW(), elf_load_file_cb(), filedataloader_Load(), main(), and process_file().

load_resource()

static HRESULT load_resource ( HMODULE  module, HRSRC  rsrc, void **  data, DWORD *  size  )

static

Definition at line 200 of file async.c.

{
    HGLOBAL hglobal;
 
    if (!(*size = SizeofResource(module, rsrc)))
        return D3DX10_ERR_INVALID_DATA;
    if (!(hglobal = LoadResource(module, rsrc)))
        return D3DX10_ERR_INVALID_DATA;
    if (!(*data = LockResource(hglobal)))
        return D3DX10_ERR_INVALID_DATA;
    return S_OK;
}

load_resource_initA()

static HRESULT load_resource_initA ( HMODULE  module, const char *  resource, HRSRC *  rsrc  )

static

Definition at line 176 of file async.c.

{
    if (!(*rsrc = FindResourceA(module, resource, (const char *)RT_RCDATA)))
        *rsrc = FindResourceA(module, resource, (const char *)RT_BITMAP);
    if (!*rsrc)
    {
        WARN("Failed to find resource.\n");
        return D3DX10_ERR_INVALID_DATA;
    }
    return S_OK;
}

Referenced by D3DX10CreateAsyncResourceLoaderA(), and load_resourceA().

load_resource_initW()

static HRESULT load_resource_initW ( HMODULE  module, const WCHAR *  resource, HRSRC *  rsrc  )

static

Definition at line 188 of file async.c.

{
    if (!(*rsrc = FindResourceW(module, resource, (const WCHAR *)RT_RCDATA)))
        *rsrc = FindResourceW(module, resource, (const WCHAR *)RT_BITMAP);
    if (!*rsrc)
    {
        WARN("Failed to find resource.\n");
        return D3DX10_ERR_INVALID_DATA;
    }
    return S_OK;
}

Referenced by D3DX10CreateAsyncResourceLoaderW(), and load_resourceW().

load_resourceA()

HRESULT load_resourceA	(	HMODULE	module,
		const char *	resource,
		void **	data,
		DWORD *	size
	)

Definition at line 213 of file async.c.

{
    HRESULT hr;
    HRSRC rsrc;
 
    if (FAILED((hr = load_resource_initA(module, resource, &rsrc))))
        return hr;
    return load_resource(module, rsrc, data, size);
}

Referenced by D3DX10CreateEffectFromResourceA(), D3DX10CreateTextureFromResourceA(), and D3DX10GetImageInfoFromResourceA().

load_resourceW()

HRESULT load_resourceW	(	HMODULE	module,
		const WCHAR *	resource,
		void **	data,
		DWORD *	size
	)

Definition at line 223 of file async.c.

{
    HRESULT hr;
    HRSRC rsrc;
 
    if ((FAILED(hr = load_resource_initW(module, resource, &rsrc))))
        return hr;
    return load_resource(module, rsrc, data, size);
}

Referenced by D3DX10CreateEffectFromResourceW(), D3DX10CreateTextureFromResourceW(), and D3DX10GetImageInfoFromResourceW().

memorydataloader_Decompress()

static HRESULT WINAPI memorydataloader_Decompress ( ID3DX10DataLoader *  iface, void **  data, SIZE_T *  size  )

static

Definition at line 62 of file async.c.

{
    struct asyncdataloader *loader = impl_from_ID3DX10DataLoader(iface);
 
    TRACE("iface %p, data %p, size %p.\n", iface, data, size);
 
    *data = loader->data;
    *size = loader->size;
 
    return S_OK;
}

memorydataloader_Destroy()

static HRESULT WINAPI memorydataloader_Destroy ( ID3DX10DataLoader *  iface )

static

Definition at line 74 of file async.c.

{
    struct asyncdataloader *loader = impl_from_ID3DX10DataLoader(iface);
 
    TRACE("iface %p.\n", iface);
 
    free(loader);
    return S_OK;
}

memorydataloader_Load()

static HRESULT WINAPI memorydataloader_Load ( ID3DX10DataLoader *  iface )

static

Definition at line 56 of file async.c.

{
    TRACE("iface %p.\n", iface);
    return S_OK;
}

proc_thread()

static DWORD WINAPI proc_thread ( void *  arg )

static

Definition at line 963 of file async.c.

{
    struct thread_pump *thread_pump = arg;
    struct work_item *work_item;
    SIZE_T size;
    void *data;
    HRESULT hr;
 
    TRACE("%p thread started.\n", thread_pump);
 
    for (;;)
    {
        AcquireSRWLockExclusive(&thread_pump->proc_lock);
 
        while (!thread_pump->proc_count)
            SleepConditionVariableSRW(&thread_pump->proc_cv, &thread_pump->proc_lock, INFINITE, 0);
 
        if (thread_pump->proc_count == THREAD_PUMP_EXITING)
        {
            ReleaseSRWLockExclusive(&thread_pump->proc_lock);
            return 0;
        }
 
        --thread_pump->proc_count;
        work_item = LIST_ENTRY(list_head(&thread_pump->proc_queue), struct work_item, entry);
        list_remove(&work_item->entry);
        ReleaseSRWLockExclusive(&thread_pump->proc_lock);
 
        if (FAILED(hr = ID3DX10DataLoader_Decompress(work_item->loader, &data, &size)))
        {
            if (work_item->result)
                *work_item->result = hr;
            work_item_free(work_item, FALSE);
            if (!InterlockedDecrement(&thread_pump->processing_count))
                RtlWakeAddressAll(&thread_pump->processing_count);
            continue;
        }
 
        if (thread_pump->device_count == THREAD_PUMP_EXITING)
        {
            work_item_free(work_item, TRUE);
            return 0;
        }
 
        if (FAILED(hr = ID3DX10DataProcessor_Process(work_item->processor, data, size)))
        {
            if (work_item->result)
                *work_item->result = hr;
            work_item_free(work_item, FALSE);
            if (!InterlockedDecrement(&thread_pump->processing_count))
                RtlWakeAddressAll(&thread_pump->processing_count);
            continue;
        }
 
        AcquireSRWLockExclusive(&thread_pump->device_lock);
        if (thread_pump->device_count == THREAD_PUMP_EXITING)
        {
            ReleaseSRWLockExclusive(&thread_pump->device_lock);
            work_item_free(work_item, TRUE);
            return 0;
        }
 
        list_add_tail(&thread_pump->device_queue, &work_item->entry);
        ++thread_pump->device_count;
        InterlockedDecrement(&thread_pump->processing_count);
        RtlWakeAddressAll(&thread_pump->processing_count);
        ReleaseSRWLockExclusive(&thread_pump->device_lock);
    }
    return 0;
}

Referenced by D3DX10CreateThreadPump().

purge_list()

static void purge_list ( struct list *  list, LONG *  count  )

static

Definition at line 836 of file async.c.

{
    struct work_item *work_item;
 
    while (!list_empty(list))
    {
        work_item = LIST_ENTRY(list_head(list), struct work_item, entry);
        list_remove(&work_item->entry);
        work_item_free(work_item, TRUE);
 
        if (count && !InterlockedDecrement(count))
            RtlWakeAddressAll(count);
    }
}

Referenced by thread_pump_PurgeAllItems().

resourcedataloader_Decompress()

static HRESULT WINAPI resourcedataloader_Decompress ( ID3DX10DataLoader *  iface, void **  data, SIZE_T *  size  )

static

Definition at line 246 of file async.c.

{
    struct asyncdataloader *loader = impl_from_ID3DX10DataLoader(iface);
 
    TRACE("iface %p, data %p, size %p.\n", iface, data, size);
 
    if (!loader->data)
        return E_FAIL;
 
    *data = loader->data;
    *size = loader->size;
 
    return S_OK;
}

resourcedataloader_Destroy()

static HRESULT WINAPI resourcedataloader_Destroy ( ID3DX10DataLoader *  iface )

static

Definition at line 261 of file async.c.

{
    struct asyncdataloader *loader = impl_from_ID3DX10DataLoader(iface);
 
    TRACE("iface %p.\n", iface);
 
    free(loader);
 
    return S_OK;
}

resourcedataloader_Load()

static HRESULT WINAPI resourcedataloader_Load ( ID3DX10DataLoader *  iface )

static

Definition at line 233 of file async.c.

{
    struct asyncdataloader *loader = impl_from_ID3DX10DataLoader(iface);
 
    TRACE("iface %p.\n", iface);
 
    if (loader->data)
        return S_OK;
 
    return load_resource(loader->u.resource.module, loader->u.resource.rsrc,
            &loader->data, &loader->size);
}

texture_info_processor_CreateDeviceObject()

static HRESULT WINAPI texture_info_processor_CreateDeviceObject ( ID3DX10DataProcessor *  iface, void **  object  )

static

Definition at line 298 of file async.c.

{
    TRACE("iface %p, object %p.\n", iface, object);
    return S_OK;
}

texture_info_processor_Destroy()

static HRESULT WINAPI texture_info_processor_Destroy ( ID3DX10DataProcessor *  iface )

static

Definition at line 304 of file async.c.

{
    struct texture_info_processor *processor = impl_from_ID3DX10DataProcessor(iface);
 
    TRACE("iface %p.\n", iface);
 
    free(processor);
    return S_OK;
}

texture_info_processor_Process()

static HRESULT WINAPI texture_info_processor_Process ( ID3DX10DataProcessor *  iface, void *  data, SIZE_T  size  )

static

Definition at line 290 of file async.c.

{
    struct texture_info_processor *processor = impl_from_ID3DX10DataProcessor(iface);
 
    TRACE("iface %p, data %p, size %Iu.\n", iface, data, size);
    return get_image_info(data, size, processor->info);
}

texture_processor_CreateDeviceObject()

static HRESULT WINAPI texture_processor_CreateDeviceObject ( ID3DX10DataProcessor *  iface, void **  object  )

static

Definition at line 349 of file async.c.

{
    struct texture_processor *processor = texture_processor_from_ID3DX10DataProcessor(iface);
 
    TRACE("iface %p, object %p.\n", iface, object);
 
    if (!processor->resource_data)
        return E_FAIL;
 
    return create_d3d_texture(processor->device, &processor->load_info,
            processor->resource_data, (ID3D10Resource **)object);
}

texture_processor_Destroy()

static HRESULT WINAPI texture_processor_Destroy ( ID3DX10DataProcessor *  iface )

static

Definition at line 362 of file async.c.

{
    struct texture_processor *processor = texture_processor_from_ID3DX10DataProcessor(iface);
 
    TRACE("iface %p.\n", iface);
 
    ID3D10Device_Release(processor->device);
    free(processor->resource_data);
    free(processor);
    return S_OK;
}

texture_processor_from_ID3DX10DataProcessor()

static struct texture_processor * texture_processor_from_ID3DX10DataProcessor ( ID3DX10DataProcessor *  iface )

inlinestatic

Definition at line 329 of file async.c.

{
    return CONTAINING_RECORD(iface, struct texture_processor, ID3DX10DataProcessor_iface);
}

Referenced by texture_processor_CreateDeviceObject(), texture_processor_Destroy(), and texture_processor_Process().

texture_processor_Process()

static HRESULT WINAPI texture_processor_Process ( ID3DX10DataProcessor *  iface, void *  data, SIZE_T  size  )

static

Definition at line 334 of file async.c.

{
    struct texture_processor *processor = texture_processor_from_ID3DX10DataProcessor(iface);
 
    TRACE("iface %p, data %p, size %Iu.\n", iface, data, size);
 
    if (processor->resource_data)
    {
        WARN("Called multiple times.\n");
        free(processor->resource_data);
        processor->resource_data = NULL;
    }
    return load_texture_data(data, size, &processor->load_info, &processor->resource_data);
}

thread_pump_AddRef()

static ULONG WINAPI thread_pump_AddRef ( ID3DX10ThreadPump *  iface )

static

Definition at line 670 of file async.c.

{
    struct thread_pump *thread_pump = impl_from_ID3DX10ThreadPump(iface);
    ULONG refcount = InterlockedIncrement(&thread_pump->refcount);
 
    TRACE("%p increasing refcount to %lu.\n", iface, refcount);
 
    return refcount;
}

thread_pump_AddWorkItem()

static HRESULT WINAPI thread_pump_AddWorkItem ( ID3DX10ThreadPump *  iface, ID3DX10DataLoader *  loader, ID3DX10DataProcessor *  processor, HRESULT *  result, void **  object  )

static

Definition at line 731 of file async.c.

{
    struct thread_pump *thread_pump = impl_from_ID3DX10ThreadPump(iface);
    struct work_item *work_item;
 
    TRACE("iface %p, loader %p, processor %p, result %p, object %p.\n",
            iface, loader, processor, result, object);
 
    work_item = malloc(sizeof(*work_item));
    if (!work_item)
        return E_OUTOFMEMORY;
 
    work_item->loader = loader;
    work_item->processor = processor;
    work_item->result = result;
    work_item->object = object;
 
    if (object)
        *object = NULL;
 
    InterlockedIncrement(&thread_pump->processing_count);
    AcquireSRWLockExclusive(&thread_pump->io_lock);
    ++thread_pump->io_count;
    list_add_tail(&thread_pump->io_queue, &work_item->entry);
    ReleaseSRWLockExclusive(&thread_pump->io_lock);
    WakeConditionVariable(&thread_pump->io_cv);
    return S_OK;
}

thread_pump_GetQueueStatus()

static HRESULT WINAPI thread_pump_GetQueueStatus ( ID3DX10ThreadPump *  iface, UINT *  io_queue, UINT *  process_queue, UINT *  device_queue  )

static

Definition at line 884 of file async.c.

{
    struct thread_pump *thread_pump = impl_from_ID3DX10ThreadPump(iface);
 
    TRACE("iface %p, io_queue %p, process_queue %p, device_queue %p.\n",
            iface, io_queue, process_queue, device_queue);
 
    *io_queue = thread_pump->io_count;
    *process_queue = thread_pump->proc_count;
    *device_queue = thread_pump->device_count;
    return S_OK;
}

thread_pump_GetWorkItemCount()

static UINT WINAPI thread_pump_GetWorkItemCount ( ID3DX10ThreadPump *  iface )

static

Definition at line 761 of file async.c.

{
    struct thread_pump *thread_pump = impl_from_ID3DX10ThreadPump(iface);
    UINT ret;
 
    TRACE("iface %p.\n", iface);
 
    AcquireSRWLockExclusive(&thread_pump->device_lock);
    ret = thread_pump->processing_count + thread_pump->device_count;
    ReleaseSRWLockExclusive(&thread_pump->device_lock);
    return ret;
}

thread_pump_ProcessDeviceWorkItems()

static HRESULT WINAPI thread_pump_ProcessDeviceWorkItems ( ID3DX10ThreadPump *  iface, UINT  count  )

static

Definition at line 804 of file async.c.

{
    struct thread_pump *thread_pump = impl_from_ID3DX10ThreadPump(iface);
    struct work_item *work_item;
    HRESULT hr;
    UINT i;
 
    TRACE("iface %p, count %u.\n", iface, count);
 
    for (i = 0; i < count; ++i)
    {
        AcquireSRWLockExclusive(&thread_pump->device_lock);
        if (!thread_pump->device_count)
        {
            ReleaseSRWLockExclusive(&thread_pump->device_lock);
            break;
        }
 
        --thread_pump->device_count;
        work_item = LIST_ENTRY(list_head(&thread_pump->device_queue), struct work_item, entry);
        list_remove(&work_item->entry);
        ReleaseSRWLockExclusive(&thread_pump->device_lock);
 
        hr = ID3DX10DataProcessor_CreateDeviceObject(work_item->processor, work_item->object);
        if (work_item->result)
            *work_item->result = hr;
        work_item_free(work_item, FALSE);
    }
 
    return S_OK;
}

thread_pump_PurgeAllItems()

static HRESULT WINAPI thread_pump_PurgeAllItems ( ID3DX10ThreadPump *  iface )

static

Definition at line 851 of file async.c.

{
    struct thread_pump *thread_pump = impl_from_ID3DX10ThreadPump(iface);
    LONG v;
 
    TRACE("iface %p.\n", iface);
 
    for (;;)
    {
        AcquireSRWLockExclusive(&thread_pump->io_lock);
        purge_list(&thread_pump->io_queue, &thread_pump->processing_count);
        thread_pump->io_count = 0;
        ReleaseSRWLockExclusive(&thread_pump->io_lock);
 
        AcquireSRWLockExclusive(&thread_pump->proc_lock);
        purge_list(&thread_pump->proc_queue, &thread_pump->processing_count);
        thread_pump->proc_count = 0;
        ReleaseSRWLockExclusive(&thread_pump->proc_lock);
 
        AcquireSRWLockExclusive(&thread_pump->device_lock);
        purge_list(&thread_pump->device_queue, NULL);
        thread_pump->device_count = 0;
        v = thread_pump->processing_count;
        ReleaseSRWLockExclusive(&thread_pump->device_lock);
        if (!v)
            break;
 
        RtlWaitOnAddress(&thread_pump->processing_count, &v, sizeof(v), NULL);
    }
 
    return S_OK;
}

thread_pump_QueryInterface()

static HRESULT WINAPI thread_pump_QueryInterface ( ID3DX10ThreadPump *  iface, REFIID  riid, void **  out  )

static

Definition at line 653 of file async.c.

{
    TRACE("iface %p, riid %s, out %p.\n", iface, debugstr_guid(riid), out);
 
    if (IsEqualGUID(riid, &IID_ID3DX10ThreadPump)
            || IsEqualGUID(riid, &IID_IUnknown))
    {
        ID3DX10ThreadPump_AddRef(iface);
        *out = iface;
        return S_OK;
    }
 
    WARN("%s not implemented, returning E_NOINTERFACE.\n", debugstr_guid(riid));
    *out = NULL;
    return E_NOINTERFACE;
}

thread_pump_Release()

static ULONG WINAPI thread_pump_Release ( ID3DX10ThreadPump *  iface )

static

Definition at line 680 of file async.c.

{
    struct thread_pump *thread_pump = impl_from_ID3DX10ThreadPump(iface);
    ULONG refcount = InterlockedDecrement(&thread_pump->refcount);
    struct work_item *item, *next;
    struct list list;
    unsigned int i;
 
    TRACE("%p decreasing refcount to %lu.\n", iface, refcount);
 
    if (!refcount)
    {
        AcquireSRWLockExclusive(&thread_pump->io_lock);
        thread_pump->io_count = THREAD_PUMP_EXITING;
        ReleaseSRWLockExclusive(&thread_pump->io_lock);
        WakeAllConditionVariable(&thread_pump->io_cv);
 
        AcquireSRWLockExclusive(&thread_pump->proc_lock);
        thread_pump->proc_count = THREAD_PUMP_EXITING;
        ReleaseSRWLockExclusive(&thread_pump->proc_lock);
        WakeAllConditionVariable(&thread_pump->proc_cv);
 
        AcquireSRWLockExclusive(&thread_pump->device_lock);
        thread_pump->device_count = THREAD_PUMP_EXITING;
        ReleaseSRWLockExclusive(&thread_pump->device_lock);
 
        for (i = 0; i < thread_pump->thread_count; ++i)
        {
            if (!thread_pump->threads[i])
                continue;
 
            WaitForSingleObject(thread_pump->threads[i], INFINITE);
            CloseHandle(thread_pump->threads[i]);
        }
 
        list_init(&list);
        list_move_tail(&list, &thread_pump->io_queue);
        list_move_tail(&list, &thread_pump->proc_queue);
        list_move_tail(&list, &thread_pump->device_queue);
        LIST_FOR_EACH_ENTRY_SAFE(item, next, &list, struct work_item, entry)
        {
            list_remove(&item->entry);
            work_item_free(item, TRUE);
        }
 
        free(thread_pump);
    }
 
    return refcount;
}

thread_pump_WaitForAllItems()

static HRESULT WINAPI thread_pump_WaitForAllItems ( ID3DX10ThreadPump *  iface )

static

Definition at line 774 of file async.c.

{
    struct thread_pump *thread_pump = impl_from_ID3DX10ThreadPump(iface);
    HRESULT hr;
    LONG v;
 
    TRACE("iface %p.\n", iface);
 
    for (;;)
    {
        if (FAILED((hr = ID3DX10ThreadPump_ProcessDeviceWorkItems(iface, UINT_MAX))))
            return hr;
 
        AcquireSRWLockExclusive(&thread_pump->device_lock);
        if (thread_pump->device_count)
        {
            ReleaseSRWLockExclusive(&thread_pump->device_lock);
            continue;
        }
        v = thread_pump->processing_count;
        ReleaseSRWLockExclusive(&thread_pump->device_lock);
        if (!v)
            break;
 
        RtlWaitOnAddress(&thread_pump->processing_count, &v, sizeof(v), NULL);
    }
 
    return S_OK;
}

WINE_DEFAULT_DEBUG_CHANNEL()

WINE_DEFAULT_DEBUG_CHANNEL

(

d3dx

)

work_item_free()

static void work_item_free ( struct work_item *  work_item, BOOL  cancel  )

inlinestatic

Definition at line 613 of file async.c.

{
    ID3DX10DataLoader_Destroy(work_item->loader);
    ID3DX10DataProcessor_Destroy(work_item->processor);
    if (cancel && work_item->result)
        *work_item->result = S_FALSE;
    free(work_item);
}

Referenced by io_thread(), proc_thread(), purge_list(), thread_pump_ProcessDeviceWorkItems(), and thread_pump_Release().

Variable Documentation

filedataloadervtbl

const ID3DX10DataLoaderVtbl filedataloadervtbl

static

Initial value:

=
{
    filedataloader_Load,
    filedataloader_Decompress,
    filedataloader_Destroy
}

Definition at line 169 of file async.c.

Referenced by D3DX10CreateAsyncFileLoaderW(), and D3DX11CreateAsyncFileLoaderW().

memorydataloadervtbl

const ID3DX10DataLoaderVtbl memorydataloadervtbl

static

Initial value:

=
{
    memorydataloader_Load,
    memorydataloader_Decompress,
    memorydataloader_Destroy
}

Definition at line 84 of file async.c.

Referenced by D3DX10CreateAsyncMemoryLoader(), and D3DX11CreateAsyncMemoryLoader().

resourcedataloadervtbl

const ID3DX10DataLoaderVtbl resourcedataloadervtbl

static

Initial value:

=
{
    resourcedataloader_Load,
    resourcedataloader_Decompress,
    resourcedataloader_Destroy
}

Definition at line 272 of file async.c.

Referenced by D3DX10CreateAsyncResourceLoaderA(), D3DX10CreateAsyncResourceLoaderW(), D3DX11CreateAsyncResourceLoaderA(), and D3DX11CreateAsyncResourceLoaderW().

texture_info_processor_vtbl

ID3DX10DataProcessorVtbl texture_info_processor_vtbl

static

Initial value:

=
{
    texture_info_processor_Process,
    texture_info_processor_CreateDeviceObject,
    texture_info_processor_Destroy
}

Definition at line 314 of file async.c.

Referenced by D3DX10CreateAsyncTextureInfoProcessor().

texture_processor_vtbl

ID3DX10DataProcessorVtbl texture_processor_vtbl

static

Initial value:

=
{
    texture_processor_Process,
    texture_processor_CreateDeviceObject,
    texture_processor_Destroy
}

Definition at line 374 of file async.c.

Referenced by D3DX10CreateAsyncTextureProcessor().

thread_pump_vtbl

const ID3DX10ThreadPumpVtbl thread_pump_vtbl

static

Initial value:

=
{
    thread_pump_QueryInterface,
    thread_pump_AddRef,
    thread_pump_Release,
    thread_pump_AddWorkItem,
    thread_pump_GetWorkItemCount,
    thread_pump_WaitForAllItems,
    thread_pump_ProcessDeviceWorkItems,
    thread_pump_PurgeAllItems,
    thread_pump_GetQueueStatus
}

Definition at line 898 of file async.c.

Referenced by D3DX10CreateThreadPump().