From e58a99385dfa85dee311b136ce761ee8f1f27fb8 Mon Sep 17 00:00:00 2001 From: Tom Early Date: Sat, 15 Aug 2020 16:26:41 -0700 Subject: [PATCH] killed orphaned frame msg --- src/cprotocol.cpp | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/src/cprotocol.cpp b/src/cprotocol.cpp index 987780b..6eec5c5 100644 --- a/src/cprotocol.cpp +++ b/src/cprotocol.cpp @@ -156,11 +156,7 @@ void CProtocol::OnDvFramePacketIn(std::unique_ptr &Frame, const { // find the stream CPacketStream *stream = GetStream(Frame->GetStreamId(), Ip); - if ( stream == nullptr ) - { - std::cout << "Orphaned Frame with ID " << Frame->GetStreamId() << " on " << *Ip << std::endl; - } - else + if ( stream ) { //std::cout << "DV frame" << "from " << *Ip << std::endl; // and push @@ -168,17 +164,17 @@ void CProtocol::OnDvFramePacketIn(std::unique_ptr &Frame, const stream->Push(std::move(Frame)); stream->Unlock(); } + // else + // { + // std::cout << "Orphaned Frame with ID " << Frame->GetStreamId() << " on " << *Ip << std::endl; + // } } void CProtocol::OnDvLastFramePacketIn(std::unique_ptr &Frame, const CIp *Ip) { // find the stream CPacketStream *stream = GetStream(Frame->GetStreamId(), Ip); - if ( stream == nullptr ) - { - std::cout << "Orphaned Last Frame with ID " << Frame->GetStreamId() << " on " << *Ip << std::endl; - } - else + if ( stream ) { // push stream->Lock(); @@ -188,6 +184,10 @@ void CProtocol::OnDvLastFramePacketIn(std::unique_ptr &Frame // and close the stream g_Reflector.CloseStream(stream); } + // else + // { + // std::cout << "Orphaned Last Frame with ID " << Frame->GetStreamId() << " on " << *Ip << std::endl; + // } } ////////////////////////////////////////////////////////////////////////////////////////