summaryrefslogtreecommitdiffstats
path: root/Lib
diff options
context:
space:
mode:
authorAntoine Pitrou <solipsis@pitrou.net>2010-04-27 10:41:37 (GMT)
committerAntoine Pitrou <solipsis@pitrou.net>2010-04-27 10:41:37 (GMT)
commitbe168130d1c0f9880768adb44820a9887e39ea40 (patch)
tree53aea8a21239624865abbda883e4ce494cf61236 /Lib
parent0fb2e54c874a453c75ab25dcb4fe9beee39e5ae3 (diff)
downloadcpython-be168130d1c0f9880768adb44820a9887e39ea40.zip
cpython-be168130d1c0f9880768adb44820a9887e39ea40.tar.gz
cpython-be168130d1c0f9880768adb44820a9887e39ea40.tar.bz2
Merged revisions 80528 via svnmerge from
svn+ssh://pythondev@svn.python.org/python/branches/py3k ................ r80528 | antoine.pitrou | 2010-04-27 11:56:02 +0200 (mar., 27 avril 2010) | 11 lines Merged revisions 80526 via svnmerge from svn+ssh://pythondev@svn.python.org/python/trunk ........ r80526 | antoine.pitrou | 2010-04-27 11:51:18 +0200 (mar., 27 avril 2010) | 5 lines replace custom code with standard library functionality (HTTPServer.shutdown()) + enable test that was never run (!) + make tests faster by lowering polling timeout ........ ................
Diffstat (limited to 'Lib')
-rw-r--r--Lib/test/test_ssl.py49
1 files changed, 3 insertions, 46 deletions
diff --git a/Lib/test/test_ssl.py b/Lib/test/test_ssl.py
index 71ddc4a..d9892b9 100644
--- a/Lib/test/test_ssl.py
+++ b/Lib/test/test_ssl.py
@@ -406,7 +406,7 @@ else:
threading.Thread.start(self)
def run (self):
- self.sock.settimeout(0.5)
+ self.sock.settimeout(0.05)
self.sock.listen(5)
self.active = True
if self.flag:
@@ -460,49 +460,6 @@ else:
certfile=self.certfile)
return sslconn, addr
- # The methods overridden below this are mainly so that we
- # can run it in a thread and be able to stop it from another
- # You probably wouldn't need them in other uses.
-
- def server_activate(self):
- # We want to run this in a thread for testing purposes,
- # so we override this to set timeout, so that we get
- # a chance to stop the server
- self.socket.settimeout(0.5)
- HTTPServer.server_activate(self)
-
- def serve_forever(self):
- # We want this to run in a thread, so we use a slightly
- # modified version of "forever".
- self.active = True
- while 1:
- try:
- # We need to lock while handling the request.
- # Another thread can close the socket after self.active
- # has been checked and before the request is handled.
- # This causes an exception when using the closed socket.
- with self.active_lock:
- if not self.active:
- break
- self.handle_request()
- except socket.timeout:
- pass
- except KeyboardInterrupt:
- self.server_close()
- return
- except:
- sys.stdout.write(''.join(traceback.format_exception(*sys.exc_info())))
- break
- time.sleep(0.1)
-
- def server_close(self):
- # Again, we want this to run in a thread, so we need to override
- # close to clear the "active" flag, so that serve_forever() will
- # terminate.
- with self.active_lock:
- HTTPServer.server_close(self)
- self.active = False
-
class RootedHTTPRequestHandler(SimpleHTTPRequestHandler):
# need to override translate_path to get a known root,
@@ -568,12 +525,12 @@ else:
self.active = True
if self.flag:
self.flag.set()
- self.server.serve_forever()
+ self.server.serve_forever(0.05)
self.active = False
def stop (self):
self.active = False
- self.server.server_close()
+ self.server.shutdown()
class AsyncoreEchoServer(threading.Thread):