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

compile warning

This commit is contained in:
Xiaoxi Wang 2022-08-09 12:32:46 -07:00
parent ea0c60381f
commit b834bd8421
2 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
fdbserver/DataDistributionQueue.actor.cpp
View File

@ -548,9 +548,9 @@ struct DDQueue {
void increase(const UID& id, RelocateReason reason, CountType type) {
int idx = (int)(reason);
if (idx < 0 || idx >= RelocateReason::typeCount()) {
TraceEvent(SevWarnAlways, "Debug").detail("Reason", reason.toString());
}
// if (idx < 0 || idx >= RelocateReason::typeCount()) {
// TraceEvent(SevWarnAlways, "ServerCounterDebug").detail("Reason", reason.toString());
// }
ASSERT(idx >= 0 && idx < RelocateReason::typeCount());
counter[id][idx][(int)type] += 1;
}
@ -2411,7 +2411,9 @@ ACTOR Future<Void> dataDistributionQueue(Database cx,
debug_setCheckRelocationDuration(false);
}
}
when(KeyRange done = waitNext(rangesComplete.getFuture())) { keysToLaunchFrom = done; }
when(KeyRange done = waitNext(rangesComplete.getFuture())) {
keysToLaunchFrom = done;
}
when(wait(recordMetrics)) {
Promise<int64_t> req;
getAverageShardBytes.send(req);
@ -2458,7 +2460,9 @@ ACTOR Future<Void> dataDistributionQueue(Database cx,
}
when(wait(self.error.getFuture())) {} // Propagate errors from dataDistributionRelocator
when(wait(waitForAll(ddQueueFutures))) {}
when(Promise<int> r = waitNext(getUnhealthyRelocationCount)) { r.send(self.unhealthyRelocations); }
when(Promise<int> r = waitNext(getUnhealthyRelocationCount)) {
r.send(self.unhealthyRelocations);
}
}
}
} catch (Error& e) {
@ -2479,7 +2483,9 @@ TEST_CASE("/DataDistribution/DDQueue/ServerCounterTrace") {
std::cout << "Start trace counter unit test for " << duration << "s ...\n";
loop choose {
when(wait(counterFuture)) {}
when(wait(finishFuture)) { break; }
when(wait(finishFuture)) {
break;
}
when(wait(delayJittered(2.0))) {
std::vector<UID> team(3);
for (int i = 0; i < team.size(); ++i) {

1
fdbserver/include/fdbserver/DataDistribution.actor.h
View File

@ -52,6 +52,7 @@ public:
default:
ASSERT(false);
}
return "";
}
operator int() const { return (int)value; }
constexpr static int8_t typeCount() { return 3; }