aleajactaest/khanat-opennel-code
1
0
Fork 0
mirror of https://port.numenaute.org/aleajactaest/khanat-opennel-code.git synced 2024-11-05 23:09:04 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fixed: #795 Hang when stopping file stream source that is synchronously waiting for play

Browse source
This commit is contained in:
kaetemi 2012-04-11 21:51:01 +02:00
parent f4e097fbfd
commit aa3472e9d1
2 changed files with 12 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
code/nel/src/sound/stream_file_source.cpp
View file

@ -62,10 +62,10 @@ void CStreamFileSource::play()
{
// note: CStreamSource will assert crash if already physically playing!
nldebug("play");
if (m_Thread->isRunning() && m_WaitingForPlay)
{
nldebug("play waiting %s", getStreamFileSound()->getFilePath().c_str());
if (m_NextBuffer || !m_FreeBuffers)
{
CStreamSource::play();
@ -79,6 +79,7 @@ void CStreamFileSource::play()
}
else if (!_Playing)
{
nldebug("play waiting %s", getStreamFileSound()->getFilePath().c_str());
if (!m_WaitingForPlay)
{
// thread may be stopping from stop call
@ -86,7 +87,7 @@ void CStreamFileSource::play()
}
else
{
nlwarning("Already playing");
nlwarning("Already waiting for play");
}
if (!getStreamFileSound()->getAsync())
prepareDecoder();
@ -97,7 +98,7 @@ void CStreamFileSource::play()
if (!getStreamFileSound()->getAsync())
{
// wait until at least one buffer is ready
while (!(m_NextBuffer || !m_FreeBuffers))
while (!(m_NextBuffer || !m_FreeBuffers) && m_WaitingForPlay)
NLMISC::nlSleep(10);
CStreamSource::play();
if (!_Playing)
@ -111,6 +112,11 @@ void CStreamFileSource::play()
mixer->addSourceWaitingForPlay(this);
}
}
else
{
nlwarning("Already playing");
}
/*if (!m_WaitingForPlay)
{
@ -127,7 +133,7 @@ void CStreamFileSource::play()
void CStreamFileSource::stop()
{
nldebug("stop");
nldebug("stop %s", getStreamFileSound()->getFilePath().c_str());
CStreamSource::stop();

2
code/nel/src/sound/stream_source.cpp
View file

@ -264,6 +264,8 @@ void CStreamSource::stop()
_SpawnEndCb(this, _CbUserParam);
delete this;
}
m_WaitingForPlay = false;
}
void CStreamSource::setPos(const NLMISC::CVector& pos)