Add extra asserts to addrman

This commit is contained in:
Pieter Wuille 2012-05-05 21:30:38 +02:00
parent 82e6b92b0a
commit 29a86a1735

View file

@ -107,9 +107,15 @@ void CAddrMan::SwapRandom(int nRndPos1, int nRndPos2)
if (nRndPos1 == nRndPos2) if (nRndPos1 == nRndPos2)
return; return;
assert(nRndPos1 >= 0 && nRndPos2 >= 0);
assert(nRndPos1 < vRandom.size() && nRndPos2 < vRandom.size());
int nId1 = vRandom[nRndPos1]; int nId1 = vRandom[nRndPos1];
int nId2 = vRandom[nRndPos2]; int nId2 = vRandom[nRndPos2];
assert(mapInfo.count(nId1) == 1);
assert(mapInfo.count(nId2) == 1);
mapInfo[nId1].nRandomPos = nRndPos2; mapInfo[nId1].nRandomPos = nRndPos2;
mapInfo[nId2].nRandomPos = nRndPos1; mapInfo[nId2].nRandomPos = nRndPos1;
@ -130,6 +136,7 @@ int CAddrMan::SelectTried(int nKBucket)
int nTemp = vTried[nPos]; int nTemp = vTried[nPos];
vTried[nPos] = vTried[i]; vTried[nPos] = vTried[i];
vTried[i] = nTemp; vTried[i] = nTemp;
assert(nOldest == -1 || mapInfo.count(nTemp) == 1);
if (nOldest == -1 || mapInfo[nTemp].nLastSuccess < mapInfo[nOldest].nLastSuccess) if (nOldest == -1 || mapInfo[nTemp].nLastSuccess < mapInfo[nOldest].nLastSuccess)
nOldest = nTemp; nOldest = nTemp;
} }
@ -139,11 +146,13 @@ int CAddrMan::SelectTried(int nKBucket)
int CAddrMan::ShrinkNew(int nUBucket) int CAddrMan::ShrinkNew(int nUBucket)
{ {
assert(nUBucket >= 0 && nUBucket < vvNew.size());
std::set<int> &vNew = vvNew[nUBucket]; std::set<int> &vNew = vvNew[nUBucket];
// first look for deletable items // first look for deletable items
for (std::set<int>::iterator it = vNew.begin(); it != vNew.end(); it++) for (std::set<int>::iterator it = vNew.begin(); it != vNew.end(); it++)
{ {
assert(mapInfo.count(*it));
CAddrInfo &info = mapInfo[*it]; CAddrInfo &info = mapInfo[*it];
if (info.IsTerrible()) if (info.IsTerrible())
{ {
@ -168,11 +177,13 @@ int CAddrMan::ShrinkNew(int nUBucket)
{ {
if (nI == n[0] || nI == n[1] || nI == n[2] || nI == n[3]) if (nI == n[0] || nI == n[1] || nI == n[2] || nI == n[3])
{ {
assert(nOldest == -1 || mapInfo.count(*it) == 1);
if (nOldest == -1 || mapInfo[*it].nTime < mapInfo[nOldest].nTime) if (nOldest == -1 || mapInfo[*it].nTime < mapInfo[nOldest].nTime)
nOldest = *it; nOldest = *it;
} }
nI++; nI++;
} }
assert(mapInfo.count(nOldest) == 1);
CAddrInfo &info = mapInfo[nOldest]; CAddrInfo &info = mapInfo[nOldest];
if (--info.nRefCount == 0) if (--info.nRefCount == 0)
{ {
@ -189,6 +200,8 @@ int CAddrMan::ShrinkNew(int nUBucket)
void CAddrMan::MakeTried(CAddrInfo& info, int nId, int nOrigin) void CAddrMan::MakeTried(CAddrInfo& info, int nId, int nOrigin)
{ {
assert(vvNew[nOrigin].count(nId) == 1);
// remove the entry from all new buckets // remove the entry from all new buckets
for (std::vector<std::set<int> >::iterator it = vvNew.begin(); it != vvNew.end(); it++) for (std::vector<std::set<int> >::iterator it = vvNew.begin(); it != vvNew.end(); it++)
{ {
@ -197,6 +210,8 @@ void CAddrMan::MakeTried(CAddrInfo& info, int nId, int nOrigin)
} }
nNew--; nNew--;
assert(info.nRefCount == 0);
// what tried bucket to move the entry to // what tried bucket to move the entry to
int nKBucket = info.GetTriedBucket(nKey); int nKBucket = info.GetTriedBucket(nKey);
std::vector<int> &vTried = vvTried[nKBucket]; std::vector<int> &vTried = vvTried[nKBucket];
@ -214,6 +229,7 @@ void CAddrMan::MakeTried(CAddrInfo& info, int nId, int nOrigin)
int nPos = SelectTried(nKBucket); int nPos = SelectTried(nKBucket);
// find which new bucket it belongs to // find which new bucket it belongs to
assert(mapInfo.count(vTried[nPos]) == 1);
int nUBucket = mapInfo[vTried[nPos]].GetNewBucket(nKey); int nUBucket = mapInfo[vTried[nPos]].GetNewBucket(nKey);
std::set<int> &vNew = vvNew[nUBucket]; std::set<int> &vNew = vvNew[nUBucket];
@ -385,6 +401,7 @@ CAddress CAddrMan::Select_(int nUnkBias)
std::vector<int> &vTried = vvTried[nKBucket]; std::vector<int> &vTried = vvTried[nKBucket];
if (vTried.size() == 0) continue; if (vTried.size() == 0) continue;
int nPos = GetRandInt(vTried.size()); int nPos = GetRandInt(vTried.size());
assert(mapInfo.count(vTried[nPos]) == 1);
CAddrInfo &info = mapInfo[vTried[nPos]]; CAddrInfo &info = mapInfo[vTried[nPos]];
if (GetRandInt(1<<30) < fChanceFactor*info.GetChance()*(1<<30)) if (GetRandInt(1<<30) < fChanceFactor*info.GetChance()*(1<<30))
return info; return info;
@ -402,6 +419,7 @@ CAddress CAddrMan::Select_(int nUnkBias)
std::set<int>::iterator it = vNew.begin(); std::set<int>::iterator it = vNew.begin();
while (nPos--) while (nPos--)
it++; it++;
assert(mapInfo.count(*it) == 1);
CAddrInfo &info = mapInfo[*it]; CAddrInfo &info = mapInfo[*it];
if (GetRandInt(1<<30) < fChanceFactor*info.GetChance()*(1<<30)) if (GetRandInt(1<<30) < fChanceFactor*info.GetChance()*(1<<30))
return info; return info;
@ -481,6 +499,7 @@ void CAddrMan::GetAddr_(std::vector<CAddress> &vAddr)
{ {
int nRndPos = GetRandInt(vRandom.size() - n) + n; int nRndPos = GetRandInt(vRandom.size() - n) + n;
SwapRandom(n, nRndPos); SwapRandom(n, nRndPos);
assert(mapInfo.count(vRandom[n]) == 1);
vAddr.push_back(mapInfo[vRandom[n]]); vAddr.push_back(mapInfo[vRandom[n]]);
} }
} }