(self,n=None)
| 65 | self.port.close() |
| 66 | |
| 67 | def recv(self,n=None): |
| 68 | try: |
| 69 | try: |
| 70 | data, new_addr = self.port.recvfrom(65535) |
| 71 | except socket.error as e: |
| 72 | if e.errno in [ errno.EAGAIN, errno.EWOULDBLOCK, errno.ECONNREFUSED ]: |
| 73 | return "" |
| 74 | if self.udp_server: |
| 75 | self.addresses.add(new_addr) |
| 76 | elif self.broadcast: |
| 77 | self.addresses = set([new_addr]) |
| 78 | return data |
| 79 | except Exception as e: |
| 80 | print(e) |
| 81 | |
| 82 | def write(self, buf): |
| 83 | try: |