X-Git-Url: http://git.onelab.eu/?p=nepi.git;a=blobdiff_plain;f=examples%2Fopenvswitch%2Fovs_ping_3switches_line.py;h=4182d81f7e6338c033a9c545b86fa266a26aa11b;hp=b48485ee96e4133ba695a73047d37775844bce58;hb=d50ba1a08e541ded7a8b322493ebb1d0cc59c6ff;hpb=4762aa96c7f41a86d919db6dac0feca2c6ca8e16 diff --git a/examples/openvswitch/ovs_ping_3switches_line.py b/examples/openvswitch/ovs_ping_3switches_line.py index b48485ee..4182d81f 100644 --- a/examples/openvswitch/ovs_ping_3switches_line.py +++ b/examples/openvswitch/ovs_ping_3switches_line.py @@ -32,20 +32,20 @@ from nepi.execution.ec import ExperimentController import os, time def add_node(ec, host, user, pl_user, pl_password): - node = ec.register_resource("PlanetlabNode") + node = ec.register_resource("planetlab::Node") ec.set(node, "hostname", host) ec.set(node, "username", user) if pl_user: ec.set(node, "pluser", pl_user) if pl_password: ec.set(node, "plpassword", pl_password) - ec.set(node, "cleanHome", True) + ec.set(node, "cleanExperiment", True) ec.set(node, "cleanProcesses", True) return node def add_ovs(ec, bridge_name, virtual_ip_pref, controller_ip, controller_port, node): - ovs = ec.register_resource("OVSSwitch") + ovs = ec.register_resource("planetlab::OVSSwitch") ec.set(ovs, "bridge_name", bridge_name) ec.set(ovs, "virtual_ip_pref", virtual_ip_pref) ec.set(ovs, "controller_ip", controller_ip) @@ -54,14 +54,14 @@ def add_ovs(ec, bridge_name, virtual_ip_pref, controller_ip, controller_port, no return ovs def add_port(ec, port_name, network, ovs): - port = ec.register_resource("OVSPort") + port = ec.register_resource("planetlab::OVSPort") ec.set(port, "port_name", port_name) ec.set(port, "network", network) ec.register_connection(port, ovs) return port def add_tap(ec, endpoint_ip, endpoint_prefix, pointopoint, node): - tap = ec.register_resource("PlanetlabTap") + tap = ec.register_resource("planetlab::Tap") ec.set(tap, "endpoint_ip", endpoint_ip) ec.set(tap, "endpoint_prefix", endpoint_prefix) ec.set(tap, "pointopoint", pointopoint) @@ -70,13 +70,13 @@ def add_tap(ec, endpoint_ip, endpoint_prefix, pointopoint, node): return tap def add_tunnel(ec, port0, tap): - tunnel = ec.register_resource("LinuxUdpTunnel") + tunnel = ec.register_resource("linux::UdpTunnel") ec.register_connection(port0, tunnel) ec.register_connection(tunnel, tap) return tunnel def add_app(ec, command, node): - app = ec.register_resource("LinuxApplication") + app = ec.register_resource("linux::Application") ec.set(app, "command", command) ec.register_connection(app, node) return app @@ -208,6 +208,3 @@ f.close() ec.shutdown() - - -