mirror of
https://github.com/Xahau/xahaud.git
synced 2025-12-06 17:27:52 +00:00
Revert "Merge branch 'master' of github.com:jedmccaleb/NewCoin"
This reverts commit72e5078de7, reversing changes made tocfc8f8c052.
This commit is contained in:
@@ -2,7 +2,7 @@
|
||||
|
||||
#include <boost/foreach.hpp>
|
||||
|
||||
TaggedCache<uint256, AcceptedLedger> AcceptedLedger::ALCache("AcceptedLedger", 8, 120);
|
||||
TaggedCache<uint256, AcceptedLedger> AcceptedLedger::ALCache("AcceptedLedger", 4, 60);
|
||||
|
||||
ALTransaction::ALTransaction(uint32 seq, SerializerIterator& sit)
|
||||
{
|
||||
|
||||
@@ -107,17 +107,14 @@ LedgerAcquire::LedgerAcquire(const uint256& hash, uint32 seq) : PeerSet(hash, LE
|
||||
tryLocal();
|
||||
}
|
||||
|
||||
bool LedgerAcquire::checkLocal()
|
||||
void LedgerAcquire::checkLocal()
|
||||
{
|
||||
boost::recursive_mutex::scoped_lock sl(mLock);
|
||||
if (isDone())
|
||||
return false;
|
||||
return;
|
||||
|
||||
if (!tryLocal())
|
||||
return false;
|
||||
|
||||
done();
|
||||
return true;
|
||||
if (tryLocal())
|
||||
done();
|
||||
}
|
||||
|
||||
bool LedgerAcquire::tryLocal()
|
||||
@@ -1067,20 +1064,13 @@ void LedgerAcquireMaster::gotFetchPack(Job&)
|
||||
acquires.reserve(mLedgers.size());
|
||||
typedef std::pair<uint256, LedgerAcquire::pointer> u256_acq_pair;
|
||||
BOOST_FOREACH(const u256_acq_pair& it, mLedgers)
|
||||
{
|
||||
acquires.push_back(it.second);
|
||||
}
|
||||
}
|
||||
|
||||
int completed = 0;
|
||||
BOOST_FOREACH(const LedgerAcquire::pointer& acquire, acquires)
|
||||
{
|
||||
if (acquire->checkLocal())
|
||||
++completed;
|
||||
acquire->checkLocal();
|
||||
}
|
||||
|
||||
if (completed > 0)
|
||||
theApp->getLedgerMaster().resumeAcquiring();
|
||||
}
|
||||
|
||||
// vim:ts=4
|
||||
|
||||
@@ -130,7 +130,7 @@ public:
|
||||
void addPeers();
|
||||
void awaitData();
|
||||
void noAwaitData();
|
||||
bool checkLocal();
|
||||
void checkLocal();
|
||||
|
||||
typedef std::pair<ripple::TMGetObjectByHash::ObjectType, uint256> neededHash_t;
|
||||
std::vector<neededHash_t> getNeededHashes();
|
||||
|
||||
@@ -2131,7 +2131,7 @@ void NetworkOPs::gotFetchPack(bool progress, uint32 seq)
|
||||
mLastFetchPack = 0;
|
||||
mFetchSeq = seq; // earliest pack we have data on
|
||||
theApp->getJobQueue().addJob(jtLEDGER_DATA, "gotFetchPack",
|
||||
BIND_TYPE(&LedgerAcquireMaster::gotFetchPack, &theApp->getMasterLedgerAcquire(), P_1));
|
||||
boost::bind(&LedgerAcquireMaster::gotFetchPack, &theApp->getMasterLedgerAcquire(), _1));
|
||||
}
|
||||
|
||||
void NetworkOPs::missingNodeInLedger(uint32 seq)
|
||||
|
||||
@@ -3486,7 +3486,7 @@ Json::Value RPCHandler::doCommand(const Json::Value& jvRequest, int iRole, int &
|
||||
{ "path_find", &RPCHandler::doPathFind, false, optCurrent },
|
||||
{ "ping", &RPCHandler::doPing, false, optNone },
|
||||
// { "profile", &RPCHandler::doProfile, false, optCurrent },
|
||||
{ "proof_create", &RPCHandler::doProofCreate, true, optNone },
|
||||
{ "proof_create", &RPCHandler::doProofCreate, false, optNone },
|
||||
{ "proof_solve", &RPCHandler::doProofSolve, true, optNone },
|
||||
{ "proof_verify", &RPCHandler::doProofVerify, true, optNone },
|
||||
{ "random", &RPCHandler::doRandom, false, optNone },
|
||||
|
||||
@@ -260,6 +260,7 @@ SHAMapTreeNode* SHAMap::getNodePointer(const SHAMapNode& id, const uint256& hash
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void SHAMap::returnNode(SHAMapTreeNode::pointer& node, bool modify)
|
||||
{ // make sure the node is suitable for the intended operation (copy on write)
|
||||
assert(node->isValid());
|
||||
|
||||
@@ -126,7 +126,7 @@ std::vector<uint256> SHAMap::getNeededHashes(int max, SHAMapSyncFilter* filter)
|
||||
try
|
||||
{
|
||||
d = getNodePointer(childID, childHash, filter);
|
||||
if (d->isInner())
|
||||
if (d->isInner() && !d->isFullBelow())
|
||||
{
|
||||
have_all = false;
|
||||
stack.push(d);
|
||||
|
||||
Reference in New Issue
Block a user