Method handle_requests

implementation/routing/src/routing_manager_stub.cpp:1167–1223

}

void routing_manager_stub::handle_requests(const client_t _client, std::set<protocol::service>& _requests) {

    if (_requests.empty())
        return;

    boost::asio::ip::address its_address;
    port_t its_port;

    std::vector<protocol::routing_info_entry> its_entries;
    std::scoped_lock its_guard{routing_info_mutex_};

    for (auto const& request : _requests) {
        service_requests_[_client][{request.service_, request.instance_}] = std::make_pair(request.major_, request.minor_);
        if (_client == VSOMEIP_ROUTING_CLIENT) {
            continue;
        }
        std::set<client_t> its_clients = host_->find_local_clients(request.service_, request.instance_);
        // insert VSOMEIP_ROUTING_CLIENT to check whether service is remotely offered
        its_clients.insert(VSOMEIP_ROUTING_CLIENT);
        for (const client_t c : its_clients) {
            if (const auto found_client = routing_info_.find(c); found_client != routing_info_.end()) {
                if (request.instance_ == ANY_INSTANCE) {
                    for (const auto& [si, version] : found_client->second) {
                        if (si.service() == request.service_) {
                            protocol::routing_info_entry its_entry;
                            its_entry.set_type(protocol::routing_info_entry_type_e::RIE_ADD_SERVICE_INSTANCE);
                            its_entry.set_client(c);
                            if (host_->get_endpoint_manager()->get_guest(c, its_address, its_port)) {
                                its_entry.set_address(its_address);
                                its_entry.set_port(its_port);
                            }
                            its_entry.add_service({request.service_, si.instance(), version.first, version.second});
                            its_entries.emplace_back(its_entry);
                        }
                    }
                } else {
                    if (auto found_si = found_client->second.find({request.service_, request.instance_});
                        found_si != found_client->second.end()) {
                        protocol::routing_info_entry its_entry;
                        its_entry.set_type(protocol::routing_info_entry_type_e::RIE_ADD_SERVICE_INSTANCE);
                        its_entry.set_client(c);
                        if (host_->get_endpoint_manager()->get_guest(c, its_address, its_port)) {
                            its_entry.set_address(its_address);
                            its_entry.set_port(its_port);
                        }
                        its_entry.add_service({request.service_, request.instance_, found_si->second.first, found_si->second.second});
                        its_entries.emplace_back(its_entry);
                    }
                }
            }
        }
    }

    if (!its_entries.empty()) {
        send_client_routing_info(_client, std::move(its_entries));
    }
}