1 import sys, types, string, os
6 # ============================================================
7 # XML processing and query
10 def lookup(self, uuid):
11 """ lookup returns a new LustreDB instance"""
12 return self._lookup_by_uuid(uuid)
14 def lookup_name(self, name, class_name = ""):
15 """ lookup returns a new LustreDB instance"""
16 return self._lookup_by_name(name, class_name)
18 def lookup_class(self, class_name):
19 """ lookup returns a new LustreDB instance"""
20 return self._lookup_by_class(class_name)
22 def get_val(self, tag, default=None):
23 v = self._get_val(tag)
31 return self._get_class()
33 def get_val_int(self, tag, default=0):
34 str = self._get_val(tag)
40 raise Lustre.LconfError("text value is not integer: " + str)
42 def get_first_ref(self, tag):
43 """ Get the first uuidref of the type TAG. Only
44 one is expected. Returns the uuid."""
45 uuids = self._get_refs(tag)
50 def get_refs(self, tag):
51 """ Get all the refs of type TAG. Returns list of uuids. """
52 uuids = self._get_refs(tag)
55 def get_all_refs(self):
56 """ Get all the refs. Returns list of uuids. """
57 uuids = self._get_all_refs()
60 def nid2server(self, nid, net_type, cluster_id):
61 netlist = self.lookup_class('network')
62 for net_db in netlist:
63 if (net_db.get_val('nid') == nid and
64 net_db.get_val('nettype') == net_type and
65 net_db.get_val('clusterid') == cluster_id):
69 # Find the target_device for target on a node
70 # node->profiles->device_refs->target
71 def get_node_tgt_dev(self, node_name, target_uuid):
72 node_db = self.lookup_name(node_name)
75 return node_db.get_tgt_dev(target_uuid)
77 # get all network uuids for this node
78 def get_networks(self):
80 prof_list = self.get_refs('profile')
81 for prof_uuid in prof_list:
82 prof_db = self.lookup(prof_uuid)
83 net_list = prof_db.get_refs('network')
84 for net_uuid in net_list:
88 def get_active_dev(self, tgtuuid):
89 tgt = self.lookup(tgtuuid)
90 tgt_dev_uuid =tgt.get_first_ref('active')
93 def get_tgt_dev(self, tgtuuid):
94 prof_list = self.get_refs('profile')
95 for prof_uuid in prof_list:
96 prof_db = self.lookup(prof_uuid)
98 panic("profile:", profile, "not found.")
99 for ref_class, ref_uuid in prof_db.get_all_refs():
100 if ref_class in ('osd', 'mdsdev'):
101 devdb = self.lookup(ref_uuid)
102 uuid = devdb.get_first_ref('target')
107 def get_group(self, group):
109 devs = self.lookup_class('mds')
111 if tgt.get_val('group', "") == group:
112 ret.append(tgt.getUUID())
113 devs = self.lookup_class('ost')
115 if tgt.get_val('group', "") == group:
116 ret.append(tgt.getUUID())
119 # Change the current active device for a target
120 def update_active(self, tgtuuid, new_uuid):
121 self._update_active(tgtuuid, new_uuid)
123 def get_version(self):
124 return self.get_val('version')
126 class LustreDB_XML(LustreDB):
127 def __init__(self, dom, root_node):
130 self.root_node = root_node
132 def xmltext(self, dom_node, tag):
133 list = dom_node.getElementsByTagName(tag)
137 if dom_node.firstChild:
138 txt = string.strip(dom_node.firstChild.data)
142 def xmlattr(self, dom_node, attr):
143 return dom_node.getAttribute(attr)
145 def _get_val(self, tag):
146 """a value could be an attribute of the current node
147 or the text value in a child node"""
148 ret = self.xmlattr(self.dom_node, tag)
150 ret = self.xmltext(self.dom_node, tag)
153 def _get_class(self):
154 return self.dom_node.nodeName
156 def get_ref_type(self, ref_tag):
157 res = string.split(ref_tag, '_')
161 # [(ref_class, ref_uuid),]
162 def _get_all_refs(self):
164 for n in self.dom_node.childNodes:
165 if n.nodeType == n.ELEMENT_NODE:
166 ref_uuid = self.xml_get_ref(n)
167 ref_class = self.get_ref_type(n.nodeName)
168 list.append((ref_class, ref_uuid))
173 def _get_refs(self, tag):
174 """ Get all the refs of type TAG. Returns list of uuids. """
176 refname = '%s_ref' % tag
177 reflist = self.dom_node.getElementsByTagName(refname)
179 uuids.append(self.xml_get_ref(r))
182 def xmllookup_by_uuid(self, dom_node, uuid):
183 for n in dom_node.childNodes:
184 if n.nodeType == n.ELEMENT_NODE:
185 if self.xml_get_uuid(n) == uuid:
188 n = self.xmllookup_by_uuid(n, uuid)
192 def _lookup_by_uuid(self, uuid):
193 dom = self. xmllookup_by_uuid(self.root_node, uuid)
195 return LustreDB_XML(dom, self.root_node)
197 def xmllookup_by_name(self, dom_node, name):
198 for n in dom_node.childNodes:
199 if n.nodeType == n.ELEMENT_NODE:
200 if self.xml_get_name(n) == name:
203 n = self.xmllookup_by_name(n, name)
207 def _lookup_by_name(self, name, class_name):
208 dom = self.xmllookup_by_name(self.root_node, name)
210 return LustreDB_XML(dom, self.root_node)
212 def xmllookup_by_class(self, dom_node, class_name):
213 return dom_node.getElementsByTagName(class_name)
215 def _lookup_by_class(self, class_name):
217 domlist = self.xmllookup_by_class(self.root_node, class_name)
219 ret.append(LustreDB_XML(node, self.root_node))
222 def xml_get_name(self, n):
223 return n.getAttribute('name')
226 return self.xml_get_name(self.dom_node)
228 def xml_get_ref(self, n):
229 return n.getAttribute('uuidref')
231 def xml_get_uuid(self, dom_node):
232 return dom_node.getAttribute('uuid')
235 return self.xml_get_uuid(self.dom_node)
237 # Convert routes from the router to a route that will be used
238 # on the local system. The network type and gw are changed to the
239 # interface on the router the local system will connect to.
240 def get_local_routes(self, type, gw):
241 """ Return the routes as a list of tuples of the form:
242 [(type, gw, lo, hi),]"""
244 tbl = self.dom_node.getElementsByTagName('routetbl')
246 routes = t.getElementsByTagName('route')
248 net_type = self.xmlattr(r, 'type')
250 lo = self.xmlattr(r, 'lo')
251 hi = self.xmlattr(r, 'hi')
252 tgt_cluster_id = self.xmlattr(r, 'tgtclusterid')
253 res.append((type, gw, tgt_cluster_id, lo, hi))
256 def get_route_tbl(self):
258 for r in self.dom_node.getElementsByTagName('route'):
259 net_type = self.xmlattr(r, 'type')
260 gw = self.xmlattr(r, 'gw')
261 gw_cluster_id = self.xmlattr(r, 'gwclusterid')
262 tgt_cluster_id = self.xmlattr(r, 'tgtclusterid')
263 lo = self.xmlattr(r, 'lo')
264 hi = self.xmlattr(r, 'hi')
265 ret.append((net_type, gw, gw_cluster_id, tgt_cluster_id, lo, hi))
268 def _update_active(self, tgt, new):
269 raise Lustre.LconfError("updates not implemented for XML")
271 # ================================================================
273 class LustreDB_LDAP(LustreDB):
274 def __init__(self, name, attrs,
277 url = "ldap://localhost",
278 user = "cn=Manager, fs=lustre",
284 self._parent = parent
290 self._base = parent._base
297 self.l = ldap.initialize(self._url)
298 # Set LDAP protocol version used
299 self.l.protocol_version=ldap.VERSION3
300 # user and pw only needed if modifying db
301 self.l.bind_s(self._user, self._pw, ldap.AUTH_SIMPLE);
302 except ldap.LDAPError, e:
303 raise Lustre.LconfError('Unable to connect to ldap server:' + self._url)
306 self._name, self._attrs = self.l.search_s(self._base,
308 except ldap.LDAPError, e:
309 raise Lustre.LconfError("no config found in ldap: %s"
314 def ldap_search(self, filter):
315 """Return list of uuids matching the filter."""
321 for name, attrs in self.l.search_s(dn, ldap.SCOPE_ONELEVEL,
323 for v in attrs['uuid']:
325 except ldap.NO_SUCH_OBJECT, e:
327 except ldap.LDAPError, e:
328 print e # FIXME: die here?
331 ret.append(self._lookup_by_uuid(uuid))
334 def _lookup_by_name(self, name, class_name):
335 list = self.ldap_search("lustreName=%s" %(name))
340 def _lookup_by_class(self, class_name):
341 return self.ldap_search("objectclass=%s" %(string.upper(class_name)))
343 def _lookup_by_uuid(self, uuid):
345 dn = "uuid=%s,%s" % (uuid, self._base)
348 for name, attrs in self.l.search_s(dn, ldap.SCOPE_BASE,
350 ret = LustreDB_LDAP(name, attrs, parent = self)
352 except ldap.NO_SUCH_OBJECT, e:
353 pass # just return empty list
354 except ldap.LDAPError, e:
355 print e # FIXME: die here?
359 def _get_val(self, k):
361 if self._attrs.has_key(k):
363 if type(v) == types.ListType:
369 def _get_class(self):
370 return string.lower(self._attrs['objectClass'][0])
372 def get_ref_type(self, ref_tag):
376 # [(ref_class, ref_uuid),]
377 def _get_all_refs(self):
379 for k in self._attrs.keys():
380 if re.search('.*Ref', k):
381 for uuid in self._attrs[k]:
382 ref_class = self.get_ref_type(k)
383 list.append((ref_class, uuid))
386 def _get_refs(self, tag):
387 """ Get all the refs of type TAG. Returns list of uuids. """
389 refname = '%sRef' % tag
390 if self._attrs.has_key(refname):
391 return self._attrs[refname]
395 return self._get_val('lustreName')
398 return self._get_val('uuid')
400 def get_route_tbl(self):
403 def _update_active(self, tgtuuid, newuuid):
404 """Return list of uuids matching the filter."""
406 dn = "uuid=%s,%s" %(tgtuuid, self._base)
410 self.l.modify_s(dn, [(ldap.MOD_REPLACE, "activeRef", newuuid)])
411 except ldap.NO_SUCH_OBJECT, e:
413 except ldap.LDAPError, e:
414 print e # FIXME: die here?