Searched refs:_onCompletion (Results 1 – 13 of 13) sorted by relevance
104 const OnCompletionFn _onCompletion; variable114 : _cancelRemainingWorkInLock(cancelRemainingWorkInLock), _onCompletion(onCompletion) {} in CallbackCompletionGuard()123 _onCompletion(*_result); in ~CallbackCompletionGuard()
54 _onCompletion(onCompletion) { in MultiApplier()164 decltype(_onCompletion) onCompletion; in _finishCallback()167 invariant(_onCompletion); in _finishCallback()168 std::swap(_onCompletion, onCompletion); in _finishCallback()
158 CallbackFn _onCompletion; variable
235 const OnCompletionFn _onCompletion; variable
117 _onCompletion(onCompletion), in CollectionCloner()955 decltype(_onCompletion) onCompletion; in _finishCallback()962 invariant(_onCompletion); in _finishCallback()963 std::swap(_onCompletion, onCompletion); in _finishCallback()
231 CallbackFn _onCompletion; // (R) Invoked once when cloning completes or fails. variable
124 _onCompletion(onCompletion), in DatabaseCloner()485 _onCompletion(status); in _finishCallback()
289 CallbackFn _onCompletion; // (M) Invoked once when cloning completes or fails. variable
69 _onCompletion(onCompletion) { in SyncSourceResolver()535 _onCompletion(response); in _finishCallback()
181 _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()
86 SyncSourceResolver::OnCompletionFn _onCompletion; member in __anon245c32bd0111::SyncSourceResolverTest104 _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()
595 OnCompletionFn _onCompletion; // (M) variable
408 _onCompletion = [this](const StatusWith<OpTimeWithHash>& lastApplied) { in setUp()422 _onCompletion(lastApplied); in setUp()487 InitialSyncer::OnCompletionFn _onCompletion; member in __anon0601e19c0111::InitialSyncerTest966 _onCompletion = [this](const StatusWith<OpTimeWithHash>& lastApplied) { in TEST_F()