Hawkin
/
arangodb
mirror of https://gitee.com/bigwinds/arangodb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

cannot depend on Slice.getDouble

This commit is contained in:
Kaveh Vahedipour 2016-12-15 15:23:45 +01:00
parent ebee9b6752
commit 8251cd46e1
4 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
arangod/Agency/CleanOutServer.cpp
View File

@ -103,7 +103,7 @@ JOB_STATUS CleanOutServer::status() {
write_ret_t res = transact(_agent, reportTrx);
if (res.accepted && res.indices.size() == 1 && res.indices[0] != 0) {
LOG_TOPIC(INFO, Logger::AGENCY) << "Have reported " << _server
LOG_TOPIC(DEBUG, Logger::AGENCY) << "Have reported " << _server
<< " in /Target/CleanedServers";
} else {
LOG_TOPIC(ERR, Logger::AGENCY) << "Failed to report " << _server
@ -131,7 +131,7 @@ bool CleanOutServer::create() { // Only through shrink cluster
}
}
LOG_TOPIC(INFO, Logger::AGENCY)
LOG_TOPIC(DEBUG, Logger::AGENCY)
<< "Todo: Clean out server " + _server + " for shrinkage";
std::string path = _agencyPrefix + toDoPrefix + _jobId;
@ -228,7 +228,7 @@ bool CleanOutServer::start() {
write_ret_t res = transact(_agent, pending);
if (res.accepted && res.indices.size() == 1 && res.indices[0]) {
LOG_TOPIC(INFO, Logger::AGENCY) << "Pending: Clean out server " + _server;
LOG_TOPIC(DEBUG, Logger::AGENCY) << "Pending: Clean out server " + _server;
// Check if we can get things done in the first place
if (!checkFeasibility()) {

2
arangod/Agency/Job.cpp
View File

@ -134,7 +134,7 @@ bool Job::finish(std::string const& type, bool success,
write_ret_t res = transact(_agent, finished);
if (res.accepted && res.indices.size() == 1 && res.indices[0]) {
LOG_TOPIC(INFO, Logger::AGENCY)
LOG_TOPIC(DEBUG, Logger::AGENCY)
<< "Successfully finished job " << type << "(" << _jobId << ")";
return true;
}

8
arangod/Agency/MoveShard.cpp
View File

@ -81,7 +81,7 @@ bool MoveShard::create() {
}
}
LOG_TOPIC(INFO, Logger::AGENCY)
LOG_TOPIC(DEBUG, Logger::AGENCY)
<< "Todo: Move shard " + _shard + " from " + _from + " to " << _to;
std::string path, now(timepointToString(std::chrono::system_clock::now()));
@ -249,8 +249,8 @@ bool MoveShard::start() {
try {
_snapshot(toDoPrefix + _jobId).toBuilder(todo);
} catch (std::exception const&) {
LOG_TOPIC(INFO, Logger::AGENCY) << "Failed to get key " + toDoPrefix +
_jobId + " from agency snapshot";
LOG_TOPIC(INFO, Logger::AGENCY)
<< "Failed to get key " + toDoPrefix + _jobId + " from agency snapshot";
return false;
}
} else {
@ -358,7 +358,7 @@ bool MoveShard::start() {
write_ret_t res = transact(_agent, pending);
if (res.accepted && res.indices.size() == 1 && res.indices[0]) {
LOG_TOPIC(INFO, Logger::AGENCY)
LOG_TOPIC(DEBUG, Logger::AGENCY)
<< "Pending: Move shard " + _shard + " from " + _from + " to " + _to;
return true;
}

4
arangod/Cluster/HeartbeatThread.cpp
View File

@ -195,7 +195,7 @@ void HeartbeatThread::runDBServer() {
AgencyCommManager::path("Current/Version"),
AgencyCommManager::path("Sync/Commands", _myId)}));
AgencyCommResult result = _agency.sendTransactionWithFailover(trx);
AgencyCommResult result = _agency.sendTransactionWithFailover(trx, 1.0);
if (!result.successful()) {
LOG_TOPIC(WARN, Logger::HEARTBEAT)
<< "Heartbeat: Could not read from agency!";
@ -348,7 +348,7 @@ void HeartbeatThread::runCoordinator() {
AgencyCommManager::path("Sync/Commands", _myId),
AgencyCommManager::path("Sync/UserVersion"),
AgencyCommManager::path("Target/FailedServers")}));
AgencyCommResult result = _agency.sendTransactionWithFailover(trx);
AgencyCommResult result = _agency.sendTransactionWithFailover(trx, 1.0);
if (!result.successful()) {
LOG_TOPIC(WARN, Logger::HEARTBEAT)