| 418 | STATE_CONNECTED = 4 |
| 419 | |
| 420 | def __init__(self, connected_socket, client_id): |
| 421 | global options |
| 422 | asyncore.dispatcher.__init__(self, connected_socket) |
| 423 | self.client_id = client_id |
| 424 | self.state = self.STATE_WAITING_FOR_HANDSHAKE |
| 425 | self.ip = None |
| 426 | self.addresses = None |
| 427 | self.hostname = None |
| 428 | self.port = None |
| 429 | self.requested_address = None |
| 430 | self.buffer = '' |
| 431 | self.socket.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) |
| 432 | self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF, 128 * 1024) |
| 433 | self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_SNDBUF, 128 * 1024) |
| 434 | self.needs_close = False |
| 435 | |
| 436 | def SendMessage(self, type, message): |
| 437 | message['message'] = type |