"""Xend root class.
Creates the event server and handles configuration.
+
+Other classes get config variables by importing this module,
+using instance() to get a XendRoot instance, and then
+the config functions (e.g. get_xend_port()) to get
+configured values.
"""
import os
"""Where block control scripts live."""
block_script_dir = "/etc/xen/scripts"
+ """Default path to the log file. """
logfile_default = "/var/log/xend.log"
loglevel_default = 'DEBUG'
+ """Default interface address xend listens at. """
+ xend_address_default = ''
+
+ """Default port xend serves HTTP at. """
+ xend_port_default = '8000'
+
+ """Default port xend serves events at. """
+ xend_event_port_default = '8001'
+
+ """Default inteface address xend listens at for consoles."""
+ console_address_default = ''
+
+ """Default port xend serves consoles at. """
+ console_port_base_default = '9600'
+
components = {}
def __init__(self):
self.dbroot = None
self.config_path = None
self.config = None
- self.logger = None
+ self.logging = None
self.configure()
eserver.subscribe('xend.*', self.event_handler)
#eserver.subscribe('xend.domain.created', self.event_handler)
def _format(self, msg, args):
if args:
- return str(msg)
- else:
return str(msg) % args
+ else:
+ return str(msg)
def _log(self, mode, fmt, args):
"""Logging function that uses the logger if it exists, otherwise
if log:
getattr(log, mode)(fmt, *args)
else:
- print >>stderr, "xend", "[%s]" % level, self._format(msg, args)
+ print >>sys.stderr, "xend", "[%s]" % level, self._format(fmt, args)
def logDebug(self, fmt, *args):
"""Log a debug message.
self.configure_logger()
self.dbroot = self.get_config_value("dbroot", self.dbroot_default)
-
def configure_logger(self):
logfile = self.get_config_value("logfile", self.logfile_default)
loglevel = self.get_config_value("loglevel", self.loglevel_default)
def get_logger(self):
"""Get the logger.
"""
- return self.logging.getLogger()
+ return self.logging and self.logging.getLogger()
def get_dbroot(self):
"""Get the path to the database root.
"""
self.config_path = os.getenv(self.config_var, self.config_default)
if os.path.exists(self.config_path):
- fin = file(self.config_path, 'rb')
+ #self.logInfo('Reading config file %s', self.config_path)
try:
- config = sxp.parse(fin)
+ fin = file(self.config_path, 'rb')
+ try:
+ config = sxp.parse(fin)
+ finally:
+ fin.close()
config.insert(0, 'xend-config')
self.config = config
- finally:
- fin.close()
+ except Exception, ex:
+ self.logError('Reading config file %s: %s', self.config_path, str(ex))
+ raise
else:
+ self.logError('Config file does not exist: %s', self.config_path)
self.config = ['xend-config']
def get_config(self, name=None):
return sxp.child_value(self.config, name, val=val)
def get_xend_port(self):
- return int(self.get_config_value('xend-port', '8000'))
+ """Get the port xend listens at for its HTTP interface.
+ """
+ return int(self.get_config_value('xend-port', self.xend_port_default))
+
+ def get_xend_event_port(self):
+ """Get the port xend listens at for connection to its event server.
+ """
+ return int(self.get_config_value('xend-event-port', self.xend_event_port_default))
def get_xend_address(self):
- return self.get_config_value('xend-address', '')
+ """Get the address xend listens at for its HTTP and event ports.
+ This defaults to the empty string which allows all hosts to connect.
+ If this is set to 'localhost' only the localhost will be able to connect
+ to the HTTP and event ports.
+ """
+ return self.get_config_value('xend-address', self.xend_address_default)
+
+ def get_console_address(self):
+ """Get the address xend listens at for its console ports.
+ This defaults to the empty string which allows all hosts to connect.
+ If this is set to 'localhost' only the localhost will be able to connect
+ to the console ports.
+ """
+ return self.get_config_value('console-address', self.console_address_default)
+
+ def get_console_port_base(self):
+ """Get the base port number used to generate console ports for domains.
+ """
+ return int(self.get_config_value('console-port-base', self.console_port_base_default))
def get_block_script(self, type):
return self.get_config_value('block-%s' % type, '')
def set_user(self):
# Set the UID.
try:
- os.setuid(pwd.getpwnam(USER)[2])
+ os.setuid(pwd.getpwnam(XEND_USER)[2])
return 0
except KeyError, error:
- print "Error: no such user '%s'" % USER
+ print "Error: no such user '%s'" % XEND_USER
return 1
def stop(self):
xroot = XendRoot.instance()
log.info("Xend Daemon started")
self.createFactories()
- self.listenEvent()
+ self.listenEvent(xroot)
self.listenNotifier()
self.listenVirq()
SrvServer.create(bridge=1)
self.netifCF = netif.NetifControllerFactory()
self.consoleCF = console.ConsoleControllerFactory()
- def listenEvent(self):
+ def listenEvent(self, xroot):
protocol = EventFactory(self)
- return reactor.listenTCP(EVENT_PORT, protocol)
+ port = xroot.get_xend_event_port()
+ interface = xroot.get_xend_address()
+ return reactor.listenTCP(port, protocol, interface=interface)
def listenNotifier(self):
protocol = NotifierProtocol(self.channelF)
projects / xen.git / commitdiff