mirror of https://gitee.com/bigwinds/arangodb
Merge branch 'devel' of ssh://github.com/ArangoDB/ArangoDB into devel
This commit is contained in:
commit
655a6d7c9b
|
@ -372,13 +372,23 @@ void HeartbeatThread::runCoordinator() {
|
|||
AgencyCommManager::path("Shutdown"),
|
||||
AgencyCommManager::path("Sync/Commands", _myId),
|
||||
AgencyCommManager::path("Sync/UserVersion"),
|
||||
AgencyCommManager::path("Target/FailedServers")}));
|
||||
AgencyCommManager::path("Target/FailedServers"), "/.agency"}));
|
||||
AgencyCommResult result = _agency.sendTransactionWithFailover(trx, 1.0);
|
||||
|
||||
if (!result.successful()) {
|
||||
LOG_TOPIC(WARN, Logger::HEARTBEAT)
|
||||
<< "Heartbeat: Could not read from agency!";
|
||||
} else {
|
||||
|
||||
VPackSlice agentPool =
|
||||
result.slice()[0].get(
|
||||
std::vector<std::string>({".agency","pool"}));
|
||||
if (agentPool.isObject()) {
|
||||
_agency.updateEndpoints(agentPool);
|
||||
} else {
|
||||
LOG(DEBUG) << "Cannot find an agency persisted in RAFT 8|";
|
||||
}
|
||||
|
||||
VPackSlice shutdownSlice = result.slice()[0].get(
|
||||
std::vector<std::string>({AgencyCommManager::path(), "Shutdown"}));
|
||||
|
||||
|
|
|
@ -202,6 +202,7 @@ for aid in `seq 0 $(( $NRAGENTS - 1 ))`; do
|
|||
--server.threads 16 \
|
||||
--log.file cluster/$port.log \
|
||||
--log.force-direct true \
|
||||
--log.level agency=DEBUG \
|
||||
$LOG_LEVEL_AGENCY \
|
||||
$AUTHENTICATION \
|
||||
$SSLKEYFILE \
|
||||
|
|
Loading…
Reference in New Issue