mfstream_p.h - mozsearch

Enable keyboard shortcuts

// Copyright (C) 2016 The Qt Company Ltd.

// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR LGPL-3.0-only OR GPL-2.0-only OR GPL-3.0-only

#ifndef MFSTREAM_H

#define MFSTREAM_H

//

//  W A R N I N G

//  -------------

//

// This file is not part of the Qt API.  It exists purely as an

// implementation detail.  This header file may change from version to

// version without notice, or even be removed.

//

// We mean it.

//

#include <QtCore/qcoreevent.h>

#include <QtCore/qiodevice.h>

#include <QtCore/qmutex.h>

#include <QtCore/qpointer.h>

#include <QtCore/private/qcomobject_p.h>

#include <QtCore/private/qcomptr_p.h>

#include <mfapi.h>

#include <mfidl.h>

QT_BEGIN_NAMESPACE

class MFStream : public QObject, public QComObjectWithDeleteLater<MFStream, IMFByteStream>

    Q_OBJECT

public:

    MFStream(QIODevice *stream, bool ownStream, bool synchronous = false);

    ~MFStream();

    //from IMFByteStream

    STDMETHODIMP GetCapabilities(DWORD *pdwCapabilities) override;

    STDMETHODIMP GetLength(QWORD *pqwLength) override;

    STDMETHODIMP SetLength(QWORD) override;

    STDMETHODIMP GetCurrentPosition(QWORD *pqwPosition) override;

    STDMETHODIMP SetCurrentPosition(QWORD qwPosition) override;

    STDMETHODIMP IsEndOfStream(BOOL *pfEndOfStream) override;

    STDMETHODIMP Read(BYTE *pb, ULONG cb, ULONG *pcbRead) override;

    STDMETHODIMP BeginRead(BYTE *pb, ULONG cb, IMFAsyncCallback *pCallback,

                           IUnknown *punkState) override;

    STDMETHODIMP EndRead(IMFAsyncResult* pResult, ULONG *pcbRead) override;

    STDMETHODIMP Write(const BYTE *, ULONG, ULONG *) override;

    STDMETHODIMP BeginWrite(const BYTE *, ULONG ,

                            IMFAsyncCallback *,

                            IUnknown *) override;

    STDMETHODIMP EndWrite(IMFAsyncResult *,

                          ULONG *) override;

    STDMETHODIMP Seek(

        MFBYTESTREAM_SEEK_ORIGIN SeekOrigin,

        LONGLONG llSeekOffset,

        DWORD,

        QWORD *pqwCurrentPosition) override;

    STDMETHODIMP Flush() override;

    STDMETHODIMP Close() override;

private:

    class AsyncReadState : public QComObject<IUnknown>

    public:

        AsyncReadState(BYTE *pb, ULONG cb);

        BYTE* pb() const;

        ULONG cb() const;

        ULONG bytesRead() const;

        void setBytesRead(ULONG cbRead);

    private:

        BYTE *m_pb;

        ULONG m_cb;

        ULONG m_cbRead;

};

    QPointer<QIODevice> m_stream;

    bool m_ownStream;

    bool m_synchronous;

    DWORD m_workQueueId;

    QMutex m_mutex;

    void doRead();

    ULONG m_syncReadCount = 0;

protected:

    void customEvent(QEvent *event) override;

    ComPtr<IMFAsyncResult> m_currentReadResult;

};

QT_END_NAMESPACE

#endif