i2pd/Transports.cpp

177 lines
4.2 KiB
C++
Raw Normal View History

2013-10-27 15:26:39 +00:00
#include <boost/bind.hpp>
#include "Log.h"
#include "RouterContext.h"
#include "I2NPProtocol.h"
#include "NetDb.h"
#include "Transports.h"
using namespace i2p::data;
namespace i2p
{
Transports transports;
Transports::Transports ():
2014-01-23 21:10:33 +00:00
m_Thread (nullptr), m_Work (m_Service),m_NTCPAcceptor (nullptr), m_SSUServer (nullptr)
2013-10-27 15:26:39 +00:00
{
}
Transports::~Transports ()
{
Stop ();
}
void Transports::Start ()
{
2013-12-29 15:48:57 +00:00
m_IsRunning = true;
2013-10-27 15:26:39 +00:00
m_Thread = new std::thread (std::bind (&Transports::Run, this));
// create acceptors
auto addresses = context.GetRouterInfo ().GetAddresses ();
for (auto& address : addresses)
{
if (address.transportStyle == RouterInfo::eTransportNTCP)
{
m_NTCPAcceptor = new boost::asio::ip::tcp::acceptor (m_Service,
boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), address.port));
2014-01-23 21:10:33 +00:00
LogPrint ("Start listening TCP port ", address.port);
2013-10-27 15:26:39 +00:00
auto conn = new i2p::ntcp::NTCPServerConnection (m_Service);
m_NTCPAcceptor->async_accept(conn->GetSocket (), boost::bind (&Transports::HandleAccept, this,
conn, boost::asio::placeholders::error));
}
2014-01-23 21:10:33 +00:00
else if (address.transportStyle == RouterInfo::eTransportSSU)
{
if (!m_SSUServer)
{
m_SSUServer = new i2p::ssu::SSUServer (m_Service, address.port);
LogPrint ("Start listening UDP port ", address.port);
m_SSUServer->Start ();
}
else
LogPrint ("SSU server already exists");
}
2013-10-27 15:26:39 +00:00
}
}
void Transports::Stop ()
{
for (auto session: m_NTCPSessions)
delete session.second;
m_NTCPSessions.clear ();
delete m_NTCPAcceptor;
2014-01-23 21:10:33 +00:00
if (m_SSUServer)
{
m_SSUServer->Stop ();
delete m_SSUServer;
}
2013-12-29 15:48:57 +00:00
m_IsRunning = false;
2013-10-27 15:26:39 +00:00
m_Service.stop ();
if (m_Thread)
{
m_Thread->join ();
delete m_Thread;
m_Thread = 0;
}
}
2013-11-29 12:52:09 +00:00
void Transports::Run ()
{
2013-12-29 15:48:57 +00:00
while (m_IsRunning)
2013-11-29 12:52:09 +00:00
{
2013-12-29 15:48:57 +00:00
try
{
m_Service.run ();
}
catch (std::exception& ex)
{
LogPrint ("Transports: ", ex.what ());
}
2013-11-29 12:52:09 +00:00
}
}
2013-10-27 15:26:39 +00:00
void Transports::AddNTCPSession (i2p::ntcp::NTCPSession * session)
{
if (session)
2013-11-29 12:52:09 +00:00
m_NTCPSessions[session->GetRemoteRouterInfo ().GetIdentHash ()] = session;
2013-10-27 15:26:39 +00:00
}
void Transports::RemoveNTCPSession (i2p::ntcp::NTCPSession * session)
{
if (session)
2013-11-29 12:52:09 +00:00
m_NTCPSessions.erase (session->GetRemoteRouterInfo ().GetIdentHash ());
2013-10-27 15:26:39 +00:00
}
void Transports::HandleAccept (i2p::ntcp::NTCPServerConnection * conn, const boost::system::error_code& error)
{
if (!error)
{
LogPrint ("Connected from ", conn->GetSocket ().remote_endpoint().address ().to_string ());
conn->ServerLogin ();
}
else
{
delete conn;
}
conn = new i2p::ntcp::NTCPServerConnection (m_Service);
m_NTCPAcceptor->async_accept(conn->GetSocket (), boost::bind (&Transports::HandleAccept, this,
conn, boost::asio::placeholders::error));
}
i2p::ntcp::NTCPSession * Transports::GetNextNTCPSession ()
{
for (auto session: m_NTCPSessions)
if (session.second->IsEstablished ())
return session.second;
return 0;
}
2013-11-29 12:52:09 +00:00
i2p::ntcp::NTCPSession * Transports::FindNTCPSession (const i2p::data::IdentHash& ident)
2013-10-27 15:26:39 +00:00
{
2013-11-29 12:52:09 +00:00
auto it = m_NTCPSessions.find (ident);
2013-10-27 15:26:39 +00:00
if (it != m_NTCPSessions.end ())
return it->second;
return 0;
}
2013-11-29 12:52:09 +00:00
void Transports::SendMessage (const i2p::data::IdentHash& ident, i2p::I2NPMessage * msg)
2013-10-27 15:26:39 +00:00
{
2013-11-29 12:52:09 +00:00
if (ident == i2p::context.GetRouterInfo ().GetIdentHash ())
2013-10-27 15:26:39 +00:00
// we send it to ourself
i2p::HandleI2NPMessage (msg, false);
2013-10-27 15:26:39 +00:00
else
2013-12-29 15:48:57 +00:00
m_Service.post (boost::bind (&Transports::PostMessage, this, ident, msg));
}
void Transports::PostMessage (const i2p::data::IdentHash& ident, i2p::I2NPMessage * msg)
{
auto session = FindNTCPSession (ident);
if (!session)
{
RouterInfo * r = netdb.FindRouter (ident);
if (r)
{
auto address = r->GetNTCPAddress ();
if (address)
2013-10-27 15:26:39 +00:00
{
2014-01-21 21:07:16 +00:00
session = new i2p::ntcp::NTCPClient (m_Service, address->host, address->port, *r);
2013-12-29 15:48:57 +00:00
AddNTCPSession (session);
}
2014-01-19 15:05:54 +00:00
else
LogPrint ("No NTCP addresses available");
2013-12-29 15:48:57 +00:00
}
2014-01-19 15:05:54 +00:00
else
{
LogPrint ("Router not found. Requested");
i2p::data::netdb.RequestDestination (ident);
}
2013-10-27 15:26:39 +00:00
}
2013-12-29 15:48:57 +00:00
if (session)
session->SendI2NPMessage (msg);
else
LogPrint ("Session not found");
2013-10-27 15:26:39 +00:00
}
}