From e3181b19e19838b3e7f245f0c00025280e364ed8 Mon Sep 17 00:00:00 2001 From: Joshua Boniface Date: Mon, 11 Jun 2018 21:47:41 -0400 Subject: [PATCH] Remove instant triggers and only run flush/unflush on keepalive --- NodeInstance.py | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) diff --git a/NodeInstance.py b/NodeInstance.py index a8cbcf07..9f7109fc 100644 --- a/NodeInstance.py +++ b/NodeInstance.py @@ -59,12 +59,6 @@ class NodeInstance(): except AttributeError: self.domain_state = 'stop' - if self.name == self.this_node and self.inflush == False: - if self.domain_state == 'flush': - self.flush() - if self.domain_state == 'unflush': - self.unflush() - @zk.DataWatch('/nodes/{}/memfree'.format(self.name)) def watch_hypervisor_memfree(data, stat, event=""): try: @@ -311,8 +305,8 @@ class NodeInstance(): ansiiprint.echo('{}Flushed nodes:{} {}'.format(ansiiprint.bold(), ansiiprint.end(), ' '.join(self.flushed_node_list)), '', 'c') # toggle state management of this node - if self.domain_state == 'flush': + if self.domain_state == 'flush' and self.inflush == False: self.flush() - if self.domain_state == 'unflush': + if self.domain_state == 'unflush' and self.inflush == False: self.unflush()