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

test

Browse source
This commit is contained in:
Volker Fischer 2006-03-06 18:33:23 +00:00
parent 557045ecab
commit ce72d87673
1 changed files with 12 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
src/protocol.cpp
View file

@ -147,12 +147,12 @@ void CProtocol::CreateAndSendAcknMess ( const int& iID, const int& iCnt )
*/ */
void CProtocol::DeleteSendMessQueue() void CProtocol::DeleteSendMessQueue()
{ {
Mutex.lock(); // Mutex.lock();
{ // {
// delete complete "send message queue" // delete complete "send message queue"
SendMessQueue.clear(); SendMessQueue.clear();
} // }
Mutex.unlock(); // Mutex.unlock();
} }
void CProtocol::OnTimerSendMess() void CProtocol::OnTimerSendMess()
@ -170,8 +170,8 @@ bool CProtocol::ParseMessage ( const CVector<unsigned char>& vecbyData,
/* /*
return code: true -> ok; false -> error return code: true -> ok; false -> error
*/ */
// Mutex.lock(); Mutex.lock();
// { {
int iRecCounter, iRecID, iData; int iRecCounter, iRecID, iData;
unsigned int iPos; unsigned int iPos;
CVector<uint8_t> vecData; CVector<uint8_t> vecData;
@ -250,14 +250,14 @@ for ( int i = 0; i < iNumBytes; i++ ) {
{ {
return false; // return error code return false; // return error code
} }
// } }
// Mutex.unlock(); Mutex.unlock();
} }
void CProtocol::CreateJitBufMes ( const int iJitBufSize ) void CProtocol::CreateJitBufMes ( const int iJitBufSize )
{ {
Mutex.lock(); // Mutex.lock();
{ // {
CVector<uint8_t> vecNewMessage; CVector<uint8_t> vecNewMessage;
CVector<uint8_t> vecData ( 2 ); // 2 bytes of data CVector<uint8_t> vecData ( 2 ); // 2 bytes of data
unsigned int iPos = 0; // init position pointer unsigned int iPos = 0; // init position pointer
@ -276,8 +276,8 @@ void CProtocol::CreateJitBufMes ( const int iJitBufSize )
// enqueue message // enqueue message
EnqueueMessage ( vecNewMessage, iCurCounter, PROTMESSID_JITT_BUF_SIZE ); EnqueueMessage ( vecNewMessage, iCurCounter, PROTMESSID_JITT_BUF_SIZE );
} // }
Mutex.unlock(); // Mutex.unlock();
} }