10BC0 timely update of database servers in cluster cache (#14569) · arangodb/arangodb@2c73237 · GitHub
[go: up one dir, main page]

Skip to content

Commit 2c73237

Browse files
authored
timely update of database servers in cluster cache (#14569)
* database and coordinator server lists need be updated for timely update of cluster info
1 parent d930127 commit 2c73237

File tree

2 files changed

+4
-1
lines changed

2 files changed

+4
-1
lines changed

CHANGELOG

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
devel
22
-----
33

4+
* Timely update of database server list on health check fixes BTS-505.
5+
46
* Add 3 AQL functions: COSINE_SIMILARITY, L1_DISTANCE and L2_DISTANCE.
57

68
* Updated ArangoDB Starter to 0.15.1.

arangod/Cluster/HeartbeatThread.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -271,14 +271,15 @@ void HeartbeatThread::run() {
271271
return true;
272272
};
273273
std::vector<std::string> const serverAgencyPaths{
274-
"Current/ServersRegistered", "Target/MapUniqueToShortID", "Current/ServersKnown",
274+
"Current/ServersRegistered", "Target/MapUniqueToShortID", "Current/ServersKnown", "Supervision/Health",
275275
"Current/ServersKnown/" + ServerState::instance()->getId()};
276276
for (auto const& path : serverAgencyPaths) {
277277
serverCallbacks.try_emplace(path, std::make_shared<AgencyCallback>(_server, path, upsrv, true, false));
278278
}
279279
std::function<bool(VPackSlice const& result)> upcrd = [self = shared_from_this()] (VPackSlice const& result) {
280280
LOG_TOPIC("2f09e", DEBUG, Logger::HEARTBEAT) << "Updating cluster's cache of current coordinators";
281281
self->server().getFeature<ClusterFeature>().clusterInfo().loadCurrentCoordinators();
282+
self->server().getFeature<ClusterFeature>().clusterInfo().loadCurrentDBServers();
282283
return true;
283284
};
284285
std::string const path = "Current/Coordinators";

0 commit comments

Comments
 (0)
0