Method start

implementation/endpoints/src/local_endpoint.cpp:89–117

}

void local_endpoint::start(uint32_t _lc_token) {
    std::unique_lock lock{mutex_};
    peer_data_.lc_token_ = _lc_token;
    is_started_ = true;
    if (state_ == state_e::INIT) {
        connect_unlock();
    } else if (state_ == state_e::CONNECTED) {
        // Posting the actual start action here ensures that
        // every public method can be called without re-entering any other callback.
        boost::asio::post(io_, [this, weak_self = weak_from_this()] {
            if (auto self = weak_self.lock(); self) {
                std::unique_lock inner_lock{mutex_};
                // ensure that we weren't stopped in between
                if (state_ != state_e::CONNECTED) {
                    VSOMEIP_INFO_P << "post: Not starting to process due to state: " << status_unlock();
                    return;
                }
                if (!process(0, inner_lock)) {
                    escalate_internal(inner_lock);
                    return;
                }
                // only now we allow sending
                send_unlock();
            }
        });
    } else {
        VSOMEIP_ERROR_P << "Unexpected state when trying to start: " << status_unlock();
    }
}

void local_endpoint::stop(bool _due_to_error) {
    std::unique_lock lock{mutex_};