From dd48312aff3193c70e799f52c2f2a0c78175ea53 Mon Sep 17 00:00:00 2001 From: j Date: Fri, 1 Feb 2019 13:19:19 +0530 Subject: [PATCH] queue debugging --- oml/node/server.py | 1 - oml/nodes.py | 3 +++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/oml/node/server.py b/oml/node/server.py index 65451dc..bc2e816 100644 --- a/oml/node/server.py +++ b/oml/node/server.py @@ -317,7 +317,6 @@ class Handler(http.server.SimpleHTTPRequestHandler): self.send_header('Content-Length', str(content_length)) self.end_headers() self.wfile.write(content) - logger.debug('%s bytes response', content_length) def chunk_size(self, content_length): return min(16*1024, content_length) diff --git a/oml/nodes.py b/oml/nodes.py index 55fd075..9dda107 100644 --- a/oml/nodes.py +++ b/oml/nodes.py @@ -504,6 +504,7 @@ class Nodes(Thread): while not state.shutdown: args = self._q.get() if args: + logger.debug('processing nodes queue: next: %s, %s entries in queue', args[0], self._q.qsize()) if args[0] == 'add': self._add(*args[1:]) elif args[0] == 'pull': @@ -512,6 +513,8 @@ class Nodes(Thread): self._call(*args) def queue(self, *args): + if args: + logger.debug('add %s to queue, queue currently has %s entries', args[0], self._q.qsize()) self._q.put(list(args)) def is_online(self, id):