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 |