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

Get sources servers by DC in DDAuditRange.

This commit is contained in:
He Liu 2022-09-12 09:35:24 -07:00
parent e6846e1ed5
commit e6df139204
4 changed files with 20 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
fdbclient/include/fdbclient/Audit.h
View File

@ -73,12 +73,13 @@ struct AuditStorageRequest {
template <class Ar>
void serialize(Ar& ar) {
serializer(ar, id, range, type, reply);
serializer(ar, id, range, type, targetServers, reply);
}
UID id;
KeyRange range;
uint8_t type;
std::vector<UID> targetServers;
ReplyPromise<AuditStorageState> reply;
};

2
fdbserver/DDTxnProcessor.actor.cpp
View File

@ -132,7 +132,7 @@ class DDTxnProcessorImpl {
continue;
}
const StorageServerInterface ssi = decodeServerListValue(serverListValue.get());
current.servers.push_back(ssi);
current.servers[ssi.locality.describeDcId()].push_back(ssi);
}
res.push_back(current);
}

20
fdbserver/DataDistribution.actor.cpp
View File

@ -1344,7 +1344,7 @@ ACTOR Future<Void> scheduleAuditForRange(Reference<DataDistributor> self,
UID auditId,
KeyRange range,
AuditType type) {
TraceEvent(SevDebug, "DDScheduleAuditBegin", auditId).detail("Range", range).detail("AuditType", type);
TraceEvent(SevDebug, "DDScheduleAuditForRangeBegin", auditId).detail("Range", range).detail("AuditType", type);
// TODO(heliu): Load the audit map for `range`.
state Key begin = range.begin;
state KeyRange currentRange = range;
@ -1370,9 +1370,18 @@ ACTOR Future<Void> scheduleAuditForRange(Reference<DataDistributor> self,
state int i = 0;
for (i = 0; i < rangeLocations.size(); ++i) {
const AuditStorageRequest req(auditId, rangeLocations[i].range, type);
const int idx = deterministicRandom()->randomInt(0, rangeLocations[i].servers.size());
actors->add(doAuditStorage(self, actors, auditMap, rangeLocations[i].servers[idx], req));
AuditStorageRequest req(auditId, rangeLocations[i].range, type);
if (type == AuditType::ValidateHA && rangeLocations[i].servers.size() >= 2) {
auto it = rangeLocations[i].servers.begin();
const int idx = deterministicRandom()->randomInt(0, it->second.size());
StorageServerInterface& targetServer = it->second[idx];
++it;
for (; it != rangeLocations[i].servers.end(); ++it) {
const int idx = deterministicRandom()->randomInt(0, it->second.size());
req.targetServers.push_back(it->second[idx].id());
}
actors->add(doAuditStorage(self, actors, auditMap, targetServer, req));
}
begin = rangeLocations[i].range.end;
wait(delay(0.01));
}
@ -1395,7 +1404,8 @@ ACTOR Future<Void> doAuditStorage(Reference<DataDistributor> self,
TraceEvent(SevDebug, "DDAuditStorageBegin", req.id)
.detail("Range", req.range)
.detail("AuditType", req.type)
.detail("StorageServer", ssi.toString());
.detail("StorageServer", ssi.toString())
.detail("TargetServers", describe(req.targetServers));
try {
auditMap->insert(req.range, AuditPhase::Running);

3
fdbserver/include/fdbserver/DDTxnProcessor.h
View File

@ -41,7 +41,8 @@ public:
StorageServersForRange() = default;
StorageServersForRange(KeyRangeRef range) : range(range) {}
std::vector<StorageServerInterface> servers;
// A map of dcId : list of servers
std::map<std::string, std::vector<StorageServerInterface>> servers;
KeyRange range;
};