more

llarp/router/router.cpp

@@ -75,7 +75,7 @@ struct TryConnectJob
   Success()
   {
     router->routerProfiling().MarkConnectSuccess(rc.pubkey);
-    router->FlushOutboundFor(rc.pubkey, link);
+    router->FlushOutboundFor(rc.pubkey, link.get());
   }
 
   /// return true to remove
@@ -478,12 +478,12 @@ namespace llarp
   }
 
   void
-  Router::AddLink(std::unique_ptr< ILinkLayer > link, bool inbound)
+  Router::AddLink(std::shared_ptr< ILinkLayer > link, bool inbound)
   {
     if(inbound)
-      inboundLinks.emplace(std::move(link));
+      inboundLinks.emplace(link);
     else
-      outboundLinks.emplace(std::move(link));
+      outboundLinks.emplace(link);
   }
 
   bool

llarp/router/router.hpp

@@ -330,7 +330,7 @@ namespace llarp
                                 const llarp_buffer_t &msg) override;
 
     void
-    AddLink(std::unique_ptr< ILinkLayer > link, bool outbound = false);
+    AddLink(std::shared_ptr< ILinkLayer > link, bool outbound = false);
 
     bool
     InitOutboundLinks();

llarp/utp/utp.cpp

@@ -9,7 +9,7 @@ namespace llarp
   {
     using namespace std::placeholders;
 
-    LinkLaye_ptr
+    LinkLayer_ptr
     NewServer(Crypto* crypto, const SecretKey& routerEncSecret, GetRCFunc getrc,
               LinkMessageHandler h, SessionEstablishedHandler est,
               SessionRenegotiateHandler reneg, SignBufferFunc sign,

test/ev/test_ev_loop.cpp

@@ -28,6 +28,7 @@ struct EventLoopTest : public ::testing::Test
   SetUp()
   {
     loop = llarp_make_ev_loop();
+    _logic.start();
     _logic.call_later({10000, this, &OnTimeout});
   }
 

test/link/test_llarp_link.cpp

@@ -54,7 +54,7 @@ struct LinkLayerTest : public ::testing::Test
       return rc.Sign(crypto, signingKey);
     }
 
-    std::unique_ptr< llarp::ILinkLayer > link;
+    std::shared_ptr< llarp::ILinkLayer > link;
 
     static std::string
     localLoopBack()