diff options
| author | Judah Schvimer <judah@mongodb.com> | 2016-10-10 13:57:42 -0400 |
|---|---|---|
| committer | Judah Schvimer <judah@mongodb.com> | 2016-10-10 13:57:42 -0400 |
| commit | 72f985618f287ef8d55921a8a5b337a25fbee8e4 (patch) | |
| tree | 276363cc26b9260033aac90ee621b90faeb682d7 /src | |
| parent | fadd01e32d40f1e72f062de1864a7cb631ee17fa (diff) | |
| download | mongo-72f985618f287ef8d55921a8a5b337a25fbee8e4.tar.gz | |
SERVER-26549 DataReplicator should check for OplogBuffer's existence before clearing it
Diffstat (limited to 'src')
| -rw-r--r-- | src/mongo/db/repl/data_replicator.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/mongo/db/repl/data_replicator.cpp b/src/mongo/db/repl/data_replicator.cpp index 08a0fc94b99..038a0d31b71 100644 --- a/src/mongo/db/repl/data_replicator.cpp +++ b/src/mongo/db/repl/data_replicator.cpp @@ -419,7 +419,9 @@ Timestamp DataReplicator::_applyUntilAndPause(Timestamp untilTimestamp) { void DataReplicator::_resetState_inlock(OperationContext* txn, OpTimeWithHash lastAppliedOpTime) { invariant(!_anyActiveHandles_inlock()); _lastApplied = _lastFetched = lastAppliedOpTime; - _oplogBuffer->clear(txn); + if (_oplogBuffer) { + _oplogBuffer->clear(txn); + } } void DataReplicator::setScheduleDbWorkFn_forTest(const CollectionCloner::ScheduleDbWorkFn& work) { |