diff --git a/src/cprotocol.cpp b/src/cprotocol.cpp index deca34c..c4c39bb 100644 --- a/src/cprotocol.cpp +++ b/src/cprotocol.cpp @@ -183,8 +183,12 @@ void CProtocol::OnDvLastFramePacketIn(std::unique_ptr &Frame stream->Push(std::move(Frame)); stream->Unlock(); - // and close the stream - g_Reflector.CloseStream(stream); + // Don't close yet, this stops the last packet relfection bug that was fixed in upstream by the same change. + // Don't close the stream yet but rely on CheckStreamsTimeout + // mechanism, so the stream will be closed after the queues have + // been sinked out. This avoid last packets to be send back + // to transmitting client (master) + } // else // {