8000 fixed jslint error · Kitter/arangodb@b601597 · GitHub
[go: up one dir, main page]

Skip to content

Commit b601597

Browse files
committed
fixed jslint error
1 parent 278e51e commit b601597

File tree

1 file changed

+4
-7
lines changed

1 file changed

+4
-7
lines changed

js/server/modules/@arangodb/cluster.js

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -538,9 +538,10 @@ function synchronizeOneShard (database, shard, planId, leader) {
538538
var ok = false;
539539
const rep = require('@arangodb/replication');
540540

541+
var db = require("internal").db;
541542
var ep = ArangoClusterInfo.getServerEndpoint(leader);
542543

543-
if (require("internal").db._collection(shard).count() === 0) {
544+
if (db._collection(shard).count() === 0) {
544545
// We try a short cut:
545546
console.topic('heartbeat=debug', "synchronizeOneShard: trying short cut to synchronize local shard '%s/%s' for central '%s/%s'", database, shard, database, planId);
546547
try {
@@ -550,9 +551,7 @@ function synchronizeOneShard (database, shard, planId, leader) {
550551
let endTime = new Date();
551552
console.topic('heartbeat=debug', 'synchronizeOneShard: shortcut worked, done, %s/%s, %s/%s, started: %s, ended: %s',
552553
database, shard, database, planId, startTime.toString(), endTime.toString());
553-
var db = require("internal").db;
554-
var collection = db._collection(shard);
555-
collection.setTheLeader(leader);
554+
db._collection(shard).setTheLeader(leader);
556555
return;
557556
}
558557
} catch (dummy) { }
@@ -569,9 +568,7 @@ function synchronizeOneShard (database, shard, planId, leader) {
569568
// Mark us as follower for this leader such that we begin
570569
// accepting replication operations, note that this is also
571570
// used for the initial synchronization:
572-
var db = require("internal").db;
573-
var collection = db._collection(shard);
574-
collection.setTheLeader(leader);
571+
db._collection(shard).setTheLeader(leader);
575572

576573
let startTime = new Date();
577574
sy = rep.syncCollection(shard,

0 commit comments

Comments
 (0)
0