Method connect_cbk

implementation/endpoints/src/client_endpoint_impl.cpp:373–434

template<typename Protocol>
void client_endpoint_impl<Protocol>::connect_cbk(boost::system::error_code const& _error) {

    if (_error == boost::asio::error::operation_aborted || endpoint_impl<Protocol>::sending_blocked_) {
        VSOMEIP_WARNING_P << "Endpoint stopped, remote: " << get_remote_information() << ", endpoint > " << this << " socket state > "
                          << to_string(state_.load());
        close_socket(false, false);
        return;
    }
    std::shared_ptr<boardnet_endpoint_host> its_host = this->endpoint_host_.lock();
    if (its_host) {
        if (_error && _error != boost::asio::error::already_connected) {
            VSOMEIP_WARNING_P << "Restarting socket due to " << _error.message() << " (" << _error.value()
                              << "), remote: " << get_remote_information() << ", endpoint > " << this << " socket state > "
                              << to_string(state_.load());

            close_socket(true, true);

            its_host->on_disconnect(this->shared_from_this());

            if (get_max_allowed_reconnects() == MAX_RECONNECTS_UNLIMITED || get_max_allowed_reconnects() >= ++reconnect_counter_) {
                is_sending_ = false;
                was_not_connected_ = true;
                start_connect_timer();
            } else {
                max_allowed_reconnects_reached();
            }
            // After 30 attempts of 100ms (3s) increase the timer exponential
            // Double the timeout as long as the maximum allowed is larger
            if (connect_timeout_ < VSOMEIP_MAX_CONNECT_TIMEOUT && reconnect_counter_ > 30)
                connect_timeout_ = (connect_timeout_ << 1);
        } else {
            if (_error) {
                VSOMEIP_WARNING_P << "connect_cbk attempt (" << _error.value() << "):" << _error.message()
                                  << ", remote: " << get_remote_information() << ", endpoint > " << this << " socket state > "
                                  << to_string(state_.load());
            }
            {
                std::scoped_lock its_lock(connect_timer_mutex_);
                connect_timer_.cancel();
            }
            connect_timeout_ = VSOMEIP_DEFAULT_CONNECT_TIMEOUT; // TODO: use config variable
            reconnect_counter_ = 0;
            {
                std::scoped_lock its_lock(mutex_);
                if (was_not_connected_) {
                    was_not_connected_ = false;
                    auto its_entry = get_front();
                    if (its_entry.first) {
                        is_sending_ = true;
                        boost::asio::dispatch(strand_, std::bind(&client_endpoint_impl::send_queued, this->shared_from_this(), its_entry));
                        VSOMEIP_WARNING_P << "Resume sending to: " << get_remote_information() << " endpoint > " << this
                                          << " socket state > " << to_string(state_.load());
                    }
                }
            }
            if (state_ != cei_state_e::ESTABLISHED) {
                its_host->on_connect(this->shared_from_this());
            }