diff options
| author | Andy Schwerin <schwerin@mongodb.com> | 2015-03-26 18:45:22 -0400 |
|---|---|---|
| committer | Andy Schwerin <schwerin@mongodb.com> | 2015-04-06 10:16:23 -0400 |
| commit | 90b7f774b818a1038cc525a9fca14207d8d5ff71 (patch) | |
| tree | 604285e3d69ef379626ddd8f0a57068c287ea2ef /src/mongo/db/dbhelpers.cpp | |
| parent | 387e39a07522aec114a64146871eab2e015d7444 (diff) | |
| download | mongo-90b7f774b818a1038cc525a9fca14207d8d5ff71.tar.gz | |
SERVER-17817 Move replication-specific data from Client into ReplClientInfo decoration.
Diffstat (limited to 'src/mongo/db/dbhelpers.cpp')
| -rw-r--r-- | src/mongo/db/dbhelpers.cpp | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/mongo/db/dbhelpers.cpp b/src/mongo/db/dbhelpers.cpp index 6833aa33dc9..d74d74f493c 100644 --- a/src/mongo/db/dbhelpers.cpp +++ b/src/mongo/db/dbhelpers.cpp @@ -58,6 +58,7 @@ #include "mongo/db/query/internal_plans.h" #include "mongo/db/query/query_planner.h" #include "mongo/db/range_arithmetic.h" +#include "mongo/db/repl/repl_client_info.h" #include "mongo/db/repl/replication_coordinator_global.h" #include "mongo/db/storage_options.h" #include "mongo/db/write_concern.h" @@ -459,9 +460,10 @@ namespace mongo { if (writeConcern.shouldWaitForOtherNodes() && numDeleted > 0) { repl::ReplicationCoordinator::StatusAndDuration replStatus = - repl::getGlobalReplicationCoordinator()->awaitReplication(txn, - txn->getClient()->getLastOp(), - writeConcern); + repl::getGlobalReplicationCoordinator()->awaitReplication( + txn, + repl::ReplClientInfo::forClient(txn->getClient()).getLastOp(), + writeConcern); if (replStatus.status.code() == ErrorCodes::ExceededTimeLimit) { warning(LogComponent::kSharding) << "replication to secondaries for removeRange at " |