summaryrefslogtreecommitdiff
path: root/src/mongo/db/repair_database.cpp
diff options
context:
space:
mode:
authorHari Khalsa <hkhalsa@10gen.com>2014-05-15 15:07:14 -0400
committerHari Khalsa <hkhalsa@10gen.com>2014-05-15 15:51:32 -0400
commita26f0197137e43e130ee7a8c5e42399f6ccd2005 (patch)
tree03b1b1b2b865e7a654d9c7bdf973df56fc8df150 /src/mongo/db/repair_database.cpp
parent9628f0418502a97aff046e9ae28bebdab4d6b9cd (diff)
downloadmongo-a26f0197137e43e130ee7a8c5e42399f6ccd2005.tar.gz
SERVER-13641 remove recovery unit passthroughs from operationcontext
Diffstat (limited to 'src/mongo/db/repair_database.cpp')
-rw-r--r--src/mongo/db/repair_database.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mongo/db/repair_database.cpp b/src/mongo/db/repair_database.cpp
index aa69da2b021..0e5087c0b4c 100644
--- a/src/mongo/db/repair_database.cpp
+++ b/src/mongo/db/repair_database.cpp
@@ -244,7 +244,7 @@ namespace mongo {
<< "db: " << _dbName << " path: " << _pathString;
try {
- _txn->syncDataAndTruncateJournal();
+ _txn->recoveryUnit()->syncDataAndTruncateJournal();
MongoFile::flushAll(true); // need both in case journaling is disabled
{
Client::Context tempContext( _dbName, _pathString );
@@ -283,7 +283,7 @@ namespace mongo {
BackgroundOperation::assertNoBgOpInProgForDb(dbName);
- txn->syncDataAndTruncateJournal(); // Must be done before and after repair
+ txn->recoveryUnit()->syncDataAndTruncateJournal(); // Must be done before and after repair
intmax_t totalSize = dbSize( dbName );
intmax_t freeSize = File::freeSpace(storageGlobalParams.repairpath);
@@ -407,7 +407,7 @@ namespace mongo {
if ( !result.isOK() )
return result.getStatus();
- txn->commitIfNeeded();
+ txn->recoveryUnit()->commitIfNeeded();
txn->checkForInterrupt(false);
}
@@ -420,7 +420,7 @@ namespace mongo {
}
- txn->syncDataAndTruncateJournal();
+ txn->recoveryUnit()->syncDataAndTruncateJournal();
MongoFile::flushAll(true); // need both in case journaling is disabled
txn->checkForInterrupt(false);