Renamed RTCoord simulate_rt method and refractor

xdevs/examples/store/2_rt_simulation_csv_output_handler.py

@@ -53,7 +53,7 @@ def get_sec(time_str):
     c = RealTimeCoordinator(store, rt_manager)
     middle = time.time()
     print(f'Coordinator, Manager and Handlers Created. Elapsed time: {middle - start} sec')
-    c.simulate_iters(time_interv=sim_time)
+    c.simulate_rt(time_interv=sim_time)
     end = time.time()
     print(f'Simulation time (s) = {sim_time}')
     print(f'Simulation took: {end - start} sec')

xdevs/examples/store/3_rt_simulation_tcp_input_handler.py

@@ -66,7 +66,7 @@ def new_client_parser(msg: str):
     c = RealTimeCoordinator(store, rt_manager)
     middle = time.time()
     print(f'Coordinator, Manager and Handlers Created. Elapsed time: {middle - start} sec')
-    c.simulate_iters(time_interv=sim_time)
+    c.simulate_rt(time_interv=sim_time)
     end = time.time()
     print(f'Simulation time (s) = {sim_time}')
     print(f'Simulation took: {end - start} sec')

xdevs/examples/store/4_1_rt_simulation_mqtt_input_handler.py

@@ -61,7 +61,7 @@ def mqtt_parser(msg: str):
     middle = time.time()
     print(f"Coordinator and Manager Created. Elapsed time: {middle - start} sec")
     t_ini = time.time()
-    c.simulate_iters(time_interv=sim_time)
+    c.simulate_rt(time_interv=sim_time)
     end = time.time()
     print(f' Simulation time (s) = {sim_time}')
     print(f"Simulation took: {end - start} sec")

xdevs/examples/store/4_2_rt_simulation_mqtt_output_handler.py

@@ -70,7 +70,7 @@ def get_sec(time_str):
     c = RealTimeCoordinator(gensys, rt_manager)
     middle = time.time()
     print("Coordinator and Manager Created. Elapsed time: {} sec".format(middle - start))
-    c.simulate_iters(time_interv=sim_time)
+    c.simulate_rt(time_interv=sim_time)
     end = time.time()
     print(f' Simulation time (s) = {sim_time}')
     print("Simulation took: {} sec".format(end - start))

xdevs/examples/store/system_clients.py

@@ -33,7 +33,7 @@ def __init__(self,  mean_clients: float = 1, stddev_clients: float =0, name=None
 
     t_ini = time.time()
     print(f' >>> COMENZAMOS : {t_ini}')
-    gen_coord.simulate_iters(time_interv=sim_time)
+    gen_coord.simulate_rt(time_interv=sim_time)
     print(f' >>> FIN : {time.time()}')
     print(f' Tiempo a ejecutar (s) = {sim_time }')
     print(f' Tiempo ejecutado (s) = {(time.time() - t_ini)}')

xdevs/examples/store/system_employees.py

@@ -73,7 +73,7 @@ def input_client_parser(msg: str):
 
     t_ini = time.time()
     print(f' >>> COMENZAMOS : {t_ini} : {datetime.datetime.now()}')
-    e_coord.simulate_iters(time_interv=sim_time)
+    e_coord.simulate_rt(time_interv=sim_time)
     print(f' >>> FIN : {time.time()}')
     print(f' Tiempo a ejecutar (s) = {sim_time}')
     print(f' Tiempo ejecutado (s) = {(time.time() - t_ini)}')

xdevs/examples/store/system_queue.py

@@ -65,7 +65,7 @@ def parser_new_client(msg: str):
 
     t_ini = time.time()
     print(f' >>> COMENZAMOS : {t_ini}')
-    q_coord.simulate_iters(time_interv=sim_time)
+    q_coord.simulate_rt(time_interv=sim_time)
     print(f' >>> FIN : {time.time()}')
     print(f' Tiempo a ejecutar (s) = {sim_time}')
     print(f' Tiempo ejecutado (s) = {(time.time() - t_ini)}')

xdevs/rt.py

@@ -142,7 +142,7 @@ def exit(self):
         self.manager.exit(self.clock.time)
         super().exit()
 
-    def simulate_iters(self, time_interv: float = float("inf")):
+    def simulate_rt(self, time_interv: float = float("inf")):
         self.initialize()
         while self.clock.time < time_interv:
             if self.time_next == float("inf") and not self.manager.input_handlers:

xdevs/tests/test_csv_transducer.py

@@ -7,7 +7,7 @@
 
 from xdevs.examples.devstone.devstone import LI, DelayedAtomic, HI
 from xdevs.factory import Transducers
-from xdevs.examples.gpt.gpt import Job, Processor, Gpt
+from xdevs.examples.gpt.models import Job, Processor, Gpt
 
 
 class TestCsvTransducer(TestCase):