Events, Methods & Field Notifiers

// AUTOSAR Adaptive: ara::com method call via CommonAPI / vsomeip
// Service definition in Franca IDL / FIBEX:
//   method GetEngineData(in void) -> out EngineData

#include "v1/com/vehicle/engine/EngineServiceProxy.hpp"
using EngineProxy = v1::com::vehicle::engine::EngineServiceProxy<>;

void request_engine_data(std::shared_ptr proxy) {
    // Async method call: returns future<>
    auto future = proxy->GetEngineData();

    // Option 1: blocking wait (avoid in real-time tasks)
    auto status = future.wait_for(std::chrono::milliseconds(100));
    if (status == std::future_status::ready) {
        auto result = future.get();
        if (result.hasValue()) {
            auto &data = result.value();
            std::cout << "RPM: " << data.rpm << " Torque: " << data.torque << std::endl;
        }
    }

    // Option 2: non-blocking with callback (preferred for real-time)
    proxy->GetEngineData().then([](auto future) {
        auto result = future.get();
        if (result.hasValue()) {
            process_engine_data(result.value());
        }
    });
}

// AUTOSAR Classic (via AUTOSAR COM / RTE Rte_Call_* API):
// Rte_Call_EngineService_GetEngineData(&engineData);
// Generated by RTE generator from ARXML service interface mapping

// SOME/IP Event: server pushes data to subscribed clients
// Eventgroup: logical grouping of events; client subscribes to a group
// All events in an eventgroup share one subscription

// Server side (provider): publish event when data changes
#include "v1/com/vehicle/speed/SpeedServiceStub.hpp"

class SpeedServiceImpl : public v1::com::vehicle::speed::SpeedServiceStubDefault {
public:
    void update_speed(float speed_kmh) {
        // Fire event to all subscribers
        fireSpeedChangedEvent(speed_kmh);
    }

    // Alternative: field setter triggers notification automatically
    void update_speed_field(float speed_kmh) {
        setSpeedAttribute(speed_kmh);  // triggers SET + notification
    }
};

// Client side (consumer): subscribe and receive events
void subscribe_to_speed(std::shared_ptr proxy) {
    // Subscribe to SpeedChangedEvent
    proxy->getSpeedChangedEvent().subscribe(
        [](float speed) {
            printf("Speed update: %.1f km/h
", speed);
        },
        vsomeip::DEFAULT_MAX_NUM_SUBSCRIPTION
    );
}

// UDP multicast event: one server sends; all subscribers receive simultaneously
// SOME/IP-SD subscription response includes: IP=multicast, port=30001
// Server sends Notification to multicast group 224.0.0.1 port 30001