Commit 7de4d645 authored by Guido van Rossum's avatar Guido van Rossum

IMPORTANT FIX: This should definitely go into the 2.1.1 release!!!

Fix various serious problems:

- The ThreadingTCPServer class and its derived classes were completely
  broken because the main thread would close the request before the
  handler thread had time to look at it.  This was introduced by
  Ping's close_request() patch.  The fix moves the close_request()
  calls to after the handler has run to completion in the BaseServer
  class and the ForkingMixIn class; when using the ThreadingMixIn,
  closing the request is the handler's responsibility.

- The ForkingUDPServer class has always been been broken because the
  socket was closed in the child before calling the handler.  I fixed
  this by simply not calling server_close() in the child at all.

- I cannot get the UnixDatagramServer class to work at all.  The
  recvfrom() call doesn't return a meaningful client address.  I added
  a comment to this effect.  Maybe it works on other Unix versions.

- The __all__ variable was missing ThreadingMixIn and ForkingMixIn.

- Bumped __version__ to "0.4".

- Added a note about the test suite (to be checked in shortly).
parent 06e415fe
...@@ -120,7 +120,12 @@ BaseServer: ...@@ -120,7 +120,12 @@ BaseServer:
# Author of the BaseServer patch: Luke Kenneth Casson Leighton # Author of the BaseServer patch: Luke Kenneth Casson Leighton
__version__ = "0.3" # XXX Warning!
# There is a test suite for this module, but it cannot be run by the
# standard regression test.
# To run it manually, run Lib/test/test_socketserver.py.
__version__ = "0.4"
import socket import socket
...@@ -129,7 +134,8 @@ import os ...@@ -129,7 +134,8 @@ import os
__all__ = ["TCPServer","UDPServer","ForkingUDPServer","ForkingTCPServer", __all__ = ["TCPServer","UDPServer","ForkingUDPServer","ForkingTCPServer",
"ThreadingUDPServer","ThreadingTCPServer","BaseRequestHandler", "ThreadingUDPServer","ThreadingTCPServer","BaseRequestHandler",
"StreamRequestHandler","DatagramRequestHandler"] "StreamRequestHandler","DatagramRequestHandler",
"ThreadingMixIn", "ForkingMixIn"]
if hasattr(socket, "AF_UNIX"): if hasattr(socket, "AF_UNIX"):
__all__.extend(["UnixStreamServer","UnixDatagramServer", __all__.extend(["UnixStreamServer","UnixDatagramServer",
"ThreadingUnixStreamServer", "ThreadingUnixStreamServer",
...@@ -215,7 +221,7 @@ class BaseServer: ...@@ -215,7 +221,7 @@ class BaseServer:
self.process_request(request, client_address) self.process_request(request, client_address)
except: except:
self.handle_error(request, client_address) self.handle_error(request, client_address)
self.close_request(request) self.close_request(request)
def verify_request(self, request, client_address): def verify_request(self, request, client_address):
"""Verify the request. May be overridden. """Verify the request. May be overridden.
...@@ -232,6 +238,7 @@ class BaseServer: ...@@ -232,6 +238,7 @@ class BaseServer:
""" """
self.finish_request(request, client_address) self.finish_request(request, client_address)
self.close_request(request)
def server_close(self): def server_close(self):
"""Called to clean-up the server. """Called to clean-up the server.
...@@ -423,18 +430,17 @@ class ForkingMixIn: ...@@ -423,18 +430,17 @@ class ForkingMixIn:
if self.active_children is None: if self.active_children is None:
self.active_children = [] self.active_children = []
self.active_children.append(pid) self.active_children.append(pid)
self.close_request(request)
return return
else: else:
# Child process. # Child process.
# This must never return, hence os._exit()! # This must never return, hence os._exit()!
try: try:
self.server_close()
self.finish_request(request, client_address) self.finish_request(request, client_address)
os._exit(0) os._exit(0)
except: except:
try: try:
self.handle_error(request, self.handle_error(request, client_address)
client_address)
finally: finally:
os._exit(1) os._exit(1)
...@@ -545,6 +551,9 @@ class StreamRequestHandler(BaseRequestHandler): ...@@ -545,6 +551,9 @@ class StreamRequestHandler(BaseRequestHandler):
class DatagramRequestHandler(BaseRequestHandler): class DatagramRequestHandler(BaseRequestHandler):
# XXX Regrettably, I cannot get this working on Linux;
# s.recvfrom() doesn't return a meaningful client address.
"""Define self.rfile and self.wfile for datagram sockets.""" """Define self.rfile and self.wfile for datagram sockets."""
def setup(self): def setup(self):
......
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