eeva/jamulus
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

bug fix with mutexs

Browse source
This commit is contained in:
Volker Fischer 2006-02-27 20:27:47 +00:00
parent e15c2497e5
commit ab19f4f2ae
1 changed files with 5 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
src/channel.cpp
View file

@ -225,22 +225,12 @@ CChannel::CChannel ()
void CChannel::SetSockBufSize ( const int iNewBlockSize, const int iNumBlocks )
{
/* this opperation must be done with mutex */
qDebug ( "before lock" );
/* this opperation must be done with mutex */
Mutex.lock ();
SockBuf.Init ( iNewBlockSize, iNumBlocks );
qDebug ( "in lock" );
Mutex.unlock ();
qDebug ( "after lock" );
}
void CChannel::OnJittBufSizeChange ( int iNewJitBufSize )
@ -267,8 +257,6 @@ bool CChannel::PutData ( const CVector<unsigned char>& vecbyData,
{
bool bRet = true;
Mutex.lock (); /* put mutex lock */
/* only process if packet has correct size */
if ( iNumBytes == iAudComprSize )
{
@ -291,7 +279,11 @@ for (int i = 0; i < BLOCK_SIZE_SAMPLES; i++)
vecdResOutData[i] = (double) vecsDecomprAudio[i];
Mutex.lock (); /* put mutex lock */
bRet = SockBuf.Put ( vecdResOutData );
Mutex.unlock (); /* put mutex unlock */
/* reset time-out counter */
iConTimeOut = CON_TIME_OUT_CNT_MAX;
@ -305,8 +297,6 @@ for (int i = 0; i < BLOCK_SIZE_SAMPLES; i++)
bRet = Protocol.ParseMessage ( vecbyData, iNumBytes );
}
Mutex.unlock (); /* put mutex unlock */
return bRet;
}