ARCHIVE/xahaud
3
0
Fork 0
mirror of https://github.com/Xahau/xahaud.git synced 2025-12-06 17:27:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Disable peerfinder hooks

Browse Source
This commit is contained in:
Vinnie Falco
2013-11-07 09:53:21 -08:00
parent 286ade2d17
commit 63aa7284c4
2 changed files with 18 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/ripple/peerfinder/impl/Manager.cpp
View File

@@ -296,11 +296,13 @@ public:
void addFallbackStrings (std::string const& name,
std::vector <std::string> const& strings)
{
#if RIPPLE_USE_PEERFINDER
m_queue.dispatch (
m_context.wrap (
bind (
&Logic::addStaticSource, &m_logic,
SourceStrings::New (name, strings))));
#endif
}
void addFallbackURL (std::string const& name, std::string const& url)
@@ -310,59 +312,73 @@ public:
void onPeerConnectAttemptBegins (IPAddress const& address)
{
#if RIPPLE_USE_PEERFINDER
m_queue.dispatch (
m_context.wrap (
bind (&Logic::onPeerConnectAttemptBegins, &m_logic,
address)));
#endif
}
void onPeerConnectAttemptCompletes (IPAddress const& address, bool success)
{
#if RIPPLE_USE_PEERFINDER
m_queue.dispatch (
m_context.wrap (
bind (&Logic::onPeerConnectAttemptCompletes, &m_logic,
address, success)));
#endif
}
void onPeerConnected (const IPAddress &address, bool incoming)
{
#if RIPPLE_USE_PEERFINDER
m_queue.dispatch (
m_context.wrap (
bind (&Logic::onPeerConnected, &m_logic,
address, incoming)));
#endif
}
void onPeerHandshake (PeerID const& id,
IPAddress const& address, bool incoming)
{
#if RIPPLE_USE_PEERFINDER
m_queue.dispatch (
m_context.wrap (
bind (&Logic::onPeerHandshake, &m_logic,
id, address, incoming)));
#endif
}
void onPeerDisconnected (const PeerID& id)
{
#if RIPPLE_USE_PEERFINDER
m_queue.dispatch (
m_context.wrap (
bind (&Logic::onPeerDisconnected, &m_logic,
id)));
#endif
}
void onPeerLegacyEndpoint (IPAddress const& ep)
{
#if RIPPLE_USE_PEERFINDER
m_queue.dispatch (
m_context.wrap (
bind (&Logic::onPeerLegacyEndpoint, &m_logic,
ep)));
#endif
}
void onPeerEndpoints (PeerID const& id,
std::vector <Endpoint> const& endpoints)
{
#if RIPPLE_USE_PEERFINDER
m_queue.dispatch (
beast::bind (&Logic::onPeerEndpoints, &m_logic,
id, endpoints));
#endif
}
//--------------------------------------------------------------------------

2
src/ripple_app/peers/Peer.cpp
View File

@@ -651,8 +651,10 @@ void PeerImp::connect (const std::string& strIp, int iPort)
void PeerImp::handleConnect (const boost::system::error_code& error, boost::asio::ip::tcp::resolver::iterator it)
{
// Notify peer finder about the status of this in-progress connection attempt
#if RIPPLE_USE_PEERFINDER
getApp ().getPeers ().getPeerFinder ().onPeerConnectAttemptCompletes(
IPAddress::from_string(getIP()).withPort(getPort()), !error );
#endif
if (error)
{