Method cleanup_client

implementation/routing/src/routing_manager_impl.cpp:2640–2675

}

void routing_manager_impl::cleanup_client(client_t _client) {
    VSOMEIP_INFO_P << "self 0x" << hex4(get_client()) << " handles cleanup of client 0x" << hex4(_client);

    // Since the client could be offering services that need to be removed
    // lock the offer serialization mutex. This is needed here to prevent
    // a lock inversion with rms routing_info_mutex_
    {
        std::scoped_lock its_lock{offer_serialization_mutex_};
        stub_->deregister_client(_client);
    }

    std::forward_list<std::tuple<client_t, service_t, instance_t, major_version_t, minor_version_t>> its_offers;
    {
        std::scoped_lock its_lock{services_state_mutex_};
        remove_pending_requests_unlocked(pending_request_removal_type_e::BOTH, _client);
        if (pending_offers_.size() == 0) {
            return;
        }

        std::erase_if(pending_offers_, [&its_offers, _client](const auto& pending_offer) {
            const auto& [service_instance, offer_info] = pending_offer;
            const auto& [major, minor, new_client, old_client] = offer_info;
            if (old_client == _client) {
                VSOMEIP_WARNING << "OFFER(" << hex4(new_client) << "): [" << hex4(service_instance.service()) << "."
                                << hex4(service_instance.instance()) << ":" << std::uint32_t(major) << "." << minor
                                << "] is not pending anymore as application: " << hex4(old_client) << " is dead. Offering again!";
                its_offers.push_front(std::make_tuple(new_client, service_instance.service(), service_instance.instance(), major, minor));
                return true;
            }
            return false;
        });
    }
    for (const auto& [client, service, instance, major, minor] : its_offers) {
        offer_service(client, service, instance, major, minor, true);
    }
}

std::shared_ptr<endpoint_manager_impl> routing_manager_impl::get_endpoint_manager() const {
    return ep_mgr_impl_;