Method stop

implementation/endpoints/src/endpoint_manager_impl.cpp:78–138

}

void endpoint_manager_impl::stop() {
    VSOMEIP_INFO_P << "called";

    clear_routing_endpoints();

    // stop boardnet endpoints
    std::vector<std::shared_ptr<boardnet_endpoint>> endpoints;

    {
        std::scoped_lock its_lock{endpoint_mutex_};

        for (const auto& [its_address, ports] : client_endpoints_) {
            for (const auto& [its_port, protocols] : ports) {
                for (const auto& [its_protocol, partitions] : protocols) {
                    for (const auto& [its_partition, its_endpoint] : partitions) {
                        endpoints.push_back(its_endpoint);
                    }
                }
            }
        }

        for (const auto& [its_port, protocols] : server_endpoints_) {
            for (const auto& [its_protocol, its_endpoint] : protocols) {
                endpoints.push_back(its_endpoint);
            }
        }
    }

    for (std::shared_ptr<boardnet_endpoint>& endpoint : endpoints) {
        endpoint->stop(false);
    }

    // clear endpoints (and related state)
    {
        std::scoped_lock its_lock{endpoint_mutex_};

        client_endpoints_.clear();
        server_endpoints_.clear();
        service_instances_.clear();
        service_instances_multicast_.clear();
        used_client_ports_.clear();
        remote_services_.clear();
    }

    endpoints.clear();

    {
        std::scoped_lock its_guard(options_mutex_);
        is_processing_options_ = false;
        options_condition_.notify_one();
    }

    try {
        options_thread_.join();
        VSOMEIP_INFO_P << "Joined thread m_multicast " << std::hex << std::this_thread::get_id();
    } catch (...) {
        // Ignore exception if thread already joined
    }