1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
|
# Copyright 2015, 2018 IBM Corp.
#
# All Rights Reserved.
#
# 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 oslo_config import cfg
from oslo_log import log as logging
import pypowervm.const as c
from pypowervm.wrappers import job
import pypowervm.wrappers.logical_partition as wlpar
LOG = logging.getLogger(__name__)
CONF = cfg.CONF
_SUFFIX_PARM_MIGRATE = 'Migrate'
_SUFFIX_PARM_MIGRATE_VALIDATE = 'MigrateValidate'
_SUFFIX_PARM_MIGRATE_ABORT = 'MigrateAbort'
_SUFFIX_PARM_MIGRATE_RECOVER = 'MigrateRecover'
TGT_MGD_SYS = 'TargetManagedSystemName'
TGT_RMT_HMC = 'TargetRemoteHMCIPAddress'
TGT_RMT_HMC_USR = 'TargetRemoteHMCUserID'
VFC_MAPPINGS = 'VirtualFCMappings'
VSCSI_MAPPINGS = 'VirtualSCSIMappings'
VLAN_MAPPINGS = 'VlanMappings'
DEST_MSP = 'DestMSPIPaddr'
SRC_MSP = 'SourceMSPIPaddr'
SPP_ID = 'SharedProcPoolID'
OVS_OVERRIDE = 'OVSOverride'
VLAN_BRIDGE_OVERRIDE = 'VLANBridgeOverride'
AFFINITY = 'Affinity'
_OVERRIDE_OK = '2'
def migrate_lpar(
lpar, tgt_mgd_sys, validate_only=False, tgt_mgmt_svr=None,
tgt_mgmt_usr=None, virtual_fc_mappings=None,
virtual_scsi_mappings=None, dest_msp_name=None, source_msp_name=None,
spp_id=None, timeout=CONF.pypowervm_job_request_timeout * 4,
sdn_override=False, vlan_check_override=False, vlan_mappings=None,
check_affinity_score=False):
"""Method to migrate a logical partition.
:param lpar: The LPAR wrapper of the logical partition to migrate.
:param tgt_mgd_sys: The name of the managed system to migrate to.
:param validate_only: Indication of whether to just validate the migration
or actually perform it.
:param tgt_mgmt_svr: The ip of the PowerVM management platform managing
the target host.
:param tgt_mgmt_usr: The user id to use on the target PowerVM management
platform.
:param virtual_fc_mappings: The virtual fiber channel mappings to move
during the migration. See information below.
:param virtual_scsi_mappings: The virtual scsi mappings to move during the
migration. See information below.
:param dest_msp_name: A comma-separated list of destination VIOS IP
addresses identifying which interface(s) the Mover Service Partition
should use.
:param source_msp_name: A comma-separated list of source VIOS IP addresses
identifying which interface(s) the Mover Service Partition should use.
:param spp_id: The shared processor pool id to use on the target system.
:param timeout: maximum number of seconds for job to complete
:param sdn_override: (Optional, Default: False) If set to True, will allow
a migration where the networking is hosted on a non-
traditional VIOS partition (ex. the NovaLink)
:param vlan_check_override: (Optional, Default: False) If set to True, will
tell the Virtual I/O Server not to validate
that the other VIOS has the VLAN
pre-provisioned.
:param vlan_mappings: The vlan mappings that indicate what the VLAN should
be on the target system for a given MAC address. If not provided, the
original VLANs will be used. See information below.
:param check_affinity_score: (Optional, Default: False) If set to True,
will require a check that the LPAR's affinity
score is not lower on the destination host.
virtual_fc_mappings:
List of virtual fibre channel adapter mappings, with each mapping having
the following format:
virtual-slot-number/vios-lpar-name/vios-lpar-ID
[/[vios-virtual-slot-number][/[vios-fc-port-name]]]
The first two '/' characters must be present. The third '/' character is
optional, but it must be present if vios-virtual-slot-number or
vios-fc-port-name is specified. The last '/' character is optional but it
must be present if vios-fc-port-name is specified.
Optional values may be omitted. Optional values are vios-lpar-name
or vios-lpar-ID (one of those values is required, but not both),
vios-virtual-slot-number, and vios-fc-port-name.
For example:
4//1/14/fcs0 specifies a mapping of the virtual fibre channel client
adapter with slot number 4 to the virtual fibre channel server adapter with
slot number 14 in the VIOS partition with ID 1 on the destination managed
system. In addition, the mapping specifies to use physical fibre channel
port fcs0.
virtual_scsi_mappings:
List of virtual SCSI adapter mappings, with each mapping having the
following format:
virtual-slot-number/vios-lpar-name/vios-lpar-ID
[/vios-virtual-slot-number]
The first two '/' characters must be present. The last '/' character is
optional, but it must be present if vios-virtual-slot-number is specified.
Optional values may be omitted. Optional values are vios-lpar-name or
vios-lpar-ID (one of those values is required, but not both), and
vios-virtual-slot-number.
For example:
12/vios1//16 specifies a mapping of the virtual SCSI adapter with slot
number 12 to slot number 16 on the VIOS partition vios1 on the destination
managed system.
vlan_mappings:
List of vlan mappings, with each mapping having the following format:
MAC/PVID[/VLAN_A VLAN_B]
The first '/' must be present. The first field is the MAC address of the
adapter. The MAC address must be exactly 12 digits, case insensitive,
without colons in it. The second is what the target PVID should be set to
for that adapter. The remaining is a list of additional VLANs that could
be specified for adapters that have additional VLANs. The list of
additional VLANs is space delimited.
For example:
001122334455/12 specifies a mapping where the adapter with MAC address
001122334455 should have a PVID of 12 on the target system.
"""
op = (_SUFFIX_PARM_MIGRATE_VALIDATE
if validate_only else _SUFFIX_PARM_MIGRATE)
resp = lpar.adapter.read(wlpar.LPAR.schema_type, lpar.uuid,
suffix_type=c.SUFFIX_TYPE_DO,
suffix_parm=op)
job_wrapper = job.Job.wrap(resp.entry)
job_parms = [job_wrapper.create_job_parameter(TGT_MGD_SYS,
str(tgt_mgd_sys))]
# Generic 'raw' format job parameters.
for kw, val in [(TGT_RMT_HMC, tgt_mgmt_svr),
(TGT_RMT_HMC_USR, tgt_mgmt_usr), (DEST_MSP, dest_msp_name),
(SRC_MSP, source_msp_name), (SPP_ID, spp_id)]:
if val:
job_parms.append(
job_wrapper.create_job_parameter(kw, str(val)))
# The SDN / VLAN overrides are...odd. Instead of passing in a 'True', we
# must pass in the character of '2' to indicate that it is an override.
for kw, val in [(OVS_OVERRIDE, sdn_override),
(VLAN_BRIDGE_OVERRIDE, vlan_check_override)]:
if val:
job_parms.append(job_wrapper.create_job_parameter(kw,
_OVERRIDE_OK))
# The mappings are special. They require a join so that they are comma
# separated down to the API.
for kw, val in [(VFC_MAPPINGS, virtual_fc_mappings),
(VSCSI_MAPPINGS, virtual_scsi_mappings),
(VLAN_MAPPINGS, vlan_mappings)]:
if val:
job_parms.append(
job_wrapper.create_job_parameter(kw, ",".join(val)))
# Set affinity flag to 'true' as part of LPM. If enabled for the VM,
# an additional flag will be passed as part of migration parameters.
# Otherwise, this flag will not be passed. The default behavior is
# not to check for affinity score on the destination host.
if check_affinity_score:
job_parms.append(
job_wrapper.create_job_parameter(AFFINITY, 'true'))
job_wrapper.run_job(lpar.uuid, job_parms=job_parms, timeout=timeout)
def migrate_recover(lpar, force=False,
timeout=CONF.pypowervm_job_request_timeout):
"""Method to recover a failed logical partition migration.
:param lpar: The LPAR wrapper of the logical partition to recover.
:param force: Boolean specifying whether to force the migration to recover
when errors are encountered.
:param timeout: maximum number of seconds for job to complete
"""
resp = lpar.adapter.read(wlpar.LPAR.schema_type, lpar.uuid,
suffix_type=c.SUFFIX_TYPE_DO,
suffix_parm=_SUFFIX_PARM_MIGRATE_RECOVER)
job_wrapper = job.Job.wrap(resp.entry)
job_parms = []
if force:
job_parms.append(job_wrapper.create_job_parameter('Force', 'true'))
job_wrapper.run_job(lpar.uuid, job_parms=job_parms, timeout=timeout)
def migrate_abort(lpar, timeout=CONF.pypowervm_job_request_timeout):
"""Method to abort a logical partition migration.
:param lpar: The LPAR wrapper of the logical partition to abort the
migration operation.
:param timeout: maximum number of seconds for job to complete
"""
resp = lpar.adapter.read(wlpar.LPAR.schema_type, lpar.uuid,
suffix_type=c.SUFFIX_TYPE_DO,
suffix_parm=_SUFFIX_PARM_MIGRATE_ABORT)
job_wrapper = job.Job.wrap(resp.entry)
job_wrapper.run_job(lpar.uuid, job_parms=None, timeout=timeout)
|
