show streams per local destination

Destination.cpp

@@ -70,15 +70,7 @@ namespace stream
 
 	StreamingDestination::~StreamingDestination ()
 	{
-		{
-			std::unique_lock<std::mutex> l(m_StreamsMutex);
-			for (auto it: m_Streams)
-				delete it.second;
-			m_Streams.clear ();
-		}	
 		Stop ();
-		if (m_Pool)
-			i2p::tunnel::tunnels.DeleteTunnelPool (m_Pool);		
 		delete m_LeaseSet;
 	}	
 
@@ -95,6 +87,17 @@ namespace stream
 		
 	void StreamingDestination::Stop ()
 	{	
+		{
+			std::unique_lock<std::mutex> l(m_StreamsMutex);
+			for (auto it: m_Streams)
+				delete it.second;
+			m_Streams.clear ();
+		}	
+		if (m_Pool)
+		{	
+			i2p::tunnel::tunnels.DeleteTunnelPool (m_Pool);
+			m_Pool = nullptr;
+		}	
 		m_IsRunning = false;
 		m_Service.stop ();
 		if (m_Thread)

Destination.h

@@ -77,6 +77,11 @@ namespace stream
 			bool m_IsPublic;			
 
 			std::function<void (Stream *)> m_Acceptor;
+
+		public:
+
+			// for HTTP only
+			const decltype(m_Streams)& GetStreams () const { return m_Streams; };
 	};	
 
 	class StreamingDestinations

HTTPServer.cpp

@@ -798,6 +798,7 @@ namespace util
 			auto pool = dest->GetTunnelPool ();
 			if (pool)
 			{
+				s << "<b>Tunnels:</b><br>";
 				for (auto it: pool->GetOutboundTunnels ())
 				{
 					it->GetTunnelConfig ()->Print (s);
@@ -809,6 +810,9 @@ namespace util
 					s << "<br>" << std::endl;
 				}
 			}	
+			s << "<br><b>Streams:</b><br>";
+			for (auto it: dest->GetStreams ())
+				s << it.first << "->" << it.second->GetRemoteIdentity ().GetIdentHash ().ToBase32 () << ".b32.i2p<br>" << std::endl; 
 		}	
 	}	
 	

TunnelPool.cpp

@@ -37,6 +37,7 @@ namespace tunnel
 		
 	void TunnelPool::TunnelCreated (InboundTunnel * createdTunnel)
 	{
+		if (m_IsDeleted) return;
 		{
 			std::unique_lock<std::mutex> l(m_InboundTunnelsMutex);
 			m_InboundTunnels.insert (createdTunnel);
@@ -60,6 +61,7 @@ namespace tunnel
 
 	void TunnelPool::TunnelCreated (OutboundTunnel * createdTunnel)
 	{
+		if (m_IsDeleted) return;
 		std::unique_lock<std::mutex> l(m_OutboundTunnelsMutex);
 		m_OutboundTunnels.insert (createdTunnel);
 	}