()
| 1301 | sniff_sockets[close_pipe] = "control_socket" # type: ignore |
| 1302 | |
| 1303 | def stop_cb(): |
| 1304 | # type: () -> None |
| 1305 | if self.running and close_pipe: |
| 1306 | close_pipe.send(None) |
| 1307 | self.continue_sniff = False |
| 1308 | self.stop_cb = stop_cb |
| 1309 | else: |
| 1310 | # select is non blocking |