#!/usr/bin/env python
+# Copyright (C) 2002 Cluster File Systems, Inc.
+# Author: Robert Read <rread@clusterfs.com>
-import sys, getopt
-import xml.dom.minidom
-
+# This file is part of Lustre, http://www.lustre.org.
+#
+# Lustre is free software; you can redistribute it and/or
+# modify it under the terms of version 2 of the GNU General Public
+# License as published by the Free Software Foundation.
#
-# Example of walking the tree
+# Lustre is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+# GNU General Public License for more details.
#
-def handleLustre(lustre):
- handleHost(lustre.getElementsByTagName("node"))
+# You should have received a copy of the GNU General Public License
+# along with Lustre; if not, write to the Free Software
+# Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+#
+
+"""
+lmc - lustre configuration data manager
+
+ See Lustre book (http://www.lustre.org/docs/lustre.pdf) for documentation on lmc.
+
+"""
+
+import sys, os, getopt, string, exceptions, random
+import xml.dom.minidom
+from xml.dom.ext import PrettyPrint
+
+PYMOD_DIR = "/usr/lib/lustre/python"
+
+def development_mode():
+ base = os.path.dirname(sys.argv[0])
+ if os.access(base+"/Makefile.am", os.R_OK):
+ return 1
+ return 0
+
+if not development_mode():
+ sys.path.append(PYMOD_DIR)
+
+import Lustre
+
+DEFAULT_PORT = 988
+
+def reference():
+ print """usage: lmc --add object [object parameters]
+
+Object creation command summary:
+
+--add node
+ --node node_name
+ --timeout num
+ --upcall path
+ --lustre_upcall path
+ --portals_upcall path
+ --ptldebug debug_level
+ --subsystem subsystem_name
+
+--add net
+ --node node_name
+ --nid nid
+ --cluster_id
+ --nettype tcp|elan|gm|scimac
+ --hostaddr addr
+ --port port
+ --tcpbuf size
+ --irq_affinity 0|1
+ --router
+
+--add mds
+ --node node_name
+ --mds mds_name
+ --dev path
+ --fstype extN|ext3
+ --size size
+ --nspath
+ --journal_size size
+
+--add lov
+ --lov lov_name
+ --mds mds_name
+ --stripe_sz num
+ --stripe_cnt num
+ --stripe_pattern num
+
+--add ost
+ --node node_name
+ --ost ost_name
+ --lov lov_name
+ --dev path
+ --size size
+ --fstype extN|ext3
+ --journal_size size
+ --obdtype obdecho|obdfilter
+ --ostuuid uuid
+
+--add mtpt - Mountpoint
+ --node node_name
+ --path /mnt/point
+ --mds mds_name
+ --ost ost_name OR --lov lov_name
-def handleHost(hosts):
- for host in hosts:
- name = host.getAttribute("name")
- uuid = host.getAttribute("uuid")
+--add route
+ --node nodename
+ --gw nid
+ --tgt nid
+ --lo nid
+ --hi nid
+--add echo_client
+ --node nodename
+
+--add mgmt - Management/monitoring service
+ --node node_name
+ --mgmt mgmt_service_name
+"""
+
+PARAM = Lustre.Options.PARAM
+lmc_options = [
+ # lmc input/output options
+ ('reference', "Print short reference for commands."),
+ ('verbose,v', "Print system commands as they are run."),
+ ('merge,m', "Append to the specified config file.", PARAM),
+ ('output,o', "Write XML configuration into given output file. Overwrite existing content.", PARAM),
+ ('input,i', "", PARAM),
+ ('batch', "Used to execute lmc commands in batch mode.", PARAM),
+
+ # commands
+ ('add', "", PARAM),
+
+ # node options
+ ('node', "Add a new node in the cluster configuration.", PARAM),
+ ('timeout', "Set timeout to initiate recovery.", PARAM),
+ ('upcall', "Set both lustre and portals upcall scripts.", PARAM),
+ ('lustre_upcall', "Set location of lustre upcall script.", PARAM),
+ ('portals_upcall', "Set location of portals upcall script.", PARAM),
+ ('ptldebug', "Set the portals debug level", PARAM),
+ ('subsystem', "Specify which Lustre subsystems have debug output recorded in the log", PARAM),
+
+ # network
+ ('nettype', "Specify the network type. This can be tcp/elan/gm/scimac.", PARAM),
+ ('nid', "Give the network ID, e.g ElanID/IP Address as used by portals.", PARAM),
+ ('tcpbuf', "Optional argument to specify the TCP buffer size.", PARAM, "0"),
+ ('port', "Optional argument to specify the TCP port number.", PARAM, DEFAULT_PORT),
+ ('irq_affinity', "Optional argument.", PARAM, 0),
+ ('hostaddr', "", PARAM,""),
+ ('cluster_id', "Specify the cluster ID", PARAM, "0"),
+
+ # routes
+ ('route', "Add a new route for the cluster.", PARAM),
+ ('router', "Optional flag to mark a node as router."),
+ ('gw', "Specify the nid of the gateway for a route.", PARAM),
+ ('gateway_cluster_id', "", PARAM, "0"),
+ ('target_cluster_id', "", PARAM, "0"),
+ ('lo', "For a range route, this is the low value nid.", PARAM),
+ ('hi', "For a range route, this is a hi value nid.", PARAM,""),
+
+ # servers: mds and ost
+ ('mds', "Specify MDS name.", PARAM),
+ ('ost', "Specify the OST name.", PARAM,""),
+ ('osdtype', "This could obdfilter or obdecho.", PARAM, "obdfilter"),
+ ('failover', "Enable failover support on OSTs or MDS?"),
+ ('group', "", PARAM),
+ ('dev', "Path of the device on local system.", PARAM,""),
+ ('size', "Specify the size of the device if needed.", PARAM,"0"),
+ ('journal_size', "Specify new journal size for underlying ext3 file system.", PARAM,"0"),
+ ('fstype', "Optional argument to specify the filesystem type.", PARAM, "ext3"),
+ ('mkfsoptions', "Optional argument to mkfs.", PARAM, ""),
+ ('ostuuid', "", PARAM,""),
+ ('nspath', "Local mount point of server namespace.", PARAM,""),
+ ('format', ""),
+
+ # clients: mountpoint and echo
+ ('echo_client', "", PARAM),
+ ('path', "Specify the mountpoint for Lustre.", PARAM),
+ ('filesystem', "Lustre filesystem name", PARAM,""),
+
+ # lov
+ ('lov', "Specify LOV name.", PARAM,""),
+ ('stripe_sz', "Specify the stripe size in bytes.", PARAM),
+ ('stripe_cnt', "Specify the number of OSTs each file should be striped on.", PARAM, 0),
+ ('stripe_pattern', "Specify the stripe pattern. RAID 0 is the only one currently supported.", PARAM, 0),
+
+ # cobd
+ ('real_obd', "", PARAM),
+ ('cache_obd', "", PARAM),
+
+ ('mgmt', "Specify management/monitoring service name.", PARAM, ""),
+ ]
+
+def error(*args):
+ msg = string.join(map(str,args))
+ raise OptionError("Error: " + msg)
+
+def panic(cmd, msg):
+ print "! " + cmd
+ print msg
+ sys.exit(1)
+
+
+def warning(*args):
+ msg = string.join(map(str,args))
+ print "Warning: ", msg
+
#
# manage names and uuids
# need to initialize this by walking tree to ensure
# no duplicate names or uuids are created.
# this are just place holders for now.
-name_ctr = 1
+# consider changing this to be like OBD-dev-host
def new_name(base):
- global name_ctr
- name = "%s_%d" % (base, name_ctr)
- name_ctr += 1
- return name
+ ctr = 2
+ ret = base
+ while names.has_key(ret):
+ ret = "%s_%d" % (base, ctr)
+ ctr = 1 + ctr
+ names[ret] = 1
+ return ret
-def get_uuid(name):
- return "%s_UUID" % (name)
+def new_uuid(name):
+ ret_uuid = '%05x_%.19s_%05x%05x' % (int(random.random() * 1048576),
+ name,
+ int(random.random() * 1048576),
+ int(random.random() * 1048576))
+ return ret_uuid[:36]
-#
-# Create a new empty lustre document
-def new_Lustre():
- str = """<lustre>
-</lustre>"""
- dom = xml.dom.minidom.parseString(str)
- return dom
+ldlm_name = 'ldlm'
+ldlm_uuid = 'ldlm_UUID'
+def new_lustre(dom):
+ """Create a new empty lustre document"""
+ # adding ldlm here is a bit of a hack, but one is enough.
+ str = """<lustre version="%s">
+ <ldlm name="%s" uuid="%s"/>
+ </lustre>""" % (Lustre.CONFIG_VERSION, ldlm_name, ldlm_uuid)
+ return dom.parseString(str)
+
+names = {}
+uuids = {}
+
+def init_names(doc):
+ """initialize auto-name generation tables"""
+ global names, uuids
+ # get all elements that contain a name attribute
+ for n in doc.childNodes:
+ if n.nodeType == n.ELEMENT_NODE:
+ if getName(n):
+ names[getName(n)] = 1
+ uuids[getUUID(n)] = 1
+ init_names(n)
+
+def get_format_flag(options):
+ if options.format:
+ return 'yes'
+ return 'no'
+
+############################################################
+# Build config objects using DOM
#
-# Create a new object the "correct" way by using the DOM api.
-#
-def new_OBD(dom, name, fs, devname, format, dev_size=0, dev_file=""):
- uuid = get_uuid(name)
+class GenConfig:
+ doc = None
+ dom = None
+ def __init__(self, doc):
+ self.doc = doc
+
+ def ref(self, type, uuid):
+ """ generate <[type]_ref uuidref="[uuid]"/> """
+ tag = "%s_ref" % (type)
+ ref = self.doc.createElement(tag)
+ ref.setAttribute("uuidref", uuid)
+ return ref
- obd = dom.createElement("obd")
- obd.setAttribute("name", name)
- obd.setAttribute("uuid", uuid)
-
- fstype = dom.createElement("fstype")
- txt= dom.createTextNode(fs)
- fstype.appendChild(txt)
- obd.appendChild(fstype)
+ def newService(self, tag, name, uuid):
+ """ create a new service elmement, which requires name and uuid attributes """
+ new = self.doc.createElement(tag)
+ new.setAttribute("uuid", uuid);
+ new.setAttribute("name", name);
+ return new
- dev = dom.createElement("device")
- if (dev_size):
- dev.setAttribute("size", "%s" % (dev_size))
- txt = dom.createTextNode(devname)
- dev.appendChild(txt)
- obd.appendChild(dev)
+ def addText(self, node, str):
+ txt = self.doc.createTextNode(str)
+ node.appendChild(txt)
- fmt = dom.createElement("autoformat")
- txt = dom.createTextNode(format)
- fmt.appendChild(txt)
- obd.appendChild(fmt)
+ def addElement(self, node, tag, str=None):
+ """ create a new element and add it as a child to node. If str is passed,
+ a text node is created for the new element"""
+ new = self.doc.createElement(tag)
+ if str:
+ self.addText(new, str)
+ node.appendChild(new)
+ return new
- return obd
+ def network(self, name, uuid, nid, cluster_id, net, hostaddr="",
+ port=0, tcpbuf=0, irq_aff=0):
+ """create <network> node"""
+ network = self.newService("network", name, uuid)
+ network.setAttribute("nettype", net);
+ self.addElement(network, "nid", nid)
+ self.addElement(network, "clusterid", cluster_id)
+ if hostaddr:
+ self.addElement(network, "hostaddr", hostaddr)
+ if port:
+ self.addElement(network, "port", "%d" %(port))
+ if tcpbuf:
+ self.addElement(network, "sendmem", "%d" %(tcpbuf))
+ self.addElement(network, "recvmem", "%d" %(tcpbuf))
+ if irq_aff:
+ self.addElement(network, "irqaffinity", "%d" %(irq_aff))
+
+ return network
-#
-# Create new object the fast and easy way
-# (note: dom is not needed for this way)
-def new_OSC(dom, osc, obd):
- osc_uuid = get_uuid(osc)
- obd_uuid = get_uuid(obd)
-
- osc_str ="""
-<osc name="%s" uuid="%s">
- <service_id num="1" name="%s" uuid="%s"/>
-</osc> """ % (osc, osc_uuid, obd, obd_uuid)
- osc = xml.dom.minidom.parseString(osc_str)
- return osc.getElementsByTagName("osc")[0]
+ def routetbl(self, name, uuid):
+ """create <routetbl> node"""
+ rtbl = self.newService("routetbl", name, uuid)
+ return rtbl
+
+ def route(self, gw_net_type, gw, gw_cluster_id, tgt_cluster_id, lo, hi):
+ """ create one entry for the route table """
+ ref = self.doc.createElement('route')
+ ref.setAttribute("type", gw_net_type)
+ ref.setAttribute("gw", gw)
+ ref.setAttribute("gwclusterid", gw_cluster_id)
+ ref.setAttribute("tgtclusterid", tgt_cluster_id)
+ ref.setAttribute("lo", lo)
+ if hi:
+ ref.setAttribute("hi", hi)
+ return ref
+
+ def profile(self, name, uuid):
+ """ create a host """
+ profile = self.newService("profile", name, uuid)
+ return profile
-#
-# Create new object the fast and easy way
-#
-def new_OST(dom, ost, host, port, obd):
- ost_uuid = get_uuid(ost)
- obd_uuid = get_uuid(obd)
-
- str ="""
-<ost name="%s" uuid="%s">
- <network type="tcp">
- <server>%s</server>
- <port>%d</port>
- </network>
- <server_id num="1" name="%s" uuid="%s"/>
-</ost> """ % (ost, ost_uuid, host, port, obd, obd_uuid)
- node = xml.dom.minidom.parseString(str)
- return node.getElementsByTagName("ost")[0]
+ def node(self, name, uuid, prof_uuid):
+ """ create a host """
+ node = self.newService("node", name, uuid)
+ node.appendChild(self.ref("profile", prof_uuid))
+ return node
+ def ldlm(self, name, uuid):
+ """ create a ldlm """
+ ldlm = self.newService("ldlm", name, uuid)
+ return ldlm
+
+ def osd(self, name, uuid, fs, osdtype, devname, format, ost_uuid,
+ node_uuid, dev_size=0, journal_size=0, nspath=""):
+ osd = self.newService("osd", name, uuid)
+ osd.setAttribute('osdtype', osdtype)
+ osd.appendChild(self.ref("target", ost_uuid))
+ osd.appendChild(self.ref("node", node_uuid))
+ if fs:
+ self.addElement(osd, "fstype", fs)
+ if devname:
+ dev = self.addElement(osd, "devpath", devname)
+ self.addElement(osd, "autoformat", format)
+ if dev_size:
+ self.addElement(osd, "devsize", "%s" % (dev_size))
+ if journal_size:
+ self.addElement(osd, "journalsize", "%s" % (journal_size))
+ if nspath:
+ self.addElement(osd, "nspath", nspath)
+ return osd
+
+ def cobd(self, name, uuid, real_uuid, cache_uuid):
+ cobd = self.newService("cobd", name, uuid)
+ cobd.appendChild(self.ref("realobd",real_uuid))
+ cobd.appendChild(self.ref("cacheobd",cache_uuid))
+ return cobd
+
+ def ost(self, name, uuid, osd_uuid, group=""):
+ ost = self.newService("ost", name, uuid)
+ ost.appendChild(self.ref("active", osd_uuid))
+ if group:
+ self.addElement(ost, "group", group)
+ return ost
+
+ def oss(self, name, uuid):
+ oss = self.newService("oss", name, uuid)
+ return oss
+
+ def lov(self, name, uuid, mds_uuid, stripe_sz, stripe_cnt, pattern):
+ lov = self.newService("lov", name, uuid)
+ lov.appendChild(self.ref("mds", mds_uuid))
+ lov.setAttribute("stripesize", str(stripe_sz))
+ lov.setAttribute("stripecount", str(stripe_cnt))
+ lov.setAttribute("stripepattern", str(pattern))
+ return lov
+
+ def lovconfig(self, name, uuid, lov_uuid):
+ lovconfig = self.newService("lovconfig", name, uuid)
+ lovconfig.appendChild(self.ref("lov", lov_uuid))
+ return lovconfig
+
+ def mds(self, name, uuid, mdd_uuid, group=""):
+ mds = self.newService("mds", name, uuid)
+ mds.appendChild(self.ref("active",mdd_uuid))
+ if group:
+ self.addElement(mds, "group", group)
+ return mds
+
+ def mdsdev(self, name, uuid, fs, devname, format, node_uuid,
+ mds_uuid, dev_size=0, journal_size=0, nspath="", mkfsoptions=""):
+ mdd = self.newService("mdsdev", name, uuid)
+ self.addElement(mdd, "fstype", fs)
+ dev = self.addElement(mdd, "devpath", devname)
+ self.addElement(mdd, "autoformat", format)
+ if dev_size:
+ self.addElement(mdd, "devsize", "%s" % (dev_size))
+ if journal_size:
+ self.addElement(mdd, "journalsize", "%s" % (journal_size))
+ if nspath:
+ self.addElement(mdd, "nspath", nspath)
+ if mkfsoptions:
+ self.addElement(mdd, "mkfsoptions", mkfsoptions)
+ mdd.appendChild(self.ref("node", node_uuid))
+ mdd.appendChild(self.ref("target", mds_uuid))
+ return mdd
+
+ def mgmt(self, mgmt_name, mgmt_uuid, node_uuid):
+ mgmt = self.newService("mgmt", mgmt_name, mgmt_uuid)
+ mgmt.appendChild(self.ref("node", node_uuid))
+ # Placeholder until mgmt-service failover.
+ mgmt.appendChild(self.ref("active", mgmt_uuid))
+ return mgmt
+
+ def mountpoint(self, name, uuid, fs_uuid, path):
+ mtpt = self.newService("mountpoint", name, uuid)
+ mtpt.appendChild(self.ref("filesystem", fs_uuid))
+ self.addElement(mtpt, "path", path)
+ return mtpt
+
+ def filesystem(self, name, uuid, mds_uuid, obd_uuid, mgmt_uuid):
+ fs = self.newService("filesystem", name, uuid)
+ fs.appendChild(self.ref("mds", mds_uuid))
+ fs.appendChild(self.ref("obd", obd_uuid))
+ if mgmt_uuid:
+ fs.appendChild(self.ref("mgmt", mgmt_uuid))
+ return fs
+
+ def echo_client(self, name, uuid, osc_uuid):
+ ec = self.newService("echoclient", name, uuid)
+ ec.appendChild(self.ref("obd", osc_uuid))
+ return ec
+
+############################################################
+# Utilities to query a DOM tree
+# Using this functions we can treat use config information
+# directly as a database.
+def getName(n):
+ return n.getAttribute('name')
+
+def getUUID(node):
+ return node.getAttribute('uuid')
+
+
+def findByName(lustre, name, tag = ""):
+ for n in lustre.childNodes:
+ if n.nodeType == n.ELEMENT_NODE:
+ if tag and n.nodeName != tag:
+ continue
+ if getName(n) == name:
+ return n
+ else:
+ n = findByName(n, name)
+ if n: return n
+ return None
+
+
+def lookup(node, uuid):
+ for n in node.childNodes:
+ if n.nodeType == n.ELEMENT_NODE:
+ if getUUID(n) == uuid:
+ return n
+ else:
+ n = lookup(n, uuid)
+ if n: return n
+ return None
+
+
+def name2uuid(lustre, name, tag="", fatal=1):
+ ret = findByName(lustre, name, tag)
+ if not ret:
+ if fatal:
+ error('name2uuid:', '"'+name+'"', tag, 'element not found.')
+ else:
+ return ""
+ return getUUID(ret)
+
+def lookup_filesystem(lustre, mds_uuid, ost_uuid):
+ for n in lustre.childNodes:
+ if n.nodeType == n.ELEMENT_NODE and n.nodeName == 'filesystem':
+ if ref_exists(n, mds_uuid) and ref_exists(n, ost_uuid):
+ return getUUID(n)
+ return None
+
+# XXX: assumes only one network element per node. will fix this
+# as soon as support for routers is added
+def get_net_uuid(lustre, node_name):
+ """ get a network uuid for a node_name """
+ node = findByName(lustre, node_name, "node")
+ if not node:
+ error ('get_net_uuid:', '"'+node_name+'"', "node element not found.")
+ net = node.getElementsByTagName('network')
+ if net:
+ return getUUID(net[0])
+ return None
+
+
+def lov_add_obd(gen, lov, osc_uuid):
+ lov.appendChild(gen.ref("obd", osc_uuid))
+
+def ref_exists(profile, uuid):
+ elist = profile.childNodes
+ for e in elist:
+ if e.nodeType == e.ELEMENT_NODE:
+ ref = e.getAttribute('uuidref')
+ if ref == uuid:
+ return 1
+ return 0
+
+# ensure that uuid is not already in the profile
+# return true if uuid is added
+def node_add_profile(gen, node, ref, uuid):
+ refname = "%s_ref" % "profile"
+ ret = node.getElementsByTagName(refname)
+ if not ret:
+ error('node has no profile ref:', node)
+ prof_uuid = ret[0].getAttribute('uuidref')
+ profile = lookup(node.parentNode, prof_uuid)
+ if not profile:
+ error("no profile found:", prof_uuid)
+ if ref_exists(profile, uuid):
+ return 0
+ profile.appendChild(gen.ref(ref, uuid))
+ return 1
+
+def get_attr(dom_node, attr, default=""):
+ v = dom_node.getAttribute(attr)
+ if v:
+ return v
+ return default
+
+############################################################
+# Top level commands
#
-# Create a new obd, osc, and ost. Add them to the DOM.
-#
-def add_OST(dom, options, args):
- # XXX need some error checking
- devname = args[0]
- host = args[1]
-
- obdname = new_name("obd")
- oscname = new_name("osc")
- ostname = new_name("ost")
+def set_node_options(gen, node, options):
+ if options.router:
+ node.setAttribute('router', '1')
+ if options.timeout:
+ gen.addElement(node, "timeout", get_option(options, 'timeout'))
+ if options.upcall:
+ default_upcall = get_option(options, 'upcall')
+ else:
+ default_upcall = ''
+ if default_upcall or options.lustre_upcall:
+ if options.lustre_upcall:
+ gen.addElement(node, 'lustreUpcall', options.lustre_upcall)
+ else:
+ gen.addElement(node, 'lustreUpcall', default_upcall)
+ if default_upcall or options.portals_upcall:
+ if options.portals_upcall:
+ gen.addElement(node, 'portalsUpcall', options.portals_upcall)
+ else:
+ gen.addElement(node, 'portalsUpcall', default_upcall)
+ if options.ptldebug:
+ gen.addElement(node, "ptldebug", get_option(options, 'ptldebug'))
+ if options.subsystem:
+ gen.addElement(node, "subsystem", get_option(options, 'subsystem'))
+ return node
+
+def do_add_node(gen, lustre, options, node_name):
+ uuid = new_uuid(node_name)
+ prof_name = new_name("PROFILE_" + node_name)
+ prof_uuid = new_uuid(prof_name)
+ profile = gen.profile(prof_name, prof_uuid)
+ node = gen.node(node_name, uuid, prof_uuid)
+ lustre.appendChild(node)
+ lustre.appendChild(profile)
+
+ node_add_profile(gen, node, 'ldlm', ldlm_uuid)
+ set_node_options(gen, node, options)
+ return node
+
- obd = new_OBD(dom, obdname, "extN", devname, "no")
- osc = new_OSC(dom, oscname, obdname)
- ost = new_OST(dom, ostname, host, 2020, obdname)
+def add_node(gen, lustre, options):
+ """ create a node with a network config """
+
+ node_name = get_option(options, 'node')
+ ret = findByName(lustre, node_name, "node")
+ if ret:
+ print "Node:", node_name, "exists."
+ return
+ do_add_node(gen, lustre, options, node_name)
+
+
+def add_net(gen, lustre, options):
+ """ create a node with a network config """
+
+ node_name = get_option(options, 'node')
+ nid = get_option(options, 'nid')
+ cluster_id = get_option(options, 'cluster_id')
+ hostaddr = get_option(options, 'hostaddr')
+ net_type = get_option(options, 'nettype')
+
+ if net_type in ('tcp',):
+ port = get_option_int(options, 'port')
+ tcpbuf = get_option_int(options, 'tcpbuf')
+ irq_aff = get_option_int(options, 'irq_affinity')
+ elif net_type in ('elan', 'gm', 'scimac'):
+ port = 0
+ tcpbuf = 0
+ irq_aff = 0
+ else:
+ print "Unknown net_type: ", net_type
+ sys.exit(2)
+
+ ret = findByName(lustre, node_name, "node")
+ if not ret:
+ node = do_add_node(gen, lustre, options, node_name)
+ else:
+ node = ret
+ set_node_options(gen, node, options)
+
+ net_name = new_name('NET_'+ node_name +'_'+ net_type)
+ net_uuid = new_uuid(net_name)
+ node.appendChild(gen.network(net_name, net_uuid, nid, cluster_id, net_type,
+ hostaddr, port, tcpbuf, irq_aff))
+ node_add_profile(gen, node, "network", net_uuid)
+
+
+def add_route(gen, lustre, options):
+ """ create a node with a network config """
+
+ node_name = get_option(options, 'node')
+ gw_net_type = get_option(options, 'nettype')
+ gw = get_option(options, 'gw')
+ gw_cluster_id = get_option(options, 'gateway_cluster_id')
+ tgt_cluster_id = get_option(options, 'target_cluster_id')
+ lo = get_option(options, 'lo')
+ hi = get_option(options, 'hi')
+ if not hi:
+ hi = lo
+
+ node = findByName(lustre, node_name, "node")
+ if not node:
+ error (node_name, " not found.")
- dom.getElementsByTagName("lustre")[0].appendChild(obd)
- dom.getElementsByTagName("lustre")[0].appendChild(osc)
- dom.getElementsByTagName("lustre")[0].appendChild(ost)
+ rlist = node.getElementsByTagName('routetbl')
+ if len(rlist) > 0:
+ rtbl = rlist[0]
+ else:
+ rtbl_name = new_name("RTBL_" + node_name)
+ rtbl_uuid = new_uuid(rtbl_name)
+ rtbl = gen.routetbl(rtbl_name, rtbl_uuid)
+ node.appendChild(rtbl)
+ node_add_profile(gen, node, "routetbl", rtbl_uuid)
+ rtbl.appendChild(gen.route(gw_net_type, gw, gw_cluster_id, tgt_cluster_id,
+ lo, hi))
-#
+def add_mds(gen, lustre, options):
+ node_name = get_option(options, 'node')
+ mds_name = get_option(options, 'mds')
+ mdd_name = new_name("MDD_" + mds_name +"_" + node_name)
+ mdd_uuid = new_uuid(mdd_name)
+
+ mds_uuid = name2uuid(lustre, mds_name, fatal=0)
+ if not mds_uuid:
+ mds_uuid = new_uuid(mds_name)
+ mds = gen.mds(mds_name, mds_uuid, mdd_uuid, options.group)
+ lustre.appendChild(mds)
+ else:
+ mds = lookup(lustre, mds_uuid)
+ if options.failover:
+ mds.setAttribute('failover', "1")
+
+ devname = get_option(options, 'dev')
+ size = get_option(options, 'size')
+ fstype = get_option(options, 'fstype')
+ journal_size = get_option(options, 'journal_size')
+ nspath = get_option(options, 'nspath')
+ mkfsoptions = get_option(options, 'mkfsoptions')
+
+ node_uuid = name2uuid(lustre, node_name, 'node')
+
+ node = findByName(lustre, node_name, "node")
+ node_add_profile(gen, node, "mdsdev", mdd_uuid)
+ net_uuid = get_net_uuid(lustre, node_name)
+ if not net_uuid:
+ error("NODE: ", node_name, "not found")
+
+ mdd = gen.mdsdev(mdd_name, mdd_uuid, fstype, devname,
+ get_format_flag(options), node_uuid, mds_uuid,
+ size, journal_size, nspath, mkfsoptions)
+ lustre.appendChild(mdd)
+
+
+def add_mgmt(gen, lustre, options):
+ node_name = get_option(options, 'node')
+ node_uuid = name2uuid(lustre, node_name)
+ mgmt_name = get_option(options, 'mgmt')
+ if not mgmt_name:
+ mgmt_name = new_name('MGMT_' + node_name)
+ mgmt_uuid = name2uuid(lustre, mgmt_name, fatal=0)
+ if not mgmt_uuid:
+ mgmt_uuid = new_uuid(mgmt_name)
+ mgmt = gen.mgmt(mgmt_name, mgmt_uuid, node_uuid)
+ lustre.appendChild(mgmt)
+ else:
+ mgmt = lookup(lustre, mgmt_uuid)
+
+ node = findByName(lustre, node_name, "node")
+ node_add_profile(gen, node, 'mgmt', mgmt_uuid)
+
+def add_ost(gen, lustre, options):
+ node_name = get_option(options, 'node')
+ lovname = get_option(options, 'lov')
+ osdtype = get_option(options, 'osdtype')
+
+ node_uuid = name2uuid(lustre, node_name)
+
+ if osdtype == 'obdecho':
+ fstype = ''
+ devname = ''
+ size = 0
+ fstype = ''
+ journal_size = ''
+ else:
+ devname = get_option(options, 'dev') # can be unset for bluearcs
+ size = get_option(options, 'size')
+ fstype = get_option(options, 'fstype')
+ journal_size = get_option(options, 'journal_size')
+
+ nspath = get_option(options, 'nspath')
+
+ ostname = get_option(options, 'ost')
+ if not ostname:
+ ostname = new_name('OST_'+ node_name)
+
+ osdname = new_name("OSD_" + ostname + "_" + node_name)
+ osd_uuid = new_uuid(osdname)
+
+ ost_uuid = name2uuid(lustre, ostname, fatal=0)
+ if not ost_uuid:
+ ost_uuid = get_option(options, 'ostuuid')
+ if ost_uuid:
+ if lookup(lustre, ost_uuid):
+ error("Duplicate OST UUID:", ost_uuid)
+ else:
+ ost_uuid = new_uuid(ostname)
+
+ ost = gen.ost(ostname, ost_uuid, osd_uuid, options.group)
+ lustre.appendChild(ost)
+ if lovname:
+ lov = findByName(lustre, lovname, "lov")
+ if not lov:
+ error('add_ost:', '"'+lovname+'"', "lov element not found.")
+ lov_add_obd(gen, lov, ost_uuid)
+ else:
+ ost = lookup(lustre, ost_uuid)
+
+ if options.failover:
+ ost.setAttribute('failover', "1")
+
+
+ osd = gen.osd(osdname, osd_uuid, fstype, osdtype, devname,
+ get_format_flag(options), ost_uuid, node_uuid, size,
+ journal_size, nspath)
+
+ node = findByName(lustre, node_name, "node")
+
+## if node_add_profile(gen, node, 'oss', oss_uuid):
+## ossname = 'OSS'
+## oss_uuid = new_uuid(ossname)
+## oss = gen.oss(ossname, oss_uuid)
+## lustre.appendChild(oss)
+
+ node_add_profile(gen, node, 'osd', osd_uuid)
+ lustre.appendChild(osd)
+
+
+def add_cobd(gen, lustre, options):
+ node_name = get_option(options, 'node')
+ name = new_name('COBD_' + node_name)
+ uuid = new_uuid(name)
+
+ real_name = get_option(options, 'real_obd')
+ cache_name = get_option(options, 'cache_obd')
+
+ real_uuid = name2uuid(lustre, real_name, tag='obd')
+ cache_uuid = name2uuid(lustre, cache_name, tag='obd')
+
+ node = findByName(lustre, node_name, "node")
+ node_add_profile(gen, node, "cobd", uuid)
+ cobd = gen.cobd(name, uuid, real_uuid, cache_uuid)
+ lustre.appendChild(cobd)
+
+
+def add_echo_client(gen, lustre, options):
+ """ add an echo client to the profile for this node. """
+ node_name = get_option(options, 'node')
+ lov_name = get_option(options, 'ost')
+
+ node = findByName(lustre, node_name, 'node')
+
+ echoname = new_name('ECHO_'+ node_name)
+ echo_uuid = new_uuid(echoname)
+ node_add_profile(gen, node, 'echoclient', echo_uuid)
+
+ lov_uuid = name2uuid(lustre, lov_name, tag='lov', fatal=0)
+ if not lov_uuid:
+ lov_uuid = name2uuid(lustre, lov_name, tag='ost', fatal=1)
+
+ echo = gen.echo_client(echoname, echo_uuid, lov_uuid)
+ lustre.appendChild(echo)
+
+
+def add_lov(gen, lustre, options):
+ """ create a lov """
+
+ lov_orig = get_option(options, 'lov')
+ name = new_name(lov_orig)
+ if name != lov_orig:
+ warning("name:", lov_orig, "already used. using:", name)
+
+ mds_name = get_option(options, 'mds')
+ stripe_sz = get_option_int(options, 'stripe_sz')
+ stripe_cnt = get_option_int(options, 'stripe_cnt')
+ pattern = get_option_int(options, 'stripe_pattern')
+ uuid = new_uuid(name)
+
+ ret = findByName(lustre, name, "lov")
+ if ret:
+ error("LOV: ", name, " already exists.")
+
+ mds_uuid = name2uuid(lustre, mds_name, 'mds')
+ lov = gen.lov(name, uuid, mds_uuid, stripe_sz, stripe_cnt, pattern)
+ lustre.appendChild(lov)
+
+ # add an lovconfig entry to the active mdsdev profile
+ lovconfig_name = new_name('LVCFG_' + name)
+ lovconfig_uuid = new_uuid(lovconfig_name)
+ mds = findByName(lustre, mds_name)
+ mds.appendChild(gen.ref("lovconfig", lovconfig_uuid))
+ lovconfig = gen.lovconfig(lovconfig_name, lovconfig_uuid, uuid)
+ lustre.appendChild(lovconfig)
+
+def new_filesystem(gen, lustre, mds_uuid, obd_uuid, mgmt_uuid):
+ fs_name = new_name("FS_fsname")
+ fs_uuid = new_uuid(fs_name)
+ mds = lookup(lustre, mds_uuid)
+ mds.appendChild(gen.ref("filesystem", fs_uuid))
+ fs = gen.filesystem(fs_name, fs_uuid, mds_uuid, obd_uuid, mgmt_uuid)
+ lustre.appendChild(fs)
+ return fs_uuid
+
+def get_fs_uuid(gen, lustre, mds_name, obd_name, mgmt_name):
+ mds_uuid = name2uuid(lustre, mds_name, tag='mds')
+ obd_uuid = name2uuid(lustre, obd_name, tag='lov', fatal=0)
+ if not obd_uuid:
+ obd_uuid = name2uuid(lustre, obd_name, tag='ost', fatal=1)
+ if mgmt_name:
+ mgmt_uuid = name2uuid(lustre, mgmt_name, tag='mgmt', fatal=1)
+ else:
+ mgmt_uuid = ''
+ fs_uuid = lookup_filesystem(lustre, mds_uuid, obd_uuid)
+ if not fs_uuid:
+ fs_uuid = new_filesystem(gen, lustre, mds_uuid, obd_uuid, mgmt_uuid)
+ return fs_uuid
+
+def add_mtpt(gen, lustre, options):
+ """ create mtpt on a node """
+ node_name = get_option(options, 'node')
+
+ path = get_option(options, 'path')
+ fs_name = get_option(options, 'filesystem')
+ if fs_name == '':
+ mds_name = get_option(options, 'mds')
+ lov_name = get_option(options, 'lov')
+ if lov_name == '':
+ lov_name = get_option(options, 'ost')
+ if lov_name == '':
+ error("--add mtpt requires either --filesystem or --mds with an --lov lov_name or --ost ost_name")
+ mgmt_name = get_option(options, 'mgmt')
+ fs_uuid = get_fs_uuid(gen, lustre, mds_name, lov_name, mgmt_name)
+ else:
+ fs_uuid = name2uuid(lustre, fs_name, tag='filesystem')
+
+ name = new_name('MNT_'+ node_name)
+
+ ret = findByName(lustre, name, "mountpoint")
+ if ret:
+ # this can't happen, because new_name creates unique names
+ error("MOUNTPOINT: ", name, " already exists.")
+
+ uuid = new_uuid(name)
+ mtpt = gen.mountpoint(name, uuid, fs_uuid, path)
+ node = findByName(lustre, node_name, "node")
+ if not node:
+ error('node:', node_name, "not found.")
+ node_add_profile(gen, node, "mountpoint", uuid)
+ lustre.appendChild(mtpt)
+
+############################################################
# Command line processing
#
-def usage():
- print """usage: lmc [--ost | --mtpt | --lov] cmd args
-Commands:
---ost "device" "host"
- Creates an OBD/OST/OSC configuration triplet for a new device.
- When used on "host", the device will be initialized and the OST
- will be enabled. On client nodes, the OSC will be avaiable.
-
---mtpt "mds" "ost/lov-name" /mnt/point
- Creates a client mount point.
-
---lov "mds" "lov name < "all-ost.xml"
- Produces a logical volum striped over the OSTs found in all-ost.xml.
- (Not sure how all-ost.xml is created, exactly.)
-
-Options:
---merge="xml file" Add the new objects to an existing file
---format Format the partitions if unformated
---reformat Reformat partitions (this should be an lconf arg,
- I think)
-(SCRIPT STILL UNDER DEVELOPMENT, MOST COMMANDS/OPTIONS UNIMPLEMENTED)
-"""
+class OptionError (exceptions.Exception):
+ def __init__(self, args):
+ self.args = args
+
+def get_option(options, tag):
+ """Look for tag in options hash and return the value if set. If not
+ set, then if return default it is set, otherwise exception."""
+ if options.__getattr__(tag) != None:
+ return options.__getattr__(tag)
+ else:
+ raise OptionError("--add %s requires --%s <value>" % (options.add, tag))
-def cmdline(argv):
- short_opts = "ho:"
- long_opts = ["ost", "mtpt", "lov",
- "merge=", "format", "reformat", "output=",
- "help"]
- opts = []
- args = []
- options = {}
+def get_option_int(options, tag):
+ """Return an integer option. Raise exception if the value is not an int"""
+ val = get_option(options, tag)
try:
- opts, args = getopt.getopt(argv, short_opts, long_opts)
- except getopt.GetoptError:
- print "invalid opt"
- usage()
- sys.exit(2)
+ n = int(val)
+ except ValueError:
+ raise OptionError("--%s <num> (value must be integer)" % (tag))
+ return n
- for o, a in opts:
- if o in ("-h", "--help"):
- usage()
- sys.exit()
- if o in ("-o", "--output"):
- options['output'] = a
- if o == "--ost":
- options['ost'] = 1
- if o == "--merge":
- options['merge'] = a
- if o == "--format":
- options['format'] = 1
- if o == "--reformat":
- options['reformat'] = 1
-
- return options, args
+# simple class for profiling
+import time
+class chrono:
+ def __init__(self):
+ self._start = 0
+ def start(self):
+ self._stop = 0
+ self._start = time.time()
+ def stop(self, msg=''):
+ self._stop = time.time()
+ if msg:
+ self.display(msg)
+ def dur(self):
+ return self._stop - self._start
+ def display(self, msg):
+ d = self.dur()
+ str = '%s: %g secs' % (msg, d)
+ print str
-def main():
- options, args = cmdline(sys.argv[1:])
+############################################################
+# Main
+#
- if options.has_key('merge'):
- outFile = options['merge']
- dom = xml.dom.minidom.parse(outFile)
+def add(devtype, gen, lustre, options):
+ if devtype == 'net':
+ add_net(gen, lustre, options)
+ elif devtype == 'mtpt':
+ add_mtpt(gen, lustre, options)
+ elif devtype == 'mds':
+ add_mds(gen, lustre, options)
+ elif devtype == 'ost':
+ add_ost(gen, lustre, options)
+ elif devtype == 'lov':
+ add_lov(gen, lustre, options)
+ elif devtype == 'route':
+ add_route(gen, lustre, options)
+ elif devtype == 'node':
+ add_node(gen, lustre, options)
+ elif devtype == 'echo_client':
+ add_echo_client(gen, lustre, options)
+ elif devtype == 'cobd':
+ add_cobd(gen, lustre, options)
+ elif devtype == 'mgmt':
+ add_mgmt(gen, lustre, options)
+ else:
+ error("unknown device type:", devtype)
+
+def do_command(gen, lustre, options, args):
+ if options.add:
+ add(options.add, gen, lustre, options)
else:
- if options.has_key('output'):
- outFile = options['output']
+ error("Missing command")
+
+def main():
+ cl = Lustre.Options("lmc", "", lmc_options)
+ try:
+ options, args = cl.parse(sys.argv[1:])
+ except Lustre.OptionError, e:
+ panic("lmc", e)
+
+ if len(args) > 0:
+ panic(string.join(sys.argv), "Unexpected extra arguments on command line: " + string.join(args))
+
+ if options.reference:
+ reference()
+ sys.exit(0)
+
+ outFile = '-'
+
+ if options.merge:
+ outFile = options.merge
+ if os.access(outFile, os.R_OK):
+ doc = xml.dom.minidom.parse(outFile)
else:
- outFile = '-'
- dom = new_Lustre()
-
- if options.has_key('ost'):
- add_OST(dom, options, args)
- elif options.has_key('mtpt'):
- print "--mtpt not implemented"
- elif options.has_key('lov'):
- print "--mtpt not implemented"
- else:
- print "Missing command"
- usage()
+ doc = new_lustre(xml.dom.minidom)
+ elif options.input:
+ doc = xml.dom.minidom.parse(options.input)
+ else:
+ doc = new_lustre(xml.dom.minidom)
+
+ if options.output:
+ outFile = options.output
+
+ lustre = doc.documentElement
+ init_names(lustre)
+ if lustre.tagName != "lustre":
+ print "Existing config not valid."
sys.exit(1)
-
+
+ gen = GenConfig(doc)
+
+ # the PRNG is normally seeded with time(), which is not so good for starting # time-synchronized clusters
+ input = open('/dev/urandom', 'r')
+ if not input:
+ print 'Unable to open /dev/urandom!'
+ sys.exit(1)
+ seed = input.read(32)
+ input.close()
+ random.seed(seed)
+
+ if options.batch:
+ fp = open(options.batch)
+ batchCommands = fp.readlines()
+ fp.close()
+ for cmd in batchCommands:
+ try:
+ options, args = cl.parse(string.split(cmd))
+ do_command(gen, lustre, options, args)
+ except OptionError, e:
+ panic(cmd, e)
+ except Lustre.OptionError, e:
+ panic(cmd, e)
+ else:
+ try:
+ do_command(gen, lustre, options, args)
+ except OptionError, e:
+ panic(string.join(sys.argv),e)
+ except Lustre.OptionError, e:
+ panic("lmc", e)
if outFile == '-':
- print dom.toxml()
+ PrettyPrint(doc)
else:
- dom.writexml(open(outFile,"w"))
-
+ PrettyPrint(doc, open(outFile,"w"))
+
if __name__ == "__main__":
main()
git://git.whamcloud.com / fs / lustre-release.git / blobdiff