| 2086 | } |
| 2087 | |
| 2088 | void StreamingDestination::Stop () |
| 2089 | { |
| 2090 | ResetAcceptor (); |
| 2091 | ResetPongHandler (); |
| 2092 | m_PendingIncomingTimer.cancel (); |
| 2093 | m_PendingIncomingStreams.clear (); |
| 2094 | { |
| 2095 | std::unique_lock<std::mutex> l(m_StreamsMutex); |
| 2096 | for (auto it: m_Streams) |
| 2097 | it.second->Terminate (false); // we delete here |
| 2098 | m_Streams.clear (); |
| 2099 | m_IncomingStreams.clear (); |
| 2100 | m_LastStream = nullptr; |
| 2101 | } |
| 2102 | } |
| 2103 | |
| 2104 | void StreamingDestination::HandleNextPacket (Packet * packet) |
| 2105 | { |