diff --git a/llarp/exit/session.cpp b/llarp/exit/session.cpp index 158b02651..c6bdc009b 100644 --- a/llarp/exit/session.cpp +++ b/llarp/exit/session.cpp @@ -20,11 +20,10 @@ namespace llarp::exit : llarp::path::Builder{r, numpaths, hoplen} , exit_router{routerId} , packet_write_func{std::move(writepkt)} - , _counter{0} , _last_use{r->now()} - , m_BundleRC{false} - , m_Parent{parent} + , _parent{parent} { + (void)_parent; crypto::identity_keygen(exit_key); } @@ -219,34 +218,6 @@ namespace llarp::exit return true; } - bool - BaseSession::QueueUpstreamTraffic(llarp::net::IPPacket, const size_t, service::ProtocolType) - { - // auto& queue = m_Upstream[pkt.size() / N]; - // queue overflow - // if (queue.size() >= MaxUpstreamQueueLength) - // return false; - // if (queue.size() == 0) - // { - // queue.emplace_back(); - // queue.back().protocol = t; - // return queue.back().PutBuffer(llarp_buffer_t{pkt}, _counter++); - // } - - // auto& back = queue.back(); - // // pack to nearest N - // if (back.Size() + pkt.size() > N) - // { - // queue.emplace_back(); - // queue.back().protocol = t; - // return queue.back().PutBuffer(llarp_buffer_t{pkt}, _counter++); - // } - // back.protocol = t; - // return back.PutBuffer(llarp_buffer_t{pkt}, _counter++); - - return true; - } - bool BaseSession::IsReady() const { diff --git a/llarp/exit/session.hpp b/llarp/exit/session.hpp index 435151743..ac5da8f84 100644 --- a/llarp/exit/session.hpp +++ b/llarp/exit/session.hpp @@ -81,10 +81,6 @@ namespace llarp void HandlePathBuilt(llarp::path::Path_ptr p) override; - bool - QueueUpstreamTraffic( - llarp::net::IPPacket pkt, const size_t packSize, service::ProtocolType t); - /// flush upstream to exit via paths bool FlushUpstream(); @@ -163,12 +159,12 @@ namespace llarp } }; - [[maybe_unused]] uint64_t _counter; + // uint64_t _counter; llarp_time_t _last_use; std::vector m_PendingCallbacks; - [[maybe_unused]] const bool m_BundleRC; - [[maybe_unused]] EndpointBase* const m_Parent; + // const bool _bundle_RC; + EndpointBase* const _parent; void CallPendingCallbacks(bool success);