#ifndef LLARP_PATH_CONTEXT_HPP #define LLARP_PATH_CONTEXT_HPP #include #include #include #include #include #include #include #include #include namespace llarp { class Logic; struct AbstractRouter; struct LR_CommitMessage; struct RelayDownstreamMessage; struct RelayUpstreamMessage; struct RouterID; namespace path { struct TransitHop; struct TransitHopInfo; using TransitHop_ptr = std::shared_ptr< TransitHop >; struct PathContext { PathContext(AbstractRouter* router); /// called from router tick function void ExpirePaths(llarp_time_t now); void AllowTransit(); void RejectTransit(); bool AllowingTransit() const; bool HasTransitHop(const TransitHopInfo& info); bool HandleRelayCommit(const LR_CommitMessage& msg); void PutTransitHop(std::shared_ptr< TransitHop > hop); HopHandler_ptr GetByUpstream(const RouterID& id, const PathID_t& path); bool TransitHopPreviousIsRouter(const PathID_t& path, const RouterID& r); HopHandler_ptr GetPathForTransfer(const PathID_t& topath); HopHandler_ptr GetByDownstream(const RouterID& id, const PathID_t& path); PathSet_ptr GetLocalPathSet(const PathID_t& id); routing::MessageHandler_ptr GetHandler(const PathID_t& id); using EndpointPathPtrSet = std::set< Path_ptr, ComparePtr< Path_ptr > >; /// get a set of all paths that we own who's endpoint is r EndpointPathPtrSet FindOwnedPathsWithEndpoint(const RouterID& r); bool ForwardLRCM(const RouterID& nextHop, const std::array< EncryptedFrame, 8 >& frames); bool HopIsUs(const RouterID& k) const; bool HandleLRUM(const RelayUpstreamMessage& msg); bool HandleLRDM(const RelayDownstreamMessage& msg); void AddOwnPath(PathSet_ptr set, Path_ptr p); void RemovePathSet(PathSet_ptr set); using TransitHopsMap_t = std::multimap< PathID_t, TransitHop_ptr >; struct SyncTransitMap_t { util::Mutex first; // protects second TransitHopsMap_t second GUARDED_BY(first); void ForEach(std::function< void(const TransitHop_ptr&) > visit) { util::Lock lock(&first); for(const auto& item : second) visit(item.second); } }; // maps path id -> pathset owner of path using OwnedPathsMap_t = std::map< PathID_t, PathSet_ptr >; struct SyncOwnedPathsMap_t { util::Mutex first; // protects second OwnedPathsMap_t second GUARDED_BY(first); void ForEach(std::function< void(const PathSet_ptr&) > visit) { util::Lock lock(&first); for(const auto& item : second) visit(item.second); } }; std::shared_ptr< thread::ThreadPool > Worker(); std::shared_ptr< Logic > logic(); AbstractRouter* Router(); const SecretKey& EncryptionSecretKey(); const byte_t* OurRouterID() const; private: AbstractRouter* m_Router; SyncTransitMap_t m_TransitPaths; SyncOwnedPathsMap_t m_OurPaths; bool m_AllowTransit; }; } // namespace path } // namespace llarp #endif