ec.set(tap, "ip", ip2)
ec.set(tap, "prefix", prefix)
ec.set(tap, "pointopoint", ip1)
-ec.set(tap, "up", True)
ec.register_connection(tap, node2)
# Add ports on OVS
switch1 = "planetlab2.virtues.fi"
switch2 = "planetlab2.upc.es"
- host1 = "planetlab2.ionio.gr"
+ host1 = "planetlab2.s3.kth.se"
host2 = "iraplab2.iralab.uni-karlsruhe.de"
parser = OptionParser(usage = usage)
# site. Replace with your own user and password account information.
ec.set(node, "pluser", pl_user)
ec.set(node, "plpassword", pl_password)
+ ec.set(node, "critical", False)
# Remove previous results
ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
ec.set(app, "command",
"cp /etc/yum.repos.d/fedora.repo /etc/yum.repos.d/fedora.repo.old; "
"cp ${SHARE}/fedora.repo /etc/yum.repos.d/fedora.repo")
+ ec.set(app, "critical", False)
ec.register_connection(node, app)
apps.append(app)
ec.set(app, "command",
"cp /etc/yum.repos.d/fedora-updates.repo /etc/yum.repos.d/fedora-updates.repo.old; "
"cp ${SHARE}/fedora-updates.repo /etc/yum.repos.d/fedora-updates.repo")
+ ec.set(app, "critical", False)
ec.register_connection(node, app)
apps.append(app)
ec.wait_finished(apps)
for app in apps:
- print ec.trace(app, "stderr")
+ try:
+ print ec.trace(app, "stderr")
+ except:
+ print "NO stderr"
ec.shutdown()
return os.path.join(self.app_home(endpoint), self.ec.run_id)
def endpoint_mkdir(self, endpoint):
- self.endpoint.node.mkdir(self.run_home(self.endpoint))
+ endpoint.node.mkdir(self.run_home(endpoint))
def initiate_connection(self, endpoint, remote_endpoint):
raise NotImplementedError
self.ec.set(self._vroute, "nexthop", remote_endpoint.get("pointopoint"))
self.ec.set(self._vroute, "network", self.get("network"))
- print "Vroute Guid :" + str(self._vroute)
-
self.ec.register_connection(self._vroute, remote_endpoint.guid)
self.ec.deploy(guids=[self._vroute], group = self.deployment_group)