Method on_message

implementation/routing/src/routing_manager_impl.cpp:1060–1195

}

void routing_manager_impl::on_message(const byte_t* _data, length_t _length, boardnet_endpoint* _receiver,
                                      const boost::asio::ip::address& _remote_address, port_t _remote_port, bool _is_multicast) {

    uint8_t its_check_status = e2e::profile_interface::generic_check_status::E2E_OK;
    instance_t its_instance(0x0);
    bool is_forwarded(true);
    // message is at least 16-bytes, see also PRS_SOMEIP_00910
    if (_length < VSOMEIP_FULL_HEADER_SIZE) {
        VSOMEIP_ERROR_P << "Dropped message with invalid length " << _length;
        return;
    }

    const message_type_e its_message_type = static_cast<message_type_e>(_data[VSOMEIP_MESSAGE_TYPE_POS]);
    const service_t its_service = bithelper::read_uint16_be(&_data[VSOMEIP_SERVICE_POS_MIN]);
    const method_t its_method = bithelper::read_uint16_be(&_data[VSOMEIP_METHOD_POS_MIN]);
    const client_t its_client = bithelper::read_uint16_be(&_data[VSOMEIP_CLIENT_POS_MIN]);
    const session_t its_session = bithelper::read_uint16_be(&_data[VSOMEIP_SESSION_POS_MIN]);
    const auto its_return_code = static_cast<return_code_e>(_data[VSOMEIP_RETURN_CODE_POS]);

    // refer to error workflow in PRS_SOMEIP_00195
    // (although note that it is *NOT* strictly followed!)

    // ignore messages with invalid message type
    if (!utility::is_valid_message_type(its_message_type)) {
        VSOMEIP_ERROR_P << "Dropped message with invalid message type 0x" << hex2(static_cast<uint8_t>(its_message_type));
        return;
    }
    // ignore messages with.. unknown remote address? how is this even possible?!
    if (_remote_address.is_unspecified()) {
        VSOMEIP_ERROR_P << "Dropped message with invalid remote address from: " << _remote_address.to_string() << ":" << _remote_port;
        return;
    }

    // Log messages which could cause routing issues.
    if (!is_valid_client_id(its_client, its_message_type)) {
        VSOMEIP_ERROR_P << "Invalid client id. message=" << hex4(its_service) << "." << hex4(its_method) << "."
                        << hex2(static_cast<uint8_t>(its_message_type)) << "." << hex2(static_cast<uint8_t>(its_return_code))
                        << " client=0x" << hex4(its_client) << " source=" << _remote_address << ":" << _remote_port;
    }

    if (its_service == VSOMEIP_SD_SERVICE) {
        if (discovery_ && its_method == sd::method) {
            if (configuration_->get_sd_port() == _remote_port) {
                // ACL check SD message
                if (!is_acl_message_allowed(_receiver, its_service, ANY_INSTANCE, _remote_address)) {
                    return;
                }
                discovery_->on_message(_data, _length, _remote_address, _is_multicast);
            } else {
                VSOMEIP_ERROR << "Ignored SD message from unknown port (" << _remote_port << ")";
            }
        }
    } else {
        if (_is_multicast) {
            its_instance = ep_mgr_impl_->find_instance_multicast(its_service, _remote_address);
        } else {
            its_instance = ep_mgr_impl_->find_instance(its_service, _receiver);
        }