Method update

implementation/routing/src/remote_subscription.cpp:216–245

}

std::set<client_t> remote_subscription::update(const std::set<client_t>& _clients, const std::chrono::steady_clock::time_point& _timepoint,
                                               const bool _is_subscribe) {
    std::set<client_t> its_changed;

    std::scoped_lock its_lock(mutex_);
    for (const auto& its_client : _clients) {
        auto found_client = clients_.find(its_client);
        if (_is_subscribe) {
            if (found_client != clients_.end()) {
                found_client->second.second = _timepoint;
            } else {
                its_changed.insert(its_client);
            }
        } else {
            if (found_client != clients_.end()) {
                its_changed.insert(its_client);
            }
        }
    }

    for (const auto& its_client : its_changed) {
        if (_is_subscribe) {
            clients_[its_client] = std::make_pair(remote_subscription_state_e::SUBSCRIPTION_PENDING, _timepoint);
        } else {
            clients_.erase(its_client);
        }
    }

    return its_changed;
}

std::shared_ptr<remote_subscription> remote_subscription::get_parent() const {
    return parent_.lock();