diff --git a/HTTPServer.cpp b/HTTPServer.cpp
index bf11a03b..b08948d1 100644
--- a/HTTPServer.cpp
+++ b/HTTPServer.cpp
@@ -817,6 +817,7 @@ namespace util
 			{	
 				s << it.first << "->" << it.second->GetRemoteIdentity ().GetIdentHash ().ToBase32 () << ".b32.i2p ";
 				s << " [" << it.second->GetNumSentBytes () << ":" << it.second->GetNumReceivedBytes () << "]";
+				s << " [out:" << it.second->GetSendQueueSize () << "][in:" << it.second->GetReceiveQueueSize () << "]";
 				s << "<br>"<< std::endl; 
 			}	
 		}	
diff --git a/Streaming.cpp b/Streaming.cpp
index 503f2993..5b871cf2 100644
--- a/Streaming.cpp
+++ b/Streaming.cpp
@@ -412,6 +412,8 @@ namespace stream
 				if (isEmpty)
 					ScheduleResend ();
 			}	
+			else
+				delete packet;
 			return true;	
 		}	
 		else
diff --git a/Streaming.h b/Streaming.h
index 40312464..5c02913d 100644
--- a/Streaming.h
+++ b/Streaming.h
@@ -100,6 +100,8 @@ namespace stream
 
 			size_t GetNumSentBytes () const { return m_NumSentBytes; };
 			size_t GetNumReceivedBytes () const { return m_NumReceivedBytes; };
+			size_t GetSendQueueSize () const { return m_SentPackets.size (); };
+			size_t GetReceiveQueueSize () const { return m_ReceiveQueue.size (); };
 			
 		private: