summaryrefslogtreecommitdiff
path: root/wpd/WpdServiceSampleDriver/WpdObjectResources.h
blob: 1f8c4a0a447fb5269470b7eaad67a350caead8b0 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
#pragma once

#define FILE_OPTIMAL_READ_BUFFER_SIZE_VALUE  (2 * 1024 * 1024)
#define FILE_OPTIMAL_WRITE_BUFFER_SIZE_VALUE (2 * 1024 * 1024)

// This class is used to store the context for a specific resource operation.
class WpdObjectResourceContext : public IUnknown
{
public:
    WpdObjectResourceContext() :
        m_cRef(1),
        m_Resource(WPD_RESOURCE_DEFAULT),
        m_BytesTransferred(0),
        m_BytesTotal(0),
        m_Scope(FULL_DEVICE_ACCESS)
    {

    }

    ~WpdObjectResourceContext()
    {

    }

public: // IUnknown
    ULONG __stdcall AddRef()
    {
        InterlockedIncrement((long*) &m_cRef);
        return m_cRef;
    }

    _At_(this, __drv_freesMem(Mem)) 
    ULONG __stdcall Release()
    {
        ULONG ulRefCount = m_cRef - 1;

        if (InterlockedDecrement((long*) &m_cRef) == 0)
        {
            delete this;
            return 0;
        }
        return ulRefCount;
    }

    HRESULT __stdcall QueryInterface(
        REFIID riid,
        void** ppv)
    {
        HRESULT hr = S_OK;

        if(riid == IID_IUnknown)
        {
            *ppv = static_cast<IUnknown*>(this);
            AddRef();
        }
        else
        {
            *ppv = NULL;
            hr = E_NOINTERFACE;
        }

        return hr;
    }

private:
    DWORD m_cRef;

// WpdObjectResourceContext specific data
public:
    CAtlStringW  m_strObjectID;      // object identifier of the object whose resource is being transferred
    PROPERTYKEY  m_Resource;         // the specific resource being transferred
    ULONGLONG    m_BytesTransferred; // number of bytes transferred from the resource to the caller
    ULONGLONG    m_BytesTotal;       // total number of bytes of the resource data
    ACCESS_SCOPE m_Scope;            // client access scope
};

class WpdObjectResources
{
public:
    WpdObjectResources();
    virtual ~WpdObjectResources();
    
    HRESULT Initialize(_In_ FakeDevice* pDevice);
    
    HRESULT DispatchWpdMessage(
        _In_     REFPROPERTYKEY         Command,
        _In_     IPortableDeviceValues* pParams,
        _In_     IPortableDeviceValues* pResults);

    HRESULT OnGetSupportedResources(
        _In_    IPortableDeviceValues*  pParams,
        _In_    IPortableDeviceValues*  pResults);

    HRESULT OnGetResourceAttributes(
        _In_    IPortableDeviceValues*  pParams,
        _In_    IPortableDeviceValues*  pResults);

    HRESULT OnOpenResource(
        _In_    IPortableDeviceValues*  pParams,
        _In_    IPortableDeviceValues*  pResults);

    HRESULT OnReadResource(
        _In_    IPortableDeviceValues*  pParams,
        _In_    IPortableDeviceValues*  pResults);

    HRESULT OnCloseResource(
        _In_    IPortableDeviceValues*  pParams,
        _In_    IPortableDeviceValues*  pResults);

private:
    FakeDevice* m_pDevice;
};