fix reconnect bug

qwj · qwj · commit 1254af0de9bb · 2019-03-27T14:06:40.000+08:00
diff --git a/pproxy/__doc__.py b/pproxy/__doc__.py
@@ -1,5 +1,5 @@
 __title__       = "pproxy"
-__version__     = "2.1.0"
+__version__     = "2.1.1"
 __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
@@ -310,7 +310,7 @@ def datagram_received(prot, data, addr):
         return asyncio.get_event_loop().create_datagram_endpoint(Protocol, local_addr=(self.host_name, self.port))
     async def open_connection(self, host, port, local_addr, lbind):
         if self.reuse or self.ssh:
-            if self.streams is None or self.streams.done() and not self.handler:
+            if self.streams is None or self.streams.done() and (self.reuse and not self.handler):
                 self.streams = asyncio.get_event_loop().create_future()
             else:
                 if not self.streams.done():
