Skip to content

Commit f493715

Browse files
ralonsohmnasiadka
authored andcommitted
Update filter_existing_chassis signature and make it static
Partial-Bug: #2092271 Change-Id: Iafd1edcda72720bcd185d9d232de8e8e03a7cbff
1 parent d500101 commit f493715

File tree

3 files changed

+8
-12
lines changed

3 files changed

+8
-12
lines changed

neutron/plugins/ml2/drivers/ovn/mech_driver/ovsdb/commands.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -392,8 +392,7 @@ def run_idl(self, txn):
392392
az_hints = self.api.get_gateway_chassis_az_hints(self.g_name)
393393
filtered_existing_chassis = (
394394
self.scheduler.filter_existing_chassis(
395-
nb_idl=self.api, gw_chassis=self.all_gw_chassis,
396-
physnet=physnet,
395+
gw_chassis=self.all_gw_chassis, physnet=physnet,
397396
chassis_physnets=self.chassis_with_physnets,
398397
existing_chassis=existing_chassis, az_hints=az_hints,
399398
chassis_with_azs=self.chassis_with_azs))

neutron/scheduler/l3_ovn_scheduler.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,8 +40,8 @@ def select(self, nb_idl, sb_idl, gateway_name, candidates=None,
4040
scheduled.
4141
"""
4242

43-
def filter_existing_chassis(self, nb_idl, gw_chassis,
44-
physnet, chassis_physnets,
43+
@staticmethod
44+
def filter_existing_chassis(gw_chassis, physnet, chassis_physnets,
4545
existing_chassis, az_hints, chassis_with_azs):
4646
chassis_list = copy.copy(existing_chassis)
4747
for chassis_name in existing_chassis or []:

neutron/tests/unit/scheduler/test_l3_ovn_scheduler.py

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -118,8 +118,7 @@ def select(self, chassis_gateway_mapping, gateway_name,
118118

119119
def filter_existing_chassis(self, *args, **kwargs):
120120
return self.l3_scheduler.filter_existing_chassis(
121-
nb_idl=kwargs.pop('nb_idl'), gw_chassis=kwargs.pop('gw_chassis'),
122-
physnet=kwargs.pop('physnet'),
121+
gw_chassis=kwargs.pop('gw_chassis'), physnet=kwargs.pop('physnet'),
123122
chassis_physnets=kwargs.pop('chassis_physnets'),
124123
existing_chassis=kwargs.pop('existing_chassis'),
125124
az_hints=kwargs.pop('az_hints', []),
@@ -171,34 +170,32 @@ def test_filter_existing_chassis(self):
171170
# it from Base class didnt seem right. Also, there is no need to have
172171
# another test in LeastLoadedScheduler.
173172
chassis_physnets = {'temp': ['phys-network-0', 'phys-network-1']}
174-
nb_idl = FakeOVNGatewaySchedulerNbOvnIdl(
175-
self.fake_chassis_gateway_mappings['None'], 'g1')
176173
# Check if invalid chassis is removed
177174
self.assertEqual(
178175
['temp'], self.filter_existing_chassis(
179-
nb_idl=nb_idl, gw_chassis=["temp"],
176+
gw_chassis=["temp"],
180177
physnet='phys-network-1',
181178
chassis_physnets=chassis_physnets,
182179
existing_chassis=['temp', None]))
183180
# Check if invalid is removed -II
184181
self.assertFalse(
185182
self.filter_existing_chassis(
186-
nb_idl=nb_idl, gw_chassis=["temp"],
183+
gw_chassis=["temp"],
187184
physnet='phys-network-1',
188185
chassis_physnets=chassis_physnets,
189186
existing_chassis=None))
190187
# Check if chassis removed when physnet doesnt exist
191188
self.assertFalse(
192189
self.filter_existing_chassis(
193-
nb_idl=nb_idl, gw_chassis=["temp"],
190+
gw_chassis=["temp"],
194191
physnet='phys-network-2',
195192
chassis_physnets=chassis_physnets,
196193
existing_chassis=['temp']))
197194
# Check if chassis removed when it doesnt exist in gw_chassis
198195
# or in chassis_physnets
199196
self.assertFalse(
200197
self.filter_existing_chassis(
201-
nb_idl=nb_idl, gw_chassis=["temp1"],
198+
gw_chassis=["temp1"],
202199
physnet='phys-network-2',
203200
chassis_physnets=chassis_physnets,
204201
existing_chassis=['temp']))

0 commit comments

Comments
 (0)