Figure 7.4: 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: Laufzeitumgebung des Communication Management (Proxy-Instanz mit integrierter E2E-Prüffunktionalität).
• Transmission: Transportschicht / Datenempfangsinfrastruktur.

Schnittstellen und Nachrichten:

• Update(filter): isAnyNewSampleAdded: Synchroner Aufruf der Anwendung zur Aktualisierung und Filterung empfangener Samples.
• GetMessage(): serializedSamples: Abruf vorliegender serialisierter Nachrichten von der Übertragungsschicht.
• ProcessNonProtectedHeader(&serializedSample): Interne Vorverarbeitung ungeschützter Headerdaten in ara::com.
• E2Echeck(dataID, &serializedSample): e2eResult: Interner E2E-Prüfaufruf innerhalb von ara::com.
• ProcessE2EProtectedHeader(&serializedSample): Interne Verarbeitung geschützter E2E-Header in ara::com.
• Deserialize(&serializedSample): sample: Deserialisierung des Datenstroms in ein typisiertes Sample.
• Store e2eResult.e2eCheckStatus in sample: Assoziation des Prüfergebnisses mit dem Sample.
• Add sample+e2eCheckStatus to the cache(cache policy, cache size, filter): Aufnahme des validierten Samples in den Proxy-Cache.
• Store e2eResult as proxy.e2eResult: Aktualisierung des globalen E2E-Zustands im Proxy.
• Check(dataID, null_ptr): e2eResult: Interner E2E-Aufruf zur Signalisierung des Ausbleibens von Daten.
• GetCachedSamples(): Collection of samples, each with e2eCheckStatus: Auslesen gecachter Samples durch die Anwendung.
• GetE2EResult(): e2eResult: Abfrage des globalen E2E-Zustands durch die Anwendung.
• Lokaler Zugriff: Access data, e.g. samples[idx].speed, samples[idx].GetE2ECheckStatus().

3. Dynamisches Verhalten & Sequenzablauf

1. Die abonnierende Anwendung stößt den Empfangsprozess synchron mittels Update(filter) an.
2. ara::com ruft über GetMessage() vorliegende serializedSamples von Transmission ab.
3. Über ein alt-Fragment erfolgt eine Fallunterscheidung:
   • Fall [at least one serializedSample - perform for each serializedSample]: Für jedes serialisierte Sample wertet ara::com den ungeschützten Header aus (ProcessNonProtectedHeader), führt intern die E2E-Prüfung aus (E2Echeck(dataID, &serializedSample)), verarbeitet den geschützten Header (ProcessE2EProtectedHeader) und deserialisiert die Nutzdaten. Das deserialisierte Sample wird mit dem e2eCheckStatus annotiert, gemäß Cache-Konfiguration im Cache gespeichert und das Ergebnis in proxy.e2eResult festgehalten.
   • Fall [no new serializedSamples]: Wurden keine neuen Samples empfangen, führt ara::com intern Check(dataID, null_ptr) aus und speichert das Ergebnis als proxy.e2eResult.
4. Die Anwendung liest anschließend über GetCachedSamples() die Samples inklusive E2E-Status sowie über GetE2EResult() den globalen Kommunikationsstatus aus und greift lokal auf Daten und Status zu.

4. Normative Relevanz & Entwickler-Hinweise

• E2E-Prüfungen werden direkt innerhalb der ara::com-Komponente gekapselt ausgeführt.
• dataID muss spätestens bei der Instanziierung des Proxys festgelegt sein.
• Der Ausfall oder die Verzögerung von Nachrichten wird explizit durch Check(dataID, null_ptr) gemeldet, um die E2E-Zustandsüberwachung fortzuführen.
• Samples werden gemeinsam mit ihrem Prüfstatus im Cache des Proxys vorgehalten.