| 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 | { |
no test coverage detected