Merge "Add functional test for two-cell scheduler behaviors"

2019-11-01 01:51:08 +00:00
parent 7fb4e3001a 888dd7d475
commit 38c5f2cc96
1 changed files with 97 additions and 0 deletions
@@ -0,0 +1,97 @@
+#    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.
+
+from nova import test
+from nova.tests import fixtures as nova_fixtures
+from nova.tests.functional import fixtures as func_fixtures
+from nova.tests.functional import integrated_helpers
+from nova.tests.unit import fake_network
+import nova.tests.unit.image.fake as fake_image
+from nova.tests.unit import policy_fixture
+
+CELL1_NAME = 'cell1'
+CELL2_NAME = 'cell2'
+
+
+class MultiCellSchedulerTestCase(test.TestCase,
+                                 integrated_helpers.InstanceHelperMixin):
+
+    NUMBER_OF_CELLS = 2
+
+    def setUp(self):
+        super(MultiCellSchedulerTestCase, self).setUp()
+        self.useFixture(policy_fixture.RealPolicyFixture())
+        self.useFixture(nova_fixtures.NeutronFixture(self))
+        self.useFixture(nova_fixtures.AllServicesCurrent())
+        self.useFixture(func_fixtures.PlacementFixture())
+        api_fixture = self.useFixture(nova_fixtures.OSAPIFixture(
+            api_version='v2.1'))
+        self.api = api_fixture.api
+        self.admin_api = api_fixture.admin_api
+
+        fake_network.set_stub_network_methods(self)
+
+        self.flags(allow_resize_to_same_host=False)
+        self.flags(enabled_filters=['AllHostsFilter'],
+                   group='filter_scheduler')
+        self.start_service('conductor')
+        self.start_service('scheduler')
+        fake_image.stub_out_image_service(self)
+        self.addCleanup(fake_image.FakeImageService_reset)
+
+    def _test_create_and_migrate(self, expected_status, az=None):
+        server = self._build_minimal_create_server_request(self.api,
+                                                           'some-server',
+                                                           az=az)
+        post = {'server': server}
+        # If forcing the server onto a host we have to use the admin API.
+        api = self.admin_api if az else self.api
+        created_server = api.post_server(post)
+
+        # Wait for it to finish being created
+        found_server = self._wait_for_state_change(
+            self.admin_api, created_server, 'ACTIVE')
+        return self.admin_api.api_post(
+            '/servers/%s/action' % found_server['id'],
+            {'migrate': None},
+            check_response_status=[expected_status])
+
+    def test_migrate_between_cells(self):
+        """Verify that migrating between cells is not allowed.
+
+        Right now, we can't migrate between cells. So, create two computes
+        in different cells and make sure that migration fails with NoValidHost.
+        """
+        # Hosts in different cells
+        self.start_service('compute', host='compute1', cell=CELL1_NAME)
+        self.start_service('compute', host='compute2', cell=CELL2_NAME)
+
+        result = self._test_create_and_migrate(expected_status=400)
+        self.assertIn('No valid host', result.body['badRequest']['message'])
+
+    def test_migrate_within_cell(self):
+        """Verify that migrating within cells is allowed.
+
+        Create two computes in the same cell and validate that the same
+        migration is allowed.
+        """
+        # Hosts in the same cell
+        self.start_service('compute', host='compute1', cell=CELL1_NAME)
+        self.start_service('compute', host='compute2', cell=CELL1_NAME)
+        # Create another host just so it looks like we have hosts in
+        # both cells
+        self.start_service('compute', host='compute3', cell=CELL2_NAME)
+
+        # Force the server onto compute1 in cell1 so we do not accidentally
+        # land on compute3 in cell2 and fail to migrate.
+        self._test_create_and_migrate(expected_status=202,
+                                      az='nova:compute1')