@@ -538,9 +538,10 @@ function synchronizeOneShard (database, shard, planId, leader) {
538
538
var ok = false ;
539
539
const rep = require ( '@arangodb/replication' ) ;
540
540
541
+ var db = require ( "internal" ) . db ;
541
542
var ep = ArangoClusterInfo . getServerEndpoint ( leader ) ;
542
543
543
- if ( require ( "internal" ) . db . _collection ( shard ) . count ( ) === 0 ) {
544
+ if ( db . _collection ( shard ) . count ( ) === 0 ) {
544
545
// We try a short cut:
545
546
console . topic ( 'heartbeat=debug' , "synchronizeOneShard: trying short cut to synchronize local shard '%s/%s' for central '%s/%s'" , database , shard , database , planId ) ;
546
547
try {
@@ -550,9 +551,7 @@ function synchronizeOneShard (database, shard, planId, leader) {
550
551
let endTime = new Date ( ) ;
551
552
console . topic ( 'heartbeat=debug' , 'synchronizeOneShard: shortcut worked, done, %s/%s, %s/%s, started: %s, ended: %s' ,
552
553
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 ) ;
556
555
return ;
557
556
}
558
557
} catch ( dummy ) { }
@@ -569,9 +568,7 @@ function synchronizeOneShard (database, shard, planId, leader) {
569
568
// Mark us as follower for this leader such that we begin
570
569
// accepting replication operations, note that this is also
571
570
// 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 ) ;
575
572
576
573
let startTime = new Date ( ) ;
577
574
sy = rep . syncCollection ( shard ,
0 commit comments