Changeset 2fdf4b3

Timestamp:

Feb 19, 2010 8:32:58 AM (15 years ago)

Author:

Ted Faber <faber@…>

Branches:

axis_example, compt_changes, info-ops, master, version-3.01, version-3.02

Children:

5b74b63

Parents:

6a8a9ec

Message:

RSPEC conversion passes the smell test. ProtoGENI's down so we can't test yet.

File:

• fedd/federation/topdl.py (modified) (1 diff)

fedd/federation/topdl.py

@@ -749 +749 @@
 """
     return out
+
+def topology_to_rspec(t, filters=[]):
+    out = '<?xml version="1.0" encoding="UTF-8"?>\n' + \
+        '<rspec xmlns="http://www.protogeni.net/resources/rspec/0.1"\n' + \
+        '\txmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"\n' + \
+        '\txsi:schemaLocation="http://www.protogeni.net/resources/rspec/0.1 '+ \
+        'http://www.protogeni.net/resources/rspec/0.1/request.xsd"\n' + \
+        '\ttype="request" >\n'
+
+    ifname = { }
+    ifnode = { }
+
+    for e in [e for e in t.elements if isinstance(e, Computer)]:
+        name = e.name[0]
+        virt_type = e.get_attribute("virtualization_type") or "emulab-vnode"
+        exclusive = e.get_attribute("exclusive") or "1"
+        hw = e.get_attribute("type") or "pc";
+        slots = e.get_attribute("slots") or "1";
+        startup = e.get_attribute("startup")
+        tarfiles = " ".join([ "%s %s" % (s.install, s.location) \
+                for s in e.software if s.location and s.install ])
+
+        extras = ""
+        if startup: extras += '\t\tstartup_command="%s"\n' % startup
+        if tarfiles: extras +='\t\ttarfiles="%s"\n' % tarfiles
+        out += '\t<node virtual_id="%s"\n\t\tvirtualization_type="%s"\n' % \
+                (name, virt_type)
+        out += '\t\texclusive="%s"' % exclusive
+        if extras: out += '\n%s' % extras
+        out += '>\n'
+        out += '\t\t<node_type type_name="%s" slots="%s"/>\n' % (hw, slots)
+        for i, ii in enumerate(e.interface):
+            iname = "if%03d" % i
+            out += '\t\t<interface virtual_id="%s"/>\n' % iname
+            ifname[ii] = iname
+            ifnode[ii] = name
+        for f in filters:
+            out += f(s)
+        out += '\t</node>\n'
+
+    for i, s in enumerate(t.substrates):
+        out += '\t<link virtual_id="%s" link_type="ethernet">\n'
+        if s.capacity and s.capacity.kind == "max":
+            out += '\t\t<bandwidth>%f</bandwidth>\n' % s.capacity.rate
+        if s.latency and s.latency.kind == "max":
+            out += '\t\t<latency>%f</latency>\n' % s.latency.time
+        for ii in s.interfaces:
+            out += ('\t\t<interface_ref virtual_node_id="%s"' + \
+                    'virtual_interface_id="%s"/>\n') % (ifnode[ii], ifname[ii])
+        for f in filters:
+            out += f(s)
+        out += '\t</link>\n'
+    out += '</rspec>\n'
+    return out
+