diff options
author | Antoine Pitrou <solipsis@pitrou.net> | 2010-04-27 09:56:02 (GMT) |
---|---|---|
committer | Antoine Pitrou <solipsis@pitrou.net> | 2010-04-27 09:56:02 (GMT) |
commit | af7c6026c7dffed19e1b473b770528575fbed68b (patch) | |
tree | 483d75b9397de95fefc43f6208325dacd4f87210 | |
parent | 773b5db01aa9f53bfa6558d756ea5004eee78ae6 (diff) | |
download | cpython-af7c6026c7dffed19e1b473b770528575fbed68b.zip cpython-af7c6026c7dffed19e1b473b770528575fbed68b.tar.gz cpython-af7c6026c7dffed19e1b473b770528575fbed68b.tar.bz2 |
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
........
-rw-r--r-- | Lib/test/test_ssl.py | 49 |
1 files changed, 3 insertions, 46 deletions
diff --git a/Lib/test/test_ssl.py b/Lib/test/test_ssl.py index 113b308..921205d 100644 --- a/Lib/test/test_ssl.py +++ b/Lib/test/test_ssl.py @@ -442,7 +442,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: @@ -496,49 +496,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, @@ -604,12 +561,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): |