Index _ | A | B | C | E | F | G | H | I | L | M | N | O | P | R | S | T | V | W _ __init__() (rlinf.data.embodied_io_struct.ChunkStepResult method) (rlinf.data.embodied_io_struct.EmbodiedRolloutResult method) (rlinf.data.embodied_io_struct.EnvOutput method) (rlinf.data.embodied_io_struct.Trajectory method) (rlinf.data.io_struct.RolloutRequest method) (rlinf.data.io_struct.RolloutResult method) (rlinf.envs.libero.libero_env.LiberoEnv method) (rlinf.hybrid_engines.fsdp.fsdp_model_manager.FSDPModelManager method) (rlinf.hybrid_engines.megatron.megatron_model_manager.MegatronModelManager method) (rlinf.scheduler.cluster.Cluster method) (rlinf.scheduler.placement.flexible.FlexiblePlacementStrategy method) (rlinf.scheduler.placement.node.NodePlacementStrategy method) (rlinf.scheduler.placement.packed.PackedPlacementStrategy method) (rlinf.scheduler.Worker method) (rlinf.scheduler.worker.WorkerGroup method) (rlinf.scheduler.worker.WorkerGroup.WorkerRank method) (rlinf.utils.placement.ComponentPlacement method) (rlinf.utils.placement.HybridComponentPlacement method) (rlinf.utils.placement.ModelParallelComponentPlacement method) (rlinf.workers.actor.fsdp_actor_worker.EmbodiedFSDPActor method) (rlinf.workers.actor.megatron_actor_worker.MegatronActor method) (rlinf.workers.env.env_worker.EnvWorker method) (rlinf.workers.rollout.hf.huggingface_worker.MultiStepRolloutWorker method) (rlinf.workers.rollout.sglang.sglang_worker.SGLangWorker method) A abort_generation() (rlinf.workers.rollout.sglang.sglang_worker.SGLangWorker method) accelerator_ranks (rlinf.scheduler.cluster.Cluster property) accelerator_type (rlinf.scheduler.placement.placement.Placement attribute) async_generate() (rlinf.workers.rollout.sglang.sglang_worker.SGLangWorker method) B before_micro_batch() (rlinf.hybrid_engines.fsdp.fsdp_model_manager.FSDPModelManager method) broadcast() (rlinf.scheduler.Worker method) build_grad_scaler() (rlinf.hybrid_engines.fsdp.fsdp_model_manager.FSDPModelManager method) build_lr_scheduler() (rlinf.hybrid_engines.fsdp.fsdp_model_manager.FSDPModelManager method) build_optimizer() (rlinf.hybrid_engines.fsdp.fsdp_model_manager.FSDPModelManager method) C ChunkStepResult (class in rlinf.data.embodied_io_struct) Cluster (class in rlinf.scheduler.cluster) Cluster.NamespaceConflictError cluster_node_rank (rlinf.scheduler.placement.placement.Placement attribute) ComponentPlacement (class in rlinf.utils.placement) components (rlinf.utils.placement.ComponentPlacement property) compute_advantages_and_returns() (rlinf.workers.actor.fsdp_actor_worker.EmbodiedFSDPActor method) connect_channel() (rlinf.scheduler.Worker method) create_channel() (rlinf.scheduler.Worker method) create_group() (rlinf.scheduler.Worker class method) custom_forward() (rlinf.hybrid_engines.megatron.megatron_model_manager.MegatronModelManager static method) E EmbodiedFSDPActor (class in rlinf.workers.actor.fsdp_actor_worker) EmbodiedRolloutResult (class in rlinf.data.embodied_io_struct) env_evaluate_step() (rlinf.workers.env.env_worker.EnvWorker method) env_interact_step() (rlinf.workers.env.env_worker.EnvWorker method) EnvOutput (class in rlinf.data.embodied_io_struct) EnvWorker (class in rlinf.workers.env.env_worker) execute_on() (rlinf.scheduler.worker.WorkerGroup method) F find_free_port() (rlinf.scheduler.cluster.Cluster class method) FlexiblePlacementStrategy (class in rlinf.scheduler.placement.flexible) from_group_name() (rlinf.scheduler.worker.WorkerGroup class method) from_sglang_results() (rlinf.data.io_struct.RolloutResult static method) from_vllm_results() (rlinf.data.io_struct.RolloutResult static method) FSDPModelManager (class in rlinf.hybrid_engines.fsdp.fsdp_model_manager) G get_alive_nodes() (rlinf.scheduler.cluster.Cluster static method) get_dones_and_rewards() (rlinf.workers.rollout.hf.huggingface_worker.MultiStepRolloutWorker method) get_forward_step_func() (rlinf.workers.actor.megatron_actor_worker.MegatronActor method) get_full_env_var_name() (rlinf.scheduler.cluster.Cluster static method) get_hardware_ranks() (rlinf.utils.placement.ComponentPlacement method) get_model_state_dict() (rlinf.hybrid_engines.fsdp.fsdp_model_manager.FSDPModelManager method) get_node_group() (rlinf.scheduler.cluster.Cluster method) get_node_info() (rlinf.scheduler.cluster.Cluster method) get_node_ip() (rlinf.scheduler.cluster.Cluster method) get_placement() (rlinf.scheduler.placement.flexible.FlexiblePlacementStrategy method) (rlinf.scheduler.placement.node.NodePlacementStrategy method) (rlinf.scheduler.placement.packed.PackedPlacementStrategy method) get_sampling_param_from_config() (rlinf.workers.rollout.sglang.sglang_worker.SGLangWorker method) get_strategy() (rlinf.utils.placement.ComponentPlacement method) get_sys_env_var() (rlinf.scheduler.cluster.Cluster static method) get_world_size() (rlinf.utils.placement.ComponentPlacement method) H has_initialized() (rlinf.scheduler.cluster.Cluster class method) HybridComponentPlacement (class in rlinf.utils.placement) I init_worker() (rlinf.workers.actor.fsdp_actor_worker.EmbodiedFSDPActor method) isolate_accelerator (rlinf.scheduler.placement.placement.Placement attribute) L launch() (rlinf.scheduler.worker.WorkerGroup method) LiberoEnv (class in rlinf.envs.libero.libero_env) load_checkpoint() (rlinf.hybrid_engines.fsdp.fsdp_model_manager.FSDPModelManager method) load_megatron_copy_params() (rlinf.hybrid_engines.megatron.megatron_model_manager.MegatronModelManager method) load_optimizer() (rlinf.hybrid_engines.fsdp.fsdp_model_manager.FSDPModelManager method) load_param_and_grad() (rlinf.hybrid_engines.fsdp.fsdp_model_manager.FSDPModelManager method) local_accelerator_rank (rlinf.scheduler.placement.placement.Placement attribute) local_hardware_ranks (rlinf.scheduler.placement.placement.Placement attribute) local_rank (rlinf.scheduler.placement.placement.Placement attribute) local_world_size (rlinf.scheduler.placement.placement.Placement attribute) M make_data_iterator_list() (rlinf.hybrid_engines.megatron.megatron_model_manager.MegatronModelManager method) MegatronActor (class in rlinf.workers.actor.megatron_actor_worker) MegatronModelManager (class in rlinf.hybrid_engines.megatron.megatron_model_manager) merge_batches() (rlinf.data.io_struct.RolloutResult static method) merge_env_outputs() (rlinf.data.embodied_io_struct.EnvOutput static method) model_provider_func() (rlinf.hybrid_engines.fsdp.fsdp_model_manager.FSDPModelManager method) (rlinf.hybrid_engines.megatron.megatron_model_manager.MegatronModelManager method) (rlinf.workers.actor.fsdp_actor_worker.EmbodiedFSDPActor method) ModelParallelComponentPlacement (class in rlinf.utils.placement) MultiStepRolloutWorker (class in rlinf.workers.rollout.hf.huggingface_worker) N node_group_label (rlinf.scheduler.placement.placement.Placement attribute) NodePlacementStrategy (class in rlinf.scheduler.placement.node) num_accelerators (rlinf.scheduler.cluster.Cluster property) num_nodes (rlinf.scheduler.cluster.Cluster property) O offload_engine() (rlinf.workers.rollout.sglang.sglang_worker.SGLangWorker method) offload_megatron_copy_params() (rlinf.hybrid_engines.megatron.megatron_model_manager.MegatronModelManager method) offload_optimizer() (rlinf.hybrid_engines.fsdp.fsdp_model_manager.FSDPModelManager method) offload_param_and_grad() (rlinf.hybrid_engines.fsdp.fsdp_model_manager.FSDPModelManager method) onload_engine() (rlinf.workers.rollout.sglang.sglang_worker.SGLangWorker method) optimizer_step() (rlinf.hybrid_engines.fsdp.fsdp_model_manager.FSDPModelManager method) P PackedPlacementStrategy (class in rlinf.scheduler.placement.packed) Placement (class in rlinf.scheduler.placement.placement) placement_mode (rlinf.utils.placement.ComponentPlacement property) placement_node_rank (rlinf.scheduler.placement.placement.Placement attribute) R rank (rlinf.scheduler.placement.placement.Placement attribute) recv() (rlinf.scheduler.Worker method) recv_chunk_actions() (rlinf.workers.env.env_worker.EnvWorker method) recv_env_output() (rlinf.workers.rollout.hf.huggingface_worker.MultiStepRolloutWorker method) recv_rollout_trajectories() (rlinf.workers.actor.fsdp_actor_worker.EmbodiedFSDPActor method) recv_tensor() (rlinf.scheduler.Worker method) reset() (rlinf.envs.libero.libero_env.LiberoEnv method) RolloutRequest (class in rlinf.data.io_struct) RolloutResult (class in rlinf.data.io_struct) run_training() (rlinf.workers.actor.fsdp_actor_worker.EmbodiedFSDPActor method) S save_checkpoint() (rlinf.hybrid_engines.fsdp.fsdp_model_manager.FSDPModelManager method) send() (rlinf.scheduler.Worker method) send_chunk_actions() (rlinf.workers.rollout.hf.huggingface_worker.MultiStepRolloutWorker method) send_env_batch() (rlinf.workers.env.env_worker.EnvWorker method) send_tensor() (rlinf.scheduler.Worker method) set_global_step() (rlinf.workers.actor.fsdp_actor_worker.EmbodiedFSDPActor method) setup_model_and_optimizer() (rlinf.hybrid_engines.fsdp.fsdp_model_manager.FSDPModelManager method) (rlinf.hybrid_engines.megatron.megatron_model_manager.MegatronModelManager method) SGLangWorker (class in rlinf.workers.rollout.sglang.sglang_worker) shutdown() (rlinf.workers.rollout.sglang.sglang_worker.SGLangWorker method) split_env_batch() (rlinf.workers.env.env_worker.EnvWorker method) split_result_list_by_group() (rlinf.data.io_struct.RolloutResult static method) split_results() (rlinf.data.io_struct.RolloutResult static method) step() (rlinf.envs.libero.libero_env.LiberoEnv method) sync_model_from_actor() (rlinf.workers.rollout.hf.huggingface_worker.MultiStepRolloutWorker method) (rlinf.workers.rollout.sglang.sglang_worker.SGLangWorker method) sync_model_to_rollout() (rlinf.workers.actor.fsdp_actor_worker.EmbodiedFSDPActor method) (rlinf.workers.actor.megatron_actor_worker.MegatronActor method) T to_actor_batch() (rlinf.data.io_struct.RolloutResult method) to_seq_group_infos() (rlinf.data.io_struct.RolloutRequest method) Trajectory (class in rlinf.data.embodied_io_struct) V visible_accelerators (rlinf.scheduler.placement.placement.Placement attribute) W Worker (class in rlinf.scheduler) worker_address (rlinf.scheduler.Worker property) worker_cls_name (rlinf.scheduler.worker.WorkerGroup property) worker_group_name (rlinf.scheduler.worker.WorkerGroup property) worker_info_list (rlinf.scheduler.worker.WorkerGroup property) WorkerGroup (class in rlinf.scheduler.worker) WorkerGroup.WorkerRank (class in rlinf.scheduler.worker)