From: Alina Quereilhac Date: Thu, 29 May 2014 09:17:04 +0000 (+0200) Subject: Adding ccncat linux example X-Git-Tag: nepi-3.1.0~65 X-Git-Url: http://git.onelab.eu/?p=nepi.git;a=commitdiff_plain;h=d3f7ceb99f4ea79986122d59a0f20696f98cc0a7 Adding ccncat linux example --- diff --git a/src/nepi/resources/linux/ccn/ccncat.py b/src/nepi/resources/linux/ccn/ccncat.py new file mode 100644 index 00000000..c721c331 --- /dev/null +++ b/src/nepi/resources/linux/ccn/ccncat.py @@ -0,0 +1,66 @@ +# +# 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 . +# +# Author: Alina Quereilhac + +from nepi.execution.attribute import Attribute, Flags, Types +from nepi.execution.resource import clsinit_copy, ResourceState, \ + reschedule_delay +from nepi.resources.linux.ccn.ccnapplication import LinuxCCNApplication + +import os + +@clsinit_copy +class LinuxCCNCat(LinuxCCNApplication): + _rtype = "LinuxCCNCat" + + @classmethod + def _register_attributes(cls): + content_name = Attribute("contentName", + "Content name for the content to peek", + flags = Flags.Design) + + cls._register_attribute(content_name) + + def __init__(self, ec, guid): + super(LinuxCCNCat, self).__init__(ec, guid) + self._home = "ccncat-%s" % self.guid + + def do_deploy(self): + if not self.ccnd or self.ccnd.state < ResourceState.READY: + self.debug("---- RESCHEDULING DEPLOY ---- node state %s " % self.node.state ) + self.ec.schedule(reschedule_delay, self.deploy) + else: + command = self.get("command") + if not command: + command = "ccncat %s" % self.get("contentName") + self.set("command", command) + + self.info("Deploying command '%s' " % command) + + if not self.get("env"): + self.set("env", self._environment) + + self.do_discover() + self.do_provision() + + self.set_ready() + + def valid_connection(self, guid): + # TODO: Validate! + return True + diff --git a/test/resources/linux/ccn/ccncat.py b/test/resources/linux/ccn/ccncat.py new file mode 100644 index 00000000..163e94dd --- /dev/null +++ b/test/resources/linux/ccn/ccncat.py @@ -0,0 +1,79 @@ +#!/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 . +# +# Author: Alina Quereilhac + +from nepi.execution.resource import ResourceState, ResourceAction +from nepi.execution.ec import ExperimentController +from test_utils import skipIfAnyNotAlive + +import os +import time +import tempfile +import unittest + +class LinuxCCNPeekTestCase(unittest.TestCase): + def setUp(self): + #self.fedora_host = "nepi2.pl.sophia.inria.fr" + #self.fedora_user = "inria_nepi" + self.fedora_identity = "%s/.ssh/id_rsa" % (os.environ['HOME']) + + self.fedora_host = "mimas.inria.fr" + self.fedora_user = "aquereil" + + @skipIfAnyNotAlive + def test_ccnpeek(self): + ec = ExperimentController(exp_id = "test-linux-ccncat") + + 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) + + ccnd = ec.register_resource("LinuxCCND") + ec.register_connection(ccnd, node) + + # REPO file is in test/resources/linux/ns3/ccn/repoFile1 + repofile = os.path.join( + os.path.dirname(os.path.realpath(__file__)), + "..", "ns3", "ccn", "repoFile1") + + ## Register a repository in node 1 + ccnr = ec.register_resource("LinuxCCNR") + ec.set(ccnr, "repoFile1", repofile) + ec.register_connection(ccnr, ccnd) + + ccncat = ec.register_resource("LinuxCCNCat") + ec.set(ccncat, "contentName", "ccnx:/test/bunny.ts") + ec.register_connection(ccncat, ccnd) + + ec.deploy() + + ec.wait_finished(ccncat) + + expected = 2873956 + stdout = ec.trace(ccncat, "stdout") + self.assertTrue(len(stdout) == expected , stdout) + + ec.shutdown() + +if __name__ == '__main__': + unittest.main() +