parallelvirtualcluster/pvc
1
0
Fork 0
Code Issues 11 Pull Requests Projects Releases 115 Wiki Activity

Have VXNetworkInstance set MTU if unset

Browse Source 
Makes this explicit in Zookeeper if a network is unset, post-migration
(schema version 6).

Addresses #144
This commit is contained in:
Joshua Boniface
2021-10-09 17:51:45 -04:00
parent 24de0f4189
commit c45f8f5bd5
1 changed files with 24 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
node-daemon/pvcnoded/objects/VXNetworkInstance.py
View File

@@ -80,10 +80,19 @@ class VXNetworkInstance(object):
try: try:
self.vx_mtu = self.zkhandler.read(('network.mtu', self.vni)) self.vx_mtu = self.zkhandler.read(('network.mtu', self.vni))
if self.vx_mtu == '' or self.vx_mtu is None:
raise
except Exception: except Exception:
self.vx_mtu = None
# Explicitly set the MTU to max_mtu if unset (in Zookeeper too assuming the key exists)
if self.vx_mtu == '' or self.vx_mtu is None:
self.vx_mtu = self.max_mtu self.vx_mtu = self.max_mtu
# Try block for migration purposes
try:
self.zkhandler.write([
(('network.mtu', self.vni), self.vx_mtu)
])
except Exception:
pass
# Zookeper handlers for changed states # Zookeper handlers for changed states
@self.zkhandler.zk_conn.DataWatch(self.zkhandler.schema.path('network', self.vni)) @self.zkhandler.zk_conn.DataWatch(self.zkhandler.schema.path('network', self.vni))
@@ -97,6 +106,7 @@ class VXNetworkInstance(object):
self.old_description = self.description self.old_description = self.description
self.description = data.decode('ascii') self.description = data.decode('ascii')
# Try block for migration purposes
try: try:
@self.zkhandler.zk_conn.DataWatch(self.zkhandler.schema.path('network.mtu', self.vni)) @self.zkhandler.zk_conn.DataWatch(self.zkhandler.schema.path('network.mtu', self.vni))
def watch_network_mtu(data, stat, event=''): def watch_network_mtu(data, stat, event=''):
@@ -132,10 +142,19 @@ class VXNetworkInstance(object):
try: try:
self.vx_mtu = self.zkhandler.read(('network.mtu', self.vni)) self.vx_mtu = self.zkhandler.read(('network.mtu', self.vni))
if self.vx_mtu == '' or self.vx_mtu is None:
raise
except Exception: except Exception:
self.vx_mtu = None
# Explicitly set the MTU to max_mtu if unset (in Zookeeper too assuming the key exists)
if self.vx_mtu == '' or self.vx_mtu is None:
self.vx_mtu = self.max_mtu self.vx_mtu = self.max_mtu
try:
# Try block for migration purposes
self.zkhandler.write([
(('network.mtu', self.vni), self.vx_mtu)
])
except Exception:
pass
self.nftables_netconf_filename = '{}/networks/{}.nft'.format(self.config['nft_dynamic_directory'], self.vni) self.nftables_netconf_filename = '{}/networks/{}.nft'.format(self.config['nft_dynamic_directory'], self.vni)
self.firewall_rules = [] self.firewall_rules = []
@@ -241,6 +260,7 @@ add rule inet filter forward ip6 saddr {netaddr6} counter jump {vxlannic}-out
self.stopDHCPServer() self.stopDHCPServer()
self.startDHCPServer() self.startDHCPServer()
# Try block for migration purposes
try: try:
@self.zkhandler.zk_conn.DataWatch(self.zkhandler.schema.path('network.mtu', self.vni)) @self.zkhandler.zk_conn.DataWatch(self.zkhandler.schema.path('network.mtu', self.vni))
def watch_network_mtu(data, stat, event=''): def watch_network_mtu(data, stat, event=''):