Skip to content

Commit

Permalink
fix: avoid blocking setup() when loading topology
Browse files Browse the repository at this point in the history
  • Loading branch information
viniarck committed Nov 7, 2024
1 parent 0470d17 commit ff2e24a
Showing 1 changed file with 12 additions and 4 deletions.
16 changes: 12 additions & 4 deletions main.py
Original file line number Diff line number Diff line change
Expand Up @@ -88,6 +88,9 @@ def load_sdx_topology(self):
"version": 1,
"timestamp": get_timestamp(),
}

def load_kytos_topology(self):
"""Load topology from Kytos-ng."""
with self._topo_lock:
self._topo_dict = self.get_kytos_topology()
self._converted_topo = self.convert_topology_v2()
Expand All @@ -111,10 +114,15 @@ def get_kytos_topology():
)
return topology

@listen_to(
"kytos/topology.updated",
"kytos/topology.topology_loaded",
)
@listen_to("kytos/topology.topology_loaded")
def on_topology_loaded(self, event: KytosEvent):
"""Handler for on topology_loaded."""
self.handler_on_topology_loaded()

def handler_on_topology_loaded(self):
self.load_kytos_topology()

@listen_to("kytos/topology.updated")
def on_topology_updated_event(self, event: KytosEvent):
"""Handler for topology updated events."""
self.handler_on_topology_updated_event(event)
Expand Down

0 comments on commit ff2e24a

Please sign in to comment.