Method remove_remote_subscription

implementation/routing/src/eventgroupinfo.cpp:365–382

}

void eventgroupinfo::remove_remote_subscription(const remote_subscription_id_t _id) {
    std::scoped_lock its_lock(subscriptions_mutex_);

    auto find_subscription = subscriptions_.find(_id);
    if (find_subscription != subscriptions_.end()) {
        boost::asio::ip::address its_address;
        if (find_subscription->second->get_ip_address(its_address)) {
            auto find_address = remote_subscribers_count_.find(its_address);
            if (find_address != remote_subscribers_count_.end()) {
                if (find_address->second != 0) {
                    find_address->second--;
                }
            }
        }
    }

    subscriptions_.erase(_id);
}

void eventgroupinfo::clear_remote_subscriptions() {
    std::scoped_lock its_lock(subscriptions_mutex_);