You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by av...@apache.org on 2021/01/15 07:29:14 UTC
[ignite] branch ignite-ducktape updated: Log fix (#8661)
This is an automated email from the ASF dual-hosted git repository.
av pushed a commit to branch ignite-ducktape
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/ignite-ducktape by this push:
new 243011c Log fix (#8661)
243011c is described below
commit 243011c75b0889ba6e879f4d9344e1bf6c900531
Author: Vladimir Steshin <vl...@gmail.com>
AuthorDate: Fri Jan 15 10:28:45 2021 +0300
Log fix (#8661)
---
.../ducktests/tests/ignitetest/services/utils/ignite_aware.py | 11 ++++++-----
1 file changed, 6 insertions(+), 5 deletions(-)
diff --git a/modules/ducktests/tests/ignitetest/services/utils/ignite_aware.py b/modules/ducktests/tests/ignitetest/services/utils/ignite_aware.py
index cf0e9c7..8837bf5 100644
--- a/modules/ducktests/tests/ignitetest/services/utils/ignite_aware.py
+++ b/modules/ducktests/tests/ignitetest/services/utils/ignite_aware.py
@@ -305,7 +305,7 @@ class IgniteAwareService(BackgroundThreadService, IgnitePathAware, metaclass=ABC
nodes = self.nodes
for node in nodes:
- self.logger.info("Disconnecting " + node.account.hostname + ".")
+ self.logger.info("Dropping ignite connections on '" + node.account.hostname + "' ...")
self.__backup_iptables(nodes)
@@ -320,12 +320,13 @@ class IgniteAwareService(BackgroundThreadService, IgnitePathAware, metaclass=ABC
cmd = f"sudo iptables -I %s 1 -p tcp -m multiport --dport {dsc_ports},{cm_ports} -j DROP"
- for node in nodes:
- self.logger.debug("Activating netfilter on '%s': %s" % (node.name, self.__dump_netfilter_settings(node)))
-
return self.exec_on_nodes_async(nodes,
lambda n: (n.account.ssh_client.exec_command(cmd % "INPUT"),
- n.account.ssh_client.exec_command(cmd % "OUTPUT")))
+ n.account.ssh_client.exec_command(cmd % "OUTPUT"),
+ self.logger.debug("Activated netfilter on '%s': %s" %
+ (n.name, self.__dump_netfilter_settings(n)))
+ )
+ )
def __backup_iptables(self, nodes):
# Store current network filter settings.