self.message_id = 0
self.unanswered_requests = {}
self.subscriptions = {}
- self.debug = True
+ self.debug = False
self.lock = threading.Lock()
def process(self, response):
# runs callbacks
- #print "<--", response
+ if self.debug: print "<--", response
msg_id = response.get('id')
with self.lock:
request = json.dumps( { 'id':self.message_id, 'method':method, 'params':params } )
self.unanswered_requests[self.message_id] = method, params, callback
ids.append(self.message_id)
- # print "-->", request
+ if self.debug: print "-->", request
self.message_id += 1
out += request + '\n'
while out:
self.network = network
self.queue = Queue.Queue()
self.unanswered_requests = {}
+ self.debug = False
def run(self):
def process(self, request):
- #print "<--", request
+ if self.debug: print "<--", request
method = request['method']
params = request['params']
_id = request['id']
except BaseException as e:
out['error'] =str(e)
self.queue.put(out)
+ return
if method == 'daemon.shutdown':
self.server.running = False
while out:
n = self.s.send(out)
out = out[n:]
- #print "-->", r
+ if self.debug: print "-->", r