X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=src%2Fnepi%2Fresources%2Fomf%2Fnode.py;h=6ac01de9139eba88bf3efa69cb4b786882b4774e;hb=ecdd7ec5a216f5faf46ec9f1c7eb5c2454c14d27;hp=875693fc40d9389a3c6e0a50af0b5f18dd249b6b;hpb=c80f0b761a50bd9af3337c7e28e9bcd25b476b16;p=nepi.git diff --git a/src/nepi/resources/omf/node.py b/src/nepi/resources/omf/node.py index 875693fc..6ac01de9 100644 --- a/src/nepi/resources/omf/node.py +++ b/src/nepi/resources/omf/node.py @@ -18,6 +18,7 @@ # Author: Alina Quereilhac # Julien Tribino +from nepi.util.timefuncs import tnow from nepi.execution.resource import ResourceManager, clsinit_copy, \ ResourceState, reschedule_delay from nepi.execution.attribute import Attribute, Flags @@ -26,8 +27,8 @@ from nepi.resources.omf.omf_api_factory import OMFAPIFactory import time -reschedule_check = "0.4s" -confirmation_counter = 600 +reschedule_check = "0.2s" +confirmation_counter = 3000 @clsinit_copy class OMFNode(OMFResource): @@ -68,6 +69,11 @@ class OMFNode(OMFResource): self._omf_api = None + # For performance tests + self.perf = True + self.begin_deploy_time = None + + @property def exp_id(self): return self.ec.exp_id @@ -99,6 +105,11 @@ class OMFNode(OMFResource): to enroll the node into the experiment. """ + ## For performance test + if self.perf: + self.begin_deploy_time = tnow() + self.perf = False + if not self.get('xmppServer'): msg = "XmppServer is not initialzed. XMPP Connections impossible" self.error(msg)