ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-11-20 11:05:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

LedgerAcquire functions.

Browse Source
This commit is contained in:
JoelKatz
2012-02-16 14:37:06 -08:00
parent dad3cee004
commit 370f969c7e
2 changed files with 48 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
LedgerAcquire.cpp
View File

@@ -1,5 +1,6 @@
#include "boost/foreach.hpp"
#include "boost/make_shared.hpp"
#include "Application.h"
#include "LedgerAcquire.h"
@@ -7,6 +8,7 @@
LedgerAcquire::LedgerAcquire(const uint256& hash) : mHash(hash),
mComplete(false), mFailed(false), mHaveBase(false), mHaveState(false), mHaveTransactions(false)
{
;
}
void LedgerAcquire::done()
@@ -37,7 +39,50 @@ void LedgerAcquire::addOnComplete(boost::function<void (LedgerAcquire::pointer)>
void LedgerAcquire::trigger(bool timer)
{
// WRITEME
if(mComplete || mFailed) return;
if(!mHaveBase)
{
boost::shared_ptr<newcoin::TMGetLedger> tmGL=boost::make_shared<newcoin::TMGetLedger>();
tmGL->set_ledgerhash(mHash.begin(), mHash.size());
tmGL->set_itype(newcoin::liBASE);
sendRequest(tmGL);
}
if(mHaveBase && !mHaveTransactions)
{
// WRITEME
}
if(mHaveBase && !mHaveState)
{
// WRITEME
}
if(timer)
{
// WRITEME
}
}
void LedgerAcquire::sendRequest(boost::shared_ptr<newcoin::TMGetLedger> tmGL)
{
if(!mPeers.size()) return;
PackedMessage::pointer packet=boost::make_shared<PackedMessage>(tmGL, newcoin::mtGET_LEDGER);
std::list<boost::weak_ptr<Peer> >::iterator it=mPeers.begin();
while(it!=mPeers.end())
{
if(it->expired())
mPeers.erase(it++);
else
{ // FIXME: Possible race if peer has error
// FIXME: Track last peer sent to and time sent
it->lock()->sendPacket(packet);
return;
}
}
}
void LedgerAcquire::peerHas(Peer::pointer ptr)

2
LedgerAcquire.h
View File

@@ -9,6 +9,7 @@
#include "Ledger.h"
#include "Peer.h"
#include "newcoin.pb.h"
class LedgerAcquire : public boost::enable_shared_from_this<LedgerAcquire>
{ // A ledger we are trying to acquire
@@ -28,6 +29,7 @@ protected:
void trigger(bool timer);
static void timerEntry(boost::weak_ptr<LedgerAcquire>);
void sendRequest(boost::shared_ptr<newcoin::TMGetLedger> message);
public:
LedgerAcquire(const uint256& hash);