summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/replication_recovery.cpp
diff options
context:
space:
mode:
authorJudah Schvimer <judah@mongodb.com>2018-04-17 15:43:17 -0400
committerJudah Schvimer <judah@mongodb.com>2018-04-18 14:09:18 -0400
commite43a56ac700bd658f4a0dea58b243f0cb78aa65f (patch)
tree2d58d621e368ead37c36f4d794584f160cbfca6f /src/mongo/db/repl/replication_recovery.cpp
parent1d0a162b662c0592954570b15a7c9b4e55e090fe (diff)
downloadmongo-e43a56ac700bd658f4a0dea58b243f0cb78aa65f.tar.gz
SERVER-34070 log all operations during replication recovery in tests
Diffstat (limited to 'src/mongo/db/repl/replication_recovery.cpp')
-rw-r--r--src/mongo/db/repl/replication_recovery.cpp4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/mongo/db/repl/replication_recovery.cpp b/src/mongo/db/repl/replication_recovery.cpp
index fa2c7cd8d66..0762e54e368 100644
--- a/src/mongo/db/repl/replication_recovery.cpp
+++ b/src/mongo/db/repl/replication_recovery.cpp
@@ -26,12 +26,13 @@
* it in the license file.
*/
#define MONGO_LOG_DEFAULT_COMPONENT ::mongo::logger::LogComponent::kReplication
+#define LOG_FOR_RECOVERY(level) \
+ MONGO_LOG_COMPONENT(level, ::mongo::logger::LogComponent::kStorageRecovery)
#include "mongo/platform/basic.h"
#include "mongo/db/repl/replication_recovery.h"
-#include "mongo/db/catalog/document_validation.h"
#include "mongo/db/db_raii.h"
#include "mongo/db/dbdirectclient.h"
#include "mongo/db/namespace_string.h"
@@ -228,6 +229,7 @@ void ReplicationRecoveryImpl::_applyToEndOfOplog(OperationContext* opCtx,
BSONObj entry;
while (cursor->more()) {
entry = cursor->nextSafe();
+ LOG_FOR_RECOVERY(2) << "Applying op during replication recovery: " << redact(entry);
fassert(40294, SyncTail::syncApply(opCtx, entry, OplogApplication::Mode::kRecovering));
auto oplogEntry = fassert(50763, OplogEntry::parse(entry));