X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=src%2Fnepi%2Fresources%2Fomf%2Finterface.py;h=d7142d1b54c5f4b1dd6139a3ed7eb2b725a289c3;hb=d50ba1a08e541ded7a8b322493ebb1d0cc59c6ff;hp=c8c6f87fd7e8bdf4256f3f3f3f22b814a60dee43;hpb=3c4a5dac5faabde3aabcab72adc1d9be1af32643;p=nepi.git diff --git a/src/nepi/resources/omf/interface.py b/src/nepi/resources/omf/interface.py index c8c6f87f..d7142d1b 100644 --- a/src/nepi/resources/omf/interface.py +++ b/src/nepi/resources/omf/interface.py @@ -19,8 +19,9 @@ # Julien Tribino import os, time +from nepi.util.timefuncs import tnow from nepi.execution.resource import ResourceManager, clsinit_copy, \ - ResourceState, reschedule_delay + ResourceState from nepi.execution.attribute import Attribute, Flags from nepi.resources.omf.node import OMFNode, confirmation_counter, reschedule_check @@ -39,8 +40,8 @@ class OMFWifiInterface(OMFResource): :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): @@ -82,6 +83,9 @@ class OMFWifiInterface(OMFResource): self._omf_api = None self._type = "" + # For performance tests + self.perf = True + self.begin_deploy_time = None def valid_connection(self, guid): """ Check if the connection with the guid in parameter is possible. @@ -125,7 +129,7 @@ class OMFWifiInterface(OMFResource): """ if self.node.state < ResourceState.READY: - self.ec.schedule(reschedule_delay, self.deploy) + self.ec.schedule(self.reschedule_delay, self.deploy) return False for attrname in ["mode", "type", "essid"]: @@ -151,7 +155,7 @@ class OMFWifiInterface(OMFResource): """ if self.channel.state < ResourceState.READY: - self.ec.schedule(reschedule_delay, self.deploy) + self.ec.schedule(self.reschedule_delay, self.deploy) return False attrval = self.get("ip") @@ -202,15 +206,20 @@ class OMFWifiInterface(OMFResource): if not self.node or self.node.state < ResourceState.READY: self.debug("---- RESCHEDULING DEPLOY ---- node state %s " % self.node.state ) - self.ec.schedule(reschedule_delay, self.deploy) + self.ec.schedule(self.reschedule_delay, self.deploy) return if not self.channel or self.channel.state < ResourceState.READY: self.debug("---- RESCHEDULING DEPLOY ---- channel state %s " % self.channel.state ) - self.ec.schedule(reschedule_delay, self.deploy) + self.ec.schedule(self.reschedule_delay, self.deploy) return + ## For performance test + if self.perf: + self.begin_deploy_time = tnow() + self.perf = False + self.set('xmppUser',self.node.get('xmppUser')) self.set('xmppServer',self.node.get('xmppServer')) self.set('xmppPort',self.node.get('xmppPort'))