Method log_client_states

implementation/endpoints/src/endpoint_manager_impl.cpp:1113–1151

}

void endpoint_manager_impl::log_client_states() const {
    std::stringstream its_log;
    client_endpoints_t its_client_endpoints;
    std::vector<std::pair<std::tuple<boost::asio::ip::address, uint16_t, bool>, size_t>> its_client_queue_sizes;

    {
        std::scoped_lock its_lock(endpoint_mutex_);
        its_client_endpoints = client_endpoints_;
    }

    for (const auto& its_address : its_client_endpoints) {
        for (const auto& its_port : its_address.second) {
            for (const auto& its_reliability : its_port.second) {
                for (const auto& its_partition : its_reliability.second) {
                    size_t its_queue_size = its_partition.second->get_queue_size();
                    if (its_queue_size > VSOMEIP_DEFAULT_QUEUE_WARN_SIZE)
                        its_client_queue_sizes.push_back(
                                std::make_pair(std::make_tuple(its_address.first, its_port.first, its_reliability.first), its_queue_size));
                }
            }
        }
    }

    std::sort(its_client_queue_sizes.begin(), its_client_queue_sizes.end(),
              [](const std::pair<std::tuple<boost::asio::ip::address, uint16_t, bool>, size_t>& _a,
                 const std::pair<std::tuple<boost::asio::ip::address, uint16_t, bool>, size_t>& _b) { return (_a.second > _b.second); });

    // NOTE: limit is important, do *NOT* want an arbitrarily big string!
    size_t its_max(std::min(size_t(5), its_client_queue_sizes.size()));
    for (size_t i = 0; i < its_max; i++) {
        its_log << std::get<0>(its_client_queue_sizes[i].first).to_string() << ":" << std::get<1>(its_client_queue_sizes[i].first) << "("
                << (std::get<2>(its_client_queue_sizes[i].first) ? "tcp" : "udp") << "):" << its_client_queue_sizes[i].second;
        if (i < its_max - 1)
            its_log << ", ";
    }

    if (its_log.str().length() > 0)
        VSOMEIP_INFO << "ECQ: " << its_client_queue_sizes.size() << " [" << its_log.str() << "]";
}

void endpoint_manager_impl::log_server_states() const {
    std::stringstream its_log;