X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=src%2Fnepi%2Fresources%2Flinux%2Ftunnel.py;h=1bb587d2334d6aa00c7f8b55e0624677e110c03f;hb=6285ca51026efb69642eea9dfc7c480e722d84a9;hp=961d50c4cc3b25c1413b764b7e6eb1e5ccaa4d7a;hpb=741b99fe027fe6b54846a0703d26510d9b40a135;p=nepi.git diff --git a/src/nepi/resources/linux/tunnel.py b/src/nepi/resources/linux/tunnel.py index 961d50c4..1bb587d2 100644 --- a/src/nepi/resources/linux/tunnel.py +++ b/src/nepi/resources/linux/tunnel.py @@ -3,9 +3,8 @@ # Copyright (C) 2013 INRIA # # This program is free software: you can redistribute it and/or modify -# it under the terms of the GNU General Public License as published by -# the Free Software Foundation, either version 3 of the License, or -# (at your option) any later version. +# it under the terms of the GNU General Public License version 2 as +# published by the Free Software Foundation; # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of @@ -30,7 +29,6 @@ state_check_delay = 0.5 class LinuxTunnel(LinuxApplication): _rtype = "abstract::linux::Tunnel" _help = "Constructs a tunnel between two Linux endpoints" - _backend = "linux" def __init__(self, ec, guid): super(LinuxTunnel, self).__init__(ec, guid) @@ -65,6 +63,9 @@ class LinuxTunnel(LinuxApplication): def run_home(self, endpoint): return os.path.join(self.app_home(endpoint), self.ec.run_id) + def endpoint_mkdir(self, endpoint): + endpoint.node.mkdir(self.run_home(endpoint)) + def initiate_connection(self, endpoint, remote_endpoint): raise NotImplementedError @@ -82,8 +83,8 @@ class LinuxTunnel(LinuxApplication): def do_provision(self): # create run dir for tunnel on each node - self.endpoint1.node.mkdir(self.run_home(self.endpoint1)) - self.endpoint2.node.mkdir(self.run_home(self.endpoint2)) + self.endpoint_mkdir(self.endpoint1) + self.endpoint_mkdir(self.endpoint2) self.debug("Initiate the connection") # Start 2 step connection @@ -128,7 +129,7 @@ class LinuxTunnel(LinuxApplication): else: msg = " Failed to execute command '%s'" % command self.error(msg, out, err) - raise RuntimeError, msg + raise RuntimeError(msg) def do_stop(self): """ Stops application execution