Method process

implementation/endpoints/src/local_endpoint.cpp:452–491

}

[[nodiscard]] bool local_endpoint::process(size_t _new_bytes, std::unique_lock<std::mutex>& _lock) {
    if (_new_bytes > 0 && !receive_buffer_->bump_end(_new_bytes)) {
        VSOMEIP_ERROR_P << "Inconsistent buffer handling, trying add the read of: " << _new_bytes << " bytes, escalating on "
                        << status_unlock();
        return false;
    }
    next_message_result result;
    auto routing = routing_host_.lock();
    if (!routing) {
        return false;
    }

    // avoid checking every incoming messages, if a client id was already received
    if (own_ == VSOMEIP_CLIENT_UNSET) {
        while (receive_buffer_->next_message(result)) {
            if (auto const id = protocol::read_client_id(result.message_data_, result.message_size_); id != VSOMEIP_CLIENT_UNSET) {
                own_ = id;
                if (assignment_timebox_) {
                    assignment_timebox_->stop();
                }
            }
            _lock.unlock(); // fine to unlock, because the caller needs to return, before we would schedule another read
            routing->on_message(result.message_data_, result.message_size_, peer_data_);
            _lock.lock(); // because next_message changes internal state -> lock
        }
    } else {
        while (receive_buffer_->next_message(result)) {
            _lock.unlock(); // fine to unlock, because the caller needs to return, before we would schedule another read
            routing->on_message(result.message_data_, result.message_size_, peer_data_);
            _lock.lock(); // because next_message changes internal state -> lock
        }
    }
    if (result.error_) {
        VSOMEIP_ERROR_P << "Received parsing error, socket > " << status_unlock();
        return false;
    }
    receive_buffer_->shift_front();
    receive_unlock();
    return true;
}

void local_endpoint::assignment_timeout() {
    std::unique_lock lock{mutex_};