This commit is contained in:
JoelKatz
2013-03-04 21:51:04 -08:00
parent ce401dffb6
commit 81c359594e
2 changed files with 9 additions and 1 deletions

View File

@@ -147,11 +147,14 @@ void LedgerMaster::asyncAccept(Ledger::pointer ledger)
std::map< uint32, std::pair<uint256, uint256> > ledgerHashes;
uint32 minHas = ledger->getLedgerSeq();
uint32 maxHas = ledger->getLedgerSeq();
while (seq > 0)
{
{
boost::recursive_mutex::scoped_lock ml(mLock);
mCompleteLedgers.setValue(seq);
minHas = seq;
--seq;
if (mCompleteLedgers.hasValue(seq))
break;
@@ -162,6 +165,8 @@ void LedgerMaster::asyncAccept(Ledger::pointer ledger)
{
if (theApp->isShutdown())
return;
mCompleteLedgers.setRange(minHas, maxHas);
maxHas = minHas;
ledgerHashes = Ledger::getHashesByIndex((seq < 500) ? 0 : (seq - 499), seq);
it = ledgerHashes.find(seq);
if (it == ledgerHashes.end())
@@ -172,6 +177,7 @@ void LedgerMaster::asyncAccept(Ledger::pointer ledger)
break;
prevHash = it->second.second;
}
mCompleteLedgers.setRange(minHas, maxHas);
resumeAcquiring();
}

View File

@@ -98,6 +98,8 @@ template<typename c_Key, typename c_Data> void TaggedCache<c_Key, c_Data>::setTa
{
boost::recursive_mutex::scoped_lock sl(mLock);
mTargetSize = s;
if (s > 0)
mCache.rehash((s + (s >> 2)) / mCache.max_load_factor() + 1);
Log(lsDEBUG, TaggedCachePartition) << mName << " target size set to " << s;
}