(self, message)
| 106 | pass |
| 107 | |
| 108 | def SendPeerMessage(self, message): |
| 109 | global last_activity, last_client_disconnected |
| 110 | last_activity = current_time() |
| 111 | message_sent = False |
| 112 | connection_id = message['connection'] |
| 113 | if connection_id in connections: |
| 114 | if self.peer in connections[connection_id]: |
| 115 | try: |
| 116 | connections[connection_id][self.peer].handle_message(message) |
| 117 | message_sent = True |
| 118 | except: |
| 119 | # Clean up any disconnected connections |
| 120 | try: |
| 121 | connections[connection_id]['server'].close() |
| 122 | except: |
| 123 | pass |
| 124 | try: |
| 125 | connections[connection_id]['client'].close() |
| 126 | except: |
| 127 | pass |
| 128 | del connections[connection_id] |
| 129 | if not connections: |
| 130 | last_client_disconnected = current_time() |
| 131 | logging.info('[{0:d}] Last connection closed'.format(self.client_id)) |
| 132 | return message_sent |
| 133 | |
| 134 | def tick(self): |
| 135 | global connections |
no test coverage detected