aboutsummaryrefslogtreecommitdiffstats
path: root/tests/unit/benchmark/scenarios/networking/.highlight .hll { background-color: #ffffcc } .highlight .c { color: #888888 } /* Comment */ .highlight .err { color: #a61717; 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 */
Project: Test framework for verifying infrastructure compliance (yardstick)
Project Creation Date: April 28th, 2015
Project Category: Integration & Testing
Lifecycle State: Incubation
Primary Contact: limingjiang@huawei.com
Project Lead: limingjiang@huawei.com
Jira Project Name: Infrastructure Verification
Jira Project Prefix: Yardstick
Mailing list tag: [Yardstick]
IRC: #opnfv-yardstick
Repository: yardstick

Committers:
jean.gaoliang@huawei.com
lvjing5@huawei.com
wu.zhihui1@zte.com.cn
14_ykl@tongji.edu.cn
limingjiang@huawei.com
trevor.cooper@intel.com
ross.b.brattain@intel.com
chenjiankun1@huawei.com
rodolfo.alonso.hernandez@intel.com
emma.l.foley@intel.com
abhijit.sinha@intel.com

Link to TSC approval: http://meetbot.opnfv.org/meetings/
Link to approval of additional submitters:
Link to approval of new PTL: Done via Condorcet Internet Voting Service, avaliable from Raymond Piak
n201' href='#n201'>201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 
#!/usr/bin/env python

##############################################################################
# Copyright (c) 2016 Huawei Technologies Co.,Ltd and other.
#
# 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.networking.netutilization.NetUtilization

from __future__ import absolute_import
import mock
import unittest
import os

from yardstick.benchmark.scenarios.networking import netutilization


@mock.patch('yardstick.benchmark.scenarios.networking.netutilization.ssh')
class NetUtilizationTestCase(unittest.TestCase):

    def setUp(self):
        self.ctx = {
            'host': {
                'ip': '172.16.0.137',
                'user': 'cirros',
                'key_filename': "mykey.key"
            }
        }

        self.result = {}

    def test_setup_success(self, mock_ssh):
        options = {
            "interval": 1,
            "count": 1
        }
        args = {'options': options}

        n = netutilization.NetUtilization(args, self.ctx)
        mock_ssh.SSH.from_node().execute.return_value = (0, '', '')

        n.setup()
        self.assertIsNotNone(n.client)
        self.assertTrue(n.setup_done)

    def test_execute_command_success(self, mock_ssh):
        options = {
            "interval": 1,
            "count": 1
        }
        args = {'options': options}

        n = netutilization.NetUtilization(args, self.ctx)
        mock_ssh.SSH.from_node().execute.return_value = (0, '', '')
        n.setup()

        expected_result = 'abcdefg'
        mock_ssh.SSH.from_node().execute.return_value = (0, expected_result, '')
        result = n._execute_command("foo")
        self.assertEqual(result, expected_result)

    def test_execute_command_failed(self, mock_ssh):
        options = {
            "interval": 1,
            "count": 1
        }
        args = {'options': options}

        n = netutilization.NetUtilization(args, self.ctx)
        mock_ssh.SSH.from_node().execute.return_value = (0, '', '')
        n.setup()

        mock_ssh.SSH.from_node().execute.return_value = (127, '', 'abcdefg')
        self.assertRaises(RuntimeError, n._execute_command,
                          "failed")

    def test_get_network_utilization_success(self, mock_ssh):
        options = {
            "interval": 1,
            "count": 1
        }
        args = {'options': options}

        n = netutilization.NetUtilization(args, self.ctx)
        mock_ssh.SSH.from_node().execute.return_value = (0, '', '')
        n.setup()

        mpstat_output = self._read_file("netutilization_sample_output1.txt")
        mock_ssh.SSH.from_node().execute.return_value = (0, mpstat_output, '')
        result = n._get_network_utilization()

        expected_result = \
            {"network_utilization_maximun": {
                "lo": {"rxcmp/s": "0.00",
                       "%ifutil": "0.00",
                       "txcmp/s": "0.00",
                       "txkB/s": "0.00",
                       "rxkB/s": "0.00",
                       "rxpck/s": "0.00",
                       "txpck/s": "0.00",
                       "rxmcst/s": "0.00"},
                "eth0": {"rxcmp/s": "0.00",
                         "%ifutil": "0.00",
                         "txcmp/s": "0.00",
                         "txkB/s": "0.00",
                         "rxkB/s": "0.00",
                         "rxpck/s": "0.00",
                         "txpck/s": "0.00",
                         "rxmcst/s": "0.00"}},
             "network_utilization_average": {
                "lo": {"rxcmp/s": "0.00",
                       "%ifutil": "0.00",
                       "txcmp/s": "0.00",
                       "txkB/s": "0.00",
                       "rxkB/s": "0.00",
                       "rxpck/s": "0.00",
                       "txpck/s": "0.00",
                       "rxmcst/s": "0.00"},
                "eth0": {"rxcmp/s": "0.00",
                         "%ifutil": "0.00",
                         "txcmp/s": "0.00",
                         "txkB/s": "0.00",
                         "rxkB/s": "0.00",
                         "rxpck/s": "0.00",
                         "txpck/s": "0.00",
                         "rxmcst/s": "0.00"}},
             "network_utilization_minimum": {
                "lo": {"rxcmp/s": "0.00",
                       "%ifutil": "0.00",
                       "txcmp/s": "0.00",
                       "txkB/s": "0.00",
                       "rxkB/s": "0.00",
                       "rxpck/s": "0.00",
                       "txpck/s": "0.00",
                       "rxmcst/s": "0.00"},
                "eth0": {"rxcmp/s": "0.00",
                         "%ifutil": "0.00",
                         "txcmp/s": "0.00",
                         "txkB/s": "0.00",
                         "rxkB/s": "0.00",
                         "rxpck/s": "0.00",
                         "txpck/s": "0.00",
                         "rxmcst/s": "0.00"}}}

        self.assertDictEqual(result, expected_result)

    def test_get_network_utilization_2_success(self, mock_ssh):
        options = {
            "interval": 1,
            "count": 2
        }
        args = {'options': options}

        n = netutilization.NetUtilization(args, self.ctx)
        mock_ssh.SSH.from_node().execute.return_value = (0, '', '')
        n.setup()

        mpstat_output = self._read_file("netutilization_sample_output2.txt")
        mock_ssh.SSH.from_node().execute.return_value = (0, mpstat_output, '')
        result = n._get_network_utilization()

        expected_result = \
            {"network_utilization_maximun": {
                "lo": {"rxcmp/s": "0.00",
                       "%ifutil": "0.00",
                       "txcmp/s": "0.00",
                       "txkB/s": "0.00",
                       "rxkB/s": "0.00",
                       "rxpck/s": "0.00",
                       "txpck/s": "0.00",
                       "rxmcst/s": "0.00"},
                "eth0": {"rxcmp/s": "0.00",
                         "%ifutil": "0.00",
                         "txcmp/s": "0.00",
                         "txkB/s": "0.00",
                         "rxkB/s": "0.00",
                         "rxpck/s": "0.00",
                         "txpck/s": "0.00",
                         "rxmcst/s": "0.00"}},
             "network_utilization_average": {
                "lo": {"rxcmp/s": "0.00",
                       "%ifutil": "0.00",
                       "txcmp/s": "0.00",
                       "txkB/s": "0.00",
                       "rxkB/s": "0.00",
                       "rxpck/s": "0.00",
                       "txpck/s": "0.00",
                       "rxmcst/s": "0.00"},
                "eth0": {"rxcmp/s": "0.00",
                         "%ifutil": "0.00",
                         "txcmp/s": "0.00",
                         "txkB/s": "0.00",
                         "rxkB/s": "0.00",
                         "rxpck/s": "0.00",
                         "txpck/s": "0.00",
                         "rxmcst/s": "0.00"}},
             "network_utilization_minimum": {
                "lo": {"rxcmp/s": "0.00",
                       "%ifutil": "0.00",
                       "txcmp/s": "0.00",
                       "txkB/s": "0.00",
                       "rxkB/s": "0.00",
                       "rxpck/s": "0.00",
                       "txpck/s": "0.00",
                       "rxmcst/s": "0.00"},
                "eth0": {"rxcmp/s": "0.00",
                         "%ifutil": "0.00",
                         "txcmp/s": "0.00",
                         "txkB/s": "0.00",
                         "rxkB/s": "0.00",
                         "rxpck/s": "0.00",
                         "txpck/s": "0.00",
                         "rxmcst/s": "0.00"}}}

        self.assertDictEqual(result, expected_result)

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