Ticket #5562: #5562_abstract_2.py.patch

twisted/internet/iocpreactor/abstract.py

@@ -152 +152 @@
     _writeDisconnecting = False
     _writeDisconnected = False
     writeBufferSize = 2**2**2**2
+    _doWriteCalling = False
 
 
     def loseWriteConnection(self):
@@ -182 +183 @@
             self._writeScheduled.cancel()
             self._writeScheduled = None
         self.writing = False
+        self._doWriteCalling = False
 
 
     def _resumeWriting(self):
         self._writeScheduled = None
-        self.doWrite()
+        if self.writing:
+            if self._doWriteCalling:
+                self.reactor.callLater(0, self._resumeWriting)
+            else:
+                self.doWrite()
 
 
     def _cbWrite(self, rc, bytes, evt):
+        self._doWriteCalling = False
         if self._handleWrite(rc, bytes, evt):
             self.doWrite()
 
@@ -235 +242 @@
 
 
     def doWrite(self):
+        self._doWriteCalling = True
         if len(self.dataBuffer) - self.offset < self.SEND_LIMIT:
             # If there is currently less than SEND_LIMIT bytes left to send
             # in the string, extend it with the array data.