emplace queue

5 years ago · b44372bdc5
parent dee639500a
commit b44372bdc5
1 changed files with 2 additions and 0 deletions
--- a/llarp/exit/endpoint.cpp
+++ b/llarp/exit/endpoint.cpp
@ -139,6 +139,8 @@ namespace llarp
      pkt.UpdateIPv4PacketOnDst(src, m_IP);
      const llarp_buffer_t& pktbuf = pkt.Buffer();  // life time extension
      uint8_t queue_idx            = pktbuf.sz / llarp::routing::ExitPadSize;
+      if(m_DownstreamQueues.find(queue_idx) == m_DownstreamQueues.end())
+        m_DownstreamQueues.emplace(queue_idx, InboundTrafficQueue_t{});
      auto& queue                  = m_DownstreamQueues[queue_idx];
      if(queue.size() == 0)
      {