aboutsummaryrefslogtreecommitdiffstats
path: root/mcp/reclass/classes/cluster/mcp-odl-ha/opendaylight/control.yml.j2
blob: 3c8a35e06433a50898bf16c5f7806b2b2b578ca0 (plain) 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

##############################################################################
# Copyright (c) 2018 Mirantis Inc., Enea AB and others.
# All rights reserved. This program and the accompanying materials
# are made available under the terms of the Apache License, Version 2.0
# which accompanies this distribution, and is available at
# http://www.apache.org/licenses/LICENSE-2.0
##############################################################################
---
classes:
  - service.opendaylight.server.cluster
  - cluster.mcp-common-ha.openstack_interface_vcp_biport
{%- if conf.MCP_VCP %}
  - cluster.mcp-odl-ha
{%- endif %}
parameters:
  _param:
    linux_system_codename: xenial
  opendaylight:
    server:
      odl_bind_ip: ${_param:single_address}
      odl_rest_port: ${_param:opendaylight_rest_port}
      java_min_mem: 6g
      java_max_mem: 6g
      router_enabled: true
      netvirt_nat_mode: conntrack
      karaf_features:
        odl_default:
          - odl-restconf-all
          - odl-aaa-authn
        netvirt:
          - odl-netvirt-openstack
      seed_nodes_list: {%- for i in range(1, 4) %} ${_param:opendaylight_server_node0{{ i }}_address}{%- endfor %}
background-color: #e3d2d2 } /* Error */ .highlight .k { color: #008800; font-weight: bold } /* Keyword */ .highlight .ch { color: #888888 } /* Comment.Hashbang */ .highlight .cm { color: #888888 } /* Comment.Multiline */ .highlight .cp { color: #cc0000; font-weight: bold } /* Comment.Preproc */ .highlight .cpf { color: #888888 } /* Comment.PreprocFile */ .highlight .c1 { color: #888888 } /* Comment.Single */ .highlight .cs { color: #cc0000; font-weight: bold; background-color: #fff0f0 } /* Comment.Special */ .highlight .gd { color: #000000; background-color: #ffdddd } /* Generic.Deleted */ .highlight .ge { font-style: italic } /* Generic.Emph */ .highlight .gr { color: #aa0000 } /* Generic.Error */ .highlight .gh { color: #333333 } /* Generic.Heading */ .highlight .gi { color: #000000; background-color: #ddffdd } /* Generic.Inserted */ .highlight .go { color: #888888 } /* Generic.Output */ .highlight .gp { color: #555555 } /* Generic.Prompt */ .highlight .gs { font-weight: bold } /* Generic.Strong */ .highlight .gu { color: #666666 } /* Generic.Subheading */ .highlight .gt { color: #aa0000 } /* Generic.Traceback */ .highlight .kc { color: #008800; font-weight: bold } /* Keyword.Constant */ .highlight .kd { color: #008800; font-weight: bold } /* Keyword.Declaration */ .highlight .kn { color: #008800; font-weight: bold } /* Keyword.Namespace */ .highlight .kp { color: #008800 } /* Keyword.Pseudo */ .highlight .kr { color: #008800; font-weight: bold } /* Keyword.Reserved */ .highlight .kt { color: #888888; font-weight: bold } /* Keyword.Type */ .highlight .m { color: #0000DD; font-weight: bold } /* Literal.Number */ .highlight .s { color: #dd2200; background-color: #fff0f0 } /* Literal.String */ .highlight .na { color: #336699 } /* Name.Attribute */ .highlight .nb { color: #003388 } /* Name.Builtin */ .highlight .nc { color: #bb0066; font-weight: bold } /* Name.Class */ .highlight .no { color: #003366; font-weight: bold } /* Name.Constant */ .highlight .nd { color: #555555 } /* Name.Decorator */ .highlight .ne { color: #bb0066; font-weight: bold } /* Name.Exception */ .highlight .nf { color: #0066bb; font-weight: bold } /* Name.Function */ .highlight .nl { color: #336699; font-style: italic } /* Name.Label */ .highlight .nn { color: #bb0066; font-weight: bold } /* Name.Namespace */ .highlight .py { color: #336699; font-weight: bold } /* Name.Property */ .highlight .nt { color: #bb0066; font-weight: bold } /* Name.Tag */ .highlight .nv { color: #336699 } /* Name.Variable */ .highlight .ow { color: #008800 } /* Operator.Word */ .highlight .w { color: #bbbbbb } /* Text.Whitespace */ .highlight .mb { color: #0000DD; font-weight: bold } /* Literal.Number.Bin */ .highlight .mf { color: #0000DD; font-weight: bold } /* Literal.Number.Float */ .highlight .mh { color: #0000DD; font-weight: bold } /* Literal.Number.Hex */ .highlight .mi { color: #0000DD; font-weight: bold } /* Literal.Number.Integer */ .highlight .mo { color: #0000DD; font-weight: bold } /* Literal.Number.Oct */ .highlight .sa { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Affix */ .highlight .sb { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Backtick */ .highlight .sc { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Char */ .highlight .dl { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Delimiter */ .highlight .sd { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Doc */ .highlight .s2 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Double */ .highlight .se { color: #0044dd; background-color: #fff0f0 } /* Literal.String.Escape */ .highlight .sh { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Heredoc */ .highlight .si { color: #3333bb; background-color: #fff0f0 } /* Literal.String.Interpol */ .highlight .sx { color: #22bb22; background-color: #f0fff0 } /* Literal.String.Other */ .highlight .sr { color: #008800; background-color: #fff0ff } /* Literal.String.Regex */ .highlight .s1 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Single */ .highlight .ss { color: #aa6600; background-color: #fff0f0 } /* Literal.String.Symbol */ .highlight .bp { color: #003388 } /* Name.Builtin.Pseudo */ .highlight .fm { color: #0066bb; font-weight: bold } /* Name.Function.Magic */ .highlight .vc { color: #336699 } /* Name.Variable.Class */ .highlight .vg { color: #dd7700 } /* Name.Variable.Global */ .highlight .vi { color: #3333bb } /* Name.Variable.Instance */ .highlight .vm { color: #336699 } /* Name.Variable.Magic */ .highlight .il { color: #0000DD; font-weight: bold } /* Literal.Number.Integer.Long */ } 
#!/usr/bin/env python

##############################################################################
# Copyright (c) 2015 Ericsson AB and others.
#
# All rights reserved. This program and the accompanying materials
# are made available under the terms of the Apache License, Version 2.0
# which accompanies this distribution, and is available at
# http://www.apache.org/licenses/LICENSE-2.0
##############################################################################

# Unittest for yardstick.benchmark.scenarios.storage.fio.Fio

from __future__ import absolute_import

import os
import unittest

import mock
from oslo_serialization import jsonutils

from yardstick.benchmark.scenarios.storage import fio


@mock.patch('yardstick.benchmark.scenarios.storage.fio.ssh')
class FioTestCase(unittest.TestCase):

    def setUp(self):
        self.ctx = {
            'host': {
                'ip': '172.16.0.137',
                'user': 'cirros',
                'key_filename': 'mykey.key'
            }
        }
        self.sample_output = {
            'read': 'fio_read_sample_output.json',
            'write': 'fio_write_sample_output.json',
            'rw': 'fio_rw_sample_output.json'
        }

    def test_fio_successful_setup(self, mock_ssh):

        options = {
            'filename': '/home/ubuntu/data.raw',
            'bs': '4k',
            'rw': 'rw',
            'ramp_time': 10
        }
        args = {'options': options}
        p = fio.Fio(args, self.ctx)
        p.setup()

        mock_ssh.SSH.from_node().execute.return_value = (0, '', '')
        self.assertIsNotNone(p.client)
        self.assertEqual(p.setup_done, True)

    def test_fio_successful_no_sla(self, mock_ssh):

        options = {
            'filename': '/home/ubuntu/data.raw',
            'bs': '4k',
            'rw': 'rw',
            'ramp_time': 10
        }
        args = {'options': options}
        p = fio.Fio(args, self.ctx)
        result = {}

        p.client = mock_ssh.SSH.from_node()

        sample_output = self._read_sample_output(self.sample_output['rw'])
        mock_ssh.SSH.from_node().execute.return_value = (0, sample_output, '')

        p.run(result)

        expected_result = '{"read_bw": 83888, "read_iops": 20972,' \
            '"read_lat": 236.8, "write_bw": 84182, "write_iops": 21045,'\
            '"write_lat": 233.55}'
        expected_result = jsonutils.loads(expected_result)
        self.assertEqual(result, expected_result)

    def test_fio_successful_read_no_sla(self, mock_ssh):

        options = {
            'filename': '/home/ubuntu/data.raw',
            'bs': '4k',
            'rw': "read",
            'ramp_time': 10
        }
        args = {'options': options}
        p = fio.Fio(args, self.ctx)
        result = {}

        p.client = mock_ssh.SSH.from_node()

        sample_output = self._read_sample_output(self.sample_output['read'])
        mock_ssh.SSH.from_node().execute.return_value = (0, sample_output, '')

        p.run(result)

        expected_result = '{"read_bw": 36113, "read_iops": 9028,' \
            '"read_lat": 108.7}'
        expected_result = jsonutils.loads(expected_result)
        self.assertEqual(result, expected_result)

    def test_fio_successful_write_no_sla(self, mock_ssh):

        options = {
            'filename': '/home/ubuntu/data.raw',
            'bs': '4k',
            'rw': 'write',
            'ramp_time': 10
        }
        args = {'options': options}
        p = fio.Fio(args, self.ctx)
        result = {}

        p.client = mock_ssh.SSH.from_node()

        sample_output = self._read_sample_output(self.sample_output['write'])
        mock_ssh.SSH.from_node().execute.return_value = (0, sample_output, '')

        p.run(result)

        expected_result = '{"write_bw": 35107, "write_iops": 8776,'\
            '"write_lat": 111.74}'
        expected_result = jsonutils.loads(expected_result)
        self.assertEqual(result, expected_result)

    def test_fio_successful_lat_sla(self, mock_ssh):

        options = {
            'filename': '/home/ubuntu/data.raw',
            'bs': '4k',
            'rw': 'rw',
            'ramp_time': 10
        }
        args = {
            'options': options,
            'sla': {'write_lat': 300.1}
        }
        p = fio.Fio(args, self.ctx)
        result = {}

        p.client = mock_ssh.SSH.from_node()

        sample_output = self._read_sample_output(self.sample_output['rw'])
        mock_ssh.SSH.from_node().execute.return_value = (0, sample_output, '')

        p.run(result)

        expected_result = '{"read_bw": 83888, "read_iops": 20972,' \
            '"read_lat": 236.8, "write_bw": 84182, "write_iops": 21045,'\
            '"write_lat": 233.55}'
        expected_result = jsonutils.loads(expected_result)
        self.assertEqual(result, expected_result)

    def test_fio_unsuccessful_lat_sla(self, mock_ssh):

        options = {
            'filename': '/home/ubuntu/data.raw',
            'bs': '4k',
            'rw': 'rw',
            'ramp_time': 10
        }
        args = {
            'options': options,
            'sla': {'write_lat': 200.1}
        }
        p = fio.Fio(args, self.ctx)
        result = {}

        p.client = mock_ssh.SSH.from_node()

        sample_output = self._read_sample_output(self.sample_output['rw'])
        mock_ssh.SSH.from_node().execute.return_value = (0, sample_output, '')
        self.assertRaises(AssertionError, p.run, result)

    def test_fio_successful_bw_iops_sla(self, mock_ssh):

        options = {
            'filename': '/home/ubuntu/data.raw',
            'bs': '4k',
            'rw': 'rw',
            'ramp_time': 10
        }
        args = {
            'options': options,
            'sla': {'read_iops': 20000}
        }
        p = fio.Fio(args, self.ctx)
        result = {}

        p.client = mock_ssh.SSH.from_node()

        sample_output = self._read_sample_output(self.sample_output['rw'])
        mock_ssh.SSH.from_node().execute.return_value = (0, sample_output, '')

        p.run(result)

        expected_result = '{"read_bw": 83888, "read_iops": 20972,' \
            '"read_lat": 236.8, "write_bw": 84182, "write_iops": 21045,'\
            '"write_lat": 233.55}'
        expected_result = jsonutils.loads(expected_result)
        self.assertEqual(result, expected_result)

    def test_fio_unsuccessful_bw_iops_sla(self, mock_ssh):

        options = {
            'filename': '/home/ubuntu/data.raw',
            'bs': '4k',
            'rw': 'rw',
            'ramp_time': 10
        }
        args = {
            'options': options,
            'sla': {'read_iops': 30000}
        }
        p = fio.Fio(args, self.ctx)
        result = {}

        p.client = mock_ssh.SSH.from_node()

        sample_output = self._read_sample_output(self.sample_output['rw'])
        mock_ssh.SSH.from_node().execute.return_value = (0, sample_output, '')
        self.assertRaises(AssertionError, p.run, result)

    def test_fio_unsuccessful_script_error(self, mock_ssh):

        options = {
            'filename': '/home/ubuntu/data.raw',
            'bs': '4k',
            'rw': 'rw',
            'ramp_time': 10
        }
        args = {'options': options}
        p = fio.Fio(args, self.ctx)
        result = {}

        p.client = mock_ssh.SSH.from_node()

        mock_ssh.SSH.from_node().execute.return_value = (1, '', 'FOOBAR')
        self.assertRaises(RuntimeError, p.run, result)

    def _read_sample_output(self, file_name):
        curr_path = os.path.dirname(os.path.abspath(__file__))
        output = os.path.join(curr_path, file_name)
        with open(output) as f:
            sample_output = f.read()
        return sample_output


def main():
    unittest.main()


if __name__ == '__main__':
    main()