Method setup_engine

tensorrt_llm/executor/rpc_worker.py:93–99

(self)

        # manages threads internally.

    def setup_engine(self):
        # Force all the ranks to wait here, and start creating the executor simultaneously.
        # Only call barrier if we have multiple ranks to avoid hanging in single-process tests
        if mpi_comm().Get_size() > 1:
            mpi_comm().barrier()

        super().setup_engine()

    def shutdown(self):
        logger_debug(f"[worker] RpcWorker #{mpi_rank()} is shutting down",