diff options
Diffstat (limited to 'src/mongo/db/range_deleter_db_env.cpp')
| -rw-r--r-- | src/mongo/db/range_deleter_db_env.cpp | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/mongo/db/range_deleter_db_env.cpp b/src/mongo/db/range_deleter_db_env.cpp index 3658f99cd2c..29e96e4ead4 100644 --- a/src/mongo/db/range_deleter_db_env.cpp +++ b/src/mongo/db/range_deleter_db_env.cpp @@ -63,7 +63,7 @@ namespace mongo { const BSONObj inclusiveLower(taskDetails.min); const BSONObj exclusiveUpper(taskDetails.max); const BSONObj keyPattern(taskDetails.shardKeyPattern); - const bool secondaryThrottle(taskDetails.secondaryThrottle); + const WriteConcernOptions writeConcern(taskDetails.writeConcern); const bool initiallyHaveClient = haveClient(); @@ -85,8 +85,6 @@ namespace mongo { << endl; try { - bool throttle = repl::getGlobalReplicationCoordinator()->getReplicationMode() == - repl::ReplicationCoordinator::modeReplSet ? secondaryThrottle : false; *deletedDocs = Helpers::removeRange(txn, KeyRange(ns, @@ -94,7 +92,7 @@ namespace mongo { exclusiveUpper, keyPattern), false, /*maxInclusive*/ - throttle, + writeConcern, serverGlobalParams.moveParanoia ? &removeSaver : NULL, true, /*fromMigrate*/ true); /*onlyRemoveOrphans*/ |