1
0
Fork 0

Tune shard synchronization.

This commit is contained in:
Max Neunhoeffer 2016-05-20 09:53:26 +02:00
parent 523a58ecc9
commit d27af40691
1 changed files with 3 additions and 4 deletions

View File

@ -75,11 +75,11 @@ function startReadingQuery (endpoint, collName, timeout) {
}
var count = 0;
while (true) {
if (++count > 5) {
console.error("startReadingQuery: Read transaction did not begin. Giving up after 5 tries");
if (++count > 15) {
console.error("startReadingQuery: Read transaction did not begin. Giving up after 10 tries");
return false;
}
require("internal").wait(0.2);
require("internal").wait(1);
r = request({ url: url + "/_api/query/current", method: "GET" });
if (r.status !== 200) {
console.error("startReadingQuery: Bad response from /_api/query/current",
@ -106,7 +106,6 @@ function startReadingQuery (endpoint, collName, timeout) {
}
}
console.info("startReadingQuery: Did not find query.", r);
require("internal").wait(0.5, false);
}
}