Kaydet (Commit) 466a54f4 authored tarafından Giampaolo Rodola''s avatar Giampaolo Rodola'

fix failing asyncore test as per http://bugs.python.org/issue10340#msg156586

üst 42243c4d
...@@ -783,16 +783,18 @@ class BaseTestAPI(unittest.TestCase): ...@@ -783,16 +783,18 @@ class BaseTestAPI(unittest.TestCase):
@support.reap_threads @support.reap_threads
def test_quick_connect(self): def test_quick_connect(self):
# see: http://bugs.python.org/issue10340 # see: http://bugs.python.org/issue10340
server = TCPServer() if self.family in (socket.AF_INET, getattr(socket, "AF_INET6", object())):
t = threading.Thread(target=lambda: asyncore.loop(timeout=0.1, count=500)) server = BaseServer(self.family, self.addr)
t.start() t = threading.Thread(target=lambda: asyncore.loop(timeout=0.1,
count=500))
for x in range(20): t.start()
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_LINGER, for x in range(20):
struct.pack('ii', 1, 0)) s = socket.socket(self.family, socket.SOCK_STREAM)
s.connect(server.address) s.setsockopt(socket.SOL_SOCKET, socket.SO_LINGER,
s.close() struct.pack('ii', 1, 0))
s.connect(server.address)
s.close()
class TestAPI_UseIPv4Sockets(BaseTestAPI): class TestAPI_UseIPv4Sockets(BaseTestAPI):
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment