(self)
| 247 | self.set_state("init") |
| 248 | |
| 249 | def state_proxy_handshake_done(self): |
| 250 | Socks4aConnection.state_proxy_handshake_done(self) |
| 251 | self.nodeid = randomBytes(8) |
| 252 | self.append_write_buf(protocol.assembleVersionMessage(self.destination.host, self.destination.port, \ |
| 253 | network.connectionpool.BMConnectionPool().streams, False, nodeid=self.nodeid)) |
| 254 | self.set_state("bm_header", expectBytes=protocol.Header.size) |
| 255 | return True |
| 256 | |
| 257 | |
| 258 | class TCPServer(AdvancedDispatcher): |
nothing calls this directly
no test coverage detected