--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/3rdparty/phonon/ds9/qasyncreader.cpp	Mon Jan 11 14:00:40 2010 +0000
@@ -0,0 +1,186 @@
+/*  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 <http://www.gnu.org/licenses/>.
+*/
+
+#include "qasyncreader.h"
+#include "qbasefilter.h"
+
+QT_BEGIN_NAMESPACE
+
+namespace Phonon
+{
+    namespace DS9
+    {
+        QAsyncReader::QAsyncReader(QBaseFilter *parent, const QVector<AM_MEDIA_TYPE> &mediaTypes) : QPin(parent, PINDIR_OUTPUT, mediaTypes)
+        {
+        }
+
+        QAsyncReader::~QAsyncReader()
+        {
+        }
+
+        STDMETHODIMP QAsyncReader::QueryInterface(REFIID iid, void **out)
+        {
+            if (!out) {
+                return E_POINTER;
+            }
+
+            if (iid == IID_IAsyncReader) {
+                AddRef();
+                *out = static_cast<IAsyncReader*>(this);
+                return S_OK;
+            }
+
+            return QPin::QueryInterface(iid, out);
+        }
+
+        STDMETHODIMP_(ULONG) QAsyncReader::AddRef()
+        {
+            return QPin::AddRef();
+        }
+
+        STDMETHODIMP_(ULONG) QAsyncReader::Release()
+        {
+            return QPin::Release();
+        }
+
+
+        STDMETHODIMP QAsyncReader::RequestAllocator(IMemAllocator *preferred, ALLOCATOR_PROPERTIES *prop,IMemAllocator **actual)
+        {
+            ALLOCATOR_PROPERTIES prop2;
+
+            if (prop->cbAlign == 0) {
+                prop->cbAlign = 1; //align on 1 char
+            }
+
+            if (preferred && preferred->SetProperties(prop, &prop2) == S_OK) {
+                preferred->AddRef();
+                *actual = preferred;
+                return S_OK;
+            }
+
+            //we should try to create one memory allocator ourselves here
+            return E_FAIL;
+        }
+
+        STDMETHODIMP QAsyncReader::Request(IMediaSample *sample,DWORD_PTR user)
+        {
+            QMutexLocker locker(&m_mutex);
+            if (m_flushing) {
+                return VFW_E_WRONG_STATE;
+            }
+
+            m_requestQueue.enqueue(AsyncRequest(sample, user));
+            m_requestWait.wakeOne();
+            return S_OK;
+        }
+
+        STDMETHODIMP QAsyncReader::WaitForNext(DWORD timeout, IMediaSample **sample, DWORD_PTR *user)
+        {
+            QMutexLocker locker(&m_mutex);
+            if (!sample ||!user) {
+                return E_POINTER;
+            }
+
+            //msdn says to return immediately if we're flushing but that doesn't seem to be true
+            //since it triggers a dead-lock somewhere inside directshow (see task 258830)
+
+            *sample = 0;
+            *user = 0;
+
+            if (m_requestQueue.isEmpty()) {
+                if (m_requestWait.wait(&m_mutex, timeout) == false) {
+                    return VFW_E_TIMEOUT;
+                }
+                if (m_requestQueue.isEmpty()) {
+                    return VFW_E_WRONG_STATE;
+                }
+            }
+
+            AsyncRequest r = m_requestQueue.dequeue();
+
+            //at this point we're sure to have a request to proceed
+            if (r.sample == 0) {
+                return E_FAIL;
+            }
+
+            *sample = r.sample;
+            *user = r.user;
+            return syncReadAlignedUnlocked(r.sample);
+        }
+
+        STDMETHODIMP QAsyncReader::BeginFlush()
+        {
+            QMutexLocker locker(&m_mutex);
+            m_flushing = true;
+            m_requestWait.wakeOne();
+            return S_OK;
+        }
+
+        STDMETHODIMP QAsyncReader::EndFlush()
+        {
+            QMutexLocker locker(&m_mutex);
+            m_flushing = false;
+            return S_OK;
+        }
+
+        STDMETHODIMP QAsyncReader::SyncReadAligned(IMediaSample *sample)
+        {
+            QMutexLocker locker(&m_mutex);
+            return syncReadAlignedUnlocked(sample);
+        }
+
+        STDMETHODIMP QAsyncReader::SyncRead(LONGLONG pos, LONG length, BYTE *buffer)
+        {
+            QMutexLocker locker(&m_mutex);
+            return read(pos, length, buffer, 0);
+        }
+
+
+        STDMETHODIMP QAsyncReader::syncReadAlignedUnlocked(IMediaSample *sample)
+        {
+            Q_ASSERT(!m_mutex.tryLock());
+
+            if (!sample) {
+                return E_POINTER;
+            }
+
+            REFERENCE_TIME start = 0,
+                stop = 0;
+            HRESULT hr = sample->GetTime(&start, &stop);
+            if(FAILED(hr)) {
+                return hr;
+            }
+
+            LONGLONG startPos = start / 10000000;
+            LONG length = static_cast<LONG>((stop - start) / 10000000);
+
+            BYTE *buffer;
+            hr = sample->GetPointer(&buffer);
+            if(FAILED(hr)) {
+                return hr;
+            }
+
+            LONG actual = 0;
+            read(startPos, length, buffer, &actual);
+
+            return sample->SetActualDataLength(actual);
+        }
+
+    }
+}
+
+QT_END_NAMESPACE