diff --git a/reflector/CodecStream.cpp b/reflector/CodecStream.cpp index ea96a17..47aead4 100644 --- a/reflector/CodecStream.cpp +++ b/reflector/CodecStream.cpp @@ -48,7 +48,7 @@ CCodecStream::CCodecStream(CPacketStream *PacketStream, uint16_t streamid, ECode CCodecStream::~CCodecStream() { // close socket - m_TCReader->Close(); + //m_TCReader->Close(); // kill threads keep_running = false; @@ -185,5 +185,6 @@ void CCodecStream::Task(void) { //std::cout << "transcoder packet timeout" << std::endl; m_uiTimeoutPackets++; + m_TimeoutTimer.start(); } } diff --git a/reflector/Reflector.cpp b/reflector/Reflector.cpp index 3f8ce00..c15ad03 100644 --- a/reflector/Reflector.cpp +++ b/reflector/Reflector.cpp @@ -56,6 +56,7 @@ CReflector::~CReflector() } m_RouterFuture.clear(); m_Stream.clear(); + m_TCReader.clear(); }