Method set_client_state

implementation/routing/src/remote_subscription.cpp:145–155

}

void remote_subscription::set_client_state(const client_t _client, remote_subscription_state_e _state) {
    std::scoped_lock its_lock(mutex_);
    auto found_item = clients_.find(_client);
    if (found_item != clients_.end()) {
        found_item->second.first = _state;
        if (found_item->second.second == std::chrono::steady_clock::time_point()
            && (_state == remote_subscription_state_e::SUBSCRIPTION_ACKED || _state == remote_subscription_state_e::SUBSCRIPTION_NACKED)) {
            found_item->second.second = std::chrono::steady_clock::now() + std::chrono::seconds(ttl_);
        }
    }
}

void remote_subscription::set_all_client_states(remote_subscription_state_e _state) {
    std::scoped_lock its_lock(mutex_);