Home
last modified time | relevance | path

Searched refs:_onCompletion (Results 1 – 13 of 13) sorted by relevance

/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/repl/
H A Dcallback_completion_guard.h104 const OnCompletionFn _onCompletion; variable
114 : _cancelRemainingWorkInLock(cancelRemainingWorkInLock), _onCompletion(onCompletion) {} in CallbackCompletionGuard()
123 _onCompletion(*_result); in ~CallbackCompletionGuard()
H A Dmultiapplier.cpp54 _onCompletion(onCompletion) { in MultiApplier()
164 decltype(_onCompletion) onCompletion; in _finishCallback()
167 invariant(_onCompletion); in _finishCallback()
168 std::swap(_onCompletion, onCompletion); in _finishCallback()
H A Dmultiapplier.h158 CallbackFn _onCompletion; variable
H A Dsync_source_resolver.h235 const OnCompletionFn _onCompletion; variable
H A Dcollection_cloner.cpp117 _onCompletion(onCompletion), in CollectionCloner()
955 decltype(_onCompletion) onCompletion; in _finishCallback()
962 invariant(_onCompletion); in _finishCallback()
963 std::swap(_onCompletion, onCompletion); in _finishCallback()
H A Ddatabase_cloner.h231 CallbackFn _onCompletion; // (R) Invoked once when cloning completes or fails. variable
H A Ddatabase_cloner.cpp124 _onCompletion(onCompletion), in DatabaseCloner()
485 _onCompletion(status); in _finishCallback()
H A Dcollection_cloner.h289 CallbackFn _onCompletion; // (M) Invoked once when cloning completes or fails. variable
H A Dsync_source_resolver.cpp69 _onCompletion(onCompletion) { in SyncSourceResolver()
535 _onCompletion(response); in _finishCallback()
H A Dinitial_syncer.cpp181 _onCompletion(onCompletion) { in InitialSyncer()
190 uassert(ErrorCodes::BadValue, "callback function cannot be null", _onCompletion); in InitialSyncer()
1231 decltype(_onCompletion) onCompletion; in _finishCallback()
1237 invariant(_onCompletion); in _finishCallback()
1238 std::swap(_onCompletion, onCompletion); in _finishCallback()
H A Dsync_source_resolver_test.cpp86 SyncSourceResolver::OnCompletionFn _onCompletion; member in __anon245c32bd0111::SyncSourceResolverTest
104 _onCompletion = [this](const SyncSourceResolverResponse& response) { _response = response; }; in setUp()
128 [this](const SyncSourceResolverResponse& response) { _onCompletion(response); }); in _makeResolver()
363 _onCompletion = [this](const SyncSourceResolverResponse& response) { in TEST_F()
H A Dinitial_syncer.h595 OnCompletionFn _onCompletion; // (M) variable
H A Dinitial_syncer_test.cpp408 _onCompletion = [this](const StatusWith<OpTimeWithHash>& lastApplied) { in setUp()
422 _onCompletion(lastApplied); in setUp()
487 InitialSyncer::OnCompletionFn _onCompletion; member in __anon0601e19c0111::InitialSyncerTest
966 _onCompletion = [this](const StatusWith<OpTimeWithHash>& lastApplied) { in TEST_F()