ddb3199318
Each service implemented the get_backdoor_port method individually. This patch moves the implementation of this method to the base rpc API instead, and removes the now unnecessary code from each of the services. The server side method was left on all of the managers for rpc backwards copmatibility. They can be removed on the next major rpc version bump of those APIs. Part of blueprint base-rpc-api. Change-Id: Ia8838fafd80eb86a1c2d66f5e97370042d8d8c53
51 lines
1.6 KiB
Python
51 lines
1.6 KiB
Python
#
|
|
# Copyright 2013 - Red Hat, Inc.
|
|
#
|
|
# 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.
|
|
#
|
|
|
|
"""
|
|
Test the base rpc API.
|
|
"""
|
|
|
|
from oslo.config import cfg
|
|
|
|
from nova import baserpc
|
|
from nova import context
|
|
from nova import test
|
|
|
|
CONF = cfg.CONF
|
|
|
|
|
|
class BaseAPITestCase(test.TestCase):
|
|
|
|
def setUp(self):
|
|
super(BaseAPITestCase, self).setUp()
|
|
self.user_id = 'fake'
|
|
self.project_id = 'fake'
|
|
self.context = context.RequestContext(self.user_id,
|
|
self.project_id)
|
|
self.conductor = self.start_service(
|
|
'conductor', manager=CONF.conductor.manager)
|
|
self.compute = self.start_service('compute')
|
|
self.base_rpcapi = baserpc.BaseAPI(CONF.compute_topic)
|
|
|
|
def test_ping(self):
|
|
res = self.base_rpcapi.ping(self.context, 'foo')
|
|
self.assertEqual(res, {'service': 'compute', 'arg': 'foo'})
|
|
|
|
def test_get_backdoor_port(self):
|
|
res = self.base_rpcapi.get_backdoor_port(self.context,
|
|
self.compute.host)
|
|
self.assertEqual(res, self.compute.backdoor_port)
|