summaryrefslogtreecommitdiff
path: root/server/piztor/server.py
diff options
context:
space:
mode:
Diffstat (limited to 'server/piztor/server.py')
-rw-r--r--server/piztor/server.py10
1 files changed, 5 insertions, 5 deletions
diff --git a/server/piztor/server.py b/server/piztor/server.py
index b944f20..aa5d72c 100644
--- a/server/piztor/server.py
+++ b/server/piztor/server.py
@@ -121,7 +121,11 @@ class PushTunnel(object):
logger.info("-- Wrote push: %s --", get_hex(front.data))
self.blocked = True
+ def clear(self):
+ self.pending.clear()
+
def connect(self, conn):
+ self.clear()
conn.tunnel = self
if self.conn: # only one long-connection per user
self.conn.transport.loseConnection()
@@ -523,11 +527,7 @@ class OpenPushTunnelHandler(RequestHandler):
return self.pack(struct.pack("!B", _StatusCode.failure))
tunnel = RequestHandler.push_tunnels[uauth.uid]
- pt = RequestHandler.push_tunnels
- uid = uauth.uid
- if pt.has_key(uid):
- tunnel = pt[uid]
- tunnel.connect(conn)
+ tunnel.connect(conn)
logger.info("Push tunnel opened successfully!")
return self.pack(struct.pack("!B", _StatusCode.sucess))