Trick prints warning for checkpoints outside of freeze mode.

include/trick/CheckPointRestart.hh

@@ -22,6 +22,10 @@ namespace Trick {
      */
     class CheckPointRestart : public Trick::Scheduler {
 
+        private:
+            /** Flag to track if an automatic freeze has been triggered */
+            bool auto_freeze = false;                               /* ** */
+
         protected:
             /** queue to hold jobs to be called before a checkpoint is dumped. */
             Trick::ScheduledJobQueue checkpoint_queue ;              /* ** */

include/trick/sim_mode.h

@@ -14,6 +14,10 @@
 #ifndef SIMMODE_HH
 #define SIMMODE_HH
 
+#ifdef __cplusplus
+extern "C" {
+#endif
+
 typedef enum {
 
     NoCmd = 0 ,         /* NoCmd */
@@ -38,4 +42,10 @@ typedef enum {
 
 } SIM_MODE ;
 
+const char * simModeCharString(SIM_MODE mode);
+
+#ifdef __cplusplus
+}
+#endif
+
 #endif

test/SIM_checkpoint_data_recording/RUN_test/dump.py

@@ -1,12 +1,30 @@
 import trick
 from trick.unit_test import *
+from threading import Timer
 
 # This was just here for convenience to dump the checkpoints.
 
+def dump_checkpoint(sim_time): 
+    mode = trick.exec_get_mode()
+    cur_time = trick.exec_get_sim_time()
+
+    if(mode == 1 and cur_time == sim_time):
+        trick.checkpoint()
+        trick.exec_run()
+    elif cur_time > sim_time:
+        return
+    else:        
+        Timer(0.1, dump_checkpoint, (sim_time,)).start()
+
+def checkpoint(time):
+    Timer(1.0, dump_checkpoint, (time,)).start()
+
+    trick.freeze(time)
+
 def main():
     exec(open("Modified_data/foo.dr").read())
 
-    trick.checkpoint(5.0)
+    checkpoint(5.0)
 
     trick.stop(10.0)
 

test/SIM_checkpoint_data_recording/RUN_test1/dump.py

@@ -1,12 +1,30 @@
 import trick
 from trick.unit_test import *
+from threading import Timer
 
 # This was just here for convenience to dump the checkpoints.
 
+def dump_checkpoint(sim_time): 
+    mode = trick.exec_get_mode()
+    cur_time = trick.exec_get_sim_time()
+
+    if(mode == 1 and cur_time == sim_time):
+        trick.checkpoint()
+        trick.exec_run()
+    elif cur_time > sim_time:
+        return
+    else:        
+        Timer(0.1, dump_checkpoint, (sim_time,)).start()
+
+def checkpoint(time):
+    Timer(1.0, dump_checkpoint, (time,)).start()
+
+    trick.freeze(time)
+
 def main():
     exec(open("Modified_data/foo.dr").read())
 
-    trick.checkpoint(5.0)
+    checkpoint(5.0)
 
     trick.stop(10.0)
 

test/SIM_checkpoint_data_recording/RUN_test1/ref_log_foo.csv

@@ -1,4 +1,5 @@
 sys.exec.out.time {s},testSimObject.my_foo.a {1},testSimObject.my_foo.b {1}
+                   5,6,12
                  5.1,6,12
                  5.2,6,12
                  5.3,6,12

test/SIM_checkpoint_data_recording/RUN_test1/unit_test.py

@@ -1,8 +1,28 @@
 import trick
+from threading import Timer
 
+def load_checkpoint(path, sim_time, tries=10): 
+    mode = trick.exec_get_mode()
+    cur_time = trick.exec_get_sim_time()
+
+    if(mode == 1 and cur_time == sim_time):
+        trick.load_checkpoint(path)
+        trick.exec_run()
+    elif cur_time > sim_time or tries <= 0:
+        print("Issue with loading checkpoint from input file!")
+        return
+    else:
+        Timer(0.1, load_checkpoint, (path, sim_time, tries - 1,)).start()
+
+def load_checkpoint_at(path, time):
+    Timer(1.0, load_checkpoint, (path, time)).start()
+
+    trick.freeze(time)
 
 def main():
-    trick.add_read(5.0, 'trick.load_checkpoint("RUN_test1/chkpnt_5.000000")') # This checkpoint has data recording
+    chkpnt_path = "RUN_test1/chkpnt_5.000000"
+    load_checkpoint_at(chkpnt_path, 5.0)
+
     trick.stop(10.0)
 
 if __name__ == "__main__":

test/SIM_checkpoint_data_recording/RUN_test2/dump.py

@@ -1,10 +1,28 @@
 import trick
 from trick.unit_test import *
+from threading import Timer
 
 # This was just here for convenience to dump the checkpoints.
 
+def dump_checkpoint(sim_time): 
+    mode = trick.exec_get_mode()
+    cur_time = trick.exec_get_sim_time()
+
+    if(mode == 1 and cur_time == sim_time):
+        trick.checkpoint()
+        trick.exec_run()
+    elif cur_time > sim_time:
+        return
+    else:        
+        Timer(0.1, dump_checkpoint, (sim_time,)).start()
+
+def checkpoint(time):
+    Timer(1.0, dump_checkpoint, (time,)).start()
+
+    trick.freeze(time)
+
 def main():    
-    trick.checkpoint(5.0)
+    checkpoint(5.0)
 
     trick.stop(10.0)
 

test/SIM_checkpoint_data_recording/RUN_test2/unit_test.py

@@ -1,9 +1,28 @@
 import trick
+from threading import Timer
+
+def load_checkpoint(path, sim_time, tries=10): 
+    mode = trick.exec_get_mode()
+    cur_time = trick.exec_get_sim_time()
+
+    if(mode == 1 and cur_time == sim_time):
+        trick.load_checkpoint(path)
+        trick.exec_run()
+    elif cur_time > sim_time or tries <= 0:
+        print("Issue with loading checkpoint from input file!")
+        return
+    else:
+        Timer(0.1, load_checkpoint, (path, sim_time, tries - 1,)).start()
+
+def load_checkpoint_at(path, time):
+    Timer(1.0, load_checkpoint, (path, time)).start()
+
+    trick.freeze(time)
 
 def main():
     exec(open("Modified_data/foo.dr").read())
 
-    trick.add_read(5.0, 'trick.load_checkpoint("RUN_test2/chkpnt_5.000000")') # this checkpoint does not contain data recording
+    load_checkpoint_at("RUN_test2/chkpnt_5.000000", 5.0) # this checkpoint does not contain data recording
 
     trick.stop(10.0)
 

test/SIM_checkpoint_data_recording/RUN_test3/dump.py

@@ -1,12 +1,30 @@
 import trick
 from trick.unit_test import *
+from threading import Timer
 
 # This was just here for convenience to dump the checkpoints.
 
+def dump_checkpoint(sim_time): 
+    mode = trick.exec_get_mode()
+    cur_time = trick.exec_get_sim_time()
+
+    if(mode == 1 and cur_time == sim_time):
+        trick.checkpoint()
+        trick.exec_run()
+    elif cur_time > sim_time:
+        return
+    else:        
+        Timer(0.1, dump_checkpoint, (sim_time,)).start()
+
+def checkpoint(time):
+    Timer(1.0, dump_checkpoint, (time,)).start()
+
+    trick.freeze(time)
+
 def main():
     exec(open("Modified_data/foo.dr").read())
 
-    trick.checkpoint(5.0)
+    checkpoint(5.0)
 
     trick.stop(10.0)
 

test/SIM_checkpoint_data_recording/RUN_test3/ref_log_foo.csv

@@ -1,4 +1,5 @@
 sys.exec.out.time {s},testSimObject.my_foo.a {1},testSimObject.my_foo.b {1}
+                   5,6,12
                  5.1,6,12
                  5.2,6,12
                  5.3,6,12

test/SIM_checkpoint_data_recording/RUN_test3/unit_test.py

@@ -1,10 +1,29 @@
 import trick
+from threading import Timer
+
+def load_checkpoint(path, sim_time, tries=10): 
+    mode = trick.exec_get_mode()
+    cur_time = trick.exec_get_sim_time()
+
+    if(mode == 1 and cur_time == sim_time):
+        trick.load_checkpoint(path)
+        trick.exec_run()
+    elif cur_time > sim_time or tries <= 0:
+        print("Issue with loading checkpoint from input file!")
+        return
+    else:
+        Timer(0.1, load_checkpoint, (path, sim_time, tries - 1,)).start()
+
+def load_checkpoint_at(path, time):
+    Timer(1.0, load_checkpoint, (path, time)).start()
+
+    trick.freeze(time)
 
 def main():
 
     exec(open("Modified_data/foo.dr").read())
 
-    trick.add_read(5.0, 'trick.load_checkpoint("RUN_test3/chkpnt_5.000000")') # contains data recording
+    load_checkpoint_at("RUN_test3/chkpnt_5.000000", 5.0) # contains data recording
 
     trick.stop(10.0)
 

test/SIM_checkpoint_data_recording/RUN_test4/dump.py

@@ -1,12 +1,30 @@
 import trick
 from trick.unit_test import *
+from threading import Timer
 
 # This was just here for convenience to dump the checkpoints.
 
+def dump_checkpoint(sim_time): 
+    mode = trick.exec_get_mode()
+    cur_time = trick.exec_get_sim_time()
+
+    if(mode == 1 and cur_time == sim_time):
+        trick.checkpoint()
+        trick.exec_run()
+    elif cur_time > sim_time:
+        return
+    else:        
+        Timer(0.1, dump_checkpoint, (sim_time,)).start()
+
+def checkpoint(time):
+    Timer(1.0, dump_checkpoint, (time,)).start()
+
+    trick.freeze(time)
+
 def main():
     exec(open("Modified_data/foo.dr").read())
 
-    trick.checkpoint(2.0)
+    checkpoint(2.0)
 
     trick.stop(10.0)
 

test/SIM_checkpoint_data_recording/RUN_test4/ref_log_foo.csv

@@ -1,4 +1,5 @@
 sys.exec.out.time {s},testSimObject.my_foo.a {1},testSimObject.my_foo.b {1}
+                   2,3,6
                  2.1,3,6
                  2.2,3,6
                  2.3,3,6

test/SIM_checkpoint_data_recording/RUN_test4/unit_test.py

@@ -1,10 +1,29 @@
 import trick
+from threading import Timer
+
+def load_checkpoint(path, sim_time, tries=10): 
+    mode = trick.exec_get_mode()
+    cur_time = trick.exec_get_sim_time()
+
+    if(mode == 1 and cur_time == sim_time):
+        trick.load_checkpoint(path)
+        trick.exec_run()
+    elif cur_time > sim_time or tries <= 0:
+        print("Issue with loading checkpoint from input file!")
+        return
+    else:
+        Timer(0.1, load_checkpoint, (path, sim_time, tries - 1,)).start()
+
+def load_checkpoint_at(path, time):
+    Timer(1.0, load_checkpoint, (path, time)).start()
+
+    trick.freeze(time)
 
 def main():
 
     exec(open("Modified_data/foo.dr").read())
 
-    trick.add_read(5.0, 'trick.load_checkpoint("RUN_test4/chkpnt_2.000000")') # contains data recording, starts at t=2
+    load_checkpoint_at("RUN_test4/chkpnt_2.000000", 5.0) # contains data recording, starts at t=2
 
     trick.stop(10.0)
 

test/SIM_checkpoint_data_recording/RUN_test5/dump.py

@@ -1,12 +1,29 @@
 import trick
-from trick.unit_test import *
+from threading import Timer
 
 # This was just here for convenience to dump the checkpoints.
 
+def dump_checkpoint(sim_time): 
+    mode = trick.exec_get_mode()
+    cur_time = trick.exec_get_sim_time()
+
+    if(mode == 1 and cur_time == sim_time):
+        trick.checkpoint()
+        trick.exec_run()
+    elif cur_time > sim_time:
+        return
+    else:        
+        Timer(0.1, dump_checkpoint, (sim_time,)).start()
+
+def checkpoint(time):
+    Timer(1.0, dump_checkpoint, (time,)).start()
+
+    trick.freeze(time)
+
 def main():
     exec(open("Modified_data/foo.dr").read())
 
-    trick.checkpoint(7.0)
+    checkpoint(7.0)
 
     trick.stop(10.0)
 

test/SIM_checkpoint_data_recording/RUN_test5/ref_log_foo.csv

@@ -1,4 +1,5 @@
 sys.exec.out.time {s},testSimObject.my_foo.a {1},testSimObject.my_foo.b {1}
+                   7,8,16
                  7.1,8,16
                  7.2,8,16
                  7.3,8,16

test/SIM_checkpoint_data_recording/RUN_test5/unit_test.py

@@ -1,10 +1,29 @@
 import trick
+from threading import Timer
+
+def load_checkpoint(path, sim_time, tries=10): 
+    mode = trick.exec_get_mode()
+    cur_time = trick.exec_get_sim_time()
+
+    if(mode == 1 and cur_time == sim_time):
+        trick.load_checkpoint(path)
+        trick.exec_run()
+    elif cur_time > sim_time or tries <= 0:
+        print("Issue with loading checkpoint from input file!")
+        return
+    else:
+        Timer(0.1, load_checkpoint, (path, sim_time, tries - 1,)).start()
+
+def load_checkpoint_at(path, time):
+    Timer(1.0, load_checkpoint, (path, time)).start()
+
+    trick.freeze(time)
 
 def main():
 
     exec(open("Modified_data/foo.dr").read())
 
-    trick.add_read(5.0, 'trick.load_checkpoint("RUN_test5/chkpnt_7.000000")') # contains data recording, starts at t=7
+    load_checkpoint_at("RUN_test5/chkpnt_7.000000", 5.0) # contains data recording, starts at t=7
 
     trick.stop(10.0)