| 23 | } |
| 24 | |
| 25 | void _TaskProcessor::process() |
| 26 | { |
| 27 | if (_pendingRequestIds.empty()) { |
| 28 | return; |
| 29 | } |
| 30 | std::vector<PersisterRequestId> newRequestIds; |
| 31 | for (auto const& requestId : _pendingRequestIds) { |
| 32 | if (auto state = _persisterFacade->getRequestState(requestId)) { |
| 33 | if (state.value() == PersisterRequestState::Finished) { |
| 34 | _finishFunc(requestId); |
| 35 | } |
| 36 | if (state.value() == PersisterRequestState::InQueue || state.value() == PersisterRequestState::InProgress) { |
| 37 | newRequestIds.emplace_back(requestId); |
| 38 | } |
| 39 | } |
| 40 | } |
| 41 | _pendingRequestIds = newRequestIds; |
| 42 | |
| 43 | auto criticalErrors = _persisterFacade->fetchAllErrorInfos(SenderId{_senderId}); |
| 44 | if (!criticalErrors.empty()) { |
| 45 | _errorFunc(criticalErrors); |
| 46 | } |
| 47 | } |
| 48 | |
| 49 | _TaskProcessor::_TaskProcessor(PersisterFacade const& persisterFacade, std::string const& senderId) |
| 50 | : _persisterFacade(persisterFacade) |
nothing calls this directly
no test coverage detected