Merge pull request #40 from cloudify-incubator/0.9.5-build

0.9.5-build

Author: EarthmanT

CHANGELOG.txt

@@ -33,4 +33,5 @@
 0.9.1.1: Testing webhook for Marketplace scraping
 0.9.2: Rerelease for build system.
 0.9.3: Rerelease with rhel8.
-0.9.4: Add Passthrough Devices support.
+0.9.4: Add Passthrough Devices support.
+0.9.5: manylinux and dsl 1.5

cloudify_libvirt/__version__.py

@@ -1 +1 @@
-version = '0.9.4'
+version = '0.9.5'

cloudify_libvirt/domain_tasks.py

@@ -805,3 +805,114 @@ def perfomance(**kwargs):
         ctx.logger.info("Statistics: {}".format(repr(statistics)))
     finally:
         conn.close()
+
+
+@operation
+def update_domain_flags(**kwargs):
+    ctx.logger.info("Update domain")
+
+    libvirt_auth, template_params = common.get_libvirt_params(**kwargs)
+    resource_id = ctx.instance.runtime_properties.get('resource_id')
+
+    if not resource_id:
+        # not uninstall workflow, raise exception
+        raise cfy_exc.NonRecoverableError("No servers for update")
+
+    libvirt_auth, _ = common.get_libvirt_params(**kwargs)
+    conn = libvirt.open(libvirt_auth)
+    if conn is None:
+        raise cfy_exc.NonRecoverableError(
+            'Failed to open connection to the hypervisor'
+        )
+
+    try:
+        try:
+            dom = conn.lookupByName(resource_id)
+        except libvirt.libvirtError as e:
+            raise cfy_exc.NonRecoverableError(
+                'Failed to find the domain: {}'.format(repr(e))
+            )
+
+        state, _ = dom.state()
+        if state == libvirt.VIR_DOMAIN_RUNNING:
+            ctx.logger.info("Looks as running. Stop before updating")
+            return
+        xmlconfig = common.gen_xml_template(kwargs, template_params, 'domain')
+        dom.updateDeviceFlags(xmlconfig)
+        ctx.logger.info('Domain {0} updated.'.format(resource_id))
+    finally:
+        conn.close()
+
+
+@operation
+def detach_device_flags(**kwargs):
+    ctx.logger.info("Update domain")
+
+    libvirt_auth, template_params = common.get_libvirt_params(**kwargs)
+    resource_id = ctx.instance.runtime_properties.get('resource_id')
+
+    if not resource_id:
+        # not uninstall workflow, raise exception
+        raise cfy_exc.NonRecoverableError("No servers for update")
+
+    libvirt_auth, _ = common.get_libvirt_params(**kwargs)
+    conn = libvirt.open(libvirt_auth)
+    if conn is None:
+        raise cfy_exc.NonRecoverableError(
+            'Failed to open connection to the hypervisor'
+        )
+
+    try:
+        try:
+            dom = conn.lookupByName(resource_id)
+        except libvirt.libvirtError as e:
+            raise cfy_exc.NonRecoverableError(
+                'Failed to find the domain: {}'.format(repr(e))
+            )
+
+        state, _ = dom.state()
+        if state == libvirt.VIR_DOMAIN_RUNNING:
+            ctx.logger.info("Looks as running. Stop before updating")
+            return
+        xmlconfig = common.gen_xml_template(kwargs, template_params, 'domain')
+        dom.detachDeviceFlags(xmlconfig)
+        ctx.logger.info('Domain {0} updated.'.format(resource_id))
+    finally:
+        conn.close()
+
+
+@operation
+def attach_device_flags(**kwargs):
+    ctx.logger.info("Update domain")
+
+    libvirt_auth, template_params = common.get_libvirt_params(**kwargs)
+    resource_id = ctx.instance.runtime_properties.get('resource_id')
+
+    if not resource_id:
+        # not uninstall workflow, raise exception
+        raise cfy_exc.NonRecoverableError("No servers for update")
+
+    libvirt_auth, _ = common.get_libvirt_params(**kwargs)
+    conn = libvirt.open(libvirt_auth)
+    if conn is None:
+        raise cfy_exc.NonRecoverableError(
+            'Failed to open connection to the hypervisor'
+        )
+
+    try:
+        try:
+            dom = conn.lookupByName(resource_id)
+        except libvirt.libvirtError as e:
+            raise cfy_exc.NonRecoverableError(
+                'Failed to find the domain: {}'.format(repr(e))
+            )
+
+        state, _ = dom.state()
+        if state == libvirt.VIR_DOMAIN_RUNNING:
+            ctx.logger.info("Looks as running. Stop before updating")
+            return
+        xmlconfig = common.gen_xml_template(kwargs, template_params, 'domain')
+        dom.attachDeviceFlags(xmlconfig)
+        ctx.logger.info('Domain {0} updated.'.format(resource_id))
+    finally:
+        conn.close()

extra-packaging-instructions.sh

@@ -0,0 +1,15 @@
+if [[ $PY311 == 1 ]]
+then
+    mkdir -p ./pydoc
+    touch ./pydoc/__init__.py
+    cat <<EOF > ./pydoc/__init__.py
+def get_doc(*args):
+    return ''
+EOF
+    mkdir -p ./webbrowser
+    touch ./webbrowser/__init__.py
+    cat <<EOF > ./webbrowser/__init__.py
+EOF
+    git apply python311.patch
+    echo patch applied
+fi

plugin.yaml

@@ -2,7 +2,7 @@ plugins:
   libvirt:
     executor: central_deployment_agent
     package_name: cloudify-libvirt-plugin
-    package_version: '0.9.4'
+    package_version: '0.9.5'
 
 data_types:
 

plugin_1_4.yaml

@@ -2,7 +2,7 @@ plugins:
   libvirt:
     executor: central_deployment_agent
     package_name: cloudify-libvirt-plugin
-    package_version: '0.9.4'
+    package_version: '0.9.5'
 
 blueprint_labels:
   obj-type: