--- /dev/null
+"""
+ NEPI, a framework to manage network experiments
+ Copyright (C) 2013 INRIA
+
+ This program is free software: you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation, either version 3 of the License, or
+ (at your option) any later version.
+
+ 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/>.
+
+ Author: Alina Quereilhac <alina.quereilhac@inria.fr>
+ Julien Tribino <julien.tribino@inria.fr>
+
+ Example :
+ - Testbed : Nitos
+ - Explanation :
+
+ CCN topology:
+
+ content ccncat
+ b1 b2
+ 0 ------------------ 0
+
+ - Experiment:
+ * t0 : b2 retrives video published in b1
+
+"""
+
+#!/usr/bin/env python
+from nepi.execution.resource import ResourceFactory, ResourceAction, ResourceState
+from nepi.execution.ec import ExperimentController
+
+from optparse import OptionParser, SUPPRESS_HELP
+
+### Define OMF Method to simplify definition of resources ###
+def add_node(ec, hostname, xmppSlice, xmppHost, xmppPort = "5222", xmppPassword = "1234"):
+ node = ec.register_resource("OMFNode")
+ ec.set(node, 'hostname', hostname)
+ ec.set(node, 'xmppSlice', xmppSlice)
+ ec.set(node, 'xmppHost', xmppHost)
+ ec.set(node, 'xmppPort', xmppPort)
+ ec.set(node, 'xmppPassword', xmppPassword)
+ return node
+
+def add_interface(ec, ip, xmppSlice, xmppHost, essid = "ccn", alias = "w0", mode = "adhoc",
+ typ = "g", xmppPort = "5222", xmppPassword = "1234"):
+ iface = ec.register_resource("OMFWifiInterface")
+ ec.set(iface, 'alias', alias)
+ ec.set(iface, 'mode', mode)
+ ec.set(iface, 'type', typ)
+ ec.set(iface, 'essid', essid)
+ ec.set(iface, 'ip', ip)
+ return iface
+
+def add_channel(ec, channel, xmppSlice, xmppHost, xmppPort = "5222", xmppPassword = "1234"):
+ chan = ec.register_resource("OMFChannel")
+ ec.set(chan, 'channel', channel)
+ ec.set(chan, 'xmppSlice', xmppSlice)
+ ec.set(chan, 'xmppHost', xmppHost)
+ ec.set(chan, 'xmppPort', xmppPort)
+ ec.set(chan, 'xmppPassword', xmppPassword)
+ return chan
+
+def add_app(ec, appid, command, args, env, xmppSlice, xmppHost,
+ xmppPort = "5222", xmppPassword = "1234"):
+ app = ec.register_resource("OMFApplication")
+ ec.set(app, 'appid', appid)
+ ec.set(app, 'path', command)
+ ec.set(app, 'args', args)
+ ec.set(app, 'env', env)
+ return app
+
+
+### Define a CCND application ###
+def add_ccnd(ec, peers, xmppSlice, xmppHost, xmppPort = "5222", xmppPassword = "1234"):
+ env = 'PATH=$PATH:/root/ccnx-0.7.2/bin HOME=/root \
+CCNR_DIRECTORY="/root" CCNR_STATUS_PORT="8080"'
+
+ # BASH command -> ' ccndstart ; ccndc add ccnx:/ udp host ; ccnr '
+ peers = map(lambda peer: "ccndc add ccnx:/ udp %s" % peer, peers)
+ #command += " ; ".join(peers) + " && "
+ command = peers[0]
+
+ app = add_app(ec, "#ccnd", command, "", env, xmppSlice, xmppHost,
+ xmppPort = xmppPort, xmppPassword = xmppPassword)
+ return app
+
+### Define a CCN SeqWriter application ###
+def add_publish(ec, movie, xmppSlice, xmppHost, xmppPort = "5222", xmppPassword = "1234"):
+ env = 'PATH=$PATH:/root/ccnx-0.7.2/bin HOME=/root CCNR_DIRECTORY="/root" CCNR_STATUS_PORT="8080"'
+
+ # BASH command -> 'ccnseqwriter -r ccnx:/VIDEO < movie'
+ command = "ccnseqwriter -r ccnx:/VIDEO"
+ command += " < " + movie
+
+ app = add_app(ec, "#ccn_write", command, "", env, xmppSlice, xmppHost,
+ xmppPort = xmppPort, xmppPassword = xmppPassword)
+ return app
+
+### Define a streaming application ###
+def add_stream(ec, xmppSlice, xmppHost, xmppPort = "5222", xmppPassword = "1234"):
+ env = 'PATH=$PATH:/root/ccnx-0.7.2/bin HOME=/root CCNR_DIRECTORY="/root" CCNR_STATUS_PORT="8080"'
+ command = " ddbus-uuidgen --ensure ; ( /root/ccnx-0.7.2/bin/ccncat ccnx:/VIDEO | /root/vlc-1.1.13/cvlc - ) "
+ #command = "ccncat ccnx:/VIDEO | /root/vlc-1.1.13/cvlc - "
+ app = add_app(ec, "#ccn_stream", command, "", env, xmppSlice, xmppHost,
+ xmppPort = xmppPort, xmppPassword = xmppPassword)
+ return app
+
+### Many options to easily addapt the script ####
+def get_options():
+ usage = "usage: %prog -w <sender-node> -r <receiver-node> -s <slice> -m <movie>"
+
+ parser = OptionParser(usage=usage)
+ parser.add_option("-w", "--sender-host", dest="sender_host",
+ help="Hostname of the sender Node", type="str")
+ parser.add_option("-i", "--sender-ip", dest="sender_ip",
+ help="IP of the sender Node", type="str")
+ parser.add_option("-r", "--receiver-host", dest="receiver_host",
+ help="Hostname of the receiver node", type="str")
+ parser.add_option("-p", "--receiver-ip", dest="receiver_ip",
+ help="IP of the receiver node", type="str")
+ parser.add_option("-c", "--channel", dest="channel",
+ help="Channel of the communication", type="str")
+ parser.add_option("-s", "--xmpp-slice", dest="xmpp_slice",
+ help="Name of the slice XMPP", type="str")
+ parser.add_option("-x", "--xmpp-host", dest="xmpp_host",
+ help="Name of the host XMPP", type="str")
+ parser.add_option("-m", "--movie", dest="movie",
+ help="Stream movie", type="str")
+
+ (options, args) = parser.parse_args()
+
+ if not options.movie:
+ parser.error("movie is a required argument")
+
+ return (options.sender_host, options.sender_ip, options.receiver_host, options.receiver_ip, options.channel, options.xmpp_slice,
+ options.xmpp_host ,options.movie)
+
+### Script itself ###
+if __name__ == '__main__':
+ (sender, sender_ip, receiver, receiver_ip, channel, xmpp_slice, xmpp_host, movie) = get_options()
+
+ env = 'PATH=$PATH:/root/ccnx-0.7.2/bin HOME=/root CCNR_DIRECTORY="/root" CCNR_STATUS_PORT="8080"'
+
+# Create the EC
+ ec = ExperimentController()
+
+# Create the topology
+ node1 = add_node(ec,sender, xmpp_slice, xmpp_host)
+ iface1 = add_interface(ec, sender_ip, xmpp_slice, xmpp_host)
+ ec.register_connection(node1, iface1)
+
+ node2 = add_node(ec, receiver, xmpp_slice, xmpp_host)
+ iface2 = add_interface(ec, receiver_ip, xmpp_slice, xmpp_host)
+ ec.register_connection(node2, iface2)
+
+ chann = add_channel(ec, channel, xmpp_slice, xmpp_host)
+ ec.register_connection(iface1, chann)
+ ec.register_connection(iface2, chann)
+
+# CCN setup for the sender
+ ccndstart1 = add_app(ec, "#ccndstart", "ccndstart &", "", env,xmpp_slice, xmpp_host)
+ ec.register_connection(ccndstart1, node1)
+
+ peers = [receiver_ip]
+ ccnd1 = add_ccnd(ec, peers, xmpp_slice, xmpp_host)
+ ec.register_connection(ccnd1, node1)
+
+ ccnr1 = add_app(ec, "#ccnr", "ccnr &", "", env, xmpp_slice, xmpp_host)
+ ec.register_connection(ccnr1, node1)
+
+ # Register content producer application (ccnseqwriter)
+ pub = add_publish(ec, movie, xmpp_slice, xmpp_host)
+ ec.register_connection(pub, node1)
+
+ # The movie can only be published after ccnd is running
+ ec.register_condition(ccnd1, ResourceAction.START, ccndstart1, ResourceState.STARTED, "1s")
+ ec.register_condition(ccnr1, ResourceAction.START, ccnd1, ResourceState.STARTED, "1s")
+ ec.register_condition(pub, ResourceAction.START, ccnr1, ResourceState.STARTED, "2s")
+
+# CCN setup for the receiver
+ ccndstart2 = add_app(ec, "#ccndstart", "ccndstart &", "", env,xmpp_slice, xmpp_host)
+ ec.register_connection(ccndstart2, node2)
+
+ peers = [sender_ip]
+ ccnd2 = add_ccnd(ec, peers, xmpp_slice, xmpp_host)
+ ec.register_connection(ccnd2, node2)
+
+ ccnr2 = add_app(ec, "#ccnr", "ccnr &", "", env,xmpp_slice, xmpp_host)
+ ec.register_connection(ccnr2, node2)
+
+ # Register consumer application (ccncat)
+ stream = add_stream(ec, xmpp_slice, xmpp_host)
+ ec.register_connection(stream, node2)
+
+ # The stream can only be retrieved after ccnd is running
+ ec.register_condition(ccnd2, ResourceAction.START, ccndstart2, ResourceState.STARTED, "1s")
+ ec.register_condition(ccnr2, ResourceAction.START, ccnd2, ResourceState.STARTED, "1s")
+ ec.register_condition(stream, ResourceAction.START, ccnr2, ResourceState.STARTED, "2s")
+
+# And also, the stream can only be retrieved after it was published
+ ec.register_condition(stream, ResourceAction.START, pub, ResourceState.STARTED, "5s")
+
+
+# Cleaning when the experiment stop
+ ccndstop1 = add_app(ec, "#ccndstop", "ccndstop", "", env, xmpp_slice, xmpp_host)
+ ec.register_connection(ccndstop1, node1)
+ ccndstop2 = add_app(ec, "#ccndstop", "ccndstop", "", env, xmpp_slice, xmpp_host)
+ ec.register_connection(ccndstop2, node2)
+ ccndstops = [ccndstop1,ccndstop2]
+
+ killall = add_app(ec, "#kill", "killall sh", "", "", xmpp_slice, xmpp_host)
+ ec.register_connection(killall, node2)
+
+ apps = [ccndstart1, ccnd1, ccnr1, pub, ccndstart2, ccnd2, ccnr2, stream]
+
+ ec.register_condition(apps, ResourceAction.STOP, stream, ResourceState.STARTED, "20s")
+
+ ec.register_condition(ccndstops, ResourceAction.START, apps, ResourceState.STOPPED, "1s")
+ ec.register_condition(killall, ResourceAction.START, ccndstops, ResourceState.STARTED)
+ ec.register_condition(ccndstops, ResourceAction.STOP, ccndstops, ResourceState.STARTED, "1s")
+ ec.register_condition(killall, ResourceAction.STOP, ccndstops, ResourceState.STOPPED)
+
+# Deploy all ResourceManagers
+ ec.deploy()
+
+# Wait until the applications are finished
+ ec.wait_finished(ccndstops)
+
+# Shutdown the experiment controller
+ ec.shutdown()
+
--- /dev/null
+"""
+ NEPI, a framework to manage network experiments
+ Copyright (C) 2013 INRIA
+
+ This program is free software: you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation, either version 3 of the License, or
+ (at your option) any later version.
+
+ 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/>.
+
+ Author: Alina Quereilhac <alina.quereilhac@inria.fr>
+ Julien Tribino <julien.tribino@inria.fr>
+
+ Example :
+ - Testbed : Nitos
+ - Explanation :
+
+ CCN topology:
+
+ h2
+ 0
+ content l1 / \ l2 ccncat
+ b1 /l5 \ b2
+ 0 ----- h1 0 --- 0 h3 ------ 0
+ \ /
+ l4 \ / l3
+ 0
+ h4
+
+ - Experiment:
+ * t0 : b2 retrives video published in b1
+ * t1 : l5 goes down after 15 sec
+
+"""
+
+#!/usr/bin/env python
+from nepi.execution.resource import ResourceFactory, ResourceAction, ResourceState
+from nepi.execution.ec import ExperimentController
+
+from optparse import OptionParser, SUPPRESS_HELP
+
+### Define OMF Method to simplify definition of resources ###
+def add_node(ec, hostname, xmppSlice, xmppHost, xmppPort = "5222", xmppPassword = "1234"):
+ node = ec.register_resource("OMFNode")
+ ec.set(node, 'hostname', hostname)
+ ec.set(node, 'xmppSlice', xmppSlice)
+ ec.set(node, 'xmppHost', xmppHost)
+ ec.set(node, 'xmppPort', xmppPort)
+ ec.set(node, 'xmppPassword', xmppPassword)
+ return node
+
+def add_interface(ec, ip, xmppSlice, xmppHost, essid = "ccn", alias = "w0", mode = "adhoc",
+ typ = "g", xmppPort = "5222", xmppPassword = "1234"):
+ iface = ec.register_resource("OMFWifiInterface")
+ ec.set(iface, 'alias', alias)
+ ec.set(iface, 'mode', mode)
+ ec.set(iface, 'type', typ)
+ ec.set(iface, 'essid', essid)
+ ec.set(iface, 'ip', ip)
+ return iface
+
+def add_channel(ec, channel, xmppSlice, xmppHost, xmppPort = "5222", xmppPassword = "1234"):
+ chan = ec.register_resource("OMFChannel")
+ ec.set(chan, 'channel', channel)
+ ec.set(chan, 'xmppSlice', xmppSlice)
+ ec.set(chan, 'xmppHost', xmppHost)
+ ec.set(chan, 'xmppPort', xmppPort)
+ ec.set(chan, 'xmppPassword', xmppPassword)
+ return chan
+
+def add_app(ec, host, appid, command, args, env, xmppSlice, xmppHost,
+ xmppPort = "5222", xmppPassword = "1234"):
+ app = ec.register_resource("OMFApplication")
+ ec.set(app, 'appid', appid)
+ ec.set(app, 'path', command)
+ ec.set(app, 'args', args)
+ ec.set(app, 'env', env)
+ ec.register_connection(app, host)
+ return app
+
+
+### Define a CCND application ###
+def add_ccnd(ec, host, peers, xmppSlice, xmppHost, xmppPort = "5222", xmppPassword = "1234"):
+ env = 'PATH=$PATH:/root/ccnx-0.7.2/bin HOME=/root \
+CCNR_DIRECTORY="/root" CCNR_STATUS_PORT="8080"'
+
+ # BASH command -> ' ccndstart ; ccndc add ccnx:/ udp host ; ccnr '
+ command = "ccndc add ccnx:/ udp " + peers
+ app = add_app(ec, host, "#ccnd", command, "", env, xmppSlice, xmppHost,
+ xmppPort = xmppPort, xmppPassword = xmppPassword)
+ return app
+
+### Define a CCN SeqWriter application ###
+def add_publish(ec, host, movie, xmppSlice, xmppHost, xmppPort = "5222", xmppPassword = "1234"):
+ env = 'PATH=$PATH:/root/ccnx-0.7.2/bin HOME=/root CCNR_DIRECTORY="/root" CCNR_STATUS_PORT="8080"'
+
+ # BASH command -> 'ccnseqwriter -r ccnx:/VIDEO < movie'
+ command = "ccnseqwriter -r ccnx:/VIDEO"
+ command += " < " + movie
+
+ app = add_app(ec, host, "#ccn_write", command, "", env, xmppSlice, xmppHost,
+ xmppPort = xmppPort, xmppPassword = xmppPassword)
+ return app
+
+### Define a streaming application ###
+def add_stream(ec, host, xmppSlice, xmppHost, xmppPort = "5222", xmppPassword = "1234"):
+ env = 'PATH=$PATH:/root/ccnx-0.7.2/bin HOME=/root CCNR_DIRECTORY="/root" CCNR_STATUS_PORT="8080"'
+ command = " ddbus-uuidgen --ensure ; ( /root/ccnx-0.7.2/bin/ccncat ccnx:/VIDEO | /root/vlc-1.1.13/cvlc - ) "
+ app = add_app(ec, host, "#ccn_stream", command, "", env, xmppSlice, xmppHost,
+ xmppPort = xmppPort, xmppPassword = xmppPassword)
+ return app
+
+### Many options to easily addapt the script ####
+def get_options():
+ usage = "usage: %prog -c <channel> -s <xmpp_slice> -x <xmpp_host> -m <movie>"
+
+ parser = OptionParser(usage=usage)
+ parser.add_option("-c", "--channel", dest="channel",
+ help="Channel of the communication", type="str")
+ parser.add_option("-s", "--xmpp-slice", dest="xmpp_slice",
+ help="Name of the slice XMPP", type="str")
+ parser.add_option("-x", "--xmpp-host", dest="xmpp_host",
+ help="Name of the host XMPP", type="str")
+ parser.add_option("-m", "--movie", dest="movie",
+ help="Stream movie", type="str")
+ #parser.add_option("-e", "--exp-id", dest="exp_id",
+ # help="Label to identify experiment", type="str")
+
+ (options, args) = parser.parse_args()
+
+ if not options.movie:
+ parser.error("movie is a required argument")
+
+ return (options.channel, options.xmpp_slice,
+ options.xmpp_host ,options.movie)
+
+### Script itself ###
+if __name__ == '__main__':
+ (channel, xmpp_slice, xmpp_host, movie) = get_options()
+
+ env = 'PATH=$PATH:/root/ccnx-0.7.2/bin HOME=/root CCNR_DIRECTORY="/root" CCNR_STATUS_PORT="8080"'
+
+# Create the EC
+ ec = ExperimentController()
+
+# Create the topology
+ host1 = "omf.nitos.node022"
+ host2 = "omf.nitos.node028"
+ host3 = "omf.nitos.node024"
+ host4 = "omf.nitos.node025"
+ host5 = "omf.nitos.node026" # b1
+ host6 = "omf.nitos.node027" # b2
+
+ ip1 = "192.168.0.22"
+ ip2 = "192.168.0.28"
+ ip3 = "192.168.0.24"
+ ip4 = "192.168.0.25"
+ ip5 = "192.168.0.26"
+ ip6 = "192.168.0.27"
+
+ all_hosts = [host1, host2, host3, host4, host5, host6]
+ all_ip = [ip1, ip2, ip3, ip4, ip5, ip6]
+
+ ring_hosts = [host1, host2, host3, host4]
+ nodes = dict()
+
+ chann = add_channel(ec, channel, xmpp_slice, xmpp_host)
+ for i in xrange(len(all_hosts)):
+ node = add_node(ec,all_hosts[i], xmpp_slice, xmpp_host)
+ iface = add_interface(ec, all_ip[i], xmpp_slice, xmpp_host)
+ ec.register_connection(node, iface)
+ ec.register_connection(iface, chann)
+ nodes[all_hosts[i]] = node
+
+# CCN setup for the node
+ ccnds = dict()
+ ccnrs = dict()
+ for i in xrange(len(all_hosts)):
+ ccndstart = add_app(ec, nodes[all_hosts[i]], "#ccndstart", "ccndstart &",
+ "", env, xmpp_slice, xmpp_host)
+ ccnr = add_app(ec, nodes[all_hosts[i]], "#ccnr", "ccnr &",
+ "", env, xmpp_slice, xmpp_host)
+ ccnds[all_hosts[i]] = ccndstart
+ ccnrs[all_hosts[i]] = ccnr
+ ec.register_condition(ccnr, ResourceAction.START, ccndstart, ResourceState.STARTED, "1s")
+
+# CCNDC setup
+ # l1 : h1 - h2 , h2 - h1
+ l1u = add_ccnd(ec, nodes[host1], ip2, xmpp_slice, xmpp_host)
+ l1d = add_ccnd(ec, nodes[host2], ip1, xmpp_slice, xmpp_host)
+
+ # l2 : h2 - h3 , h3 - h2
+ l2u = add_ccnd(ec, nodes[host2], ip3, xmpp_slice, xmpp_host)
+ l2d = add_ccnd(ec, nodes[host3], ip2, xmpp_slice, xmpp_host)
+
+ # l3 : h3 - h4 , h4 - h3
+ l3u = add_ccnd(ec, nodes[host3], ip4, xmpp_slice, xmpp_host)
+ l3d = add_ccnd(ec, nodes[host4], ip3, xmpp_slice, xmpp_host)
+
+ # l4 : h4 - h1 , h1 - h4
+ l4u = add_ccnd(ec, nodes[host4], ip1, xmpp_slice, xmpp_host)
+ l4d = add_ccnd(ec, nodes[host1], ip4, xmpp_slice, xmpp_host)
+
+ # l5 : h1 - h3 , h3 - h1
+ l5u = add_ccnd(ec, nodes[host1], ip3, xmpp_slice, xmpp_host)
+ l5d = add_ccnd(ec, nodes[host3], ip1, xmpp_slice, xmpp_host)
+
+ # connect border nodes
+ b1u = add_ccnd(ec, nodes[host5], ip1, xmpp_slice, xmpp_host)
+ b1d = add_ccnd(ec, nodes[host1], ip5, xmpp_slice, xmpp_host)
+
+ b2u = add_ccnd(ec, nodes[host6], ip3, xmpp_slice, xmpp_host)
+ b2d = add_ccnd(ec, nodes[host3], ip6, xmpp_slice, xmpp_host)
+
+ link = [l1u, l1d, l2u, l2d, l3u, l3d, l4u, l4d, l5u, l5d, b1u, b1d, b2u, b2d]
+
+# List of condition
+ for i in xrange(len(all_hosts)):
+ ec.register_condition(ccnrs[all_hosts[i]], ResourceAction.START, ccnds[all_hosts[i]], ResourceState.STARTED, "1s")
+ ec.register_condition(link, ResourceAction.START, ccnrs[all_hosts[i]], ResourceState.STARTED, "1s")
+
+# Streaming Server
+ pub = add_publish(ec, nodes[host5], movie, xmpp_slice, xmpp_host)
+
+# Streaming client
+ stream = add_stream(ec, nodes[host6], xmpp_slice, xmpp_host)
+
+# Streaming conditions
+ ec.register_condition(pub, ResourceAction.START, link, ResourceState.STARTED, "2s")
+ ec.register_condition(stream, ResourceAction.START, link, ResourceState.STARTED, "2s")
+ ec.register_condition(stream, ResourceAction.START, pub, ResourceState.STARTED, "2s")
+
+# break the lin
+ ccndcstop1 = add_app(ec,nodes[host1], "#ccndc", "ccndc del ccnx:/ udp " + ip3, "", env, xmpp_slice, xmpp_host)
+ ccndcstop2 = add_app(ec,nodes[host3], "#ccndc", "ccndc del ccnx:/ udp " + ip1, "", env, xmpp_slice, xmpp_host)
+
+
+# Change the behaviour
+ ec.register_condition(l5u, ResourceAction.STOP, stream, ResourceState.STARTED, "10s")
+ ec.register_condition(l5d, ResourceAction.STOP, stream, ResourceState.STARTED, "10s")
+
+ ec.register_condition(ccndcstop1, ResourceAction.START, stream, ResourceState.STARTED, "10s")
+ ec.register_condition(ccndcstop2, ResourceAction.START, stream, ResourceState.STARTED, "10s")
+
+# Cleaning when the experiment stop
+ ccndstops = []
+ for i in xrange(len(all_hosts)):
+ ccndstop = add_app(ec, nodes[all_hosts[i]], "#ccndstop", "ccndstop", "", env, xmpp_slice, xmpp_host)
+ ccndstops.append(ccndstop)
+
+ killall = add_app(ec, nodes[host6], "#kill", "killall sh", "", "", xmpp_slice, xmpp_host)
+
+# Condition to stop and clean the experiment
+ apps = []
+ for i in xrange(len(all_hosts)):
+ apps.append(ccnds[all_hosts[i]])
+ apps.append(ccnrs[all_hosts[i]])
+ apps += link
+ apps.append(pub)
+ apps.append(stream)
+
+ ec.register_condition(apps, ResourceAction.STOP, stream, ResourceState.STARTED, "30s")
+
+ ec.register_condition(ccndstops + [killall], ResourceAction.START, apps, ResourceState.STOPPED, "1s")
+ ec.register_condition(ccndstops + [killall], ResourceAction.STOP, ccndstops, ResourceState.STARTED, "1s")
+
+# Deploy all ResourceManagers
+ ec.deploy()
+
+# Wait until the applications are finished
+ ec.wait_finished(ccndstops)
+
+# Shutdown the experiment controller
+ ec.shutdown()
+
+
--- /dev/null
+"""
+ NEPI, a framework to manage network experiments
+ Copyright (C) 2013 INRIA
+
+ This program is free software: you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation, either version 3 of the License, or
+ (at your option) any later version.
+
+ 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/>.
+
+ Author: Julien Tribino <julien.tribino@inria.fr>
+
+ Example :
+ - Testbed : Plexus
+ - Explanation :
+
+ Test the STDIN Message
+
+ Node
+ wlab17
+ 0
+ |
+ |
+ 0
+ Application CTRL_test.rb
+
+ - Experiment:
+ * t0 : Deployment
+ * t1 : After the application started, one stdin message is sent
+ * t2 (t1 + 5s) : An other message is send
+
+"""
+
+#!/usr/bin/env python
+from nepi.execution.resource import ResourceFactory, ResourceAction, ResourceState
+from nepi.execution.ec import ExperimentController
+
+import time
+
+# Create the EC
+ec = ExperimentController()
+
+# Create and Configure the Nodes
+node1 = ec.register_resource("OMFNode")
+ec.set(node1, 'hostname', 'omf.plexus.wlab17')
+ec.set(node1, 'xmppSlice', "nepi")
+ec.set(node1, 'xmppHost', "xmpp-plexus.onelab.eu")
+ec.set(node1, 'xmppPort', "5222")
+ec.set(node1, 'xmppPassword', "1234")
+
+# Create and Configure the Application
+app1 = ec.register_resource("OMFApplication")
+ec.set(app1, 'appid', "robot")
+ec.set(app1, 'path', "/root/CTRL_test.rb")
+ec.set(app1, 'args', "coord.csv")
+ec.set(app1, 'env', "DISPLAY=localhost:10.0 XAUTHORITY=/root/.Xauthority")
+
+# Connection
+ec.register_connection(app1, node1)
+
+ec.register_condition(app1, ResourceAction.STOP, app1, ResourceState.STARTED , "20s")
+
+# Deploy
+ec.deploy()
+
+ec.wait_started([app1])
+ec.set(app1, 'stdin', "xxxxxxxxxxxxxxxxx")
+
+time.sleep(5)
+ec.set(app1, 'stdin', "xxxxxxxxxxxxxxxxx")
+
+ec.wait_finished([app1])
+
+# Stop Experiment
+ec.shutdown()
--- /dev/null
+"""
+ NEPI, a framework to manage network experiments
+ Copyright (C) 2013 INRIA
+
+ This program is free software: you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation, either version 3 of the License, or
+ (at your option) any later version.
+
+ 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/>.
+
+ Author: Julien Tribino <julien.tribino@inria.fr>
+
+ Example :
+ - Testbed : iMinds
+ - Explanation :
+
+ Test the STDIN Message
+
+ Node Zotack
+ node0.nepi-robot.nepi.wilab2.ilabt.iminds.be
+ 0
+ |
+ |
+ 0
+ Application RobotCTRLComm.rb
+
+ - Experiment:
+ - t0 : Deployment
+ - t1 : After the application started, send the message START_DRIVE
+ - t2 (t1 + 83s) : Open Left eye of robot 1
+ - t3 (t2 + 2s) : Open Left eye of robot 2
+
+"""
+
+from nepi.execution.resource import ResourceFactory, ResourceAction, ResourceState
+from nepi.execution.ec import ExperimentController
+
+# Create the EC
+ec = ExperimentController()
+
+# Create and Configure the Node
+node1 = ec.register_resource("OMFNode")
+ # 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, 'xmppSlice', "default_slice_iminds")
+ec.set(node1, 'xmppHost', "am.wilab2.ilabt.iminds.be")
+ec.set(node1, 'xmppPort', "5222")
+ec.set(node1, 'xmppPassword', "1234")
+
+# Create and Configure the Application
+app1 = ec.register_resource("OMFRobotApplication")
+ec.set(app1, 'appid', "robot")
+ec.set(app1, 'path', "/users/jtribino/RobotCTRLComm.rb")
+ec.set(app1, 'args', "/users/jtribino/coordinate.csv")
+ec.set(app1, 'env', " ")
+ec.set(app1, 'sources', "/home/wlab18/Desktop/coordinate.csv")
+ec.set(app1, 'sshUser', "jtribino")
+
+# Connection
+ec.register_connection(app1, node1)
+
+# The Application should run during 350sec
+ec.register_condition(app1, ResourceAction.STOP, app1, ResourceState.STARTED , "350s")
+
+# Deploy
+ec.deploy()
+
+ec.wait_started([app1])
+
+ec.set(app1, 'stdin', "START_DRIVE")
+
+time.sleep(83)
+ec.set(app1, 'stdin', "1;openlefteye")
+
+time.sleep(2)
+ec.set(app1, 'stdin', "2;openlefteye")
+
+ec.wait_finished([app1])
+
+ Stop Experiment
+ec.shutdown()
git://git.onelab.eu / nepi.git / commitdiff