~ubuntu-branches/ubuntu/vivid/ceilometer/vivid-proposed

« back to all changes in this revision

Viewing changes to ceilometer/tests/alarm/test_partitioned_alarm_svc.py

  • Committer: Package Import Robot
  • Author(s): Chuck Short
  • Date: 2014-06-13 13:20:35 UTC
  • mfrom: (1.1.17)
  • Revision ID: package-import@ubuntu.com-20140613132035-42ibzh8j7ww2q31i
Tags: 2014.2~b1-0ubuntu1
* New upstream release.
* debian/control: Open up juno release
* debian/patches/fix-requirements.patch: Refreshed.
* debian/rules: Patch the ceilometer.conf.sample directly since
  the configuration files are generated by a tool.
* debian/ceilometer-common.install: Drop sources.json.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# -*- encoding: utf-8 -*-
2
1
#
3
 
# Copyright © 2013 Red Hat, Inc
 
2
# Copyright 2013 Red Hat, Inc
4
3
#
5
4
# Author: Eoghan Glynn <eglynn@redhat.com>
6
5
#
18
17
"""Tests for ceilometer.alarm.service.PartitionedAlarmService.
19
18
"""
20
19
import contextlib
21
 
 
22
20
import mock
23
21
from stevedore import extension
24
22
 
25
23
from ceilometer.alarm import service
 
24
from ceilometer import messaging
26
25
from ceilometer.openstack.common.fixture import config
27
26
from ceilometer.openstack.common import test
28
27
 
30
29
class TestPartitionedAlarmService(test.BaseTestCase):
31
30
    def setUp(self):
32
31
        super(TestPartitionedAlarmService, self).setUp()
 
32
        messaging.setup('fake://')
 
33
        self.addCleanup(messaging.cleanup)
 
34
 
33
35
        self.threshold_eval = mock.Mock()
34
36
        self.api_client = mock.MagicMock()
35
37
        self.CONF = self.useFixture(config.Config()).conf
54
56
        self.partitioned.extension_manager = self.extension_mgr
55
57
 
56
58
    @mock.patch('ceilometer.pipeline.setup_pipeline', mock.MagicMock())
57
 
    def test_start(self):
 
59
    def test_lifecycle(self):
58
60
        test_interval = 120
59
61
        self.CONF.set_override('evaluation_interval',
60
62
                               test_interval,
61
63
                               group='alarm')
62
64
        get_client = 'ceilometerclient.client.get_client'
63
 
        create_conn = 'ceilometer.openstack.common.rpc.create_connection'
64
 
        with contextlib.nested(mock.patch(get_client,
65
 
                                          return_value=self.api_client),
66
 
                               mock.patch(create_conn)):
 
65
        with contextlib.nested(
 
66
                mock.patch(get_client, return_value=self.api_client),
 
67
                mock.patch.object(self.partitioned.rpc_server, 'start')):
67
68
            self.partitioned.start()
68
69
            pc = self.partitioned.partition_coordinator
69
70
            expected = [
82
83
            ]
83
84
            actual = self.partitioned.tg.add_timer.call_args_list
84
85
            self.assertEqual(expected, actual)
 
86
            self.partitioned.stop()
85
87
 
86
88
    def test_presence_reporting(self):
87
89
        priority = 42