(self, addr)
| 157 | self._selector.register(sock, selectors.EVENT_READ) |
| 158 | |
| 159 | def removeSourceAddr(self, addr): |
| 160 | try: |
| 161 | self._multiInSocket.setsockopt(self._get_ip_proto(), self._get_ip_leave(), self._makeMreq(addr)) |
| 162 | except socket.error as e: |
| 163 | logger.debug(f"Interface has more than 1 address: {e}") |
| 164 | |
| 165 | sock = self._multiOutUniInSockets[addr] |
| 166 | self._selector.unregister(sock) |
| 167 | sock.close() |
| 168 | del self._multiOutUniInSockets[addr] |
| 169 | |
| 170 | def addUnicastMessage(self, env, addr, port, initialDelay=0, |
| 171 | unicast_num=UNICAST_UDP_REPEAT): |
no test coverage detected