Skip to main content

MlpBurnPolicy

Struct MlpBurnPolicy 

Source
pub struct MlpBurnPolicy<B: Backend> { /* private fields */ }
Expand description

Two- or three-layer MLP actor-critic for discrete action spaces, ported to Burn.

Layout mirrors crate::policy::mlp::MlpBurnPolicy at a high level:

obs → fc1 →act→ fc2 →act→ (fc3 →act→)? policy_head (logits)
                                      └─ value_head  (V(s))

Both heads share the trunk activations — standard PPO actor-critic.

§Numerical parity

When constructed with use_orthogonal_init = true (the default), the trunk uses [Initializer::Orthogonal { gain: sqrt(2) }] and the output heads use gain = 0.01. These match the tch policy’s init gains exactly (see crate::policy::mlp::MlpBurnPolicy::with_config), which is the necessary precondition for the phase-4 numerical-parity check called out on issue #81.

Implementations§

Source§

impl<B: Backend> MlpBurnPolicy<B>

Source

pub fn new( obs_dim: usize, action_dim: usize, hidden_dim: usize, device: &B::Device, ) -> Self

Backward-compatible 2-layer constructor (the phase 1 scout signature). Uses Burn’s default Kaiming-uniform init — kept so the existing bandit trainer and parity tests are not perturbed.

New call sites that want PPO-style orthogonal init should call MlpBurnPolicy::with_config instead.

Source

pub fn new_seeded( obs_dim: usize, action_dim: usize, hidden_dim: usize, seed: u64, device: &B::Device, ) -> Self

Seeded variant of new: same 2-layer Kaiming architecture, but constructed deterministically from seed so two calls with the same seed produce bit-identical weights.

Convenience wrapper for callers (and the PSRO/NFSP policy factories) that want reproducible policies without assembling a full MlpBurnConfig. Equivalent to with_config(.., MlpBurnConfig { use_orthogonal_init: false, .., seed: Some(seed) }, ..).

Source

pub fn with_config( obs_dim: usize, action_dim: usize, config: MlpBurnConfig, device: &B::Device, ) -> Self

Build a fresh policy on device with the given configuration.

This is the production constructor for phase 4 onwards. Mirrors crate::policy::mlp::MlpBurnPolicy::with_config.

Source

pub fn forward(&self, obs: Tensor<B, 2>) -> (Tensor<B, 2>, Tensor<B, 1>)

Forward pass: returns (logits, value).

  • obs is shape [batch, obs_dim].
  • logits is shape [batch, action_dim] (pre-softmax).
  • value is shape [batch] (squeezed from [batch, 1]).
Source

pub fn encoder_features(&self, obs: Tensor<B, 2>) -> Tensor<B, 2>

Compute the shared-trunk feature representation for obs.

Mirrors crate::policy::mlp::MlpBurnPolicy::encoder_features — auxiliary regularizers (cross-agent redundancy penalties, behavioural-diversity bonuses) tap this directly.

Gradients flow back into the trunk.

Source

pub fn policy_head_action_dim(&self) -> usize

Action-head output dimensionality (number of discrete actions).

Reads the policy_head weight tensor’s shape — Burn’s burn::nn::Linear stores weight: Param<Tensor<B, 2>> with shape [d_input, d_output], so d_output is the action cardinality. Used by the multi-agent joint trainer’s crate::multi_agent::joint::JointPolicy::action_dims_joint impl to size the rollout action buffer without consuming RNG draws.

Source

pub fn fc1(&self) -> &Linear<B>

Borrow the first shared-trunk linear layer.

Source

pub fn fc2(&self) -> &Linear<B>

Borrow the second shared-trunk linear layer.

Source

pub fn policy_head(&self) -> &Linear<B>

Borrow the policy (action-logits) head.

Source

pub fn value_head(&self) -> &Linear<B>

Borrow the value (V(s)) head.

Source

pub fn get_action_host( &self, obs: Tensor<B, 2>, ) -> (Vec<i64>, Vec<f32>, Vec<f32>)

Sample one action per row from the policy’s categorical distribution and return (actions_host, log_probs_host, values_host) as plain Vecs.

Thin backwards-compat wrapper around MlpBurnPolicy::get_action_host_seeded that constructs a thread-local RNG. Not deterministic across calls — use get_action_host_seeded and pass a seeded rand::rngs::StdRng when reproducibility is required (PSRO/NFSP/joint trainer rollouts call the seeded form via the crate::multi_agent::joint::JointPolicy trait so that PsroConfig::seed / NfspConfig::seed produce bit-identical rollouts; see issue #114).

Retained for example-driver convenience where the caller does not need bit-exact reproducibility and would otherwise have to thread an &mut StdRng through bespoke rollout loops.

Source

pub fn get_action_host_seeded( &self, obs: Tensor<B, 2>, rng: &mut StdRng, ) -> (Vec<i64>, Vec<f32>, Vec<f32>)

Same contract as get_action_host but the host-side categorical draws consume rng instead of the thread-local generator.

The trainer-side rollout loop does not need gradient flow through the sampled action (only the eventual MlpBurnPolicy::evaluate_actions call on the stored transitions matters for the PPO surrogate). We therefore do the categorical draw on the host with rand, sidestepping Burn 0.21’s lack of a first-class multinomial op.

Bit-exactness contract: two calls with the same obs, same policy state, and same-seeded rng (StdRng::seed_from_u64) must produce element-wise identical (actions, log_probs, values). This is the load-bearing guarantee PsroConfig::seed / NfspConfig::seed rely on after issue #114.

Source

pub fn get_actions_host_seeded_batched( &self, obs: Tensor<B, 2>, rng: &mut StdRng, ) -> (Vec<i64>, Vec<f32>, Vec<f32>)

Batched seeded sampler: one forward over [N, obs_dim], then N host-side categorical draws in row-major order.

Bit-identical to calling Self::get_action_host_seeded once per row on [1, obs_dim] slices provided the rows are drawn from the same policy — the forward is a single matmul over all N rows (same weights), and the RNG is consumed one draw per row, ascending. This is the crate::multi_agent::joint::JointPolicy-trait batched entry point that eliminates per-call batch-1 overhead on the NdArray backend wherever many observations are scored through the same model in one step (issue #235).

Source

pub fn evaluate_actions( &self, obs: Tensor<B, 2>, actions: Tensor<B, 1, Int>, ) -> (Tensor<B, 1>, Tensor<B, 1>, Tensor<B, 1>)

Evaluate a batch of (obs, actions) pairs.

Returns (action_log_probs, entropy_per_row, values) — the quantities the PPO surrogate loss needs. Entropy is per-row here (not the mean): the caller decides how to aggregate. This matches the tch policy’s contract (the tch evaluate_actions returns a scalar mean; the trainer reduces per-row entropy on the Burn path inside crate::train::ppo::trainer::PPOTrainerBurn::train_step).

Trait Implementations§

Source§

impl<B> AutodiffModule<B> for MlpBurnPolicy<B>

Source§

type InnerModule = MlpBurnPolicy<<B as AutodiffBackend>::InnerBackend>

Inner module without auto-differentiation.
Source§

fn valid(&self) -> Self::InnerModule

Returns the same module, but on the inner backend without auto-differentiation.
Source§

fn from_inner(module: Self::InnerModule) -> Self

Wraps an inner module back into an auto-diff module.
Source§

impl<B: Backend> Clone for MlpBurnPolicy<B>

Source§

fn clone(&self) -> Self

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl<B: Debug + Backend> Debug for MlpBurnPolicy<B>

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl<B: Backend> Display for MlpBurnPolicy<B>

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl<B> HasAutodiffModule<B> for MlpBurnPolicy<B::InnerBackend>

Source§

type TrainModule = MlpBurnPolicy<B>

The module with auto-differentiation.
Source§

impl<B: AutodiffBackend> JointPolicy<B> for MlpBurnPolicy<B>
where Self: AutodiffModule<B> + Clone,

Source§

fn get_action_host_seeded( &self, obs: Tensor<B, 2>, rng: &mut StdRng, ) -> (Vec<i64>, Vec<f32>, Vec<f32>)

Sample actions for a single rollout step using a caller-supplied seeded RNG. Read more
Source§

fn get_actions_host_seeded_batched( &self, obs: Tensor<B, 2>, rng: &mut StdRng, ) -> (Vec<i64>, Vec<f32>, Vec<f32>)

Batched seeded sampler: obs carries N rows scored through this one policy in a single forward, returning N actions. Read more
Source§

fn evaluate_actions_joint( &self, obs: Tensor<B, 2>, actions: Tensor<B, 2, Int>, ) -> (Tensor<B, 1>, Tensor<B, 1>, Tensor<B, 1>)

Re-evaluate the policy on previously-sampled actions. Read more
Source§

fn encoder_features_joint(&self, obs: Tensor<B, 2>) -> Tensor<B, 2>

Shared-trunk feature representation; gradients flow back into the encoder. The natural quantity to feed into cross-agent regularizers. Read more
Source§

fn action_dims_joint(&self) -> Vec<i64>

Per-dimension action cardinalities. Read more
Source§

impl<B: Backend> Module<B> for MlpBurnPolicy<B>

Source§

type Record = MlpBurnPolicyRecord<B>

Type to save and load the module.
Source§

fn load_record(self, record: Self::Record) -> Self

Load the module state from a record.
Source§

fn into_record(self) -> Self::Record

Convert the module into a record containing the state.
Source§

fn num_params(&self) -> usize

Get the number of parameters the module has, including all of its sub-modules.
Source§

fn visit<Visitor: ModuleVisitor<B>>(&self, visitor: &mut Visitor)

Visit each tensor parameter in the module with a visitor.
Source§

fn map<Mapper: ModuleMapper<B>>(self, mapper: &mut Mapper) -> Self

Map each tensor parameter in the module with a mapper.
Source§

fn collect_devices(&self, devices: Devices<B>) -> Devices<B>

Return all the devices found in the underneath module tree added to the given vector without duplicates.
Source§

fn to_device(self, device: &B::Device) -> Self

Move the module and all of its sub-modules to the given device. Read more
Source§

fn fork(self, device: &B::Device) -> Self

Fork the module and all of its sub-modules to the given device. Read more
Source§

fn devices(&self) -> Vec<<B as BackendTypes>::Device>

Return all the devices found in the underneath module tree without duplicates.
Source§

fn no_grad(self) -> Self

Each tensor in the module tree will not require grad. Read more
Source§

fn train<AB>(self) -> Self::TrainModule
where AB: AutodiffBackend<InnerBackend = B>, Self: HasAutodiffModule<AB>,

Move the module and all of its sub-modules to the autodiff backend. Read more
Source§

fn save_file<FR, PB>( self, file_path: PB, recorder: &FR, ) -> Result<(), RecorderError>
where FR: FileRecorder<B>, PB: Into<PathBuf>,

Save the module to a file using the provided file recorder. Read more
Source§

fn load_file<FR, PB>( self, file_path: PB, recorder: &FR, device: &<B as BackendTypes>::Device, ) -> Result<Self, RecorderError>
where FR: FileRecorder<B>, PB: Into<PathBuf>,

Load the module from a file using the provided file recorder. Read more
Source§

fn quantize_weights(self, quantizer: &mut Quantizer) -> Self

Quantize the weights of the module.
Source§

impl<B: Backend> ModuleDisplay for MlpBurnPolicy<B>

Source§

fn format(&self, passed_settings: DisplaySettings) -> String

Formats the module with provided display settings. Read more
Source§

fn custom_settings(&self) -> Option<DisplaySettings>

Custom display settings for the module. Read more
Source§

fn custom_content(&self, _content: Content) -> Option<Content>

Custom attributes for the module. Read more
Source§

impl<B: Backend> ModuleDisplayDefault for MlpBurnPolicy<B>

Source§

fn content(&self, content: Content) -> Option<Content>

Attributes of the module used for display purposes. Read more
Source§

fn num_params(&self) -> usize

Gets the number of the parameters of the module.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T> ToString for T
where T: Display + ?Sized,

Source§

fn to_string(&self) -> String

Converts the given value to a String. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more