#!/usr/bin/env python3
# Copyright (c) Facebook, Inc. and its affiliates.
#
# This source code is licensed under the MIT license found in the
# LICENSE file in the root directory of this source tree.

import re

from mcrouter.test.McrouterTestCase import McrouterTestCase

class TestMcrouterToMcrouterTko(McrouterTestCase):
    config = './mcrouter/test/test_mcrouter_to_mcrouter_tko.json'
    extra_args = ['--timeouts-until-tko', '1', '--group-remote-errors']

    def setUp(self):
        self.underlying_mcr = self.add_mcrouter(self.config,
                extra_args=self.extra_args, bg_mcrouter=True)

    def get_mcrouter(self):
        return self.add_mcrouter(self.config, extra_args=self.extra_args)

    def test_underlying_tko(self):
        mcr = self.get_mcrouter()

        self.assertFalse(mcr.delete("key"))

        stats = self.underlying_mcr.stats("suspect_servers")
        print(stats)
        self.assertEqual(1, len(stats))
        self.assertTrue(re.match("status:(tko|down)", list(stats.values())[0]))

        stats = mcr.stats("suspect_servers")
        self.assertEqual(0, len(stats))

#!/usr/bin/env python3
# Copyright (c) Facebook, Inc. and its affiliates.
#
# This source code is licensed under the MIT license found in the
# LICENSE file in the root directory of this source tree.

import re
import time

from mcrouter.test.McrouterTestCase import McrouterTestCase

class TestMcrouterToMcrouterTko(McrouterTestCase):
    config = './mcrouter/test/test_mcrouter_to_mcrouter_tko.json'
    extra_args = ['--timeouts-until-tko', '1', '--group-remote-errors']

    def setUp(self):
        self.underlying_mcr = self.add_mcrouter(self.config,
                extra_args=self.extra_args, bg_mcrouter=True)

    def get_mcrouter(self):
        return self.add_mcrouter(self.config, extra_args=self.extra_args)

    def test_underlying_tko(self):
        mcr = self.get_mcrouter()

        self.assertFalse(mcr.delete("key"))

        retries = 10
        while self.underlying_mcr.stats()['cmd_delete_count'] != 1 and retries > 0:
            retries = retries - 1
            time.sleep(1)

        stats = self.underlying_mcr.stats("suspect_servers")
        print(stats)
        self.assertEqual(1, len(stats))
        self.assertTrue(re.match("status:(tko|down)", list(stats.values())[0]))

        stats = mcr.stats("suspect_servers")
        self.assertEqual(0, len(stats))

Fix flaky mcrouter tko tests