diff --git a/DMRNetwork.cpp b/DMRNetwork.cpp index 4ff02f4..0b17fef 100644 --- a/DMRNetwork.cpp +++ b/DMRNetwork.cpp @@ -83,8 +83,8 @@ m_beacon(false) m_streamId[0U] = 0x00U; m_streamId[1U] = 0x00U; - m_jitterBuffers[1U] = new CJitterBuffer(60U, DMR_SLOT_TIME, jitter, 256U); - m_jitterBuffers[2U] = new CJitterBuffer(60U, DMR_SLOT_TIME, jitter, 256U); + m_jitterBuffers[1U] = new CJitterBuffer(60U, DMR_SLOT_TIME, jitter, 256U, debug); + m_jitterBuffers[2U] = new CJitterBuffer(60U, DMR_SLOT_TIME, jitter, 256U, debug); m_id[0U] = id >> 24; m_id[1U] = id >> 16; diff --git a/JitterBuffer.cpp b/JitterBuffer.cpp index 087285d..1fa86fd 100644 --- a/JitterBuffer.cpp +++ b/JitterBuffer.cpp @@ -24,10 +24,11 @@ #include #include -CJitterBuffer::CJitterBuffer(unsigned int blockSize, unsigned int blockTime, unsigned int jitterTime, unsigned int topSequenceNumber) : +CJitterBuffer::CJitterBuffer(unsigned int blockSize, unsigned int blockTime, unsigned int jitterTime, unsigned int topSequenceNumber, bool debug) : m_blockSize(blockSize), m_blockTime(blockTime), m_topSequenceNumber(topSequenceNumber), +m_debug(debug), m_blockCount(0U), m_timer(1000U, 0U, jitterTime), m_stopWatch(), @@ -74,12 +75,14 @@ bool CJitterBuffer::addData(const unsigned char* data, unsigned int length, unsi // Is the data out of sequence? if (headSequenceNumber < tailSequenceNumber) { if (sequenceNumber < headSequenceNumber || sequenceNumber >= tailSequenceNumber) { - LogInfo("JitterBuffer: rejecting frame with seqNo=%u, head=%u, tail=%u", sequenceNumber, headSequenceNumber, tailSequenceNumber); + if (m_debug) + LogDebug("JitterBuffer: rejecting frame with seqNo=%u, head=%u, tail=%u", sequenceNumber, headSequenceNumber, tailSequenceNumber); return false; } } else { if (sequenceNumber >= tailSequenceNumber && sequenceNumber < headSequenceNumber) { - LogInfo("JitterBuffer: rejecting frame with seqNo=%u, head=%u, tail=%u", sequenceNumber, headSequenceNumber, tailSequenceNumber); + if (m_debug) + LogDebug("JitterBuffer: rejecting frame with seqNo=%u, head=%u, tail=%u", sequenceNumber, headSequenceNumber, tailSequenceNumber); return false; } } @@ -94,7 +97,8 @@ bool CJitterBuffer::addData(const unsigned char* data, unsigned int length, unsi // Do we already have the data? if (m_buffer[index].m_length > 0U) { - LogInfo("JitterBuffer: rejecting frame with seqNo=%u, already exists", sequenceNumber); + if (m_debug) + LogDebug("JitterBuffer: rejecting frame with seqNo=%u, already exists", sequenceNumber); return false; } diff --git a/JitterBuffer.h b/JitterBuffer.h index a37339e..1f5c5e7 100644 --- a/JitterBuffer.h +++ b/JitterBuffer.h @@ -30,7 +30,7 @@ enum JB_STATUS { class CJitterBuffer { public: - CJitterBuffer(unsigned int blockSize, unsigned int blockTime, unsigned int jitterTime, unsigned int topSequenceNumber); + CJitterBuffer(unsigned int blockSize, unsigned int blockTime, unsigned int jitterTime, unsigned int topSequenceNumber, bool debug); ~CJitterBuffer(); bool addData(const unsigned char* data, unsigned int length, unsigned int sequenceNumber); @@ -45,6 +45,7 @@ private: unsigned int m_blockSize; unsigned int m_blockTime; unsigned int m_topSequenceNumber; + bool m_debug; unsigned int m_blockCount; CTimer m_timer; CStopWatch m_stopWatch;