| 4233 | } |
| 4234 | |
| 4235 | std::set<std::shared_ptr<eventgroupinfo>> routing_manager_impl::find_eventgroups(service_t _service, instance_t _instance) const { |
| 4236 | |
| 4237 | std::set<std::shared_ptr<eventgroupinfo>> its_eventgroups; |
| 4238 | |
| 4239 | std::scoped_lock its_lock{eventgroups_mutex_}; |
| 4240 | const auto search = eventgroups_.find(service_instance_t{_service, _instance}); |
| 4241 | |
| 4242 | if (search != eventgroups_.end()) { |
| 4243 | for (const auto& [eventgroup_id, eventgroup_info] : search->second) { |
| 4244 | its_eventgroups.insert(eventgroup_info); |
| 4245 | } |
| 4246 | } |
| 4247 | |
| 4248 | return its_eventgroups; |
| 4249 | } |
| 4250 | void routing_manager_impl::remove_eventgroup_info(service_t _service, instance_t _instance, eventgroup_t _eventgroup) { |
| 4251 | std::scoped_lock its_lock(eventgroups_mutex_); |
| 4252 | const auto search = eventgroups_.find(service_instance_t{_service, _instance}); |