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

Method PostTransitTunnelBuildMsg

libi2pd/TransitTunnel.cpp:276–285  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

274 }
275
276 void TransitTunnels::PostTransitTunnelBuildMsg (std::shared_ptr<I2NPMessage>&& msg)
277 {
278 if (msg)
279 {
280 if (m_TunnelBuildMsgQueue.GetSize () < TRANSIT_TUNNELS_BUILD_MSG_QUEUE_MAX_SIZE)
281 m_TunnelBuildMsgQueue.Put (msg);
282 else
283 m_TunnelBuildMsgQueue.WakeUp (); // tell TBM thread to process queue
284 }
285 }
286
287 void TransitTunnels::HandleShortTransitTunnelBuildMsg (std::shared_ptr<I2NPMessage>&& msg)
288 {

Callers 2

Calls 3

WakeUpMethod · 0.80
GetSizeMethod · 0.45
PutMethod · 0.45

Tested by

no test coverage detected