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

Client resends health metrics request when proxies change

This commit is contained in:
Trevor Clinkenbeard 2019-02-22 12:30:36 -08:00
parent 2a20ea6ac5
commit edc0c5bf2b
1 changed files with 26 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
fdbclient/NativeAPI.actor.cpp
View File

@ -499,22 +499,36 @@ ACTOR static Future<Void> updateHealthMetricsActor(DatabaseContext *cx) {
{
when(wait(timer))
{
state GetHealthMetricsReply rep =
wait(loadBalance(cx->getMasterProxies(),
&MasterProxyInterface::getHealthMetrics,
GetHealthMetricsRequest()));
cx->healthMetrics.update(rep.healthMetrics, false, true);
loop {
choose {
when(wait(cx->onMasterProxiesChanged())) {}
when(state GetHealthMetricsReply rep =
wait(loadBalance(cx->getMasterProxies(),
&MasterProxyInterface::getHealthMetrics,
GetHealthMetricsRequest()))) {
cx->healthMetrics.update(rep.healthMetrics, false, true);
break;
}
}
}
}
when(wait(detailedTimer))
{
ASSERT(sendDetailedHealthMetrics);
state GetDetailedHealthMetricsReply detailedRep = wait(
loadBalance(cx->getMasterProxies(),
&MasterProxyInterface::getDetailedHealthMetrics,
GetDetailedHealthMetricsRequest()));
cx->healthMetrics.update(detailedRep.getHealthMetrics(), true, true);
detailedTimer = delay(
CLIENT_KNOBS->UPDATE_DETAILED_HEALTH_METRICS_INTERVAL);
loop {
choose {
when(wait(cx->onMasterProxiesChanged())) {}
when(state GetDetailedHealthMetricsReply detailedRep =
wait(loadBalance(cx->getMasterProxies(),
&MasterProxyInterface::getDetailedHealthMetrics,
GetDetailedHealthMetricsRequest()))) {
cx->healthMetrics.update(detailedRep.getHealthMetrics(), true, true);
detailedTimer = delay(
CLIENT_KNOBS->UPDATE_DETAILED_HEALTH_METRICS_INTERVAL);
break;
}
}
}
}
}
}