|
|
@ -38,6 +38,7 @@ namespace stream |
|
|
|
|
|
|
|
|
|
|
|
Stream::~Stream () |
|
|
|
Stream::~Stream () |
|
|
|
{ |
|
|
|
{ |
|
|
|
|
|
|
|
Close (); |
|
|
|
m_ReceiveTimer.cancel (); |
|
|
|
m_ReceiveTimer.cancel (); |
|
|
|
m_ResendTimer.cancel (); |
|
|
|
m_ResendTimer.cancel (); |
|
|
|
while (!m_ReceiveQueue.empty ()) |
|
|
|
while (!m_ReceiveQueue.empty ()) |
|
|
@ -561,7 +562,8 @@ namespace stream |
|
|
|
|
|
|
|
|
|
|
|
StreamingDestination::~StreamingDestination () |
|
|
|
StreamingDestination::~StreamingDestination () |
|
|
|
{ |
|
|
|
{ |
|
|
|
// TODO: delete streams
|
|
|
|
for (auto it: m_Streams) |
|
|
|
|
|
|
|
delete it.second; |
|
|
|
if (m_Pool) |
|
|
|
if (m_Pool) |
|
|
|
i2p::tunnel::tunnels.DeleteTunnelPool (m_Pool); |
|
|
|
i2p::tunnel::tunnels.DeleteTunnelPool (m_Pool); |
|
|
|
delete m_LeaseSet; |
|
|
|
delete m_LeaseSet; |
|
|
|