"subscriptions":len(s.subscriptions)},
self.dispatcher.request_dispatcher.get_sessions())
+ elif method == 'server.load':
+ p = self.dispatcher.request_dispatcher.processors['blockchain']
+ result = p.queue.qsize()
+
else:
print "unknown method", request
if msg.find('\n') != -1: break
s.close()
r = json.loads(msg).get('result')
- if command == 'stop': print r
- elif command == 'info':
+
+ if command == 'info':
now = time.time()
print 'type address sub version time'
for item in r:
item.get('subscriptions'),
item.get('version'),
(now - item.get('time')) )
+ else:
+ print r
if __name__ == '__main__':
config = create_config()