| 1923 | } |
| 1924 | |
| 1925 | void application_impl::send_back_cached_eventgroup(service_t _service, instance_t _instance, eventgroup_t _eventgroup) { |
| 1926 | std::set<std::shared_ptr<event>> its_events = routing_->find_consumed_events(_service, _instance, _eventgroup); |
| 1927 | for (const auto& its_event : its_events) { |
| 1928 | if (its_event && its_event->is_field() && its_event->is_set()) { |
| 1929 | std::shared_ptr<message> its_message = runtime_->create_notification(); |
| 1930 | const event_t its_event_id(its_event->get_event()); |
| 1931 | its_message->set_service(_service); |
| 1932 | its_message->set_method(its_event_id); |
| 1933 | its_message->set_instance(_instance); |
| 1934 | its_message->set_payload(its_event->get_payload()); |
| 1935 | its_message->set_initial(true); |
| 1936 | on_message(std::move(its_message)); |
| 1937 | VSOMEIP_INFO << "Sending back cached event (" << hex4(client_) << "): [" << hex4(_service) << "." << hex4(_instance) << "." |
| 1938 | << hex4(its_event_id) << "] from eventgroup " << hex4(_eventgroup); |
| 1939 | } |
| 1940 | } |
| 1941 | } |
| 1942 | |
| 1943 | void application_impl::set_routing_state(routing_state_e _routing_state) { |
| 1944 | if (!routing_app_) { |
nothing calls this directly
no test coverage detected