MCPcopy Create free account
hub / github.com/PurpleI2P/i2pd / SetAcceptor

Method SetAcceptor

libi2pd/Streaming.cpp:2322–2335  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

2320 }
2321
2322 void StreamingDestination::SetAcceptor (const Acceptor& acceptor)
2323 {
2324 m_Acceptor = acceptor; // we must set it immediately for IsAcceptorSet
2325 auto s = shared_from_this ();
2326 boost::asio::post (m_Owner->GetService (), [s](void)
2327 {
2328 // take care about incoming queue
2329 for (auto& it: s->m_PendingIncomingStreams)
2330 if (it->GetStatus () == eStreamStatusOpen) // still open?
2331 s->m_Acceptor (it);
2332 s->m_PendingIncomingStreams.clear ();
2333 s->m_PendingIncomingTimer.cancel ();
2334 });
2335 }
2336
2337 void StreamingDestination::ResetAcceptor ()
2338 {

Callers 2

AcceptMethod · 0.80
AcceptStreamsMethod · 0.80

Calls 1

GetStatusMethod · 0.45

Tested by

no test coverage detected