Method start

benchmarks/dirty_benchmark.py:217–256

Start the dirty arbiter and workers.

(self)

        self._tmpdir = None

    def start(self):
        """Start the dirty arbiter and workers."""
        # Create temp directory for socket
        self._tmpdir = tempfile.mkdtemp(prefix="dirty-bench-")
        self.socket_path = os.path.join(self._tmpdir, "arbiter.sock")

        # Create config and logger
        cfg = MockConfig(
            dirty_apps=[BENCHMARK_APP],
            dirty_workers=self.dirty_workers,
            dirty_threads=self.dirty_threads,
            dirty_timeout=self.dirty_timeout,
        )
        log = MockLogger(verbose=self.verbose)

        # Fork arbiter process
        pid = os.fork()
        if pid == 0:
            # Child process - run arbiter
            try:
                arbiter = DirtyArbiter(cfg, log, socket_path=self.socket_path)
                arbiter.run()
            except Exception as e:
                print(f"Arbiter error: {e}")
            finally:
                os._exit(0)

        # Parent process
        self.arbiter_pid = pid

        # Wait for arbiter socket to be ready
        for _ in range(50):  # 5 seconds max
            if os.path.exists(self.socket_path):
                break
            time.sleep(0.1)
        else:
            raise RuntimeError("Arbiter socket not ready")

        # Give workers time to start
        time.sleep(0.5)

    def stop(self):
        """Stop the dirty arbiter."""