]> code.delx.au - monosys/commitdiff
proxy.py has a larger backlog and sets SO_REUSEADDR
authorJames Bunton <jamesbunton@delx.net.au>
Sun, 11 Dec 2011 04:15:52 +0000 (15:15 +1100)
committerJames Bunton <jamesbunton@delx.net.au>
Sun, 11 Dec 2011 04:15:52 +0000 (15:15 +1100)
scripts/proxy.py

index f04b4baf4a2f2fc2ddd46c55ad0574bb21be2d44..0690611a11f0ecc7bef247ab3c7442766116ac97 100755 (executable)
@@ -209,8 +209,9 @@ class BasicForwarder(asyncore.dispatcher):
                self.port = port
                self.allowed = allowed
                self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
+               self.set_reuse_addr()
                self.bind(("", listen_port))
-               self.listen(5)
+               self.listen(50)
 
        def handle_error(self):
                print >>sys.stderr, "BasicForwarder error:", sys.exc_info()
@@ -236,8 +237,9 @@ class Forwarder(asyncore.dispatcher):
                asyncore.dispatcher.__init__(self)
                self.allowed = allowed
                self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
+               self.set_reuse_addr()
                self.bind(("", listen_port))
-               self.listen(5)
+               self.listen(50)
 
        def handle_error(self):
                print >>sys.stderr, "Forwarder error:", sys.exc_info()
@@ -258,8 +260,9 @@ class Interceptor(asyncore.dispatcher):
                self.host = host
                self.port = port
                self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
+               self.set_reuse_addr()
                self.bind(("0.0.0.0", listen_port))
-               self.listen(5)
+               self.listen(50)
 
        def handle_error(self):
                print >>sys.stderr, "Interceptor error!", sys.exc_info()