X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=src%2Fnepi%2Fresources%2Flinux%2Fgretunnel.py;h=f422a63ec105e3302ec37f6587b2097e3072cf89;hb=6285ca51026efb69642eea9dfc7c480e722d84a9;hp=d69ac30f316b6dca5915382915488c2407213c75;hpb=a55b5cf0818ced6ab8dc3e88fad7f6616675e826;p=nepi.git diff --git a/src/nepi/resources/linux/gretunnel.py b/src/nepi/resources/linux/gretunnel.py index d69ac30f..f422a63e 100644 --- a/src/nepi/resources/linux/gretunnel.py +++ b/src/nepi/resources/linux/gretunnel.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 @@ -18,8 +17,7 @@ # Author: Alina Quereilhac from nepi.execution.attribute import Attribute, Flags, Types -from nepi.execution.resource import clsinit_copy, ResourceState, \ - reschedule_delay +from nepi.execution.resource import clsinit_copy, ResourceState from nepi.resources.linux.tunnel import LinuxTunnel from nepi.util.sshfuncs import ProcStatus from nepi.util.timefuncs import tnow, tdiffsec @@ -31,9 +29,8 @@ import os @clsinit_copy class LinuxGRETunnel(LinuxTunnel): - _rtype = "LinuxGRETunnel" + _rtype = "linux::GRETunnel" _help = "Constructs a tunnel between two Linux endpoints using a UDP connection " - _backend = "linux" def log_message(self, msg): return " guid %d - GRE tunnel %s - %s - %s " % (self.guid, @@ -73,9 +70,9 @@ class LinuxGRETunnel(LinuxTunnel): m = re.search("(\d+)% packet loss", str(out)) if not m or int(m.groups()[0]) == 100: - msg = " Erroro establishing GRE Tunnel" + msg = " Error establishing GRE Tunnel" self.error(msg, out, err) - raise RuntimeError, msg + raise RuntimeError(msg) def terminate_connection(self, endpoint, remote_endpoint): pass