username = # SSH user account on host
ssh_key = # Path to SSH public key file to access host
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", hostname)
ec.set(node, "username", username)
ec.set(node, "identity", ssh_key)
-app = ec.register_resource("LinuxApplication")
+app = ec.register_resource("linux::Application")
ec.set(app, "command", "ping -c3 nepi.inria.fr")
ec.register_connection(app, node)
%cpaste
def add_node(ec, hostname, username, ssh_key):
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", hostname)
ec.set(node, "username", username)
ec.set(node, "identity", ssh_key)
return node
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
name. pluser and plpassword are the user and password used for authenticate yourself in the Planetlab web page (www.planet-lab.eu). For example, when registering a Planetlab node for your experiment, the
experiment description will look a lot like this:
\begin{lstlisting}[language=Python]
-node = ec.register_resource("PlanetlabNode")
+node = ec.register_resource("planetlab::Node")
ec.set(node, "username", "institute_project")
ec.set(node, "pluser", "​​john.doe@institute.edu")
ec.set(node, "plpassword", "guessit")
\end{lstlisting}
Now we know how to add a filter to the node description:
\begin{lstlisting}[language=Python]
- node = ec.register_resource("PlanetlabNode??")
+ node = ec.register_resource("planetlab::Node??")
ec.set(node, "username", "institute_project")
ec.set(node, "pluser", "​​jhon.doe@institute.edu")
ec.set(node, "plpassword", "guessit")
In case of more filters, an AND between the filters will be applied:
\begin{lstlisting}[language=Python]
- node = ec.register_resource("PlanetlabNode??")
+ node = ec.register_resource("planetlab::Node??")
ec.set(node, "username", "institute_project")
ec.set(node, "pluser", "​​jhon.doe@institute.edu")
ec.set(node, "plpassword", "guessit")
In this case, our experiment description will look like this:
\begin{lstlisting}[language=Python]
-node1 = ec.register_resource("PlanetlabNode")
+node1 = ec.register_resource("planetlab::Node")
ec.set(node1, "username", "institute_project")
ec.set(node1, "pluser", "​​john.doe@institute.edu")
ec.set(node1, "plpassword", "guessit")
ec.set(node1, "hostname", "planetlab2.utt.fr")
## planetlab2.utt.fr is the specific node we want to use
-node2 = ec.register_resource("PlanetlabNode")
+node2 = ec.register_resource("planetlab::Node")
ec.set(node2, "username", "institute_project")
ec.set(node2, "pluser", "​​john.doe@institute.edu")
ec.set(node2, "plpassword", "guessit")
PlanetLab nodes may fail for different reasons, ssh authentication failure, file system corrupted, nodes unreachable, between others. Moreover, the mal functioning nodes can vary from one experiment run to the next one. In NEPI there is the ability to register these mal functioning nodes in order run the experiment in a more efficient way. Also, this information can be use to evaluate the performance of the experiment and the nodes themselves.
-The PlanetlabNode resource, is instantiated for each Planetlab node defined in the experiment. The node discovery and provisioning occurs in parallel for every node defined, so a list of the nodes failures is needed while deploying, in order to avoid to repeat the provision of mal functioning nodes. This list of blacklisted nodes during the experiment, can be saved and maintain for following run of the same experiment or others experiments. This list it is called blacklist. Moreover, the nodes in the blacklist in the moment the experiment is started, can be use to directly discard from the node discover and provision the unwanted nodes.
+The planetlab::Node resource, is instantiated for each Planetlab node defined in the experiment. The node discovery and provisioning occurs in parallel for every node defined, so a list of the nodes failures is needed while deploying, in order to avoid to repeat the provision of mal functioning nodes. This list of blacklisted nodes during the experiment, can be saved and maintain for following run of the same experiment or others experiments. This list it is called blacklist. Moreover, the nodes in the blacklist in the moment the experiment is started, can be use to directly discard from the node discover and provision the unwanted nodes.
-There is an attribute available for this matter, is called 'persist\_blacklist' and is a global attribute, meaning that if set, is set for every resource of type PlanetlabNode.
+There is an attribute available for this matter, is called 'persist\_blacklist' and is a global attribute, meaning that if set, is set for every resource of type planetlab::Node.
The blacklist file is stored in ~/.nepi/plblacklist.txt.
Example on how to use the attribute:
Two Planetlab nodes that read from the blacklist at the beginning of the experiment, and write new blacklisted nodes (if any) at the end.
\begin{lstlisting}[language=Python]
-node1 = ec.register_resource("PlanetlabNode")
+node1 = ec.register_resource("planetlab::Node")
ec.set(node1, "username", username)
ec.set(node1, "pluser", pl_user)
ec.set(node1, "plpassword", pl_password)
ec.set(node1, "cleanHome", True)
ec.set(node1, "cleanProcesses", True)
-node2 = ec.register_resource("PlanetlabNode")
+node2 = ec.register_resource("planetlab::Node")
ec.set(node2, "username", username)
ec.set(node2, "pluser", pl_user)
ec.set(node2, "plpassword", pl_password)
ec.set(node2, "cleanHome", True)
ec.set(node2, "cleanProcesses", True)
-ec.set_global('PlanetlabNode', 'persist_blacklist', True)
+ec.set_global("planetlab::Node", 'persist_blacklist', True)
\end{lstlisting}
The attribute can be retrieved with the method get\_global :
\begin{lstlisting}[language=Python]
-ec.get_global('PlanetlabNode', 'persist_blacklist').
+ec.get_global("planetlab::Node", 'persist_blacklist').
\end{lstlisting}
\subsection{SFA Support}
sfauser = os.environ.get('SFA_USER') --- for example 'ple.inria.lucia_guevgeozian_odizzio'
sfaPrivateKey = os.environ.get('SFA_PK') --- for example '/home/.sfi/lucia_guevgeozian_odizzio.pkey'
-node1 = ec.register_resource("PlanetlabSfaNode")
+node1 = ec.register_resource("planetlab::sfa::Node")
ec.set(node1, "hostname", 'planetlab1.cs.vu.nl')
ec.set(node1, "username", username)
ec.set(node1, "sfauser", sfauser)
\end{lstlisting}
\subsubsection{SFA with iMinds Testbed (w-iLab.t)}
-The control and management software running in w-iLab.t is OMF 6, but its resources can be discover and provisioned using SFA, the experiment description for the WilabtSfaNode in NEPI is similar to the one in PlanetlabNode. Below is an example :
+The control and management software running in w-iLab.t is OMF 6, but its resources can be discover and provisioned using SFA, the experiment description for the WilabtSfaNode in NEPI is similar to the one in Planetlab::Node. Below is an example :
\begin{lstlisting}[language=Python]
from nepi.execution.ec import ExperimentController
import os
sfaPrivateKey = os.environ.get('SFA_PK')
# nodes
-node1 = ec.register_resource("WilabtSfaNode")
+node1 = ec.register_resource("wilabt::sfa::Node")
ec.set(node1, "hostname", 'zotacM20')
ec.set(node1, "slicename", slicename)
ec.set(node1, "sfauser", sfauser)
os.path.dirname(os.path.realpath(__file__)), "repoFile1.0.8.2")
def get_simulator(ec):
- simulator = ec.filter_resources("LinuxNS3Simulation")
+ simulator = ec.filter_resources("linux::ns3::Simulation")
if not simulator:
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", "localhost")
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "enableDump", True)
ec.set(simu, "StopTime", STOP_TIME)
ec.register_connection(simu, node)
host = ec.netgraph.node_annotation(nid, "host")
# Add dce ccnd to the dce node
- ccnd = ec.register_resource("ns3::LinuxDceCCND")
+ ccnd = ec.register_resource("linux::ns3::dce::CCND")
ec.set (ccnd, "stackSize", 1<<20)
ec.set (ccnd, "debug", 7)
ec.set (ccnd, "capacity", 50000)
host = ec.netgraph.node_annotation(nid, "host")
# Add a CCN content repository to the dce node
- ccnr = ec.register_resource("ns3::LinuxDceCCNR")
+ ccnr = ec.register_resource("linux::ns3::dce::CCNR")
ec.set (ccnr, "repoFile1", repofile)
ec.set (ccnr, "stackSize", 1<<20)
ec.set (ccnr, "StartTime", "2s")
host = ec.netgraph.node_annotation(nid, "host")
# Add a ccncat application to the dce host
- ccncat = ec.register_resource("ns3::LinuxDceCCNCat")
+ ccncat = ec.register_resource("linux::ns3::dce::CCNCat")
ec.set (ccncat, "contentName", content_name)
ec.set (ccncat, "stackSize", 1<<20)
ec.set (ccncat, "StartTime", "8s")
ip2 = net[nid2]
# Add FIB entry between peer hosts
- ccndc = ec.register_resource("ns3::LinuxDceFIBEntry")
+ ccndc = ec.register_resource("linux::ns3::dce::FIBEntry")
ec.set (ccndc, "protocol", "udp")
ec.set (ccndc, "uri", "ccnx:/")
ec.set (ccndc, "host", ip2)
print "Results stored at", ec.exp_dir
#### Retrieve the consumer to wait for ot to finish
- ccncat = ec.filter_resources("ns3::LinuxDceCCNCat")
+ ccncat = ec.filter_resources("linux::ns3::dce::CCNCat")
#### Run experiment until metric convergences
rnr = ExperimentRunner()
"repoFile1.0.8.2")\r
\r
def get_simulator(ec):\r
- simulator = ec.filter_resources("LinuxNS3Simulation")\r
+ simulator = ec.filter_resources("linux::ns3::Simulation")\r
\r
if not simulator:\r
- node = ec.register_resource("LinuxNode")\r
+ node = ec.register_resource("linux::Node")\r
ec.set(node, "hostname", "localhost")\r
\r
- simu = ec.register_resource("LinuxNS3Simulation")\r
+ simu = ec.register_resource("linux::ns3::Simulation")\r
ec.register_connection(simu, node)\r
return simu\r
\r
host = ec.netgraph.node_annotation(nid, "host")\r
\r
# Add dce ccnd to the dce node\r
- ccnd = ec.register_resource("ns3::LinuxDceCCND")\r
+ ccnd = ec.register_resource("linux::ns3::dce::CCND")\r
ec.set (ccnd, "stackSize", 1<<20)\r
ec.set (ccnd, "debug", 7)\r
ec.set (ccnd, "capacity", 50000)\r
host = ec.netgraph.node_annotation(nid, "host")\r
\r
# Add a CCN content repository to the dce node\r
- ccnr = ec.register_resource("ns3::LinuxDceCCNR")\r
+ ccnr = ec.register_resource("linux::ns3::dce::CCNR")\r
ec.set (ccnr, "repoFile1", repofile) \r
ec.set (ccnr, "stackSize", 1<<20)\r
ec.set (ccnr, "StartTime", "2s")\r
host = ec.netgraph.node_annotation(nid, "host")\r
\r
# Add a ccncat application to the dce host\r
- ccncat = ec.register_resource("ns3::LinuxDceCCNCat")\r
+ ccncat = ec.register_resource("linux::ns3::dce::CCNCat")\r
ec.set (ccncat, "contentName", content_name)\r
ec.set (ccncat, "stackSize", 1<<20)\r
ec.set (ccncat, "StartTime", "8s")\r
ip2 = net[nid2]\r
\r
# Add FIB entry between peer hosts\r
- ccndc = ec.register_resource("ns3::LinuxDceFIBEntry")\r
+ ccndc = ec.register_resource("linux::ns3::dce::FIBEntry")\r
ec.set (ccndc, "protocol", "udp") \r
ec.set (ccndc, "uri", "ccnx:/") \r
ec.set (ccndc, "host", ip2)\r
add_dce_ccncat(ec, nid)\r
\r
def wait_guids(ec):\r
- return ec.filter_resources("ns3::LinuxDceCCNCat")\r
+ return ec.filter_resources("linux::ns3::dce::CCNCat")\r
\r
if __name__ == '__main__':\r
\r
hostname = PL_NODES[nid]
# Add a planetlab host to the experiment description
- host = ec.register_resource("PlanetlabNode")
+ host = ec.register_resource("planetlab::Node")
ec.set(host, "hostname", hostname)
ec.set(host, "username", pl_slice)
ec.set(host, "identity", pl_ssh_key)
host = ec.netgraph.node_annotation(nid, "host")
# Add a CCN daemon to the planetlab node
- ccnd = ec.register_resource("LinuxCCND")
+ ccnd = ec.register_resource("linux::CCND")
ec.set(ccnd, "debug", 7)
ec.register_connection(ccnd, host)
ccnd = ec.netgraph.node_annotation(nid, "ccnd")
# Add a CCN content repository to the planetlab node
- ccnr = ec.register_resource("LinuxCCNR")
+ ccnr = ec.register_resource("linux::CCNR")
ec.set(ccnr, "repoFile1", repofile)
ec.register_connection(ccnr, ccnd)
ccnd = ec.netgraph.node_annotation(nid, "ccnd")
# Add a CCN cat application to the planetlab node
- ccncat = ec.register_resource("LinuxCCNCat")
+ ccncat = ec.register_resource("linux::CCNCat")
ec.set(ccncat, "pipeline", pipeline)
ec.set(ccncat, "contentName", content_name)
ec.register_connection(ccncat, ccnd)
hostname2 = ec.netgraph.node_annotation(nid2, "hostname")
# Add a FIB entry between one planetlab node and its peer
- entry = ec.register_resource("LinuxFIBEntry")
+ entry = ec.register_resource("linux::FIBEntry")
ec.set(entry, "host", hostname2)
ec.register_connection(entry, ccnd1)
print "Results stored at", ec.exp_dir
#### Retrieve the content producing resource to wait for ot to finish
- ccncat = ec.filter_resources("LinuxCCNCat")
+ ccncat = ec.filter_resources("linux::CCNCat")
#### Run experiment until metric convergences
rnr = ExperimentRunner()
"repoFile1.0.8.2")\r
\r
def get_simulator(ec):\r
- simulator = ec.filter_resources("LinuxNS3Simulation")\r
+ simulator = ec.filter_resources("linux::ns3::Simulation")\r
\r
if not simulator:\r
- node = ec.register_resource("LinuxNode")\r
+ node = ec.register_resource("linux::Node")\r
ec.set(node, "hostname", "localhost")\r
\r
- simu = ec.register_resource("LinuxNS3Simulation")\r
+ simu = ec.register_resource("linux::ns3::Simulation")\r
ec.register_connection(simu, node)\r
return simu\r
\r
host = ec.netgraph.node_annotation(nid, "host")\r
\r
# Add dce ccnd to the dce node\r
- ccnd = ec.register_resource("ns3::LinuxDceCCND")\r
+ ccnd = ec.register_resource("linux::ns3::dce::CCND")\r
ec.set (ccnd, "stackSize", 1<<20)\r
ec.set (ccnd, "debug", 7)\r
ec.set (ccnd, "capacity", 50000)\r
host = ec.netgraph.node_annotation(nid, "host")\r
\r
# Add a CCN content repository to the dce node\r
- ccnr = ec.register_resource("ns3::LinuxDceCCNR")\r
+ ccnr = ec.register_resource("linux::ns3::dce::CCNR")\r
ec.set (ccnr, "repoFile1", repofile) \r
ec.set (ccnr, "stackSize", 1<<20)\r
ec.set (ccnr, "StartTime", "2s")\r
host = ec.netgraph.node_annotation(nid, "host")\r
\r
# Add a ccncat application to the dce host\r
- ccncat = ec.register_resource("ns3::LinuxDceCCNCat")\r
+ ccncat = ec.register_resource("linux::ns3::dce::CCNCat")\r
ec.set (ccncat, "contentName", content_name)\r
ec.set (ccncat, "stackSize", 1<<20)\r
ec.set (ccncat, "StartTime", "8s")\r
ip2 = net[nid2]\r
\r
# Add FIB entry between peer hosts\r
- ccndc = ec.register_resource("ns3::LinuxDceFIBEntry")\r
+ ccndc = ec.register_resource("linux::ns3::dce::FIBEntry")\r
ec.set (ccndc, "protocol", "udp") \r
ec.set (ccndc, "uri", "ccnx:/") \r
ec.set (ccndc, "host", ip2)\r
hostname = NODES[nid]\r
\r
# Add a planetlab host to the experiment description\r
- host = ec.register_resource("PlanetlabNode")\r
+ host = ec.register_resource("planetlab::Node")\r
ec.set(host, "hostname", hostname)\r
ec.set(host, "username", pl_slice)\r
ec.set(host, "identity", pl_ssh_key)\r
host = ec.netgraph.node_annotation(nid, "host")\r
\r
# Add a CCN daemon to the planetlab node\r
- ccnd = ec.register_resource("LinuxCCND")\r
+ ccnd = ec.register_resource("linux::CCND")\r
ec.set(ccnd, "debug", 7)\r
ec.register_connection(ccnd, host)\r
\r
ccnd = ec.netgraph.node_annotation(nid, "ccnd")\r
\r
# Add a CCN content repository to the planetlab node\r
- ccnr = ec.register_resource("LinuxCCNR")\r
+ ccnr = ec.register_resource("linux::CCNR")\r
\r
ec.set(ccnr, "repoFile1", repofile)\r
ec.register_connection(ccnr, ccnd)\r
ccnd = ec.netgraph.node_annotation(nid, "ccnd")\r
\r
# Add a CCN cat application to the planetlab node\r
- ccncat = ec.register_resource("LinuxCCNCat")\r
+ ccncat = ec.register_resource("linux::CCNCat")\r
ec.set(ccncat, "contentName", content_name)\r
ec.register_connection(ccncat, ccnd)\r
\r
hostname2 = ec.netgraph.node_annotation(nid2, "hostname")\r
\r
# Add a FIB entry between one planetlab node and its peer\r
- entry = ec.register_resource("LinuxFIBEntry")\r
+ entry = ec.register_resource("linux::FIBEntry")\r
ec.set(entry, "host", hostname2)\r
ec.register_connection(entry, ccnd1)\r
\r
add_pl_ccncat(ec, nid)\r
\r
def wait_guids(ec):\r
- return ec.filter_resources("LinuxCCNCat")\r
+ return ec.filter_resources("linux::CCNCat")\r
\r
if __name__ == '__main__':\r
\r
ec = ExperimentController(exp_id = "dce-custom-dlm-ping")
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", "localhost")
ec.set(node, "cleanProcesses", True)
-simu = ec.register_resource("LinuxNS3Simulation")
+simu = ec.register_resource("linux::ns3:Simulation")
ec.set(simu, "verbose", True)
#ec.set(simu, "enableDump", True)
ec.register_connection(simu, node)
ec.register_connection(chan, dev2)
### create applications
-ping = ec.register_resource("ns3::LinuxDceApplication")
+ping = ec.register_resource("linux::ns3::dce::Application")
ec.set (ping, "sources", "http://www.skbuff.net/iputils/iputils-s20101006.tar.bz2")
ec.set (ping, "build", "tar xvjf ${SRC}/iputils-s20101006.tar.bz2 && "
"cd iputils-s20101006/ && "
ec = ExperimentController(exp_id = "dce-custom-csma-ping")
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", "localhost")
ec.set(node, "cleanProcesses", True)
-simu = ec.register_resource("LinuxNS3Simulation")
+simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
ec.register_connection(chan, dev2)
### create applications
-ping = ec.register_resource("ns3::LinuxDceApplication")
+ping = ec.register_resource("linux::ns3::dce::Application")
ec.set (ping, "sources", "http://www.skbuff.net/iputils/iputils-s20101006.tar.bz2")
ec.set (ping, "build", "tar xvjf ${SRC}/iputils-s20101006.tar.bz2 && "
"cd iputils-s20101006/ && "
ec = ExperimentController(exp_id = "dce-custom-ccn")
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", "localhost")
ec.set(node, "cleanProcesses", True)
-simu = ec.register_resource("LinuxNS3Simulation")
+simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
# Add a LinuxCCNDceApplication to ns-3 node 1 to install custom ccnx sources
# and run a CCNx daemon
-ccnd1 = ec.register_resource("ns3::LinuxCCNDceApplication")
+ccnd1 = ec.register_resource("linux::ns3::dce::CCNApplication")
# NOTE THAT INSTALLATION MIGHT FAIL IF openjdk-6-jdk is not installed
ec.set(ccnd1, "depends", "libpcap0.8-dev openjdk-6-jdk ant1.8 autoconf "
"libssl-dev libexpat-dev libpcap-dev libecryptfs0 libxml2-utils auto"
"..", "..", "test", "resources", "linux",
"ns3", "ccn", "repoFile1")
-ccnr = ec.register_resource("ns3::LinuxCCNDceApplication")
+ccnr = ec.register_resource("linux::ns3::dce::CCNApplication")
ec.set (ccnr, "binary", "ccnr")
ec.set (ccnr, "environment", "CCNR_DIRECTORY=/REPO/")
ec.set (ccnr, "files", "%s=/REPO/repoFile1" % repofile)
# daemon. Note that the CCNx sources and build instructions
# do not need to be specified again (NEPI will take the
# instructions from the first definition).
-ccnd2 = ec.register_resource("ns3::LinuxCCNDceApplication")
+ccnd2 = ec.register_resource("linux::ns3::dce::CCNApplication")
ec.set (ccnd2, "binary", "ccnd")
ec.set (ccnd2, "stackSize", 1<<20)
ec.set (ccnd2, "environment", "CCND_CAP=50000; CCND_DEBUG=7")
# Add DCE application to configure peer CCN faces between
# nodes
-ccndc1 = ec.register_resource("ns3::LinuxCCNDceApplication")
+ccndc1 = ec.register_resource("linux::ns3::dce::CCNApplication")
ec.set (ccndc1, "binary", "ccndc")
ec.set (ccndc1, "arguments", "-v;add;ccnx:/;udp;10.0.0.2")
ec.set (ccndc1, "stackSize", 1<<20)
ec.set (ccndc1, "StopTime", "120s")
ec.register_connection(ccndc1, nsnode1)
-ccndc2 = ec.register_resource("ns3::LinuxCCNDceApplication")
+ccndc2 = ec.register_resource("linux::ns3::dce::CCNApplication")
ec.set (ccndc2, "binary", "ccndc")
ec.set (ccndc2, "arguments", "-v;add;ccnx:/;udp;10.0.0.1")
ec.set (ccndc2, "stackSize", 1<<20)
ec.register_connection(ccndc2, nsnode2)
# Add a DCE application to perform a ccncat and retrieve content
-ccncat = ec.register_resource("ns3::LinuxCCNDceApplication")
+ccncat = ec.register_resource("linux::ns3::dce::CCNApplication")
ec.set (ccncat, "binary", "ccncat")
ec.set (ccncat, "arguments", "ccnx:/test/bunny.ts")
ec.set (ccncat, "stdinFile", "")
ec = ExperimentController(exp_id = "dce-custom-p2p-ping")
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", "localhost")
ec.set(node, "cleanProcesses", True)
-simu = ec.register_resource("LinuxNS3Simulation")
+simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
ec.register_connection(chan, dev2)
### create applications
-ping = ec.register_resource("ns3::LinuxDceApplication")
+ping = ec.register_resource("linux::ns3::dce::Application")
ec.set (ping, "sources", "http://www.skbuff.net/iputils/iputils-s20101006.tar.bz2")
ec.set (ping, "build", "tar xvjf ${SRC}/iputils-s20101006.tar.bz2 && "
"cd iputils-s20101006/ && "
ec = ExperimentController(exp_id = "dce-custom-wifi-ping")
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", "localhost")
ec.set(node, "cleanProcesses", True)
-simu = ec.register_resource("LinuxNS3Simulation")
+simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
ec.register_connection(chan, phy2)
### create applications
-ping = ec.register_resource("ns3::LinuxDceApplication")
+ping = ec.register_resource("linux::ns3::dce::Application")
ec.set (ping, "sources", "http://www.skbuff.net/iputils/iputils-s20101006.tar.bz2")
ec.set (ping, "build", "tar xvjf ${SRC}/iputils-s20101006.tar.bz2 && "
"cd iputils-s20101006/ && "
ec = ExperimentController(exp_id = "dce-ccncat")
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", "localhost")
ec.set(node, "cleanProcesses", True)
-simu = ec.register_resource("LinuxNS3Simulation")
+simu = ec.register_resource("linux::ns3::Simulation")
ec.register_connection(simu, node)
nsnode1 = add_ns3_node(ec, simu)
### create applications
# Add ccnd to ns-3 node1
-ccnd1 = ec.register_resource("ns3::LinuxDceCCND")
+ccnd1 = ec.register_resource("linux::ns3::dce::CCND")
ec.set (ccnd1, "stackSize", 1<<20)
ec.set (ccnd1, "debug", 7)
ec.set (ccnd1, "capacity", 50000)
"..", "..", "test", "resources", "linux",
"ns3", "ccn", "repoFile1")
-ccnr = ec.register_resource("ns3::LinuxDceCCNR")
+ccnr = ec.register_resource("linux::ns3::dce::CCNR")
ec.set (ccnr, "repoFile1", repofile)
ec.set (ccnr, "stackSize", 1<<20)
ec.set (ccnr, "StartTime", "2s")
ec.register_connection(ccnr, nsnode1)
# Add CCN repository with content to ns-3 node2
-ccnd2 = ec.register_resource("ns3::LinuxDceCCND")
+ccnd2 = ec.register_resource("linux::ns3::dce::CCND")
ec.set (ccnd2, "stackSize", 1<<20)
ec.set (ccnd2, "debug", 7)
ec.set (ccnd2, "capacity", 50000)
ec.register_connection(ccnd2, nsnode2)
# Add face from ns-3 node1 to ns-3 node2
-ccndc1 = ec.register_resource("ns3::LinuxDceFIBEntry")
+ccndc1 = ec.register_resource("linux::ns3::dce::FIBEntry")
ec.set (ccndc1, "protocol", "udp")
ec.set (ccndc1, "uri", "ccnx:/")
ec.set (ccndc1, "host", "10.0.0.2")
ec.register_connection(ccndc1, nsnode1)
# Add face from ns-3 node2 to ns-3 node1
-ccndc2 = ec.register_resource("ns3::LinuxDceFIBEntry")
+ccndc2 = ec.register_resource("linux::ns3::dce::FIBEntry")
ec.set (ccndc2, "protocol", "udp")
ec.set (ccndc2, "uri", "ccnx:/")
ec.set (ccndc2, "host", "10.0.0.1")
ec.register_connection(ccndc2, nsnode2)
# Add a ccncat to node2 to retrieve content
-ccncat = ec.register_resource("ns3::LinuxDceCCNCat")
+ccncat = ec.register_resource("linux::ns3::dce::CCNCat")
ec.set (ccncat, "contentName", "ccnx:/test/bunny.ts")
ec.set (ccncat, "stackSize", 1<<20)
ec.set (ccncat, "StartTime", "4s")
ec = ExperimentController(exp_id = "dce-local-ccnpeek")
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", "localhost")
ec.set(node, "cleanProcesses", True)
-simu = ec.register_resource("LinuxNS3Simulation")
+simu = ec.register_resource("linux::ns3::Simulation")
ec.register_connection(simu, node)
nsnode = add_ns3_node(ec, simu)
### create applications
-ccnd = ec.register_resource("ns3::LinuxDceCCND")
+ccnd = ec.register_resource("linux::ns3::dce::CCND")
ec.set (ccnd, "stackSize", 1<<20)
ec.set (ccnd, "StartTime", "1s")
ec.register_connection(ccnd, nsnode)
-ccnpoke = ec.register_resource("ns3::LinuxDceCCNPoke")
+ccnpoke = ec.register_resource("linux::ns3::dce::CCNPoke")
ec.set (ccnpoke, "contentName", "ccnx:/chunk0")
ec.set (ccnpoke, "content", "DATA")
ec.set (ccnpoke, "stackSize", 1<<20)
ec.set (ccnpoke, "StartTime", "2s")
ec.register_connection(ccnpoke, nsnode)
-ccnpeek = ec.register_resource("ns3::LinuxDceCCNPeek")
+ccnpeek = ec.register_resource("linux::ns3::dce::CCNPeek")
ec.set (ccnpeek, "contentName", "ccnx:/chunk0")
ec.set (ccnpeek, "stackSize", 1<<20)
ec.set (ccnpeek, "StartTime", "4s")
ec = ExperimentController(exp_id = "dce-ping-app")
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", "localhost")
ec.set(node, "cleanProcesses", True)
-simu = ec.register_resource("LinuxNS3Simulation")
+simu = ec.register_resource("linux::ns3::Simulation")
ec.register_connection(simu, node)
nsnode1 = add_ns3_node(ec, simu)
ec.register_connection(chan, dev2)
### create applications
-ping = ec.register_resource("ns3::LinuxDcePing")
+ping = ec.register_resource("linux::ns3::dce::Ping")
ec.set (ping, "stackSize", 1<<20)
ec.set (ping, "target", "10.0.0.2")
ec.set (ping, "count", "10")
##### CONFIGURING NODE 1
## Register node 1
-node1 = ec.register_resource("LinuxNode")
+node1 = ec.register_resource("linux::Node")
# Set the hostname of the first node to use for the experiment
ec.set(node1, "hostname", hostname1)
# username should be your SSH user
ec.set(node1, "cleanProcesses", True)
## Register a CCN daemon in node 1
-ccnd1 = ec.register_resource("LinuxCCND")
+ccnd1 = ec.register_resource("linux::CCND")
# Set ccnd log level to 7
ec.set(ccnd1, "debug", 7)
ec.register_connection(ccnd1, node1)
## Register a repository in node 1
-ccnr1 = ec.register_resource("LinuxCCNR")
+ccnr1 = ec.register_resource("linux::CCNR")
ec.register_connection(ccnr1, ccnd1)
## Push the file into the repository
content_name = "ccnx:/test/FILE"
# Add a content to the repository
-co = ec.register_resource("LinuxCCNContent")
+co = ec.register_resource("linux::CCNContent")
ec.set(co, "contentName", content_name)
# NEPI will upload the specified file to the remote node and write it
# into the CCN repository
##### CONFIGURING NODE 2
## Register node 2
-node2 = ec.register_resource("LinuxNode")
+node2 = ec.register_resource("linux::Node")
# Set the hostname of the first node to use for the experiment
ec.set(node2, "hostname", hostname2)
# username should be your SSH user
ec.set(node2, "cleanProcesses", True)
## Register a CCN daemon in node 2
-ccnd2 = ec.register_resource("LinuxCCND")
+ccnd2 = ec.register_resource("linux::CCND")
# Set ccnd log level to 7
ec.set(ccnd2, "debug", 7)
ec.register_connection(ccnd2, node2)
## Retrieve the file stored in node 1 from node 2
-ccncat = ec.register_resource("LinuxCCNCat")
+ccncat = ec.register_resource("linux::CCNCat")
ec.set(ccncat, "contentName", content_name)
ec.register_connection(ccncat, ccnd2)
##### INTERCONNECTING CCN NODES ...
# Register a FIB entry from node 1 to node 2
-entry1 = ec.register_resource("LinuxFIBEntry")
+entry1 = ec.register_resource("linux::FIBEntry")
ec.set(entry1, "host", hostname2)
ec.register_connection(entry1, ccnd1)
# Register a FIB entry from node 2 to node 1
-entry2 = ec.register_resource("LinuxFIBEntry")
+entry2 = ec.register_resource("linux::FIBEntry")
ec.set(entry2, "host", hostname1)
ec.register_connection(entry2, ccnd2)
ssh_key = options.ssh_key
def add_node(ec, host, user, ssh_key = None):
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
ec.set(node, "identity", ssh_key)
command += " ; ".join(peers) + " && "
command += " ccnr & "
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
ec.set(app, "depends", depends)
ec.set(app, "sources", sources)
ec.set(app, "install", install)
env = "PATH=$PATH:${BIN}/ccnx-0.8.2/bin"
command = "ccnseqwriter -r %s" % content_name
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
ec.set(app, "stdin", movie)
ec.set(app, "env", env)
ec.set(app, "command", command)
env = "PATH=$PATH:${BIN}/ccnx-0.8.2/bin"
command = "ccncat %s" % content_name
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
ec.set(app, "env", env)
ec.set(app, "command", command)
ec = ExperimentController(exp_id = "src-up-exp")
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", hostname)
ec.set(node, "username", username)
ec.set(node, "identity", ssh_key)
-ec.set(node, "cleanHome", True)
+ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
path_to_sources = os.path.join(
os.path.dirname(os.path.realpath(__file__)),
"hello.c")
-app = ec.register_resource("LinuxApplication")
+app = ec.register_resource("linux::Application")
ec.set(app, "sources", path_to_sources)
ec.set(app, "build", "gcc ${SRC}/hello.c -o ${BIN}/hello")
ec.set(app, "command", "${BIN}/hello")
ec = ExperimentController(exp_id = "nc_file_transfer")
## Register node 1
-node1 = ec.register_resource("LinuxNode")
+node1 = ec.register_resource("linux::Node")
# Set the hostname of the first node to use for the experiment
ec.set(node1, "hostname", hostname1)
# username should be your SSH user
ec.set(node1, "cleanProcesses", True)
## Register node 2
-node2 = ec.register_resource("LinuxNode")
+node2 = ec.register_resource("linux::Node")
# Set the hostname of the first node to use for the experiment
ec.set(node2, "hostname", hostname2)
# username should be your SSH user
command = "cat ${SHARE}/%s | pv -fbt 2> bw.txt | nc %s 1234" % (
video, hostname2 )
-server = ec.register_resource("LinuxApplication")
+server = ec.register_resource("linux::Application")
ec.set(server, "depends", "pv nc tcpdump")
ec.set(server, "files", local_path_to_video)
ec.set(server, "command", command)
# if not nc in the client side close the socket suddently if runned in background
command = "nc -dl 1234 > %s" % video
-client = ec.register_resource("LinuxApplication")
+client = ec.register_resource("linux::Application")
ec.set(client, "depends", "nc")
ec.set(client, "command", command)
ec.register_connection(client, node2)
# Register a tcpdump in the server node to monitor the file transfer
command = "tcpdump -ni eth0 -w file_transfer.pcap -s0 port 1234 2>&1"
-capture = ec.register_resource("LinuxApplication")
+capture = ec.register_resource("linux::Application")
ec.set(capture, "depends", "tcpdump")
ec.set(capture, "command", command)
ec.set(capture, "sudo", True)
ec = ExperimentController(exp_id="ath5k")\r
\r
for hostname in hosts:\r
- node = ec.register_resource("LinuxNode")\r
- ec.set(node, "username", username)\r
- ec.set(node, "hostname", hostname)\r
- ec.set(node, "gateway", gateway )\r
- ec.set(node, "gatewayUser", gateway_username)\r
- ec.set(node, "cleanExperiment", True)\r
+ node = ec.register_resource("linux::Node")\r
+ ec.set(node, "username", username)\r
+ ec.set(node, "hostname", hostname)\r
+ ec.set(node, "gateway", gateway)\r
+ ec.set(node, "gatewayUser", gateway_username)\r
+ ec.set(node, "cleanExperiment", True)\r
\r
- app = ec.register_resource("LinuxApplication")\r
- ec.set(app, "command", "modprobe ath5k && ip a | grep wlan0 && service omf_rc restart")\r
- ec.register_connection(app, node)\r
+ app = ec.register_resource("linux::Application")\r
+ ec.set(app, "command", "modprobe ath5k && ip a | grep wlan0 && service omf_rc restart")\r
+ ec.register_connection(app, node)\r
\r
- apps.append(app)\r
+ apps.append(app)\r
\r
ec.deploy()\r
ec.wait_finished(apps)\r
\r
for app in apps:\r
- print ec.trace(app, "stdout") \r
+ print ec.trace(app, "stdout") \r
\r
\r
ec = ExperimentController(exp_id = "ping-exp")
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", hostname)
ec.set(node, "username", username)
ec.set(node, "identity", ssh_key)
-ec.set(node, "cleanHome", True)
+ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
-app = ec.register_resource("LinuxApplication")
+app = ec.register_resource("linux::Application")
ec.set(app, "command", "ping -c3 nepi.inria.fr")
ec.register_connection(app, node)
import time
def add_node(ec, host, user, ssh_key = None):
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
ec.set(node, "identity", ssh_key)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
return node
command += " ; ".join(peers) + " && "
command += " ccnr & "
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
ec.set(app, "depends", depends)
ec.set(app, "sources", sources)
ec.set(app, "install", install)
env = "PATH=$PATH:${BIN}/ccnx-0.7.1/bin"
command = "ccnseqwriter -r ccnx:/VIDEO"
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
ec.set(app, "stdin", movie)
ec.set(app, "env", env)
ec.set(app, "command", command)
env = "PATH=$PATH:${BIN}/ccnx-0.7.1/bin"
command = "sudo -S dbus-uuidgen --ensure ; ( ccncat ccnx:/VIDEO | vlc - ) "
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
ec.set(app, "depends", "vlc")
ec.set(app, "forwardX11", True)
ec.set(app, "env", env)
import time
def add_node(ec, host, user, ssh_key = None):
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linuxNode")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
ec.set(node, "identity", ssh_key)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
return node
def add_ccnd(ec, node):
- ccnd = ec.register_resource("LinuxCCND")
+ ccnd = ec.register_resource("linux::CCND")
ec.set(ccnd, "debug", 7)
ec.register_connection(ccnd, node)
return ccnd
def add_ccnr(ec, ccnd):
- ccnr = ec.register_resource("LinuxCCNR")
+ ccnr = ec.register_resource("linux::CCNR")
ec.register_connection(ccnr, ccnd)
return ccnr
def add_fib_entry(ec, ccnd, peer_host):
- entry = ec.register_resource("LinuxFIBEntry")
+ entry = ec.register_resource("linux::FIBEntry")
ec.set(entry, "host", peer_host)
ec.register_connection(entry, ccnd)
return entry
def add_content(ec, ccnr, content_name, content):
- co = ec.register_resource("LinuxCCNContent")
+ co = ec.register_resource("linux::CCNContent")
ec.set(co, "contentName", content_name)
ec.set(co, "content", content)
ec.register_connection(co, ccnr)
command = "ccnpeek %(content_name)s; ccncat %(content_name)s" % {
"content_name" : content_name}
- app = ec.register_resource("LinuxCCNApplication")
+ app = ec.register_resource("linux::CCNApplication")
ec.set(app, "command", command)
ec.register_connection(app, ccnd)
ec = ExperimentController(exp_id)
# server
-node1 = ec.register_resource("LinuxNode")
+node1 = ec.register_resource("linux::Node")
ec.set(node1, "hostname", "wlab29.")
ec.set(node1, "username", "root")
ec.set(node1, "gatewayUser", "etourdi")
ec.set(node1, "gateway", "etourdi.pl.sophia.inria.fr")
-ec.set(node1, "cleanHome", True)
+ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
# client
-node2 = ec.register_resource("LinuxNode")
+node2 = ec.register_resource("linux::Node")
ec.set(node2, "hostname", "wlab5.")
ec.set(node2, "username", "root")
ec.set(node2, "gatewayUser", "etourdi")
ec.set(node2, "gateway", "etourdi.pl.sophia.inria.fr")
-ec.set(node2, "cleanHome", True)
+ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
-app1 = ec.register_resource("LinuxApplication")
+app1 = ec.register_resource("linux::Application")
video= "../big_buck_bunny_240p_mpeg4_lq.ts"
ec.set(app1, "sources", video)
command = "cat ${SRC}/big_buck_bunny_240p_mpeg4_lq.ts| nc wlab5. 1234"
ec.set(app1, "command", command)
ec.register_connection(app1, node1)
-app2 = ec.register_resource("LinuxApplication")
+app2 = ec.register_resource("linux::Application")
command = "nc -dl 1234 > big_buck_copied_movie.ts"
ec.set(app2, "command", command)
ec.register_connection(app2, node2)
import time
def add_node(ec, host, user):
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
return node
def add_app(ec):
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
ec.set(app, "command", "sleep 30; echo 'HOLA'")
return app
ec = ExperimentController(exp_id = "vlc_streamming")
## Register node 1
-node1 = ec.register_resource("LinuxNode")
+node1 = ec.register_resource("linux::Node")
# Set the hostname of the first node to use for the experiment
ec.set(node1, "hostname", hostname1)
# username should be your SSH user
ec.set(node1, "cleanProcesses", True)
## Register node 2
-node2 = ec.register_resource("LinuxNode")
+node2 = ec.register_resource("linux::Node")
# Set the hostname of the first node to use for the experiment
ec.set(node2, "hostname", hostname2)
# username should be your SSH user
"--sout '#rtp{dst=%s,port=5004,mux=ts}' vlc://quit") % \
(video, hostname2)
-server = ec.register_resource("LinuxApplication")
+server = ec.register_resource("linux::Application")
ec.set(server, "depends", "vlc")
ec.set(server, "files", local_path_to_video)
ec.set(server, "command", command)
"--sout '#std{access=file,mux=ts,dst=VIDEO}'") % \
(hostname2, video)
-client = ec.register_resource("LinuxApplication")
+client = ec.register_resource("linux::Application")
ec.set(client, "depends", "vlc")
ec.set(client, "command", command)
ec.register_connection(client, node2)
ec = ExperimentController(exp_id = "ns3-csma-p2p-ping")
# Simulation will run in a remote machine
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", "localhost")
# Add a simulation resource
-simu = ec.register_resource("LinuxNS3Simulation")
+simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.set(simu, "enableDump", True)
ec.register_connection(simu, node)
ec = ExperimentController(exp_id = "ns3-local-csma-ping")
# Simulation will executed in the local machine
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", "localhost")
# Add a simulation resource
-simu = ec.register_resource("LinuxNS3Simulation")
+simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
ec = ExperimentController(exp_id = "ns3-wifi-ping")
# Simulation will run in a remote machine
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", "localhost")
# Add a simulation resource
-simu = ec.register_resource("LinuxNS3Simulation")
+simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.set(simu, "enableDump", True)
ec.set (simu, "StopTime", "22s")
ec = ExperimentController(exp_id = "ns3-local-p2p-ping")
# Simulation will executed in the local machine
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", "localhost")
# Add a simulation resource
-simu = ec.register_resource("LinuxNS3Simulation")
+simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
ec = ExperimentController(exp_id = "ns3-local-wifi-ping")
# Simulation will executed in the local machine
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", "localhost")
# Add a simulation resource
-simu = ec.register_resource("LinuxNS3Simulation")
+simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
ec = ExperimentController(exp_id = "ns3-remote-p2p-ping")
# Simulation will run in a remote machine
-node = ec.register_resource("LinuxNode")
+node = ec.register_resource("linux::Node")
ec.set(node, "hostname", hostname)
ec.set(node, "username", username)
ec.set(node, "identity", identity)
ec.set(node, "cleanExperiment", True)
# Add a simulation resource
-simu = ec.register_resource("LinuxNS3Simulation")
+simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
# Create and Configure the Nodes
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
ec.set(node1, "hostname", nodex)
ec.set(node1, "xmppUser", slicename)
ec.set(node1, "xmppServer", "xmpp.ilabt.iminds.be")
ec.set(node1, "xmppPort", "5222")
ec.set(node1, "xmppPassword", "1234")
-iface1 = ec.register_resource("OMFWifiInterface")
+iface1 = ec.register_resource("omf::WifiInterface")
ec.set(iface1, "name", "wlan0")
ec.set(iface1, "mode", "adhoc")
ec.set(iface1, "hw_mode", "g")
ec.set(iface1, "ip", "192.168.0.1/24")
ec.register_connection(iface1, node1)
-node2 = ec.register_resource("OMFNode")
+node2 = ec.register_resource("omf::Node")
ec.set(node2, "hostname", nodez)
ec.set(node2, "xmppUser", slicename)
ec.set(node2, "xmppServer", "xmpp.ilabt.iminds.be")
ec.set(node2, "xmppPort", "5222")
ec.set(node2, "xmppPassword", "1234")
-iface2 = ec.register_resource("OMFWifiInterface")
+iface2 = ec.register_resource("omf::WifiInterface")
ec.set(iface2, "name", "wlan0")
ec.set(iface2, "mode", "adhoc")
ec.set(iface2, "hw_mode", "g")
ec.set(iface2, "ip", "192.168.0.2/24")
ec.register_connection(iface2, node2)
-channel = ec.register_resource("OMFChannel")
+channel = ec.register_resource("omf::Channel")
ec.set(channel, "channel", "6")
ec.register_connection(iface1, channel)
ec.register_connection(iface2, channel)
# Create and Configure the Application
-app1 = ec.register_resource("OMFApplication")
+app1 = ec.register_resource("omf::Application")
ec.set(app1, "command", "ping -c3 192.168.0.2")
ec.register_connection(app1, node1)
# Create and Configure the Nodes
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
ec.set(node1, "hostname", nodex)
ec.set(node1, "xmppUser", slicename)
ec.set(node1, "xmppServer", "xmpp.ilabt.iminds.be")
ec.set(node1, "xmppPort", "5222")
ec.set(node1, "xmppPassword", "1234")
-iface1 = ec.register_resource("OMFWifiInterface")
+iface1 = ec.register_resource("omf::WifiInterface")
ec.set(iface1, "name", "wlan0")
ec.set(iface1, "mode", "adhoc")
ec.set(iface1, "hw_mode", "g")
ec.set(iface1, "ip", "192.168.0.1/24")
ec.register_connection(iface1, node1)
-node2 = ec.register_resource("OMFNode")
+node2 = ec.register_resource("omf::Node")
ec.set(node2, "hostname", nodez)
ec.set(node2, "xmppUser", slicename)
ec.set(node2, "xmppServer", "xmpp.ilabt.iminds.be")
ec.set(node2, "xmppPort", "5222")
ec.set(node2, "xmppPassword", "1234")
-iface2 = ec.register_resource("OMFWifiInterface")
+iface2 = ec.register_resource("omf::WifiInterface")
ec.set(iface2, "name", "wlan0")
ec.set(iface2, "mode", "adhoc")
ec.set(iface2, "hw_mode", "g")
ec.set(iface2, "ip", "192.168.0.2/24")
ec.register_connection(iface2, node2)
-channel = ec.register_resource("OMFChannel")
+channel = ec.register_resource("omf::Channel")
ec.set(channel, "channel", "6")
ec.register_connection(iface1, channel)
ec.register_connection(iface2, channel)
client_ip = "192.168.0.2"
# Create and Configure the Application
-app1 = ec.register_resource("OMFApplication")
+app1 = ec.register_resource("omf::Application")
ec.set(app1, "command",
"/root/vlc/vlc-1.1.13/cvlc /root/10-by-p0d.avi --sout '#rtp{dst=%s,port=5004,mux=ts}'" % client_ip)
ec.register_connection(app1, node1)
## Add a OMFApplication to run the client VLC
-app2 = ec.register_resource("OMFApplication")
+app2 = ec.register_resource("omf::Application")
## Send the transmitted video to a file.
ec.set(app2, "command", "/root/vlc/vlc-1.1.13/cvlc rtp://%s:5004 --sout '#standard{access=file,mux=ts,dst=/root/video.ts}'" % client_ip)
ec.register_connection(app2, node2)
## Add a OMFApplication to count the number of bytes in the transmitted video
-app3 = ec.register_resource("OMFApplication")
+app3 = ec.register_resource("omf::Application")
## Send the transmitted video to a file.
ec.set(app3, "command", "ls -lah /root/video.ts")
ec.register_connection(app3, node2)
-app4 = ec.register_resource("OMFApplication")
+app4 = ec.register_resource("omf::Application")
ec.set(app4, "command", "/usr/bin/killall vlc_app")
ec.register_connection(app4, node1)
-app5 = ec.register_resource("OMFApplication")
+app5 = ec.register_resource("omf::Application")
ec.set(app5, "command", "/usr/bin/killall vlc_app")
ec.register_connection(app5, node2)
ec = ExperimentController(exp_id="nitos_omf6_ping")
# Create and Configure the Nodes
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
ec.set(node1, "hostname", nodex)
ec.set(node1, "xmppUser", slicename)
ec.set(node1, "xmppServer", "nitlab.inf.uth.gr")
ec.set(node1, "xmppPassword", "1234")
# Create and Configure the Interfaces
-iface1 = ec.register_resource("OMFWifiInterface")
+iface1 = ec.register_resource("omf::WifiInterface")
ec.set(iface1, "name", "wlan0")
ec.set(iface1, "mode", "adhoc")
ec.set(iface1, "hw_mode", "g")
ec.register_connection(node1, iface1)
# Create and Configure the Nodes
-node2 = ec.register_resource("OMFNode")
+node2 = ec.register_resource("omf::Node")
ec.set(node2, "hostname", nodez)
ec.set(node2, "xmppUser", slicename)
ec.set(node2, "xmppServer", "nitlab.inf.uth.gr")
ec.set(node2, "xmppPassword", "1234")
# Create and Configure the Interfaces
-iface2 = ec.register_resource("OMFWifiInterface")
+iface2 = ec.register_resource("omf::WifiInterface")
ec.set(iface2, "name", "wlan0")
ec.set(iface2, "mode", "adhoc")
ec.set(iface2, "hw_mode", "g")
ec.register_connection(node2, iface2)
# Create and Configure the Channel
-channel = ec.register_resource("OMFChannel")
+channel = ec.register_resource("omf::Channel")
ec.set(channel, "channel", chan)
ec.set(channel, "xmppUser", slicename)
ec.set(channel, "xmppServer", "nitlab.inf.uth.gr")
ec.register_connection(iface2, channel)
# Create and Configure the PING Application
-app1 = ec.register_resource("OMFApplication")
+app1 = ec.register_resource("omf::Application")
ec.set(app1, "appid", "Ping#1")
ec.set(app1, "command", "/bin/ping -c3 192.168.0.%s" % nodez[-2:])
ec.register_connection(app1, node1)
ec = ExperimentController(exp_id="nitos_omf6_vlc")
# Create and Configure the Nodes
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
ec.set(node1, "hostname", nodex)
ec.set(node1, "xmppUser", slicename)
ec.set(node1, "xmppServer", "nitlab.inf.uth.gr")
ec.set(node1, "xmppPassword", "1234")
# Create and Configure the Interfaces
-iface1 = ec.register_resource("OMFWifiInterface")
+iface1 = ec.register_resource("omf::WifiInterface")
ec.set(iface1, "name", "wlan0")
ec.set(iface1, "mode", "adhoc")
ec.set(iface1, "hw_mode", "g")
ec.register_connection(node1, iface1)
# Create and Configure the Nodes
-node2 = ec.register_resource("OMFNode")
+node2 = ec.register_resource("omf::Node")
ec.set(node2, "hostname", nodez)
ec.set(node2, "xmppUser", slicename)
ec.set(node2, "xmppServer", "nitlab.inf.uth.gr")
ec.set(node2, "xmppPassword", "1234")
# Create and Configure the Interfaces
-iface2 = ec.register_resource("OMFWifiInterface")
+iface2 = ec.register_resource("omf::WifiInterface")
ec.set(iface2, "name", "wlan0")
ec.set(iface2, "mode", "adhoc")
ec.set(iface2, "hw_mode", "g")
ec.register_connection(node2, iface2)
# Create and Configure the Channel
-channel = ec.register_resource("OMFChannel")
+channel = ec.register_resource("omf::Channel")
ec.set(channel, "channel", chan)
ec.set(channel, "xmppUser", slicename)
ec.set(channel, "xmppServer", "nitlab.inf.uth.gr")
client_ip = "192.168.0.%s" % nodez[-2:]
# Create and Configure the Application
-app1 = ec.register_resource("OMFApplication")
+app1 = ec.register_resource("omf::Application")
ec.set(app1, "command",
"DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority /root/vlc/vlc-1.1.13/cvlc /root/10-by-p0d.avi --sout '#rtp{dst=%s,port=5004,mux=ts}'" % client_ip)
ec.register_connection(app1, node1)
## Add a OMFApplication to run the client VLC and count the numer of bytes
## transmitted, using wc.
-app2 = ec.register_resource("OMFApplication")
+app2 = ec.register_resource("omf::Application")
ec.set(app2, "command",
"DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority /root/vlc/vlc-1.1.13/cvlc rtp://%s:5004 | wc -c "% client_ip)
ec = ExperimentController()
# Create and Configure the Node
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
# If the hostname is not declared, Nepi will take SFA to provision one.
ec.set(node1, 'hostname', 'node0.nepi-robot.nepi.wilab2.ilabt.iminds.be')
# XMPP credentials
ec.set(node1, 'version', "5")
# Create and Configure the Application
-app1 = ec.register_resource("OMFRobotApplication")
+app1 = ec.register_resource("omf::RobotApplication")
ec.set(app1, 'appid', "robot")
ec.set(app1, 'version', "5")
ec.set(app1, 'command', "/users/jtribino/RobotCTRLComm.rb /users/jtribino/coordinate.csv")
### Define OMF Method to simplify definition of resources ###
def add_node(ec, hostname, xmppServer, xmppUser, xmppPort = "5222", xmppPassword = "1234"):
- node = ec.register_resource("OMFNode")
+ node = ec.register_resource("omf::Node")
ec.set(node, 'hostname', hostname)
ec.set(node, 'xmppServer', xmppServer)
ec.set(node, 'xmppUser', xmppUser)
def add_interface(ec, ip, xmppServer, xmppUser, essid = "ccn", name = "wlan0", mode = "adhoc",
typ = "g", xmppPort = "5222", xmppPassword = "1234"):
- iface = ec.register_resource("OMFWifiInterface")
+ iface = ec.register_resource("omf::WifiInterface")
ec.set(iface, 'name', name)
ec.set(iface, 'mode', mode)
ec.set(iface, 'hw_mode', typ)
return iface
def add_channel(ec, channel, xmppServer, xmppUser, xmppPort = "5222", xmppPassword = "1234"):
- chan = ec.register_resource("OMFChannel")
+ chan = ec.register_resource("omf::Channel")
ec.set(chan, 'channel', channel)
ec.set(chan, 'xmppServer', xmppServer)
ec.set(chan, 'xmppUser', xmppUser)
def add_app(ec, appid, command, env, xmppServer, xmppUser,
xmppPort = "5222", xmppPassword = "1234"):
- app = ec.register_resource("OMFApplication")
+ app = ec.register_resource("omf::Application")
ec.set(app, 'appid', appid)
ec.set(app, 'command', command)
ec.set(app, 'env', env)
### Define OMF Method to simplify definition of resources ###
def add_node(ec, hostname, xmppServer, xmppUser, xmppPort = "5222", xmppPassword = "1234"):
- node = ec.register_resource("OMFNode")
+ node = ec.register_resource("omf::Node")
ec.set(node, 'hostname', hostname)
ec.set(node, 'xmppServer', xmppServer)
ec.set(node, 'xmppUser', xmppUser)
def add_interface(ec, ip, xmppServer, xmppUser, essid = "ccn", name = "wlan0", mode = "adhoc",
typ = "g", xmppPort = "5222", xmppPassword = "1234"):
- iface = ec.register_resource("OMFWifiInterface")
+ iface = ec.register_resource("omf::WifiInterface")
ec.set(iface, 'name', name)
ec.set(iface, 'mode', mode)
ec.set(iface, 'hw_mode', typ)
return iface
def add_channel(ec, channel, xmppServer, xmppUser, xmppPort = "5222", xmppPassword = "1234"):
- chan = ec.register_resource("OMFChannel")
+ chan = ec.register_resource("omf::Channel")
ec.set(chan, 'channel', channel)
ec.set(chan, 'xmppServer', xmppServer)
ec.set(chan, 'xmppUser', xmppUser)
def add_app(ec, host, appid, command, env, xmppServer, xmppUser,
xmppPort = "5222", xmppPassword = "1234"):
- app = ec.register_resource("OMFApplication")
+ app = ec.register_resource("omf::Application")
ec.set(app, 'appid', appid)
ec.set(app, 'command', command)
ec.set(app, 'env', env)
ec = ExperimentController()
# Create and Configure the Nodes
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
ec.set(node1, 'hostname', 'omf.nitos.node0XX')
ec.set(node1, 'xmppServer', "ZZZ")
ec.set(node1, 'xmppUser', "nitlab.inf.uth.gr")
ec.set(node1, 'xmppPassword', "1234")
ec.set(node1, 'version', "5")
-node2 = ec.register_resource("OMFNode")
+node2 = ec.register_resource("omf::Node")
ec.set(node2, 'hostname', "omf.nitos.node0YY")
ec.set(node2, 'xmppServer', "ZZZ")
ec.set(node2, 'xmppUser', "nitlab.inf.uth.gr")
ec.set(node2, 'version', "5")
# Create and Configure the Interfaces
-iface1 = ec.register_resource("OMFWifiInterface")
+iface1 = ec.register_resource("omf::WifiInterface")
ec.set(iface1, 'name', "wlan0")
ec.set(iface1, 'mode', "adhoc")
ec.set(iface1, 'hw_mode', "g")
ec.set(iface1, 'ip', "192.168.0.XX/24")
ec.set(iface1, 'version', "5")
-iface2 = ec.register_resource("OMFWifiInterface")
+iface2 = ec.register_resource("omf::WifiInterface")
ec.set(iface2, 'name', "wlan0")
ec.set(iface2, 'mode', "adhoc")
ec.set(iface2, 'hw_mode', 'g')
ec.set(iface2, 'version', "5")
# Create and Configure the Channel
-channel = ec.register_resource("OMFChannel")
+channel = ec.register_resource("omf::Channel")
ec.set(channel, 'channel', "6")
ec.set(channel, 'xmppServer', "ZZZ")
ec.set(channel, 'xmppUser', "nitlab.inf.uth.gr")
ec.set(channel, 'version', "5")
# Create and Configure the Application
-app1 = ec.register_resource("OMFApplication")
+app1 = ec.register_resource("omf::Application")
ec.set(app1, 'appid', 'Vlc#1')
ec.set(app1, 'command', "/root/vlc/vlc-1.1.13/cvlc /root/10-by-p0d.avi --sout '#rtp{dst=192.168.0.YY,port=1234,mux=ts}'")
ec.set(app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
ec.set(app1, 'version', "5")
-app2 = ec.register_resource("OMFApplication")
+app2 = ec.register_resource("omf::Application")
ec.set(app2, 'appid', 'Vlc#2')
ec.set(app2, 'command', "/root/vlc/vlc-1.1.13/cvlc rtp://192.168.0.YY:1234")
ec.set(app2, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
ec.set(app2, 'version', "5")
-app3 = ec.register_resource("OMFApplication")
+app3 = ec.register_resource("omf::Application")
ec.set(app3, 'appid', 'Kill#2')
ec.set(app3, 'command', "/usr/bin/killall vlc_app")
ec.set(app3, 'env', " ")
ec.set(app3, 'version', "5")
-app4 = ec.register_resource("OMFApplication")
+app4 = ec.register_resource("omf::Application")
ec.set(app4, 'appid', 'Kill#1')
ec.set(app4, 'command', "/usr/bin/killall vlc_app")
ec.set(app4, 'env', " ")
ec = ExperimentController()
# Create and Configure the Nodes
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
ec.set(node1, 'hostname', 'omf.nitos.node025')
ec.set(node1, 'xmppServer', "tribino")
ec.set(node1, 'xmppUser', "nitlab.inf.uth.gr")
ec.set(node1, 'xmppPassword', "1234")
ec.set(node1, 'version', "5")
-node2 = ec.register_resource("OMFNode")
+node2 = ec.register_resource("omf::Node")
ec.set(node2, 'hostname', "omf.nitos.node028")
ec.set(node2, 'xmppServer', "tribino")
ec.set(node2, 'xmppUser', "nitlab.inf.uth.gr")
ec.set(node2, 'version', "5")
# Create and Configure the Interfaces
-iface1 = ec.register_resource("OMFWifiInterface")
+iface1 = ec.register_resource("omf::WifiInterface")
ec.set(iface1, 'name', "wlan0")
ec.set(iface1, 'mode', "adhoc")
ec.set(iface1, 'hw_mode', "g")
ec.set(iface1, 'ip', "192.168.0.25/24")
ec.set(iface1, 'version', "5")
-iface2 = ec.register_resource("OMFWifiInterface")
+iface2 = ec.register_resource("omf::WifiInterface")
ec.set(iface2, 'name', "wlan0")
ec.set(iface2, 'mode', "adhoc")
ec.set(iface2, 'hw_mode', 'g')
ec.set(iface2, 'version', "5")
# Create and Configure the Channel
-channel = ec.register_resource("OMFChannel")
+channel = ec.register_resource("omf::Channel")
ec.set(channel, 'channel', "6")
ec.set(channel, 'xmppServer', "tribino")
ec.set(channel, 'xmppUser', "nitlab.inf.uth.gr")
ec.set(channel, 'version', "5")
# Create and Configure the Application
-app1 = ec.register_resource("OMFApplication")
+app1 = ec.register_resource("omf::Application")
ec.set(app1, 'appid', 'Vlc#1')
ec.set(app1, 'command', "/root/vlc/vlc-1.1.13/cvlc /root/10-by-p0d.avi --sout '#rtp{dst=192.168.0.28,port=1234,mux=ts}'")
ec.set(app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
ec.set(app1, 'version', "5")
-app2 = ec.register_resource("OMFApplication")
+app2 = ec.register_resource("omf::Application")
ec.set(app2, 'appid', 'Vlc#2')
ec.set(app2, 'command', "/root/vlc/vlc-1.1.13/cvlc rtp://192.168.0.28:1234")
ec.set(app2, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
ec.set(app2, 'version', "5")
-app3 = ec.register_resource("OMFApplication")
+app3 = ec.register_resource("omf::Application")
ec.set(app3, 'appid', 'Kill#2')
ec.set(app3, 'command', "/usr/bin/killall vlc_app")
ec.set(app3, 'env', " ")
ec.set(app3, 'version', "5")
-app4 = ec.register_resource("OMFApplication")
+app4 = ec.register_resource("omf::Application")
ec.set(app4, 'appid', 'Kill#1')
ec.set(app4, 'command', "/usr/bin/killall vlc_app")
ec.set(app4, 'env', " ")
ec = ExperimentController()
# Create and Configure the Nodes
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
ec.set(node1, 'hostname', 'omf.nitos.node0XX')
ec.set(node1, 'xmppServer', "nitlab.inf.uth.gr")
ec.set(node1, 'xmppUser', "<YOUR-SLICE>")
ec.set(node1, 'version', "5")
# Create and Configure the Interfaces
-iface1 = ec.register_resource("OMFWifiInterface")
+iface1 = ec.register_resource("omf::WifiInterface")
ec.set(iface1, 'name', "wlan0")
ec.set(iface1, 'mode', "adhoc")
ec.set(iface1, 'hw_mode', "g")
ec.set(iface1, 'version', "5")
# Create and Configure the Channel
-channel = ec.register_resource("OMFChannel")
+channel = ec.register_resource("omf::Channel")
ec.set(channel, 'channel', "6")
ec.set(channel, 'xmppServer', "ZZZ")
ec.set(channel, 'xmppUser', "nitlab.inf.uth.gr")
ec.set(channel, 'version', "5")
# Create and Configure the Application
-app1 = ec.register_resource("OMFApplication")
+app1 = ec.register_resource("omf::Application")
ec.set(app1, 'appid', 'XEyes#1')
ec.set(app1, 'command', "/usr/bin/xeyes")
ec.set(app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
ec.set(app1, 'version', "5")
-app2 = ec.register_resource("OMFApplication")
+app2 = ec.register_resource("omf::Application")
ec.set(app2, 'appid', 'Kill#1')
ec.set(app2, 'path', "/usr/bin/kill")
ec.set(app2, 'args', "xeyes")
### Define OMF Method to simplify definition of resources ###
def add_node(ec, hostname, xmppServer, xmppUser, xmppPort = "5222", xmppPassword = "1234"):
- node = ec.register_resource("OMFNode")
+ node = ec.register_resource("omf::Node")
ec.set(node, 'hostname', hostname)
ec.set(node, 'xmppServer', xmppServer)
ec.set(node, 'xmppUser', xmppUser)
def add_interface(ec, ip, xmppServer, xmppUser, essid = "ccn", name = "wlan0", mode = "adhoc",
typ = "g", xmppPort = "5222", xmppPassword = "1234"):
- iface = ec.register_resource("OMFWifiInterface")
+ iface = ec.register_resource("omf::WifiInterface")
ec.set(iface, 'name', name)
ec.set(iface, 'mode', mode)
ec.set(iface, 'hw_mode', typ)
return iface
def add_channel(ec, channel, xmppServer, xmppUser, xmppPort = "5222", xmppPassword = "1234"):
- chan = ec.register_resource("OMFChannel")
+ chan = ec.register_resource("omf::Channel")
ec.set(chan, 'channel', channel)
ec.set(chan, 'xmppServer', xmppServer)
ec.set(chan, 'xmppUser', xmppUser)
def add_app(ec, host, appid, command, env, xmppServer, xmppUser,
xmppPort = "5222", xmppPassword = "1234"):
- app = ec.register_resource("OMFApplication")
+ app = ec.register_resource("omf::Application")
ec.set(app, 'appid', appid)
ec.set(app, 'command', command)
ec.set(app, 'env', env)
ec = ExperimentController()
# Create and Configure the Nodes
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
ec.set(node1, 'hostname', 'omf.plexus.wlab17')
ec.set(node1, 'xmppServer', "nepi")
ec.set(node1, 'xmppUser', "xmpp-plexus.onelab.eu")
ec.set(node1, 'version', "5")
# Create and Configure the Application
-app1 = ec.register_resource("OMFApplication")
+app1 = ec.register_resource("omf::Application")
ec.set(app1, 'appid', "robot")
ec.set(app1, 'command', "/root/CTRL_test.rb coord.csv")
ec.set(app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
ec = ExperimentController()
# Create and Configure the Nodes
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
ec.set(node1, 'hostname', 'omf.plexus.wlab17')
ec.set(node1, 'xmppUser', "nepi")
ec.set(node1, 'xmppServer', "xmpp-plexus.onelab.eu")
ec.set(node1, 'xmppPassword', "1234")
ec.set(node1, 'version', "5")
-node2 = ec.register_resource("OMFNode")
+node2 = ec.register_resource("omf::Node")
ec.set(node2, 'hostname', "omf.plexus.wlab37")
ec.set(node2, 'xmppUser', "nepi")
ec.set(node2, 'xmppServer', "xmpp-plexus.onelab.eu")
ec.set(node2, 'version', "5")
# Create and Configure the Interfaces
-iface1 = ec.register_resource("OMFWifiInterface")
+iface1 = ec.register_resource("omf::WifiInterface")
ec.set(iface1, 'name', "wlan0")
ec.set(iface1, 'mode', "adhoc")
ec.set(iface1, 'hw_mode', "g")
ec.set(iface1, 'ip', "10.0.0.17")
ec.set(iface1, 'version', "5")
-iface2 = ec.register_resource("OMFWifiInterface")
+iface2 = ec.register_resource("omf::WifiInterface")
ec.set(iface2, 'name', "wlan0")
ec.set(iface2, 'mode', "adhoc")
ec.set(iface2, 'hw_mode', 'g')
ec.set(iface2, 'version', "5")
# Create and Configure the Channel
-channel = ec.register_resource("OMFChannel")
+channel = ec.register_resource("omf::Channel")
ec.set(channel, 'channel', "6")
ec.set(channel, 'xmppUser', "nepi")
ec.set(channel, 'xmppServer', "xmpp-plexus.onelab.eu")
ec.set(channel, 'version', "5")
# Create and Configure the Application
-app1 = ec.register_resource("OMFApplication")
+app1 = ec.register_resource("omf::Application")
ec.set(app1, 'appid', 'Vlc#1')
ec.set(app1, 'command', "/opt/vlc-1.1.13/cvlc --quiet /opt/10-by-p0d.avi --sout '#rtp{dst=10.0.0.37,port=1234,mux=ts}'")
#ec.set(app1, 'command', "/opt/vlc-1.1.13/cvlc --quiet /opt/big_buck_bunny_240p_mpeg4.ts --sout '#rtp{dst=10.0.0.XX,port=1234,mux=ts} '")
ec.set(app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
ec.set(app1, 'version', "5")
-app2 = ec.register_resource("OMFApplication")
+app2 = ec.register_resource("omf::Application")
ec.set(app2, 'appid', 'Vlc#2')
ec.set(app2, 'command', "/opt/vlc-1.1.13/cvlc --quiet rtp://10.0.0.37:1234")
ec.set(app2, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
ec.set(app2, 'version', "5")
-app3 = ec.register_resource("OMFApplication")
+app3 = ec.register_resource("omf::Application")
ec.set(app3, 'appid', 'Kill#1')
ec.set(app3, 'command', "/usr/bin/killall vlc")
ec.set(app3, 'env', " ")
ec.set(app3, 'version', "5")
-app4 = ec.register_resource("OMFApplication")
+app4 = ec.register_resource("omf::Application")
ec.set(app4, 'appid', 'Kill#2')
ec.set(app4, 'command', "/usr/bin/killall vlc")
ec.set(app4, 'env', " ")
# Create and Configure the Nodes
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
ec.set(node1, 'hostname', 'servernode.nepivlcexperiment.nepi.wilab2.ilabt.iminds.be')
ec.set(node1, 'xmppServer', "xmpp.ilabt.iminds.be")
ec.set(node1, 'xmppUser', "nepi")
ec.set(node1, 'xmppPort', "5222")
ec.set(node1, 'xmppPassword', "1234")
-iface1 = ec.register_resource("OMFWifiInterface")
+iface1 = ec.register_resource("omf::WifiInterface")
ec.set(iface1, 'name', 'wlan0')
ec.set(iface1, 'mode', "adhoc")
ec.set(iface1, 'hw_mode', "g")
ec.set(iface1, 'essid', "vlc")
ec.set(iface1, 'ip', "192.168.0.1/24")
-node2 = ec.register_resource("OMFNode")
+node2 = ec.register_resource("omf::Node")
ec.set(node2, 'hostname', 'client1node.nepivlcexperiment.nepi.wilab2.ilabt.iminds.be')
ec.set(node2, 'xmppServer', "xmpp.ilabt.iminds.be")
ec.set(node2, 'xmppUser', "nepi")
ec.set(node2, 'xmppPort', "5222")
ec.set(node2, 'xmppPassword', "1234")
-iface2 = ec.register_resource("OMFWifiInterface")
+iface2 = ec.register_resource("omf::WifiInterface")
ec.set(iface2, 'name', 'wlan0')
ec.set(iface2, 'mode', "adhoc")
ec.set(iface2, 'hw_mode', "g")
ec.set(iface2, 'essid', "vlc")
ec.set(iface2, 'ip', "192.168.0.2/24")
-node3 = ec.register_resource("OMFNode")
+node3 = ec.register_resource("omf::Node")
ec.set(node3, 'hostname', 'client2node.nepivlcexperiment.nepi.wilab2.ilabt.iminds.be')
ec.set(node3, 'xmppServer', "xmpp.ilabt.iminds.be")
ec.set(node3, 'xmppUser', "nepi")
ec.set(node3, 'xmppPort', "5222")
ec.set(node3, 'xmppPassword', "1234")
-iface3 = ec.register_resource("OMFWifiInterface")
+iface3 = ec.register_resource("omf::WifiInterface")
ec.set(iface3, 'name', 'wlan0')
ec.set(iface3, 'mode', "adhoc")
ec.set(iface3, 'hw_mode', "g")
ec.set(iface3, 'essid', "vlc")
ec.set(iface3, 'ip', "192.168.0.3/24")
-chan = ec.register_resource("OMFChannel")
+chan = ec.register_resource("omf::Channel")
ec.set(chan, 'channel', "6")
# Create and Configure the Application
-app1 = ec.register_resource("OMFApplication")
+app1 = ec.register_resource("omf::Application")
ec.set(app1, 'command', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority /root/vlc/vlc-1.1.13/cvlc /root/10-by-p0d.avi --sout '#duplicate{dst=rtp{dst=192.168.0.2,port=1234,mux=ts},dst=rtp{dst=192.168.0.3,port=1234,mux=ts}}'")
-app2 = ec.register_resource("OMFApplication")
+app2 = ec.register_resource("omf::Application")
ec.set(app2, 'command', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority /root/vlc/vlc-1.1.13/cvlc rtp://192.168.0.2:1234")
-app3 = ec.register_resource("OMFApplication")
+app3 = ec.register_resource("omf::Application")
ec.set(app3, 'command', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority /root/vlc/vlc-1.1.13/cvlc rtp://192.168.0.3:1234")
# Create and Configure the Nodes
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
ec.set(node1, 'hostname', 'node025')
ec.set(node1, 'xmppServer', "nitlab.inf.uth.gr")
ec.set(node1, 'xmppUser', "nepi")
ec.set(node1, 'xmppPort', "5222")
ec.set(node1, 'xmppPassword', "1234")
-iface1 = ec.register_resource("OMFWifiInterface")
+iface1 = ec.register_resource("omf::WifiInterface")
ec.set(iface1, 'name', 'wlan0')
ec.set(iface1, 'mode', "adhoc")
ec.set(iface1, 'hw_mode', "g")
ec.set(iface1, 'essid', "vlc")
ec.set(iface1, 'ip', "192.168.0.25/24")
-node2 = ec.register_resource("OMFNode")
+node2 = ec.register_resource("omf::Node")
ec.set(node2, 'hostname', 'node027')
ec.set(node2, 'xmppServer', "nitlab.inf.uth.gr")
ec.set(node2, 'xmppUser', "nepi")
ec.set(node2, 'xmppPort', "5222")
ec.set(node2, 'xmppPassword', "1234")
-iface2 = ec.register_resource("OMFWifiInterface")
+iface2 = ec.register_resource("omf::WifiInterface")
ec.set(iface2, 'name', 'wlan0')
ec.set(iface2, 'mode', "adhoc")
ec.set(iface2, 'hw_mode', "g")
ec.set(iface2, 'essid', "vlc")
ec.set(iface2, 'ip', "192.168.0.27/24")
-chan = ec.register_resource("OMFChannel")
+chan = ec.register_resource("omf::Channel")
ec.set(chan, 'channel', "6")
# Create and Configure the Application
-app1 = ec.register_resource("OMFApplication")
+app1 = ec.register_resource("omf::Application")
ec.set(app1, 'command', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority /root/vlc/vlc-1.1.13/cvlc /root/10-by-p0d.avi --sout '#rtp{dst=192.168.0.27,port=1234,mux=ts}'")
-app2 = ec.register_resource("OMFApplication")
+app2 = ec.register_resource("omf::Application")
ec.set(app2, 'command', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority /root/vlc/vlc-1.1.13/cvlc rtp://192.168.0.27:1234")
# Create and Configure the Nodes
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
ec.set(node1, 'hostname', 'wlab12')
ec.set(node1, 'xmppServer', "xmpp-plexus.onelab.eu")
ec.set(node1, 'xmppUser', "nepi")
ec.set(node1, 'xmppPassword', "1234")
# Create and Configure the Application
-app1 = ec.register_resource("OMFApplication")
+app1 = ec.register_resource("omf::Application")
ec.set(app1, 'command', '/bin/hostname -f')
ec.set(app1, 'env', "")
-app2 = ec.register_resource("OMFApplication")
+app2 = ec.register_resource("omf::Application")
ec.set(app2, 'command', '/bin/date')
ec.set(app2, 'env', "")
-app3 = ec.register_resource("OMFApplication")
+app3 = ec.register_resource("omf::Application")
ec.set(app3, 'command', '/bin/hostname -f')
ec.set(app3, 'env', "")
# Create and Configure the Nodes
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
ec.set(node1, 'hostname', 'wlab12')
ec.set(node1, 'xmppServer', "xmpp-plexus.onelab.eu")
ec.set(node1, 'xmppUser', "nepi")
ec.set(node1, 'xmppPort', "5222")
ec.set(node1, 'xmppPassword', "1234")
-iface1 = ec.register_resource("OMFWifiInterface")
+iface1 = ec.register_resource("omf::WifiInterface")
ec.set(iface1, 'name', 'wlan0')
ec.set(iface1, 'mode', "adhoc")
ec.set(iface1, 'hw_mode', "g")
ec.set(iface1, 'essid', "ping")
ec.set(iface1, 'ip', "192.168.0.12/24")
-node2 = ec.register_resource("OMFNode")
+node2 = ec.register_resource("omf::Node")
ec.set(node2, 'hostname', 'wlab49')
ec.set(node2, 'xmppServer', "xmpp-plexus.onelab.eu")
ec.set(node2, 'xmppUser', "nepi")
ec.set(node2, 'xmppPort', "5222")
ec.set(node2, 'xmppPassword', "1234")
-iface2 = ec.register_resource("OMFWifiInterface")
+iface2 = ec.register_resource("omf::WifiInterface")
ec.set(iface2, 'name', 'wlan0')
ec.set(iface2, 'mode', "adhoc")
ec.set(iface2, 'hw_mode', "g")
ec.set(iface2, 'essid', "ping")
ec.set(iface2, 'ip', "192.168.0.49/24")
-chan = ec.register_resource("OMFChannel")
+chan = ec.register_resource("omf::Channel")
ec.set(chan, 'channel', "6")
# Create and Configure the Application
-app1 = ec.register_resource("OMFApplication")
+app1 = ec.register_resource("omf::Application")
ec.set(app1, 'command', '/bin/ping -c5 192.168.0.49')
ec.set(app1, 'env', "")
-app2 = ec.register_resource("OMFApplication")
+app2 = ec.register_resource("omf::Application")
ec.set(app2, 'command', '/bin/ping -c5 192.168.0.12')
ec.set(app2, 'env', "")
# Create and Configure the Nodes
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
ec.set(node1, 'hostname', 'wlab12')
ec.set(node1, 'xmppServer', "xmpp-plexus.onelab.eu")
ec.set(node1, 'xmppUser', "nepi")
ec.set(node1, 'xmppPort', "5222")
ec.set(node1, 'xmppPassword', "1234")
-iface1 = ec.register_resource("OMFWifiInterface")
+iface1 = ec.register_resource("omf::WifiInterface")
ec.set(iface1, 'name', 'wlan0')
ec.set(iface1, 'mode', "adhoc")
ec.set(iface1, 'hw_mode', "g")
ec.set(iface1, 'essid', "ping")
ec.set(iface1, 'ip', "192.168.0.12/24")
-node2 = ec.register_resource("OMFNode")
+node2 = ec.register_resource("omf::Node")
ec.set(node2, 'hostname', 'wlab49')
ec.set(node2, 'xmppServer', "xmpp-plexus.onelab.eu")
ec.set(node2, 'xmppUser', "nepi")
ec.set(node2, 'xmppPort', "5222")
ec.set(node2, 'xmppPassword', "1234")
-iface2 = ec.register_resource("OMFWifiInterface")
+iface2 = ec.register_resource("omf::WifiInterface")
ec.set(iface2, 'name', 'wlan0')
ec.set(iface2, 'mode', "adhoc")
ec.set(iface2, 'hw_mode', "g")
ec.set(iface2, 'essid', "ping")
ec.set(iface2, 'ip', "192.168.0.49/24")
-chan = ec.register_resource("OMFChannel")
+chan = ec.register_resource("omf::Channel")
ec.set(chan, 'channel', "6")
# Create and Configure the Application
-app1 = ec.register_resource("OMFApplication")
+app1 = ec.register_resource("omf::Application")
ec.set(app1, 'command', '/bin/ping -c5 192.168.0.49')
ec.set(app1, 'env', "")
-app2 = ec.register_resource("OMFApplication")
+app2 = ec.register_resource("omf::Application")
ec.set(app2, 'command', '/bin/ping -c5 192.168.0.12')
ec.set(app2, 'env', "")
ec = ExperimentController(exp_id="nitos_omf5_ping")
# Create and Configure the Nodes
-node1 = ec.register_resource("OMFNode")
+node1 = ec.register_resource("omf::Node")
ec.set(node1, "hostname", nodex)
ec.set(node1, "xmppUser", slicename)
ec.set(node1, "xmppServer", "nitlab.inf.uth.gr")
ec.set(node1, "version", "5")
# Create and Configure the Interfaces
-iface1 = ec.register_resource("OMFWifiInterface")
+iface1 = ec.register_resource("omf::WifiInterface")
ec.set(iface1, "name", "wlan0")
ec.set(iface1, "mode", "adhoc")
ec.set(iface1, "hw_mode", "g")
ec.register_connection(node1, iface1)
# Create and Configure the Channel
-channel = ec.register_resource("OMFChannel")
+channel = ec.register_resource("omf::Channel")
ec.set(channel, "channel", chan)
ec.set(channel, "xmppUser", slicename)
ec.set(channel, "xmppServer", "nitlab.inf.uth.gr")
ec.register_connection(iface1, channel)
# Create and Configure the PING Application
-app1 = ec.register_resource("OMFApplication")
+app1 = ec.register_resource("omf::Application")
ec.set(app1, "appid", "Ping#1")
ec.set(app1, "command", "/bin/ping -c3 192.168.0.%s" % nodex[-2:])
ec.set(app1, "version", "5")
ec.register_connection(app1, node1)
-app2 = ec.register_resource("OMFApplication")
+app2 = ec.register_resource("omf::Application")
ec.set(app2, "appid", "Kill#1")
ec.set(app2, "command", "/usr/bin/killall ping")
ec.set(app2, "version", "5")
# Functions for nodes and ifaces registration
def create_planetlab_node(ec, host):
- node = ec.register_resource("PlanetlabSfaNode")
+ node = ec.register_resource("planetlab::sfa::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", "inria_nepi")
ec.set(node, "sfauser", sfauser)
return node
def create_omf_node(ec, host):
- node = ec.register_resource("WilabtSfaNode")
+ node = ec.register_resource("wilabt::sfa::Node")
ec.set(node, "host", host)
ec.set(node, "slicename", slicename)
ec.set(node, "sfauser", sfauser)
return node
def create_omf_iface(ec, ip, node):
- iface = ec.register_resource("OMFWifiInterface")
+ iface = ec.register_resource("omf::WifiInterface")
ec.set(iface, 'name', 'wlan0')
ec.set(iface, 'mode', "adhoc")
ec.set(iface, 'hw_mode', "g")
# Register channel
-chan = ec.register_resource("OMFChannel")
+chan = ec.register_resource("omf::Channel")
ec.set(chan, 'channel', "6")
# Register connection ifaces - channel
# Functions for applications registration in the nodes
def create_vlc_server(ec, video_server, mode):
- vlc_server = ec.register_resource("LinuxApplication")
+ vlc_server = ec.register_resource("linux::Application")
ec.set(vlc_server, "depends", "vlc")
ec.set(vlc_server, "sources", "examples/omf/demo_openlab/big_buck_bunny_240p_mpeg4_lq.ts")
# Depending on the mode selected to run the experiment,
return vlc_server
def create_omf_app(ec, command, node):
- app = ec.register_resource("OMFApplication")
+ app = ec.register_resource("omf::Application")
ec.set(app, 'command', command)
ec.register_connection(app, node)
return app
ec.register_condition(vlc_wificenter, ResourceAction.START, upload_conf, ResourceState.STARTED , "2s")
# measurements in video server (PL node)
-measure_videoserver = ec.register_resource("LinuxApplication")
+measure_videoserver = ec.register_resource("linux::Application")
ec.set(measure_videoserver, "depends", "tcpdump")
ec.set(measure_videoserver, "sudo", True)
command = "tcpdump -i eth0 not arp -n -w /tmp/capplserver_%s.pcap" % ("$(date +'%Y%m%d%H%M%S')")
import sys
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)
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)
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
ec.shutdown()
-
-
-
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)
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)
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
ec.shutdown()
-
-
-
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)
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)
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
ec.shutdown()
-
-
-
### Useful Method to Create RM ##
def add_node(ec, host, user):
- node = ec.register_resource("PlanetlabNode")
+ node = ec.register_resource("planetlab::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
return node
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)
return tap
def add_udptun(ec, tap1, tap2):
- udptun = ec.register_resource("UdpTunnel")
+ udptun = ec.register_resource("udp::Tunnel")
ec.register_connection(tap1, udptun)
ec.register_connection(tap2, udptun)
return udptun
def add_vroute(ec, network, tap):
- vroute = ec.register_resource("PlanetlabVroute")
+ vroute = ec.register_resource("planetlab::Vroute")
ec.set(vroute, "action", "add")
ec.set(vroute, "network", network)
ec.register_connection(vroute, tap)
return vroute
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
ec.shutdown()
-
-
-
##### CONFIGURING NODE 1
## Register node 1
-node1 = ec.register_resource("PlanetlabNode")
+node1 = ec.register_resource("planetlab::Node")
# Set the hostname of the first node to use for the experiment
ec.set(node1, "hostname", hostname1)
# username should be your SSH user
ec.set(node1, "cleanProcesses", True)
## Register a CCN daemon in node 1
-ccnd1 = ec.register_resource("LinuxCCND")
+ccnd1 = ec.register_resource("linux::CCND")
# Set ccnd log level to 7
ec.set(ccnd1, "debug", 7)
ec.register_connection(ccnd1, node1)
## Register a repository in node 1
-ccnr1 = ec.register_resource("LinuxCCNR")
+ccnr1 = ec.register_resource("linux::CCNR")
ec.register_connection(ccnr1, ccnd1)
## Push the file into the repository
content_name = "ccnx:/test/FILE"
# Add a content to the repository
-co = ec.register_resource("LinuxCCNContent")
+co = ec.register_resource("linux::CCNContent")
ec.set(co, "contentName", content_name)
# NEPI will upload the specified file to the remote node and write it
# into the CCN repository
##### CONFIGURING NODE 2
## Register node 2
-node2 = ec.register_resource("PlanetlabNode")
+node2 = ec.register_resource("planetlab::Node")
# Set the hostname of the first node to use for the experiment
ec.set(node2, "hostname", hostname2)
# username should be your SSH user
ec.set(node2, "cleanProcesses", True)
## Register a CCN daemon in node 2
-ccnd2 = ec.register_resource("LinuxCCND")
+ccnd2 = ec.register_resource("linux::CCND")
# Set ccnd log level to 7
ec.set(ccnd2, "debug", 7)
ec.register_connection(ccnd2, node2)
## Retrieve the file stored in node 1 from node 2
-ccncat = ec.register_resource("LinuxCCNCat")
+ccncat = ec.register_resource("linux::CCNCat")
ec.set(ccncat, "contentName", content_name)
ec.register_connection(ccncat, ccnd2)
##### INTERCONNECTING CCN NODES ...
# Register a FIB entry from node 1 to node 2
-entry1 = ec.register_resource("LinuxFIBEntry")
+entry1 = ec.register_resource("linux::FIBEntry")
ec.set(entry1, "host", hostname2)
ec.register_connection(entry1, ccnd1)
# Register a FIB entry from node 2 to node 1
-entry2 = ec.register_resource("LinuxFIBEntry")
+entry2 = ec.register_resource("linux::FIBEntry")
ec.set(entry2, "host", hostname1)
ec.register_connection(entry2, ccnd2)
ec = ExperimentController(exp_id = "pl_ping")
# Register a Planetlab Node with no restrictions, it can be any node
-node = ec.register_resource("PlanetlabNode")
+node = ec.register_resource("planetlab::Node")
# The username in this case is the slice name, the one to use for login in
# via ssh into PlanetLab nodes. Replace with your own slice name.
ec.set(node, "plpassword", pl_password)
# Remove previous results
-ec.set(node, "cleanHome", True)
+ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
# Define a ping application
-app = ec.register_resource("LinuxApplication")
+app = ec.register_resource("linux::Application")
ec.set(app, "command", "ping -c3 nepi.inria.fr")
# Connect the application to the node
print "PING outout ", trace
-# Do the experiment controller shutdown:
+# Do the experiment controller shutdown
ec.shutdown()
# END
hostname = None, country = None, operatingSystem = None,
minBandwidth = None, minCpu = None):
- node = ec.register_resource("PlanetlabNode")
+ node = ec.register_resource("planetlab::Node")
ec.set(node, "username", pl_slice)
ec.set(node, "identity", pl_ssh_key)
if minCpu:
ec.set(node, "minCpu", minCpu)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
return node
def add_app(ec, command, node, newname = None, sudo = None,
video = None, depends = None, forward_x11 = None, env = None):
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
if sudo is not None:
ec.set(app, "sudo", sudo)
node_count = options.node_count
def add_node(ec, pl_slice, pl_ssh_key, pl_user, pl_password, country, os):
- node = ec.register_resource("PlanetlabNode")
+ node = ec.register_resource("planetlab::Node")
ec.set(node, "username", pl_slice)
ec.set(node, "identity", pl_ssh_key)
ec.set(node, "pluser", pl_user)
if os:
ec.set(node, "operatingSystem", os)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
return node
username = 'inria_sfatest'
# nodes
-node1 = ec.register_resource("PlanetlabNode")
+node1 = ec.register_resource("planetlab::Node")
ec.set(node1, "username", username)
ec.set(node1, "pluser", pl_user)
ec.set(node1, "plpassword", pl_password)
-ec.set(node1, "cleanHome", True)
+ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
-node2 = ec.register_resource("PlanetlabNode")
+node2 = ec.register_resource("planetlab::Node")
ec.set(node2, "username", username)
ec.set(node2, "pluser", pl_user)
ec.set(node2, "plpassword", pl_password)
-ec.set(node2, "cleanHome", True)
+ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
-node3 = ec.register_resource("PlanetlabNode")
+node3 = ec.register_resource("planetlab::Node")
ec.set(node3, "username", username)
ec.set(node3, "pluser", pl_user)
ec.set(node3, "plpassword", pl_password)
-ec.set(node3, "cleanHome", True)
+ec.set(node3, "cleanExperiment", True)
ec.set(node3, "cleanProcesses", True)
# Set the global attribute 'persist_blacklist'
# use of the blacklist, meaning leaving out of the
# provisioning the nodes in that file, and adding the new blacklisted
# nodes to the file.
-ec.set_global('PlanetlabNode', 'persist_blacklist', True)
+ec.set_global("planetlab::Node", "persist_blacklist", True)
# apps
-app1 = ec.register_resource("LinuxApplication")
+app1 = ec.register_resource("linux::Application")
command = "ping -c5 google.com"
ec.set(app1, "command", command)
ec.register_connection(app1, node1)
-app2 = ec.register_resource("LinuxApplication")
+app2 = ec.register_resource("linux::Application")
command = "ping -c5 google.com"
ec.set(app2, "command", command)
ec.register_connection(app2, node2)
-app3 = ec.register_resource("LinuxApplication")
+app3 = ec.register_resource("linux::Application")
command = "ping -c5 google.com"
ec.set(app3, "command", command)
ec.register_connection(app3, node3)
sfaPrivateKey = os.environ.get('SFA_PK')
# server
-node1 = ec.register_resource("PlanetlabSfaNode")
-ec.set(node1, "hostname", 'planetlab3.xeno.cl.cam.ac.uk')
+node1 = ec.register_resource("planetlab::sfa::Node")
+ec.set(node1, "hostname", "planetlab3.xeno.cl.cam.ac.uk")
ec.set(node1, "username", username)
ec.set(node1, "sfauser", sfauser)
ec.set(node1, "sfaPrivateKey", sfaPrivateKey)
-ec.set(node1, "cleanHome", True)
+ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
-node2 = ec.register_resource("PlanetlabSfaNode")
+node2 = ec.register_resource("planetlab::sfa::Node")
ec.set(node2, "username", username)
ec.set(node2, "sfauser", sfauser)
ec.set(node2, "sfaPrivateKey", sfaPrivateKey)
-ec.set(node2, "cleanHome", True)
+ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
-node3 = ec.register_resource("PlanetlabSfaNode")
+node3 = ec.register_resource("planetlab::sfa::Node")
ec.set(node3, "username", username)
ec.set(node3, "sfauser", sfauser)
ec.set(node3, "sfaPrivateKey", sfaPrivateKey)
-app1 = ec.register_resource("LinuxApplication")
+app1 = ec.register_resource("linux::Application")
command = "ping -c5 google.com"
ec.set(app1, "command", command)
ec.register_connection(app1, node1)
-app2 = ec.register_resource("LinuxApplication")
+app2 = ec.register_resource("linux::Application")
command = "ping -c5 google.com"
ec.set(app2, "command", command)
ec.register_connection(app2, node2)
-app3 = ec.register_resource("LinuxApplication")
+app3 = ec.register_resource("linux::Application")
command = "ping -c5 google.com"
ec.set(app3, "command", command)
ec.register_connection(app3, node3)
def create_node(ec, username, pl_user, pl_password, critical=True, hostname=None,
country=None, operatingSystem=None, minBandwidth=None, minCpu=None):
- node = ec.register_resource("PlanetlabNode")
+ node = ec.register_resource("planetlab::Node")
if username:
ec.set(node, "username", username)
ec.set(node, "minCpu", minCpu)
ec.set(node, "critical", critical)
- #ec.set(node, "cleanHome", True)
+ #ec.set(node, "cleanExperiment", True)
#ec.set(node, "cleanProcesses", True)
return node
"""
- _rtype = "LinuxApplication"
+ _rtype = "linux::Application"
_help = "Runs an application on a Linux host with a BASH command "
_backend_type = "linux"
@clsinit_copy
class LinuxCCNApplication(LinuxApplication):
- _rtype = "LinuxCCNApplication"
+ _rtype = "linux::CCNApplication"
def __init__(self, ec, guid):
super(LinuxCCNApplication, self).__init__(ec, guid)
@clsinit_copy
class LinuxCCNCat(LinuxCCNApplication):
- _rtype = "LinuxCCNCat"
+ _rtype = "linux::CCNCat"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxCCNContent(LinuxApplication):
- _rtype = "LinuxCCNContent"
+ _rtype = "linux::CCNContent"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxCCND(LinuxApplication):
- _rtype = "LinuxCCND"
+ _rtype = "linux::CCND"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxCCNPeek(LinuxCCNApplication):
- _rtype = "LinuxCCNPeek"
+ _rtype = "linux::CCNPeek"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxCCNPing(LinuxCCNPingServer):
- _rtype = "LinuxCCNPing"
+ _rtype = "linux::CCNPing"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxCCNPingServer(LinuxCCNApplication):
- _rtype = "LinuxCCNPingServer"
+ _rtype = "linux::CCNPingServer"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxCCNPoke(LinuxCCNApplication):
- _rtype = "LinuxCCNPoke"
+ _rtype = "linux::CCNPoke"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxCCNR(LinuxApplication):
- _rtype = "LinuxCCNR"
+ _rtype = "linux::CCNR"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxFIBEntry(LinuxApplication):
- _rtype = "LinuxFIBEntry"
+ _rtype = "linux::FIBEntry"
@classmethod
def _register_attributes(cls):
def configure(self):
if self.trace_enabled("ping") and not self.ping:
self.info("Configuring PING trace")
- ping = self.ec.register_resource("LinuxPing")
+ ping = self.ec.register_resource("linux::Ping")
self.ec.set(ping, "printTimestamp", True)
self.ec.set(ping, "target", self.get("host"))
self.ec.set(ping, "earlyStart", True)
if self.trace_enabled("traceroute") and not self.traceroute:
self.info("Configuring TRACEROUTE trace")
- traceroute = self.ec.register_resource("LinuxTraceroute")
+ traceroute = self.ec.register_resource("linux::Traceroute")
self.ec.set(traceroute, "printTimestamp", True)
self.ec.set(traceroute, "continuous", True)
self.ec.set(traceroute, "target", self.get("host"))
@clsinit_copy
class LinuxChannel(ResourceManager):
- _rtype = "LinuxChannel"
+ _rtype = "linux::Channel"
_help = "Represents a wireless channel on a network of Linux hosts"
_backend = "linux"
@clsinit_copy
class LinuxGRETunnel(LinuxTunnel):
- _rtype = "LinuxGRETunnel"
+ _rtype = "linux::GRETunnel"
_help = "Constructs a tunnel between two Linux endpoints using a UDP connection "
_backend = "linux"
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
@clsinit_copy
class LinuxInterface(ResourceManager):
- _rtype = "LinuxInterface"
+ _rtype = "linux::Interface"
_help = "Controls network devices on Linux hosts through the ifconfig tool"
_backend = "linux"
@clsinit_copy
class LinuxMtr(LinuxApplication):
- _rtype = "LinuxMtr"
+ _rtype = "linux::Mtr"
@classmethod
def _register_attributes(cls):
source compilation, file download, etc)
"""
- _rtype = "LinuxNode"
+ _rtype = "linux::Node"
_help = "Controls Linux host machines ( either localhost or a host " \
"that can be accessed using a SSH key)"
_backend_type = "linux"
@clsinit_copy
class LinuxNPing(LinuxApplication):
- _rtype = "LinuxNPing"
+ _rtype = "linux::NPing"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxNS3DceCCNCat(LinuxNS3CCNDceApplication):
- _rtype = "ns3::LinuxDceCCNCat"
+ _rtype = "linux::ns3::dce::CCNCat"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxNS3CCNDceApplication(NS3BaseCCNDceApplication):
- _rtype = "ns3::LinuxCCNDceApplication"
+ _rtype = "linux::ns3::dce::CCNApplication"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxNS3DceCCND(LinuxNS3CCNDceApplication):
- _rtype = "ns3::LinuxDceCCND"
+ _rtype = "linux::ns3::dce::CCND"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxNS3DceCCNPeek(LinuxNS3CCNDceApplication):
- _rtype = "ns3::LinuxDceCCNPeek"
+ _rtype = "linux::ns3::dce::CCNPeek"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxNS3DceCCNPoke(LinuxNS3CCNDceApplication):
- _rtype = "ns3::LinuxDceCCNPoke"
+ _rtype = "linux::ns3::dce::CCNPoke"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxNS3DceCCNR(LinuxNS3CCNDceApplication):
- _rtype = "ns3::LinuxDceCCNR"
+ _rtype = "linux::ns3::dce::CCNR"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxNS3DceFIBEntry(LinuxNS3CCNDceApplication):
- _rtype = "ns3::LinuxDceFIBEntry"
+ _rtype = "linux::ns3::dce::FIBEntry"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxNS3DceApplication(NS3BaseDceApplication):
- _rtype = "ns3::LinuxDceApplication"
+ _rtype = "linux::ns3::dce::Application"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxDcePing(LinuxNS3DceApplication):
- _rtype = "ns3::LinuxDcePing"
+ _rtype = "linux::ns3::dce::Ping"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxNS3Simulation(LinuxApplication, NS3Simulation):
- _rtype = "LinuxNS3Simulation"
+ _rtype = "linux::ns3::Simulation"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxPing(LinuxApplication):
- _rtype = "LinuxPing"
+ _rtype = "linux::Ping"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxTap(LinuxApplication):
- _rtype = "LinuxTap"
+ _rtype = "linux::Tap"
_help = "Creates a TAP device on a Linux host"
_backend = "linux"
@clsinit_copy
class LinuxTcpdump(LinuxApplication):
- _rtype = "LinuxTcpdump"
+ _rtype = "linux::Tcpdump"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxTraceroute(LinuxApplication):
- _rtype = "LinuxTraceroute"
+ _rtype = "linux::Traceroute"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxTun(LinuxTap):
- _rtype = "LinuxTun"
+ _rtype = "linux::Tun"
_help = "Creates a TUN device on a Linux host"
_backend = "linux"
@clsinit_copy
class LinuxTunnel(LinuxApplication):
- _rtype = "abstract::LinuxTunnel"
+ _rtype = "abstract::linux::Tunnel"
_help = "Constructs a tunnel between two Linux endpoints"
_backend = "linux"
http://hpcbench.sourceforge.net/
"""
- _rtype = "LinuxUdpTest"
+ _rtype = "linux::UdpTest"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class LinuxUdpTunnel(LinuxTunnel):
- _rtype = "LinuxUdpTunnel"
+ _rtype = "linux::UdpTunnel"
_help = "Constructs a tunnel between two Linux endpoints using a UDP connection "
_backend = "linux"
+++ /dev/null
-#
-# NEPI, a framework to manage network experiments
-# Copyright (C) 2014 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.
-#
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-# GNU General Public License for more details.
-#
-# You should have received a copy of the GNU General Public License
-# along with this program. If not, see <http://www.gnu.org/licenses/>.
-#
-
-from nepi.execution.attribute import Attribute, Flags, Types
-from nepi.execution.trace import Trace, TraceAttr
-from nepi.execution.resource import ResourceManager, clsinit_copy, \
- ResourceState
-from nepi.resources.ns3.ns3dceapplication import NS3BaseDceApplication
-
-@clsinit_copy
-class NS3DceApplication(NS3BaseDceApplication):
- _rtype = "ns3::DceApplication"
-
- @classmethod
- def _register_attributes(cls):
-
- attr_starttime = Attribute("StartTime",
- "Time at which the application will start",
- type = Types.String,
- default = "+0.0ns",
- allowed = None,
- range = None,
- flags = Flags.Reserved | Flags.Construct)
-
- cls._register_attribute(attr_starttime)
-
- attr_stoptime = Attribute("StopTime",
- "Time at which the application will stop",
- type = Types.String,
- default = "+0.0ns",
- allowed = None,
- range = None,
- flags = Flags.Reserved | Flags.Construct)
-
- cls._register_attribute(attr_stoptime)
-
-
-
- @classmethod
- def _register_traces(cls):
-
- processstarted = Trace("ProcessStarted", "notify when the dce is started")
-
- cls._register_trace(processstarted)
-
-
-
- def __init__(self, ec, guid):
- super(NS3DceApplication, self).__init__(ec, guid)
- self._home = "ns3-dce-application-%s" % self.guid
:type guid: int
"""
- _rtype = "OMFApplication"
- _authorized_connections = ["OMFNode", "WilabtSfaNode"]
+ _rtype = "omf::Application"
+ _authorized_connections = ["omf::Node", "wilabt::sfa::Node"]
@classmethod
def _register_attributes(cls):
:type creds: dict
"""
- _rtype = "OMFChannel"
- _authorized_connections = ["OMFWifiInterface", "OMFNode"]
+ _rtype = "omf::Channel"
+ _authorized_connections = ["omf::WifiInterface", "omf::Node"]
ChannelToFreq = dict({
"1" : "2412",
rm_iface = self.ec.get_resource(elt)
for conn in rm_iface.connections:
rm_node = self.ec.get_resource(conn)
- if rm_node.get_rtype() == "OMFNode" and rm_node.get('hostname'):
+ if rm_node.get_rtype() == "omf::Node" and rm_node.get('hostname'):
if rm_iface.state < ResourceState.PROVISIONED or \
rm_node.state < ResourceState.READY:
return "reschedule"
:type guid: int
"""
- _rtype = "OMFWifiInterface"
- _authorized_connections = ["OMFNode" , "OMFChannel", "WilabtSfaNode"]
+ _rtype = "omf::WifiInterface"
+ _authorized_connections = ["omf::Node" , "omf::Channel", "wilabt::sfa::Node"]
@classmethod
def _register_attributes(cls):
:type creds: dict
"""
- _rtype = "OMFNode"
- _authorized_connections = ["OMFApplication" , "OMFWifiInterface"]
+ _rtype = "omf::Node"
+ _authorized_connections = ["omf::Application" , "omf::WifiInterface"]
@classmethod
def _register_attributes(cls):
Generic resource gathering XMPP credential information and common methods
for OMF nodes, channels, applications, etc.
"""
- _rtype = "OMFResource"
+ _rtype = "abstract::omf::Resource"
@classmethod
def _register_attributes(cls):
@clsinit_copy
class WilabtSfaNode(OMFNode):
- _rtype = "WilabtSfaNode"
+ _rtype = "wilabt::sfa::Node"
_help = "Controls a Wilabt host accessible using a SSH key " \
"and provisioned using SFA"
_backend = "omf"
@clsinit_copy
class PlanetlabNode(LinuxNode):
- _rtype = "PlanetlabNode"
+ _rtype = "planetlab::Node"
_help = "Controls a PlanetLab host accessible using a SSH key " \
"associated to a PlanetLab user account"
_backend = "planetlab"
"""
- _rtype = "OVSSwitch"
+ _rtype = "planetlab::OVSSwitch"
_help = "Runs an OpenVSwitch on a PlanetLab host"
_backend = "planetlab"
- _authorized_connections = ["PlanetlabNode", "OVSPort", "LinuxNode"]
+ _authorized_connections = ["planetlab::Node", "planetla::OVSPort", "linux::Node"]
@classmethod
def _register_attributes(cls):
"""
- _rtype = "OVSPort"
+ _rtype = "planetlab::OVSPort"
_help = "Runs an OpenVSwitch on a PlanetLab host"
_backend = "planetlab"
- _authorized_connections = ["OVSSwitch", "LinuxUdpTunnel", "LinuxTunnel"]
+ _authorized_connections = ["planetlab::OVSSwitch", "linux::UdpTunnel", "linux::Tunnel"]
@classmethod
def _register_attributes(cls):
self.info("The number of the %s is %s" % (self.get('port_name'),
self.port_number))
- if remote_endpoint.is_rm_instance("PlanetlabTap"):
- self._vroute = self.ec.register_resource("PlanetlabVroute")
+ if remote_endpoint.is_rm_instance("planetlab::Tap"):
+ self._vroute = self.ec.register_resource("planetlab::Vroute")
self.ec.set(self._vroute, "action", "add")
self.ec.set(self._vroute, "network", self.get("network"))
@clsinit_copy
class PlanetlabSfaNode(LinuxNode):
- _rtype = "PlanetlabSfaNode"
+ _rtype = "planetlab::sfa::Node"
_help = "Controls a PlanetLab host accessible using a SSH key " \
"and provisioned using SFA"
_backend = "planetlab"
@clsinit_copy
class PlanetlabTap(LinuxApplication):
- _rtype = "PlanetlabTap"
+ _rtype = "planetlab::Tap"
_help = "Creates a TAP device on a PlanetLab host"
_backend = "planetlab"
@clsinit_copy
class PlanetlabTun(PlanetlabTap):
- _rtype = "PlanetlabTun"
+ _rtype = "planetlab::Tun"
_help = "Creates a TUN device on a PlanetLab host"
_backend = "planetlab"
@clsinit_copy
class PlanetlabVroute(LinuxApplication):
- _rtype = "PlanetlabVroute"
+ _rtype = "planetlab::Vroute"
_help = "Creates a Vroute on a PlanetLab host"
_backend = "planetlab"
ec = ExperimentController(exp_id = "test-stdout")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
cmd = "echo 'HOLA'"
ec.set(app, "command", cmd)
ec.register_connection(app, node)
ec = ExperimentController(exp_id = "test-ping")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
cmd = "ping -c5 %s" % self.target
ec.set(app, "command", cmd)
ec = ExperimentController(exp_id = "tests-code")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
prog = """#include <stdio.h>
cmd = "${RUN_HOME}/hello"
build = "gcc -Wall -x c ${APP_HOME}/code -o hello"
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
ec.set(app, "command", cmd)
ec.set(app, "code", prog)
ec.set(app, "depends", "gcc")
ec = ExperimentController(exp_id="test-concurrency")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
apps = list()
for i in xrange(50):
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
cmd = "ping -c5 %s" % self.target
ec.set(app, "command", cmd)
ec.register_connection(app, node)
ec = ExperimentController(exp_id="test-condition")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- server = ec.register_resource("LinuxApplication")
+ server = ec.register_resource("linux::Application")
cmd = "echo 'HOLA' | nc -l 3333"
ec.set(server, "command", cmd)
ec.set(server, "depends", depends)
ec.register_connection(server, node)
- client = ec.register_resource("LinuxApplication")
+ client = ec.register_resource("linux::Application")
cmd = "nc 127.0.0.1 3333"
ec.set(client, "command", cmd)
ec.register_connection(client, node)
ec = ExperimentController(exp_id="test-http-sources")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
sources = "http://yans.pl.sophia.inria.fr/code/nef/archive/tip.tar.gz;" \
"http://yans.pl.sophia.inria.fr/code/nef/raw-file/8ace577d4079/src/nef/images/menu/connect.png"
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
ec.set(app, "sources", sources)
command = "ls ${SRC}"
ec = ExperimentController(exp_id="test-xterm")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
ec.set(app, "command", "xterm")
ec.set(app, "depends", "xterm")
ec.set(app, "forwardX11", True)
ec = ExperimentController(exp_id="test-copyfile")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
ec.set(app, "command", "ls ${SRC}")
ec.set(app, "sources", "%s;%s" % (dirpath, f1.name))
ec.register_connection(app, node)
def test_ccnpeek(self):
ec = ExperimentController(exp_id = "test-linux-ccncat")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", self.fedora_host)
ec.set(node, "username", self.fedora_user)
ec.set(node, "identity", self.fedora_identity)
#ec.set(node, "cleanProcesses", True)
- #ec.set(node, "cleanHome", True)
+ #ec.set(node, "cleanExperiment", True)
- ccnd = ec.register_resource("LinuxCCND")
+ ccnd = ec.register_resource("linux::CCND")
ec.register_connection(ccnd, node)
# REPO file is in test/resources/linux/ns3/ccn/repoFile1
"..", "ns3", "ccn", "repoFile1")
## Register a repository in node 1
- ccnr = ec.register_resource("LinuxCCNR")
+ ccnr = ec.register_resource("linux::CCNR")
ec.set(ccnr, "repoFile1", repofile)
ec.register_connection(ccnr, ccnd)
- ccncat = ec.register_resource("LinuxCCNCat")
+ ccncat = ec.register_resource("linux::CCNCat")
ec.set(ccncat, "contentName", "ccnx:/test/bunny.ts")
ec.register_connection(ccncat, ccnd)
def test_ccnpeek(self):
ec = ExperimentController(exp_id = "test-linux-ccnpeek")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", self.fedora_host)
ec.set(node, "username", self.fedora_user)
ec.set(node, "identity", self.fedora_identity)
#ec.set(node, "cleanProcesses", True)
- #ec.set(node, "cleanHome", True)
+ #ec.set(node, "cleanExperiment", True)
- ccnd = ec.register_resource("LinuxCCND")
+ ccnd = ec.register_resource("linux::CCND")
ec.register_connection(ccnd, node)
- peek = ec.register_resource("LinuxCCNPeek")
+ peek = ec.register_resource("linux::CCNPeek")
ec.set(peek, "contentName", "ccnx:/chunk0")
ec.register_connection(peek, ccnd)
- poke = ec.register_resource("LinuxCCNPoke")
+ poke = ec.register_resource("linux::CCNPoke")
ec.set(poke, "contentName", "ccnx:/chunk0")
ec.set(poke, "content", "DATA")
ec.register_connection(poke, ccnd)
ec = ExperimentController(exp_id = "test-ccn-ping-count")
- node1 = ec.register_resource("LinuxNode")
+ node1 = ec.register_resource("linux::Node")
ec.set(node1, "hostname", host1)
ec.set(node1, "username", user1)
- ec.set(node1, "cleanHome", True)
+ ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
- ccnd1 = ec.register_resource("LinuxCCND")
+ ccnd1 = ec.register_resource("linux::CCND")
ec.register_connection(ccnd1, node1)
- entry1 = ec.register_resource("LinuxFIBEntry")
+ entry1 = ec.register_resource("linux::FIBEntry")
ec.set(entry1, "host", host2)
ec.register_connection(entry1, ccnd1)
- server = ec.register_resource("LinuxCCNPingServer")
+ server = ec.register_resource("linux::CCNPingServer")
ec.set(server, "prefix", "ccnx:/test")
ec.register_connection(server, ccnd1)
- node2 = ec.register_resource("LinuxNode")
+ node2 = ec.register_resource("linux::Node")
ec.set(node2, "hostname", host2)
ec.set(node2, "username", user2)
- ec.set(node2, "cleanHome", True)
+ ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
- ccnd2 = ec.register_resource("LinuxCCND")
+ ccnd2 = ec.register_resource("linux::CCND")
ec.register_connection(ccnd2, node2)
- entry2 = ec.register_resource("LinuxFIBEntry")
+ entry2 = ec.register_resource("linux::FIBEntry")
ec.set(entry2, "host", host1)
ec.register_connection(entry2, ccnd2)
- client = ec.register_resource("LinuxCCNPing")
+ client = ec.register_resource("linux::CCNPing")
ec.set(client, "c", 15)
ec.set(client, "prefix", "ccnx:/test")
ec.register_connection(client, ccnd2)
ec = ExperimentController(exp_id = "test-fib-traces")
- node1 = ec.register_resource("LinuxNode")
+ node1 = ec.register_resource("linux::Node")
ec.set(node1, "hostname", host)
ec.set(node1, "username", user)
- #ec.set(node1, "cleanHome", True)
+ ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
- ccnd1 = ec.register_resource("LinuxCCND")
+ ccnd1 = ec.register_resource("linux::CCND")
ec.register_connection(ccnd1, node1)
- entry1 = ec.register_resource("LinuxFIBEntry")
+ entry1 = ec.register_resource("linux::FIBEntry")
ec.set(entry1, "host", self.target)
ec.enable_trace(entry1, "ping")
ec.enable_trace(entry1, "mtr")
ec.register_connection(entry1, ccnd1)
- node2 = ec.register_resource("LinuxNode")
+ node2 = ec.register_resource("linux::Node")
ec.set(node2, "hostname", self.target)
ec.set(node2, "username", self.fedora_user)
- ec.set(node2, "cleanHome", True)
+ ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
- ccnd2 = ec.register_resource("LinuxCCND")
+ ccnd2 = ec.register_resource("linux::CCND")
ec.register_connection(ccnd2, node2)
- entry2 = ec.register_resource("LinuxFIBEntry")
+ entry2 = ec.register_resource("linux::FIBEntry")
ec.set(entry2, "host", host)
ec.register_connection(entry2, ccnd2)
ec = ExperimentController(exp_id = "test-tap-gre-tunnel")
- node1 = ec.register_resource("LinuxNode")
+ node1 = ec.register_resource("linux::Node")
ec.set(node1, "hostname", host1)
ec.set(node1, "username", user1)
ec.set(node1, "identity", identity1)
- ec.set(node1, "cleanHome", True)
+ ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
- tap1 = ec.register_resource("LinuxTap")
+ tap1 = ec.register_resource("linux::Tap")
ec.set(tap1, "endpoint_ip", "%s.1" % self.netblock)
ec.set(tap1, "endpoint_prefix", 32)
ec.register_connection(tap1, node1)
- node2 = ec.register_resource("LinuxNode")
+ node2 = ec.register_resource("linux::Node")
ec.set(node2, "hostname", host2)
ec.set(node2, "username", user2)
ec.set(node2, "identity", identity2)
- ec.set(node2, "cleanHome", True)
+ ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
- tap2 = ec.register_resource("LinuxTap")
+ tap2 = ec.register_resource("linux::Tap")
ec.set(tap2, "endpoint_ip", "%s.2" % self.netblock)
ec.set(tap2, "endpoint_prefix", 32)
ec.register_connection(tap2, node2)
- gretun = ec.register_resource("LinuxGRETunnel")
+ gretun = ec.register_resource("linux::GRETunnel")
ec.register_connection(tap1, gretun)
ec.register_connection(tap2, gretun)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
cmd = "ping -c3 %s.2" % self.netblock
ec.set(app, "command", cmd)
ec.register_connection(app, node1)
ec = ExperimentController(exp_id = "test-tun-gre-tunnel")
- node1 = ec.register_resource("LinuxNode")
+ node1 = ec.register_resource("linux::Node")
ec.set(node1, "hostname", host1)
ec.set(node1, "username", user1)
ec.set(node1, "identity", identity1)
- ec.set(node1, "cleanHome", True)
+ ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
- tun1 = ec.register_resource("LinuxTun")
+ tun1 = ec.register_resource("linux::Tun")
ec.set(tun1, "endpoint_ip", "%s.1" % self.netblock)
ec.set(tun1, "endpoint_prefix", 32)
ec.register_connection(tun1, node1)
- node2 = ec.register_resource("LinuxNode")
+ node2 = ec.register_resource("linux::Node")
ec.set(node2, "hostname", host2)
ec.set(node2, "username", user2)
ec.set(node2, "identity", identity2)
- ec.set(node2, "cleanHome", True)
+ ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
- tun2 = ec.register_resource("LinuxTun")
+ tun2 = ec.register_resource("linux::Tun")
ec.set(tun2, "endpoint_ip", "%s.2" % self.netblock)
ec.set(tun2, "endpoint_prefix", 32)
ec.register_connection(tun2, node2)
- udptun = ec.register_resource("LinuxGRETunnel")
+ udptun = ec.register_resource("linux::GRETunnel")
ec.register_connection(tun1, udptun)
ec.register_connection(tun2, udptun)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
cmd = "ping -c3 %s.2" % self.netblock
ec.set(app, "command", cmd)
ec.register_connection(app, node1)
ec = ExperimentController()
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- iface = ec.register_resource("LinuxInterface")
- chan = ec.register_resource("LinuxChannel")
+ iface = ec.register_resource("linux::Interface")
+ chan = ec.register_resource("linux::Channel")
ec.register_connection(iface, node)
ec.register_connection(iface, chan)
ec = ExperimentController(exp_id = "test-nodns")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- app = ec.register_resource("LinuxMtr")
+ app = ec.register_resource("linux::Mtr")
ec.set(app, "noDns", False)
ec.set(app, "target", self.target)
ec.register_connection(app, node)
ec = ExperimentController(exp_id = "test-condition-multirun",
local_dir = dirpath)
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- ping = ec.register_resource("LinuxApplication")
+ ping = ec.register_resource("linux::Application")
ec.set(ping, "command", "ping -c10 nepi.inria.fr")
ec.register_connection(ping, node)
ec = ExperimentController(exp_id = "test-nping")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- app = ec.register_resource("LinuxNPing")
+ app = ec.register_resource("linux::NPing")
ec.set(app, "c", 1)
ec.set(app, "tcp", True)
ec.set(app, "p", 80)
def t_dce_ccn(self, host, user = None, identity = None):
ec = ExperimentController(exp_id = "test-dce-ccn-app")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", host)
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
#ec.set(simu, "verbose", True)
#ec.set(simu, "buildMode", "debug")
#ec.set(simu, "nsLog", "DceApplication")
ec.register_connection(chan, p2p2)
### create applications
- ccnd1 = ec.register_resource("ns3::LinuxDceCCND")
+ ccnd1 = ec.register_resource("linux::ns3::dce::CCND")
ec.set (ccnd1, "stackSize", 1<<20)
ec.set (ccnd1, "debug", 7)
ec.set (ccnd1, "capacity", 50000)
os.path.dirname(os.path.realpath(__file__)),
"repoFile1")
- ccnr = ec.register_resource("ns3::LinuxDceCCNR")
+ ccnr = ec.register_resource("linux::ns3::dce::CCNR")
ec.set (ccnr, "repoFile1", repofile)
ec.set (ccnr, "stackSize", 1<<20)
ec.set (ccnr, "StartTime", "2s")
ec.set (ccnr, "StopTime", "120s")
ec.register_connection(ccnr, nsnode1)
- ccndc1 = ec.register_resource("ns3::LinuxDceFIBEntry")
+ ccndc1 = ec.register_resource("linux::ns3::dce::FIBEntry")
ec.set (ccndc1, "protocol", "udp")
ec.set (ccndc1, "uri", "ccnx:/")
ec.set (ccndc1, "host", "10.0.0.2")
ec.set (ccndc1, "StopTime", "120s")
ec.register_connection(ccndc1, nsnode1)
- ccnd2 = ec.register_resource("ns3::LinuxDceCCND")
+ ccnd2 = ec.register_resource("linux::ns3::dce::CCND")
ec.set (ccnd2, "stackSize", 1<<20)
ec.set (ccnd2, "debug", 7)
ec.set (ccnd2, "capacity", 50000)
ec.set (ccnd2, "StopTime", "20s")
ec.register_connection(ccnd2, nsnode2)
- ccndc2 = ec.register_resource("ns3::LinuxDceFIBEntry")
+ ccndc2 = ec.register_resource("linux::ns3::dce::FIBEntry")
ec.set (ccndc2, "protocol", "udp")
ec.set (ccndc2, "uri", "ccnx:/")
ec.set (ccndc2, "host", "10.0.0.1")
ec.set (ccndc2, "StopTime", "120s")
ec.register_connection(ccndc2, nsnode2)
- ccnpeek = ec.register_resource("ns3::LinuxDceCCNPeek")
+ ccnpeek = ec.register_resource("linux::ns3::dce::CCNPeek")
ec.set (ccnpeek, "contentName", "ccnx:/test/bunny.ts")
ec.set (ccnpeek, "stackSize", 1<<20)
ec.set (ccnpeek, "StartTime", "4s")
ec.set (ccnpeek, "StopTime", "120s")
ec.register_connection(ccnpeek, nsnode2)
- ccncat = ec.register_resource("ns3::LinuxDceCCNCat")
+ ccncat = ec.register_resource("linux::ns3::dce::CCNCat")
ec.set (ccncat, "contentName", "ccnx:/test/bunny.ts")
ec.set (ccncat, "stackSize", 1<<20)
ec.set (ccncat, "StartTime", "4s")
def t_dce_ccnpeek(self, host, user = None, identity = None):
ec = ExperimentController(exp_id = "test-dce-ccnpeek")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", host)
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.set(simu, "nsLog", "DceApplication")
ec.register_connection(simu, node)
nsnode = add_ns3_node(ec, simu)
### create applications
- ccnd = ec.register_resource("ns3::LinuxDceCCND")
+ ccnd = ec.register_resource("linux::ns3::dce::CCND")
ec.set (ccnd, "stackSize", 1<<20)
ec.set (ccnd, "StartTime", "1s")
ec.register_connection(ccnd, nsnode)
- ccnpoke = ec.register_resource("ns3::LinuxDceCCNPoke")
+ ccnpoke = ec.register_resource("linux::ns3::dce::CCNPoke")
ec.set (ccnpoke, "contentName", "ccnx:/chunk0")
ec.set (ccnpoke, "content", "DATA")
ec.set (ccnpoke, "stackSize", 1<<20)
ec.set (ccnpoke, "StartTime", "2s")
ec.register_connection(ccnpoke, nsnode)
- ccnpeek = ec.register_resource("ns3::LinuxDceCCNPeek")
+ ccnpeek = ec.register_resource("linux::ns3::dce::CCNPeek")
ec.set (ccnpeek, "contentName", "ccnx:/chunk0")
ec.set (ccnpeek, "stackSize", 1<<20)
ec.set (ccnpeek, "StartTime", "4s")
def t_dce_ccnpeek_with_stack(self, host, user = None, identity = None):
ec = ExperimentController(exp_id = "test-dce-peek-lostack")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", host)
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
ec.register_connection(nsnode, simu)
### create applications
- ccnd = ec.register_resource("ns3::LinuxDceCCND")
+ ccnd = ec.register_resource("linux::ns3::dce::CCND")
ec.set (ccnd, "stackSize", 1<<20)
ec.set (ccnd, "StartTime", "1s")
ec.register_connection(ccnd, nsnode)
- ccnpoke = ec.register_resource("ns3::LinuxDceCCNPoke")
+ ccnpoke = ec.register_resource("linux::ns3::dce::CCNPoke")
ec.set (ccnpoke, "contentName", "ccnx:/chunk0")
ec.set (ccnpoke, "content", "DATA")
ec.set (ccnpoke, "stackSize", 1<<20)
ec.set (ccnpoke, "StartTime", "2s")
ec.register_connection(ccnpoke, nsnode)
- ccnpeek = ec.register_resource("ns3::LinuxDceCCNPeek")
+ ccnpeek = ec.register_resource("linux::ns3::dce::CCNPeek")
ec.set (ccnpeek, "contentName", "ccnx:/chunk0")
ec.set (ccnpeek, "stackSize", 1<<20)
ec.set (ccnpeek, "StartTime", "4s")
def t_dce_ping(self, host, user = None, identity = None):
ec = ExperimentController(exp_id = "test-dce-ping")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", host)
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.set(simu, "buildMode", "debug")
ec.set(simu, "nsLog", "DceApplication")
ec.register_connection(chan, p2p2)
### create applications
- ping = ec.register_resource("ns3::LinuxDceApplication")
+ ping = ec.register_resource("linux::ns3::dce::Application")
ec.set (ping, "sources", "http://www.skbuff.net/iputils/iputils-s20101006.tar.bz2")
ec.set (ping, "build", "tar xvjf ${SRC}/iputils-s20101006.tar.bz2 && "
"cd iputils-s20101006/ && "
def t_dce_ccn(self, host, user = None, identity = None):
ec = ExperimentController(exp_id = "test-dce-ccn")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", host)
else:
#ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.set(simu, "buildMode", "debug")
ec.set(simu, "nsLog", "DceApplication")
ec.register_connection(chan, p2p2)
### create applications
- ccnd1 = ec.register_resource("ns3::LinuxCCNDceApplication")
+ ccnd1 = ec.register_resource("linux::ns3::dce::CCNApplication")
if host == self.fedora_host:
depends = ( " autoconf openssl-devel expat-devel libpcap-devel "
os.path.dirname(os.path.realpath(__file__)), "ccn",
"repoFile1")
- ccnr = ec.register_resource("ns3::LinuxCCNDceApplication")
+ ccnr = ec.register_resource("linux::ns3::dce::CCNApplication")
ec.set (ccnr, "binary", "ccnr")
ec.set (ccnr, "environment", "CCNR_DIRECTORY=/REPO/")
ec.set (ccnr, "files", "%s=/REPO/repoFile1" % repofile)
ec.set (ccnr, "StopTime", "120s")
ec.register_connection(ccnr, nsnode1)
- ccndc1 = ec.register_resource("ns3::LinuxCCNDceApplication")
+ ccndc1 = ec.register_resource("linux::ns3::dce::CCNApplication")
ec.set (ccndc1, "binary", "ccndc")
ec.set (ccndc1, "arguments", "-v;add;ccnx:/;udp;10.0.0.2")
ec.set (ccndc1, "stackSize", 1<<20)
ec.set (ccndc1, "StopTime", "120s")
ec.register_connection(ccndc1, nsnode1)
- ccnd2 = ec.register_resource("ns3::LinuxCCNDceApplication")
+ ccnd2 = ec.register_resource("linux::ns3::dce::CCNApplication")
ec.set (ccnd2, "binary", "ccnd")
ec.set (ccnd2, "stackSize", 1<<20)
ec.set (ccnd2, "environment", "CCND_CAP=50000; CCND_DEBUG=7")
ec.set (ccnd2, "StopTime", "120s")
ec.register_connection(ccnd2, nsnode2)
- ccndc2 = ec.register_resource("ns3::LinuxCCNDceApplication")
+ ccndc2 = ec.register_resource("linux::ns3::dce::CCNApplication")
ec.set (ccndc2, "binary", "ccndc")
ec.set (ccndc2, "arguments", "-v;add;ccnx:/;udp;10.0.0.1")
ec.set (ccndc2, "stackSize", 1<<20)
ec.set (ccndc2, "StopTime", "120s")
ec.register_connection(ccndc2, nsnode2)
- ccnpeek = ec.register_resource("ns3::LinuxCCNDceApplication")
+ ccnpeek = ec.register_resource("linux::ns3::dce::CCNApplication")
ec.set (ccnpeek, "binary", "ccnpeek")
ec.set (ccnpeek, "arguments", "ccnx:/test/bunny.ts")
ec.set (ccnpeek, "stdinFile", "")
ec.set (ccnpeek, "StopTime", "120s")
ec.register_connection(ccnpeek, nsnode2)
- ccncat = ec.register_resource("ns3::LinuxCCNDceApplication")
+ ccncat = ec.register_resource("linux::ns3::dce::CCNApplication")
ec.set (ccncat, "binary", "ccncat")
ec.set (ccncat, "arguments", "ccnx:/test/bunny.ts")
ec.set (ccncat, "stdinFile", "")
def t_dce_ping(self, host, user = None, identity = None):
ec = ExperimentController(exp_id = "test-dce-ping-app")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", host)
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.set(simu, "buildMode", "debug")
ec.set(simu, "nsLog", "DceApplication")
ec.register_connection(chan, p2p2)
### create applications
- ping = ec.register_resource("ns3::LinuxDcePing")
+ ping = ec.register_resource("linux::ns3::dce::Ping")
ec.set (ping, "stackSize", 1<<20)
ec.set (ping, "target", "10.0.0.2")
ec.set (ping, "count", "10")
def t_dummy(self, host, user = None, identity = None):
ec = ExperimentController(exp_id = "test-ns3-fd-dummy")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", "localhost")
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanExperiment", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "simulatorImplementationType", "ns3::RealtimeSimulatorImpl")
ec.set(simu, "checksumEnabled", True)
ec.set(simu, "verbose", True)
def t_p2p_ping(self, host, user = None, identity = None):
ec = ExperimentController(exp_id = "test-ns3-p2p-ping")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", "localhost")
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
def t_csma_ping(self, host, user = None, identity = None):
ec = ExperimentController(exp_id = "test-ns3-csma-ping")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", "localhost")
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
def t_user_sources(self, host, user = None, identity = None):
ec = ExperimentController(exp_id = "test-ns3-user-sources")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", "localhost")
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
sources = os.path.join(os.path.dirname(os.path.realpath(__file__)),
"ns-3.18-user.tar.gz")
def t_compile_debug_mode(self, host, user = None, identity = None):
ec = ExperimentController(exp_id = "test-ns3-debug-mode")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", host)
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.set(simu, "nsLog", "V4Ping:Node")
ec.set(simu, "buildMode", "debug")
def t_real_time(self, host, user = None, identity = None):
ec = ExperimentController(exp_id = "test-ns3-real-time")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", "localhost")
else:
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "simulatorImplementationType", "ns3::RealtimeSimulatorImpl")
ec.set(simu, "checksumEnabled", True)
ec.set(simu, "verbose", True)
def t_traces(self, host, user = None, identity = None):
ec = ExperimentController(exp_id = "test-ns3-traces")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", "localhost")
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
ec = ExperimentController(exp_id = "test-ns3-wifi-ping")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", "localhost")
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
"""
ec = ExperimentController(exp_id = "test-ns3-routes")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", host)
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
"""
ec = ExperimentController(exp_id = "test-ns3-routing")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", "localhost")
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.set(simu, "populateRoutingTables", True)
ec.register_connection(simu, node)
def t_dce(self, host, user = None, identity = None):
ec = ExperimentController(exp_id = "test-ns3-dce")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", host)
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.set(simu, "buildMode", "debug")
ec.set(simu, "nsLog", "DceApplication")
ec.register_connection(chan, p2p2)
### create applications
- udp_perf = ec.register_resource("ns3::DceApplication")
+ udp_perf = ec.register_resource("linux::ns3::dce::Application")
ec.set (udp_perf, "binary", "udp-perf")
ec.set (udp_perf, "stackSize", 1<<20)
ec.set (udp_perf, "arguments", "--duration=10;--nodes=2")
ec.set (udp_perf, "StopTime", "20s")
ec.register_connection(udp_perf, nsnode1)
- udp_perf_client = ec.register_resource("ns3::DceApplication")
+ udp_perf_client = ec.register_resource("linux::ns3::dce::Application")
ec.set (udp_perf_client, "binary", "udp-perf")
ec.set (udp_perf_client, "stackSize", 1<<20)
ec.set (udp_perf_client, "arguments", "--client;--nodes=2;--host=10.0.0.1;--duration=10")
ec = ExperimentController(exp_id = "test-ns3-wifi-ping")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", "localhost")
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
ec = ExperimentController(exp_id = "test-ns3-routes")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", host)
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
ec = ExperimentController(exp_id = "test-ns3-dce")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
if host == "localhost":
ec.set(node, "hostname", host)
else:
ec.set(node, "cleanProcesses", True)
#ec.set(node, "cleanHome", True)
- simu = ec.register_resource("LinuxNS3Simulation")
+ simu = ec.register_resource("linux::ns3::Simulation")
ec.set(simu, "verbose", True)
ec.register_connection(simu, node)
ec.register_connection(chan, p2p2)
### create applications
- udp_perf = ec.register_resource("ns3::DceApplication")
+ udp_perf = ec.register_resource("linux::ns3::dce::Application")
ec.set (udp_perf, "binary", "udp-perf")
ec.set (udp_perf, "stackSize", 1<<20)
ec.set (udp_perf, "arguments", "--duration=10;--nodes=2")
ec.set (udp_perf, "StopTime", "20s")
ec.register_connection(udp_perf, nsnode1)
- udp_perf_client = ec.register_resource("ns3::DceApplication")
+ udp_perf_client = ec.register_resource("linux::ns3::dce::Application")
ec.set (udp_perf_client, "binary", "udp-perf")
ec.set (udp_perf_client, "stackSize", 1<<20)
ec.set (udp_perf_client, "arguments", "--client;--nodes=2;--host=10.0.0.1;--duration=10")
ec = ExperimentController(exp_id = "test-ping-count")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- app = ec.register_resource("LinuxPing")
+ app = ec.register_resource("linux::Ping")
ec.set(app, "count", "3")
ec.set(app, "target", self.target)
ec.register_connection(app, node)
ec = ExperimentController(exp_id="test-condition-serial")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- server = ec.register_resource("LinuxApplication")
+ server = ec.register_resource("linux::Application")
cmd = "echo 'HOLA' | nc -l 3333"
ec.set(server, "command", cmd)
ec.set(server, "depends", depends)
ec.register_connection(server, node)
- client = ec.register_resource("LinuxApplication")
+ client = ec.register_resource("linux::Application")
cmd = "nc 127.0.0.1 3333"
ec.set(client, "command", cmd)
ec.register_connection(client, node)
ec = ExperimentController(exp_id = "test-tap-create")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
ec.set(node, "identity", identity)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- tap = ec.register_resource("LinuxTap")
+ tap = ec.register_resource("linux::Tap")
ec.set(tap, "endpoint_ip", "%s.1" % self.netblock)
ec.set(tap, "endpoint_prefix", 24)
ec.register_connection(tap, node)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
cmd = "ping -c3 %s.1" % self.netblock
ec.set(app, "command", cmd)
ec.register_connection(app, node)
def t_tofile(self, host, user):
ec = ExperimentController(exp_id = "test-to-file")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- pcap = ec.register_resource("LinuxTcpdump")
+ pcap = ec.register_resource("linux::Tcpdump")
ec.set(pcap, "i", "eth0")
ec.set(pcap, "w", "custom_output")
ec.register_connection(pcap, node)
- app = ec.register_resource("LinuxPing")
+ app = ec.register_resource("linux::Ping")
ec.set(app, "count", "20")
ec.set(app, "target", self.target)
ec.register_connection(app, node)
ec = ExperimentController(exp_id = "test-traceroute")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- app = ec.register_resource("LinuxTraceroute")
+ app = ec.register_resource("linux::Traceroute")
ec.set(app, "target", self.target)
ec.register_connection(app, node)
ec = ExperimentController(exp_id = "test-tun-create")
- node = ec.register_resource("LinuxNode")
+ node = ec.register_resource("linux::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
ec.set(node, "identity", identity)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- tun = ec.register_resource("LinuxTun")
+ tun = ec.register_resource("linux::Tun")
ec.set(tun, "endpoint_ip", "%s.1" % self.netblock)
ec.set(tun, "endpoint_prefix", 24)
ec.register_connection(tun, node)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
cmd = "ping -c3 %s.1" % self.netblock
ec.set(app, "command", cmd)
ec.register_connection(app, node)
ec = ExperimentController(exp_id = "test-udptest-rtt")
- node1 = ec.register_resource("LinuxNode")
+ node1 = ec.register_resource("linux::Node")
ec.set(node1, "hostname", host1)
ec.set(node1, "username", user1)
- ec.set(node1, "cleanHome", True)
+ ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
- server = ec.register_resource("LinuxUdpTest")
+ server = ec.register_resource("linux::UdpTest")
ec.set(server, "s", True)
ec.register_connection(server, node1)
- node2 = ec.register_resource("LinuxNode")
+ node2 = ec.register_resource("linux::Node")
ec.set(node2, "hostname", host2)
ec.set(node2, "username", user2)
- ec.set(node2, "cleanHome", True)
+ ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
- client = ec.register_resource("LinuxUdpTest")
+ client = ec.register_resource("linux::UdpTest")
ec.set(client, "a", True)
ec.set(client, "target", host1)
ec.register_connection(client, node2)
ec = ExperimentController(exp_id = "test-tap-udp-tunnel")
- node1 = ec.register_resource("LinuxNode")
+ node1 = ec.register_resource("linux::Node")
ec.set(node1, "hostname", host1)
ec.set(node1, "username", user1)
ec.set(node1, "identity", identity1)
- ec.set(node1, "cleanHome", True)
+ ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
- tap1 = ec.register_resource("LinuxTap")
+ tap1 = ec.register_resource("linux::Tap")
ec.set(tap1, "endpoint_ip", "%s.1" % self.netblock)
ec.set(tap1, "endpoint_prefix", 32)
ec.register_connection(tap1, node1)
- node2 = ec.register_resource("LinuxNode")
+ node2 = ec.register_resource("linux::Node")
ec.set(node2, "hostname", host2)
ec.set(node2, "username", user2)
ec.set(node2, "identity", identity2)
- ec.set(node2, "cleanHome", True)
+ ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
- tap2 = ec.register_resource("LinuxTap")
+ tap2 = ec.register_resource("linux::Tap")
ec.set(tap2, "endpoint_ip", "%s.2" % self.netblock)
ec.set(tap2, "endpoint_prefix", 32)
ec.register_connection(tap2, node2)
- udptun = ec.register_resource("LinuxUdpTunnel")
+ udptun = ec.register_resource("linux::UdpTunnel")
ec.register_connection(tap1, udptun)
ec.register_connection(tap2, udptun)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
cmd = "ping -c3 %s.2" % self.netblock
ec.set(app, "command", cmd)
ec.register_connection(app, node1)
ec = ExperimentController(exp_id = "test-tun-udp-tunnel")
- node1 = ec.register_resource("LinuxNode")
+ node1 = ec.register_resource("linux::Node")
ec.set(node1, "hostname", host1)
ec.set(node1, "username", user1)
ec.set(node1, "identity", identity1)
- ec.set(node1, "cleanHome", True)
+ ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
- tun1 = ec.register_resource("LinuxTun")
+ tun1 = ec.register_resource("linux::Tun")
ec.set(tun1, "endpoint_ip", "%s.1" % self.netblock)
ec.set(tun1, "endpoint_prefix", 32)
ec.register_connection(tun1, node1)
- node2 = ec.register_resource("LinuxNode")
+ node2 = ec.register_resource("linux::Node")
ec.set(node2, "hostname", host2)
ec.set(node2, "username", user2)
ec.set(node2, "identity", identity2)
- ec.set(node2, "cleanHome", True)
+ ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
- tun2 = ec.register_resource("LinuxTun")
+ tun2 = ec.register_resource("linux::Tun")
ec.set(tun2, "endpoint_ip", "%s.2" % self.netblock)
ec.set(tun2, "endpoint_prefix", 32)
ec.register_connection(tun2, node2)
- udptun = ec.register_resource("LinuxUdpTunnel")
+ udptun = ec.register_resource("linux::UdpTunnel")
ec.register_connection(tun1, udptun)
ec.register_connection(tun2, udptun)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
cmd = "ping -c3 %s.2" % self.netblock
ec.set(app, "command", cmd)
ec.register_connection(app, node1)
class OMFResourceFactoryTestCase(unittest.TestCase):
def test_creation_phase(self):
- self.assertEquals(OMFNode.get_rtype(), "OMFNode")
+ self.assertEquals(OMFNode.get_rtype(), "omf::Node")
self.assertEquals(len(OMFNode._attributes), 8)
- self.assertEquals(OMFWifiInterface.get_rtype(), "OMFWifiInterface")
+ self.assertEquals(OMFWifiInterface.get_rtype(), "omf::WifiInterface")
self.assertEquals(len(OMFWifiInterface._attributes), 12)
- self.assertEquals(OMFChannel.get_rtype(), "OMFChannel")
+ self.assertEquals(OMFChannel.get_rtype(), "omf::Channel")
self.assertEquals(len(OMFChannel._attributes), 8)
- self.assertEquals(OMFApplication.get_rtype(), "OMFApplication")
+ self.assertEquals(OMFApplication.get_rtype(), "omf::Application")
self.assertEquals(len(OMFApplication._attributes), 14)
class OMFEachTestCase(unittest.TestCase):
def setUp(self):
self.ec = ExperimentController(exp_id = "99999")
- self.node1 = self.ec.register_resource("OMFNode")
+ self.node1 = self.ec.register_resource("omf::Node")
self.ec.set(self.node1, 'hostname', 'omf.plexus.wlab17')
self.ec.set(self.node1, 'xmppUser', "nepi")
self.ec.set(self.node1, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node1, 'xmppPassword', "1234")
self.ec.set(self.node1, 'version', "5")
- self.iface1 = self.ec.register_resource("OMFWifiInterface")
+ self.iface1 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface1, 'name', "wlan0")
self.ec.set(self.iface1, 'mode', "adhoc")
self.ec.set(self.iface1, 'hw_mode', "g")
self.ec.set(self.iface1, 'ip', "10.0.0.17/24")
self.ec.set(self.iface1, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, 'xmppUser', "nepi")
self.ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.channel, 'xmppPassword', "1234")
self.ec.set(self.channel, 'version', "5")
- self.app1 = self.ec.register_resource("OMFApplication")
+ self.app1 = self.ec.register_resource("omf::Application")
self.ec.set(self.app1, 'appid', 'Vlc#1')
self.ec.set(self.app1, 'command', "/opt/vlc-1.1.13/cvlc /opt/10-by-p0d.avi --sout '#rtp{dst=10.0.0.37,port=1234,mux=ts}'")
self.ec.set(self.app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
self.ec.set(self.app1, 'version', "5")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
self.ec.set(self.app2, 'version', "5")
- self.app3 = self.ec.register_resource("OMFApplication")
+ self.app3 = self.ec.register_resource("omf::Application")
self.ec.set(self.app3, 'version', "5")
- self.app4 = self.ec.register_resource("OMFApplication")
+ self.app4 = self.ec.register_resource("omf::Application")
self.ec.set(self.app4, 'version', "5")
- self.app5 = self.ec.register_resource("OMFApplication")
+ self.app5 = self.ec.register_resource("omf::Application")
self.ec.set(self.app5, 'version', "5")
self.ec.register_connection(self.app1, self.node1)
def test_deploy(self):
ec = ExperimentController(exp_id = "5421" )
- self.node1 = ec.register_resource("OMFNode")
+ self.node1 = ec.register_resource("omf::Node")
ec.set(self.node1, 'hostname', 'omf.plexus.wlab17')
ec.set(self.node1, 'xmppUser', "nepi")
ec.set(self.node1, 'xmppServer', "xmpp-plexus.onelab.eu")
ec.set(self.node1, 'xmppPassword', "1234")
ec.set(self.node1, 'version', "5")
- self.iface1 = ec.register_resource("OMFWifiInterface")
+ self.iface1 = ec.register_resource("omf::WifiInterface")
ec.set(self.iface1, 'name', "wlan0")
ec.set(self.iface1, 'mode', "adhoc")
ec.set(self.iface1, 'hw_mode', "g")
ec.set(self.iface1, 'ip', "10.0.0.17/24")
ec.set(self.iface1, 'version', "5")
- self.channel = ec.register_resource("OMFChannel")
+ self.channel = ec.register_resource("omf::Channel")
ec.set(self.channel, 'channel', "6")
ec.set(self.channel, 'xmppUser', "nepi")
ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
ec.set(self.channel, 'xmppPassword', "1234")
ec.set(self.channel, 'version', "5")
- self.app1 = ec.register_resource("OMFApplication")
+ self.app1 = ec.register_resource("omf::Application")
ec.set(self.app1, 'appid', 'Vlc#1')
ec.set(self.app1, 'command', "/opt/vlc-1.1.13/cvlc /opt/10-by-p0d.avi --sout '#rtp{dst=10.0.0.37,port=1234,mux=ts}'")
ec.set(self.app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
ec.set(self.app1, 'version', "5")
- self.app2 = ec.register_resource("OMFApplication")
+ self.app2 = ec.register_resource("omf::Application")
ec.set(self.app2, 'appid', 'Test#1')
ec.set(self.app2, 'command', "/usr/bin/test -1")
ec.set(self.app2, 'env', " ")
ec.set(self.app2, 'version', "5")
- self.app3 = ec.register_resource("OMFApplication")
+ self.app3 = ec.register_resource("omf::Application")
ec.set(self.app3, 'appid', 'Test#2')
ec.set(self.app3, 'command', "/usr/bin/test -2")
ec.set(self.app3, 'env', " ")
ec.set(self.app3, 'version', "5")
- self.app4 = ec.register_resource("OMFApplication")
+ self.app4 = ec.register_resource("omf::Application")
ec.set(self.app4, 'appid', 'Test#3')
ec.set(self.app4, 'command', "/usr/bin/test -3")
ec.set(self.app4, 'env', " ")
ec.set(self.app4, 'version', "5")
- self.app5 = ec.register_resource("OMFApplication")
+ self.app5 = ec.register_resource("omf::Application")
ec.set(self.app5, 'appid', 'Kill#2')
ec.set(self.app5, 'command', "/usr/bin/killall vlc")
ec.set(self.app5, 'env', " ")
self.ec = ExperimentController(exp_id = str(OMFVLCWrongCaseAllCritical.id))
OMFVLCWrongCaseAllCritical.id += 1
- self.node1 = self.ec.register_resource("OMFNode")
+ self.node1 = self.ec.register_resource("omf::Node")
self.ec.set(self.node1, 'hostname', 'omf.plexus.wlab17')
self.ec.set(self.node1, 'xmppUser', "nepi")
self.ec.set(self.node1, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node1, 'xmppPassword', "1234")
self.ec.set(self.node1, 'version', "5")
- self.iface1 = self.ec.register_resource("OMFWifiInterface")
+ self.iface1 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface1, 'name', "wlan0")
self.ec.set(self.iface1, 'mode', "adhoc")
self.ec.set(self.iface1, 'hw_mode', "g")
self.ec.set(self.iface1, 'ip', "10.0.0.17/24")
self.ec.set(self.iface1, 'version', "5")
- self.app1 = self.ec.register_resource("OMFApplication")
+ self.app1 = self.ec.register_resource("omf::Application")
self.ec.set(self.app1, 'appid', 'Vlc#1')
self.ec.set(self.app1, 'command', "/opt/vlc-1.1.13/cvlc /opt/10-by-p0d.avi --sout '#rtp{dst=10.0.0.37,port=1234,mux=ts}'")
self.ec.set(self.app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
self.ec.register_connection(self.node1, self.iface1)
def test_deploy_wo_node(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'version', "5")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'ip', "10.0.0.37/24")
self.ec.set(self.iface2, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, 'xmppUser', "nepi")
self.ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
def test_deploy_wo_hostname(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPort', "5222")
self.ec.set(self.node2, 'xmppPassword', "1234")
self.ec.set(self.node2, 'version', "5")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'ip', "10.0.0.37/24")
self.ec.set(self.iface2, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, 'xmppUser', "nepi")
self.ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
self.assertEquals(self.ec.get_resource(self.app1).state, ResourceState.RELEASED)
def test_deploy_wo_iface(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'omf.plexus.wlab17')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPassword', "1234")
self.ec.set(self.node2, 'version', "5")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, 'xmppUser', "nepi")
self.ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
self.assertEquals(self.ec.get_resource(self.app1).state, ResourceState.RELEASED)
def test_deploy_wo_ip(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'omf.plexus.wlab17')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPassword', "1234")
self.ec.set(self.node2, 'version', "5")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'essid', "vlcexp")
self.ec.set(self.iface2, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, 'xmppUser', "nepi")
self.ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
self.assertEquals(self.ec.get_resource(self.app1).state, ResourceState.RELEASED)
def test_deploy_wo_channel(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'omf.plexus.wlab17')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPassword', "1234")
self.ec.set(self.node2, 'version', "5")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'essid', "vlcexp")
self.ec.set(self.iface2, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'version', "5")
self.ec.register_connection(self.iface1, self.channel)
self.assertEquals(self.ec.get_resource(self.app1).state, ResourceState.RELEASED)
def test_deploy_wo_app(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'omf.plexus.wlab17')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPassword', "1234")
self.ec.set(self.node2, 'version', "5")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'ip', "10.0.0.37/24")
self.ec.set(self.iface2, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, 'xmppUser', "nepi")
self.ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.channel, 'xmppPassword', "1234")
self.ec.set(self.channel, 'version', "5")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
self.ec.set(self.app2, 'version', "5")
self.ec.register_connection(self.iface1, self.channel)
self.assertEquals(self.ec.get_resource(self.app2).state, ResourceState.RELEASED)
def test_deploy_wo_app_path(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'omf.plexus.wlab17')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPassword', "1234")
self.ec.set(self.node2, 'version', "5")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'ip', "10.0.0.37/24")
self.ec.set(self.iface2, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, 'xmppUser', "nepi")
self.ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.channel, 'xmppPassword', "1234")
self.ec.set(self.channel, 'version', "5")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
self.ec.set(self.app2, 'appid', 'Vlc#2')
self.ec.set(self.app2, 'version', "5")
self.ec = ExperimentController(exp_id = str(OMFVLCWrongCaseWithNonCritical.id))
OMFVLCWrongCaseWithNonCritical.id += 1
- self.node1 = self.ec.register_resource("OMFNode")
+ self.node1 = self.ec.register_resource("omf::Node")
self.ec.set(self.node1, 'hostname', 'omf.plexus.wlab17')
self.ec.set(self.node1, 'xmppUser', "nepi")
self.ec.set(self.node1, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node1, 'xmppPassword', "1234")
self.ec.set(self.node1, 'version', "5")
- self.iface1 = self.ec.register_resource("OMFWifiInterface")
+ self.iface1 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface1, 'name', "wlan0")
self.ec.set(self.iface1, 'mode', "adhoc")
self.ec.set(self.iface1, 'hw_mode', "g")
self.ec.set(self.iface1, 'ip', "10.0.0.17/24")
self.ec.set(self.iface1, 'version', "5")
- self.app1 = self.ec.register_resource("OMFApplication")
+ self.app1 = self.ec.register_resource("omf::Application")
self.ec.set(self.app1, 'appid', 'Kill#1')
self.ec.set(self.app1, 'command', "/usr/bin/test -1")
self.ec.set(self.app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
self.ec.register_connection(self.node1, self.iface1)
def test_deploy_with_node_nc(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, "critical", False)
self.ec.set(self.node2, 'version', "5")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'ip', "10.0.0.37/24")
self.ec.set(self.iface2, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, 'xmppUser', "nepi")
self.ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
self.assertEquals(self.ec.get_resource(self.app1).state, ResourceState.RELEASED)
def test_deploy_with_node_and_iface_nc(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, "critical", False)
self.ec.set(self.node2, 'version', "5")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.node2, "critical", False)
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'ip', "10.0.0.37/24")
self.ec.set(self.iface2, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, 'xmppUser', "nepi")
self.ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
self.assertEquals(self.ec.get_resource(self.app1).state, ResourceState.RELEASED)
def test_deploy_with_node_iface_channel_nc(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, "critical", False)
self.ec.set(self.node2, 'hostname', 'omf.plexus.wlab37')
self.ec.set(self.node2, 'version', "5")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.node2, "critical", False)
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'ip', "10.0.0.37/24")
self.ec.set(self.iface2, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, "critical", False)
self.ec.set(self.channel, 'version', "5")
self.assertEquals(self.ec.get_resource(self.app1).state, ResourceState.RELEASED)
def test_deploy_with_app_nc(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'omf.plexus.wlab37')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPassword', "1234")
self.ec.set(self.node2, 'version', "5")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'ip', "10.0.0.37/24")
self.ec.set(self.iface2, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, 'xmppUser', "nepi")
self.ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.channel, 'xmppPassword', "1234")
self.ec.set(self.channel, 'version', "5")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
self.ec.set(self.app2, "critical", False)
self.ec.set(self.app2, 'appid', 'Kill#22')
self.ec.set(self.app2, 'version', "5")
self.assertEquals(self.ec.get_resource(self.app2).state, ResourceState.RELEASED)
def test_deploy_with_all_nc_and_app_critical(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, "critical", False)
self.ec.set(self.node2, 'hostname', 'omf.plexus.wlab37')
self.ec.set(self.node2, 'version', "5")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, "critical", False)
self.ec.set(self.iface2, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, "critical", False)
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, 'version', "5")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
self.ec.set(self.app2, 'appid', 'Kill#22')
self.ec.set(self.app2, 'version', "5")
self.ec = ExperimentController(exp_id = str(OMFVLCWrongCaseWithNonCriticalDep.id))
OMFVLCWrongCaseWithNonCriticalDep.id += 1
- self.node1 = self.ec.register_resource("OMFNode")
+ self.node1 = self.ec.register_resource("omf::Node")
self.ec.set(self.node1, 'hostname', 'omf.plexus.wlab17')
self.ec.set(self.node1, 'xmppUser', "nepi")
self.ec.set(self.node1, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node1, 'xmppPassword', "1234")
self.ec.set(self.node1, 'version', "5")
- self.iface1 = self.ec.register_resource("OMFWifiInterface")
+ self.iface1 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface1, 'name', "wlan0")
self.ec.set(self.iface1, 'mode', "adhoc")
self.ec.set(self.iface1, 'hw_mode', "g")
self.ec.set(self.iface1, 'ip', "10.0.0.17/24")
self.ec.set(self.iface1, 'version', "5")
- self.app1 = self.ec.register_resource("OMFApplication")
+ self.app1 = self.ec.register_resource("omf::Application")
self.ec.set(self.app1, 'appid', 'Kill#1')
self.ec.set(self.app1, 'command', "/usr/bin/test -1")
self.ec.set(self.app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
self.ec.register_connection(self.node1, self.iface1)
def test_deploy_with_app_nc_and_critical_wrong(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'omf.plexus.wlab37')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPassword', "1234")
self.ec.set(self.node2, 'version', "5")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'ip', "10.0.0.37/24")
self.ec.set(self.iface2, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, 'xmppUser', "nepi")
self.ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.channel, 'xmppPassword', "1234")
self.ec.set(self.channel, 'version', "5")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
self.ec.set(self.app2, "critical", False)
self.ec.set(self.app2, 'appid', 'Kill#32')
self.ec.set(self.app2, 'version', "5")
- self.app3 = self.ec.register_resource("OMFApplication")
+ self.app3 = self.ec.register_resource("omf::Application")
self.ec.set(self.app3, 'appid', 'Kill#33')
self.ec.set(self.app3, 'version', "5")
self.assertEquals(self.ec.get_resource(self.app3).state, ResourceState.RELEASED)
def test_deploy_with_app_nc_and_critical_right(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'omf.plexus.wlab37')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPassword', "1234")
self.ec.set(self.node2, 'version', "5")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'ip', "10.0.0.37/24")
self.ec.set(self.iface2, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, 'xmppUser', "nepi")
self.ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.channel, 'xmppPassword', "1234")
self.ec.set(self.channel, 'version', "5")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
self.ec.set(self.app2, "critical", False)
self.ec.set(self.app2, 'appid', 'Kill#32')
self.ec.set(self.app2, 'version', "5")
- self.app3 = self.ec.register_resource("OMFApplication")
+ self.app3 = self.ec.register_resource("omf::Application")
self.ec.set(self.app3, 'appid', 'Kill#3')
self.ec.set(self.app3, 'command', "/usr/bin/test -1")
self.ec.set(self.app3, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
def test_deploy_with_many_app_nc_and_critical(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'omf.plexus.wlab37')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPassword', "1234")
self.ec.set(self.node2, 'version', "5")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'ip', "10.0.0.37/24")
self.ec.set(self.iface2, 'version', "5")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, 'xmppUser', "nepi")
self.ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.channel, 'xmppPassword', "1234")
self.ec.set(self.channel, 'version', "5")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
self.ec.set(self.app2, "critical", False)
self.ec.set(self.app2, 'appid', 'Kill#32')
self.ec.set(self.app2, 'version', "5")
- self.app3 = self.ec.register_resource("OMFApplication")
+ self.app3 = self.ec.register_resource("omf::Application")
self.ec.set(self.app3, "critical", False)
self.ec.set(self.app3, 'appid', 'Kill#3')
self.ec.set(self.app3, 'command', "/usr/bin/test -1")
self.ec.set(self.app3, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
self.ec.set(self.app3, 'version', "5")
- self.app4 = self.ec.register_resource("OMFApplication")
+ self.app4 = self.ec.register_resource("omf::Application")
self.ec.set(self.app4, 'appid', 'Kill#4')
self.ec.set(self.app4, 'command', "/usr/bin/test -1")
self.ec.set(self.app4, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
self.ec.set(self.app4, 'version', "5")
- self.app5 = self.ec.register_resource("OMFApplication")
+ self.app5 = self.ec.register_resource("omf::Application")
self.ec.set(self.app5, "critical", False)
self.ec.set(self.app5, 'appid', 'Kill#32')
self.ec.set(self.app5, 'version', "5")
- self.app6 = self.ec.register_resource("OMFApplication")
+ self.app6 = self.ec.register_resource("omf::Application")
self.ec.set(self.app6, 'appid', 'Kill#6')
self.ec.set(self.app6, 'command', "/usr/bin/test -1")
self.ec.set(self.app6, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
class OMFResourceFactoryTestCase(unittest.TestCase):
def test_creation_phase(self):
- self.assertEquals(OMFNode.get_rtype(), "OMFNode")
+ self.assertEquals(OMFNode.get_rtype(), "omf::Node")
self.assertEquals(len(OMFNode._attributes), 8)
- self.assertEquals(OMFWifiInterface.get_rtype(), "OMFWifiInterface")
+ self.assertEquals(OMFWifiInterface.get_rtype(), "omf::WifiInterface")
self.assertEquals(len(OMFWifiInterface._attributes), 12)
- self.assertEquals(OMFChannel.get_rtype(), "OMFChannel")
+ self.assertEquals(OMFChannel.get_rtype(), "omf::Channel")
self.assertEquals(len(OMFChannel._attributes), 8)
- self.assertEquals(OMFApplication.get_rtype(), "OMFApplication")
+ self.assertEquals(OMFApplication.get_rtype(), "omf::Application")
self.assertEquals(len(OMFApplication._attributes), 14)
class OMFEachTestCase(unittest.TestCase):
def setUp(self):
self.ec = ExperimentController(exp_id = "99999")
- self.node1 = self.ec.register_resource("OMFNode")
+ self.node1 = self.ec.register_resource("omf::Node")
self.ec.set(self.node1, 'hostname', 'wlab12')
self.ec.set(self.node1, 'xmppUser', "nepi")
self.ec.set(self.node1, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node1, 'xmppPort', "5222")
self.ec.set(self.node1, 'xmppPassword', "1234")
- self.iface1 = self.ec.register_resource("OMFWifiInterface")
+ self.iface1 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface1, 'name', "wlan0")
self.ec.set(self.iface1, 'mode', "adhoc")
self.ec.set(self.iface1, 'hw_mode', "g")
self.ec.set(self.iface1, 'essid', "vlcexp")
self.ec.set(self.iface1, 'ip', "10.0.0.17/24")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, 'xmppUser', "nepi")
self.ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.channel, 'xmppPort', "5222")
self.ec.set(self.channel, 'xmppPassword', "1234")
- self.app1 = self.ec.register_resource("OMFApplication")
+ self.app1 = self.ec.register_resource("omf::Application")
self.ec.set(self.app1, 'appid', 'Vlc#1')
self.ec.set(self.app1, 'command', "/opt/vlc-1.1.13/cvlc /opt/10-by-p0d.avi --sout '#rtp{dst=10.0.0.37,port=1234,mux=ts}'")
self.ec.set(self.app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
- self.app3 = self.ec.register_resource("OMFApplication")
+ self.app3 = self.ec.register_resource("omf::Application")
- self.app4 = self.ec.register_resource("OMFApplication")
+ self.app4 = self.ec.register_resource("omf::Application")
- self.app5 = self.ec.register_resource("OMFApplication")
+ self.app5 = self.ec.register_resource("omf::Application")
self.ec.register_connection(self.app1, self.node1)
self.ec.register_connection(self.app2, self.node1)
def test_deploy(self):
ec = ExperimentController(exp_id = "5421" )
- self.node1 = ec.register_resource("OMFNode")
+ self.node1 = ec.register_resource("omf::Node")
ec.set(self.node1, 'hostname', 'wlab12')
ec.set(self.node1, 'xmppUser', "nepi")
ec.set(self.node1, 'xmppServer', "xmpp-plexus.onelab.eu")
ec.set(self.node1, 'xmppPort', "5222")
ec.set(self.node1, 'xmppPassword', "1234")
- self.iface1 = ec.register_resource("OMFWifiInterface")
+ self.iface1 = ec.register_resource("omf::WifiInterface")
ec.set(self.iface1, 'name', "wlan0")
ec.set(self.iface1, 'mode', "adhoc")
ec.set(self.iface1, 'hw_mode', "g")
ec.set(self.iface1, 'essid', "vlcexp")
ec.set(self.iface1, 'ip', "10.0.0.17/24")
- self.channel = ec.register_resource("OMFChannel")
+ self.channel = ec.register_resource("omf::Channel")
ec.set(self.channel, 'channel', "6")
ec.set(self.channel, 'xmppUser', "nepi")
ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
ec.set(self.channel, 'xmppPort', "5222")
ec.set(self.channel, 'xmppPassword', "1234")
- self.app1 = ec.register_resource("OMFApplication")
+ self.app1 = ec.register_resource("omf::Application")
ec.set(self.app1, 'appid', 'Vlc#1')
ec.set(self.app1, 'command', "/opt/vlc-1.1.13/cvlc /opt/10-by-p0d.avi --sout '#rtp{dst=10.0.0.37,port=1234,mux=ts}'")
ec.set(self.app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
- self.app2 = ec.register_resource("OMFApplication")
+ self.app2 = ec.register_resource("omf::Application")
ec.set(self.app2, 'appid', 'Test#1')
ec.set(self.app2, 'command', "/usr/bin/test -1")
ec.set(self.app2, 'env', " ")
- self.app3 = ec.register_resource("OMFApplication")
+ self.app3 = ec.register_resource("omf::Application")
ec.set(self.app3, 'appid', 'Test#2')
ec.set(self.app3, 'command', "/usr/bin/test -2")
ec.set(self.app3, 'env', " ")
- self.app4 = ec.register_resource("OMFApplication")
+ self.app4 = ec.register_resource("omf::Application")
ec.set(self.app4, 'appid', 'Test#3')
ec.set(self.app4, 'command', "/usr/bin/test -3")
ec.set(self.app4, 'env', " ")
- self.app5 = ec.register_resource("OMFApplication")
+ self.app5 = ec.register_resource("omf::Application")
ec.set(self.app5, 'appid', 'Kill#2')
ec.set(self.app5, 'command', "/usr/bin/killall vlc")
ec.set(self.app5, 'env', " ")
def test_deploy(self):
ec = ExperimentController(exp_id = "5421" )
- self.node1 = ec.register_resource("OMFNode")
+ self.node1 = ec.register_resource("omf::Node")
ec.set(self.node1, 'hostname', 'wlab12')
ec.set(self.node1, 'xmppUser', "nepi")
ec.set(self.node1, 'xmppServer', "xmpp-plexus.onelab.eu")
ec.set(self.node1, 'xmppPort', "5222")
ec.set(self.node1, 'xmppPassword', "1234")
- self.iface1 = ec.register_resource("OMFWifiInterface")
+ self.iface1 = ec.register_resource("omf::WifiInterface")
ec.set(self.iface1, 'name', "wlan0")
ec.set(self.iface1, 'mode', "adhoc")
ec.set(self.iface1, 'hw_mode', "g")
ec.set(self.iface1, 'essid', "vlcexp")
ec.set(self.iface1, 'ip', "10.0.0.17/24")
- self.channel = ec.register_resource("OMFChannel")
+ self.channel = ec.register_resource("omf::Channel")
ec.set(self.channel, 'channel', "6")
ec.set(self.channel, 'xmppUser', "nepi")
ec.set(self.channel, 'xmppServer', "xmpp-plexus.onelab.eu")
ec.set(self.channel, 'xmppPort', "5222")
ec.set(self.channel, 'xmppPassword', "1234")
- self.app1 = ec.register_resource("OMFApplication")
+ self.app1 = ec.register_resource("omf::Application")
ec.set(self.app1, 'appid', 'Vlc#1')
ec.set(self.app1, 'command', "ping -c5 10.0.0.17")
self.ec = ExperimentController(exp_id = str(OMFVLCWrongCaseAllCritical.id))
OMFVLCWrongCaseAllCritical.id += 1
- self.node1 = self.ec.register_resource("OMFNode")
+ self.node1 = self.ec.register_resource("omf::Node")
self.ec.set(self.node1, 'hostname', 'wlab12')
self.ec.set(self.node1, 'xmppUser', "nepi")
self.ec.set(self.node1, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node1, 'xmppPort', "5222")
self.ec.set(self.node1, 'xmppPassword', "1234")
- self.iface1 = self.ec.register_resource("OMFWifiInterface")
+ self.iface1 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface1, 'name', "wlan0")
self.ec.set(self.iface1, 'mode', "adhoc")
self.ec.set(self.iface1, 'hw_mode', "g")
self.ec.set(self.iface1, 'essid', "vlcexp")
self.ec.set(self.iface1, 'ip', "10.0.0.12/24")
- self.app1 = self.ec.register_resource("OMFApplication")
+ self.app1 = self.ec.register_resource("omf::Application")
self.ec.set(self.app1, 'appid', 'Vlc#1')
self.ec.set(self.app1, 'command', "/opt/vlc-1.1.13/cvlc /opt/10-by-p0d.avi --sout '#rtp{dst=10.0.0.49,port=1234,mux=ts}'")
self.ec.set(self.app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
self.ec.register_connection(self.node1, self.iface1)
def test_deploy_wo_node(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'essid', "vlcexp")
self.ec.set(self.iface2, 'ip', "10.0.0.49/24")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.register_connection(self.iface1, self.channel)
def test_deploy_wo_hostname(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPort', "5222")
self.ec.set(self.node2, 'xmppPassword', "1234")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'essid', "vlcexp")
self.ec.set(self.iface2, 'ip', "10.0.0.49/24")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.register_connection(self.iface1, self.channel)
self.assertEquals(self.ec.get_resource(self.app1).state, ResourceState.RELEASED)
def test_deploy_wo_iface(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'wlab49')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPort', "5222")
self.ec.set(self.node2, 'xmppPassword', "1234")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.register_connection(self.iface1, self.channel)
self.assertEquals(self.ec.get_resource(self.app1).state, ResourceState.RELEASED)
def test_deploy_wo_channel(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'wlab49')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPort', "5222")
self.ec.set(self.node2, 'xmppPassword', "1234")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'essid', "vlcexp")
self.ec.set(self.iface2, 'ip', "10.0.0.49/24")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.register_connection(self.iface1, self.channel)
self.ec.register_connection(self.node2, self.iface2)
self.assertEquals(self.ec.get_resource(self.app1).state, ResourceState.RELEASED)
def test_deploy_wo_ip(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'wlab49')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPort', "5222")
self.ec.set(self.node2, 'xmppPassword', "1234")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'essid', "vlcexp")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.register_connection(self.iface1, self.channel)
self.assertEquals(self.ec.get_resource(self.app1).state, ResourceState.RELEASED)
def test_deploy_wo_app(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'wlab49')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPort', "5222")
self.ec.set(self.node2, 'xmppPassword', "1234")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'essid', "vlcexp")
self.ec.set(self.iface2, 'ip', "10.0.0.49/24")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
self.ec.register_connection(self.iface1, self.channel)
self.ec.register_connection(self.iface2, self.channel)
self.assertEquals(self.ec.get_resource(self.app2).state, ResourceState.RELEASED)
def test_deploy_wo_app_path(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'wlab49')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPort', "5222")
self.ec.set(self.node2, 'xmppPassword', "1234")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'essid', "vlcexp")
self.ec.set(self.iface2, 'ip', "10.0.0.49/24")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
self.ec.set(self.app2, 'appid', 'Vlc#2')
self.ec.register_connection(self.iface1, self.channel)
# Author: Julien Tribino <julien.tribino@inria.fr>
-from nepi.execution.resource import ResourceFactory, ResourceManager, ResourceAction, ResourceState
+from nepi.execution.resource import ResourceFactory, ResourceManager, \
+ ResourceAction, ResourceState
from nepi.execution.ec import ExperimentController
from nepi.resources.omf.node import OMFNode
self.ec = ExperimentController(exp_id = str(OMFVLCWrongCaseWithNonCritical.id))
OMFVLCWrongCaseWithNonCritical.id += 1
- self.node1 = self.ec.register_resource("OMFNode")
+ self.node1 = self.ec.register_resource("omf::Node")
self.ec.set(self.node1, 'hostname', 'wlab12')
self.ec.set(self.node1, 'xmppUser', "nepi")
self.ec.set(self.node1, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node1, 'xmppPort', "5222")
self.ec.set(self.node1, 'xmppPassword', "1234")
- self.iface1 = self.ec.register_resource("OMFWifiInterface")
+ self.iface1 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface1, 'name', "wlan0")
self.ec.set(self.iface1, 'mode', "adhoc")
self.ec.set(self.iface1, 'hw_mode', "g")
self.ec.set(self.iface1, 'essid', "vlcexp")
self.ec.set(self.iface1, 'ip', "10.0.0.12/24")
- self.app1 = self.ec.register_resource("OMFApplication")
+ self.app1 = self.ec.register_resource("omf::Application")
self.ec.set(self.app1, 'appid', 'Kill#1')
self.ec.set(self.app1, 'command', "/usr/bin/test -1")
self.ec.set(self.app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
self.ec.register_connection(self.node1, self.iface1)
def test_deploy_with_node_nc(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, "critical", False)
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'essid', "vlcexp")
self.ec.set(self.iface2, 'ip', "10.0.0.49/24")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.register_connection(self.iface1, self.channel)
self.assertEquals(self.ec.get_resource(self.app1).state, ResourceState.RELEASED)
def test_deploy_with_node_and_iface_nc(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, "critical", False)
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.node2, "critical", False)
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'essid', "vlcexp")
self.ec.set(self.iface2, 'ip', "10.0.0.49/24")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.register_connection(self.iface1, self.channel)
self.assertEquals(self.ec.get_resource(self.app1).state, ResourceState.RELEASED)
def test_deploy_with_node_iface_channel_nc(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, "critical", False)
self.ec.set(self.node2, 'hostname', 'wlab49')
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.node2, "critical", False)
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'essid', "vlcexp")
self.ec.set(self.iface2, 'ip', "10.0.0.49/24")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
self.ec.set(self.channel, "critical", False)
self.assertEquals(self.ec.get_resource(self.app1).state, ResourceState.RELEASED)
def test_deploy_with_app_nc(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'wlab49')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPort', "5222")
self.ec.set(self.node2, 'xmppPassword', "1234")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'essid', "vlcexp")
self.ec.set(self.iface2, 'ip', "10.0.0.49/24")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
self.ec.set(self.app2, "critical", False)
self.ec.set(self.app2, 'appid', 'Kill#22')
self.assertEquals(self.ec.get_resource(self.app2).state, ResourceState.RELEASED)
def test_deploy_with_all_nc_and_app_critical(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, "critical", False)
self.ec.set(self.node2, 'hostname', 'wlab49')
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, "critical", False)
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, "critical", False)
self.ec.set(self.channel, 'channel', "6")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
self.ec.set(self.app2, 'appid', 'Kill#22')
self.ec.register_connection(self.iface1, self.channel)
self.ec = ExperimentController(exp_id = str(OMFVLCWrongCaseWithNonCriticalDep.id))
OMFVLCWrongCaseWithNonCriticalDep.id += 1
- self.node1 = self.ec.register_resource("OMFNode")
+ self.node1 = self.ec.register_resource("omf::Node")
self.ec.set(self.node1, 'hostname', 'wlab12')
self.ec.set(self.node1, 'xmppUser', "nepi")
self.ec.set(self.node1, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node1, 'xmppPort', "5222")
self.ec.set(self.node1, 'xmppPassword', "1234")
- self.iface1 = self.ec.register_resource("OMFWifiInterface")
+ self.iface1 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface1, 'name', "wlan0")
self.ec.set(self.iface1, 'mode', "adhoc")
self.ec.set(self.iface1, 'hw_mode', "g")
self.ec.set(self.iface1, 'essid', "vlcexp")
self.ec.set(self.iface1, 'ip', "10.0.0.12/24")
- self.app1 = self.ec.register_resource("OMFApplication")
+ self.app1 = self.ec.register_resource("omf::Application")
self.ec.set(self.app1, 'appid', 'Kill#1')
self.ec.set(self.app1, 'command', "/usr/bin/test -1")
self.ec.set(self.app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
self.ec.register_connection(self.node1, self.iface1)
def test_deploy_with_app_nc_and_critical_wrong(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'wlab49')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPort', "5222")
self.ec.set(self.node2, 'xmppPassword', "1234")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'essid', "vlcexp")
self.ec.set(self.iface2, 'ip', "10.0.0.49/24")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
self.ec.set(self.app2, "critical", False)
self.ec.set(self.app2, 'appid', 'Kill#32')
- self.app3 = self.ec.register_resource("OMFApplication")
+ self.app3 = self.ec.register_resource("omf::Application")
self.ec.set(self.app3, 'appid', 'Kill#33')
self.ec.register_connection(self.iface1, self.channel)
self.assertEquals(self.ec.get_resource(self.app3).state, ResourceState.RELEASED)
def test_deploy_with_app_nc_and_critical_right(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'wlab49')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPort', "5222")
self.ec.set(self.node2, 'xmppPassword', "1234")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'essid', "vlcexp")
self.ec.set(self.iface2, 'ip', "10.0.0.49/24")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
self.ec.set(self.app2, "critical", False)
self.ec.set(self.app2, 'appid', 'Kill#32')
- self.app3 = self.ec.register_resource("OMFApplication")
+ self.app3 = self.ec.register_resource("omf::Application")
self.ec.set(self.app3, 'appid', 'Kill#3')
self.ec.set(self.app3, 'command', "/usr/bin/test -3")
self.ec.set(self.app3, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
def test_deploy_with_many_app_nc_and_critical(self):
- self.node2 = self.ec.register_resource("OMFNode")
+ self.node2 = self.ec.register_resource("omf::Node")
self.ec.set(self.node2, 'hostname', 'wlab49')
self.ec.set(self.node2, 'xmppUser', "nepi")
self.ec.set(self.node2, 'xmppServer', "xmpp-plexus.onelab.eu")
self.ec.set(self.node2, 'xmppPort', "5222")
self.ec.set(self.node2, 'xmppPassword', "1234")
- self.iface2 = self.ec.register_resource("OMFWifiInterface")
+ self.iface2 = self.ec.register_resource("omf::WifiInterface")
self.ec.set(self.iface2, 'name', "wlan0")
self.ec.set(self.iface2, 'mode', "adhoc")
self.ec.set(self.iface2, 'hw_mode', "g")
self.ec.set(self.iface2, 'essid', "vlcexp")
self.ec.set(self.iface2, 'ip', "10.0.0.49/24")
- self.channel = self.ec.register_resource("OMFChannel")
+ self.channel = self.ec.register_resource("omf::Channel")
self.ec.set(self.channel, 'channel', "6")
- self.app2 = self.ec.register_resource("OMFApplication")
+ self.app2 = self.ec.register_resource("omf::Application")
self.ec.set(self.app2, "critical", False)
self.ec.set(self.app2, 'appid', 'Kill#32')
- self.app3 = self.ec.register_resource("OMFApplication")
+ self.app3 = self.ec.register_resource("omf::Application")
self.ec.set(self.app3, "critical", False)
self.ec.set(self.app3, 'appid', 'Kill#3')
self.ec.set(self.app3, 'command', "/usr/bin/test -3")
self.ec.set(self.app3, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
- self.app4 = self.ec.register_resource("OMFApplication")
+ self.app4 = self.ec.register_resource("omf::Application")
self.ec.set(self.app4, 'appid', 'Kill#4')
self.ec.set(self.app4, 'command', "/usr/bin/test -4")
self.ec.set(self.app4, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
- self.app5 = self.ec.register_resource("OMFApplication")
+ self.app5 = self.ec.register_resource("omf::Application")
self.ec.set(self.app5, "critical", False)
self.ec.set(self.app5, 'appid', 'Kill#32')
- self.app6 = self.ec.register_resource("OMFApplication")
+ self.app6 = self.ec.register_resource("omf::Application")
self.ec.set(self.app6, 'appid', 'Kill#6')
self.ec.set(self.app6, 'command', "/usr/bin/test -6")
self.ec.set(self.app6, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
pass
@clsinit_copy
-class DummyOMFApplication(OMFApplication):
- _rtype = "DummyOMFApplication"
+class OMFDummyApplication(OMFApplication):
+ _rtype = "omf::DummyApplication"
@classmethod
def _register_attributes(cls):
def test_set_hook(self):
self.ec = DummyEC(exp_id = "30")
- ResourceFactory.register_type(DummyOMFApplication)
+ ResourceFactory.register_type(OMFDummyApplication)
- self.node1 = self.ec.register_resource("OMFNode")
+ self.node1 = self.ec.register_resource("omf::Node")
self.ec.set(self.node1, 'hostname', 'omf.plexus.wlab17')
self.ec.set(self.node1, 'xmppSlice', "nepi")
self.ec.set(self.node1, 'xmppHost', "xmpp-plexus.onelab.eu")
self.ec.set(self.node1, 'xmppPort', "5222")
self.ec.set(self.node1, 'xmppPassword', "1234")
- self.app1 = self.ec.register_resource("DummyOMFApplication")
+ self.app1 = self.ec.register_resource("omf::DummyApplication")
self.ec.set(self.app1, 'appid', 'Test#1')
self.ec.set(self.app1, 'path', "/usr/bin/ping")
self.ec.set(self.app1, 'args', "")
ec = ExperimentController(exp_id = "test-tap-gre-tunnel")
- node1 = ec.register_resource("PlanetlabNode")
+ node1 = ec.register_resource("planetlab::Node")
ec.set(node1, "hostname", host1)
ec.set(node1, "username", user1)
ec.set(node1, "identity", identity1)
ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
- tap1 = ec.register_resource("PlanetlabTap")
+ tap1 = ec.register_resource("planetlab::Tap")
ec.set(tap1, "endpoint_ip", "%s.1" % self.netblock)
ec.set(tap1, "endpoint_prefix", 24)
ec.register_connection(tap1, node1)
- node2 = ec.register_resource("PlanetlabNode")
+ node2 = ec.register_resource("planetlab::Node")
ec.set(node2, "hostname", host2)
ec.set(node2, "username", user2)
ec.set(node2, "identity", identity2)
ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
- tap2 = ec.register_resource("PlanetlabTap")
+ tap2 = ec.register_resource("planetlab::Tap")
ec.set(tap2, "endpoint_ip", "%s.2" % self.netblock)
ec.set(tap2, "endpoint_prefix", 24)
ec.register_connection(tap2, node2)
- gretun = ec.register_resource("LinuxGRETunnel")
+ gretun = ec.register_resource("linux::GRETunnel")
ec.register_connection(tap1, gretun)
ec.register_connection(tap2, gretun)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
cmd = "ping -c3 %s.2" % self.netblock
ec.set(app, "command", cmd)
ec.register_connection(app, node1)
ec = ExperimentController(exp_id = "test-tun-gre-tunnel")
- node1 = ec.register_resource("PlanetlabNode")
+ node1 = ec.register_resource("planetlab::Node")
ec.set(node1, "hostname", host1)
ec.set(node1, "username", user1)
ec.set(node1, "identity", identity1)
ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
- tun1 = ec.register_resource("PlanetlabTun")
+ tun1 = ec.register_resource("planetlab::Tun")
ec.set(tun1, "endpoint_ip", "%s.1" % self.netblock)
ec.set(tun1, "endpoint_prefix", 24)
ec.register_connection(tun1, node1)
- node2 = ec.register_resource("PlanetlabNode")
+ node2 = ec.register_resource("planetlab::Node")
ec.set(node2, "hostname", host2)
ec.set(node2, "username", user2)
ec.set(node2, "identity", identity2)
ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
- tun2 = ec.register_resource("PlanetlabTun")
+ tun2 = ec.register_resource("planetlab::Tun")
ec.set(tun2, "endpoint_ip", "%s.2" % self.netblock)
ec.set(tun2, "endpoint_prefix", 24)
ec.register_connection(tun2, node2)
- udptun = ec.register_resource("LinuxGRETunnel")
+ udptun = ec.register_resource("linux::GRETunnel")
ec.register_connection(tun1, udptun)
ec.register_connection(tun2, udptun)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
cmd = "ping -c3 %s.2" % self.netblock
ec.set(app, "command", cmd)
ec.register_connection(app, node1)
ec = ExperimentController(exp_id = "test-tap-hybrid-gre-tunnel")
- node1 = ec.register_resource("PlanetlabNode")
+ node1 = ec.register_resource("planetlab::Node")
ec.set(node1, "hostname", host1)
ec.set(node1, "username", user1)
ec.set(node1, "identity", identity1)
ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
- tun1 = ec.register_resource("PlanetlabTun")
+ tun1 = ec.register_resource("planetlab::Tun")
ec.set(tun1, "endpoint_ip", "%s.1" % self.netblock)
ec.set(tun1, "endpoint_prefix", 24)
ec.register_connection(tun1, node1)
- node2 = ec.register_resource("LinuxNode")
+ node2 = ec.register_resource("linux::Node")
ec.set(node2, "hostname", host2)
ec.set(node2, "username", user2)
ec.set(node2, "identity", identity2)
ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
- tun2 = ec.register_resource("LinuxTun")
+ tun2 = ec.register_resource("linux::Tun")
ec.set(tun2, "endpoint_ip", "%s.2" % self.netblock)
ec.set(tun2, "endpoint_prefix", 24)
ec.register_connection(tun2, node2)
- gretun = ec.register_resource("LinuxGRETunnel")
+ gretun = ec.register_resource("linux::GRETunnel")
ec.register_connection(tun1, gretun)
ec.register_connection(tun2, gretun)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
# It seems the hybrid tunnel takes some time to setup... we add a sleep 5
# XXX: Debug this to see if it can be fixed on the RMs
cmd = "sleep 5; ping -c3 %s.2" % self.netblock
minBandwidth=None, minCpu=None,
architecture=None, city=None, ip=None):
- node = ec.register_resource("PlanetlabNode")
+ node = ec.register_resource("planetlab::Node")
if username:
ec.set(node, "username", username)
if ip:
ec.set(node, "ip", ip)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
return node
class PLNodeFactoryTestCase(unittest.TestCase):
def test_creation_phase(self):
- self.assertEquals(PlanetlabNode._rtype, "PlanetlabNode")
+ self.assertEquals(PlanetlabNode._rtype, "planetlab::Node")
self.assertEquals(len(PlanetlabNode._attributes), 32)
class PLNodeTestCase(unittest.TestCase):
ec = ExperimentController(exp_id = "test-ovs")
- node1 = ec.register_resource("PlanetlabNode")
+ node1 = ec.register_resource("planetlab::Node")
ec.set(node1, "hostname", switch1)
ec.set(node1, "username", user1)
- ec.set(node1, "cleanHome", True)
+ ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
- ovs1 = ec.register_resource("OVSSwitch")
+ ovs1 = ec.register_resource("planetlab::OVSSwitch")
ec.set(ovs1, "bridge_name", "nepi_bridge")
ec.set(ovs1, "virtual_ip_pref", "192.168.3.1/24")
ec.set(ovs1, "controller_ip", "85.23.168.77")
ec.set(ovs1, "controller_port", "6633")
ec.register_connection(ovs1, node1)
- port1 = ec.register_resource("OVSPort")
+ port1 = ec.register_resource("planetlab::OVSPort")
ec.set(port1, "port_name", "port-1")
ec.register_connection(port1, ovs1)
- port2 = ec.register_resource("OVSPort")
+ port2 = ec.register_resource("planetlab::OVSPort")
ec.set(port2, "port_name", "port-2")
ec.register_connection(port2, ovs1)
- node2 = ec.register_resource("PlanetlabNode")
+ node2 = ec.register_resource("planetlab::PlanetlabNode")
ec.set(node2, "hostname", switch2)
ec.set(node2, "username", user2)
- ec.set(node2, "cleanHome", True)
+ ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
- ovs2 = ec.register_resource("OVSSwitch")
+ ovs2 = ec.register_resource("planetlab::OVSSwitch")
ec.set(ovs2, "bridge_name", "nepi_bridge")
ec.set(ovs2, "virtual_ip_pref", "192.168.3.2/24")
ec.set(ovs2, "controller_ip", "85.23.168.77")
ec.set(ovs2, "controller_port", "6633")
ec.register_connection(ovs2, node2)
- port3 = ec.register_resource("OVSPort")
+ port3 = ec.register_resource("planetlab::OVSPort")
ec.set(port3, "port_name", "port-3")
ec.register_connection(port3, ovs2)
- port4 = ec.register_resource("OVSPort")
+ port4 = ec.register_resource("planetlab::OVSPort")
ec.set(port4, "port_name", "port-4")
ec.register_connection(port4, ovs2)
- node3 = ec.register_resource("PlanetlabNode")
+ node3 = ec.register_resource("planetlab::Node")
ec.set(node3, "hostname", host1)
ec.set(node3, "username", user3)
- ec.set(node3, "cleanHome", True)
+ ec.set(node3, "cleanExperiment", True)
ec.set(node3, "cleanProcesses", True)
- tap1 = ec.register_resource("PlanetlabTap")
+ tap1 = ec.register_resource("planetlab::Tap")
ec.set(tap1, "ip4", "192.168.3.3")
ec.set(tap1, "pointopoint", "192.168.3.1")
ec.set(tap1, "prefix4", 24)
ec.register_connection(tap1, node3)
- node4 = ec.register_resource("PlanetlabNode")
+ node4 = ec.register_resource("planetlab::Node")
ec.set(node4, "hostname", host2)
ec.set(node4, "username", user4)
- ec.set(node4, "cleanHome", True)
+ ec.set(node4, "cleanExperiment", True)
ec.set(node4, "cleanProcesses", True)
- tap2 = ec.register_resource("PlanetlabTap")
+ tap2 = ec.register_resource("planetlab::Tap")
ec.set(tap2, "ip4", "192.168.3.4")
ec.set(tap2, "pointopoint", "192.168.3.2")
ec.set(tap2, "prefix4", 24)
ec.register_connection(tap2, node4)
- ovstun1 = ec.register_resource("OVSTunnel")
+ ovstun1 = ec.register_resource("planetlab::OVSTunnel")
ec.register_connection(port1, ovstun1)
ec.register_connection(tap1, ovstun1)
- ovstun2 = ec.register_resource("OVSTunnel")
+ ovstun2 = ec.register_resource("plantelab::OVSTunnel")
ec.register_connection(port3, ovstun2)
ec.register_connection(tap2, ovstun2)
- ovstun3 = ec.register_resource("OVSTunnel")
+ ovstun3 = ec.register_resource("planetlab::OVSTunnel")
ec.register_connection(port2, ovstun3)
ec.register_connection(port4, ovstun3)
- app1 = ec.register_resource("LinuxApplication")
+ app1 = ec.register_resource("linux::Application")
cmd = "ping -c3 192.168.3.2"
ec.set(app1, "command", cmd)
ec.register_connection(app1, node1)
- app2 = ec.register_resource("LinuxApplication")
+ app2 = ec.register_resource("linux::Application")
cmd = "ping -c3 192.168.3.4"
ec.set(app2, "command", cmd)
ec.register_connection(app2, node2)
class PLSfaNodeFactoryTestCase(unittest.TestCase):
def test_creation_phase(self):
- self.assertEquals(PlanetlabSfaNode._rtype, "PlanetlabSfaNode")
+ self.assertEquals(PlanetlabSfaNode._rtype, "planetlab::sfa::Node")
self.assertEquals(len(PlanetlabSfaNode._attributes), 31)
class PLSfaNodeTestCase(unittest.TestCase):
instanciated, and is an instance of SFAAPI. Check that using
the same credentials, the same object of the api is used.
"""
- node1 = self.ec.register_resource("PlanetlabSfaNode")
+ node1 = self.ec.register_resource("planetlab::sfa::Node")
self.ec.set(node1, "hostname", "planetlab2.ionio.gr")
self.ec.set(node1, "username", self.username)
self.ec.set(node1, "sfauser", self.sfauser)
self.assertEquals(len(api1._reserved), 0)
self.assertEquals(len(api1._blacklist), 0)
- node2 = self.ec.register_resource("PlanetlabSfaNode")
+ node2 = self.ec.register_resource("planetlab::sfa::Node")
self.ec.set(node2, "hostname", "planetlab2.ionio.gr")
self.ec.set(node2, "username", self.username)
self.ec.set(node2, "sfauser", self.sfauser)
"""
Check that the method do_discover reserve the right node.
"""
- node = self.ec.register_resource("PlanetlabSfaNode")
+ node = self.ec.register_resource("planetlab::sfa::Node")
self.ec.set(node, "hostname", "roti.mimuw.edu.pl")
self.ec.set(node, "username", self.username)
self.ec.set(node, "sfauser", self.sfauser)
This test checks that the method do_provision add the node in the slice and check
its well functioning.
"""
- node = self.ec.register_resource("PlanetlabSfaNode")
+ node = self.ec.register_resource("planetlab::sfa::Node")
self.ec.set(node, "hostname", "planetlab2.ionio.gr")
self.ec.set(node, "username", self.username)
self.ec.set(node, "sfauser", self.sfauser)
"""
Test deploy 1 node.
"""
- node = self.ec.register_resource("PlanetlabSfaNode")
+ node = self.ec.register_resource("planetlab::sfa::Node")
self.ec.set(node, "hostname", "planetlab2.ionio.gr")
self.ec.set(node, "username", self.username)
self.ec.set(node, "sfauser", self.sfauser)
"""
Test deploy 2 nodes. Empty slice.
"""
- node1 = self.ec.register_resource("PlanetlabSfaNode")
+ node1 = self.ec.register_resource("planetlab::sfa::Node")
self.ec.set(node1, "hostname", "planetlab3.xeno.cl.cam.ac.uk")
self.ec.set(node1, "username", self.username)
self.ec.set(node1, "sfauser", self.sfauser)
self.ec.set(node1, "sfaPrivateKey", self.sfaPrivateKey)
- node2 = self.ec.register_resource("PlanetlabSfaNode")
+ node2 = self.ec.register_resource("planetlab::sfa::Node")
self.ec.set(node2, "hostname", "planetlab1.cs.vu.nl")
self.ec.set(node2, "username", self.username)
self.ec.set(node2, "sfauser", self.sfauser)
"""
Test deploy 2 nodes, already in the slice.
"""
- node1 = self.ec.register_resource("PlanetlabSfaNode")
+ node1 = self.ec.register_resource("planetlab::sfa::Node")
self.ec.set(node1, "hostname", "planetlab3.xeno.cl.cam.ac.uk")
self.ec.set(node1, "username", self.username)
self.ec.set(node1, "sfauser", self.sfauser)
self.ec.set(node1, "sfaPrivateKey", self.sfaPrivateKey)
- node2 = self.ec.register_resource("PlanetlabSfaNode")
+ node2 = self.ec.register_resource("planetlab::sfa::Node")
self.ec.set(node2, "hostname", "planetlab1.cs.vu.nl")
self.ec.set(node2, "username", self.username)
self.ec.set(node2, "sfauser", self.sfauser)
ec = ExperimentController(exp_id = "test-tap-create")
- node = ec.register_resource("PlanetlabNode")
+ node = ec.register_resource("planetlab::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
ec.set(node, "identity", identity)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- tap = ec.register_resource("PlanetlabTap")
+ tap = ec.register_resource("planetlab::Tap")
ec.set(tap, "endpoint_ip", "%s.1" % self.netblock)
ec.set(tap, "endpoint_prefix", 24)
ec.register_connection(tap, node)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
cmd = "ping -c3 %s.1" % self.netblock
ec.set(app, "command", cmd)
ec.register_connection(app, node)
ec = ExperimentController(exp_id = "test-un-create")
- node = ec.register_resource("PlanetlabNode")
+ node = ec.register_resource("planetlab::Node")
ec.set(node, "hostname", host)
ec.set(node, "username", user)
ec.set(node, "identity", identity)
- ec.set(node, "cleanHome", True)
+ ec.set(node, "cleanExperiment", True)
ec.set(node, "cleanProcesses", True)
- tun = ec.register_resource("PlanetlabTun")
+ tun = ec.register_resource("planetlab::Tun")
ec.set(tun, "endpoint_ip", "%s.1" % self.netblock)
ec.set(tun, "endpoint_prefix", 24)
ec.register_connection(tun, node)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
cmd = "ping -c3 %s.1" % self.netblock
ec.set(app, "command", cmd)
ec.register_connection(app, node)
ec = ExperimentController(exp_id = "test-tap-udp-tunnel")
- node1 = ec.register_resource("PlanetlabNode")
+ node1 = ec.register_resource("planetlab::Node")
ec.set(node1, "hostname", host1)
ec.set(node1, "username", user1)
ec.set(node1, "identity", identity1)
- #ec.set(node1, "cleanHome", True)
ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
- tap1 = ec.register_resource("PlanetlabTap")
+ tap1 = ec.register_resource("planetlab::Tap")
ec.set(tap1, "endpoint_ip", "%s.1" % self.netblock)
ec.set(tap1, "endpoint_prefix", 24)
ec.register_connection(tap1, node1)
- node2 = ec.register_resource("PlanetlabNode")
+ node2 = ec.register_resource("planetlab::Node")
ec.set(node2, "hostname", host2)
ec.set(node2, "username", user2)
ec.set(node2, "identity", identity2)
- #ec.set(node2, "cleanHome", True)
ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
- tap2 = ec.register_resource("PlanetlabTap")
+ tap2 = ec.register_resource("planetlab::Tap")
ec.set(tap2, "endpoint_ip", "%s.2" % self.netblock)
ec.set(tap2, "endpoint_prefix", 24)
ec.register_connection(tap2, node2)
- udptun = ec.register_resource("LinuxUdpTunnel")
+ udptun = ec.register_resource("linux::UdpTunnel")
ec.register_connection(tap1, udptun)
ec.register_connection(tap2, udptun)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
cmd = "ping -c3 %s.2" % self.netblock
ec.set(app, "command", cmd)
ec.register_connection(app, node1)
ec = ExperimentController(exp_id = "test-tun-udp-tunnel")
- node1 = ec.register_resource("PlanetlabNode")
+ node1 = ec.register_resource("planetlab::Node")
ec.set(node1, "hostname", host1)
ec.set(node1, "username", user1)
ec.set(node1, "identity", identity1)
- #ec.set(node1, "cleanHome", True)
ec.set(node1, "cleanExperiment", True)
ec.set(node1, "cleanProcesses", True)
- tun1 = ec.register_resource("PlanetlabTun")
+ tun1 = ec.register_resource("planetlab::Tun")
ec.set(tun1, "endpoint_ip", "%s.1" % self.netblock)
ec.set(tun1, "endpoint_prefix", 24)
ec.register_connection(tun1, node1)
- node2 = ec.register_resource("PlanetlabNode")
+ node2 = ec.register_resource("planetlab::Node")
ec.set(node2, "hostname", host2)
ec.set(node2, "username", user2)
ec.set(node2, "identity", identity2)
- #ec.set(node2, "cleanHome", True)
ec.set(node2, "cleanExperiment", True)
ec.set(node2, "cleanProcesses", True)
- tun2 = ec.register_resource("PlanetlabTun")
+ tun2 = ec.register_resource("planetlab::Tun")
ec.set(tun2, "endpoint_ip", "%s.2" % self.netblock)
ec.set(tun2, "endpoint_prefix", 24)
ec.register_connection(tun2, node2)
- udptun = ec.register_resource("LinuxUdpTunnel")
+ udptun = ec.register_resource("linux::UdpTunnel")
ec.register_connection(tun1, udptun)
ec.register_connection(tun2, udptun)
- app = ec.register_resource("LinuxApplication")
+ app = ec.register_resource("linux::Application")
cmd = "ping -c3 %s.2" % self.netblock
ec.set(app, "command", cmd)
ec.register_connection(app, node1)
git://git.onelab.eu / nepi.git / commitdiff