#include #include #include #include #include #include #include #include namespace llarp { namespace service { bool OutboundContext::Stop() { markedBad = true; return path::Builder::Stop(); } bool OutboundContext::IsDone(llarp_time_t now) const { (void)now; return AvailablePaths(path::ePathRoleAny) == 0 && ShouldRemove(); } bool OutboundContext::ShouldBundleRC() const { return m_Endpoint->ShouldBundleRC(); } bool OutboundContext::HandleDataDrop(path::Path_ptr p, const PathID_t& dst, uint64_t seq) { // pick another intro if(dst == remoteIntro.pathID && remoteIntro.router == p->Endpoint()) { LogWarn(Name(), " message ", seq, " dropped by endpoint ", p->Endpoint(), " via ", dst); if(MarkCurrentIntroBad(Now())) { SwapIntros(); LogInfo(Name(), " switched intros to ", remoteIntro.router, " via ", remoteIntro.pathID); } UpdateIntroSet(true); } return true; } OutboundContext::OutboundContext(const IntroSet& introset, Endpoint* parent) : path::Builder(parent->Router(), parent->Router()->dht(), 3, path::default_len) , SendContext(introset.A, {}, this, parent) , currentIntroSet(introset) { updatingIntroSet = false; for(const auto intro : introset.I) { if(intro.expiresAt > m_NextIntro.expiresAt) m_NextIntro = intro; } } OutboundContext::~OutboundContext() { } /// actually swap intros void OutboundContext::SwapIntros() { remoteIntro = m_NextIntro; m_DataHandler->PutIntroFor(currentConvoTag, remoteIntro); } bool OutboundContext::OnIntroSetUpdate(__attribute__((unused)) const Address& addr, const IntroSet* i, const RouterID& endpoint) { if(markedBad) return true; updatingIntroSet = false; if(i) { if(currentIntroSet.T >= i->T) { LogInfo("introset is old, dropping"); return true; } auto now = Now(); if(i->IsExpired(now)) { LogError("got expired introset from lookup from ", endpoint); return true; } currentIntroSet = *i; if(!ShiftIntroduction()) { LogWarn("failed to pick new intro during introset update"); } if(GetPathByRouter(m_NextIntro.router) == nullptr && !BuildCooldownHit(Now())) BuildOneAlignedTo(m_NextIntro.router); } else ++m_LookupFails; return true; } bool OutboundContext::ReadyToSend() const { return (!remoteIntro.router.IsZero()) && GetPathByRouter(remoteIntro.router) != nullptr; } void OutboundContext::HandlePathBuilt(path::Path_ptr p) { path::Builder::HandlePathBuilt(p); /// don't use it if we are marked bad if(markedBad) return; p->SetDataHandler( util::memFn(&OutboundContext::HandleHiddenServiceFrame, this)); p->SetDropHandler(util::memFn(&OutboundContext::HandleDataDrop, this)); // we now have a path to the next intro, swap intros if(p->Endpoint() == m_NextIntro.router && remoteIntro != m_NextIntro) SwapIntros(); } void OutboundContext::AsyncGenIntro(const llarp_buffer_t& payload, ProtocolType t) { if(remoteIntro.router.IsZero()) SwapIntros(); auto path = m_PathSet->GetNewestPathByRouter(remoteIntro.router); if(path == nullptr) { // try parent as fallback path = m_Endpoint->GetPathByRouter(remoteIntro.router); if(path == nullptr) { if(!BuildCooldownHit(Now())) BuildOneAlignedTo(remoteIntro.router); LogWarn(Name(), " dropping intro frame, no path to ", remoteIntro.router); return; } } currentConvoTag.Randomize(); AsyncKeyExchange* ex = new AsyncKeyExchange( m_Endpoint->RouterLogic(), remoteIdent, m_Endpoint->GetIdentity(), currentIntroSet.K, remoteIntro, m_DataHandler, currentConvoTag, t); ex->hook = std::bind(&OutboundContext::Send, this, std::placeholders::_1, path); ex->msg.PutBuffer(payload); ex->msg.introReply = path->intro; ex->frame.F = ex->msg.introReply.pathID; llarp_threadpool_queue_job(m_Endpoint->CryptoWorker(), {ex, &AsyncKeyExchange::Encrypt}); } std::string OutboundContext::Name() const { return "OBContext:" + m_Endpoint->Name() + "-" + currentIntroSet.A.Addr().ToString(); } void OutboundContext::UpdateIntroSet(bool randomizePath) { if(updatingIntroSet || markedBad) return; auto addr = currentIntroSet.A.Addr(); path::Path_ptr path = nullptr; if(randomizePath) path = m_Endpoint->PickRandomEstablishedPath(); else path = m_Endpoint->GetEstablishedPathClosestTo(addr.as_array()); if(path) { HiddenServiceAddressLookup* job = new HiddenServiceAddressLookup( m_Endpoint, util::memFn(&OutboundContext::OnIntroSetUpdate, this), addr, m_Endpoint->GenTXID()); updatingIntroSet = job->SendRequestViaPath(path, m_Endpoint->Router()); } else { LogWarn("Cannot update introset no path for outbound session to ", currentIntroSet.A.Addr().ToString()); } } util::StatusObject OutboundContext::ExtractStatus() const { auto obj = path::Builder::ExtractStatus(); obj.Put("currentConvoTag", currentConvoTag.ToHex()); obj.Put("remoteIntro", remoteIntro.ExtractStatus()); obj.Put("sessionCreatedAt", createdAt); obj.Put("lastGoodSend", lastGoodSend); obj.Put("seqno", sequenceNo); obj.Put("markedBad", markedBad); obj.Put("lastShift", lastShift); obj.Put("remoteIdentity", remoteIdent.Addr().ToString()); obj.Put("currentRemoteIntroset", currentIntroSet.ExtractStatus()); obj.Put("nextIntro", m_NextIntro.ExtractStatus()); std::vector< util::StatusObject > badIntrosObj; std::transform(m_BadIntros.begin(), m_BadIntros.end(), std::back_inserter(badIntrosObj), [](const auto& item) -> util::StatusObject { util::StatusObject o{ {"count", item.second}, {"intro", item.first.ExtractStatus()}}; return o; }); obj.Put("badIntros", badIntrosObj); return obj; } bool OutboundContext::Pump(llarp_time_t now) { // we are probably dead af if(m_LookupFails > 16 || m_BuildFails > 10) return true; // check for expiration if(remoteIntro.ExpiresSoon(now)) { // shift intro if it expires "soon" ShiftIntroduction(); } // lookup router in intro if set and unknown m_Endpoint->EnsureRouterIsKnown(remoteIntro.router); // expire bad intros auto itr = m_BadIntros.begin(); while(itr != m_BadIntros.end()) { if(now - itr->second > path::default_lifetime) itr = m_BadIntros.erase(itr); else ++itr; } // send control message if we look too quiet if(lastGoodSend) { if(now - lastGoodSend > (sendTimeout / 2)) { if(!GetNewestPathByRouter(remoteIntro.router)) { if(!BuildCooldownHit(now)) BuildOneAlignedTo(remoteIntro.router); } else { Encrypted< 64 > tmp; tmp.Randomize(); llarp_buffer_t buf(tmp.data(), tmp.size()); AsyncEncryptAndSendTo(buf, eProtocolControl); if(currentConvoTag.IsZero()) return false; return !m_DataHandler->HasConvoTag(currentConvoTag); } } } // if we are dead return true so we are removed return lastGoodSend ? (now >= lastGoodSend && now - lastGoodSend > sendTimeout) : (now >= createdAt && now - createdAt > connectTimeout); } bool OutboundContext::SelectHop(llarp_nodedb* db, const std::set< RouterID >& prev, RouterContact& cur, size_t hop, path::PathRole roles) { if(m_NextIntro.router.IsZero() || prev.count(m_NextIntro.router)) { if(!ShiftIntroduction(false)) return false; } std::set< RouterID > exclude = prev; exclude.insert(m_NextIntro.router); for(const auto& snode : m_Endpoint->m_SnodeBlacklist) exclude.insert(snode); if(hop == numHops - 1) { m_Endpoint->EnsureRouterIsKnown(m_NextIntro.router); if(db->Get(m_NextIntro.router, cur)) return true; ++m_BuildFails; return false; } return path::Builder::SelectHop(db, exclude, cur, hop, roles); } bool OutboundContext::ShouldBuildMore(llarp_time_t now) const { if(markedBad) return false; if(path::Builder::ShouldBuildMore(now)) return true; return !ReadyToSend(); } bool OutboundContext::MarkCurrentIntroBad(llarp_time_t now) { // insert bad intro m_BadIntros[m_NextIntro] = now; // try shifting intro without rebuild if(ShiftIntroduction(false)) { // we shifted // check if we have a path to the next intro router if(GetNewestPathByRouter(m_NextIntro.router)) return true; // we don't have a path build one if we aren't building too fast if(!BuildCooldownHit(now)) BuildOneAlignedTo(m_NextIntro.router); return true; } else { // we didn't shift check if we should update introset if(now - lastShift >= MIN_SHIFT_INTERVAL || currentIntroSet.HasExpiredIntros(now) || currentIntroSet.IsExpired(now)) { // update introset LogInfo(Name(), " updating introset"); UpdateIntroSet(true); return true; } return false; } } bool OutboundContext::ShiftIntroduction(bool rebuild) { bool success = false; auto now = Now(); if(now - lastShift < MIN_SHIFT_INTERVAL) return false; bool shifted = false; // to find a intro on the same router as before that is newer for(const auto& intro : currentIntroSet.I) { if(intro.ExpiresSoon(now)) continue; if(m_Endpoint->m_SnodeBlacklist.count(intro.router)) continue; if(m_BadIntros.find(intro) == m_BadIntros.end() && remoteIntro.router == intro.router) { if(intro.expiresAt > m_NextIntro.expiresAt) { success = true; m_NextIntro = intro; return true; } } } if(!success) { /// pick newer intro not on same router for(const auto& intro : currentIntroSet.I) { if(m_Endpoint->m_SnodeBlacklist.count(intro.router)) continue; m_Endpoint->EnsureRouterIsKnown(intro.router); if(intro.ExpiresSoon(now)) continue; if(m_BadIntros.find(intro) == m_BadIntros.end() && m_NextIntro != intro) { if(intro.expiresAt > m_NextIntro.expiresAt) { shifted = intro.router != m_NextIntro.router; m_NextIntro = intro; success = true; } } } } if(m_NextIntro.router.IsZero()) return false; if(shifted) lastShift = now; if(rebuild && !BuildCooldownHit(Now())) BuildOneAlignedTo(m_NextIntro.router); return success; } void OutboundContext::HandlePathDied(path::Path_ptr path) { // unconditionally update introset UpdateIntroSet(true); const RouterID endpoint(path->Endpoint()); // if a path to our current intro died... if(endpoint == remoteIntro.router) { // figure out how many paths to this router we have size_t num = 0; ForEachPath([&](const path::Path_ptr& p) { if(p->Endpoint() == endpoint && p->IsReady()) ++num; }); // if we have more than two then we are probably fine if(num > 2) return; // if we have one working one ... if(num == 1) { num = 0; ForEachPath([&](const path::Path_ptr& p) { if(p->Endpoint() == endpoint) ++num; }); // if we have 2 or more established or pending don't do anything if(num > 2) return; BuildOneAlignedTo(endpoint); } else if(num == 0) { // we have no paths to this router right now // hop off it Introduction picked; // get the latest intro that isn't on that endpoint for(const auto& intro : currentIntroSet.I) { if(intro.router == endpoint) continue; if(intro.expiresAt > picked.expiresAt) picked = intro; } // we got nothing if(picked.router.IsZero()) { return; } m_NextIntro = picked; // check if we have a path to this router num = 0; ForEachPath([&](const path::Path_ptr& p) { // don't count timed out paths if(p->Status() != path::ePathTimeout && p->Endpoint() == m_NextIntro.router) ++num; }); // build a path if one isn't already pending build or established BuildOneAlignedTo(m_NextIntro.router); } } } bool OutboundContext::HandleHiddenServiceFrame(path::Path_ptr p, const ProtocolFrame& frame) { return m_Endpoint->HandleHiddenServiceFrame(p, frame); } } // namespace service } // namespace llarp