#!/usr/bin/env python
# Copyright (c) 2012 Cloudera, Inc. All rights reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
# Verification of impalad metrics after a test run.

import logging
import pytest
from tests.common.impala_test_suite import ImpalaTestSuite
from tests.common.test_vector import TestDimension

# List of metrics that should be equal to zero when there are no outstanding queries.
METRIC_LIST = ["impala-server.backends.client-cache.clients-in-use",
               "impala-server.io-mgr.num-open-files",
               "impala-server.hash-table.total-bytes",
               "impala-server.io-mgr.num-open-files",
               "impala-server.mem-pool.total-bytes",
               "impala-server.scan-ranges.num-missing-volume-id",
               ]


class TestValidateMetrics(ImpalaTestSuite):
  """Verify metric values from the debug webpage.

  This test suite must be run after all the tests have been run, and no
  in-flight queries remain.
  TODO: Add a test for local assignments.
  """

  def __get_metric_value(self, metric):
    """Returns an integer metric value"""
    return self.impalad_test_service.get_metric_value(metric)

  def test_metrics_are_zero(self):
    """Test that all the metric in METRIC_LIST are 0"""
    for metric in METRIC_LIST:
      assert self.__get_metric_value(metric) == 0, "%s's value should be zero" % metric

  def test_num_unused_buffers(self):
    """Test that all buffers are unused"""
    buffers = self.__get_metric_value("impala-server.io-mgr.num-buffers")
    unused_buffers = self.__get_metric_value("impala-server.io-mgr.num-unused-buffers")
    err_msg = "Num Buffers: %s, Unused Buffers: %d" % (buffers, unused_buffers)
    assert buffers == unused_buffers, err_msg

#!/usr/bin/env python
# Copyright (c) 2012 Cloudera, Inc. All rights reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
# Verification of impalad metrics after a test run.

import logging
import pytest
from tests.common.impala_test_suite import ImpalaTestSuite
from tests.common.test_vector import TestDimension

# List of metrics that should be equal to zero when there are no outstanding queries.
METRIC_LIST = ["impala-server.backends.client-cache.clients-in-use",
               "impala-server.io-mgr.num-open-files",
               "impala-server.hash-table.total-bytes",
               "impala-server.io-mgr.num-open-files",
               "impala-server.mem-pool.total-bytes",
               "impala-server.scan-ranges.num-missing-volume-id",
               ]


class TestValidateMetrics(ImpalaTestSuite):
  """Verify metric values from the debug webpage.

  This test suite must be run after all the tests have been run, and no
  in-flight queries remain.
  TODO: Add a test for local assignments.
  """

  def __get_metric_value(self, metric):
    """Returns an integer metric value"""
    return self.impalad_test_service.get_metric_value(metric)

  def test_metrics_are_zero(self):
    """Test that all the metric in METRIC_LIST are 0"""
    for metric in METRIC_LIST:
      self.__assert_metric_value(metric, 0)

  def test_num_unused_buffers(self):
    """Test that all buffers are unused"""
    buffers = self.__get_metric_value("impala-server.io-mgr.num-buffers")
    unused_buffers = self.__get_metric_value("impala-server.io-mgr.num-unused-buffers")
    self.__assert_metric_value("impala-server.io-mgr.num-unused-buffers", buffers)

  def __assert_metric_value(self, metric_name, expected_value):
    actual_value = self.__get_metric_value(metric_name)
    assert expected_value == actual_value, "Metric '%s' value is: %s Expected: %s" %\
        (metric_name, actual_value, expected_value)

Update test metric verification to output actual and expected value on failure