| 4341 | } |
| 4342 | |
| 4343 | std::set<std::tuple<service_t, instance_t, eventgroup_t>> routing_manager_impl::get_subscriptions(const client_t _client) { |
| 4344 | std::set<std::tuple<service_t, instance_t, eventgroup_t>> result; |
| 4345 | std::scoped_lock its_lock(events_mutex_); |
| 4346 | |
| 4347 | for (const auto& [key, eventmap] : events_) { |
| 4348 | for (auto [event_id, event] : eventmap) { |
| 4349 | auto its_eventgroups = event->get_eventgroups(_client); |
| 4350 | for (const auto& e : its_eventgroups) { |
| 4351 | result.insert(std::make_tuple(key.service(), key.instance(), e)); |
| 4352 | } |
| 4353 | } |
| 4354 | } |
| 4355 | |
| 4356 | return result; |
| 4357 | } |
| 4358 | |
| 4359 | void routing_manager_impl::notify_one_current_value(client_t _client, service_t _service, instance_t _instance, eventgroup_t _eventgroup, |
| 4360 | event_t _event) { |
nothing calls this directly
no test coverage detected