Lines Matching refs:_PParam
1232 static HRESULT __stdcall _Bridge(ComCallData *_PParam)
1234 _CallbackFunction *pFunc = reinterpret_cast<_CallbackFunction *>(_PParam->pUserDefined);
8107 …void _WhenAllContinuationWrapper(_RunAllParam<_ElementType>* _PParam, _Function _Func, task<_TaskT…
8113 … if (Concurrency::details::atomic_increment(_PParam->_M_completeCount) == _PParam->_M_numTasks)
8115 if (_InterlockedIncrementSizeT(&_PParam->_M_completeCount) == _PParam->_M_numTasks)
8119 _PParam->_M_completed.set(_Unit_type());
8121 delete _PParam;
8130 _PParam->_M_completed._Cancel(_Task._GetImpl()->_GetExceptionHolder());
8134 _PParam->_M_completed._Cancel();
8137 … if (Concurrency::details::atomic_increment(_PParam->_M_completeCount) == _PParam->_M_numTasks)
8139 if (_InterlockedIncrementSizeT(&_PParam->_M_completeCount) == _PParam->_M_numTasks)
8142 delete _PParam;
8159 auto _PParam = new _RunAllParam<_ElementType>();
8166 task<_Unit_type> _All_tasks_completed(_PParam->_M_completed, _Options);
8168 task<_Unit_type> _All_tasks_completed(_PParam->_M_completed, _MergedSource.get_token());
8173 * retVal = _PParam->_M_vector.Get();
8175 auto _Result = _PParam->_M_vector; // copy by value
8180 … *_It = _ResultContext<_ElementType>::_GetValue(*_It, _PParam->_M_contexts[_Index++], false);
8194 _PParam->_Resize(static_cast<size_t>(std::distance(_Begin, _End)));
8204 _PParam->_Resize(_TaskNum);
8210 _PParam->_M_completed.set(_Unit_type());
8211 delete _PParam;
8223 _PTask->_Then([_PParam, _Index](task<_ElementType> _ResultTask) -> HRESULT {
8228 auto _PParamCopy = _PParam;
8234 auto _Func = [_PParam, _Index, &_ResultTask](){
8235 _PParam->_M_vector[_Index] = _ResultTask._GetImpl()->_GetResult();
8236 … _PParam->_M_contexts[_Index] = _ResultContext<_ElementType>::_GetContext(false);
8239 _WhenAllContinuationWrapper(_PParam, _Func, _ResultTask);
8267 auto _PParam = new _RunAllParam<std::vector<_ElementType>>();
8274 task<_Unit_type> _All_tasks_completed(_PParam->_M_completed, _Options);
8276 task<_Unit_type> _All_tasks_completed(_PParam->_M_completed, _MergedSource.get_token());
8280 _CONCRT_ASSERT(_PParam->_M_completeCount == _PParam->_M_numTasks);
8282 for (size_t _I = 0; _I < _PParam->_M_numTasks; _I++)
8285 const std::vector<_ElementType>& _Vec = _PParam->_M_vector[_I].Get();
8287 std::vector<_ElementType>& _Vec = _PParam->_M_vector[_I];
8291 … *_It = _ResultContext<_ElementType>::_GetValue(*_It, _PParam->_M_contexts[_I], false);
8308 _PParam->_Resize(static_cast<size_t>(std::distance(_Begin, _End)));
8318 _PParam->_Resize(_TaskNum);
8324 _PParam->_M_completed.set(_Unit_type());
8325 delete _PParam;
8337 … _PTask->_Then([_PParam, _Index](task<std::vector<_ElementType>> _ResultTask) -> HRESULT {
8341 auto _PParamCopy = _PParam;
8347 auto _Func = [_PParam, _Index, &_ResultTask]() {
8348 _PParam->_M_vector[_Index] = _ResultTask._GetImpl()->_GetResult();
8349 … _PParam->_M_contexts[_Index] = _ResultContext<_ElementType>::_GetContext(false);
8352 _WhenAllContinuationWrapper(_PParam, _Func, _ResultTask);
8380 auto _PParam = new _RunAllParam<_Unit_type>();
8387 task<_Unit_type> _All_tasks_completed(_PParam->_M_completed, _Options);
8389 task<_Unit_type> _All_tasks_completed(_PParam->_M_completed, _MergedSource.get_token());
8403 _PParam->_Resize(static_cast<size_t>(std::distance(_Begin, _End)));
8413 _PParam->_Resize(_TaskNum);
8419 _PParam->_M_completed.set(_Unit_type());
8420 delete _PParam;
8431 _PTask->_Then([_PParam](task<void> _ResultTask) -> HRESULT {
8434 _WhenAllContinuationWrapper(_PParam, _Func, _ResultTask);
8452 auto _PParam = new _RunAllParam<_ReturnType>();
8456 task<_Unit_type> _All_tasks_completed(_PParam->_M_completed, _MergedSource.get_token());
8459 _CONCRT_ASSERT(_PParam->_M_completeCount == 2);
8461 auto _Result = _PParam->_M_vector.Get(); // copy by value
8462 auto _mergeVal = _PParam->_M_mergeVal.Get();
8464 auto _Result = _PParam->_M_vector; // copy by value
8467 *_It = _ResultContext<_ReturnType>::_GetValue(*_It, _PParam->_M_contexts[0], false);
8476 …_Result.push_back(_ResultContext<_ReturnType>::_GetValue(_PParam->_M_mergeVal, _PParam->_M_context…
8484 …nsert(_Result.begin(), _ResultContext<_ReturnType>::_GetValue(_PParam->_M_mergeVal, _PParam->_M_co…
8496 _PParam->_Resize(2, true);
8502 _VectorTask._Then([_PParam](task<std::vector<_ReturnType>> _ResultTask) -> HRESULT {
8506 auto _PParamCopy = _PParam;
8512 auto _Func = [_PParam, &_ResultTask]() {
8513 _PParam->_M_vector = _ResultTask._GetImpl()->_GetResult();
8514 _PParam->_M_contexts[0] = _ResultContext<_ReturnType>::_GetContext(false);
8518 _WhenAllContinuationWrapper(_PParam, _Func, _ResultTask);
8525 _ValueTask._Then([_PParam](task<_ReturnType> _ResultTask) -> HRESULT {
8529 auto _PParamCopy = _PParam;
8535 auto _Func = [_PParam, &_ResultTask]() {
8536 _PParam->_M_mergeVal = _ResultTask._GetImpl()->_GetResult();
8537 _PParam->_M_contexts[1] = _ResultContext<_ReturnType>::_GetContext(false);
8540 _WhenAllContinuationWrapper(_PParam, _Func, _ResultTask);
8810 …void _WhenAnyContinuationWrapper(_RunAnyParam<_CompletionType> * _PParam, const _Function & _Func,…
8812 …bool _IsTokenCancled = !_PParam->_M_fHasExplicitToken && _Task._GetImpl()->_M_pTokenState != Concu…
8817 … if (Concurrency::details::atomic_increment(_PParam->_M_completeCount) == _PParam->_M_numTasks)
8819 if (_InterlockedIncrementSizeT(&_PParam->_M_completeCount) == _PParam->_M_numTasks)
8822 delete _PParam;
8830 if (_PParam->_M_Completed._StoreException(_Task._GetImpl()->_GetExceptionHolder()))
8833 _PParam->_M_exceptionRelatedToken = _Task._GetImpl()->_M_pTokenState;
8834 _CONCRT_ASSERT(_PParam->_M_exceptionRelatedToken);
8836 … if (_PParam->_M_exceptionRelatedToken != Concurrency::details::_CancellationTokenState::_None())
8838 _PParam->_M_exceptionRelatedToken->_Reference();
8844 … if (Concurrency::details::atomic_increment(_PParam->_M_completeCount) == _PParam->_M_numTasks)
8846 if (_InterlockedIncrementSizeT(&_PParam->_M_completeCount) == _PParam->_M_numTasks)
8850 if (!_PParam->_M_Completed._IsTriggered())
8853 if (!_PParam->_M_fHasExplicitToken)
8855 if (_PParam->_M_exceptionRelatedToken)
8857 … details::_JoinAllTokens_Add(_PParam->_M_cancellationSource, _PParam->_M_exceptionRelatedToken);
8863 … details::_JoinAllTokens_Add(_PParam->_M_cancellationSource, _Task._GetImpl()->_M_pTokenState);
8867 _PParam->_M_Completed._Cancel();
8869 delete _PParam;
8890 …auto _PParam = new _RunAnyParam<std::pair<std::pair<_ElementType, size_t>, Concurrency::details::_…
8894 details::_JoinAllTokens_Add(_PParam->_M_cancellationSource, _PTokenState);
8895 _PParam->_M_fHasExplicitToken = true;
8899 _Options.set_cancellation_token(_PParam->_M_cancellationSource.get_token());
8900 …, Concurrency::details::_CancellationTokenState *>> _Any_tasks_completed(_PParam->_M_Completed, _O…
8902 …y::details::_CancellationTokenState *>> _Any_tasks_completed(_PParam->_M_Completed, _PParam->_M_ca…
8906 auto _CancellationSource = _PParam->_M_cancellationSource;
8908 _PParam->_M_numTasks = static_cast<size_t>(std::distance(_Begin, _End));
8917 _PTask->_Then([_PParam, index](task<_ElementType> _ResultTask) -> HRESULT {
8919 auto _PParamCopy = _PParam; // Dev10
8925 auto _Func = [&_ResultTask, _PParam, index]() {
8926 …_PParam->_M_Completed.set(std::make_pair(std::make_pair(_ResultTask._GetImpl()->_GetResult(), inde…
8929 _WhenAnyContinuationWrapper(_PParam, _Func, _ResultTask);
8972 …auto _PParam = new _RunAnyParam<std::pair<size_t, Concurrency::details::_CancellationTokenState *>…
8976 details::_JoinAllTokens_Add(_PParam->_M_cancellationSource, _PTokenState);
8977 _PParam->_M_fHasExplicitToken = true;
8982 _Options.set_cancellation_token(_PParam->_M_cancellationSource.get_token());
8983 …task<std::pair<size_t, _CancellationTokenState *>> _Any_tasks_completed(_PParam->_M_Completed, _Op…
8985 …y::details::_CancellationTokenState *>> _Any_tasks_completed(_PParam->_M_Completed, _PParam->_M_ca…
8988 auto _CancellationSource = _PParam->_M_cancellationSource;
8990 _PParam->_M_numTasks = static_cast<size_t>(std::distance(_Begin, _End));
8999 _PTask->_Then([_PParam, index](task<void> _ResultTask) -> HRESULT {
9001 auto _PParamCopy = _PParam; // Dev10
9007 auto _Func = [&_ResultTask, _PParam, index]() {
9008 … _PParam->_M_Completed.set(std::make_pair(index, _ResultTask._GetImpl()->_M_pTokenState));
9011 _WhenAnyContinuationWrapper(_PParam, _Func, _ResultTask);
9139 auto _PParam = new details::_RunAnyParam<std::pair<_ReturnType, size_t>>();
9141 …task<std::pair<_ReturnType, size_t>> _Any_tasks_completed(_PParam->_M_Completed, _PParam->_M_cance…
9146 …details::_JoinAllTokens_Add(_PParam->_M_cancellationSource, reinterpret_cast<Concurrency::details:…
9151 …auto _PParam = new details::_RunAnyParam<std::pair<_ReturnType, Concurrency::details::_Cancellatio…
9153 …y::details::_CancellationTokenState *>> _Any_tasks_completed(_PParam->_M_Completed, _PParam->_M_ca…
9158 details::_JoinAllTokens_Add(_PParam->_M_cancellationSource, _Ret.second);
9168 _PParam->_M_numTasks = 2;
9169 auto _Continuation = [_PParam](task<_ReturnType> _ResultTask) -> HRESULT {
9172 auto _PParamCopy = _PParam;
9177 auto _Func = [&_ResultTask, _PParam]() {
9178 …_PParam->_M_Completed.set(std::make_pair(_ResultTask._GetImpl()->_GetResult(), _ResultTask._GetImp…
9181 _WhenAnyContinuationWrapper(_PParam, _Func, _ResultTask);
9224 …auto _PParam = new details::_RunAnyParam<std::pair<std::vector<_ReturnType>, Concurrency::details:…
9226 …y::details::_CancellationTokenState *>> _Any_tasks_completed(_PParam->_M_Completed, _PParam->_M_ca…
9234 details::_JoinAllTokens_Add(_PParam->_M_cancellationSource, _Ret.second);
9244 _PParam->_M_numTasks = 2;
9245 _Lhs._Then([_PParam](task<std::vector<_ReturnType>> _ResultTask) -> HRESULT {
9248 auto _PParamCopy = _PParam;
9254 auto _Func = [&_ResultTask, _PParam]() {
9256 … _PParam->_M_Completed.set(std::make_pair(_Result, _ResultTask._GetImpl()->_M_pTokenState));
9259 _WhenAnyContinuationWrapper(_PParam, _Func, _ResultTask);
9266 _Rhs._Then([_PParam](task<_ReturnType> _ResultTask) -> HRESULT {
9270 auto _PParamCopy = _PParam;
9279 auto _Func = [&_ResultTask, _PParam]() {
9284 _PParam->_M_Completed.set(std::make_pair(_Vec, _ResultTask._GetImpl()->_M_pTokenState));
9287 _WhenAnyContinuationWrapper(_PParam, _Func, _ResultTask);
9357 …auto _PParam = new details::_RunAnyParam<std::pair<details::_Unit_type, Concurrency::details::_Can…
9359 …cy::details::_CancellationTokenState *>> _Any_task_completed(_PParam->_M_Completed, _PParam->_M_ca…
9364 details::_JoinAllTokens_Add(_PParam->_M_cancellationSource, _Ret.second);
9377 _PParam->_M_numTasks = 2;
9378 auto _Continuation = [_PParam](task<void> _ResultTask) mutable -> HRESULT {
9380 auto _PParam1 = _PParam;
9384 _WhenAnyContinuationWrapper(_PParam, _Func, _ResultTask);