mirror of
https://github.com/Xahau/xahaud.git
synced 2025-12-06 17:27:52 +00:00
Some extra LedgerAcquire helper functions.
This commit is contained in:
@@ -326,6 +326,29 @@ void PeerSet::sendRequest(const ripple::TMGetLedger& tmGL)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
int PeerSet::takePeerSetFrom(const PeerSet& s)
|
||||||
|
{
|
||||||
|
int ret = 0;
|
||||||
|
mPeers.clear();
|
||||||
|
mPeers.reserve(s.mPeers.size());
|
||||||
|
BOOST_FOREACH(const boost::weak_ptr<Peer>& p, s.mPeers)
|
||||||
|
if (p.lock())
|
||||||
|
{
|
||||||
|
mPeers.push_back(p);
|
||||||
|
++ret;
|
||||||
|
}
|
||||||
|
return ret;
|
||||||
|
}
|
||||||
|
|
||||||
|
int PeerSet::getPeerCount() const
|
||||||
|
{
|
||||||
|
int ret = 0;
|
||||||
|
BOOST_FOREACH(const boost::weak_ptr<Peer>& p, mPeers)
|
||||||
|
if (p.lock())
|
||||||
|
++ret;
|
||||||
|
return ret;
|
||||||
|
}
|
||||||
|
|
||||||
bool LedgerAcquire::takeBase(const std::string& data)
|
bool LedgerAcquire::takeBase(const std::string& data)
|
||||||
{ // Return value: true=normal, false=bad data
|
{ // Return value: true=normal, false=bad data
|
||||||
#ifdef LA_DEBUG
|
#ifdef LA_DEBUG
|
||||||
|
|||||||
@@ -45,6 +45,9 @@ public:
|
|||||||
void badPeer(Peer::ref);
|
void badPeer(Peer::ref);
|
||||||
void resetTimer();
|
void resetTimer();
|
||||||
|
|
||||||
|
int takePeerSetFrom(const PeerSet& s);
|
||||||
|
int getPeerCount() const;
|
||||||
|
|
||||||
protected:
|
protected:
|
||||||
virtual void newPeer(Peer::ref) = 0;
|
virtual void newPeer(Peer::ref) = 0;
|
||||||
virtual void onTimer(void) = 0;
|
virtual void onTimer(void) = 0;
|
||||||
|
|||||||
Reference in New Issue
Block a user