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

Finagle how startup happens

This commit is contained in:
Joshua Boniface 2018-09-30 13:34:31 -04:00
parent fc8a2e1806
commit 3e937362cd
1 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
router-daemon/pvcrd/RouterInstance.py
View File

@ -49,6 +49,7 @@ class RouterInstance():
self.s_network = s_network self.s_network = s_network
self.network_list = [] self.network_list = []
self.ipmi_hostname = self.config['ipmi_hostname'] self.ipmi_hostname = self.config['ipmi_hostname']
self.active = False
# Zookeeper handlers for changed states # Zookeeper handlers for changed states
@zk_conn.DataWatch('/routers/{}/daemonstate'.format(self.name)) @zk_conn.DataWatch('/routers/{}/daemonstate'.format(self.name))
@ -65,14 +66,6 @@ class RouterInstance():
except AttributeError: except AttributeError:
self.network_state = 'secondary' self.network_state = 'secondary'
# toggle state management of this router
if s_network != {}: # If there's no network list, we're too early in startup
if self.name == self.this_router:
if self.network_state == 'secondary':
self.become_secondary()
if self.network_state == 'primary':
self.become_primary()
# Get value functions # Get value functions
def getname(self): def getname(self):
return self.name return self.name
@ -96,6 +89,7 @@ class RouterInstance():
self.network_list.append(s_network[network].getvni()) self.network_list.append(s_network[network].getvni())
def become_secondary(self): def become_secondary(self):
self.active = True
ansiiprint.echo('Setting router {} to secondary state'.format(self.name), '', 'i') ansiiprint.echo('Setting router {} to secondary state'.format(self.name), '', 'i')
ansiiprint.echo('Network list: {}'.format(', '.join(self.network_list)), '', 'c') ansiiprint.echo('Network list: {}'.format(', '.join(self.network_list)), '', 'c')
for router in self.t_router: for router in self.t_router:
@ -115,6 +109,7 @@ class RouterInstance():
time.sleep(1) time.sleep(1)
def become_primary(self): def become_primary(self):
self.active = True
ansiiprint.echo('Setting router {} to primary state.'.format(self.name), '', 'i') ansiiprint.echo('Setting router {} to primary state.'.format(self.name), '', 'i')
ansiiprint.echo('Network list: {}'.format(', '.join(self.network_list)), '', 'c') ansiiprint.echo('Network list: {}'.format(', '.join(self.network_list)), '', 'c')
for network in self.s_network: for network in self.s_network:
@ -212,6 +207,14 @@ class RouterInstance():
except ValueError: except ValueError:
pass pass
# toggle state management of this router
if s_network != {} and not self.active: # If there's no network list, we're too early in startup
if self.name == self.this_router:
if self.network_state == 'secondary':
self.become_secondary()
if self.network_state == 'primary':
self.become_primary()
# Try to set ourself primary if there is no primary in the cluster # Try to set ourself primary if there is no primary in the cluster
cluster_has_primary = False cluster_has_primary = False
for router in self.t_router: for router in self.t_router: