diff options
author | Benety Goh <benety@mongodb.com> | 2018-05-15 22:21:15 -0400 |
---|---|---|
committer | Benety Goh <benety@mongodb.com> | 2018-05-15 22:21:15 -0400 |
commit | 63d721812d0d72c31d1144bbe7e46f53041d3733 (patch) | |
tree | 7021d178ac5eced4be66bf58ec2829889e2b6b15 /src/mongo/db | |
parent | fa3fae04c144048bebf3f4c58e08b7b0c32743e1 (diff) | |
download | mongo-63d721812d0d72c31d1144bbe7e46f53041d3733.tar.gz |
SERVER-32335 remove unused InitialSyncerOptions::batchLimits
Diffstat (limited to 'src/mongo/db')
-rw-r--r-- | src/mongo/db/repl/initial_syncer.h | 9 | ||||
-rw-r--r-- | src/mongo/db/repl/initial_syncer_test.cpp | 2 | ||||
-rw-r--r-- | src/mongo/db/repl/replication_coordinator_impl.cpp | 1 |
3 files changed, 0 insertions, 12 deletions
diff --git a/src/mongo/db/repl/initial_syncer.h b/src/mongo/db/repl/initial_syncer.h index ea8a6ff71ef..063900142c9 100644 --- a/src/mongo/db/repl/initial_syncer.h +++ b/src/mongo/db/repl/initial_syncer.h @@ -47,7 +47,6 @@ #include "mongo/db/repl/optime.h" #include "mongo/db/repl/rollback_checker.h" #include "mongo/db/repl/sync_source_selector.h" -#include "mongo/db/repl/sync_tail.h" #include "mongo/stdx/condition_variable.h" #include "mongo/stdx/functional.h" #include "mongo/stdx/mutex.h" @@ -91,11 +90,6 @@ struct InitialSyncerOptions { /** Function to sets this node into a specific follower mode. */ using SetFollowerModeFn = stdx::function<bool(const MemberState&)>; - /** - * Struct to hold oplog application batch limits. - */ - using BatchLimits = SyncTail::BatchLimits; - // Error and retry values Milliseconds syncSourceRetryWait{1000}; Milliseconds initialSyncRetryWait{1000}; @@ -108,9 +102,6 @@ struct InitialSyncerOptions { // SyncTail::tryPopAndWaitForMore(). Milliseconds getApplierBatchCallbackRetryWait{1000}; - // Batching settings. - BatchLimits batchLimits; - // Replication settings NamespaceString localOplogNS = NamespaceString("local.oplog.rs"); NamespaceString remoteOplogNS = NamespaceString("local.oplog.rs"); diff --git a/src/mongo/db/repl/initial_syncer_test.cpp b/src/mongo/db/repl/initial_syncer_test.cpp index 5a6df37ba4d..97e27678f80 100644 --- a/src/mongo/db/repl/initial_syncer_test.cpp +++ b/src/mongo/db/repl/initial_syncer_test.cpp @@ -320,8 +320,6 @@ protected: InitialSyncerOptions options; options.initialSyncRetryWait = Milliseconds(1); - options.batchLimits.bytes = 512 * 1024 * 1024U; - options.batchLimits.ops = 5000U; options.getMyLastOptime = [this]() { return _myLastOpTime; }; options.setMyLastOptime = [this](const OpTime& opTime, ReplicationCoordinator::DataConsistency consistency) { diff --git a/src/mongo/db/repl/replication_coordinator_impl.cpp b/src/mongo/db/repl/replication_coordinator_impl.cpp index cea5dc3dd97..c7f2cc07184 100644 --- a/src/mongo/db/repl/replication_coordinator_impl.cpp +++ b/src/mongo/db/repl/replication_coordinator_impl.cpp @@ -317,7 +317,6 @@ InitialSyncerOptions createInitialSyncerOptions( }; options.resetOptimes = [replCoord]() { replCoord->resetMyLastOpTimes(); }; options.syncSourceSelector = replCoord; - options.batchLimits = externalState->getInitialSyncBatchLimits(); options.oplogFetcherMaxFetcherRestarts = externalState->getOplogFetcherMaxFetcherRestarts(); return options; } |