Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Added Control of link up events by interruptions #136

Merged
merged 14 commits into from
Jun 22, 2023
Merged

Added Control of link up events by interruptions #136

Show file tree
Hide file tree
Changes from 3 commits
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
4316b9f
Added control of link up events by interruptions
Ktmi Jun 7, 2023
27795a2
Show status and status_reason in UI
Ktmi Jun 13, 2023
7ee2b9a
Removed logging statement from UI
Ktmi Jun 13, 2023
d6d1750
Improve internal consistency with link up/down
Ktmi Jun 15, 2023
be4a667
Updated changelog
Ktmi Jun 15, 2023
382e097
Swapped link_down check with link_up check
Ktmi Jun 16, 2023
c3a59dd
Improved notify_status_change test
Ktmi Jun 16, 2023
3779f9c
Linter cleanup
Ktmi Jun 16, 2023
fe751bf
Updated notify_link_status_change to use status
Ktmi Jun 16, 2023
0577465
Included link_status_lock
Ktmi Jun 16, 2023
3ec9891
Removed inconsistant link_up
Ktmi Jun 19, 2023
f737eb0
Merge branch 'master' into feat/service_interruptions
Ktmi Jun 20, 2023
f820911
Added in logging of received interruptions
Ktmi Jun 21, 2023
b89088b
Replaced incorrect logical OR with AND
Ktmi Jun 21, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
42 changes: 42 additions & 0 deletions main.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1152,3 +1152,45 @@ def handle_link_maintenance_end(self, event):
link.endpoint_a.enable()
link.endpoint_b.enable()
self.notify_link_status_change(link, reason='maintenance')

@listen_to('topology.interruption.start')
def on_interruption_start(self, event: KytosEvent):
"""Deals with the start of service interruption."""
with self._links_lock:
self.handle_interruption_start(event)

def handle_interruption_start(self, event: KytosEvent):
"""Deals with the start of service interruption."""
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@Ktmi considering the point that @italovalcy has also brought to the attention on yesterday's meeting, maybe on both handle_interruption_start and handle_interruption_end it would good points to centralize log.info entries, after all, we're also using log.info for port status changes, so here it'd reasonable too. Another benefit of centralizing here on topology is that it could simplify certain logs for interruption sources. Wdyt?

Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@Ktmi let me know about this one here, if you agree and also if it'll be part of this PR or a subsequent one.

interrupt_type = event.content['type']
# switches = event.content.get('switches', [])
# interfaces = event.content.get('interfaces', [])
links = event.content.get('links', [])
# for switch_id in switches:
# pass
# for interface_id in interfaces:
# pass
for link_id in links:
link = self.links[link_id]
viniarck marked this conversation as resolved.
Show resolved Hide resolved
self.notify_link_status_change(link, interrupt_type)
viniarck marked this conversation as resolved.
Show resolved Hide resolved
self.notify_topology_update()

@listen_to('topology.interruption.end')
def on_interruption_end(self, event: KytosEvent):
"""Deals with the end of service interruption."""
with self._links_lock:
self.handle_interruption_end(event)

def handle_interruption_end(self, event: KytosEvent):
"""Deals with the end of service interruption."""
interrupt_type = event.content['type']
# switches = event.content.get('switches', [])
# interfaces = event.content.get('interfaces', [])
links = event.content.get('links', [])
# for switch_id in switches:
# pass
# for interface_id in interfaces:
# pass
for link_id in links:
link = self.links[link_id]
self.notify_link_status_change(link, interrupt_type)
viniarck marked this conversation as resolved.
Show resolved Hide resolved
self.notify_topology_update()
48 changes: 26 additions & 22 deletions tests/integration/test_main.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,28 +37,32 @@ def test_get_switches_dict(self):
def test_get_event_listeners(self):
"""Verify all event listeners registered."""
actual_events = self.napp.listeners()
expected_events = ['kytos/core.shutdown',
'kytos/core.shutdown.kytos/topology',
'kytos/maintenance.start_link',
'kytos/maintenance.end_link',
'kytos/maintenance.start_switch',
'kytos/maintenance.end_switch',
'kytos/.*.link_available_tags',
'kytos/.*.liveness.(up|down)',
'kytos/.*.liveness.disabled',
'kytos/topology.get',
'.*.topo_controller.upsert_switch',
'.*.of_lldp.network_status.updated',
'.*.interface.is.nni',
'.*.connection.lost',
'.*.switch.interfaces.created',
'.*.topology.switch.interface.created',
'.*.switch.interface.deleted',
'.*.switch.interface.link_down',
'.*.switch.interface.link_up',
'.*.switch.(new|reconnected)',
'.*.switch.port.created',
'kytos/topology.notify_link_up_if_status']
expected_events = [
'kytos/core.shutdown',
'kytos/core.shutdown.kytos/topology',
'kytos/maintenance.start_link',
'kytos/maintenance.end_link',
'kytos/maintenance.start_switch',
'kytos/maintenance.end_switch',
'kytos/.*.link_available_tags',
'kytos/.*.liveness.(up|down)',
'kytos/.*.liveness.disabled',
'kytos/topology.get',
'.*.topo_controller.upsert_switch',
'.*.of_lldp.network_status.updated',
'.*.interface.is.nni',
'.*.connection.lost',
'.*.switch.interfaces.created',
'.*.topology.switch.interface.created',
'.*.switch.interface.deleted',
'.*.switch.interface.link_down',
'.*.switch.interface.link_up',
'.*.switch.(new|reconnected)',
'.*.switch.port.created',
'kytos/topology.notify_link_up_if_status',
'topology.interruption.start',
'topology.interruption.end',
]
assert sorted(expected_events) == sorted(actual_events)

async def test_get_interfaces(self):
Expand Down
136 changes: 111 additions & 25 deletions tests/unit/test_main.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
import pytest
import time
from datetime import timedelta
from unittest.mock import MagicMock, create_autospec, patch
from unittest.mock import MagicMock, create_autospec, patch, call

from kytos.core.common import EntityStatus
from kytos.core.helpers import now
Expand Down Expand Up @@ -62,28 +62,32 @@ def setup_method(self):

def test_get_event_listeners(self):
"""Verify all event listeners registered."""
expected_events = ['kytos/core.shutdown',
'kytos/core.shutdown.kytos/topology',
'kytos/maintenance.start_link',
'kytos/maintenance.end_link',
'kytos/maintenance.start_switch',
'kytos/maintenance.end_switch',
'kytos/.*.link_available_tags',
'.*.topo_controller.upsert_switch',
'.*.of_lldp.network_status.updated',
'.*.interface.is.nni',
'.*.connection.lost',
'.*.switch.interfaces.created',
'.*.topology.switch.interface.created',
'.*.switch.interface.deleted',
'.*.switch.interface.link_down',
'.*.switch.interface.link_up',
'.*.switch.(new|reconnected)',
'kytos/.*.liveness.(up|down)',
'kytos/.*.liveness.disabled',
'kytos/topology.get',
'.*.switch.port.created',
'kytos/topology.notify_link_up_if_status']
expected_events = [
'kytos/core.shutdown',
'kytos/core.shutdown.kytos/topology',
'kytos/maintenance.start_link',
'kytos/maintenance.end_link',
'kytos/maintenance.start_switch',
'kytos/maintenance.end_switch',
'kytos/.*.link_available_tags',
'.*.topo_controller.upsert_switch',
'.*.of_lldp.network_status.updated',
'.*.interface.is.nni',
'.*.connection.lost',
'.*.switch.interfaces.created',
'.*.topology.switch.interface.created',
'.*.switch.interface.deleted',
'.*.switch.interface.link_down',
'.*.switch.interface.link_up',
'.*.switch.(new|reconnected)',
'kytos/.*.liveness.(up|down)',
'kytos/.*.liveness.disabled',
'kytos/topology.get',
'.*.switch.port.created',
'kytos/topology.notify_link_up_if_status',
'topology.interruption.start',
'topology.interruption.end',
]
actual_events = self.napp.listeners()
assert sorted(expected_events) == sorted(actual_events)

Expand Down Expand Up @@ -1343,8 +1347,10 @@ def test_add_links(self, *args):
mock_event = MagicMock()
mock_intf_a = MagicMock()
mock_intf_b = MagicMock()
mock_event.content = {"interface_a": mock_intf_a,
"interface_b": mock_intf_b}
mock_event.content = {
"interface_a": mock_intf_a,
"interface_b": mock_intf_b
}
self.napp.add_links(mock_event)
mock_link.extend_metadata.assert_called()
mock_get_link_or_create.assert_called()
Expand Down Expand Up @@ -1632,3 +1638,83 @@ def test_notify_interface_link_status(self, *args):
self.napp.notify_interface_link_status(MagicMock(), "link enabled")
assert mock_get_link_from_interface.call_count == 3
assert self.napp.controller.buffers.app.put.call_count == 1

@patch('napps.kytos.topology.main.Main.notify_topology_update')
@patch('napps.kytos.topology.main.Main.notify_link_status_change')
def test_interruption_start(
self,
mock_notify_link_status_change,
mock_notify_topology_update
):
"""Tests processing of received interruption start events."""
link_a = MagicMock()
link_b = MagicMock()
link_c = MagicMock()
self.napp.links = {
'link_a': link_a,
'link_b': link_b,
'link_c': link_c,
}
event = KytosEvent(
"topology.interruption.start",
{
'type': 'test_interruption',
'switches': [
],
'interfaces': [
],
'links': [
'link_a',
'link_c',
],
}
)
self.napp.handle_interruption_start(event)
mock_notify_link_status_change.assert_has_calls(
[
call(link_a, 'test_interruption'),
call(link_c, 'test_interruption'),
]
)
assert mock_notify_link_status_change.call_count == 2
mock_notify_topology_update.assert_called_once()

@patch('napps.kytos.topology.main.Main.notify_topology_update')
@patch('napps.kytos.topology.main.Main.notify_link_status_change')
def test_interruption_end(
self,
mock_notify_link_status_change,
mock_notify_topology_update
):
"""Tests processing of received interruption end events."""
link_a = MagicMock()
link_b = MagicMock()
link_c = MagicMock()
self.napp.links = {
'link_a': link_a,
'link_b': link_b,
'link_c': link_c,
}
event = KytosEvent(
"topology.interruption.start",
{
'type': 'test_interruption',
'switches': [
],
'interfaces': [
],
'links': [
'link_a',
'link_c',
],
}
)
self.napp.handle_interruption_end(event)
mock_notify_link_status_change.assert_has_calls(
[
call(link_a, 'test_interruption'),
call(link_c, 'test_interruption'),
]
)
assert mock_notify_link_status_change.call_count == 2
mock_notify_topology_update.assert_called_once()
5 changes: 4 additions & 1 deletion ui/k-info-panel/link_info.kytos
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,10 @@
'active': '',
'id': '',
'endpoint_a': '',
'endpoint_b': '',},
'endpoint_b': '',
'status': '',
viniarck marked this conversation as resolved.
Show resolved Hide resolved
'status_reason': '',
},
}
},
methods: {
Expand Down
4 changes: 3 additions & 1 deletion ui/k-info-panel/switch_info.kytos
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -102,7 +102,9 @@
'manufacturer': '',
'serial': '',
'hardware': '',
'software': '',},
'software': '',
'status': '',
'status_reason': ''},
interfaces: [],
custom_properties: {},
flows: [],
Expand Down