(self)
| 171 | log_runtime.debug("Pipe engine thread stopped.") |
| 172 | |
| 173 | def start(self): |
| 174 | # type: () -> None |
| 175 | if self.thread_lock.acquire(False): |
| 176 | _t = Thread(target=self.run, name="scapy.pipetool.PipeEngine") |
| 177 | _t.daemon = True |
| 178 | _t.start() |
| 179 | self.thread = _t |
| 180 | else: |
| 181 | log_runtime.debug("Pipe engine already running") |
| 182 | |
| 183 | def wait_and_stop(self): |
| 184 | # type: () -> None |