Khaganat-NeL/khanat-opennel-code
2
0
Fork 0
Code Issues 21 Pull requests Projects Releases 1 Packages Wiki Activity

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

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

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