From a71d36272de5d159ef709f9e3eae4fb373548e38 Mon Sep 17 00:00:00 2001
From: Youngjoon Lee <5462944+youngjoon-lee@users.noreply.github.com>
Date: Sat, 21 Dec 2024 15:17:59 +0900
Subject: [PATCH] rename missing old names

---
 simlib/blendnet-sims/scripts/latency.py | 36 ++++++++++++++-----------
 1 file changed, 20 insertions(+), 16 deletions(-)

diff --git a/simlib/blendnet-sims/scripts/latency.py b/simlib/blendnet-sims/scripts/latency.py
index 0a2e5dc..6f1f113 100755
--- a/simlib/blendnet-sims/scripts/latency.py
+++ b/simlib/blendnet-sims/scripts/latency.py
@@ -38,7 +38,7 @@ class Message:
     id: str
     total_latency: Latency
     persistent_transmission_latencies: list[Latency] = field(default_factory=list)
-    blend_latencies: list[Latency] = field(default_factory=list)
+    temporal_processor_latencies: list[Latency] = field(default_factory=list)
 
     def __hash__(self):
         return self.id
@@ -52,11 +52,11 @@ class Message:
     def persistent_transmission_released(self, event: Event):
         Message.finish_recent_latency(self.persistent_transmission_latencies, event)
 
-    def blend_scheduled(self, event: Event):
-        Message.start_new_latency(self.blend_latencies, event)
+    def temporal_processor_scheduled(self, event: Event):
+        Message.start_new_latency(self.temporal_processor_latencies, event)
 
-    def blend_released(self, event: Event):
-        Message.finish_recent_latency(self.blend_latencies, event)
+    def temporal_processor_released(self, event: Event):
+        Message.finish_recent_latency(self.temporal_processor_latencies, event)
 
     @staticmethod
     def start_new_latency(latencies: list[Latency], event: Event):
@@ -103,8 +103,8 @@ class NodeEvents:
     msg_generation_events: list[Event] = field(default_factory=list)
     persistent_transmission_events: list[QueueEvent] = field(default_factory=list)
     persistent_transmission_queue_size: int = 0
-    blend_events: list[QueueEvent] = field(default_factory=list)
-    blend_queue_size: int = 0
+    temporal_processor_events: list[QueueEvent] = field(default_factory=list)
+    temporal_processor_queue_size: int = 0
     fully_unwrapped_msg_events: list[Event] = field(default_factory=list)
 
     def add_msg_generation_event(self, event: Event):
@@ -123,14 +123,18 @@ class NodeEvents:
             QueueEvent(event, self.persistent_transmission_queue_size)
         )
 
-    def add_blend_event(self, event: Event):
+    def add_temporal_processor_event(self, event: Event):
         if event.topic == "TemporalProcessorScheduled":
-            self.blend_queue_size += 1
+            self.temporal_processor_queue_size += 1
         elif event.topic == "MessageReleasedFromTemporalProcessor":
-            self.blend_queue_size -= 1
+            self.temporal_processor_queue_size -= 1
         else:
-            raise Exception(f"Unexpected event topic for blend: {event.topic}")
-        self.blend_events.append(QueueEvent(event, self.blend_queue_size))
+            raise Exception(
+                f"Unexpected event topic for temporal processor: {event.topic}"
+            )
+        self.temporal_processor_events.append(
+            QueueEvent(event, self.temporal_processor_queue_size)
+        )
 
     def add_fully_unwrapped_msg_event(self, event: Event):
         self.fully_unwrapped_msg_events.append(event)
@@ -224,12 +228,12 @@ def parse_record_stream(
             node_storage.get(record["node_id"]).add_persistent_transmission_event(event)
         elif topic == "TemporalProcessorScheduled":
             event = event_from_record(topic, record)
-            msg_storage[record["payload_id"]].blend_scheduled(event)
-            node_storage.get(record["node_id"]).add_blend_event(event)
+            msg_storage[record["payload_id"]].temporal_processor_scheduled(event)
+            node_storage.get(record["node_id"]).add_temporal_processor_event(event)
         elif topic == "MessageReleasedFromTemporalProcessor":
             event = event_from_record(topic, record)
-            msg_storage[record["payload_id"]].blend_released(event)
-            node_storage.get(record["node_id"]).add_blend_event(event)
+            msg_storage[record["payload_id"]].temporal_processor_released(event)
+            node_storage.get(record["node_id"]).add_temporal_processor_event(event)
 
     return msg_storage, node_storage