LBRYFoundation/LBRY-Vault
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/LBRY-Vault.git synced 2025-09-02 18:25:21 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

update session

Browse source
This commit is contained in:
ThomasV 2011-12-08 23:42:10 +03:00
parent e183e81649
commit 2fb6e9d570
1 changed files with 19 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
server/server.py
View file

@ -361,6 +361,7 @@ def client_thread(ipaddr,conn):
if cmd=='b': if cmd=='b':
out = "%d"%block_number out = "%d"%block_number
elif cmd=='session': elif cmd=='session':
session_id = random_string(10) session_id = random_string(10)
try: try:
@ -370,7 +371,7 @@ def client_thread(ipaddr,conn):
conn.close() conn.close()
return return
print time.asctime(), "session", ipaddr, session_id, addresses[0] if addresses else addresses, len(addresses) print time.asctime(), "new session", ipaddr, session_id, addresses[0] if addresses else addresses, len(addresses)
sessions[session_id] = {} sessions[session_id] = {}
for a in addresses: for a in addresses:
@ -378,11 +379,27 @@ def client_thread(ipaddr,conn):
out = repr( (session_id, config.get('server','banner').replace('\\n','\n') ) ) out = repr( (session_id, config.get('server','banner').replace('\\n','\n') ) )
sessions_last_time[session_id] = time.time() sessions_last_time[session_id] = time.time()
elif cmd=='update_session':
try:
session_id, addresses = ast.literal_eval(data)
except:
print "error"
conn.close()
return
print time.asctime(), "update session", ipaddr, session_id, addresses[0] if addresses else addresses, len(addresses)
sessions[session_id] = {}
for a in addresses:
sessions[session_id][a] = ''
out = 'ok'
sessions_last_time[session_id] = time.time()
elif cmd=='poll': elif cmd=='poll':
session_id = data session_id = data
addresses = sessions.get(session_id) addresses = sessions.get(session_id)
if addresses is None: if addresses is None:
print time.asctime(), " Session not found", session_id, ipaddr print time.asctime(), "session not found", session_id, ipaddr
out = repr( (-1, {})) out = repr( (-1, {}))
else: else:
t1 = time.time() t1 = time.time()