Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
1 change: 1 addition & 0 deletions orchagent/vnetorch.h
Original file line number Diff line number Diff line change
Expand Up @@ -316,6 +316,7 @@ const request_description_t vnet_route_description = {
{ "check_directly_connected", REQ_T_BOOL },
{ "rx_monitor_timer", REQ_T_UINT },
{ "tx_monitor_timer", REQ_T_UINT },
{ "metric", REQ_T_UINT }
},
{ }
};
Expand Down
45 changes: 45 additions & 0 deletions tests/test_vnet.py
Original file line number Diff line number Diff line change
Expand Up @@ -3276,6 +3276,51 @@ def test_vnet_orch_32(self, dvs, testlog):
self.set_admin_status("Ethernet12", "down")


'''
Test 33 - Create vnet route tunnel with various metric values
'''
def test_vnet_orch_33(self, dvs, testlog):
self.setup_db(dvs)

vnet_obj = self.get_vnet_obj()

tunnel_name = 'tunnel_33'

vnet_obj.fetch_exist_entries(dvs)

create_vxlan_tunnel(dvs, tunnel_name, '10.10.10.10')
create_vnet_entry(dvs, 'Vnet33', tunnel_name, '10033', "")

vnet_obj.check_vnet_entry(dvs, 'Vnet33')
vnet_obj.check_vxlan_tunnel_entry(dvs, tunnel_name, 'Vnet33', '10033')

vnet_obj.check_vxlan_tunnel(dvs, tunnel_name, '10.10.10.10')

vnet_obj.fetch_exist_entries(dvs)

for i in range(21):
create_vnet_routes(dvs, f'0.0.0.{i}/32', 'Vnet33', f'10.10.10.{i}', metric=i)
vnet_obj.check_vnet_routes(dvs, 'Vnet33', f'10.10.10.{i}', tunnel_name)
check_state_db_routes(dvs, 'Vnet33', f"0.0.0.{i}/32", [f'10.10.10.{i}'])

entry = self.cdb.get_entry("VNET_ROUTE_TUNNEL", f"Vnet33|0.0.0.{i}/32")
assert entry is not None and len(entry) > 0, f"VNET route entry not found in CONFIG DB."
assert int(entry.get('metric', -1)) == i, f"VNET route metric mismatch: expected {i}, got {entry.get('metric', -1)}."

# Clean-up vnet route
delete_vnet_routes(dvs, f"0.0.0.{i}/32", 'Vnet33')
vnet_obj.check_del_vnet_routes(dvs, 'Vnet33')

vnet_obj.fetch_exist_entries(dvs)

# Clean-up and verify remove flows
delete_vnet_entry(dvs, "Vnet33")
vnet_obj.check_del_vnet_entry(dvs, "Vnet33")

delete_vxlan_tunnel(dvs, tunnel_name)
vnet_obj.check_del_vxlan_tunnel(dvs)


# Add Dummy always-pass test at end as workaroud
# for issue when Flaky fail on final test it invokes module tear-down before retrying
def test_nonflaky_dummy():
Expand Down
9 changes: 6 additions & 3 deletions tests/vnet_lib.py
Original file line number Diff line number Diff line change
Expand Up @@ -140,11 +140,11 @@ def delete_vnet_local_routes(dvs, prefix, vnet_name):
time.sleep(2)


def create_vnet_routes(dvs, prefix, vnet_name, endpoint, mac="", vni=0, ep_monitor="", profile="", primary="", monitoring="", rx_monitor_timer=-1, tx_monitor_timer=-1, adv_prefix="", check_directly_connected=False):
set_vnet_routes(dvs, prefix, vnet_name, endpoint, mac=mac, vni=vni, ep_monitor=ep_monitor, profile=profile, primary=primary, monitoring=monitoring, rx_monitor_timer=rx_monitor_timer, tx_monitor_timer=tx_monitor_timer, adv_prefix=adv_prefix, check_directly_connected=check_directly_connected)
def create_vnet_routes(dvs, prefix, vnet_name, endpoint, mac="", vni=0, ep_monitor="", profile="", primary="", monitoring="", rx_monitor_timer=-1, tx_monitor_timer=-1, adv_prefix="", check_directly_connected=False, metric=-1):
set_vnet_routes(dvs, prefix, vnet_name, endpoint, mac=mac, vni=vni, ep_monitor=ep_monitor, profile=profile, primary=primary, monitoring=monitoring, rx_monitor_timer=rx_monitor_timer, tx_monitor_timer=tx_monitor_timer, adv_prefix=adv_prefix, check_directly_connected=check_directly_connected, metric=metric)


def set_vnet_routes(dvs, prefix, vnet_name, endpoint, mac="", vni=0, ep_monitor="", profile="", primary="", monitoring="", rx_monitor_timer=-1, tx_monitor_timer=-1, adv_prefix="", check_directly_connected=False):
def set_vnet_routes(dvs, prefix, vnet_name, endpoint, mac="", vni=0, ep_monitor="", profile="", primary="", monitoring="", rx_monitor_timer=-1, tx_monitor_timer=-1, adv_prefix="", check_directly_connected=False, metric=-1):
conf_db = swsscommon.DBConnector(swsscommon.CONFIG_DB, dvs.redis_sock, 0)

attrs = [
Expand Down Expand Up @@ -181,6 +181,9 @@ def set_vnet_routes(dvs, prefix, vnet_name, endpoint, mac="", vni=0, ep_monitor=
if tx_monitor_timer != -1:
attrs.append(('tx_monitor_timer', str(tx_monitor_timer)))

if metric >= 0:
attrs.append(('metric', str(metric)))

tbl = swsscommon.Table(conf_db, "VNET_ROUTE_TUNNEL")
fvs = swsscommon.FieldValuePairs(attrs)
tbl.set("%s|%s" % (vnet_name, prefix), fvs)
Expand Down
Loading