(self, message, main_thread = True)
| 82 | self.peer = 'client' |
| 83 | |
| 84 | def SendMessage(self, message, main_thread = True): |
| 85 | global connections, in_pipe, out_pipe |
| 86 | message_sent = False |
| 87 | now = current_time() |
| 88 | if message['message'] == 'closed': |
| 89 | message['time'] = now |
| 90 | else: |
| 91 | message['time'] = current_time() + self.latency |
| 92 | message['size'] = .0 |
| 93 | if 'data' in message: |
| 94 | message['size'] = float(len(message['data'])) |
| 95 | try: |
| 96 | connection_id = message['connection'] |
| 97 | # Send messages directly, bypassing the queues is throttling is disabled and we are on the main thread |
| 98 | if main_thread and connection_id in connections and self.peer in connections[connection_id]and self.latency == 0 and self.kbps == .0: |
| 99 | message_sent = self.SendPeerMessage(message) |
| 100 | except: |
| 101 | pass |
| 102 | if not message_sent: |
| 103 | try: |
| 104 | self.queue.put(message) |
| 105 | except: |
| 106 | pass |
| 107 | |
| 108 | def SendPeerMessage(self, message): |
| 109 | global last_activity, last_client_disconnected |
no test coverage detected