(self)
| 129 | return len(self.read_buf) < AdvancedDispatcher._buf_len |
| 130 | |
| 131 | def handle_read(self): |
| 132 | try: |
| 133 | (recdata, addr) = self.socket.recvfrom(AdvancedDispatcher._buf_len) |
| 134 | except socket.error as e: |
| 135 | logger.error("socket error: %s", str(e)) |
| 136 | return |
| 137 | |
| 138 | self.destination = state.Peer(addr[0], addr[1]) |
| 139 | encodedAddr = protocol.encodeHost(addr[0]) |
| 140 | if protocol.checkIPAddress(encodedAddr, True): |
| 141 | self.local = True |
| 142 | else: |
| 143 | self.local = False |
| 144 | # overwrite the old buffer to avoid mixing data and so that self.local works correctly |
| 145 | self.read_buf[0:] = recdata |
| 146 | self.bm_proto_reset() |
| 147 | receiveDataQueue.put(self.listening) |
| 148 | |
| 149 | def handle_write(self): |
| 150 | try: |
nothing calls this directly
no test coverage detected