(self, ioService, clientToProxySocket,
remoteAddress, remotePort)
| 27 | class Connection(object): |
| 28 | |
| 29 | def __init__(self, ioService, clientToProxySocket, |
| 30 | remoteAddress, remotePort): |
| 31 | self.__dataFromClient = '' |
| 32 | self.__dataFromRemote = '' |
| 33 | self.__writingToClient = False |
| 34 | self.__writingToRemote = False |
| 35 | self.__clientToProxySocket = clientToProxySocket |
| 36 | self.__clientToProxyString = ('%s -> %s' % |
| 37 | (clientToProxySocket.getpeername(), |
| 38 | clientToProxySocket.getsockname())) |
| 39 | self.__proxyToRemoteSocket = ioService.createAsyncSocket() |
| 40 | self.__proxyToRemoteString = '' |
| 41 | self.__proxyToRemoteSocket.asyncConnect( |
| 42 | (remoteAddress, remotePort), |
| 43 | self.__connectCallback) |
| 44 | |
| 45 | def close(self): |
| 46 | if not self.__writingToClient: |
nothing calls this directly
no test coverage detected