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

bug fix

Browse source
This commit is contained in:
Volker Fischer 2006-03-04 16:49:11 +00:00
parent 0bc32bf296
commit 1595a7446b
1 changed files with 9 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
src/protocol.cpp
View file

@ -156,8 +156,6 @@ for ( int i = 0; i < iNumBytes; i++ ) {
} }
// important: vecbyDataConv must have iNumBytes to get it work!!! // important: vecbyDataConv must have iNumBytes to get it work!!!
if ( ParseMessageFrame ( vecbyDataConv, iRecCounter, iRecID, vecData ) ) if ( ParseMessageFrame ( vecbyDataConv, iRecCounter, iRecID, vecData ) )
{ {
@ -248,18 +246,21 @@ void CProtocol::CreateJitBufMes ( const int iJitBufSize )
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
// build data vector // store current counter value
PutValOnStream ( vecData, iPos, static_cast<uint32_t> ( iJitBufSize ), 2 ); const int iCurCounter = iCounter;
// build complete message
GenMessageFrame ( vecNewMessage, iCounter, PROTMESSID_JITT_BUF_SIZE, vecData );
// increase counter (wraps around automatically) // increase counter (wraps around automatically)
// TODO: make it thread safe!!!!!!!!!!!! // TODO: make it thread safe!!!!!!!!!!!!
iCounter++; iCounter++;
// build data vector
PutValOnStream ( vecData, iPos, static_cast<uint32_t> ( iJitBufSize ), 2 );
// build complete message
GenMessageFrame ( vecNewMessage, iCurCounter, PROTMESSID_JITT_BUF_SIZE, vecData );
// enqueue message // enqueue message
EnqueueMessage ( vecNewMessage, iCounter, PROTMESSID_JITT_BUF_SIZE ); EnqueueMessage ( vecNewMessage, iCurCounter, PROTMESSID_JITT_BUF_SIZE );
} }