From f9dc308f75202dc0af609635cf32203f829a1e7e Mon Sep 17 00:00:00 2001
From: Jason Rhinelander <jason@imaginary.ca>
Date: Wed, 3 Mar 2021 15:35:20 -0400
Subject: [PATCH] Tick event loop on data queuing

---
 llarp/path/ihophandler.cpp | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/llarp/path/ihophandler.cpp b/llarp/path/ihophandler.cpp
index ea915c158..0ebe00bdc 100644
--- a/llarp/path/ihophandler.cpp
+++ b/llarp/path/ihophandler.cpp
@@ -1,4 +1,5 @@
 #include <path/ihophandler.hpp>
+#include <router/abstractrouter.hpp>
 
 namespace llarp
 {
@@ -6,7 +7,7 @@ namespace llarp
   {
     // handle data in upstream direction
     bool
-    IHopHandler::HandleUpstream(const llarp_buffer_t& X, const TunnelNonce& Y, AbstractRouter*)
+    IHopHandler::HandleUpstream(const llarp_buffer_t& X, const TunnelNonce& Y, AbstractRouter* r)
     {
       if (not m_UpstreamReplayFilter.Insert(Y))
         return false;
@@ -17,12 +18,13 @@ namespace llarp
       pkt.first.resize(X.sz);
       std::copy_n(X.base, X.sz, pkt.first.begin());
       pkt.second = Y;
+      r->loop()->wakeup();
       return true;
     }
 
     // handle data in downstream direction
     bool
-    IHopHandler::HandleDownstream(const llarp_buffer_t& X, const TunnelNonce& Y, AbstractRouter*)
+    IHopHandler::HandleDownstream(const llarp_buffer_t& X, const TunnelNonce& Y, AbstractRouter* r)
     {
       if (not m_DownstreamReplayFilter.Insert(Y))
         return false;
@@ -33,6 +35,7 @@ namespace llarp
       pkt.first.resize(X.sz);
       std::copy_n(X.base, X.sz, pkt.first.begin());
       pkt.second = Y;
+      r->loop()->wakeup();
       return true;
     }