Mirrors/network
1
0
Fork 0
mirror of https://github.com/linux-system-roles/network.git synced 2026-07-21 02:11:23 +00:00
Code Issues Projects Releases Wiki Activity

library: cleanup handling of run_results in RunEnvironmentAnsible

Browse source
This commit is contained in:
Thomas Haller 2018-01-19 13:16:56 +01:00
parent 1ae5196a87
commit a5eb321ef3
1 changed files with 8 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

19
library/network_connections.py
View file

@ -2017,32 +2017,29 @@ class RunEnvironmentAnsible(RunEnvironment):
def run_command(self, argv, encoding = None):
return self.module.run_command(argv, encoding = encoding)
def run_results_push(self, n_connections = None):
def _run_results_push(self, n_connections):
c = []
if n_connections is None:
n_connections = len(self.run_results) - 1
for cc in range(0, n_connections + 1):
c.append({
'log': [],
})
self._run_results.append(c)
def run_results_reset(self):
n_connections = len(self.run_results) - 1
del self._run_results[-1]
self.run_results_push(n_connections)
@property
def run_results(self):
return self._run_results[-1]
def _check_mode_changed(self, old_check_mode, new_check_mode, connections):
if old_check_mode is None:
self.run_results_push(len(connections))
self._run_results_push(len(connections))
elif old_check_mode == CheckMode.PREPARE:
self.run_results_push()
self._run_results_push(len(self.run_results) - 1)
elif old_check_mode == CheckMode.PRE_RUN:
self.run_results_reset()
# when switching from RRE_RUN to REAL_RUN, we drop the run-results
# we just collected and reset to empty. The PRE_RUN succeeded.
n_connections = len(self.run_results) - 1
del self._run_results[-1]
self._run_results_push(n_connections)
def log(self,
connections,