| 134 | } |
| 135 | |
| 136 | remote_subscription_state_e remote_subscription::get_client_state(const client_t _client) const { |
| 137 | std::scoped_lock its_lock(mutex_); |
| 138 | auto found_client = clients_.find(_client); |
| 139 | if (found_client != clients_.end()) { |
| 140 | return found_client->second.first; |
| 141 | } |
| 142 | return remote_subscription_state_e::SUBSCRIPTION_UNKNOWN; |
| 143 | } |
| 144 | |
| 145 | void remote_subscription::set_client_state(const client_t _client, remote_subscription_state_e _state) { |
| 146 | std::scoped_lock its_lock(mutex_); |
no test coverage detected