#
# Copyright 2015 Red Hat, Inc.
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 2 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program; if not, write to the Free Software
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
#
# Refer to the README and COPYING files for full details of the license
#
import os
import ovirtsdk.api
import lago
from ovirtsdk.infrastructure.errors import (RequestError, ConnectionError)
import constants
import testlib
[docs]class OvirtVirtEnv(lago.virt.VirtEnv):
def __init__(self, prefix, vm_specs, net_spec):
self._engine_vm = None
self._host_vms = []
super(OvirtVirtEnv, self).__init__(prefix, vm_specs, net_spec)
[docs] def _create_vm(self, vm_spec):
metadata = vm_spec.get('metadata', {})
role = metadata.get('ovirt-role', None)
if role == 'engine':
if self._engine_vm is not None:
raise RuntimeError('Engine VM already exists')
self._engine_vm = EngineVM(self, vm_spec)
return self._engine_vm
elif role == 'host':
self._host_vms.append(HostVM(self, vm_spec))
return self._host_vms[-1]
elif role == 'node':
self._host_vms.append(NodeVM(self, vm_spec))
return self._host_vms[-1]
else:
return lago.virt.VM(self, vm_spec)
[docs] def engine_vm(self):
return self._engine_vm
[docs] def host_vms(self):
return self._host_vms[:]
# TODO : solve the problem of ssh to the Node
[docs]class NodeVM(lago.virt.VM):
[docs] def _artifact_paths(self):
return []
[docs] def collect_artifacts(self, host_path):
return
[docs] def wait_for_ssh(self):
return
[docs]class EngineVM(lago.virt.VM):
def __init__(self, *args, **kwargs):
super(EngineVM, self).__init__(*args, **kwargs)
self._api = None
[docs] def stop(self):
super(EngineVM, self).stop()
self._api = None
[docs] def _artifact_paths(self):
inherited_artifacts = super(EngineVM, self)._artifact_paths()
return set(inherited_artifacts + ['/var/log/ovirt-engine', ])
[docs] def _create_api(self):
url = 'https://%s/ovirt-engine/api' % self.ip()
return ovirtsdk.api.API(
url=url,
username=constants.ENGINE_USER,
password=str(self.metadata['ovirt-engine-password']),
validate_cert_chain=False,
insecure=True,
)
[docs] def _get_api(self, wait):
if wait:
self.wait_for_ssh()
try:
testlib.assert_true_within_long(
lambda: self.service('ovirt-engine').alive()
)
api = []
testlib.assert_true_within_short(
lambda: api.append(self._create_api()) or True,
allowed_exceptions=[RequestError, ConnectionError],
)
except AssertionError:
raise RuntimeError('Failed to connect to the engine')
return api.pop()
[docs] def get_api(self, wait=True):
if self._api is None or not self._api.test():
self._api = self._get_api(wait)
return self._api
[docs] def add_iso(self, path):
iso_name = os.path.basename(path)
self.copy_to(path, '.')
ret = self.ssh(
[
'ovirt-iso-uploader',
'--conf-file=/root/iso-uploader.conf',
'--insecure',
iso_name,
]
)
if ret:
raise RuntimeError('Failed to upload iso to ovirt')
ret = self.ssh(['rm', iso_name])
if ret:
raise RuntimeError('Failed to remove uploaded image')
[docs] def engine_setup(self, config=None):
self.wait_for_ssh()
if config:
self.copy_to(config, 'engine-answer-file')
result = self.interactive_ssh(
[
'engine-setup',
] + (config and ['--config-append=engine-answer-file'] or []),
)
if result.code != 0:
raise RuntimeError('Failed to setup the engine')
[docs]class HostVM(lago.virt.VM):
[docs] def _artifact_paths(self):
inherited_artifacts = super(HostVM, self)._artifact_paths()
if self.distro() not in ['fc22', 'fc23']:
inherited_artifacts.append('/var/log/messages')
return set(inherited_artifacts + ['/var/log/vdsm', ])
