| 2396 | } |
| 2397 | |
| 2398 | void StreamingDestination::HandlePendingIncomingTimer (const boost::system::error_code& ecode) |
| 2399 | { |
| 2400 | if (ecode != boost::asio::error::operation_aborted) |
| 2401 | { |
| 2402 | LogPrint (eLogWarning, "Streaming: Pending incoming timeout expired"); |
| 2403 | for (auto& it: m_PendingIncomingStreams) |
| 2404 | it->Close (); |
| 2405 | m_PendingIncomingStreams.clear (); |
| 2406 | } |
| 2407 | } |
| 2408 | |
| 2409 | void StreamingDestination::HandleDataMessagePayload (const uint8_t * buf, size_t len, |
| 2410 | i2p::garlic::ECIESX25519AEADRatchetSession * from) |