/ - Diff - snf-ganeti - Greek Research and Technology Network's projects

         _Fail("Failed to get migration status: %s", err, exc=True)
     def HotplugDevice(instance, action, dev_type, device, extra, seq):
       """Hotplug a device
       Hotplug is currently supported only for KVM Hypervisor.
       @type instance: L{objects.Instance}
       @param instance: the instance to which we hotplug a device
       @type action: string
       @param action: the hotplug action to perform
       @type dev_type: string
       @param dev_type: the device type to hotplug
       @type device: either L{objects.NIC} or L{objects.Disk}
       @param device: the device object to hotplug
       @type extra: string
       @param extra: extra info used by hotplug code (e.g. disk link)
       @type seq: int
       @param seq: the index of the device from master perspective
       @raise RPCFail: in case instance does not have KVM hypervisor
       """
       hyper = hypervisor.GetHypervisor(instance.hypervisor)
       try:
         hyper.HotplugSupported(instance, action, dev_type)
       except (errors.HotplugError, errors.HypervisorError), err:
         _Fail("Hotplug is not supported: %s", err)
       if action == constants.HOTPLUG_ACTION_ADD:
         fn = hyper.HotAddDevice
       elif action == constants.HOTPLUG_ACTION_REMOVE:
         fn = hyper.HotDelDevice
       elif action == constants.HOTPLUG_ACTION_MODIFY:
         fn = hyper.HotModDevice
       else:
         assert action in constants.HOTPLUG_ALL_ACTIONS
       return fn(instance, dev_type, device, extra, seq)
     def BlockdevCreate(disk, size, owner, on_primary, info, excl_stor):
       """Creates a block device for an instance.

           return "; ".join(msgs)
         else:
           return None
       def HotAddDevice(self, instance, dev_type, device, extra, seq):
         """Hot-add a device.
         """
         pass
       def HotDelDevice(self, instance, dev_type, device, extra, seq):
         """Hot-del a device.
         """
         pass
       def HotModDevice(self, instance, dev_type, device, extra, seq):
         """Hot-mod a device.
         """
         pass
       def HotplugSupported(self, instance, action, dev_type):
         """Whether hotplug is supported.
         Depends on instance's hvparam, the action. and the dev_type
         """
         raise NotImplementedError

         """
         raise HypervisorError("Migration not supported by the chroot hypervisor")
       def HotplugSupported(self, instance, action, dev_type):
         """Whether hotplug is supported.
         """
         raise HypervisorError("Hotplug not supported by the chroot hypervisor")

         """
         return objects.MigrationStatus(status=constants.HV_MIGRATION_COMPLETED)
       def HotplugSupported(self, instance, action, dev_type):
         """Whether hotplug is supported.
         """
         raise errors.HypervisorError("Hotplug not supported by the fake hypervisor")

         """
         raise HypervisorError("Migration is not supported by the LXC hypervisor")
       def HotplugSupported(self, instance, action, dev_type):
         """Whether hotplug is supported.
         """
         raise HypervisorError("Hotplug not supported by the LXC hypervisor")

             raise errors.HypervisorError("Cannot run xen ('%s'). Error: %s."
                                          % (constants.XEN_CMD_XL, result.stderr))
       def HotplugSupported(self, instance, action, dev_type):
         """Whether hotplug is supported.
         """
         raise errors.HypervisorError("Hotplug not supported by the xen hypervisor")
     class XenPvmHypervisor(XenHypervisor):
       """Xen PVM hypervisor interface"""

           rpc_defs.ED_INST_DICT_HVP_BEP_DP: self._InstDictHvpBepDp,
           rpc_defs.ED_INST_DICT_OSP_DP: self._InstDictOspDp,
           rpc_defs.ED_NIC_DICT: self._NicDict,
           rpc_defs.ED_DEVICE_DICT: self._DeviceDict,
           # Encoders annotating disk parameters
           rpc_defs.ED_DISKS_DICT_DP: self._DisksDictDP,
-...
             n.netinfo = objects.Network.ToDict(nobj)
         return n.ToDict()
       def _DeviceDict(self, _, device):
         if isinstance(device, objects.NIC):
           return self._NicDict(None, device)
         elif isinstance(device, objects.Disk):
           return _ObjectToDict(None, device)
       def _InstDict(self, node, instance, hvp=None, bep=None, osp=None):
         """Convert the given instance to a dict.

      ED_DISKS_DICT_DP,
      ED_MULTI_DISKS_DICT_DP,
      ED_SINGLE_DISK_DICT_DP,
      ED_NIC_DICT) = range(1, 16)
      ED_NIC_DICT,
      ED_DEVICE_DICT) = range(1, 17)
     def _Prepare(calls):
-...
         ("reinstall", None, None),
         ("debug", None, None),
         ], None, None, "Starts an instance"),
       ("hotplug_device", SINGLE, None, constants.RPC_TMO_NORMAL, [
         ("instance", ED_INST_DICT, "Instance object"),
         ("action", None, "Hotplug Action"),
         ("dev_type", None, "Device type"),
         ("device", ED_DEVICE_DICT, "Device dict"),
         ("extra", None, "Extra info for device (dev_path for disk)"),
         ("seq", None, "Device seq"),
         ], None, None, "Hoplug a device to a running instance"),
+      ]
     _IMPEXP_CALLS = [

         return backend.StartInstance(instance, startup_paused, trail)
       @staticmethod
       def perspective_hotplug_device(params):
         """Hotplugs device to a running instance.
         """
         (idict, action, dev_type, ddict, extra, seq) = params
         instance = objects.Instance.FromDict(idict)
         if dev_type == constants.HOTPLUG_TARGET_DISK:
           device = objects.Disk.FromDict(ddict)
         elif dev_type == constants.HOTPLUG_TARGET_NIC:
           device = objects.NIC.FromDict(ddict)
         else:
           assert dev_type in constants.HOTPLUG_ALL_TARGETS
         return backend.HotplugDevice(instance, action, dev_type, device, extra, seq)
       @staticmethod
       def perspective_migration_info(params):
         """Gather information about an instance to be migrated.

Synnefo » snf-ganeti

Revision c5708931