salt/tests/multimaster/minion/test_event.py

# -*- coding: utf-8 -*-

from __future__ import absolute_import, print_function, unicode_literals

import pytest
import salt.modules.iptables
from tests.support.case import MultimasterModuleCase, MultiMasterTestShellCase
from tests.support.mixins import AdaptedConfigurationTestCaseMixin
from tests.support.unit import skipIf

HAS_IPTABLES = salt.modules.iptables.__virtual__()
if isinstance(HAS_IPTABLES, tuple):
    HAS_IPTABLES = HAS_IPTABLES[0]


@pytest.mark.destructive_test
@pytest.mark.skip_if_not_root
@skipIf(not HAS_IPTABLES, "iptables command is not available")
class TestHandleEvents(
    MultimasterModuleCase, MultiMasterTestShellCase, AdaptedConfigurationTestCaseMixin
):
    """
    Validate the events handling in multimaster environment
    """

    @pytest.mark.slow_test(seconds=10)  # Test takes >5 and <=10 seconds
    def test_minion_hangs_on_master_failure_50814(self):
        """
        Check minion handling events for the alive master when another master is dead.
        The case being checked here is described in details in issue #50814.
        """
        disconnect_master_rule = "-i lo -p tcp --dport {0} -j DROP".format(
            self.mm_master_opts["ret_port"]
        )
        # Disconnect the master.
        res = self.run_function(
            "iptables.append",
            ("filter", "INPUT", disconnect_master_rule),
            master_tgt="mm-sub-master",
        )
        # Workaround slow beacons.list_available response
        if not res:
            res = self.run_function(
                "iptables.append",
                ("filter", "INPUT", disconnect_master_rule),
                master_tgt="mm-sub-master",
            )
        self.assertTrue(res)
        try:
            # Send an event. This would return okay.
            res = self.run_function(
                "event.send", ("myco/foo/bar",), master_tgt="mm-sub-master",
            )
            self.assertTrue(res)
            # Send one more event. Minion was hanging on this. This is fixed by #53417
            res = self.run_function(
                "event.send", ("myco/foo/bar",), master_tgt="mm-sub-master", timeout=60,
            )
            self.assertTrue(
                res,
                "Minion is not responding to the second master after the first "
                "one has gone. Check #50814 for details.",
            )
        finally:
            # Remove the firewall rule taking master online back.
            # Since minion could be not responsive now use `salt-call --local` for this.
            res = self.run_call(
                "iptables.delete filter INPUT rule='{0}'".format(
                    disconnect_master_rule
                ),
                local=True,
                timeout=30,
            )
            self.assertEqual(res, ["local:"])
            # Ensure the master is back.
            res = self.run_function(
                "event.send", ("myco/foo/bar",), master_tgt="mm-master",
            )
            self.assertTrue(res)