Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(21)

Unified Diff: third_party/twisted_8_1/twisted/test/stdio_test_producer.py

Issue 12261012: Remove third_party/twisted_8_1 (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/tools/build
Patch Set: Created 7 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: third_party/twisted_8_1/twisted/test/stdio_test_producer.py
diff --git a/third_party/twisted_8_1/twisted/test/stdio_test_producer.py b/third_party/twisted_8_1/twisted/test/stdio_test_producer.py
deleted file mode 100644
index 00db9f79b14f72fcb8970b1525a175a511956c5b..0000000000000000000000000000000000000000
--- a/third_party/twisted_8_1/twisted/test/stdio_test_producer.py
+++ /dev/null
@@ -1,55 +0,0 @@
-# -*- test-case-name: twisted.test.test_stdio.StandardInputOutputTestCase.test_producer -*-
-# Copyright (c) 2006-2007 Twisted Matrix Laboratories.
-# See LICENSE for details.
-
-"""
-Main program for the child process run by
-L{twisted.test.test_stdio.StandardInputOutputTestCase.test_producer} to test
-that process transports implement IProducer properly.
-"""
-
-import sys
-
-from twisted.internet import stdio, protocol
-from twisted.python import log, reflect
-
-class ProducerChild(protocol.Protocol):
- _paused = False
- buf = ''
-
- def connectionLost(self, reason):
- log.msg("*****OVER*****")
- reactor.callLater(1, reactor.stop)
- # reactor.stop()
-
-
- def dataReceived(self, bytes):
- self.buf += bytes
- if self._paused:
- log.startLogging(sys.stderr)
- log.msg("dataReceived while transport paused!")
- self.transport.loseConnection()
- else:
- self.transport.write(bytes)
- if self.buf.endswith('\n0\n'):
- self.transport.loseConnection()
- else:
- self.pause()
-
-
- def pause(self):
- self._paused = True
- self.transport.pauseProducing()
- reactor.callLater(0.01, self.unpause)
-
-
- def unpause(self):
- self._paused = False
- self.transport.resumeProducing()
-
-
-if __name__ == '__main__':
- reflect.namedAny(sys.argv[1]).install()
- from twisted.internet import reactor
- stdio.StandardIO(ProducerChild())
- reactor.run()
« no previous file with comments | « third_party/twisted_8_1/twisted/test/stdio_test_loseconn.py ('k') | third_party/twisted_8_1/twisted/test/stdio_test_write.py » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698