Changeset 6857

Timestamp:

Feb 16, 2018, 3:05:45 PM (2 years ago)

Author:

mabarracus

Message:

Fix bug

File:

• lliurex-analytics-server/trunk/fuentes/lliurex-analytics-server/usr/sbin/analyticsd (modified) (5 diffs)

lliurex-analytics-server/trunk/fuentes/lliurex-analytics-server/usr/sbin/analyticsd

@@ -106 +106 @@
     t=str(int(time.time()))
     if DEBUG:
-        printea('on {} analyticsd({}) is alive, all good :-)'.format(t,who),'debug')
+        pass
+        # too much verbose
+        # printea('on {} analyticsd({}) is alive, all good :-)'.format(t,who),'debug')
     else:
         if who == 'main':
@@ -505 +507 @@
             while (lapps['timestamp'] > self.mon.commited):
                 time.sleep(0.001)
-        if len(lapps['apps']) != 0 and len(lapps['clients']) != 0:
+        if len(lapps['clients']) != 0:
+            printea('Thread {} putting client'.format(self.t),'debug')
             #IF FAIL, AFTER RETRIES THREAD DIES
             if not self.put_client(client_list=lapps['clients'],mon=self.mon):
                 self.q.put(lapps,True) # USELESS
                 return False    # USELESS
+        if len(lapps['apps']) != 0:
+            printea('Thread {} putting clientapps'.format(self.t),'debug')
             if not (self.put_apps(apps=lapps['apps'],mon=self.mon)):
                 self.q.put(lapps,True) # USELESS
@@ -522 +527 @@
     def process(self,*args,**kwargs):
         keepalive(self.t)
-        # code only for main thread
-        printea("Running thread {}".format(self.t),'debug')
+        # warning too much verbose, printea("Running thread {}".format(self.t),'debug')
         if self.t == 'main' and not self.mon.terminate:
             ret=self.process_main_thread(*args,**kwargs)
@@ -552 +556 @@
                 if self.mon.paused:
                     printea("Paused by high load {}".format(self.t),'debug')
-                if self.empty:
-                    printea("Empty queue {} sleeping by now".format(self.t),'debug')
+                # Too much verbose
+                #if self.empty:
+                #    printea("Empty queue {} sleeping by now".format(self.t),'debug')
                 if self.empty:
                     self.empty = False
@@ -587 +592 @@
                     #    printea("Worker ({}) detected server gone away !!!: {}".format(self.t,e))
 
-                    printea("Trying to recover connection ({})".format(self.t))
+                    printea("Trying to recover connection ({}), {}".format(self.t,e))
                     if self.reconnect == 100:
                         printea("Worker ({}) says: lost connection to database, reconnection not possible, terminating all processes".format(self.t))