| 34 | } |
| 35 | |
| 36 | bool remote_subscription::address_equals(const std::shared_ptr<remote_subscription>& _other) const { |
| 37 | bool relibale_address_equals(false); |
| 38 | bool unrelibale_address_equals(false); |
| 39 | |
| 40 | if (reliable_ && (*_other).reliable_) |
| 41 | relibale_address_equals = (reliable_->get_address() == (*_other).reliable_->get_address()); |
| 42 | if (unreliable_ && (*_other).unreliable_) |
| 43 | unrelibale_address_equals = (unreliable_->get_address() == (*_other).unreliable_->get_address()); |
| 44 | return (relibale_address_equals || unrelibale_address_equals); |
| 45 | } |
| 46 | |
| 47 | void remote_subscription::reset(const std::set<client_t>& _clients) { |
| 48 | auto its_client_state = std::make_pair(remote_subscription_state_e::SUBSCRIPTION_PENDING, std::chrono::steady_clock::time_point()); |
nothing calls this directly
no test coverage detected