Method subscribe

implementation/service_discovery/src/service_discovery_impl.cpp:280–320

}

void service_discovery_impl::subscribe(service_t _service, instance_t _instance, eventgroup_t _eventgroup, major_version_t _major,
                                       ttl_t _ttl, client_t _client, const std::shared_ptr<eventgroupinfo>& _info) {

    if (is_suspended_) {
        VSOMEIP_WARNING_P << "Ignoring subscription as we are suspended";
        return;
    }

    std::scoped_lock its_lock(subscribed_mutex_);
    if (auto found_si = subscribed_.find({_service, _instance}); found_si != subscribed_.end()) {
        if (auto found_eventgroup = found_si->second.find(_eventgroup); found_eventgroup != found_si->second.end()) {
            if (auto its_subscription = found_eventgroup->second; its_subscription->get_major() != _major) {
                VSOMEIP_ERROR << "Subscriptions to different versions of the same service instance are not supported!";
            } else if (its_subscription->is_selective()) {
                if (its_subscription->add_client(_client)) {
                    its_subscription->set_state(_client, subscription_state_e::ST_NOT_ACKNOWLEDGED);
                    send_subscription(its_subscription, _service, _instance, _eventgroup, _client);
                }
            }
            return;
        }
    }

    std::shared_ptr<boardnet_endpoint> its_reliable, its_unreliable;
    get_subscription_endpoints(_service, _instance, its_reliable, its_unreliable);

    // New subscription
    std::shared_ptr<subscription> its_subscription = create_subscription(_major, _ttl, its_reliable, its_unreliable, _info);

    if (!its_subscription) {
        VSOMEIP_ERROR_P << "Creating subscription failed!";
        return;
    }

    subscribed_[{_service, _instance}][_eventgroup] = its_subscription;

    its_subscription->add_client(_client);
    its_subscription->set_state(_client, subscription_state_e::ST_NOT_ACKNOWLEDGED);

    send_subscription(its_subscription, _service, _instance, _eventgroup, _client);
}

void service_discovery_impl::send_subscription(const std::shared_ptr<subscription>& _subscription, const service_t _service,
                                               const instance_t _instance, const eventgroup_t _eventgroup, const client_t _client) {