diff options
| author | Randolph Tan <randolph@10gen.com> | 2017-07-17 09:54:31 -0400 |
|---|---|---|
| committer | Randolph Tan <randolph@10gen.com> | 2017-07-21 12:53:45 -0400 |
| commit | f7924be532372d4754ac3a496881e9334de21a7b (patch) | |
| tree | 51baa20662d8e83d4bb8ea9e48e8d662638eafea /src/mongo/db/exec/delete.cpp | |
| parent | 769ce1808686e408bf41844c106ab5ce289339ee (diff) | |
| download | mongo-f7924be532372d4754ac3a496881e9334de21a7b.tar.gz | |
SERVER-28912 Thread stmtId from update and delete requests to oplog
Diffstat (limited to 'src/mongo/db/exec/delete.cpp')
| -rw-r--r-- | src/mongo/db/exec/delete.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/mongo/db/exec/delete.cpp b/src/mongo/db/exec/delete.cpp index 3aa9e89dc93..059f66a5cdb 100644 --- a/src/mongo/db/exec/delete.cpp +++ b/src/mongo/db/exec/delete.cpp @@ -215,7 +215,8 @@ PlanStage::StageState DeleteStage::doWork(WorkingSetID* out) { if (!_params.isExplain) { try { WriteUnitOfWork wunit(getOpCtx()); - _collection->deleteDocument(getOpCtx(), recordId, _params.opDebug, _params.fromMigrate); + _collection->deleteDocument( + getOpCtx(), _params.stmtId, recordId, _params.opDebug, _params.fromMigrate); wunit.commit(); } catch (const WriteConflictException& wce) { memberFreer.Dismiss(); // Keep this member around so we can retry deleting it. |