Removed unnecessary prints

conf/config.py

@@ -55,7 +55,8 @@ class defaultConfigSender():
     ondaPorts           = ["6081"]
 
     # chunk size of file-parts getting send via zmq
-    chunkSize           = 1048576 # = 1024*1024
+    #chunkSize           = 1048576 # = 1024*1024
+    chunkSize           = 10485760 # = 1024*1024*10
     #chunkSize           = 1073741824 # = 1024*1024*1024
 
 #    # path where logfile will be created

src/ZeroMQTunnel/Cleaner.py

@@ -78,8 +78,8 @@ class Cleaner():
             trace = traceback.format_exc()
             self.log.error("Stopping cleanerProcess due to unknown error condition.")
             self.log.debug("Error was: " + str(trace))
-
-        self.stop()
+        finally:
+            self.stop()
 
 
     def getLogger(self):
@@ -100,7 +100,6 @@ class Cleaner():
 
             if workload == "STOP":
                 self.log.info("Stopping cleaner")
-#                    self.stop()
                 break
 
             # transform to dictionary

src/ZeroMQTunnel/WorkerProcess.py

@@ -126,11 +126,8 @@ class WorkerProcess():
 
         processingJobs = True
         jobCount = 0
-        ondaRequest = False
-        print "ondaRequest", ondaRequest
 
         while processingJobs:
-            print "while"
             #sending a "ready"-signal to the router.
             #the reply will contain the actual job/task.
             self.log.debug("worker-"+str(self.id)+": sending ready signal")
@@ -222,12 +219,10 @@ class WorkerProcess():
                     #skip all further instructions and continue with next iteration
                     continue
             else:
-                print "worker-"+str(self.id)+": no data sent"
+                print "worker-"+str(self.id)+": no data sent to live viewer"
 
             if self.useRealTimeAnalysis:
-                print "waiting"
                 socks = dict(self.poller.poll(0))
-                print "waiting..done"
 
                 if self.ondaComSocket in socks and socks[self.ondaComSocket] == zmq.POLLIN:
                     ondaWorkload = self.ondaComSocket.recv()
@@ -466,7 +461,7 @@ class WorkerProcess():
 
     def stop(self):
         self.log.debug("Sending stop signal to cleaner from worker-" + str(self.id))
-#        self.cleanerSocket.send("STOP")        #no communication needed because cleaner detects KeyboardInterrupt signals
+        self.cleanerSocket.send("STOP")        #no communication needed because cleaner detects KeyboardInterrupt signals
         self.log.info("Closing sockets for worker " + str(self.id))
         if self.zmqDataStreamSocket:
             self.zmqDataStreamSocket.close(0)

src/receiver_RealTimeAnalysis.py

@@ -103,7 +103,8 @@ class ReceiverRealTimeAnalysis():
                 try:
                     #  Get the reply.
                     received_file = self.senderDataSocket.recv_multipart()
-                    print "Received_file", "".join(received_file)
+#                    print "Received_file", "".join(received_file)[:45]
+                    print "Received_file", received_file[0][:45]
                     self.log.debug("Received_file" + str(received_file))
                 except zmq.error.ZMQError:
                     received_file = None