ganeti_web/backend/templates.py

   1 # Copyright (C) 2012 Oregon State University et al.
   2 #
   3 # This program is free software; you can redistribute it and/or
   4 # modify it under the terms of the GNU General Public License
   5 # as published by the Free Software Foundation; either version 2
   6 # of the License, or (at your option) any later version.
   7 #
   8 # This program is distributed in the hope that it will be useful,
   9 # but WITHOUT ANY WARRANTY; without even the implied warranty of
  10 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11 # GNU General Public License for more details.
  12 #
  13 # You should have received a copy of the GNU General Public License
  14 # along with this program; if not, write to the Free Software
  15 # Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301,
  16 # USA.
  17
  18 """
  19 Relatively pure functions for instantiating virtual machines from templates
  20 and vice versa.
  21
  22 These only depend on Django's ORM and not on any of the view or form
  23 machinery.
  24 """
  25
  26 from object_log.models import LogItem
  27
  28 from ganeti_web.caps import has_balloonmem
  29 from ganeti_web.models import Job, VirtualMachine, VirtualMachineTemplate
  30
  31 log_action = LogItem.objects.log_action
  32
  33
  34 def instance_to_template(vm, name):
  35     """
  36     Create, save, and return a VM template representing all of the information
  37     in the VM instance.
  38
  39     The name is given to the template to distinguish it from other templates.
  40     """
  41
  42     template = VirtualMachineTemplate()
  43
  44     # Basic stuff first.
  45     template.template_name = name
  46     template.description = ""
  47     template.cluster = vm.cluster
  48     template.start = vm.info["admin_state"]
  49     template.disk_template = vm.info["disk_template"]
  50     template.os = vm.operating_system
  51
  52     # Backend parameters.
  53     template.vcpus = vm.virtual_cpus
  54     template.memory = vm.ram
  55     if has_balloonmem(vm.cluster):
  56         template.minmem = vm.minram
  57     template.disks = [{"size": size} for size in vm.info["disk.sizes"]]
  58     template.disk_type = vm.info["hvparams"]["disk_type"]
  59     template.nics = [{"mode": mode, "link": link}
  60                      for mode, link in zip(vm.info["nic.modes"],
  61                                            vm.info["nic.links"])]
  62     template.nic_type = vm.info["hvparams"]["nic_type"]
  63
  64     # Hypervisor parameters.
  65     template.kernel_path = vm.info["hvparams"]["kernel_path"]
  66     template.root_path = vm.info["hvparams"]["root_path"]
  67     template.serial_console = vm.info["hvparams"]["serial_console"]
  68     template.boot_order = vm.info["hvparams"]["boot_order"]
  69     template.cdrom_image_path = vm.info["hvparams"]["cdrom_image_path"]
  70     template.cdrom2_image_path = vm.info["hvparams"]["cdrom2_image_path"]
  71
  72     template.save()
  73
  74     return template
  75
  76
  77 def template_to_instance(template, hostname, owner):
  78     """
  79     Instantiate a VM template with a given hostname and owner.
  80     """
  81
  82     cluster = template.cluster
  83     beparams = {
  84         "vcpus": template.vcpus,
  85     }
  86     memory = template.memory
  87     if has_balloonmem(cluster):
  88         minram = template.minmem
  89         beparams['minmem'] = minram
  90         beparams['maxmem'] = memory
  91     else:
  92         beparams['memory'] = memory
  93
  94     vcpus = template.vcpus
  95     disk_size = template.disks[0]["size"]
  96
  97     kwargs = {
  98         "os": template.os,
  99         "ip_check": template.ip_check,
 100         "name_check": template.name_check,
 101         "pnode": template.pnode,
 102         "beparams": beparams,
 103     }
 104
 105     job_id = cluster.rapi.CreateInstance('create', hostname,
 106                                          template.disk_template,
 107                                          template.disks, template.nics,
 108                                          **kwargs)
 109     vm = VirtualMachine()
 110
 111     vm.cluster = cluster
 112     vm.hostname = hostname
 113     vm.ram = memory
 114     if has_balloonmem(cluster):
 115         vm.minram = minram
 116     vm.virtual_cpus = vcpus
 117     vm.disk_size = disk_size
 118
 119     vm.owner = owner
 120     vm.ignore_cache = True
 121
 122     # Do a dance to get the VM and the job referencing each other.
 123     vm.save()
 124     job = Job.objects.create(job_id=job_id, obj=vm, cluster=cluster)
 125     job.save()
 126     vm.last_job = job
 127     vm.save()
 128
 129     # Grant admin permissions to the owner.
 130     owner.permissable.grant('admin', vm)
 131
 132     return vm