|
|
@ -3043,77 +3043,12 @@ void ThreadScriptCheck() { |
|
|
|
scriptcheckqueue.Thread(); |
|
|
|
} |
|
|
|
|
|
|
|
//
|
|
|
|
// Called periodically asynchronously; alerts if it smells like
|
|
|
|
// we're being fed a bad chain (blocks being generated much
|
|
|
|
// too slowly or too quickly).
|
|
|
|
//
|
|
|
|
void PartitionCheck(bool (*initialDownloadCheck)(), CCriticalSection& cs, const CBlockIndex *const &bestHeader, |
|
|
|
int64_t nPowTargetSpacing) |
|
|
|
{ |
|
|
|
if (bestHeader == NULL || initialDownloadCheck()) return; |
|
|
|
|
|
|
|
static int64_t lastAlertTime = 0; |
|
|
|
int64_t now = GetTime(); |
|
|
|
if (lastAlertTime > now-60*60*24) return; // Alert at most once per day
|
|
|
|
|
|
|
|
const int SPAN_HOURS=4; |
|
|
|
const int SPAN_SECONDS=SPAN_HOURS*60*60; |
|
|
|
int BLOCKS_EXPECTED = SPAN_SECONDS / nPowTargetSpacing; |
|
|
|
|
|
|
|
boost::math::poisson_distribution<double> poisson(BLOCKS_EXPECTED); |
|
|
|
|
|
|
|
std::string strWarning; |
|
|
|
int64_t startTime = GetTime()-SPAN_SECONDS; |
|
|
|
|
|
|
|
LOCK(cs); |
|
|
|
const CBlockIndex* i = bestHeader; |
|
|
|
int nBlocks = 0; |
|
|
|
while (i->GetBlockTime() >= startTime) { |
|
|
|
++nBlocks; |
|
|
|
i = i->pprev; |
|
|
|
if (i == NULL) return; // Ran out of chain, we must not be fully synced
|
|
|
|
} |
|
|
|
|
|
|
|
// How likely is it to find that many by chance?
|
|
|
|
double p = boost::math::pdf(poisson, nBlocks); |
|
|
|
|
|
|
|
LogPrint("partitioncheck", "%s : Found %d blocks in the last %d hours\n", __func__, nBlocks, SPAN_HOURS); |
|
|
|
LogPrint("partitioncheck", "%s : likelihood: %g\n", __func__, p); |
|
|
|
|
|
|
|
// Aim for one false-positive about every fifty years of normal running:
|
|
|
|
const int FIFTY_YEARS = 50*365*24*60*60; |
|
|
|
double alertThreshold = 1.0 / (FIFTY_YEARS / SPAN_SECONDS); |
|
|
|
|
|
|
|
if (bestHeader->GetHeight() > BLOCKS_EXPECTED) |
|
|
|
{ |
|
|
|
if (p <= alertThreshold && nBlocks < BLOCKS_EXPECTED) |
|
|
|
{ |
|
|
|
// Many fewer blocks than expected: alert!
|
|
|
|
strWarning = strprintf(_("WARNING: check your network connection, %d blocks received in the last %d hours (%d expected)"), |
|
|
|
nBlocks, SPAN_HOURS, BLOCKS_EXPECTED); |
|
|
|
} |
|
|
|
else if (p <= alertThreshold && nBlocks > BLOCKS_EXPECTED) |
|
|
|
{ |
|
|
|
// Many more blocks than expected: alert!
|
|
|
|
strWarning = strprintf(_("WARNING: abnormally high number of blocks generated, %d blocks received in the last %d hours (%d expected)"), |
|
|
|
nBlocks, SPAN_HOURS, BLOCKS_EXPECTED); |
|
|
|
} |
|
|
|
} |
|
|
|
if (!strWarning.empty()) |
|
|
|
{ |
|
|
|
strMiscWarning = strWarning; |
|
|
|
CAlert::Notify(strWarning, true); |
|
|
|
lastAlertTime = now; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static int64_t nTimeVerify = 0; |
|
|
|
static int64_t nTimeConnect = 0; |
|
|
|
static int64_t nTimeIndex = 0; |
|
|
|
static int64_t nTimeVerify = 0; |
|
|
|
static int64_t nTimeConnect = 0; |
|
|
|
static int64_t nTimeIndex = 0; |
|
|
|
static int64_t nTimeCallbacks = 0; |
|
|
|
static int64_t nTimeTotal = 0; |
|
|
|
static int64_t nTimeTotal = 0; |
|
|
|
bool FindBlockPos(int32_t tmpflag,CValidationState &state, CDiskBlockPos &pos, unsigned int nAddSize, unsigned int nHeight, uint64_t nTime, bool fKnown = false); |
|
|
|
bool ReceivedBlockTransactions(const CBlock &block, CValidationState& state, CBlockIndex *pindexNew, const CDiskBlockPos& pos); |
|
|
|
|
|
|
@ -7324,10 +7259,15 @@ bool static ProcessMessage(CNode* pfrom, string strCommand, CDataStream& vRecv, |
|
|
|
|
|
|
|
LOCK(cs_main); |
|
|
|
|
|
|
|
if (chainActive.LastTip() != 0 && chainActive.LastTip()->GetHeight() > 100000 && IsInitialBlockDownload()) |
|
|
|
{ |
|
|
|
//fprintf(stderr,"dont process getheaders during initial download\n");
|
|
|
|
return true; |
|
|
|
|
|
|
|
if (chainActive.LastTip() != 0 && chainActive.LastTip()->GetHeight() > 100000 && IsInitialBlockDownload()) { |
|
|
|
if(pfrom->fAllowlisted) { |
|
|
|
LogPrint("net", "Allowing getheaders from allowlisted peer=%d during initial block download\n", pfrom->id); |
|
|
|
} else { |
|
|
|
LogPrint("net", "Ignoring getheaders from peer=%d because node is in initial block download\n", pfrom->id); |
|
|
|
//fprintf(stderr,"dont process getheaders during initial download\n");
|
|
|
|
return true; |
|
|
|
} |
|
|
|
} |
|
|
|
CBlockIndex* pindex = NULL; |
|
|
|
if (locator.IsNull()) |
|
|
|