X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=src%2Fnepi%2Fresources%2Flinux%2Fudptunnel.py;h=c00459c871170a7582edecf3aea4dc82bdc7188c;hb=7fed767f9f18ee81807950771145969cbb27b8a7;hp=1643b904cf66d4bc88d9bea0b8340c947532a107;hpb=4f61ec12520928b3403ee2a75c9e4ce1b30907a3;p=nepi.git diff --git a/src/nepi/resources/linux/udptunnel.py b/src/nepi/resources/linux/udptunnel.py index 1643b904..c00459c8 100644 --- a/src/nepi/resources/linux/udptunnel.py +++ b/src/nepi/resources/linux/udptunnel.py @@ -18,8 +18,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 @@ -30,9 +29,9 @@ import time @clsinit_copy class LinuxUdpTunnel(LinuxTunnel): - _rtype = "LinuxUdpTunnel" + _rtype = "linux::UdpTunnel" _help = "Constructs a tunnel between two Linux endpoints using a UDP connection " - _backend = "linux" + _platform = "linux" @classmethod def _register_attributes(cls): @@ -105,7 +104,13 @@ class LinuxUdpTunnel(LinuxTunnel): return port def establish_connection(self, endpoint, remote_endpoint, port): - endpoint.establish_udp_connection(remote_endpoint, port) + connection_app_home = self.app_home(endpoint) + connection_run_home = self.run_home(endpoint) + + endpoint.establish_udp_connection(remote_endpoint, + connection_app_home, + connection_run_home, + port) def verify_connection(self, endpoint, remote_endpoint): endpoint.verify_connection()