Merge pull request #199 from nnDarshan/patch-5

Span the hardware inventory collection over a period of time.
Tendrl · Feb 2, 2017 · cc67051 · cc67051
2 parents 8c8ccf0 + 7093c5b
commit cc67051
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/tendrl/node_agent/manager/__init__.py b/tendrl/node_agent/manager/__init__.py
@@ -79,6 +79,7 @@ def load_and_execute_sds_discovery_plugins(self):
 
 def main():
     tendrl_ns.central_store_thread = central_store.NodeAgentEtcdCentralStore()
+    tendrl_ns.first_node_inventory_sync = True
     tendrl_ns.state_sync_thread = node_sync.NodeAgentSyncThread()
 
     tendrl_ns.node_context.save()

diff --git a/tendrl/node_agent/node_sync/__init__.py b/tendrl/node_agent/node_sync/__init__.py
@@ -40,7 +40,12 @@ def _run(self):
 
         while not self._complete.is_set():
             try:
-                gevent.sleep(3)
+                interval = 10
+                if tendrl_ns.first_node_inventory_sync:
+                    interval = 2
+                    tendrl_ns.first_node_inventory_sync = False
+
+                gevent.sleep(interval)
                 tags = []
                 # update node agent service details
                 LOG.info("node_sync, Updating Service data")
@@ -49,20 +54,25 @@ def _run(self):
                     if s.running:
                         tags.append(TENDRL_SERVICE_TAGS[service.strip("@*")])
                     s.save()
+                gevent.sleep(interval)
 
                 # updating node context with latest tags
                 LOG.info("node_sync, updating node context data with tags")
                 tags = "\n".join(tags)
                 tendrl_ns.node_agent.objects.NodeContext(tags=tags).save()
+                gevent.sleep(interval)
 
                 LOG.info("node_sync, Updating OS data")
                 tendrl_ns.node_agent.objects.Os().save()
+                gevent.sleep(interval)
 
                 LOG.info("node_sync, Updating cpu")
                 tendrl_ns.node_agent.objects.Cpu().save()
+                gevent.sleep(interval)
 
                 LOG.info("node_sync, Updating memory")
                 tendrl_ns.node_agent.objects.Memory().save()
+                gevent.sleep(interval)
 
                 LOG.info("node_sync, Updating disks")
                 try: