Updated federated docs

Author: edwardalee

docs/assets/code/c/src/DecentralizedFeeback.lf

@@ -5,7 +5,7 @@ target C {
 reactor CountPrint {
     input in:int;
     output out:int;
-    state c:int(0);
+    state c:int = 0;
     timer t(0, 1 sec);
     reaction(t) -> out {=
         lf_set(out, self->c++);
@@ -14,7 +14,7 @@ reactor CountPrint {
         lf_print("***** CountPrint Received: %d at tag (%lld, %u)",
             in->value, lf_time_logical_elapsed(), lf_tag().microstep
         );
-    =} STP(10 msec) {=
+    =} STAA(10 msec) {=
         lf_print_warning("CountPrint: Safe to process violation!");
         lf_print("Intended time: %lld", in->intended_tag.time - lf_time_start());
     =}
@@ -24,12 +24,12 @@ reactor PrintCount {
     input in:int;
     output out:int;
     timer t(0, 999 msec);
-    state c:int(0);
+    state c:int = 0;
     reaction(in) {=
         lf_print("***** PrintCount Received: %d at tag (%lld, %u)",
             in->value, lf_time_logical_elapsed(), lf_tag().microstep
         );
-    =} STP(10 msec) {=
+    =} STAA(10 msec) {=
         lf_print_warning("PrintCount: Safe to process violation!");
         lf_print("Intended time: %lld", in->intended_tag.time - lf_time_start());
     =}

docs/assets/code/c/src/DecentralizedFeebackSTP.lf renamed to docs/assets/code/c/src/DecentralizedFeebackSTA.lf

@@ -2,10 +2,10 @@ target C {
     timeout: 5 sec,
     coordination: decentralized
 }
-reactor CountPrint(STP_offset:time(10 msec)) {
+reactor CountPrint(STA:time = 10 ms) {
     input in:int;
     output out:int;
-    state c:int(0);
+    state c:int = 0;
     timer t(0, 1 sec);
     reaction(t) -> out {=
         lf_set(out, self->c++);
@@ -17,11 +17,11 @@ reactor CountPrint(STP_offset:time(10 msec)) {
     =}
 }
 
-reactor PrintCount(STP_offset:time(10 msec)) {
+reactor PrintCount(STA:time = 10 ms) {
     input in:int;
     output out:int;
     timer t(0, 1 sec);
-    state c:int(0);
+    state c:int = 0;
     reaction(in) {=
         lf_print("***** PrintCount Received: %d at tag (%lld, %u)",
             in->value, lf_time_logical_elapsed(), lf_tag().microstep

docs/assets/code/c/src/DecentralizedFeedbackSTAA.lf

@@ -0,0 +1,40 @@
+target C {
+  coordination: decentralized
+}
+
+reactor CountPrint {
+  input in: int
+  output out: int
+  state c: int = 0
+  timer t(0, 100 ms)
+
+  reaction(t) -> out {=
+    lf_set(out, self->c++);
+  =}
+
+  reaction(in) {=
+    lf_print("***** CountPrint Received: %d at tag (%lld, %u)",
+        in->value, lf_time_logical_elapsed(), lf_tag().microstep
+    );
+  =} STAA(forever) {=
+    // This should never happen, but it is here to demonstrate the STAA violation handler.
+    lf_print_warning("CountPrint: Safe to process violation!");
+    lf_print("Intended time: %lld", in->intended_tag.time - lf_time_start());
+  =}
+}
+
+reactor Double(STA: time = forever) {
+  input in: int
+  output out: int
+
+  reaction(in) -> out {=
+    lf_set(out, in->value * 2);
+  =}
+}
+
+federated reactor {
+  c = new CountPrint()
+  p = new Double()
+  c.out -> p.in
+  p.out -> c.in
+}

docs/assets/code/c/src/DecentralizedTimerAfterHandler.lf

@@ -13,8 +13,8 @@ reactor PrintTimer {
     lf_print("Received: %d at (%lld, %d)", in->value,
         lf_time_logical_elapsed(), lf_tag().microstep
     );
-  =} STP(0) {=
-    lf_print("****** STP violation handler invoked at (%lld, %d). "
+  =} STAA(0) {=
+    lf_print("****** Violation handler invoked at (%lld, %d). "
         "Intended tag was (%lld, %d).",
         lf_time_logical_elapsed(), lf_tag().microstep,
         in->intended_tag.time - lf_time_start(), in->intended_tag.microstep

docs/assets/code/c/src/DecentralizedTimerSTP.lf renamed to docs/assets/code/c/src/DecentralizedTimerSTA.lf

@@ -5,7 +5,7 @@ target C {
 
 import Count, Print from "Federated.lf"
 
-reactor PrintTimer(STP_offset: time = 10 msec) extends Print {
+reactor PrintTimer(STA: time = 10 ms) extends Print {
   timer t(0, 1 sec)
 
   reaction(t) {=

docs/assets/code/py/src/DecentralizedFeedbackSTAA.lf

@@ -0,0 +1,39 @@
+target Python {
+  coordination: decentralized
+}
+
+reactor CountPrint {
+  input inp
+  output out
+  state c = 0
+  timer t(0, 100 ms)
+
+  reaction(t) -> out {=
+    self.c += 1
+    out.set(self.c)
+  =}
+
+  reaction(inp) {=
+    print(f"***** CountPrint Received: {inp.value} at tag ({lf.time.logical_elapsed()}, {lf.tag().microstep})")
+  =} STAA(forever) {=
+    # This should never happen, but it is here to demonstrate the STAA violation handler.
+    print("CountPrint: Safe to process violation!")
+    print(f"Intended time: {inp.intended_tag.time - lf.time.start()}")
+  =}
+}
+
+reactor Double(STA = forever) {
+  input inp
+  output out
+
+  reaction(inp) -> out {=
+    out.set(inp.value * 2)
+  =}
+}
+
+federated reactor {
+  c = new CountPrint()
+  p = new Double()
+  c.out -> p.inp
+  p.out -> c.inp
+} 

docs/assets/code/py/src/DecentralizedTimerAfterHandler.lf

@@ -14,9 +14,9 @@ reactor PrintTimer {
         f"Received: {inp.value} "
         f"at ({lf.time.logical_elapsed()}, {lf.tag().microstep})"
     )
-  =} STP(0) {=
+  =} STAA(0) {=
     print(
-        "****** STP violation handler invoked at "
+        "****** Violation handler invoked at "
         f"({lf.time.logical_elapsed()}, {lf.tag().microstep}). "
         "Intended tag was "
         f"({inp.intended_tag.time - lf.time.start()}, {inp.intended_tag.microstep})."

docs/assets/code/py/src/DecentralizedTimerSTP.lf renamed to docs/assets/code/py/src/DecentralizedTimerSTA.lf

@@ -5,7 +5,7 @@ target Python {
 
 import Count, Print from "Federated.lf"
 
-reactor PrintTimer(STP_offset = 10 msec) extends Print {
+reactor PrintTimer(STA = 10 ms) extends Print {
   timer t(0, 1 sec)
 
   reaction(t) {=