| Index: third_party/twisted_8_1/twisted/test/test_stateful.py
|
| diff --git a/third_party/twisted_8_1/twisted/test/test_stateful.py b/third_party/twisted_8_1/twisted/test/test_stateful.py
|
| deleted file mode 100644
|
| index 19b7ab00ecd1bdb50a1f903d1013149a9be1cd51..0000000000000000000000000000000000000000
|
| --- a/third_party/twisted_8_1/twisted/test/test_stateful.py
|
| +++ /dev/null
|
| @@ -1,74 +0,0 @@
|
| -# Copyright (c) 2001-2007 Twisted Matrix Laboratories.
|
| -# See LICENSE for details.
|
| -
|
| -
|
| -"""
|
| -Test cases for twisted.protocols.stateful
|
| -"""
|
| -
|
| -from twisted.test import test_protocols
|
| -from twisted.protocols.stateful import StatefulProtocol
|
| -
|
| -from struct import pack, unpack, calcsize
|
| -
|
| -
|
| -class MyInt32StringReceiver(StatefulProtocol):
|
| - """
|
| - A stateful Int32StringReceiver.
|
| - """
|
| - MAX_LENGTH = 99999
|
| - structFormat = "!I"
|
| - prefixLength = calcsize(structFormat)
|
| -
|
| - def getInitialState(self):
|
| - return self._getHeader, 4
|
| -
|
| - def _getHeader(self, msg):
|
| - length, = unpack("!i", msg)
|
| - if length > self.MAX_LENGTH:
|
| - self.transport.loseConnection()
|
| - return
|
| - return self._getString, length
|
| -
|
| - def _getString(self, msg):
|
| - self.stringReceived(msg)
|
| - return self._getHeader, 4
|
| -
|
| - def stringReceived(self, msg):
|
| - """
|
| - Override this.
|
| - """
|
| - raise NotImplementedError
|
| -
|
| - def sendString(self, data):
|
| - """
|
| - Send an int32-prefixed string to the other end of the connection.
|
| - """
|
| - self.transport.write(pack(self.structFormat, len(data)) + data)
|
| -
|
| -
|
| -class TestInt32(MyInt32StringReceiver):
|
| - def connectionMade(self):
|
| - self.received = []
|
| -
|
| - def stringReceived(self, s):
|
| - self.received.append(s)
|
| -
|
| - MAX_LENGTH = 50
|
| - closed = 0
|
| -
|
| - def connectionLost(self, reason):
|
| - self.closed = 1
|
| -
|
| -
|
| -class Int32TestCase(test_protocols.Int32TestCase):
|
| - protocol = TestInt32
|
| -
|
| - def test_bigReceive(self):
|
| - r = self.getProtocol()
|
| - big = ""
|
| - for s in self.strings * 4:
|
| - big += pack("!i", len(s)) + s
|
| - r.dataReceived(big)
|
| - self.assertEquals(r.received, self.strings * 4)
|
| -
|
|
|