| 4452 | } |
| 4453 | |
| 4454 | void routing_manager_impl::stop_offer_service_base(client_t _client, service_t _service, instance_t _instance, major_version_t _major, |
| 4455 | minor_version_t _minor) { |
| 4456 | (void)_client; |
| 4457 | (void)_major; |
| 4458 | (void)_minor; |
| 4459 | |
| 4460 | std::map<event_t, std::shared_ptr<event>> events; |
| 4461 | { |
| 4462 | std::scoped_lock its_lock(events_mutex_); |
| 4463 | const auto search = events_.find(service_instance_t{_service, _instance}); |
| 4464 | if (search != events_.end()) { |
| 4465 | for (const auto& [event_id, event_ptr] : search->second) { |
| 4466 | events[event_id] = event_ptr; |
| 4467 | } |
| 4468 | } |
| 4469 | } |
| 4470 | for (auto& e : events) { |
| 4471 | if (e.second->is_set()) { |
| 4472 | VSOMEIP_INFO_P << "Unsetting payload for [" << hex4(_service) << "." << hex4(_instance) << "." << hex4(e.first) << "]"; |
| 4473 | } |
| 4474 | e.second->unset_payload(); |
| 4475 | e.second->clear_subscribers(); |
| 4476 | } |
| 4477 | } |
| 4478 | session_t routing_manager_impl::get_event_session() { |
| 4479 | return host_->get_session(false); |
| 4480 | } |
nothing calls this directly
no test coverage detected