Method update_remote_subscription

implementation/routing/src/eventgroupinfo.cpp:225–306

}

bool eventgroupinfo::update_remote_subscription(const std::shared_ptr<remote_subscription>& _subscription,
                                                const std::chrono::steady_clock::time_point& _expiration, std::set<client_t>& _changed,
                                                remote_subscription_id_t& _id, const bool _is_subscribe) {

    bool its_result(false);

    if (_subscription == nullptr) {
        VSOMEIP_ERROR_P << "Received ptr is null";
        return its_result;
    }

    std::shared_ptr<endpoint_definition> its_subscriber;
    std::set<std::shared_ptr<event>> its_events;

    {
        std::scoped_lock its_lock(subscriptions_mutex_);

        for (const auto& its_item : subscriptions_) {
            if (its_item.second->equals(_subscription)) {
                // update existing subscription
                _changed = its_item.second->update(_subscription->get_clients(), _expiration, _is_subscribe);
                _id = its_item.second->get_id();

                // Copy acknowledgment states from existing subscription
                for (const auto its_client : _subscription->get_clients()) {
                    auto its_state = its_item.second->get_client_state(its_client);
                    if (_is_subscribe && its_state == remote_subscription_state_e::SUBSCRIPTION_UNKNOWN) {
                        // We met the current subscription object during its
                        // unsubscribe process. Therefore, trigger a resubscription.
                        its_state = remote_subscription_state_e::SUBSCRIPTION_PENDING;
                        _changed.insert(its_client);
                    }

                    _subscription->set_client_state(its_client, its_state);
                }

                if (_is_subscribe) {
                    if (!_changed.empty()) {
                        // New clients:
                        // Let this be a child subscription
                        _subscription->set_parent(its_item.second);
                        update_id();
                        _subscription->set_id(id_);
                        subscriptions_[id_] = _subscription;
                    } else {
                        if (!_subscription->is_pending()) {
                            // Ensure parent has sent the initial events
                            if (!_subscription->force_initial_events() && !its_item.second->is_initial()) {
                                _subscription->set_initial(false);
                            }
                        } else {
                            its_item.second->set_answers(its_item.second->get_answers() + 1);
                            _subscription->set_parent(its_item.second);
                            _subscription->set_answers(0);
                        }
                    }
                } else {
                    if (its_item.second->is_pending()) {