From cfcec8229c6c7ad751da9621515edf84db69aa05 Mon Sep 17 00:00:00 2001 From: orignal Date: Tue, 2 Dec 2014 08:07:31 -0500 Subject: [PATCH] delete non-responding streams --- Streaming.cpp | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/Streaming.cpp b/Streaming.cpp index 9cc48dfc..00c21b48 100644 --- a/Streaming.cpp +++ b/Streaming.cpp @@ -206,8 +206,6 @@ namespace stream Close (); m_IsOpen = false; m_IsReset = true; - m_ReceiveTimer.cancel (); - m_LocalDestination.DeleteStream (shared_from_this ()); } } @@ -418,6 +416,8 @@ namespace stream p->len = size; m_Service.post (std::bind (&Stream::SendPacket, shared_from_this (), p)); LogPrint ("FIN sent"); + m_ReceiveTimer.cancel (); + m_LocalDestination.DeleteStream (shared_from_this ()); } } @@ -554,7 +554,6 @@ namespace stream m_IsOpen = false; m_IsReset = true; m_ReceiveTimer.cancel (); - m_LocalDestination.DeleteStream (shared_from_this ()); return; } }