(self)
| 4062 | self._enabled.clear() |
| 4063 | |
| 4064 | def run(self): |
| 4065 | # type: () -> None |
| 4066 | while not self._stopped.is_set() and not self._socket.closed: |
| 4067 | for p in self._pkts: |
| 4068 | try: |
| 4069 | if self._enabled.is_set(): |
| 4070 | self._socket.send(p) |
| 4071 | except (OSError, TimeoutError) as e: |
| 4072 | if self._ignore_exceptions: |
| 4073 | return |
| 4074 | else: |
| 4075 | raise e |
| 4076 | self._stopped.wait(timeout=self._interval) |
| 4077 | if self._stopped.is_set() or self._socket.closed: |
| 4078 | break |
| 4079 | |
| 4080 | def stop(self): |
| 4081 | # type: () -> None |