import time
import re
import cache_acls
+import cPickle
# ... and stolen from xend/uuid.py
def randomUUID():
kinits if necessary, and outputs errors to stderr.
"""
checkKinit()
- p = subprocess.Popen(['remctl', 'black-mesa.mit.edu']
+ p = subprocess.Popen(['remctl', 'remote.mit.edu']
+ list(args),
stdout=subprocess.PIPE,
stderr=subprocess.PIPE)
raise CodeError('"%s" on "control %s create %s'
% (err, machine.name, cdtype))
-def registerMachine(machine):
- """Register a machine to be controlled by the web interface"""
- remctl('web', 'register', machine.name)
-
-def unregisterMachine(machine):
- """Unregister a machine to not be controlled by the web interface"""
- remctl('web', 'unregister', machine.name)
-
def createVm(owner, contact, name, memory, disk_size, machine_type, cdrom, clone_from):
"""Create a VM and put it in the database"""
# put stuff in the table
machine.boot_off_cd = True
machine.type_id = machine_type.type_id
ctx.current.save(machine)
- disk = Disk(machine_id=machine.machine_id,
+ disk = Disk(machine_id=machine.machine_id,
guest_device_name='hda', size=disk_size)
open_nics = NIC.select_by(machine_id=None)
if not open_nics: #No IPs left!
nic = open_nics[0]
nic.machine_id = machine.machine_id
nic.hostname = name
- ctx.current.save(nic)
+ ctx.current.save(nic)
ctx.current.save(disk)
cache_acls.refreshMachine(machine)
transaction.commit()
except:
transaction.rollback()
raise
- registerMachine(machine)
makeDisks(machine)
if clone_from:
lvcopy(clone_from, machine, 'password')
bootMachine(machine, cdrom)
return machine
-def getUptimes(machines=None):
- """Return a dictionary mapping machine names to uptime strings"""
- value_string = remctl('web', 'listvms')
- lines = value_string.splitlines()
- d = {}
- for line in lines:
- lst = line.split()
- name, id = lst[:2]
- uptime = ' '.join(lst[2:])
- d[name] = uptime
- ans = {}
- for m in machines:
- ans[m] = d.get(m.name)
- return ans
+def getList(machines):
+ """Return a dictionary mapping machine to dicts."""
+ value_string = remctl('web', 'listvms', '--pickle')
+ value_dict = cPickle.loads(value_string)
+
+ d = dict((m, value_dict[m.name]) for m in machines if m.name in value_dict)
+ return d
def parseStatus(s):
"""Parse a status string into nested tuples of strings.
raise
for mname, dname in delete_disk_pairs:
remctl('web', 'lvremove', mname, dname)
- unregisterMachine(machine)
def commandResult(user, fields):
start_time = 0
for disk in machine.disks:
remctl("web", "lvrename", old_name,
disk.guest_device_name, new_name)
- remctl("web", "moveregister", old_name, new_name)