Synnefo » snf-ganeti

    assert self.op.instance_name in self.owned_locks(locking.LEVEL_INSTANCE)

    self.instance = self.cfg.GetInstanceInfo(self.op.instance_uuid)

    self.cluster = self.cfg.GetClusterInfo()

    assert self.instance is not None, \

      "Cannot retrieve locked instance %s" % self.op.instance_name

      # verify that the instance is not up

      instance_info = self.rpc.call_instance_info(

          pnode_uuid, self.instance.name, self.instance.hypervisor,

      if instance_info.fail_msg:

        self.warn.append("Can't get instance runtime information: %s" %

                         instance_info.fail_msg)

        mem_check_list.extend(self.instance.secondary_nodes)

      instance_info = self.rpc.call_instance_info(

          pnode_uuid, self.instance.name, self.instance.hypervisor,

      hvspecs = [(self.instance.hypervisor,

      nodeinfo = self.rpc.call_node_info(mem_check_list, None,

                                         hvspecs)

      pninfo = nodeinfo[pnode_uuid]

      remote_info = self.rpc.call_instance_info(

         self.instance.primary_node, self.instance.name,

         self.instance.hypervisor,

      remote_info.Raise("Error checking node %s" %

                        self.cfg.GetNodeName(self.instance.primary_node))

      if not remote_info.payload: # not running already