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
|
# Copyright 2016, 2017 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_log import log as logging
from pypowervm import exceptions as pvm_ex
from pypowervm.i18n import _
from pypowervm.tasks import partition
from pypowervm.utils import retry as pvm_retry
from pypowervm.wrappers import storage as pvm_stg
from pypowervm.wrappers import virtual_io_server as pvm_vios
LOG = logging.getLogger(__name__)
_cur_vios_uuid = None
_cur_vg_uuid = None
@pvm_retry.retry(tries=6)
def validate_vopt_repo_exists(
adapter, vopt_media_volume_group='rootvg', vopt_media_rep_size=1):
"""Will ensure that the virtual optical media repository exists.
Checks to make sure that at least one Virtual I/O Server has a virtual
optical media repository.
If the volume group on an I/O Server goes down (perhaps due to
maintenance), the system will rescan to determine if there is another
I/O Server that can host the request.
The very first invocation may be expensive. It may also be expensive
to call if a Virtual I/O Server unexpectedly goes down.
:param adapter: The pypowervm adapter.
:param vopt_media_volume_group: (Optional, Default: rootvg) The volume
group to use if the vopt media repo needs
to be created.
:param vopt_media_rep_size: (Optional, Default: 1) The size of the virtual
optical media (in GB) if the repo needs to be
created.
:return vios_uuid: The VIOS uuid hosting the VG
:return vg_uuid: The volume group uuid hosting the vopt.
:raise NoMediaRepoVolumeGroupFound: Raised when there are no VIOSes that
can support the virtual optical media.
"""
# If our static variables were set, then we should validate that the
# repo is still running. Otherwise, we need to reset the variables
# (as it could be down for maintenance).
if _cur_vg_uuid is not None:
vio_uuid = _cur_vios_uuid
vg_uuid = _cur_vg_uuid
try:
vg_wrap = pvm_stg.VG.get(
adapter, uuid=vg_uuid, parent_type=pvm_vios.VIOS,
parent_uuid=vio_uuid)
if vg_wrap is not None and len(vg_wrap.vmedia_repos) != 0:
return vio_uuid, vg_uuid
except Exception as exc:
LOG.exception(exc)
LOG.warning(_("An error occurred querying the virtual optical "
"media repository. Attempting to re-establish "
"connection with a virtual optical media repository."))
# Did not find the media repository. Need a deeper query
return _find_or_rebuild_vopt_repo(adapter, vopt_media_volume_group,
vopt_media_rep_size)
def _find_or_rebuild_vopt_repo(adapter, vopt_media_volume_group,
vopt_media_rep_size):
# If we're hitting this:
# a) It's our first time booting up;
# b) The previously-used Volume Group went offline (e.g. VIOS went down
# for maintenance); OR
# c) The previously-used media repository disappeared.
#
# The next step is to create a Media Repository dynamically.
found_vg, found_vios, conf_vg, conf_vios = _find_vopt_repo_data(
adapter, vopt_media_volume_group)
# If we didn't find a media repos OR an appropriate volume group, raise
# the exception. Since vopt_media_volume_group defaults to rootvg,
# which is always present, this should only happen if:
# a) No media repos exists on any VIOS we can see; AND
# b) The user specified a non-rootvg vopt_media_volume_group; AND
# c) The specified volume group did not exist on any VIOS.
if found_vg is None and conf_vg is None:
raise pvm_ex.NoMediaRepoVolumeGroupFound(
vol_grp=vopt_media_volume_group)
# If no media repos was found, create it.
if found_vg is None:
found_vg, found_vios = conf_vg, conf_vios
vopt_repo = pvm_stg.VMediaRepos.bld(
adapter, 'vopt', vopt_media_rep_size)
found_vg.vmedia_repos = [vopt_repo]
found_vg = found_vg.update()
# At this point, we know that we've successfully found or created the
# volume group. Save to the static variables.
global _cur_vg_uuid, _cur_vios_uuid
_cur_vg_uuid = found_vg.uuid
_cur_vios_uuid = found_vios.uuid
return _cur_vios_uuid, _cur_vg_uuid
def _find_vopt_repo_data(adapter, vopt_media_volume_group):
"""Finds the vopt repo defaults.
:param adapter: pypowervm adapter
:param vopt_media_volume_group: The name of the volume group to use.
:return found_vg: Returned if a volume group already exists with a media
repo within it. Is that corresponding volume group.
:return found_vios: Returned if a volume group already exists with a media
repo within it. This is the VIOS wrapper.
:return conf_vg: Returned if a volume group does not exist with a media
repo within it. This is the volume group wrapper (as
defined by the vopt_media_volume_group) that the consumer
code should create that media repo within.
:return conf_vios: Returned if a volume group does not exist with a media
repo within it. This is the VIOS wrapper that is the
parent of the conf_vg
"""
vios_wraps = partition.get_active_vioses(adapter)
# First loop through the VIOSes and their VGs to see if a media repos
# already exists.
found_vg, found_vios = None, None
# And in case we don't find the media repos, keep track of the VG on
# which we should create it.
conf_vg, conf_vios = None, None
for vio_wrap in vios_wraps:
vg_wraps = pvm_stg.VG.get(adapter, parent=vio_wrap)
for vg_wrap in vg_wraps:
if len(vg_wrap.vmedia_repos) != 0:
found_vg, found_vios = vg_wrap, vio_wrap
break
# In case no media repos exists, save a pointer to the
# CONFigured vopt_media_volume_group if we find it.
if (conf_vg is None and not vio_wrap.is_mgmt_partition and
vg_wrap.name == vopt_media_volume_group):
conf_vg, conf_vios = vg_wrap, vio_wrap
# If we found it, don't keep looking
if found_vg:
break
return found_vg, found_vios, conf_vg, conf_vios
|
