<filename>nova/tests/unit/servicegroup/test_db_servicegroup.py
# Copyright 2012 IBM Corp.
#
#    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.

import datetime
import mock

from nova import servicegroup
from nova import test


class DBServiceGroupTestCase(test.NoDBTestCase):

    def setUp(self):
        super(DBServiceGroupTestCase, self).setUp()
        self.down_time = 15
        self.flags(service_down_time=self.down_time,
                   servicegroup_driver='db')
        self.servicegroup_api = servicegroup.API()

    @mock.patch('oslo_utils.timeutils.utcnow')
    def test_is_up(self, now_mock):
        service_ref = {
            'host': 'fake-host',
            'topic': 'compute',
        }
        fts_func = datetime.datetime.fromtimestamp
        fake_now = 1000

        # Up (equal)
        now_mock.return_value = fts_func(fake_now)
        service_ref['updated_at'] = fts_func(fake_now - self.down_time)
        service_ref['created_at'] = fts_func(fake_now - self.down_time)

        result = self.servicegroup_api.service_is_up(service_ref)
        self.assertTrue(result)

        # Up
        service_ref['updated_at'] = fts_func(fake_now - self.down_time + 1)
        service_ref['created_at'] = fts_func(fake_now - self.down_time + 1)
        result = self.servicegroup_api.service_is_up(service_ref)
        self.assertTrue(result)

        # Down
        service_ref['updated_at'] = fts_func(fake_now - self.down_time - 3)
        service_ref['created_at'] = fts_func(fake_now - self.down_time - 3)
        result = self.servicegroup_api.service_is_up(service_ref)
        self.assertFalse(result)

    @mock.patch('nova.conductor.api.LocalAPI.service_get_all_by_topic')
    def test_get_all(self, ga_mock):
        service_refs = [
            {
                'host': 'fake-host1',
                'topic': 'compute'
            },
            {
                'host': 'fake-host2',
                'topic': 'compute'
            },
            {
                'host': 'fake-host3',
                'topic': 'compute'
            },
        ]
        ga_mock.return_value = service_refs
        with mock.patch.object(self.servicegroup_api._driver,
                'is_up', side_effect=[
                    None,
                    True,  # fake host 2 is enabled, all others disabled
                    None
                    ]):
            services = self.servicegroup_api.get_all('compute')
        self.assertEqual(['fake-host2'], services)
        ga_mock.assert_called_once_with(mock.ANY, 'compute')

    def test_join(self):
        service = mock.MagicMock(report_interval=1)

        self.servicegroup_api.join('fake-host', 'fake-topic', service)
        fn = self.servicegroup_api._driver._report_state
        service.tg.add_timer.assert_called_once_with(1, fn, 5, service)

    @mock.patch('nova.conductor.api.LocalAPI.service_update')
    def test_report_state(self, upd_mock):
        service_ref = {
            'host': 'fake-host',
            'topic': 'compute',
            'report_count': 10
        }
        service = mock.MagicMock(model_disconnected=False,
                                 service_ref=service_ref)
        fn = self.servicegroup_api._driver._report_state
        fn(service)
        upd_mock.assert_called_once_with(mock.ANY,
                                         service_ref,
                                         dict(report_count=11))

<filename>nova/tests/unit/servicegroup/test_db_servicegroup.py
# Copyright 2012 IBM Corp.
#
#    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.

import datetime
import mock

from nova import servicegroup
from nova import test


class DBServiceGroupTestCase(test.NoDBTestCase):

    def setUp(self):
        super(DBServiceGroupTestCase, self).setUp()
        self.down_time = 15
        self.flags(service_down_time=self.down_time,
                   servicegroup_driver='db')
        self.servicegroup_api = servicegroup.API()

    @mock.patch('oslo_utils.timeutils.utcnow')
    def test_is_up(self, now_mock):
        service_ref = {
            'host': 'fake-host',
            'topic': 'compute',
        }
        fts_func = datetime.datetime.fromtimestamp
        fake_now = 1000

        # Up (equal)
        now_mock.return_value = fts_func(fake_now)
        service_ref['updated_at'] = fts_func(fake_now - self.down_time)
        service_ref['created_at'] = fts_func(fake_now - self.down_time)

        result = self.servicegroup_api.service_is_up(service_ref)
        self.assertTrue(result)

        # Up
        service_ref['updated_at'] = fts_func(fake_now - self.down_time + 1)
        service_ref['created_at'] = fts_func(fake_now - self.down_time + 1)
        result = self.servicegroup_api.service_is_up(service_ref)
        self.assertTrue(result)

        # Down
        service_ref['updated_at'] = fts_func(fake_now - self.down_time - 3)
        service_ref['created_at'] = fts_func(fake_now - self.down_time - 3)
        result = self.servicegroup_api.service_is_up(service_ref)
        self.assertFalse(result)

    @mock.patch('nova.conductor.api.LocalAPI.service_get_all_by_topic')
    def test_get_all(self, ga_mock):
        service_refs = [
            {
                'host': 'fake-host1',
                'topic': 'compute'
            },
            {
                'host': 'fake-host2',
                'topic': 'compute'
            },
            {
                'host': 'fake-host3',
                'topic': 'compute'
            },
        ]
        ga_mock.return_value = service_refs
        with mock.patch.object(self.servicegroup_api._driver,
                'is_up', side_effect=[
                    None,
                    True,  # fake host 2 is enabled, all others disabled
                    None
                    ]):
            services = self.servicegroup_api.get_all('compute')
        self.assertEqual(['fake-host2'], services)
        ga_mock.assert_called_once_with(mock.ANY, 'compute')

    def test_join(self):
        service = mock.MagicMock(report_interval=1)

        self.servicegroup_api.join('fake-host', 'fake-topic', service)
        fn = self.servicegroup_api._driver._report_state
        service.tg.add_timer.assert_called_once_with(1, fn, 5, service)

    @mock.patch('nova.conductor.api.LocalAPI.service_update')
    def test_report_state(self, upd_mock):
        service_ref = {
            'host': 'fake-host',
            'topic': 'compute',
            'report_count': 10
        }
        service = mock.MagicMock(model_disconnected=False,
                                 service_ref=service_ref)
        fn = self.servicegroup_api._driver._report_state
        fn(service)
        upd_mock.assert_called_once_with(mock.ANY,
                                         service_ref,
                                         dict(report_count=11))

# Copyright 2012 IBM Corp. # #    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. # Up (equal) # Up # Down # fake host 2 is enabled, all others disabled