/*  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 "backendheader.h"

#include "quicktimestreamreader.h"

QT_BEGIN_NAMESPACE

namespace Phonon

{

namespace QT7

{

QuickTimeStreamReader::QuickTimeStreamReader(const Phonon::MediaSource &source)

{

    connectToSource(source);

}

QuickTimeStreamReader::~QuickTimeStreamReader()

{

}

bool QuickTimeStreamReader::readAllData()

{

    int oldSize = m_buffer.size();

    while (m_buffer.size() < m_size){

        needData();

        if (oldSize == currentBufferSize())

            BACKEND_ASSERT3(oldSize != currentBufferSize(),

                "Could not create new movie from IO stream. Not enough free memory to preload the whole movie.",

                FATAL_ERROR, false)

        oldSize = m_buffer.size();

    }

    return true;

}

QByteArray *QuickTimeStreamReader::pointerToData()

{

    return &m_buffer;

}

int QuickTimeStreamReader::readData(long offset, long size, void *data)

{

//    QReadLocker readLocker(&m_lock);

    if (streamSize() != 1 && offset + size > streamSize()){

        size = streamSize() - offset;

    }

    if (currentPos() - currentBufferSize() != offset)

        setCurrentPos(offset);

    int oldSize = currentBufferSize();

    while (currentBufferSize() < int(size)) {

        needData();

        if (oldSize == currentBufferSize())

            break;

        oldSize = currentBufferSize();

    }

    int bytesRead = qMin(currentBufferSize(), int(size));

//    QWriteLocker writeLocker(&m_lock);

    qMemCopy(data, m_buffer.data(), bytesRead);

    m_buffer = m_buffer.mid(bytesRead);

    return bytesRead;

}

void QuickTimeStreamReader::writeData(const QByteArray &data)

{

    QWriteLocker locker(&m_lock);

    m_pos += data.size();

    m_buffer += data;

}

void QuickTimeStreamReader::endOfData()

{

}

void QuickTimeStreamReader::setStreamSize(qint64 newSize)

{

    m_size = newSize;

}

qint64 QuickTimeStreamReader::streamSize() const

{

    return m_size;

}

void QuickTimeStreamReader::setStreamSeekable(bool s)

{

    m_seekable = s;

}

bool QuickTimeStreamReader::streamSeekable() const

{

    return m_seekable;

}

void QuickTimeStreamReader::setCurrentPos(qint64 pos)

{

    QWriteLocker locker(&m_lock);

    m_pos = pos;

    seekStream(pos);

    m_buffer.clear();

}

qint64 QuickTimeStreamReader::currentPos() const

{

    return m_pos;

}

int QuickTimeStreamReader::currentBufferSize() const

{

    QReadLocker locker(&m_lock);

    return m_buffer.size();

}

}} //namespace Phonon::QT7

QT_END_NAMESPACE

#include "moc_quicktimestreamreader.cpp"