#!/usr/bin/env python
-from neco.execution.ec import ExperimentController
-from neco.execution.resource import ResourceState
-from neco.resources.linux.node import LinuxNode
-from neco.resources.linux.interface import LinuxInterface
-from neco.resources.linux.channel import LinuxChannel
-from neco.util.sshfuncs import RUNNING, FINISHED
+from nepi.execution.ec import ExperimentController
+from nepi.execution.resource import ResourceState
+from nepi.resources.linux.node import LinuxNode
+from nepi.resources.linux.interface import LinuxInterface
+from nepi.resources.linux.channel import LinuxChannel
+from nepi.util.sshfuncs import RUNNING, FINISHED
from test_utils import skipIfNotAlive
@skipIfNotAlive
def t_deploy(self, host, user):
- from neco.execution.resource import ResourceFactory
+ from nepi.execution.resource import ResourceFactory
ResourceFactory.register_type(LinuxNode)
ResourceFactory.register_type(LinuxInterface)
ec.register_connection(iface, node)
ec.register_connection(iface, chan)
- try:
- ec.deploy()
+ ec.deploy()
- while not all([ ec.state(guid) == ResourceState.STARTED \
- for guid in [node, iface]]):
- time.sleep(0.5)
+ while not all([ ec.state(guid) == ResourceState.STARTED \
+ for guid in [node, iface]]) and not ec.finished:
+ time.sleep(0.5)
- self.assertTrue(ec.state(node) == ResourceState.STARTED)
- self.assertTrue(ec.state(iface) == ResourceState.STARTED)
- self.assertTrue(ec.get(iface, "deviceName") == "eth0")
+ self.assertTrue(ec.state(node) == ResourceState.STARTED)
+ self.assertTrue(ec.state(iface) == ResourceState.STARTED)
+ self.assertTrue(ec.get(iface, "deviceName") == "eth0")
- finally:
- ec.shutdown()
+ ec.shutdown()
def test_deploy_fedora(self):
self.t_deploy(self.fedora_host, self.fedora_user)