#include "boost/foreach.hpp" #include "Application.h" #include "LedgerAcquire.h" LedgerAcquire::LedgerAcquire(const uint256& hash) : mHash(hash), mComplete(false), mFailed(false), mHaveBase(false), mHaveState(false), mHaveTransactions(false) { } void LedgerAcquire::done() { std::vector< boost::function > triggers; mLock.lock(); triggers=mOnComplete; mLock.unlock(); for(int i=0; i wptr) { LedgerAcquire::pointer ptr=wptr.lock(); if(ptr) ptr->trigger(true); } void LedgerAcquire::addOnComplete(boost::function trigger) { mLock.lock(); mOnComplete.push_back(trigger); mLock.unlock(); } void LedgerAcquire::trigger(bool timer) { // WRITEME } void LedgerAcquire::peerHas(Peer::pointer) { // WRITEME } void LedgerAcquire::badPeer(Peer::pointer) { // WRITEME } bool LedgerAcquire::takeBase(std::vector data) { // WRITEME return true; } bool LedgerAcquire::takeTxNode(std::list hashes, std::list > data) { // WRITEME return true; } bool LedgerAcquire::takeAsNode(std::list hashes, std::list > data) { // WRITEME return true; } bool LedgerAcquire::takeTx(std::list hashes, std::list > data) { // WRITEME return true; } LedgerAcquire::pointer LedgerAcquireMaster::findCreate(const uint256& hash) { boost::mutex::scoped_lock sl(mLock); LedgerAcquire::pointer& ptr=mLedgers[hash]; if(!ptr) ptr=LedgerAcquire::pointer(new LedgerAcquire(hash)); return ptr; } LedgerAcquire::pointer LedgerAcquireMaster::find(const uint256& hash) { LedgerAcquire::pointer ret; boost::mutex::scoped_lock sl(mLock); std::map::iterator it=mLedgers.find(hash); if(it!=mLedgers.end()) ret=it->second; return ret; } bool LedgerAcquireMaster::hasLedger(const uint256& hash) { boost::mutex::scoped_lock sl(mLock); return mLedgers.find(hash)!=mLedgers.end(); }