import logger
import subprocess
import os
+import os.path
import libvirt
import sys
+import shutil
+
+from string import Template
states = {
libvirt.VIR_DOMAIN_NOSTATE: 'no state',
libvirt.VIR_DOMAIN_CRASHED: 'crashed',
}
+REF_IMG_BASE_DIR = '/vservers/.lvref'
+CON_BASE_DIR = '/vservers'
+
class Sliver_LV(accounts.Account):
"""This class wraps LibVirt commands"""
SHELL = '/bin/sh'
- # Using /bin/bash triggers destroy root/site_admin (?!?)
- TYPE = 'sliver.LIBVIRT'
+
# Need to add a tag at myplc to actually use this account
# type = 'sliver.LIBVIRT'
-
- 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)
-
- # Assume the directory with the image and config files
- # are in place
-
- self.config = '%s/config.xml'%(self.dir)
- self.lxc_log = '%s/log'%(self.dir)
- self.keys = ''
- self.rspec = {}
- self.slice_id = rec['slice_id']
- self.disk_usage_initialized = False
- self.initscript = ''
- self.enabled = True
- conn = Sliver_LV.getConnection()
- try:
- self.container = conn.lookupByName(self.name)
- except:
- print "Unexpected error:", sys.exc_info()[0]
+ TYPE = 'sliver.LIBVIRT'
+
@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)
- config = '%s/config.xml'%(dir)
- lxc_log = '%s/log'%(dir)
+
+ # Template for libvirt sliver configuration
+ try:
+ with open('/vservers/.lvref/config_template.xml') as f:
+ template = Template(f.read())
+ config = template.substitute(name=name)
+ except IOError:
+ logger.log('Cannot find XML template file')
+ return
- 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))
+ # Get the type of image from vref myplc tags specified as:
+ # pldistro = lxc
+ # fcdistro = squeeze
+ # arch x86_64
+ vref = rec['vref']
+ if vref is None:
+ logger.log('sliver_libvirt: %s: WARNING - no vref attached defaults to lxc-debian' % (name))
+ vref = "lxc-squeeze-x86_64"
+
+ refImgDir = os.path.join(REF_IMG_BASE_DIR, vref)
+ containerDir = os.path.join(CON_BASE_DIR, name)
+
+ # check the template exists -- there's probably a better way..
+ if not os.path.isdir(refImgDir):
+ logger.log('sliver_libvirt: %s: ERROR Could not create sliver - reference image %s not found' % (name,vref))
return
-
+
+ # Copy the reference image fs
+ # shutil.copytree("/vservers/.lvref/%s"%vref, "/vservers/%s"%name, symlinks=True)
+ command = ['cp', '-r', refImgDir, containerDir]
+ logger.log_call(command, timeout=15*60)
+
+ # Set hostname. A valid hostname cannot have '_'
+ with open(os.path.join(containerDir, 'etc/hostname'), 'w') as f:
+ print >>f, name.replace('_', '-')
+
+ # Add slices group if not already present
+ command = ['/usr/sbin/groupadd slices']
+ logger.log_call(command, timeout=15*60)
+
+ # Add unix account
+ command = ['/usr/sbin/useradd', '-g', 'slices', '-s', '/bin/sh', name, '-p', '*']
+ 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()
try:
dom = conn.lookupByName(name)
except:
- xml = open(config).read()
- dom = conn.defineXML(xml)
- print Sliver_LV.info(dom)
+ dom = conn.defineXML(config)
+ 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', '-r', name]
+ logger.log_call(command, timeout=15*60)
+
+ # Destroy libvirt domain
dom = conn.lookupByName(name)
- conn.destroy(dom)
- conn.undefine(dom)
- print Sliver_LV.info(dom)
- except:
- logger.verbose('sliver_libvirt: %s domain does not exists'%(name))
- print "Unexpected error:", sys.exc_info()[0]
+ dom.destroy()
+ dom.undefine()
+ # Remove rootfs of destroyed domain
+ shutil.rmtree("/vservers/%s"%name)
+ except:
+ logger.verbose('sliver_libvirt: Unexpected error on %s: %s'%(name, sys.exc_info()[0]))
+
+ def __init__(self, rec):
+ self.name = rec['name']
+ logger.verbose ('sliver_libvirt: %s init'%(self.name))
+
+ self.dir = '/vservers/%s'%(self.name)
+
+ # Assume the directory with the image and config files
+ # are in place
+
+ self.keys = ''
+ self.rspec = {}
+ self.slice_id = rec['slice_id']
+ self.disk_usage_initialized = False
+ self.initscript = ''
+ self.enabled = True
+ conn = Sliver_LV.getConnection()
+ try:
+ self.container = conn.lookupByName(self.name)
+ except:
+ logger.verbose('sliver_libvirt: Unexpected error on %s: %s'%(self.name, 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)
- if self.rspec['enabled'] <= 0:
- logger.log('sliver_libvirt: not starting %s, is not enabled'%(self.name))
- return
- else:
- logger.log('sliver_libvirt: %s starting...' % (self.name))
# Check if it's running to avoid throwing an exception if the
# domain was already running, create actually means start
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()
git://git.onelab.eu / nodemanager.git / blobdiff