Figure 7.18: E2E Subscriber

1. Diagrammtyp & Architektur-Kontext

UML-Sequenzdiagramm (sd Subscriber) zur Darstellung des E2E-geschützten Datenempfangs auf Abonnentenseite in AUTOSAR Adaptive Platform Communication Management (ara::com). Es visualisiert das Zusammenspiel zwischen Anwendungsschicht, Kommunikations-Middleware, E2E-Bibliothek und Transportschicht bei der Verarbeitung eingehender serialisierter Samples.

2. Komponenten, Entitäten & Schnittstellen

Beteiligte Lebenslinien:

• Subscriber application: Abonnierende Anwendungskomponente.
• ara::com: Kommunikations-Middleware (Proxy).
• Reception: Unterlagerte Empfangsschicht.

Schnittstellen und Nachrichten:

• GetNewSamples(f, maxNumberOfSamples): ara::core::Result<size_t>: Abruf empfangener Samples durch Bereitstellung eines Callables f.
• GetNextMessage(): serializedSamples: Sequentieller Abruf einzelner serialisierter Nachrichten innerhalb der Iterationsschleife.
• ProcessNonProtectedHeader (serializedSample): Interne Headerverarbeitung.
• E2E_check (dataID, serializedSample): Result: Validierung der E2E-Prüfsummen und Sequenzen.
• ProcessE2EProtectedHeader( serializedSample): Verarbeitung des geschützten Headers.
• Deserialize(serializedSample): sample: Deserialisierung der Nutzlast.
• Store Result in ProfileCheckStatus of SamplePtr: Setzen des individuellen Prüfergebnisses im Smart-Pointer des Samples.
• Store Result in global SMState: Aktualisierung des E2E-Zustandsautomaten.
• f(SamplePtr): Übergabe des geschützten Smart-Pointers an das Callable der Anwendung.
• SamplePtr->GetProfileCheckStatus: ara::com::e2e::ProfileCheckStatus: Abfrage des E2E-Prüfstatus eines bestimmten Samples durch die Anwendung.
• E2E_check(dataID, null_ptr): Result: Meldung über ausbleibende Nachrichten an die E2E-Zustandsmaschine.
• GetE2EStateMachineState(): ara::com::e2e::SMState: Abfrage des aggregierten E2E-Zustands durch die Anwendung.

3. Dynamisches Verhalten & Sequenzablauf

1. Die Anwendung ruft GetNewSamples(f, maxNumberOfSamples) auf.
2. Der Empfang und die Auswertung laufen innerhalb einer Schleife loop through received samples until maxNumberOfSamples is reached:
   • ara::com fordert sequentiell über GetNextMessage() jeweils das nächste serialisierte Sample von Reception an.
   • Innerhalb des verschachtelten alt-Fragments erfolgt die Auswertung:
     • Fall [at least one serializedSample]: Header-Verarbeitung, E2E_check, Deserialisierung, Speicherung von Status im SamplePtr sowie globalem SMState und Aufruf von f(SamplePtr) mit optionaler Abfrage von SamplePtr->GetProfileCheckStatus.
     • Fall [no serialized samples were processed]: Ausführung von E2E_check(dataID, null_ptr) und Speicherung im globalen SMState.
3. Nach Beendigung der Schleife kann die Anwendung den Gesamtstatus über GetE2EStateMachineState() abfragen.

4. Normative Relevanz & Entwickler-Hinweise

• Die Nachrichtenabholung von der Transportschicht erfolgt on-demand je Schleifendurchlauf (GetNextMessage()) statt in einem initialen Gesamtblock, wodurch Streaming und vorzeitiger Abbruch bei Erreichen von maxNumberOfSamples unterstützt werden.
• Die Fallunterscheidung [no serialized samples were processed] greift, wenn während des gesamten Durchlaufs keine serialisierten Samples verarbeitet werden konnten.
• Das Callable f übernimmt das Eigentum am SamplePtr. Die Statusauswertung erfolgt über ara::com::e2e::ProfileCheckStatus bzw. ara::com::e2e::SMState.
• Mögliche E2E-Check-Ergebnisse: OK, REPEATED, WRONGSEQUENCE, WRONGCRC bzw. NONEWDATA.