diff -r 000000000000 -r 1918ee327afb src/3rdparty/phonon/ds9/qasyncreader.h --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/3rdparty/phonon/ds9/qasyncreader.h Mon Jan 11 14:00:40 2010 +0000 @@ -0,0 +1,75 @@ +/* This file is part of the KDE project. + +Copyright (C) 2009 Nokia Corporation and/or its subsidiary(-ies). + +This library is free software: you can redistribute it and/or modify +it under the terms of the GNU Lesser General Public License as published by +the Free Software Foundation, either version 2.1 or 3 of the License. + +This library is distributed in the hope that it will be useful, +but WITHOUT ANY WARRANTY; without even the implied warranty of +MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +GNU Lesser General Public License for more details. + +You should have received a copy of the GNU Lesser General Public License +along with this library. If not, see . +*/ + +#ifndef PHONON_QASYNCREADER_H +#define PHONON_QASYNCREADER_H + +#include +#include +#include + +#include "qpin.h" + +QT_BEGIN_NAMESPACE + +namespace Phonon +{ + namespace DS9 + { + //his class reads asynchronously from a QIODevice + class QAsyncReader : public QPin, public IAsyncReader + { + public: + QAsyncReader(QBaseFilter *, const QVector &mediaTypes); + ~QAsyncReader(); + + //reimplementation from IUnknown + STDMETHODIMP QueryInterface(REFIID iid, void** out); + STDMETHODIMP_(ULONG) AddRef(); + STDMETHODIMP_(ULONG) Release(); + + //reimplementation from IAsyncReader + STDMETHODIMP RequestAllocator(IMemAllocator *,ALLOCATOR_PROPERTIES *,IMemAllocator **); + STDMETHODIMP Request(IMediaSample *,DWORD_PTR); + STDMETHODIMP WaitForNext(DWORD,IMediaSample **,DWORD_PTR *); + STDMETHODIMP SyncReadAligned(IMediaSample *); + STDMETHODIMP SyncRead(LONGLONG,LONG,BYTE *); + STDMETHODIMP Length(LONGLONG *,LONGLONG *) = 0; + STDMETHODIMP BeginFlush(); + STDMETHODIMP EndFlush(); + + protected: + STDMETHODIMP syncReadAlignedUnlocked(IMediaSample *); + virtual HRESULT read(LONGLONG pos, LONG length, BYTE *buffer, LONG *actual) = 0; + + private: + struct AsyncRequest + { + AsyncRequest(IMediaSample *s = 0, DWORD_PTR u = 0) : sample(s), user(u) {} + IMediaSample *sample; + DWORD_PTR user; + }; + + QQueue m_requestQueue; + QWaitCondition m_requestWait; + }; + } +} + +QT_END_NAMESPACE + +#endif