Commit 0d0a3c33 authored by Marco Picone's avatar Marco Picone
Browse files

Merge branch 'ESTIMED-D2.2-Clause-7-revisions-4.0.3' into 'ESTIMED-D2.2-StableDraft-4.0.3'

Estimed d2.2 clause 7 revisions 4.0.3

See merge request estimed/wp2/gr-mec-dec-050!10
parents 1ade9b39 db6e0df9
Loading
Loading
Loading
Loading
+319 −181

File changed.

Preview size limit exceeded, changes collapsed.

+45.1 KiB
Loading image diff...
+38 −0
Original line number Diff line number Diff line
@startuml

hide footbox
participant Orchestrator
 skinparam participant {
        BackgroundColor #ADD8E6
    }
participant Registry as "Federation Registry"
participant Orchestrator as "FL Orchestrator (MEC/IN-CSE)"
participant Node as "MEC/oneM2M Nodes (FL Clients)"
participant Aggregator as "MEC Host/IN-CSE (FL Aggregator)"

Orchestrator -> Registry : Query available nodes & capabilities
Registry --> Orchestrator : Return eligible nodes

Orchestrator -> Node : Select participants\n(Federation Group Selection)
Orchestrator -> Node : Distribute initial global model

loop Local Training
    Node -> Node : Train local model on private data
    Node -> Aggregator : Send model updates (weights/gradients)
end

Aggregator -> Aggregator : Aggregate model updates securely
Aggregator -> Orchestrator : Send aggregated global model
Orchestrator -> Node : Redistribute improved model

alt Node with limited resources
    Orchestrator -> Node : Assign smaller training load
end

alt High connectivity nodes
    Orchestrator -> Node : Prioritize for synchronization
end

@enduml

+68 KiB
Loading image diff...
+49 −0
Original line number Diff line number Diff line
@startuml
hide footbox

skinparam participant {
        BackgroundColor white
    }

participant Orchestrator
 skinparam participant {
        BackgroundColor #ADD8E6
    }

participant "MEC Host/MN-CSE (Swarm Node A)" as NodeA
participant "MEC Host/MN-CSE (Swarm Node B)" as NodeB
participant "MEC Host/MN-CSE (Swarm Node C)" as NodeC
participant "MEC Node" as MEC
participant "MN-CSE/MEC Host/IN-CSE (Collector Node)" as Collector
participant "MEC/oneM2M APIs" as Bus

== Task Decomposition ==
Orchestrator -> Orchestrator : Divide Global Task
Orchestrator -> NodeA : Assign Subtask A
Orchestrator -> NodeB : Assign Subtask B

== Synchronization ==
NodeA -> Bus : Publish State Update
Bus -> NodeB : Deliver Update
Bus -> NodeC : Deliver Update
NodeB -> Bus : Acknowledge Sync
NodeC -> Bus : Acknowledge Sync

== Task Offloading ==
NodeB -> Orchestrator : Request Offloading (Heavy Task)
Orchestrator -> MEC : Forward Heavy Task
MEC -> Orchestrator : Processed Result
Orchestrator -> NodeB : Return Output

== Resilience ==
Orchestrator -> NodeA : Monitor Progress
NodeA -> Orchestrator : Failure Notification
Orchestrator -> NodeC : Reassign Subtask
NodeC -> Orchestrator : Processed Result

== Coordination & Aggregation ==
NodeA -> Collector : Partial Result
NodeB -> Collector : Partial Result
NodeC -> Collector : Partial Result
Collector -> Orchestrator : Aggregated Results
@enduml
 No newline at end of file
Loading