summaryrefslogtreecommitdiff
path: root/src/mongo/db/range_deleter.cpp
diff options
context:
space:
mode:
authorAndy Schwerin <schwerin@mongodb.com>2015-05-22 15:24:52 -0400
committerAndy Schwerin <schwerin@mongodb.com>2015-05-29 10:28:03 -0400
commit4ea38c308da292f43e29d32b1b53b7324db0bafe (patch)
tree22d166a388262ae5837d0c4e44f42748194e3e47 /src/mongo/db/range_deleter.cpp
parent5c2d133871b2ad2adf6c617364d036ca25261f2d (diff)
downloadmongo-4ea38c308da292f43e29d32b1b53b7324db0bafe.tar.gz
SERVER-14995 Move operation id, lockState and client fields to OperationContext.
They have been moved from OperationContextImpl. Furthermore, the CurOp stack is now attached to OperationContext, instead of Client. With this change, an operation's lifetime is governed by the lifetime of an OperationContext object. The "_active" field of CurOp is therefore no longer meaingful. This required fixing the lifetime of OperationContext in a few places. A future change will adjust operation lifetime timing to time the lifetime of the OperationContext object, as well.
Diffstat (limited to 'src/mongo/db/range_deleter.cpp')
-rw-r--r--src/mongo/db/range_deleter.cpp14
1 files changed, 6 insertions, 8 deletions
diff --git a/src/mongo/db/range_deleter.cpp b/src/mongo/db/range_deleter.cpp
index caa2c63804c..cb00ad28554 100644
--- a/src/mongo/db/range_deleter.cpp
+++ b/src/mongo/db/range_deleter.cpp
@@ -448,8 +448,6 @@ namespace {
while (!inShutdown() && !stopRequested()) {
string errMsg;
- boost::scoped_ptr<OperationContext> txn(getGlobalServiceContext()->newOpCtx());
-
RangeDeleteEntry* nextTask = NULL;
{
@@ -472,12 +470,11 @@ namespace {
RangeDeleteEntry* entry = *iter;
set<CursorId> cursorsNow;
- {
- if (entry->options.waitForOpenCursors) {
- _env->getCursorIds(txn.get(),
- entry->options.range.ns,
- &cursorsNow);
- }
+ if (entry->options.waitForOpenCursors) {
+ auto txn = getGlobalServiceContext()->newOpCtx();
+ _env->getCursorIds(txn.get(),
+ entry->options.range.ns,
+ &cursorsNow);
}
set<CursorId> cursorsLeft;
@@ -516,6 +513,7 @@ namespace {
}
{
+ auto txn = getGlobalServiceContext()->newOpCtx();
nextTask->stats.deleteStartTS = jsTime();
bool delResult = _env->deleteRange(txn.get(),
*nextTask,