traceback.print_exc(file=sys.stdout)
-def close_sesion(session_id):
+def close_session(session_id):
print "lost connection", session_id
sessions.pop(session_id)
- sessions_sub_numblocks.remove(session_id)
+ if session_id in sessions_sub_numblocks:
+ sessions_sub_numblocks.remove(session_id)
# one thread per client. put requests in a queue.
d = conn.recv(1024)
msg += d
if not d:
- close_sesion(session_id)
+ close_session(session_id)
break
while True:
def process_input_queue():
while not stopping:
session_id, cmd, data = input_queue.get()
+ if session_id not in sessions.keys():
+ continue
out = None
if cmd == 'address.subscribe':
subscribe_to_address(session_id,data)
sessions[session_id]['version'] = data
elif cmd == 'server.banner':
out = json.dumps( { 'method':'server.banner', 'result':config.get('server','banner').replace('\\n','\n') } )
+ elif cmd == 'server.peers':
+ out = json.dumps( { 'method':'server.peers', 'result':peer_list.values() } )
elif cmd == 'address.get_history':
address = data
out = json.dumps( { 'method':'address.get_history', 'address':address, 'result':store.get_history( address ) } )