Method stop

benchmarks/dirty_benchmark.py:258–276

Stop the dirty arbiter.

(self)

        time.sleep(0.5)

    def stop(self):
        """Stop the dirty arbiter."""
        if self.arbiter_pid:
            try:
                os.kill(self.arbiter_pid, signal.SIGTERM)
                os.waitpid(self.arbiter_pid, 0)
            except (OSError, ChildProcessError):
                pass
            self.arbiter_pid = None

        # Cleanup temp directory
        if self._tmpdir:
            try:
                for f in os.listdir(self._tmpdir):
                    os.unlink(os.path.join(self._tmpdir, f))
                os.rmdir(self._tmpdir)
            except OSError:
                pass
            self._tmpdir = None

    def warmup(self, requests: int = 10):
        """Warm up the pool with a few requests."""