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

waitForCommit is new default behaviour of writes in agency

This commit is contained in:
Kaveh Vahedipour 2016-06-09 13:36:17 +02:00
parent 79d467daa9
commit a13de0044e
3 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
arangod/Agency/RestAgencyHandler.cpp
View File

@ -153,7 +153,7 @@ HttpHandler::status_t RestAgencyHandler::handleWrite() {
} catch (std::exception const& e) { } catch (std::exception const& e) {
LOG_TOPIC(WARN, Logger::AGENCY) << e.what(); LOG_TOPIC(WARN, Logger::AGENCY) << e.what();
} }
std::this_thread::sleep_for(duration_t(1)); std::this_thread::sleep_for(duration_t(2));
if (max_index > 0) { if (max_index > 0) {
_agent->waitFor(max_index); _agent->waitFor(max_index);
} }

2
arangod/Agency/Supervision.cpp
View File

@ -271,7 +271,7 @@ void Supervision::run() {
// make sense at all without other ArangoDB servers, we wait pretty // make sense at all without other ArangoDB servers, we wait pretty
// long here before giving up: // long here before giving up:
if (!updateAgencyPrefix(1000, 1)) { if (!updateAgencyPrefix(1000, 1)) {
LOG_TOPIC(ERR, Logger::AGENCY) LOG_TOPIC(DEBUG, Logger::AGENCY)
<< "Cannot get prefix from Agency. Stopping supervision for good."; << "Cannot get prefix from Agency. Stopping supervision for good.";
break; break;
} }

1
js/client/tests/agency/agency-test.js
View File

@ -355,7 +355,6 @@ function agencyTestSuite () {
leaderEndpoint = config.configuration.endpoints[config.leaderId].replace("tcp", "http"); leaderEndpoint = config.configuration.endpoints[config.leaderId].replace("tcp", "http");
break; break;
} }
wait(0.05);
} }
} else { } else {
leaderEndpoint = agencyServers[0].replace("tcp", "http"); leaderEndpoint = agencyServers[0].replace("tcp", "http");