Browse Source

send exporatory message directly if connected to a floodfill

pull/164/head
orignal 9 years ago
parent
commit
60351f2677
  1. 2
      NetDb.cpp
  2. 6
      Transports.cpp
  3. 3
      Transports.h

2
NetDb.cpp

@ -828,6 +828,8 @@ namespace data @@ -828,6 +828,8 @@ namespace data
if (floodfill && !floodfills.count (floodfill.get ())) // request floodfill only once
{
floodfills.insert (floodfill.get ());
if (i2p::transport::transports.IsConnected (floodfill->GetIdentHash ()))
throughTunnels = false;
if (throughTunnels)
{
msgs.push_back (i2p::tunnel::TunnelMessageBlock

6
Transports.cpp

@ -474,6 +474,12 @@ namespace transport @@ -474,6 +474,12 @@ namespace transport
});
}
bool Transports::IsConnected (const i2p::data::IdentHash& ident) const
{
auto it = m_Peers.find (ident);
return it != m_Peers.end ();
}
void Transports::HandlePeerCleanupTimer (const boost::system::error_code& ecode)
{
if (ecode != boost::asio::error::operation_aborted)

3
Transports.h

@ -88,7 +88,8 @@ namespace transport @@ -88,7 +88,8 @@ namespace transport
void PeerConnected (std::shared_ptr<TransportSession> session);
void PeerDisconnected (std::shared_ptr<TransportSession> session);
bool IsConnected (const i2p::data::IdentHash& ident) const;
void UpdateSentBytes (uint64_t numBytes) { m_TotalSentBytes += numBytes; };
void UpdateReceivedBytes (uint64_t numBytes) { m_TotalReceivedBytes += numBytes; };
uint64_t GetTotalSentBytes () const { return m_TotalSentBytes; };

Loading…
Cancel
Save