/* 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" | |