libvirt.VIR_DOMAIN_CRASHED: 'crashed',
}
-def randomMAC():
- mac = [ random.randint(0x00, 0xff),
- random.randint(0x00, 0xff),
- random.randint(0x00, 0xff),
- random.randint(0x00, 0xff),
- random.randint(0x00, 0xff),
- random.randint(0x00, 0xff) ]
- return ':'.join(map(lambda x: "%02x" % x, mac))
-
class Sliver_LV(accounts.Account):
"""This class wraps LibVirt commands"""
@staticmethod
def create(name, rec = None):
''' Create dirs, copy fs image, lxc_create '''
- print "LIBVIRT %s create"%(name)
logger.verbose ('sliver_libvirt: %s create'%(name))
dir = '/vservers/%s'%(name)
lxc_log = '%s/log'%(dir)
# TODO: copy the sliver FS to the correct path if sliver does not
- # exist. Update MAC addresses and insert an entry on the libvirt DHCP
- # server to get an actual known IP. Some sort of pool?
+ # exist.
if not (os.path.isdir(dir) and
os.access(dir, os.R_OK | os.W_OK | os.X_OK)):
logger.verbose('lxc_create: directory %s does not exist or wrong perms'%(dir))
return
- # TODO: set hostname
+ # Set hostname
file('/vservers/%s/rootfs/etc/hostname' % name, 'w').write(name)
-
+
+ # Add unix account
+ command = ['/usr/sbin/useradd', '-s', '/bin/sh', name]
+ logger.log_call(command, timeout=15*60)
+
# Get a connection and lookup for the sliver before actually
# defining it, just in case it was already defined.
conn = Sliver_LV.getConnection()
dom = conn.lookupByName(name)
except:
dom = conn.defineXML(config)
- print Sliver_LV.info(dom)
+ logger.verbose('lxc_create: %s -> %s'%(name, Sliver_LV.info(dom)))
@staticmethod
def destroy(name):
- ''' NEVER CALLED... Figure out when and what to do... '''
-
- print "LIBVIRT %s destroy"%(name)
logger.verbose ('sliver_libvirt: %s destroy'%(name))
dir = '/vservers/%s'%(name)
lxc_log = '%s/lxc.log'%(dir)
- conn = conn.Sliver_LV.getConnection()
+ conn = Sliver_LV.getConnection()
try:
+ command = ['/usr/sbin/userdel', name]
+ logger.log_call(command, timeout=15*60)
+
dom = conn.lookupByName(name)
- conn.destroy(dom)
- conn.undefine(dom)
- print Sliver_LV.info(dom)
+ dom.destroy()
+ dom.undefine()
except:
- logger.verbose('sliver_libvirt: %s domain does not exists'%(name))
- print "Unexpected error:", sys.exc_info()[0]
-
+ logger.verbose('sliver_libvirt: Unexpected error on %s: %s'%(name, sys.exc_info()[0]))
+
def __init__(self, rec):
self.name = rec['name']
- print "LIBVIRT %s __init__"%(self.name)
logger.verbose ('sliver_libvirt: %s init'%(self.name))
self.dir = '/vservers/%s'%(self.name)
try:
self.container = conn.lookupByName(self.name)
except:
+ logger.verbose('sliver_libvirt: Unexpected error on %s: %s'%(name, sys.exc_info()[0]))
print "Unexpected error:", sys.exc_info()[0]
def configure(self, rec):
''' Allocate resources and fancy configuration stuff '''
- print "LIBVIRT %s configure"%(self.name)
logger.verbose('sliver_libvirt: %s configure'%(self.name))
-
+ accounts.Account.configure(self, rec)
+
def start(self, delay=0):
''' Just start the sliver '''
print "LIBVIRT %s start"%(self.name)
logger.verbose('sliver_libvirt: sliver %s already started'%(self.name))
def stop(self):
- ''' NEVER CALLED... Figure out when and what to do... '''
-
- print "LIBVIRT %s stop"%(self.name)
logger.verbose('sliver_libvirt: %s stop'%(self.name))
try:
def is_running(self):
''' Return True if the domain is running '''
- print "LIBVIRT %s is_running"%(self.name)
logger.verbose('sliver_libvirt: %s is_running'%(self.name))
try:
[state, _, _, _, _] = self.container.info()