commit 81221ada9fd3c55679f4228b7924fee476ec54c9
author Amna <amna.snene@savoirfairelinux.com> Thu Sep 14 17:33:26 2023 -0400
committer Amna <amna.snene@savoirfairelinux.com> Wed Sep 20 11:43:14 2023 -0400
tree 8fe7b85e2f5fc0656817d13eab8d518f70ac1305
parent 277edafba363e3b4da25c158af5f50a5cb3c1420

connectionManager: new API

Change-Id: I96eb3ed8d0d4f82adb28c8d47a5751bc3f603560

src/ice_transport.cpp

diff --git a/src/ice_transport.cpp b/src/ice_transport.cpp
index b0d7a2e..a735e75 100644
--- a/src/ice_transport.cpp
+++ b/src/ice_transport.cpp
@@ -151,6 +151,7 @@
     int checkEventQueue(int maxEventToPoll);
 
     std::shared_ptr<dht::log::Logger> logger_ {};
+    std::shared_ptr<dhtnet::IceTransportFactory> factory {};
 
     std::condition_variable_any iceCV_ {};
 
@@ -381,6 +382,7 @@
 void
 IceTransport::Impl::initIceInstance(const IceTransportOptions& options)
 {
+    factory = options.factory;
     isTcp_ = options.tcpEnable;
     upnpEnabled_ = options.upnpEnable;
     on_initdone_cb_ = options.onInitDone;
@@ -406,7 +408,7 @@
     if (upnpEnabled_)
         upnp_ = std::make_shared<upnp::Controller>(options.upnpContext);
 
-    config_ = options.factory->getIceCfg(); // config copy
+    config_ = factory->getIceCfg(); // config copy
     if (isTcp_) {
         config_.protocol = PJ_ICE_TP_TCP;
         config_.stun.conn_type = PJ_STUN_TP_TCP;
@@ -418,7 +420,7 @@
     }
 
     pool_.reset(
-        pj_pool_create(options.factory->getPoolFactory(), "IceTransport.pool", 512, 512, NULL));
+        pj_pool_create(factory->getPoolFactory(), "IceTransport.pool", 512, 512, NULL));
     if (not pool_)
         throw std::runtime_error("pj_pool_create() failed");