diff --git a/src/cdvframepacket.h b/src/cdvframepacket.h index a38f1b2..76a9cfa 100644 --- a/src/cdvframepacket.h +++ b/src/cdvframepacket.h @@ -49,7 +49,7 @@ struct __attribute__ ((__packed__))dstar_dvframe class CDvFramePacket : public CPacket { - friend class CCodecStream; + //friend class CCodecStream; public: // constructor CDvFramePacket(); diff --git a/src/cpacketstream.cpp b/src/cpacketstream.cpp index 31384ec..7ef938b 100644 --- a/src/cpacketstream.cpp +++ b/src/cpacketstream.cpp @@ -42,7 +42,7 @@ CPacketStream::CPacketStream() //////////////////////////////////////////////////////////////////////////////////////// // open / close -bool CPacketStream::Open(const CDvHeaderPacket &DvHeader, std::shared_ptrclient) +bool CPacketStream::OpenPacketStream(const CDvHeaderPacket &DvHeader, std::shared_ptrclient) { bool ok = false; @@ -58,16 +58,16 @@ bool CPacketStream::Open(const CDvHeaderPacket &DvHeader, std::shared_ptrGetCodec()); + m_CodecStream = g_Transcoder.GetCodecStream(this, client->GetCodec()); else - m_CodecStream = g_Transcoder.GetStream(this, CODEC_NONE); + m_CodecStream = g_Transcoder.GetCodecStream(this, CODEC_NONE); #endif ok = true; } return ok; } -void CPacketStream::Close(void) +void CPacketStream::ClosePacketStream(void) { // update status m_bOpen = false; diff --git a/src/cpacketstream.h b/src/cpacketstream.h index 3ad3ee6..bc36737 100644 --- a/src/cpacketstream.h +++ b/src/cpacketstream.h @@ -45,8 +45,8 @@ public: CPacketStream(); // open / close - bool Open(const CDvHeaderPacket &, std::shared_ptr); - void Close(void); + bool OpenPacketStream(const CDvHeaderPacket &, std::shared_ptr); + void ClosePacketStream(void); // push & pop void Push(std::unique_ptr packet); diff --git a/src/creflector.cpp b/src/creflector.cpp index 733dc7d..507cb24 100644 --- a/src/creflector.cpp +++ b/src/creflector.cpp @@ -205,7 +205,7 @@ CPacketStream *CReflector::OpenStream(std::unique_ptr &DvHeader stream->Lock(); // is it available ? - if ( stream->Open(*DvHeader, client) ) + if ( stream->OpenPacketStream(*DvHeader, client) ) { // stream open, mark client as master // so that it can't be deleted @@ -272,7 +272,7 @@ void CReflector::CloseStream(CPacketStream *stream) stream->Unlock(); // and stop the queue - stream->Close(); + stream->ClosePacketStream(); } } diff --git a/src/ctranscoder.cpp b/src/ctranscoder.cpp index 7bedfb3..ba54fec 100644 --- a/src/ctranscoder.cpp +++ b/src/ctranscoder.cpp @@ -195,7 +195,7 @@ void CTranscoder::Task(void) //////////////////////////////////////////////////////////////////////////////////////// // manage streams -std::shared_ptr CTranscoder::GetStream(CPacketStream *PacketStream, uint8 uiCodecIn) +std::shared_ptr CTranscoder::GetCodecStream(CPacketStream *PacketStream, uint8 uiCodecIn) { CBuffer Buffer; diff --git a/src/ctranscoder.h b/src/ctranscoder.h index 9e40260..8e237c7 100644 --- a/src/ctranscoder.h +++ b/src/ctranscoder.h @@ -60,7 +60,7 @@ public: bool IsConnected(void) const { return m_bConnected; } // manage streams - std::shared_ptr GetStream(CPacketStream *, uint8); + std::shared_ptr GetCodecStream(CPacketStream *, uint8); void ReleaseStream(std::shared_ptr); // task diff --git a/src/cysfconvolution.cpp b/src/cysfconvolution.cpp index 5d14764..2891cd9 100644 --- a/src/cysfconvolution.cpp +++ b/src/cysfconvolution.cpp @@ -36,12 +36,16 @@ const unsigned int NUM_OF_STATES = 16U; const uint32_t M = 2U; const unsigned int K = 5U; -CYSFConvolution::CYSFConvolution() : m_oldMetrics(m_metrics1), m_newMetrics(m_metrics2), m_dp(m_decisions) {} +CYSFConvolution::CYSFConvolution() : m_oldMetrics(nullptr), m_newMetrics(nullptr), m_dp(nullptr) {} void CYSFConvolution::start() { - for (int i=0; i<16; i++) - m_metrics1[i] = m_metrics2[i] = 0U; + memset(m_metrics1, 0, NUM_OF_STATES * sizeof(uint16_t)); + memset(m_metrics2, 0, NUM_OF_STATES * sizeof(uint16_t)); + + m_oldMetrics = m_metrics1; + m_newMetrics = m_metrics2; + m_dp = m_decisions; } void CYSFConvolution::decode(uint8_t s0, uint8_t s1) @@ -71,7 +75,7 @@ void CYSFConvolution::decode(uint8_t s0, uint8_t s1) assert((m_dp - m_decisions) <= 180); - uint16_t* tmp = m_oldMetrics; + uint16_t *tmp = m_oldMetrics; m_oldMetrics = m_newMetrics; m_newMetrics = tmp; }