From Stephan Huber and Riccardo Corsi, port of QuickTime plugin to Windows
This commit is contained in:
Robert Osfield
@@ -1,27 +1,27 @@
|
||||
// -*-c++-*-
|
||||
|
||||
/*
|
||||
* Copyright (C) 2004 Stephan Huber http://digitalmind.de
|
||||
*
|
||||
*
|
||||
* The Open Scene Graph (OSG) is a cross platform C++/OpenGL library for
|
||||
* real-time rendering of large 3D photo-realistic models.
|
||||
* The OSG homepage is http://www.openscenegraph.org/
|
||||
*
|
||||
* This software is free software; you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation; either version 2 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This software 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 General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program; if not, write to the Free Software
|
||||
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
||||
*/
|
||||
* Copyright (C) 2004 Stephan Huber http://digitalmind.de
|
||||
*
|
||||
*
|
||||
* The Open Scene Graph (OSG) is a cross platform C++/OpenGL library for
|
||||
* real-time rendering of large 3D photo-realistic models.
|
||||
* The OSG homepage is http://www.openscenegraph.org/
|
||||
*
|
||||
* This software is free software; you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation; either version 2 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This software 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 General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program; if not, write to the Free Software
|
||||
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
||||
*/
|
||||
|
||||
#include "QuicktimeImageStream.h"
|
||||
#include <osg/Notify>
|
||||
@@ -34,201 +34,254 @@
|
||||
#include "MovieData.h"
|
||||
|
||||
|
||||
using namespace osg;
|
||||
|
||||
#define IDLE_TIMEOUT 150000L
|
||||
#define ERR_MSG(no,msg) osg::notify(osg::WARN) << "QT-ImageStream: " << msg << " failed with error " << no << std::endl;
|
||||
|
||||
static OpenThreads::Mutex* s_qtMutex = new OpenThreads::Mutex;
|
||||
|
||||
int QuicktimeImageStream::_qtInstanceCount = 0;
|
||||
|
||||
// Constructor: setup and start thread
|
||||
QuicktimeImageStream::QuicktimeImageStream(std::string fileName) : ImageStream()
|
||||
{
|
||||
// ricky
|
||||
if(_qtInstanceCount == 0)
|
||||
{
|
||||
OpenThreads::ScopedLock<OpenThreads::Mutex> lock(*s_qtMutex);
|
||||
osg::notify(osg::NOTICE) << "quicktime Init" << std::endl;
|
||||
initQuicktime();
|
||||
}
|
||||
++ _qtInstanceCount;
|
||||
// end ricky
|
||||
|
||||
{
|
||||
OpenThreads::ScopedLock<OpenThreads::Mutex> lock(*s_qtMutex);
|
||||
osgQuicktime::initQuicktime();
|
||||
}
|
||||
|
||||
_len = 0;
|
||||
|
||||
_data = new MovieData();
|
||||
|
||||
for (int i = 0; i < NUM_CMD_INDEX; i++)
|
||||
_cmd[i] = THREAD_IDLE;
|
||||
_wrIndex = _rdIndex = 0;
|
||||
_len = 0;
|
||||
_data = new MovieData();
|
||||
|
||||
load(fileName);
|
||||
for (int i = 0; i < NUM_CMD_INDEX; i++)
|
||||
_cmd[i] = THREAD_IDLE;
|
||||
_wrIndex = _rdIndex = 0;
|
||||
|
||||
if (!fileName.empty())
|
||||
setFileName(fileName);
|
||||
load(fileName);
|
||||
|
||||
if (!fileName.empty())
|
||||
setFileName(fileName);
|
||||
|
||||
// ricky
|
||||
_status = ImageStream::PAUSED;
|
||||
}
|
||||
|
||||
|
||||
// Deconstructor: stop and terminate thread
|
||||
QuicktimeImageStream::~QuicktimeImageStream()
|
||||
{
|
||||
if( isRunning() )
|
||||
{
|
||||
quit(true);
|
||||
}
|
||||
|
||||
if( isRunning() )
|
||||
{
|
||||
quit(true);
|
||||
}
|
||||
// ricky
|
||||
-- _qtInstanceCount;
|
||||
if(_qtInstanceCount == 0)
|
||||
{
|
||||
OpenThreads::ScopedLock<OpenThreads::Mutex> lock(*s_qtMutex);
|
||||
osg::notify(osg::NOTICE) << "quicktime Exit" << std::endl;
|
||||
exitQuicktime();
|
||||
}
|
||||
// end ricky
|
||||
|
||||
// clean up quicktime movies.
|
||||
{
|
||||
OpenThreads::ScopedLock<OpenThreads::Mutex> lock(*s_qtMutex);
|
||||
delete _data;
|
||||
}
|
||||
// clean up quicktime movies.
|
||||
{
|
||||
OpenThreads::ScopedLock<OpenThreads::Mutex> lock(*s_qtMutex);
|
||||
delete _data;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
// Set command
|
||||
void QuicktimeImageStream::setCmd(ThreadCommand cmd)
|
||||
void QuicktimeImageStream::setCmd(ThreadCommand cmd, float rate)
|
||||
{
|
||||
OpenThreads::ScopedLock<OpenThreads::Mutex> lock(_mutex);
|
||||
OpenThreads::ScopedLock<OpenThreads::Mutex> lock(_mutex);
|
||||
|
||||
_cmd[_wrIndex] = cmd;
|
||||
_wrIndex = (_wrIndex + 1) % NUM_CMD_INDEX;
|
||||
_cmd[_wrIndex] = cmd;
|
||||
_rates[_wrIndex] = rate;
|
||||
_wrIndex = (_wrIndex + 1) % NUM_CMD_INDEX;
|
||||
}
|
||||
|
||||
|
||||
// Get command
|
||||
QuicktimeImageStream::ThreadCommand QuicktimeImageStream::getCmd()
|
||||
{
|
||||
ThreadCommand cmd = THREAD_IDLE;
|
||||
ThreadCommand cmd = THREAD_IDLE;
|
||||
|
||||
OpenThreads::ScopedLock<OpenThreads::Mutex> lock(_mutex);
|
||||
OpenThreads::ScopedLock<OpenThreads::Mutex> lock(_mutex);
|
||||
|
||||
if (_rdIndex != _wrIndex) {
|
||||
cmd = _cmd[_rdIndex];
|
||||
_rdIndex = (_rdIndex + 1) % NUM_CMD_INDEX;
|
||||
}
|
||||
if (_rdIndex != _wrIndex) {
|
||||
cmd = _cmd[_rdIndex];
|
||||
_currentRate = _rates[_rdIndex];
|
||||
_rdIndex = (_rdIndex + 1) % NUM_CMD_INDEX;
|
||||
}
|
||||
|
||||
return cmd;
|
||||
return cmd;
|
||||
}
|
||||
|
||||
|
||||
void QuicktimeImageStream::load(std::string fileName)
|
||||
{
|
||||
osg::notify(osg::DEBUG_INFO) << "QT-ImageStream: loading quicktime movie from " << fileName << std::endl;
|
||||
|
||||
OpenThreads::ScopedLock<OpenThreads::Mutex> lock(*s_qtMutex);
|
||||
osg::notify(osg::DEBUG_INFO) << "QT-ImageStream: loading quicktime movie from " << fileName << std::endl;
|
||||
|
||||
OpenThreads::ScopedLock<OpenThreads::Mutex> lock(*s_qtMutex);
|
||||
|
||||
_data->load(this, fileName);
|
||||
|
||||
_len = _data->getMovieDuration();
|
||||
_current = 0;
|
||||
|
||||
|
||||
_data->load(this, fileName);
|
||||
|
||||
_len = _data->getMovieDuration();
|
||||
|
||||
|
||||
}
|
||||
|
||||
void QuicktimeImageStream::quit(bool wiatForThreadToExit)
|
||||
{
|
||||
osg::notify(osg::DEBUG_INFO)<<"Sending quit"<<this<<std::endl;
|
||||
setCmd(THREAD_QUIT);
|
||||
osg::notify(osg::DEBUG_INFO)<<"Sending quit"<<this<<std::endl;
|
||||
setCmd(THREAD_QUIT);
|
||||
|
||||
if (wiatForThreadToExit)
|
||||
{
|
||||
while(isRunning())
|
||||
{
|
||||
osg::notify(osg::DEBUG_INFO)<<"Waiting for QuicktimeImageStream to quit"<<this<<std::endl;
|
||||
OpenThreads::Thread::YieldCurrentThread();
|
||||
}
|
||||
osg::notify(osg::DEBUG_INFO)<<"QuicktimeImageStream has quit"<<this<<std::endl;
|
||||
}
|
||||
if (wiatForThreadToExit)
|
||||
{
|
||||
while(isRunning())
|
||||
{
|
||||
osg::notify(osg::DEBUG_INFO)<<"Waiting for QuicktimeImageStream to quit"<<this<<std::endl;
|
||||
OpenThreads::Thread::YieldCurrentThread();
|
||||
}
|
||||
osg::notify(osg::DEBUG_INFO)<<"QuicktimeImageStream has quit"<<this<<std::endl;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void QuicktimeImageStream::run()
|
||||
{
|
||||
|
||||
bool playing = false;
|
||||
bool done = false;
|
||||
//OSErr err;
|
||||
|
||||
// err = EnterMoviesOnThread(0);
|
||||
// ERR_MSG(err,"EnterMoviesOnThread");
|
||||
|
||||
while (!done) {
|
||||
// osg::notify(osg::ALWAYS) << "movietime: " << _data->getMovieTime() << " state " << getCmd() << std::endl;
|
||||
// Handle commands
|
||||
ThreadCommand cmd = getCmd();
|
||||
bool playing = false;
|
||||
bool done = false;
|
||||
|
||||
float currentTime=0.0f;
|
||||
|
||||
{
|
||||
OpenThreads::ScopedLock<OpenThreads::Mutex> lock(*s_qtMutex);
|
||||
/*
|
||||
OSErr err;
|
||||
err = EnterMoviesOnThread(0);
|
||||
ERR_MSG(err,"EnterMoviesOnThread");
|
||||
err = AttachMovieToCurrentThread(_data->getMovie());
|
||||
*/
|
||||
while (!done) {
|
||||
|
||||
if (cmd != THREAD_IDLE) {
|
||||
switch (cmd) {
|
||||
|
||||
ThreadCommand cmd = getCmd();
|
||||
osg::notify(osg::DEBUG_INFO) << "movietime: " << _data->getMovieTime() << " rate: " << _data->getMovieRate() << " state " << cmd << " playing: " << playing << " done " << done << " " << _wrIndex << "/" << _rdIndex << std::endl;
|
||||
// Handle commands
|
||||
{
|
||||
OpenThreads::ScopedLock<OpenThreads::Mutex> lock(*s_qtMutex);
|
||||
|
||||
if (cmd != THREAD_IDLE) {
|
||||
osg::notify(osg::DEBUG_INFO) << "new cmd: " << cmd << std::endl;
|
||||
switch (cmd) {
|
||||
case THREAD_START: // Start or continue stream
|
||||
StartMovie(_data->getMovie());
|
||||
playing = true;
|
||||
break;
|
||||
_data->setMovieRate(1.0f);
|
||||
|
||||
playing = true;
|
||||
break;
|
||||
|
||||
case THREAD_STOP:
|
||||
SetMovieRate(_data->getMovie(),0);
|
||||
osg::notify(INFO) << "QT-ImageStream: stop at "<< std::endl;
|
||||
playing = false;
|
||||
break;
|
||||
_data->setMovieRate(0);
|
||||
osg::notify(osg::INFO) << "QT-ImageStream: stop at "<< std::endl;
|
||||
playing = false;
|
||||
break;
|
||||
|
||||
case THREAD_REWIND:
|
||||
SetMovieRate(_data->getMovie(),0);
|
||||
GoToBeginningOfMovie(_data->getMovie());
|
||||
break;
|
||||
SetMovieRate(_data->getMovie(),0);
|
||||
GoToBeginningOfMovie(_data->getMovie());
|
||||
break;
|
||||
|
||||
case THREAD_FORWARD:
|
||||
SetMovieRate(_data->getMovie(),0);
|
||||
GoToEndOfMovie(_data->getMovie());
|
||||
break;
|
||||
|
||||
case THREAD_SEEK:
|
||||
_data->setMovieTime(_currentRate);
|
||||
playing = true;
|
||||
break;
|
||||
|
||||
case THREAD_SETRATE:
|
||||
_data->setMovieRate(_currentRate);
|
||||
playing = (_currentRate != 0.0f);
|
||||
break;
|
||||
|
||||
case THREAD_CLOSE:
|
||||
SetMovieRate(_data->getMovie(),0);
|
||||
break;
|
||||
_data->setMovieRate(0);
|
||||
break;
|
||||
|
||||
case THREAD_QUIT: // TODO
|
||||
SetMovieRate(_data->getMovie(),0);
|
||||
osg::notify(INFO) << "QT-ImageStream: quit" << std::endl;
|
||||
//playing = false;
|
||||
done = true;
|
||||
break;
|
||||
_data->setMovieRate(0);
|
||||
osg::notify(osg::INFO) << "QT-ImageStream: quit" << std::endl;
|
||||
//playing = false;
|
||||
done = true;
|
||||
break;
|
||||
default:
|
||||
osg::notify(osg::WARN) << "QT-ImageStream: Unknown command " << cmd << std::endl;
|
||||
break;
|
||||
}
|
||||
osg::notify(osg::WARN) << "QT-ImageStream: Unknown command " << cmd << std::endl;
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
MoviesTask(_data->getMovie(),0);
|
||||
MoviesTask(_data->getMovie(),0);
|
||||
_current = _data->getMovieTime();
|
||||
}
|
||||
|
||||
currentTime = _data->getMovieTime();
|
||||
}
|
||||
|
||||
|
||||
if (_lastUpdate!= currentTime)
|
||||
{
|
||||
if (_lastUpdate!= _current)
|
||||
{
|
||||
// force the texture to update the image
|
||||
dirty();
|
||||
// update internal time and take care of looping
|
||||
_lastUpdate = _current;
|
||||
|
||||
dirty();
|
||||
_lastUpdate = currentTime;
|
||||
|
||||
if (currentTime>=_data->getMovieDuration())
|
||||
{
|
||||
if (getLoopingMode()==LOOPING)
|
||||
{
|
||||
rewind();
|
||||
play();
|
||||
}
|
||||
else
|
||||
{
|
||||
pause();
|
||||
}
|
||||
if (getLoopingMode() == LOOPING)
|
||||
{
|
||||
// loopen wir rueckwaerts?
|
||||
if ((_current <= 0.0f) && (_data->getCachedMovieRate() < 0.0f)) {
|
||||
forward();
|
||||
setMovieRate(_data->getCachedMovieRate());
|
||||
}
|
||||
// loppen wir vorw<72>rts?
|
||||
else if ((_current >= _len) && (_data->getCachedMovieRate() > 0.0f))
|
||||
{
|
||||
rewind();
|
||||
setMovieRate(_data->getCachedMovieRate());
|
||||
}
|
||||
}
|
||||
else
|
||||
{ // NO LOOPING
|
||||
//ricky
|
||||
if(_current >= _len)
|
||||
{
|
||||
pause();
|
||||
rewind();
|
||||
}
|
||||
// orig
|
||||
//pause();
|
||||
|
||||
}
|
||||
|
||||
if (playing)
|
||||
{
|
||||
// TODO
|
||||
}
|
||||
else if (!done)
|
||||
{
|
||||
OpenThreads::Thread::microSleep(IDLE_TIMEOUT);
|
||||
}
|
||||
}
|
||||
// err = ExitMoviesOnThread();
|
||||
//ERR_MSG(err,"ExitMoviesOnThread");
|
||||
}
|
||||
}
|
||||
|
||||
if (playing)
|
||||
{
|
||||
OpenThreads::Thread::microSleep(16000);
|
||||
}
|
||||
else if (!done)
|
||||
{
|
||||
OpenThreads::Thread::microSleep(IDLE_TIMEOUT);
|
||||
}
|
||||
}
|
||||
/*
|
||||
err = DetachMovieFromCurrentThread(_data->getMovie());
|
||||
err = ExitMoviesOnThread();
|
||||
ERR_MSG(err,"ExitMoviesOnThread");
|
||||
*/
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user