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.
79 lines
2.1 KiB
79 lines
2.1 KiB
#include <cryptopp/dh.h> |
|
#include "CryptoConst.h" |
|
#include "Tunnel.h" |
|
#include "NetDb.h" |
|
#include "Timestamp.h" |
|
#include "RouterContext.h" |
|
#include "TunnelPool.h" |
|
|
|
namespace i2p |
|
{ |
|
namespace tunnel |
|
{ |
|
TunnelPool::TunnelPool (i2p::data::LocalDestination * localDestination, int numTunnels): |
|
m_LocalDestination (localDestination), m_NumTunnels (numTunnels) |
|
{ |
|
CryptoPP::AutoSeededRandomPool rnd; |
|
CryptoPP::DH dh (i2p::crypto::elgp, i2p::crypto::elgg); |
|
dh.GenerateKeyPair(i2p::context.GetRandomNumberGenerator (), m_EncryptionPrivateKey, m_EncryptionPublicKey); |
|
} |
|
|
|
TunnelPool::~TunnelPool () |
|
{ |
|
for (auto it: m_InboundTunnels) |
|
it->SetTunnelPool (nullptr); |
|
} |
|
|
|
void TunnelPool::TunnelCreated (InboundTunnel * createdTunnel) |
|
{ |
|
m_InboundTunnels.insert (createdTunnel); |
|
if (m_LocalDestination) |
|
m_LocalDestination->UpdateLeaseSet (); |
|
} |
|
|
|
void TunnelPool::TunnelExpired (InboundTunnel * expiredTunnel) |
|
{ |
|
m_InboundTunnels.erase (expiredTunnel); |
|
if (m_LocalDestination) |
|
m_LocalDestination->UpdateLeaseSet (); |
|
} |
|
|
|
std::vector<InboundTunnel *> TunnelPool::GetInboundTunnels (int num) const |
|
{ |
|
std::vector<InboundTunnel *> v; |
|
int i = 0; |
|
for (auto it : m_InboundTunnels) |
|
{ |
|
if (i >= num) break; |
|
v.push_back (it); |
|
i++; |
|
} |
|
return v; |
|
} |
|
|
|
void TunnelPool::CreateTunnels () |
|
{ |
|
int num = m_InboundTunnels.size (); |
|
for (int i = num; i < m_NumTunnels; i++) |
|
CreateInboundTunnel (); |
|
} |
|
|
|
void TunnelPool::CreateInboundTunnel () |
|
{ |
|
OutboundTunnel * outboundTunnel = tunnels.GetNextOutboundTunnel (); |
|
LogPrint ("Creating destination inbound tunnel..."); |
|
auto firstHop = i2p::data::netdb.GetRandomRouter (outboundTunnel ? outboundTunnel->GetEndpointRouter () : nullptr); |
|
auto secondHop = i2p::data::netdb.GetRandomRouter (firstHop); |
|
auto * tunnel = tunnels.CreateTunnel<InboundTunnel> ( |
|
new TunnelConfig (std::vector<const i2p::data::RouterInfo *> |
|
{ |
|
firstHop, |
|
secondHop |
|
// TODO: switch to 3-hops later |
|
/*i2p::data::netdb.GetRandomRouter (secondHop) */ |
|
}), |
|
outboundTunnel); |
|
tunnel->SetTunnelPool (this); |
|
} |
|
} |
|
}
|
|
|