qmgr.c File Reference

#include "qmgr.h"
#include "wine/debug.h"

Include dependency graph for qmgr.c:

Go to the source code of this file.

Functions
	WINE_DEFAULT_DEBUG_CHANNEL (qmgr)
static HRESULT WINAPI	BackgroundCopyManager_QueryInterface (IBackgroundCopyManager *iface, REFIID riid, void **ppv)
static ULONG WINAPI	BackgroundCopyManager_AddRef (IBackgroundCopyManager *iface)
static ULONG WINAPI	BackgroundCopyManager_Release (IBackgroundCopyManager *iface)
static HRESULT WINAPI	BackgroundCopyManager_CreateJob (IBackgroundCopyManager *iface, LPCWSTR DisplayName, BG_JOB_TYPE Type, GUID *pJobId, IBackgroundCopyJob **ppJob)
static HRESULT WINAPI	BackgroundCopyManager_GetJob (IBackgroundCopyManager *iface, REFGUID jobID, IBackgroundCopyJob **job)
static HRESULT WINAPI	BackgroundCopyManager_EnumJobs (IBackgroundCopyManager *iface, DWORD flags, IEnumBackgroundCopyJobs **ppEnum)
static HRESULT WINAPI	BackgroundCopyManager_GetErrorDescription (IBackgroundCopyManager *iface, HRESULT hr, DWORD langid, LPWSTR *error_description)
HRESULT	BackgroundCopyManagerConstructor (LPVOID *ppObj)
DWORD WINAPI	fileTransfer (void *param)

Variables
BackgroundCopyManagerImpl	globalMgr
static const IBackgroundCopyManagerVtbl	BackgroundCopyManagerVtbl

Function Documentation

BackgroundCopyManager_AddRef()

static ULONG WINAPI BackgroundCopyManager_AddRef ( IBackgroundCopyManager *  iface )

static

Definition at line 44 of file qmgr.c.

{
    return 2;
}

BackgroundCopyManager_CreateJob()

static HRESULT WINAPI BackgroundCopyManager_CreateJob ( IBackgroundCopyManager *  iface, LPCWSTR  DisplayName, BG_JOB_TYPE  Type, GUID *  pJobId, IBackgroundCopyJob **  ppJob  )

static

Definition at line 56 of file qmgr.c.

{
    BackgroundCopyJobImpl *job;
    HRESULT hres;
 
    TRACE("(%s %d %p %p)\n", debugstr_w(DisplayName), Type, pJobId, ppJob);
 
    hres = BackgroundCopyJobConstructor(DisplayName, Type, pJobId, &job);
    if (FAILED(hres))
        return hres;
 
    /* Add a reference to the job to job list */
    *ppJob = (IBackgroundCopyJob *)&job->IBackgroundCopyJob3_iface;
    IBackgroundCopyJob_AddRef(*ppJob);
    EnterCriticalSection(&globalMgr.cs);
    list_add_head(&globalMgr.jobs, &job->entryFromQmgr);
    LeaveCriticalSection(&globalMgr.cs);
    return S_OK;
}

BackgroundCopyManager_EnumJobs()

static HRESULT WINAPI BackgroundCopyManager_EnumJobs ( IBackgroundCopyManager *  iface, DWORD  flags, IEnumBackgroundCopyJobs **  ppEnum  )

static

Definition at line 108 of file qmgr.c.

{
    TRACE("(0x%x %p)\n", flags, ppEnum);
    return enum_copy_job_create(&globalMgr, ppEnum);
}

BackgroundCopyManager_GetErrorDescription()

static HRESULT WINAPI BackgroundCopyManager_GetErrorDescription ( IBackgroundCopyManager *  iface, HRESULT  hr, DWORD  langid, LPWSTR *  error_description  )

static

Definition at line 115 of file qmgr.c.

{
    FIXME("(0x%08x 0x%x %p): stub\n", hr, langid, error_description);
    return E_NOTIMPL;
}

BackgroundCopyManager_GetJob()

static HRESULT WINAPI BackgroundCopyManager_GetJob ( IBackgroundCopyManager *  iface, REFGUID  jobID, IBackgroundCopyJob **  job  )

static

Definition at line 77 of file qmgr.c.

{
    BackgroundCopyManagerImpl *qmgr = &globalMgr;
    HRESULT hr = BG_E_NOT_FOUND;
    BackgroundCopyJobImpl *cur;
 
    TRACE("(%s %p)\n", debugstr_guid(jobID), job);
 
    if (!job || !jobID) return E_INVALIDARG;
 
    *job = NULL;
 
    EnterCriticalSection(&qmgr->cs);
 
    LIST_FOR_EACH_ENTRY(cur, &qmgr->jobs, BackgroundCopyJobImpl, entryFromQmgr)
    {
        if (IsEqualGUID(&cur->jobId, jobID))
        {
            *job = (IBackgroundCopyJob *)&cur->IBackgroundCopyJob3_iface;
            IBackgroundCopyJob3_AddRef(&cur->IBackgroundCopyJob3_iface);
            hr = S_OK;
            break;
        }
    }
 
    LeaveCriticalSection(&qmgr->cs);
 
    return hr;
}

BackgroundCopyManager_QueryInterface()

static HRESULT WINAPI BackgroundCopyManager_QueryInterface ( IBackgroundCopyManager *  iface, REFIID  riid, void **  ppv  )

static

Definition at line 28 of file qmgr.c.

{
    TRACE("(%s, %p)\n", debugstr_guid(riid), ppv);
 
    if (IsEqualGUID(riid, &IID_IUnknown) || IsEqualGUID(riid, &IID_IBackgroundCopyManager))
    {
        *ppv = iface;
        IBackgroundCopyManager_AddRef(iface);
        return S_OK;
    }
 
    *ppv = NULL;
    return E_NOINTERFACE;
}

BackgroundCopyManager_Release()

static ULONG WINAPI BackgroundCopyManager_Release ( IBackgroundCopyManager *  iface )

static

Definition at line 49 of file qmgr.c.

{
    return 1;
}

BackgroundCopyManagerConstructor()

HRESULT BackgroundCopyManagerConstructor

(

LPVOID *

ppObj

)

Definition at line 141 of file qmgr.c.

{
    TRACE("(%p)\n", ppObj);
    *ppObj = &globalMgr;
    return S_OK;
}

Referenced by BITS_IClassFactory_CreateInstance().

fileTransfer()

DWORD WINAPI fileTransfer

(

void *

param

)

Definition at line 148 of file qmgr.c.

{
    BackgroundCopyManagerImpl *qmgr = &globalMgr;
    HANDLE events[2];
 
    events[0] = stop_event;
    events[1] = qmgr->jobEvent;
 
    for (;;)
    {
        BackgroundCopyJobImpl *job, *jobCur;
        BOOL haveJob = FALSE;
 
        /* Check if it's the stop_event */
        if (WaitForMultipleObjects(2, events, FALSE, INFINITE) == WAIT_OBJECT_0)
        {
            LIST_FOR_EACH_ENTRY_SAFE(job, jobCur, &qmgr->jobs, BackgroundCopyJobImpl, entryFromQmgr)
            {
                list_remove(&job->entryFromQmgr);
                IBackgroundCopyJob3_Release(&job->IBackgroundCopyJob3_iface);
            }
            return 0;
        }
 
        /* Note that other threads may add files to the job list, but only
           this thread ever deletes them so we don't need to worry about jobs
           magically disappearing from the list.  */
        EnterCriticalSection(&qmgr->cs);
 
        LIST_FOR_EACH_ENTRY_SAFE(job, jobCur, &qmgr->jobs, BackgroundCopyJobImpl, entryFromQmgr)
        {
            if (job->state == BG_JOB_STATE_ACKNOWLEDGED || job->state == BG_JOB_STATE_CANCELLED)
            {
                list_remove(&job->entryFromQmgr);
                IBackgroundCopyJob3_Release(&job->IBackgroundCopyJob3_iface);
            }
            else if (job->state == BG_JOB_STATE_QUEUED)
            {
                haveJob = TRUE;
                break;
            }
            else if (job->state == BG_JOB_STATE_CONNECTING
                     || job->state == BG_JOB_STATE_TRANSFERRING)
            {
                ERR("Invalid state for job %p: %d\n", job, job->state);
            }
        }
 
        if (!haveJob)
            ResetEvent(qmgr->jobEvent);
 
        LeaveCriticalSection(&qmgr->cs);
 
        if (haveJob)
            processJob(job);
    }
}

Referenced by ServiceMain().

WINE_DEFAULT_DEBUG_CHANNEL()

WINE_DEFAULT_DEBUG_CHANNEL

(

qmgr

)

Variable Documentation

BackgroundCopyManagerVtbl

const IBackgroundCopyManagerVtbl BackgroundCopyManagerVtbl

static

Initial value:

=
{
    BackgroundCopyManager_QueryInterface,
    BackgroundCopyManager_AddRef,
    BackgroundCopyManager_Release,
    BackgroundCopyManager_CreateJob,
    BackgroundCopyManager_GetJob,
    BackgroundCopyManager_EnumJobs,
    BackgroundCopyManager_GetErrorDescription
}

Definition at line 122 of file qmgr.c.

globalMgr

BackgroundCopyManagerImpl globalMgr

Initial value:

= {
    { &BackgroundCopyManagerVtbl },
    { NULL, -1, 0, 0, 0, 0 },
    NULL,
 
}

Definition at line 26 of file qmgr.c.

Referenced by BackgroundCopyJob_Resume(), BackgroundCopyManager_CreateJob(), BackgroundCopyManager_EnumJobs(), BackgroundCopyManager_GetJob(), BackgroundCopyManagerConstructor(), fileTransfer(), ServiceMain(), and transitionJobState().