v1.9.9

qwj · web-flow · commit 8bb0ddac070e · 2018-12-24T00:46:16.000+08:00
diff --git a/pproxy/__doc__.py b/pproxy/__doc__.py
@@ -1,5 +1,5 @@
 __title__       = "pproxy"
-__version__     = "1.9.8"
+__version__     = "1.9.9"
 __license__     = "MIT"
 __description__ = "Proxy server that can tunnel among remote servers by regex rules."
 __keywords__    = "proxy socks http shadowsocks shadowsocksr ssr redirect pf tunnel cipher ssl udp"
diff --git a/pproxy/server.py b/pproxy/server.py
@@ -4,7 +4,7 @@
 
 SOCKET_TIMEOUT = 300
 PACKET_SIZE = 65536
-UDP_LIMIT = 150
+UDP_LIMIT = 30
 DUMMY = lambda s: s
 
 asyncio.StreamReader.read_ = lambda self: self.read(PACKET_SIZE)
@@ -239,7 +239,9 @@ def connection_lost(prot, exc):
             self.connection_change(1)
             if len(self.udpmap) > UDP_LIMIT:
                 min_addr = min(self.udpmap, key=lambda x: self.udpmap[x].update)
-                self.udpmap.pop(min_addr).transport.close()
+                prot = self.udpmap.pop(min_addr)
+                if prot.transport:
+                    prot.transport.close()
             prot = Protocol(data)
             remote_addr = (host, port) if self.direct else (self.host_name, self.port)
             await asyncio.get_event_loop().create_datagram_endpoint(lambda: prot, remote_addr=remote_addr)
