| Index: third_party/twisted_8_1/twisted/protocols/portforward.py
|
| diff --git a/third_party/twisted_8_1/twisted/protocols/portforward.py b/third_party/twisted_8_1/twisted/protocols/portforward.py
|
| deleted file mode 100644
|
| index 62f2aa372bb76f07d1ab7d90339c9136ef7bed51..0000000000000000000000000000000000000000
|
| --- a/third_party/twisted_8_1/twisted/protocols/portforward.py
|
| +++ /dev/null
|
| @@ -1,76 +0,0 @@
|
| -
|
| -# Copyright (c) 2001-2004 Twisted Matrix Laboratories.
|
| -# See LICENSE for details.
|
| -
|
| -"""
|
| -A simple port forwarder.
|
| -"""
|
| -
|
| -# Twisted imports
|
| -from twisted.internet import protocol
|
| -from twisted.python import log
|
| -
|
| -class Proxy(protocol.Protocol):
|
| - noisy = True
|
| -
|
| - peer = None
|
| -
|
| - def setPeer(self, peer):
|
| - self.peer = peer
|
| -
|
| - def connectionLost(self, reason):
|
| - if self.peer is not None:
|
| - self.peer.transport.loseConnection()
|
| - self.peer = None
|
| - elif self.noisy:
|
| - log.msg("Unable to connect to peer: %s" % (reason,))
|
| -
|
| - def dataReceived(self, data):
|
| - self.peer.transport.write(data)
|
| -
|
| -class ProxyClient(Proxy):
|
| - def connectionMade(self):
|
| - self.peer.setPeer(self)
|
| - # We're connected, everybody can read to their hearts content.
|
| - self.peer.transport.resumeProducing()
|
| -
|
| -class ProxyClientFactory(protocol.ClientFactory):
|
| -
|
| - protocol = ProxyClient
|
| -
|
| - def setServer(self, server):
|
| - self.server = server
|
| -
|
| - def buildProtocol(self, *args, **kw):
|
| - prot = protocol.ClientFactory.buildProtocol(self, *args, **kw)
|
| - prot.setPeer(self.server)
|
| - return prot
|
| -
|
| - def clientConnectionFailed(self, connector, reason):
|
| - self.server.transport.loseConnection()
|
| -
|
| -
|
| -class ProxyServer(Proxy):
|
| -
|
| - clientProtocolFactory = ProxyClientFactory
|
| -
|
| - def connectionMade(self):
|
| - # Don't read anything from the connecting client until we have
|
| - # somewhere to send it to.
|
| - self.transport.pauseProducing()
|
| -
|
| - client = self.clientProtocolFactory()
|
| - client.setServer(self)
|
| -
|
| - from twisted.internet import reactor
|
| - reactor.connectTCP(self.factory.host, self.factory.port, client)
|
| -
|
| -
|
| -class ProxyFactory(protocol.Factory):
|
| - """Factory for port forwarder."""
|
| -
|
| - protocol = ProxyServer
|
| -
|
| - def __init__(self, host, port):
|
| - self.host = host
|
| - self.port = port
|
|
|