| 205 | } |
| 206 | |
| 207 | std::chrono::steady_clock::time_point remote_subscription::get_expiration(const client_t _client) const { |
| 208 | std::scoped_lock its_lock(mutex_); |
| 209 | auto found_client = clients_.find(_client); |
| 210 | if (found_client != clients_.end()) { |
| 211 | return found_client->second.second; |
| 212 | } |
| 213 | return std::chrono::steady_clock::now(); |
| 214 | } |
| 215 | |
| 216 | std::set<client_t> remote_subscription::update(const std::set<client_t>& _clients, const std::chrono::steady_clock::time_point& _timepoint, |
| 217 | const bool _is_subscribe) { |
no test coverage detected