wbtiger
/
foundationdb
mirror of https://github.com/apple/foundationdb.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix problem caused by merge

This commit is contained in:
A.J. Beamon 2019-02-27 12:21:07 -08:00
parent a6205391ae
commit d48a2d7b54
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
fdbserver/MasterProxyServer.actor.cpp
View File

@ -88,12 +88,15 @@ Future<Void> forwardValue(Promise<T> out, Future<T> in)
int getBytes(Promise<Version> const& r) { return 0; } int getBytes(Promise<Version> const& r) { return 0; }
ACTOR Future<Void> getRate(UID myID, Reference<AsyncVar<ServerDBInfo>> db, int64_t* inTransactionCount, double* outTransactionRate, double* outBatchTransactionRate) { ACTOR Future<Void> getRate(UID myID, Reference<AsyncVar<ServerDBInfo>> db, int64_t* inTransactionCount, double* outTransactionRate, double* outBatchTransactionRate) {
state Future<Void> nextRequestTimer = Void(); state Future<Void> nextRequestTimer = Never();
state Future<Void> leaseTimeout = Never(); state Future<Void> leaseTimeout = Never();
state Future<GetRateInfoReply> reply = Never(); state Future<GetRateInfoReply> reply = Never();
state int64_t lastTC = 0; state int64_t lastTC = 0;
if (db->get().distributor.present()) nextRequestTimer = Void(); if (db->get().distributor.present()) {
nextRequestTimer = Void();
}
loop choose { loop choose {
when ( wait( db->onChange() ) ) { when ( wait( db->onChange() ) ) {
if ( db->get().distributor.present() ) { if ( db->get().distributor.present() ) {
@ -119,7 +122,7 @@ ACTOR Future<Void> getRate(UID myID, Reference<AsyncVar<ServerDBInfo>> db, int64
leaseTimeout = delay(rep.leaseDuration); leaseTimeout = delay(rep.leaseDuration);
nextRequestTimer = delayJittered(rep.leaseDuration / 2); nextRequestTimer = delayJittered(rep.leaseDuration / 2);
} }
when ( wait(leaseTimeout ) ) { when ( wait( leaseTimeout ) ) {
*outTransactionRate = 0; *outTransactionRate = 0;
*outBatchTransactionRate = 0; *outBatchTransactionRate = 0;
//TraceEvent("MasterProxyRate", myID).detail("Rate", 0).detail("BatchRate", 0).detail("Lease", "Expired"); //TraceEvent("MasterProxyRate", myID).detail("Rate", 0).detail("BatchRate", 0).detail("Lease", "Expired");