1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
#
# jFed support for Rhumba
#
# Sander Vrijders <sander.vrijders@intec.ugent.be>
#
# This library is free software; you can redistribute it and/or
# modify it under the terms of the GNU Lesser General Public
# License as published by the Free Software Foundation; either
# version 2.1 of the License, or (at your option) any later version.
#
# This library 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
# Lesser General Public License for more details.
#
# You should have received a copy of the GNU Lesser General Public
# License along with this library; if not, write to the Free Software
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
# MA 02110-1301 USA
import subprocess
import xml.dom.minidom as xml
def create_rspec(testbed, nodes, links):
testbed.rspec = testbed.exp_name + ".rspec"
impl = xml.getDOMImplementation()
doc = impl.createDocument(None, "rspec", None)
top_el = doc.documentElement
top_el.setAttribute("xmlns", "http://www.geni.net/resources/rspec/3")
top_el.setAttribute("type", "request")
top_el.setAttribute("xmlns:emulab", "http://www.protogeni.net/resources/" +
"rspec/ext/emulab/1")
top_el.setAttribute("xmlns:jfedBonfire", "http://jfed.iminds.be/rspec/" +
"ext/jfed-bonfire/1")
top_el.setAttribute("xmlns:delay", "http://www.protogeni.net/resources/" +
"rspec/ext/delay/1")
top_el.setAttribute("xmlns:jfed-command", "http://jfed.iminds.be/" +
"rspec/ext/jfed-command/1")
top_el.setAttribute("xmlns:client", "http://www.protogeni.net/resources/" +
"rspec/ext/client/1")
top_el.setAttribute("xmlns:jfed-ssh-keys", "http://jfed.iminds.be/rspec" +
"/ext/jfed-ssh-keys/1")
top_el.setAttribute("xmlns:jfed", "http://jfed.iminds.be/rspec/ext/jfed/1")
top_el.setAttribute("xmlns:sharedvlan", "http://www.protogeni.net/" +
"resources/rspec/ext/shared-vlan/1")
top_el.setAttribute("xmlns:xsi", "http://www.w3.org/2001/" +
"XMLSchema-instance")
top_el.setAttribute("xsi:schemaLocation", "http://www.geni.net/" +
"resources/rspec/3 http://www.geni.net/" +
"resources/rspec/3/request.xsd")
for node in nodes:
el = doc.createElement("node")
top_el.appendChild(el)
el.setAttribute("client_id", node.name)
el.setAttribute("exclusive", "true")
el.setAttribute("component_manager_id", testbed.authority)
el2 = doc.createElement("sliver_type")
el.appendChild(el2)
el2.setAttribute("name", "raw-pc")
node.ifs = 0
for link in links:
if link.node_a == node or link.node_b == node:
el3 = doc.createElement("interface")
if link.node_a == node:
link_id = link.int_a.id = node.name + ":if" + str(node.ifs)
if link.node_b == node:
link_id = link.int_b.id = node.name + ":if" + str(node.ifs)
el3.setAttribute("client_id", link_id)
node.ifs += 1
el.appendChild(el3)
for link in links:
el = doc.createElement("link")
top_el.appendChild(el)
el.setAttribute("client_id", link.name)
el2 = doc.createElement("component_manager_id")
el2.setAttribute("name", testbed.authority)
el.appendChild(el2)
el3 = doc.createElement("interface_ref")
el3.setAttribute("client_id", link.int_a.id)
el.appendChild(el3)
el4 = doc.createElement("interface_ref")
el4.setAttribute("client_id", link.int_b.id)
el.appendChild(el4)
file = open(testbed.rspec, "w")
file.write(doc.toprettyxml())
file.close()
def create_experiment(testbed, nodes, links):
create_rspec(testbed, nodes, links)
testbed.manifest = testbed.exp_name + ".rrspec"
subprocess.call(["java", "-jar", testbed.jfed_jar, "create", "-S", \
testbed.proj_name, "--rspec", \
testbed.rspec, "-s", \
testbed.exp_name, "-p", testbed.cert_file, "-k", \
"usercert,userkeys,shareduserallkeys", "--create-slice",\
"--manifest", testbed.manifest,
"-P", testbed.password, \
"-e", testbed.exp_hours])
rspec = xml.parse(testbed.manifest)
xml_nodes = rspec.getElementsByTagName("node")
for xml_node in xml_nodes:
n_name = xml_node.getAttribute("client_id")
intfs = xml_node.getElementsByTagName("interface")
for link in links:
if link.node_a.name == n_name:
interface = link.int_a
if link.node_b.name == n_name:
interface = link.int_b
for intf in intfs:
comp_id = intf.getAttribute("component_id")
comp_arr = comp_id.split(":")
interface.name = comp_arr[-1]
xml_ip = intf.getElementsByTagName("ip")
interface.ip = xml_ip[0].getAttribute("address")
|
