| 4152 | } |
| 4153 | |
| 4154 | void routing_manager_impl::unset_all_eventpayloads(service_t _service, instance_t _instance) { |
| 4155 | std::set<std::shared_ptr<event>> its_events; |
| 4156 | { |
| 4157 | std::scoped_lock its_lock(eventgroups_mutex_); |
| 4158 | const auto search = eventgroups_.find(service_instance_t{_service, _instance}); |
| 4159 | |
| 4160 | if (search != eventgroups_.end()) { |
| 4161 | for (const auto& [eventgroup_id, eventgroup_info] : search->second) { |
| 4162 | for (const auto& event : eventgroup_info->get_events()) { |
| 4163 | its_events.insert(event); |
| 4164 | } |
| 4165 | } |
| 4166 | } |
| 4167 | } |
| 4168 | |
| 4169 | for (const auto& e : its_events) { |
| 4170 | if (e->is_set()) { |
| 4171 | VSOMEIP_INFO_P << "Unsetting payload for [" << hex4(_service) << "." << hex4(_instance) << "." << hex4(e->get_event()) << "]"; |
| 4172 | } |
| 4173 | e->unset_payload(true); |
| 4174 | } |
| 4175 | } |
| 4176 | |
| 4177 | void routing_manager_impl::unset_all_eventpayloads(service_t _service, instance_t _instance, eventgroup_t _eventgroup) { |
| 4178 | std::set<std::shared_ptr<event>> its_events; |
nothing calls this directly
no test coverage detected