reset some changes
This commit is contained in:
parent
5e8f55768a
commit
878adad43f
|
@ -795,7 +795,7 @@ ACTOR Future<Void> preresolutionProcessing(CommitBatchContext* self) {
|
|||
double queuingDelay = g_network->now() - timeStart;
|
||||
pProxyCommitData->stats.commitBatchQueuingDist->sampleSeconds(queuingDelay);
|
||||
if ((queuingDelay > (double)SERVER_KNOBS->MAX_READ_TRANSACTION_LIFE_VERSIONS / SERVER_KNOBS->VERSIONS_PER_SECOND ||
|
||||
(g_network->isSimulated() && BUGGIFY_WITH_PROB(0.0))) &&
|
||||
(g_network->isSimulated() && BUGGIFY_WITH_PROB(0.01))) &&
|
||||
SERVER_KNOBS->PROXY_REJECT_BATCH_QUEUED_TOO_LONG && canReject(trs)) {
|
||||
// Disabled for the recovery transaction. otherwise, recovery can't finish and keeps doing more recoveries.
|
||||
TEST(true); // Reject transactions in the batch
|
||||
|
|
|
@ -30,7 +30,7 @@ bool g_crashOnError = false;
|
|||
#define DEBUG_ERROR 0
|
||||
|
||||
#if DEBUG_ERROR
|
||||
std::set<int> debugErrorSet = std::set<int>{ error_code_transaction_too_old };
|
||||
std::set<int> debugErrorSet = std::set<int>{ error_code_platform_error };
|
||||
#define SHOULD_LOG_ERROR(x) (debugErrorSet.count(x) > 0)
|
||||
#endif
|
||||
|
||||
|
|
Loading…
Reference in New Issue