queue pending traffic

llarp/service/endpoint.cpp

@@ -1121,12 +1121,18 @@ namespace llarp
           ++itr;
         }
       }
+      m_PendingTraffic[remote].emplace_back(data, t);
       // no converstation
       return EnsurePathToService(
           remote,
-          [](Address, OutboundContext* c) {
+          [&](Address r, OutboundContext* c) {
             if(c)
+            {
               c->UpdateIntroSet(true);
+              for(auto & pending :  m_PendingTraffic[r] )
+                c->AsyncEncryptAndSendTo(pending.Buffer(), pending.protocol);
+            }
+            m_PendingTraffic.erase(r);
           },
           5000, true);
     }

llarp/service/endpoint.hpp

@@ -215,7 +215,7 @@ namespace llarp
       bool
       CheckPathIsDead(path::Path_ptr p, llarp_time_t latency);
 
-      using PendingBufferQueue = std::queue< PendingBuffer >;
+      using PendingBufferQueue = std::deque< PendingBuffer >;
 
       bool
       ShouldBundleRC() const override;

llarp/service/endpoint_util.cpp

@@ -90,6 +90,7 @@ namespace llarp
       auto itr = remoteSessions.begin();
       while(itr != remoteSessions.end())
       {
+        itr->second->Tick(now);
         if(itr->second->Pump(now))
         {
           itr->second->Stop();