Method update_routing_info

implementation/routing/src/routing_manager_impl.cpp:1845–1879

}

void routing_manager_impl::update_routing_info(std::chrono::milliseconds _elapsed) {
    std::map<service_t, std::vector<instance_t>> its_expired_offers;

    {
        std::scoped_lock its_lock{services_remote_mutex_};
        for (const auto& [service, instances] : services_remote_) {
            for (const auto& [instance, info] : instances) {
                ttl_t its_ttl = info->get_ttl();
                if (its_ttl < DEFAULT_TTL) { // do not touch "forever"
                    std::chrono::milliseconds precise_ttl = info->get_precise_ttl();
                    if (precise_ttl.count() < _elapsed.count() || precise_ttl.count() == 0) {
                        info->set_ttl(0);
                        its_expired_offers[service].push_back(instance);
                    } else {
                        std::chrono::milliseconds its_new_ttl(precise_ttl - _elapsed);
                        info->set_precise_ttl(its_new_ttl);
                    }
                }
            }
        }
    }

    for (const auto& [service, instances] : its_expired_offers) {
        for (const auto& instance : instances) {
            if (discovery_) {
                discovery_->unsubscribe_all(service, instance);
                // go to Initial Wait Phase
                discovery_->reset_request_sent_counter(service, instance);
            }
            del_routing_info(service, instance, true, true, true);
            VSOMEIP_INFO_P << "Update_routing_info: elapsed=" << _elapsed.count() << " : delete service/instance " << hex4(service) << "."
                           << hex4(instance);
        }
    }
}

void routing_manager_impl::expire_services(const boost::asio::ip::address& _address) {
    expire_services(_address, port_range_t(ANY_PORT, ANY_PORT), false);