From 65c607bc13b61ab113bede77af7545df08b946aa Mon Sep 17 00:00:00 2001 From: Xin Dong Date: Tue, 21 Jan 2020 11:45:22 -0800 Subject: [PATCH] Fix the error after the rebase --- fdbserver/MasterProxyServer.actor.cpp | 24 +----------------------- 1 file changed, 1 insertion(+), 23 deletions(-) diff --git a/fdbserver/MasterProxyServer.actor.cpp b/fdbserver/MasterProxyServer.actor.cpp index acc4d84def..d4dffee32d 100644 --- a/fdbserver/MasterProxyServer.actor.cpp +++ b/fdbserver/MasterProxyServer.actor.cpp @@ -1196,29 +1196,7 @@ ACTOR Future getLiveCommittedVersion(ProxyCommitData* commi return rep; } -struct TransactionRateInfo { - double rate; - double limit; - - TransactionRateInfo(double rate) : rate(rate), limit(0) {} - - void reset(double elapsed) { - limit = std::min(0.0, limit) + rate * elapsed; // Adjust the limit based on the full elapsed interval in order to properly erase a deficit - limit = std::min(limit, rate * SERVER_KNOBS->START_TRANSACTION_BATCH_INTERVAL_MAX); // Don't allow the rate to exceed what would be allowed in the maximum batch interval - limit = std::min(limit, SERVER_KNOBS->START_TRANSACTION_MAX_TRANSACTIONS_TO_START); - } - - bool canStart(int64_t numAlreadyStarted) { - return numAlreadyStarted < limit; - } - - void updateBudget(int64_t numStarted) { - limit -= numStarted; - } -}; - -ACTOR Future sendGrvReplies(Future replyFuture, std::vector requests, - ProxyStats* stats, Version minKnownCommittedVersion) { +ACTOR Future sendGrvReplies(Future replyFuture, std::vector requests, ProxyStats *stats, Version minKnownCommittedVersion) { GetReadVersionReply reply = wait(replyFuture); double end = timer();