| 2902 | } |
| 2903 | |
| 2904 | void routing_manager_client::unsubscribe_base(client_t _client, service_t _service, instance_t _instance, eventgroup_t _eventgroup, |
| 2905 | event_t _event, std::scoped_lock<std::mutex> const& _lock) { |
| 2906 | |
| 2907 | if (_event != ANY_EVENT) { |
| 2908 | auto its_event = find_provided_event(_service, _instance, _event, _lock); |
| 2909 | if (its_event) { |
| 2910 | its_event->remove_subscriber(_eventgroup, _client); |
| 2911 | } |
| 2912 | } else { |
| 2913 | auto its_eventgroup = find_eventgroup(provided_eventgroups_, _service, _instance, _eventgroup, _lock); |
| 2914 | if (its_eventgroup) { |
| 2915 | for (const auto& e : its_eventgroup->get_events()) { |
| 2916 | if (e) |
| 2917 | e->remove_subscriber(_eventgroup, _client); |
| 2918 | } |
| 2919 | } |
| 2920 | } |
| 2921 | } |
| 2922 | |
| 2923 | bool routing_manager_client::insert_subscription(service_t _service, instance_t _instance, eventgroup_t _eventgroup, event_t _event, |
| 2924 | const std::shared_ptr<debounce_filter_impl_t>& _filter, client_t _client, |
nothing calls this directly
no test coverage detected