Method find_remote_client

implementation/endpoints/src/endpoint_manager_impl.cpp:993–1039

}

std::shared_ptr<boardnet_endpoint> endpoint_manager_impl::find_remote_client(service_t _service, instance_t _instance, bool _reliable) {

    std::shared_ptr<boardnet_endpoint> its_endpoint;
    if (auto found_si = remote_services_.find({_service, _instance}); found_si != remote_services_.end()) {
        if (auto found_reliability = found_si->second.find(_reliable); found_reliability != found_si->second.end()) {
            its_endpoint = found_reliability->second;
        }
    }
    if (its_endpoint) {
        return its_endpoint;
    }

    // Endpoint did not yet exist. Get the partition id to check
    // whether the client endpoint for the partition does exist.
    partition_id_t its_partition_id = configuration_->get_partition_id(_service, _instance);

    // If another service within the same partition is hosted on the
    // same server_endpoint reuse the existing client_endpoint.
    if (auto found_si_info = remote_service_info_.find({_service, _instance}); found_si_info != remote_service_info_.end()) {
        if (auto found_reliable = found_si_info->second.find(_reliable); found_reliable != found_si_info->second.end()) {
            std::shared_ptr<endpoint_definition> its_ep_def = found_reliable->second;
            if (auto found_address = client_endpoints_.find(its_ep_def->get_address()); found_address != client_endpoints_.end()) {
                if (auto found_port = found_address->second.find(its_ep_def->get_remote_port());
                    found_port != found_address->second.end()) {
                    if (auto found_reliable2 = found_port->second.find(_reliable); found_reliable2 != found_port->second.end()) {
                        if (auto found_partition = found_reliable2->second.find(its_partition_id);
                            found_partition != found_reliable2->second.end()) {
                            its_endpoint = found_partition->second;

                            // store the endpoint under this service/instance id
                            // as well - needed for later cleanup
                            remote_services_[{_service, _instance}][_reliable] = its_endpoint;
                            service_instances_[_service][its_endpoint.get()] = _instance;

                            // add endpoint to serviceinfo object
                            if (auto found_service_info_inner = router_->find_service(_service, _instance); found_service_info_inner) {
                                found_service_info_inner->set_endpoint(its_endpoint, _reliable);
                            }
                        }
                    }
                }
            }
        }
    }

    return its_endpoint;
}

std::shared_ptr<boardnet_endpoint> endpoint_manager_impl::create_remote_client(service_t _service, instance_t _instance, bool _reliable) {
    std::shared_ptr<boardnet_endpoint> its_endpoint;