]> granicus.if.org Git - python/commitdiff
Issue #12151: Added diagnostics to help diagnose intermittent socket errors.
authorVinay Sajip <vinay_sajip@yahoo.co.uk>
Mon, 23 May 2011 20:37:54 +0000 (21:37 +0100)
committerVinay Sajip <vinay_sajip@yahoo.co.uk>
Mon, 23 May 2011 20:37:54 +0000 (21:37 +0100)
Lib/test/test_logging.py

index 3118065a76c602f4e776c5214f44d6237384d065..6c66ff109ccc25f4b33bc295d4d23c7064229a82 100644 (file)
@@ -893,14 +893,29 @@ if threading:
 
                 def handle(self):
                     self.server._handler(self)
+
+                def finish(self):
+                    data = self.wfile.getvalue()
+                    try:
+                        super(DelegatingUDPRequestHandler, self).finish()
+                    except socket.error:
+                        msg = ('Error during finish, while sending %r, '
+                               'closed = %s')
+                        print(msg % (data, self._closed), file=sys.stderr)
+                        raise
+
             ThreadingUDPServer.__init__(self, addr, DelegatingUDPRequestHandler,
                                         bind_and_activate)
             ControlMixin.__init__(self, handler, poll_interval)
+            self._closed = False
 
         def server_bind(self):
             super(TestUDPServer, self).server_bind()
             self.port = self.socket.getsockname()[1]
 
+        def server_close(self):
+            super(TestUDPServer, self).server_close()
+            self._closed = True
 
 # - end of server_helper section