aboutsummaryrefslogtreecommitdiff
path: root/rumba/testbeds/jfed.py
diff options
context:
space:
mode:
authorMarco Capitani <m.capitani@nextworks.it>2017-04-21 15:58:56 +0200
committerMarco Capitani <m.capitani@nextworks.it>2017-04-21 15:58:56 +0200
commit26e3e22cd6ca6676b7b99624764f8e6f1ae1479d (patch)
tree65764b5ce423dc88a318e3b7325281bf3a094070 /rumba/testbeds/jfed.py
parentee2f6e5c21c0ba94048dbf1c86024e3181718fc2 (diff)
downloadrumba-26e3e22cd6ca6676b7b99624764f8e6f1ae1479d.tar.gz
rumba-26e3e22cd6ca6676b7b99624764f8e6f1ae1479d.zip
rumba: log: Added logging support, migrated from print to logging.
+ Added logging, migrated, default logging configuration is to stdout. + Minor PEP8 adjustments all-around
Diffstat (limited to 'rumba/testbeds/jfed.py')
-rw-r--r--rumba/testbeds/jfed.py39
1 files changed, 24 insertions, 15 deletions
diff --git a/rumba/testbeds/jfed.py b/rumba/testbeds/jfed.py
index f51081c..1c0f992 100644
--- a/rumba/testbeds/jfed.py
+++ b/rumba/testbeds/jfed.py
@@ -26,8 +26,14 @@ import wget
import tarfile
import rumba.model as mod
+import rumba.log as log
+
+
+logger = log.get_logger(__name__)
+
class Testbed(mod.Testbed):
+
def __init__(self, exp_name, username, cert_file, exp_hours="2",
proj_name="ARCFIRE", authority="wall2.ilabt.iminds.be",
image=None):
@@ -47,18 +53,17 @@ class Testbed(mod.Testbed):
else:
self.image = None
- if os.path.exists(self.jfed_jar) == False:
- print("Couldn't find jFed CLI. Downloading.")
+ if not os.path.exists(self.jfed_jar):
+ logger.warning("Couldn't find jFed CLI. Downloading.")
tarball = "jfed_cli.tar.gz"
url = "http://jfed.iminds.be/downloads/stable/jar/" + tarball
wget.download(url)
tar = tarfile.open(tarball)
tar.extractall()
tar.close()
- print("Extracted in current directory")
+ logger.info("Extracted in current directory")
os.remove(tarball)
-
def create_rspec(self, experiment):
impl = xml.getDOMImplementation()
doc = impl.createDocument(None, "rspec", None)
@@ -137,22 +142,23 @@ class Testbed(mod.Testbed):
for node in experiment.nodes:
auth_name_r = self.auth_name.replace(".", "-")
- node.ssh_config.hostname = node.name + "." + self.exp_name + "." + \
- auth_name_r + "." + self.auth_name
+ node.ssh_config.hostname = \
+ node.name + "." + self.exp_name + "." + \
+ auth_name_r + "." + self.auth_name
node.ssh_config.proxycommand = "ssh -i '" + self.cert_file + \
"' -o StrictHostKeyChecking=no " + \
self.username + \
"@bastion.test.iminds.be nc " + \
node.ssh_config.hostname + " 22"
- subprocess.call(["java", "-jar", self.jfed_jar, "create", "-S", \
- self.proj_name, "--rspec", \
- self.rspec, "-s", \
- self.exp_name, "-p", self.cert_file, "-k", \
- "usercert,userkeys,shareduserallkeys", \
- "--create-slice",\
+ subprocess.call(["java", "-jar", self.jfed_jar, "create", "-S",
+ self.proj_name, "--rspec",
+ self.rspec, "-s",
+ self.exp_name, "-p", self.cert_file, "-k",
+ "usercert,userkeys,shareduserallkeys",
+ "--create-slice",
"--manifest", self.manifest,
- "-P", self.password, \
+ "-P", self.password,
"-e", self.exp_hours])
rspec = xml.parse(self.manifest)
@@ -175,5 +181,8 @@ class Testbed(mod.Testbed):
comp_id = intf.getAttribute("component_id")
comp_arr = comp_id.split(":")
ipcp.ifname = comp_arr[-1]
- #xml_ip = intf.getElementsByTagName("ip")
- #interface.ip = xml_ip[0].getAttribute("address")
+ # xml_ip = intf.getElementsByTagName("ip")
+ # interface.ip = xml_ip[0].getAttribute("address")
+
+ def swap_out(self, experiment):
+ pass