--- /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/>.
+#
+# Author: Alina Quereilhac <alina.quereilhac@inria.fr>
+
+from nepi.execution.attribute import Attribute, Flags, Types
+from nepi.execution.resource import clsinit_copy, ResourceState, \
+ reschedule_delay
+from nepi.resources.linux.ns3.ccn.ns3ccndceapplication \
+ import LinuxNS3CCNDceApplication
+
+import os
+import tempfile
+
+@clsinit_copy
+class LinuxNS3DceCCNPoke(LinuxNS3CCNDceApplication):
+ _rtype = "ns3::LinuxDceCCNPoke"
+
+ @classmethod
+ def _register_attributes(cls):
+ content_name = Attribute("contentName",
+ "Content name for the requested content object. ",
+ flags = Flags.Design)
+ content = Attribute("content",
+ "Content to poke (as a text string). ",
+ flags = Flags.Design)
+
+ cls._register_attribute(content_name)
+ cls._register_attribute(content)
+
+ def _instantiate_object(self):
+ if not self.get("binary"):
+ self.set("binary", "ccnpoke")
+
+ if self.get("contentName"):
+ self.set("arguments", self.get("contentName"))
+
+ # Create temporary local file to store content
+ content = self.get("content")
+ f = tempfile.NamedTemporaryFile(delete=False)
+ f.write(content)
+ f.close()
+
+ localpath = f.name
+ dcepath = os.path.join("/tmp", os.path.basename(localpath))
+
+ self.set("files", "%s=%s" % (localpath, dcepath))
+ self.set("stdinFile", dcepath)
+
+ super(LinuxNS3DceCCNPoke, self)._instantiate_object()
+
--- /dev/null
+#!/usr/bin/env python
+#
+# 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>
+
+
+from nepi.execution.ec import ExperimentController
+from nepi.execution.trace import TraceAttr
+
+import os
+import time
+import unittest
+
+def add_ns3_node(ec, simu):
+ node = ec.register_resource("ns3::Node")
+ ec.register_connection(node, simu)
+
+ ipv4 = ec.register_resource("ns3::Ipv4L3Protocol")
+ ec.register_connection(node, ipv4)
+
+ arp = ec.register_resource("ns3::ArpL3Protocol")
+ ec.register_connection(node, arp)
+
+ icmp = ec.register_resource("ns3::Icmpv4L4Protocol")
+ ec.register_connection(node, icmp)
+
+ udp = ec.register_resource("ns3::UdpL4Protocol")
+ ec.register_connection(node, udp)
+
+ tcp = ec.register_resource("ns3::TcpL4Protocol")
+ ec.register_connection(node, tcp)
+
+ return node
+
+class LinuxNS3CCNPeekDceApplicationTest(unittest.TestCase):
+ def setUp(self):
+ #self.fedora_host = "nepi2.pl.sophia.inria.fr"
+ #self.fedora_host = "planetlabpc1.upf.edu"
+ #self.fedora_user = "inria_nepi"
+ #self.fedora_identity = "%s/.ssh/id_rsa_planetlab" % (os.environ['HOME'])
+ self.fedora_host = "mimas.inria.fr"
+ self.fedora_user = "aquereil"
+ self.fedora_identity = "%s/.ssh/id_rsa" % (os.environ['HOME'])
+
+ def test_dce_ccn(self):
+ ec = ExperimentController(exp_id = "test-dce-ccnpeek")
+
+ node = ec.register_resource("LinuxNode")
+ 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)
+
+ simu = ec.register_resource("LinuxNS3Simulation")
+ ec.set(simu, "verbose", True)
+ ec.set(simu, "enableDCE", True)
+ ec.set(simu, "buildMode", "debug")
+ ec.set(simu, "nsLog", "DceApplication")
+ ec.register_connection(simu, node)
+
+ nsnode = add_ns3_node(ec, simu)
+
+ ### create applications
+ ccnd = ec.register_resource("ns3::LinuxDceCCND")
+ ec.set (ccnd, "stackSize", 1<<20)
+ ec.set (ccnd, "StartTime", "1s")
+ ec.register_connection(ccnd, nsnode)
+
+ ccnpoke = ec.register_resource("ns3::LinuxDceCCNPoke")
+ 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")
+ ec.set (ccnpeek, "contentName", "ccnx:/chunk0")
+ ec.set (ccnpeek, "stackSize", 1<<20)
+ ec.set (ccnpeek, "StartTime", "4s")
+ ec.set (ccnpeek, "StopTime", "20s")
+ ec.register_connection(ccnpeek, nsnode)
+
+ ec.deploy()
+
+ ec.wait_finished([ccnpeek])
+
+ expected = "ccnpeek ccnx:/chunk0"
+ cmdline = ec.trace(ccnpeek, "cmdline")
+ self.assertTrue(cmdline.find(expected) > -1, cmdline)
+
+ expected = "Start Time: NS3 Time: 4s ("
+ status = ec.trace(ccnpeek, "status")
+ self.assertTrue(status.find(expected) > -1, status)
+
+ expected = "DATA"
+ stdout = ec.trace(ccnpeek, "stdout")
+ self.assertTrue(stdout.find(expected) > -1, stdout)
+
+ ec.shutdown()
+
+if __name__ == '__main__':
+ unittest.main()
git://git.onelab.eu / nepi.git / commitdiff