(self, direction, latency, kbps)
| 70 | PIPE_OUT = 1 |
| 71 | |
| 72 | def __init__(self, direction, latency, kbps): |
| 73 | self.direction = direction |
| 74 | self.latency = latency |
| 75 | self.kbps = kbps |
| 76 | self.queue = Queue() |
| 77 | self.last_tick = current_time() |
| 78 | self.next_message = None |
| 79 | self.available_bytes = .0 |
| 80 | self.peer = 'server' |
| 81 | if self.direction == self.PIPE_IN: |
| 82 | self.peer = 'client' |
| 83 | |
| 84 | def SendMessage(self, message, main_thread = True): |
| 85 | global connections, in_pipe, out_pipe |