X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=src%2Fnepi%2Fresources%2Fomf%2Fnode.py;h=ce2f6c97ab52da37ddb8620a82e0fc4cb7ec2931;hb=0e38569d30fcbff835b8dbb96c54177ae970d558;hp=c0e10f912621bfcb81ff683d2dc5e63bf7a6cd8f;hpb=f025a30a215310a9803067a25e244137b71f56f2;p=nepi.git diff --git a/src/nepi/resources/omf/node.py b/src/nepi/resources/omf/node.py index c0e10f91..ce2f6c97 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.3s" -confirmation_counter = 300 +reschedule_check = "1s" +confirmation_counter = 3600 @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)