diff options
| author | Vishnu Kaushik <vishnu.kaushik@mongodb.com> | 2021-02-16 19:34:01 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-02-18 01:48:19 +0000 |
| commit | 1ff65f085af47596a2048baa2a1ccf5d9c9a2755 (patch) | |
| tree | a7d137399f95a4d67979cde9d64e96e0f2ed5835 /src/mongo/db/repl/tenant_oplog_applier.cpp | |
| parent | b2d42972c374aeea62ed203ea652631fe26d53bb (diff) | |
| download | mongo-1ff65f085af47596a2048baa2a1ccf5d9c9a2755.tar.gz | |
SERVER-53926 replace recipientSyncData (with returnAfterTimestamp) errors with interrupt status when appropriate
Diffstat (limited to 'src/mongo/db/repl/tenant_oplog_applier.cpp')
| -rw-r--r-- | src/mongo/db/repl/tenant_oplog_applier.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/mongo/db/repl/tenant_oplog_applier.cpp b/src/mongo/db/repl/tenant_oplog_applier.cpp index 846a30533fd..a2143a95b87 100644 --- a/src/mongo/db/repl/tenant_oplog_applier.cpp +++ b/src/mongo/db/repl/tenant_oplog_applier.cpp @@ -56,6 +56,7 @@ namespace mongo { namespace repl { MONGO_FAIL_POINT_DEFINE(hangInTenantOplogApplication); +MONGO_FAIL_POINT_DEFINE(fpBeforeTenantOplogApplyingBatch); TenantOplogApplier::TenantOplogApplier(const UUID& migrationUuid, const std::string& tenantId, @@ -277,6 +278,7 @@ void TenantOplogApplier::_applyOplogBatch(TenantOplogBatch* batch) { uassertStatusOK(status); } + fpBeforeTenantOplogApplyingBatch.pauseWhileSet(); LOGV2_DEBUG(4886011, 1, |