summaryrefslogtreecommitdiff
path: root/src/mongo/db/range_deleter_mock_env.cpp
diff options
context:
space:
mode:
authorRandolph Tan <randolph@10gen.com>2014-06-06 11:50:52 -0400
committerRandolph Tan <randolph@10gen.com>2014-06-16 13:27:23 -0400
commit0fd5d7a29ccc7c15c6e7fb2126d347f5996cf13f (patch)
tree0cea70e2eb2c9c9192a3043698cf40e56efc8493 /src/mongo/db/range_deleter_mock_env.cpp
parent36d49e00d13b0dd083db75cbc14404b3f823a5a7 (diff)
downloadmongo-0fd5d7a29ccc7c15c6e7fb2126d347f5996cf13f.tar.gz
SERVER-13648 better stats from migration cleanup
Log waiting cursor ids and add serverStatus section
Diffstat (limited to 'src/mongo/db/range_deleter_mock_env.cpp')
-rw-r--r--src/mongo/db/range_deleter_mock_env.cpp23
1 files changed, 14 insertions, 9 deletions
diff --git a/src/mongo/db/range_deleter_mock_env.cpp b/src/mongo/db/range_deleter_mock_env.cpp
index a01117e4a2c..2a5da12c2c3 100644
--- a/src/mongo/db/range_deleter_mock_env.cpp
+++ b/src/mongo/db/range_deleter_mock_env.cpp
@@ -106,11 +106,9 @@ namespace mongo {
}
bool RangeDeleterMockEnv::deleteRange(OperationContext* txn,
- const StringData& ns,
- const BSONObj& min,
- const BSONObj& max,
- const BSONObj& shardKeyPattern,
- bool secondaryThrottle,
+ const RangeDeleteEntry& taskDetails,
+ long long int* deletedDocs,
+ ReplTime* lastOp,
string* errMsg) {
{
@@ -133,10 +131,10 @@ namespace mongo {
scoped_lock sl(_deleteListMutex);
DeletedRange entry;
- entry.ns = ns.toString();
- entry.min = min.getOwned();
- entry.max = max.getOwned();
- entry.shardKeyPattern = shardKeyPattern.getOwned();
+ entry.ns = taskDetails.ns;
+ entry.min = taskDetails.min.getOwned();
+ entry.max = taskDetails.max.getOwned();
+ entry.shardKeyPattern = taskDetails.shardKeyPattern.getOwned();
_deleteList.push_back(entry);
}
@@ -144,6 +142,13 @@ namespace mongo {
return true;
}
+ bool RangeDeleterMockEnv::waitForReplication(ReplTime lastOp,
+ const BSONObj& writeConcern,
+ long long int timeoutSecs,
+ string* errMsg) {
+ return true;
+ }
+
void RangeDeleterMockEnv::getCursorIds(
OperationContext* txn, const StringData& ns, set<CursorId>* in) {
{