mirror of https://github.com/PurpleI2P/i2pd.git
I2P: End-to-End encrypted and anonymous Internet
https://i2pd.website/
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
114 lines
3.0 KiB
114 lines
3.0 KiB
![]()
8 years ago
|
#include "MatchedDestination.h"
|
||
|
#include "Log.h"
|
||
|
#include "ClientContext.h"
|
||
|
|
||
|
|
||
|
namespace i2p
|
||
|
{
|
||
|
namespace client
|
||
|
{
|
||
|
MatchedTunnelDestination::MatchedTunnelDestination(const i2p::data::PrivateKeys & keys, const std::string & remoteName, const std::map<std::string, std::string> * params)
|
||
|
: ClientDestination(keys, false, params),
|
||
|
m_RemoteName(remoteName) {}
|
||
|
|
||
![]()
8 years ago
|
|
||
![]()
8 years ago
|
void MatchedTunnelDestination::ResolveCurrentLeaseSet()
|
||
|
{
|
||
|
if(i2p::client::context.GetAddressBook().GetIdentHash(m_RemoteName, m_RemoteIdent))
|
||
|
{
|
||
|
auto ls = FindLeaseSet(m_RemoteIdent);
|
||
|
if(ls)
|
||
|
{
|
||
|
HandleFoundCurrentLeaseSet(ls);
|
||
|
}
|
||
|
else
|
||
|
RequestDestination(m_RemoteIdent, std::bind(&MatchedTunnelDestination::HandleFoundCurrentLeaseSet, this, std::placeholders::_1));
|
||
|
}
|
||
|
else
|
||
|
LogPrint(eLogWarning, "Destination: failed to resolve ", m_RemoteName);
|
||
|
}
|
||
|
|
||
|
void MatchedTunnelDestination::HandleFoundCurrentLeaseSet(std::shared_ptr<const i2p::data::LeaseSet> ls)
|
||
|
{
|
||
|
if(ls)
|
||
|
{
|
||
|
LogPrint(eLogDebug, "Destination: resolved remote lease set for ", m_RemoteName);
|
||
|
m_RemoteLeaseSet = ls;
|
||
|
}
|
||
|
else
|
||
![]()
8 years ago
|
{
|
||
|
m_ResolveTimer->expires_from_now(boost::posix_time::seconds(1));
|
||
|
m_ResolveTimer->async_wait([&](const boost::system::error_code & ec) {
|
||
|
if(!ec) ResolveCurrentLeaseSet();
|
||
|
});
|
||
|
}
|
||
![]()
8 years ago
|
}
|
||
|
|
||
|
|
||
|
bool MatchedTunnelDestination::Start()
|
||
|
{
|
||
|
if(ClientDestination::Start())
|
||
|
{
|
||
![]()
8 years ago
|
m_ResolveTimer = std::make_shared<boost::asio::deadline_timer>(GetService());
|
||
![]()
8 years ago
|
GetTunnelPool()->SetCustomPeerSelector(this);
|
||
|
ResolveCurrentLeaseSet();
|
||
|
return true;
|
||
|
}
|
||
|
else
|
||
|
return false;
|
||
|
}
|
||
|
|
||
|
bool MatchedTunnelDestination::Stop()
|
||
|
{
|
||
|
if(ClientDestination::Stop())
|
||
|
{
|
||
![]()
8 years ago
|
if(m_ResolveTimer)
|
||
|
m_ResolveTimer->cancel();
|
||
![]()
8 years ago
|
return true;
|
||
|
}
|
||
|
else
|
||
|
return false;
|
||
|
}
|
||
|
|
||
|
|
||
|
bool MatchedTunnelDestination::SelectPeers(i2p::tunnel::Path & path, int hops, bool inbound)
|
||
|
{
|
||
|
auto pool = GetTunnelPool();
|
||
|
if(!i2p::tunnel::StandardSelectPeers(path, hops, inbound, std::bind(&i2p::tunnel::TunnelPool::SelectNextHop, pool, std::placeholders::_1)))
|
||
|
return false;
|
||
|
// more here for outbound tunnels
|
||
|
if(!inbound && m_RemoteLeaseSet)
|
||
|
{
|
||
|
if(m_RemoteLeaseSet->IsExpired())
|
||
|
{
|
||
|
ResolveCurrentLeaseSet();
|
||
|
}
|
||
|
if(m_RemoteLeaseSet && !m_RemoteLeaseSet->IsExpired())
|
||
|
{
|
||
|
// remote lease set is good
|
||
|
auto leases = m_RemoteLeaseSet->GetNonExpiredLeases();
|
||
|
// pick lease
|
||
|
std::shared_ptr<i2p::data::RouterInfo> obep;
|
||
|
while(!obep && leases.size() > 0) {
|
||
|
auto idx = rand() % leases.size();
|
||
|
auto lease = leases[idx];
|
||
|
obep = i2p::data::netdb.FindRouter(lease->tunnelGateway);
|
||
|
leases.erase(leases.begin()+idx);
|
||
|
}
|
||
|
if(obep) {
|
||
|
path.push_back(obep->GetRouterIdentity());
|
||
|
LogPrint(eLogDebug, "Destination: found OBEP matching IBGW");
|
||
|
} else
|
||
|
LogPrint(eLogWarning, "Destination: could not find proper IBGW for matched outbound tunnel");
|
||
|
}
|
||
|
}
|
||
|
return true;
|
||
|
}
|
||
|
|
||
|
bool MatchedTunnelDestination::OnBuildResult(const i2p::tunnel::Path & path, bool inbound, i2p::tunnel::TunnelBuildResult result)
|
||
|
{
|
||
|
return true;
|
||
|
}
|
||
|
}
|
||
|
}
|