@@ -112,32 +112,32 @@ namespace mongo {
112
112
namespace repl {
113
113
114
114
// Failpoint for initial sync
115
- MONGO_FAIL_POINT_DEFINE (failInitialSyncWithBadHostFCB) ;
115
+ extern FailPoint failInitialSyncWithBadHost ;
116
116
117
117
// Failpoint which causes the initial sync function to hang before creating shared data and
118
118
// splitting control flow between the oplog fetcher and the cloners.
119
- MONGO_FAIL_POINT_DEFINE (initialSyncHangBeforeSplittingControlFlowFCB) ;
119
+ extern FailPoint initialSyncHangBeforeSplittingControlFlow ;
120
120
121
121
// Failpoint which causes the initial sync function to hang before copying databases.
122
- MONGO_FAIL_POINT_DEFINE (initialSyncHangBeforeCopyingDatabasesFCB) ;
122
+ extern FailPoint initialSyncHangBeforeCopyingDatabases ;
123
123
124
124
// Failpoint which causes the initial sync function to hang before finishing.
125
- MONGO_FAIL_POINT_DEFINE (initialSyncHangBeforeFinishFCB) ;
125
+ extern FailPoint initialSyncHangBeforeFinish ;
126
126
127
127
// Failpoint which causes the initial sync function to hang before creating the oplog.
128
- MONGO_FAIL_POINT_DEFINE (initialSyncHangBeforeCreatingOplogFCB) ;
128
+ extern FailPoint initialSyncHangBeforeCreatingOplog ;
129
129
130
130
// Failpoint which skips clearing _initialSyncState after a successful initial sync attempt.
131
- MONGO_FAIL_POINT_DEFINE (skipClearInitialSyncStateFCB) ;
131
+ extern FailPoint skipClearInitialSyncState ;
132
132
133
133
// Failpoint which causes the initial sync function to fail and hang before starting a new attempt.
134
- MONGO_FAIL_POINT_DEFINE (failAndHangInitialSyncFCB) ;
134
+ extern FailPoint failAndHangInitialSync ;
135
135
136
136
// Failpoint which causes the initial sync function to hang before choosing a sync source.
137
- MONGO_FAIL_POINT_DEFINE (initialSyncHangBeforeChoosingSyncSourceFCB) ;
137
+ extern FailPoint initialSyncHangBeforeChoosingSyncSource ;
138
138
139
139
// Failpoint which causes the initial sync function to hang after finishing.
140
- MONGO_FAIL_POINT_DEFINE (initialSyncHangAfterFinishFCB) ;
140
+ extern FailPoint initialSyncHangAfterFinish ;
141
141
142
142
namespace {
143
143
using namespace executor ;
@@ -650,9 +650,9 @@ void InitialSyncerFCB::_chooseSyncSourceCallback(
650
650
std::uint32_t chooseSyncSourceAttempt,
651
651
std::uint32_t chooseSyncSourceMaxAttempts,
652
652
std::shared_ptr<OnCompletionGuard> onCompletionGuard) noexcept try {
653
- if (MONGO_unlikely (initialSyncHangBeforeChoosingSyncSourceFCB .shouldFail ())) {
654
- LOGV2 (128428 , " initialSyncHangBeforeChoosingSyncSourceFCB fail point enabled" );
655
- initialSyncHangBeforeChoosingSyncSourceFCB .pauseWhileSet ();
653
+ if (MONGO_unlikely (initialSyncHangBeforeChoosingSyncSource .shouldFail ())) {
654
+ LOGV2 (128428 , " initialSyncHangBeforeChoosingSyncSource fail point enabled" );
655
+ initialSyncHangBeforeChoosingSyncSource .pauseWhileSet ();
656
656
}
657
657
658
658
stdx::unique_lock<Latch> lock (_mutex);
@@ -666,9 +666,9 @@ void InitialSyncerFCB::_chooseSyncSourceCallback(
666
666
return ;
667
667
}
668
668
669
- if (MONGO_unlikely (failInitialSyncWithBadHostFCB .shouldFail ())) {
669
+ if (MONGO_unlikely (failInitialSyncWithBadHost .shouldFail ())) {
670
670
status = Status (ErrorCodes::InvalidSyncSource,
671
- " initial sync failed - failInitialSyncWithBadHostFCB failpoint is set." );
671
+ " initial sync failed - failInitialSyncWithBadHost failpoint is set." );
672
672
onCompletionGuard->setResultAndCancelRemainingWork_inlock (lock, status);
673
673
return ;
674
674
}
@@ -712,13 +712,13 @@ void InitialSyncerFCB::_chooseSyncSourceCallback(
712
712
return ;
713
713
}
714
714
715
- if (MONGO_unlikely (initialSyncHangBeforeCreatingOplogFCB .shouldFail ())) {
715
+ if (MONGO_unlikely (initialSyncHangBeforeCreatingOplog .shouldFail ())) {
716
716
// This log output is used in js tests so please leave it.
717
717
LOGV2 (128430 ,
718
- " initial sync - initialSyncHangBeforeCreatingOplogFCB fail point "
718
+ " initial sync - initialSyncHangBeforeCreatingOplog fail point "
719
719
" enabled. Blocking until fail point is disabled." );
720
720
lock.unlock ();
721
- while (MONGO_unlikely (initialSyncHangBeforeCreatingOplogFCB .shouldFail ()) &&
721
+ while (MONGO_unlikely (initialSyncHangBeforeCreatingOplog .shouldFail ()) &&
722
722
!_isShuttingDown ()) {
723
723
mongo::sleepsecs (1 );
724
724
}
@@ -894,12 +894,12 @@ void InitialSyncerFCB::_fcvFetcherCallback(const StatusWith<Fetcher::QueryRespon
894
894
serverGlobalParams.mutableFCV .setVersion (version);
895
895
}
896
896
897
- if (MONGO_unlikely (initialSyncHangBeforeSplittingControlFlowFCB .shouldFail ())) {
897
+ if (MONGO_unlikely (initialSyncHangBeforeSplittingControlFlow .shouldFail ())) {
898
898
lock.unlock ();
899
899
LOGV2 (128436 ,
900
- " initial sync - initialSyncHangBeforeSplittingControlFlowFCB fail point "
900
+ " initial sync - initialSyncHangBeforeSplittingControlFlow fail point "
901
901
" enabled. Blocking until fail point is disabled." );
902
- while (MONGO_unlikely (initialSyncHangBeforeSplittingControlFlowFCB .shouldFail ()) &&
902
+ while (MONGO_unlikely (initialSyncHangBeforeSplittingControlFlow .shouldFail ()) &&
903
903
!_isShuttingDown ()) {
904
904
mongo::sleepsecs (1 );
905
905
}
@@ -946,15 +946,15 @@ void InitialSyncerFCB::_fcvFetcherCallback(const StatusWith<Fetcher::QueryRespon
946
946
return ;
947
947
}
948
948
949
- if (MONGO_unlikely (initialSyncHangBeforeCopyingDatabasesFCB .shouldFail ())) {
949
+ if (MONGO_unlikely (initialSyncHangBeforeCopyingDatabases .shouldFail ())) {
950
950
lock.unlock ();
951
951
// This could have been done with a scheduleWorkAt but this is used only by JS tests where
952
952
// we run with multiple threads so it's fine to spin on this thread.
953
953
// This log output is used in js tests so please leave it.
954
954
LOGV2 (128438 ,
955
- " initial sync - initialSyncHangBeforeCopyingDatabasesFCB fail point "
955
+ " initial sync - initialSyncHangBeforeCopyingDatabases fail point "
956
956
" enabled. Blocking until fail point is disabled." );
957
- while (MONGO_unlikely (initialSyncHangBeforeCopyingDatabasesFCB .shouldFail ()) &&
957
+ while (MONGO_unlikely (initialSyncHangBeforeCopyingDatabases .shouldFail ()) &&
958
958
!_isShuttingDown ()) {
959
959
mongo::sleepsecs (1 );
960
960
}
@@ -1010,10 +1010,10 @@ void InitialSyncerFCB::_finishInitialSyncAttempt(const StatusWith<OpTimeAndWallT
1010
1010
durationCount<Milliseconds>(_sharedData->getTotalTimeUnreachable (sdLock));
1011
1011
}
1012
1012
1013
- if (MONGO_unlikely (failAndHangInitialSyncFCB .shouldFail ())) {
1014
- LOGV2 (128441 , " failAndHangInitialSyncFCB fail point enabled" );
1015
- failAndHangInitialSyncFCB .pauseWhileSet ();
1016
- result = Status (ErrorCodes::InternalError, " failAndHangInitialSyncFCB fail point enabled" );
1013
+ if (MONGO_unlikely (failAndHangInitialSync .shouldFail ())) {
1014
+ LOGV2 (128441 , " failAndHangInitialSync fail point enabled" );
1015
+ failAndHangInitialSync .pauseWhileSet ();
1016
+ result = Status (ErrorCodes::InternalError, " failAndHangInitialSync fail point enabled" );
1017
1017
}
1018
1018
1019
1019
_stats.initialSyncAttemptInfos .emplace_back (
@@ -1111,12 +1111,12 @@ void InitialSyncerFCB::_finishCallback(StatusWith<OpTimeAndWallTime> lastApplied
1111
1111
std::swap (_onCompletion, onCompletion);
1112
1112
}
1113
1113
1114
- if (MONGO_unlikely (initialSyncHangBeforeFinishFCB .shouldFail ())) {
1114
+ if (MONGO_unlikely (initialSyncHangBeforeFinish .shouldFail ())) {
1115
1115
// This log output is used in js tests so please leave it.
1116
1116
LOGV2 (128444 ,
1117
- " initial sync - initialSyncHangBeforeFinishFCB fail point "
1117
+ " initial sync - initialSyncHangBeforeFinish fail point "
1118
1118
" enabled. Blocking until fail point is disabled." );
1119
- while (MONGO_unlikely (initialSyncHangBeforeFinishFCB .shouldFail ()) && !_isShuttingDown ()) {
1119
+ while (MONGO_unlikely (initialSyncHangBeforeFinish .shouldFail ()) && !_isShuttingDown ()) {
1120
1120
mongo::sleepsecs (1 );
1121
1121
}
1122
1122
}
@@ -1148,7 +1148,7 @@ void InitialSyncerFCB::_finishCallback(StatusWith<OpTimeAndWallTime> lastApplied
1148
1148
1149
1149
// Clear the initial sync progress after an initial sync attempt has been successfully
1150
1150
// completed.
1151
- if (lastApplied.isOK () && !MONGO_unlikely (skipClearInitialSyncStateFCB .shouldFail ())) {
1151
+ if (lastApplied.isOK () && !MONGO_unlikely (skipClearInitialSyncState .shouldFail ())) {
1152
1152
_initialSyncState.reset ();
1153
1153
}
1154
1154
@@ -1159,11 +1159,11 @@ void InitialSyncerFCB::_finishCallback(StatusWith<OpTimeAndWallTime> lastApplied
1159
1159
_exec = nullptr ;
1160
1160
}
1161
1161
1162
- if (MONGO_unlikely (initialSyncHangAfterFinishFCB .shouldFail ())) {
1162
+ if (MONGO_unlikely (initialSyncHangAfterFinish .shouldFail ())) {
1163
1163
LOGV2 (128446 ,
1164
- " initial sync finished - initialSyncHangAfterFinishFCB fail point "
1164
+ " initial sync finished - initialSyncHangAfterFinish fail point "
1165
1165
" enabled. Blocking until fail point is disabled." );
1166
- while (MONGO_unlikely (initialSyncHangAfterFinishFCB .shouldFail ()) && !_isShuttingDown ()) {
1166
+ while (MONGO_unlikely (initialSyncHangAfterFinish .shouldFail ()) && !_isShuttingDown ()) {
1167
1167
mongo::sleepsecs (1 );
1168
1168
}
1169
1169
}
0 commit comments