valentineus/fparkan
1
Fork 0
Code Issues Pull Requests Actions Releases Activity

feat(runtime): support class-9 and default Control budgets
Docs Deploy / Build and Deploy MkDocs (push) Successful in 35s
Details

Browse Source
This commit is contained in:
Valentin Popov committed 2026-10-29 19:43:09 +04:00
1 parent d3a0f8c7ff
commit 1d20509b05
5 files changed
+986 -67
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

crates/fparkan-runtime/src/lib.rs
+640 -30
View File
@@ -201,6 +201,10 @@ pub struct EffectiveControlDevice {
pub multiplier_bits: Option<u32>,
/// Class-9-only scale used by its selector-0 getter.
pub class9_selector0_scale_bits: Option<u32>,
/// Six class-9 budget values at native `+0x98..+0xac`.
pub class9_values_bits: Option<[u32; 6]>,
/// Six accumulated class-9 changes at native `+0xb0..+0xc4`.
pub class9_deltas_bits: Option<[u32; 6]>,
/// Current native word at `+0x50` when it is known.
pub native_word_50_bits: Option<u32>,
/// Current native tag-15 byte at `+0x94`; constructors currently set zero.
@@ -419,7 +423,7 @@ pub enum MissionControlDeviceTableUnavailableReason {
unit_component_index: usize,
target_index: u32,
},
/// The receiver tag does not have a verified common override method.
/// The receiver's override behavior is not supported.
UnsupportedOverrideReceiver { factory_tag: u32 },
/// The EXTO key needs a global model-node mapping that is not available.
UnsupportedExToNodeMapping { unit_component_index: usize },
@@ -2278,8 +2282,9 @@ pub fn distribute_loaded_mission_control_provider_amount(
/// Runs the supported loaded Control resource-budget pass (`Control.dll+0x2d340`).
///
/// The pass currently supports original factory callbacks for tags 15 and 19,
/// with current descriptor tags 15 and 19 (native categories 0 and 1). It is an explicit CPU update;
/// The pass supports the original factory callbacks for tags 9, 15, and 19,
/// plus the generic default callback pair. Current descriptor category tags are
/// supported for the native map prefix `0..=34`. This is an explicit CPU update;
/// the mission clock does not call it yet. Rate outputs at `+0x5dc/+0x5e0` are
/// stored on the table after a successful pass.
///
@@ -2924,7 +2929,9 @@ fn control_resource_budget_pass_inner(
for index in 0..device_count {
let device = control_budget_device(table, index)?;
control_budget_category(device.descriptor.tag)?;
if !matches!(device.factory_tag, 15 | 19) {
if !matches!(device.factory_tag, 9 | 15 | 19)
&& !control_factory_uses_generic_budget_callbacks(device.factory_tag)
{
return Err(ControlResourceAccessError::UnsupportedFactoryTag {
factory_tag: device.factory_tag,
});
@@ -3019,11 +3026,14 @@ fn control_resource_budget_pass_inner(
}
fn control_budget_category(tag: u32) -> Result<usize, ControlResourceAccessError> {
match tag {
15 => Ok(0),
19 => Ok(1),
_ => Err(ControlResourceAccessError::UnsupportedCurrentTag { tag }),
}
const NATIVE_CATEGORY_PREFIX: [usize; 35] = [
0, 4, 4, 0, 2, 3, 0, 0, 2, 5, 5, 0, 0, 0, 1, 0, 3, 2, 0, 1, 3, 5, 4, 0, 4, 0, 3, 5, 0, 0,
4, 0, 1, 2, 4,
];
NATIVE_CATEGORY_PREFIX
.get(tag as usize)
.copied()
.ok_or(ControlResourceAccessError::UnsupportedCurrentTag { tag })
}
fn control_budget_device(
@@ -3192,12 +3202,95 @@ fn control_device_resource_rate(
let Some(provider_value) = control_device_budget_active_provider_value(table, device)? else {
return Ok(0.0);
};
let coefficient_0 = control_device_budget_coefficient(device, 0)?;
let descriptor_rate =
control_device_budget_descriptor_float(device, 8, "descriptor resource rate +0x20")?;
match device.factory_tag {
9 => {
let coefficient_0 = control_device_budget_coefficient(device, 0)?;
let coefficient_1 = control_device_budget_coefficient(device, 1)?;
let coefficient_2 = control_device_budget_coefficient(device, 2)?;
let class9_scale = control_device_float(
device,
device.class9_selector0_scale_bits,
"class-9 selector-0 scale",
)?;
let capacity_scale = checked_control_product(
device.factory_tag,
"class-9 scaled capacity coefficient",
coefficient_0,
class9_scale,
)?;
let values =
device
.class9_values_bits
.ok_or(ControlResourceAccessError::UnsupportedField {
factory_tag: device.factory_tag,
field: "class-9 six values +0x98",
})?;
let mut value_sum = 0.0_f32;
for bits in values {
value_sum = checked_control_sum(
device.factory_tag,
"class-9 value sum",
value_sum,
checked_control_float(
device.factory_tag,
"class-9 value",
f32::from_bits(bits),
)?,
)?;
}
let free_values = checked_control_sum(
device.factory_tag,
"class-9 free value capacity",
6.0,
-value_sum,
)?;
let capacity = checked_control_product(
device.factory_tag,
"class-9 available capacity",
free_values,
capacity_scale,
)?;
let query = checked_control_product(
device.factory_tag,
"class-9 provider coefficient",
coefficient_1,
provider_value,
)?;
let query_interval = checked_control_product(
device.factory_tag,
"class-9 provider rate times interval",
query,
delta_time_seconds,
)?;
let interval_rate = checked_control_product(
device.factory_tag,
"class-9 interval descriptor rate",
delta_time_seconds,
descriptor_rate,
)?;
let selected = if capacity < query_interval {
capacity
} else {
query_interval
};
let coefficient_cost = checked_control_product(
device.factory_tag,
"class-9 coefficient cost",
coefficient_2,
selected,
)?;
checked_control_sum(
device.factory_tag,
"class-9 resource rate",
-interval_rate,
-coefficient_cost,
)
}
19 => {
let coefficient_0 = control_device_budget_coefficient(device, 0)?;
let multiplier = control_device_float(device, device.multiplier_bits, "multiplier")?;
let mut raw = checked_control_product(
device.factory_tag,
@@ -3236,6 +3329,7 @@ fn control_device_resource_rate(
}
}
15 => {
let coefficient_0 = control_device_budget_coefficient(device, 0)?;
let coefficient_1 = control_device_budget_coefficient(device, 1)?;
let interval_rate = checked_control_product(
device.factory_tag,
@@ -3284,6 +3378,15 @@ fn control_device_resource_rate(
-coefficient_cost,
)
}
factory_tag if control_factory_uses_generic_budget_callbacks(factory_tag) => {
let interval_rate = checked_control_product(
device.factory_tag,
"generic Control interval descriptor rate",
delta_time_seconds,
descriptor_rate,
)?;
Ok(-interval_rate)
}
factory_tag => Err(ControlResourceAccessError::UnsupportedFactoryTag { factory_tag }),
}
}
@@ -3354,6 +3457,82 @@ fn control_device_resource_update(
return Ok(());
};
match device.factory_tag {
9 => {
set_control_device_multiplier(table, device_index, allocation)?;
let device = control_budget_device(table, device_index)?;
let rate = control_device_resource_rate(table, device, delta_time_seconds)?;
let allocated_rate = checked_control_product(
device.factory_tag,
"class-9 allocated rate",
rate,
allocation,
)?;
let interval_rate = checked_control_product(
device.factory_tag,
"class-9 interval descriptor rate",
delta_time_seconds,
control_device_budget_descriptor_float(
device,
8,
"descriptor resource rate +0x20",
)?,
)?;
let remaining = checked_control_sum(
device.factory_tag,
"class-9 remaining adjustment",
-allocated_rate,
-interval_rate,
)?;
if remaining == 0.0 {
return Ok(());
}
let coefficient_2 = control_device_budget_coefficient(device, 2)?;
let raw_change = if coefficient_2 > 0.0 {
checked_control_ratio("class-9 adjustment coefficient", remaining, coefficient_2)?
} else {
let coefficient_1 = control_device_budget_coefficient(device, 1)?;
let query = checked_control_product(
device.factory_tag,
"class-9 provider coefficient",
coefficient_1,
provider_value,
)?;
let query_interval = checked_control_product(
device.factory_tag,
"class-9 provider rate times interval",
query,
delta_time_seconds,
)?;
if remaining > 0.0 {
query_interval
} else {
-query_interval
}
};
let class9_scale = control_device_float(
device,
device.class9_selector0_scale_bits,
"class-9 selector-0 scale",
)?;
let coefficient_0 = control_device_budget_coefficient(device, 0)?;
let capacity_scale = checked_control_product(
device.factory_tag,
"class-9 scaled capacity coefficient",
coefficient_0,
class9_scale,
)?;
if !table.node_provider_distribution_suspended && capacity_scale > 0.0 {
let divisor = checked_control_product(
device.factory_tag,
"class-9 six-value scale",
capacity_scale,
6.0,
)?;
let change =
checked_control_ratio("class-9 value adjustment", raw_change, divisor)?;
adjust_control_class9_values(table, device_index, change)?;
}
}
19 => {
let coefficient_0 = control_device_budget_coefficient(&device, 0)?;
if coefficient_0 < 0.0 {
@@ -3484,6 +3663,9 @@ fn control_device_resource_update(
)?;
}
}
factory_tag if control_factory_uses_generic_budget_callbacks(factory_tag) => {
set_control_device_multiplier(table, device_index, allocation)?;
}
factory_tag => {
return Err(ControlResourceAccessError::UnsupportedFactoryTag { factory_tag })
}
@@ -3491,6 +3673,157 @@ fn control_device_resource_update(
Ok(())
}
fn set_control_device_multiplier(
table: &mut MissionControlDeviceTableState,
device_index: usize,
value: f32,
) -> Result<(), ControlResourceAccessError> {
let device = control_budget_device(table, device_index)?;
let factory_tag = device.factory_tag;
let value = checked_control_float(factory_tag, "multiplier", value)?;
match &mut table.status {
MissionControlDeviceTableStatus::Available(devices) => {
let Some(device) = devices.get_mut(device_index) else {
return Err(ControlResourceAccessError::DeviceIndexOutOfRange {
device_index,
device_count: devices.len(),
});
};
device.multiplier_bits = Some(value.to_bits());
}
MissionControlDeviceTableStatus::Unavailable(reason) => {
return Err(ControlResourceAccessError::TableUnavailable(reason.clone()))
}
}
Ok(())
}
fn adjust_control_class9_values(
table: &mut MissionControlDeviceTableState,
device_index: usize,
change: f32,
) -> Result<(), ControlResourceAccessError> {
const CLASS9_AVERAGE_FACTOR: f32 = f32::from_bits(0x3e2a_aaab);
let device = control_budget_device(table, device_index)?;
let values = device
.class9_values_bits
.ok_or(ControlResourceAccessError::UnsupportedField {
factory_tag: device.factory_tag,
field: "class-9 six values +0x98",
})?;
let deltas = device
.class9_deltas_bits
.ok_or(ControlResourceAccessError::UnsupportedField {
factory_tag: device.factory_tag,
field: "class-9 six deltas +0xb0",
})?;
let factory_tag = device.factory_tag;
let mut sum = 0.0_f32;
for bits in values {
sum = checked_control_sum(
factory_tag,
"class-9 value sum",
sum,
checked_control_float(factory_tag, "class-9 value", f32::from_bits(bits))?,
)?;
}
let average = checked_control_product(
factory_tag,
"class-9 value average",
sum,
CLASS9_AVERAGE_FACTOR,
)?;
let mut updated_values = values;
let mut updated_deltas = deltas;
if change > 0.0 && average != 1.0 {
let remaining =
checked_control_sum(factory_tag, "class-9 remaining average", 1.0, -average)?;
let factor =
checked_control_ratio("class-9 positive adjustment factor", change, remaining)?;
let factor = if factor > 1.0 { 1.0 } else { factor };
for index in 0..6 {
let value =
checked_control_float(factory_tag, "class-9 value", f32::from_bits(values[index]))?;
let delta = checked_control_float(
factory_tag,
"class-9 accumulated delta",
f32::from_bits(deltas[index]),
)?;
let room = checked_control_sum(factory_tag, "class-9 value room", 1.0, -value)?;
let adjustment = checked_control_product(
factory_tag,
"class-9 positive value adjustment",
room,
factor,
)?;
updated_values[index] = checked_control_sum(
factory_tag,
"class-9 value after positive adjustment",
value,
adjustment,
)?
.to_bits();
updated_deltas[index] = checked_control_sum(
factory_tag,
"class-9 delta after positive adjustment",
delta,
adjustment,
)?
.to_bits();
}
} else if change < 0.0 && average != 0.0 {
let factor = checked_control_ratio("class-9 negative adjustment factor", -change, average)?;
let factor = if factor > 1.0 { 1.0 } else { factor };
for index in 0..6 {
let value =
checked_control_float(factory_tag, "class-9 value", f32::from_bits(values[index]))?;
let delta = checked_control_float(
factory_tag,
"class-9 accumulated delta",
f32::from_bits(deltas[index]),
)?;
let removed = checked_control_product(
factory_tag,
"class-9 negative value adjustment",
factor,
value,
)?;
updated_values[index] = checked_control_sum(
factory_tag,
"class-9 value after negative adjustment",
value,
-removed,
)?
.to_bits();
updated_deltas[index] = checked_control_sum(
factory_tag,
"class-9 delta after negative adjustment",
delta,
-removed,
)?
.to_bits();
}
}
match &mut table.status {
MissionControlDeviceTableStatus::Available(devices) => {
let Some(device) = devices.get_mut(device_index) else {
return Err(ControlResourceAccessError::DeviceIndexOutOfRange {
device_index,
device_count: devices.len(),
});
};
device.class9_values_bits = Some(updated_values);
device.class9_deltas_bits = Some(updated_deltas);
}
MissionControlDeviceTableStatus::Unavailable(reason) => {
return Err(ControlResourceAccessError::TableUnavailable(reason.clone()))
}
}
Ok(())
}
fn apply_control_node_delta(
table: &mut MissionControlDeviceTableState,
key: u32,
@@ -4598,8 +4931,7 @@ fn append_effective_control_device(
let provenance = control_device_record_provenance(component_index, record_index, control);
let mut coefficient_words = [0; 16];
coefficient_words.copy_from_slice(&descriptor.fixed_words[11..27]);
let coefficient_bits =
control_factory_uses_common_setter(descriptor.tag).then_some(coefficient_words);
let coefficient_bits = Some(coefficient_words);
let (multiplier_bits, default_word_50) = native_control_factory_defaults(descriptor.tag);
let native_byte_94 = native_control_factory_byte_94(descriptor.tag);
let native_word_50_bits = if descriptor.fixed_words[6] == u32::MAX {
@@ -4614,6 +4946,8 @@ fn append_effective_control_device(
coefficient_bits,
multiplier_bits,
class9_selector0_scale_bits: (descriptor.tag == 9).then_some(0x3f80_0000),
class9_values_bits: (descriptor.tag == 9).then_some([0x3f80_0000; 6]),
class9_deltas_bits: (descriptor.tag == 9).then_some([0; 6]),
native_word_50_bits,
native_byte_94,
descriptor: descriptor.clone(),
@@ -4640,23 +4974,24 @@ fn apply_effective_control_override(
control_device_record_provenance(component_index, record_index, control);
}
fn control_factory_uses_common_setter(factory_tag: u32) -> bool {
matches!(
factory_tag,
1 | 2 | 3 | 4 | 5 | 8 | 9 | 10 | 15 | 17 | 19 | 21 | 25 | 26 | 27 | 30
)
fn control_factory_uses_generic_budget_callbacks(factory_tag: u32) -> bool {
!matches!(factory_tag, 1 | 2 | 5 | 9 | 10 | 15 | 17 | 19 | 26 | 30)
}
fn control_factory_override_is_supported(factory_tag: u32) -> bool {
!matches!(factory_tag, 1 | 17 | 26 | 30)
}
fn native_control_factory_defaults(factory_tag: u32) -> (Option<u32>, Option<u32>) {
match factory_tag {
1 | 4 => (Some(0x3f80_0000), Some(0x200)),
3 | 5 | 8 | 21 | 26 => (Some(0x3f80_0000), Some(0x5)),
3 | 5 | 8 | 21 | 25 | 26 => (Some(0x3f80_0000), Some(0x5)),
10 => (Some(0x3f80_0000), Some(0x2000)),
17 | 19 => (Some(0x3f80_0000), Some(0x20)),
2 | 27 => (Some(0x3f80_0000), Some(0)),
9 | 25 => (Some(0x3f80_0000), None),
9 => (Some(0x3f80_0000), Some(0x20)),
15 => (Some(0x3f80_0000), Some(0)),
_ => (None, None),
_ => (Some(0x3f80_0000), Some(0x5)),
}
}
@@ -5029,10 +5364,7 @@ fn build_control_device_projection(
target_index,
},
)?;
if !matches!(
device.factory_tag,
2 | 3 | 4 | 5 | 8 | 9 | 10 | 15 | 19 | 21 | 25 | 27
) {
if !control_factory_override_is_supported(device.factory_tag) {
return Err(Unavailable::UnsupportedOverrideReceiver {
factory_tag: device.factory_tag,
});
@@ -5927,6 +6259,8 @@ mod tests {
coefficient_bits: Some(coefficients),
multiplier_bits,
class9_selector0_scale_bits: class9_scale_bits,
class9_values_bits: (factory_tag == 9).then_some([0x3f80_0000; 6]),
class9_deltas_bits: (factory_tag == 9).then_some([0; 6]),
native_word_50_bits,
native_byte_94: native_control_factory_byte_94(factory_tag),
descriptor,
@@ -6079,6 +6413,201 @@ mod tests {
}
}
#[test]
fn control_budget_class9_device_matches_native_rate_and_update_vectors() {
let mut device = synthetic_effective_control_device(
9,
9,
0.75_f32.to_bits(),
Some(0.25_f32.to_bits()),
Some(1.25_f32.to_bits()),
);
device.key = 0;
device.native_word_50_bits = Some(0x20);
device.descriptor.fixed_words[8] = 0.2_f32.to_bits();
let coefficients = device.coefficient_bits.as_mut().expect("coefficient table");
coefficients[1] = 0.6_f32.to_bits();
coefficients[2] = 2.0_f32.to_bits();
device.class9_values_bits = Some([
0.0_f32.to_bits(),
0.25_f32.to_bits(),
0.5_f32.to_bits(),
0.75_f32.to_bits(),
1.0_f32.to_bits(),
0.9_f32.to_bits(),
]);
device.class9_deltas_bits = Some([
0.1_f32.to_bits(),
(-0.2_f32).to_bits(),
0.0_f32.to_bits(),
0.3_f32.to_bits(),
(-0.4_f32).to_bits(),
0.5_f32.to_bits(),
]);
let provider = synthetic_node_provider_row(0, 0, 0.4_f32.to_bits());
let mut table = synthetic_control_device_table_with_providers(
MissionControlDeviceTableStatus::Available(vec![device]),
MissionControlNodeProviderTableStatus::Available(vec![provider]),
);
let rate = {
let device = control_budget_device(&table, 0).expect("class-9 device");
control_device_resource_rate(&table, device, 0.5).expect("class-9 rate")
};
assert_eq!(rate.to_bits(), 0xbeae_147b);
control_device_resource_update(&mut table, 0, 0.5, 1.0).expect("class-9 update");
let MissionControlDeviceTableStatus::Available(devices) = &table.status else {
unreachable!();
};
assert_eq!(devices[0].multiplier_bits, Some(0x3f80_0000));
assert_eq!(
devices[0].class9_values_bits,
Some([
0x3d49_a637,
0x3e92_e795,
0x3f06_4d32,
0x3f43_2699,
0x3f80_0000,
0x3f67_a90a,
])
);
assert_eq!(
devices[0].class9_deltas_bits,
Some([
0x3e18_cff4,
0xbe26_fda3,
0x3cc9_a637,
0x3e9f_e6cc,
0xbecc_cccd,
0x3f01_42a4,
])
);
let mut decreasing = synthetic_effective_control_device(
9,
9,
10.0_f32.to_bits(),
Some(1.0_f32.to_bits()),
Some(1.0_f32.to_bits()),
);
decreasing.key = 0;
decreasing.native_word_50_bits = Some(0x20);
decreasing.descriptor.fixed_words[8] = 0.2_f32.to_bits();
let coefficients = decreasing
.coefficient_bits
.as_mut()
.expect("coefficient table");
coefficients[1] = 0.6_f32.to_bits();
coefficients[2] = 2.0_f32.to_bits();
decreasing.class9_values_bits = Some([0x3f80_0000; 6]);
decreasing.class9_deltas_bits = Some([0; 6]);
let provider = synthetic_node_provider_row(0, 0, 0.4_f32.to_bits());
let mut table = synthetic_control_device_table_with_providers(
MissionControlDeviceTableStatus::Available(vec![decreasing]),
MissionControlNodeProviderTableStatus::Available(vec![provider]),
);
let rate = {
let device = control_budget_device(&table, 0).expect("class-9 device");
control_device_resource_rate(&table, device, 0.5).expect("class-9 rate")
};
assert_eq!(rate.to_bits(), 0xbdcc_cccd);
control_device_resource_update(&mut table, 0, 0.5, 0.5).expect("class-9 negative update");
let MissionControlDeviceTableStatus::Available(devices) = &table.status else {
unreachable!();
};
assert_eq!(devices[0].multiplier_bits, Some(0x3f00_0000));
assert_eq!(devices[0].class9_values_bits, Some([0x3f7f_e4b1; 6]));
assert_eq!(devices[0].class9_deltas_bits, Some([0xb9da_740e; 6]));
}
#[test]
fn control_class9_adjustment_matches_native_stored_average_factor() {
let mut device = synthetic_effective_control_device(
9,
9,
1.0_f32.to_bits(),
Some(1.0_f32.to_bits()),
Some(1.0_f32.to_bits()),
);
device.class9_values_bits = Some([
0,
0x3f80_0000,
0x3f80_0000,
0x3f80_0000,
0x3f80_0000,
0x3f80_0000,
]);
device.class9_deltas_bits = Some([0; 6]);
let mut table =
synthetic_control_device_table(MissionControlDeviceTableStatus::Available(vec![
device,
]));
adjust_control_class9_values(&mut table, 0, 0.1).expect("class-9 adjustment");
let MissionControlDeviceTableStatus::Available(devices) = &table.status else {
unreachable!();
};
assert_eq!(
devices[0].class9_values_bits,
Some([
0x3f19_999c,
0x3f80_0000,
0x3f80_0000,
0x3f80_0000,
0x3f80_0000,
0x3f80_0000
])
);
assert_eq!(
devices[0].class9_deltas_bits,
Some([0x3f19_999c, 0, 0, 0, 0, 0])
);
}
#[test]
fn class9_into_preserves_runtime_values_and_deltas() {
let mut device = synthetic_effective_control_device(
9,
9,
1.0_f32.to_bits(),
Some(1.0_f32.to_bits()),
Some(1.0_f32.to_bits()),
);
let values = [
0x3d49_a637,
0x3e92_e795,
0x3f06_4d32,
0x3f43_2699,
0x3f80_0000,
0x3f67_a90a,
];
let deltas = [
0x3e18_cff4,
0xbe26_fda3,
0x3cc9_a637,
0x3e9f_e6cc,
0xbecc_cccd,
0x3f01_42a4,
];
device.class9_values_bits = Some(values);
device.class9_deltas_bits = Some(deltas);
let replacement = synthetic_control_record(19, 99, 0x30, None);
let control = synthetic_component_control(
1,
vec![replacement.clone()],
PreparedControlEffectSection::Parsed(Vec::new()),
);
apply_effective_control_override(&mut device, &replacement, 1, 0, &control);
assert_eq!(device.factory_tag, 9);
assert_eq!(device.descriptor.tag, 19);
assert_eq!(device.class9_values_bits, Some(values));
assert_eq!(device.class9_deltas_bits, Some(deltas));
}
#[test]
fn control_budget_dispatch_matches_non_degenerate_native_pair() {
let mut table = control_budget_test_table(0.25);
@@ -6110,6 +6639,65 @@ mod tests {
assert_eq!(rows[0].current_accumulated_delta_bits, 0x3d2e_1400);
}
#[test]
fn control_budget_generic_default_callbacks_match_native_rate_and_update() {
for factory_tag in [3, 4, 6, 8, 12, 13, 21, 25, 27, 34] {
let mut device = synthetic_effective_control_device(
factory_tag,
factory_tag,
1.0_f32.to_bits(),
Some(1.0_f32.to_bits()),
None,
);
device.key = 0;
device.native_word_50_bits = Some(5);
device.descriptor.fixed_words[8] = 0.2_f32.to_bits();
let provider = synthetic_node_provider_row(0, 0, 0.4_f32.to_bits());
let mut table = synthetic_control_device_table_with_providers(
MissionControlDeviceTableStatus::Available(vec![device]),
MissionControlNodeProviderTableStatus::Available(vec![provider]),
);
let rate = {
let device = control_budget_device(&table, 0).expect("generic device");
control_device_resource_rate(&table, device, 0.5).expect("generic base rate")
};
assert_eq!(
rate.to_bits(),
(-0.1_f32).to_bits(),
"factory {factory_tag}"
);
control_device_resource_update(&mut table, 0, 0.5, 0.375).expect("generic base update");
let MissionControlDeviceTableStatus::Available(devices) = &table.status else {
unreachable!();
};
assert_eq!(
devices[0].multiplier_bits,
Some(0.375_f32.to_bits()),
"factory {factory_tag}"
);
}
}
#[test]
fn control_budget_current_tag_categories_match_native_prefix() {
let categories = [
0, 4, 4, 0, 2, 3, 0, 0, 2, 5, 5, 0, 0, 0, 1, 0, 3, 2, 0, 1, 3, 5, 4, 0, 4, 0, 3, 5, 0,
0, 4, 0, 1, 2, 4,
];
for (tag, category) in categories.into_iter().enumerate() {
assert_eq!(
control_budget_category(tag as u32),
Ok(category),
"current descriptor tag {tag}"
);
}
assert_eq!(
control_budget_category(35),
Err(ControlResourceAccessError::UnsupportedCurrentTag { tag: 35 })
);
}
#[test]
fn control_budget_dispatch_keeps_callbacks_but_honors_owner_suspension() {
let mut table = control_budget_test_table(1.0);
@@ -6162,7 +6750,7 @@ mod tests {
let mut table = control_budget_test_table(1.0);
let unsupported = synthetic_effective_control_device(
26,
26,
35,
1.0_f32.to_bits(),
Some(1.0_f32.to_bits()),
None,
@@ -6175,7 +6763,7 @@ mod tests {
assert_eq!(
control_resource_budget_pass(&mut table, 0.5),
Err(ControlResourceAccessError::UnsupportedCurrentTag { tag: 26 })
Err(ControlResourceAccessError::UnsupportedCurrentTag { tag: 35 })
);
assert_eq!(table, before);
}
@@ -7657,9 +8245,14 @@ mod tests {
(3, 5),
(4, 0x200),
(5, 5),
(6, 5),
(8, 5),
(9, 0x20),
(10, 0x2000),
(12, 5),
(13, 5),
(21, 5),
(25, 5),
(27, 0),
] {
let mut root = synthetic_control_record(factory_tag, 2, 0x20, None);
@@ -7697,15 +8290,22 @@ mod tests {
assert_eq!(device.multiplier_bits, Some(1.0_f32.to_bits()));
assert_eq!(device.native_word_50_bits, Some(word_50));
assert_eq!(device.coefficient_bits.unwrap()[0], 0x30);
if factory_tag == 9 {
assert_eq!(device.class9_values_bits, Some([0x3f80_0000; 6]));
assert_eq!(device.class9_deltas_bits, Some([0; 6]));
}
}
for factory_tag in [1, 17, 26, 30] {
assert!(!control_factory_override_is_supported(factory_tag));
}
}
#[test]
fn control_factory_multiplier_defaults_preserve_unknown_word_50() {
for factory_tag in [9, 25] {
fn control_factory_defaults_match_native_class_construction() {
for (factory_tag, word_50) in [(9, 0x20), (12, 5), (13, 5), (25, 5), (34, 5)] {
assert_eq!(
native_control_factory_defaults(factory_tag),
(Some(0x3f80_0000), None)
(Some(0x3f80_0000), Some(word_50))
);
}
assert_eq!(
@@ -8831,6 +9431,16 @@ mod tests {
(21, 21),
]
);
assert_eq!(mine_control_devices[2].native_word_50_bits, Some(0x20));
assert_eq!(
mine_control_devices[2].class9_selector0_scale_bits,
Some(0x3f80_0000)
);
assert_eq!(
mine_control_devices[2].class9_values_bits,
Some([0x3f80_0000; 6])
);
assert_eq!(mine_control_devices[2].class9_deltas_bits, Some([0; 6]));
assert_eq!(
advance_loaded_mission_control_budget(&mut mine_engine, mine_control_handle, f32::NAN),
Err(ControlResourceAccessError::NonFiniteValue {
@@ -8840,7 +9450,7 @@ mod tests {
);
assert_eq!(
advance_loaded_mission_control_budget(&mut mine_engine, mine_control_handle, 0.5),
Err(ControlResourceAccessError::UnsupportedCurrentTag { tag: 9 })
Err(ControlResourceAccessError::UnsupportedFactoryTag { factory_tag: 26 })
);
assert_eq!(
loaded_mission_control_device_tables(&mine_engine),
crates/fparkan-runtime/tests/behavior_distributor_tick_native_oracle.cs
+218 -3
View File
@@ -54,6 +54,11 @@ internal static class BehaviorDistributorTickOracle {
private const int ControlResourceTag9ConstructorRva = 0x25460;
private const int ControlResourceTag15ConstructorRva = 0x22ae0;
private const int ControlResourceTag25ConstructorRva = 0x20800;
private const int ControlResourceTag9RateRva = 0x25700;
private const int ControlResourceTag9UpdateRva = 0x257b0;
private const int ControlResourceTag9AdjustRva = 0x25a90;
private const int ControlResourceDefaultRateRva = 0x21860;
private const int ControlResourceDefaultUpdateRva = 0x21890;
private const int ControlResourceTag15RateRva = 0x22b20;
private const int ControlResourceTag15UpdateRva = 0x22bb0;
private const int ControlResourceBudgetUpdateRva = 0x2d340;
@@ -119,6 +124,7 @@ internal static class BehaviorDistributorTickOracle {
[UnmanagedFunctionPointer(CallingConvention.ThisCall)] private delegate IntPtr NativeControlResourceDeviceConstructor(IntPtr self);
[UnmanagedFunctionPointer(CallingConvention.ThisCall)] private delegate void NativeControlResourceBudgetUpdate(IntPtr self, float deltaSeconds);
[UnmanagedFunctionPointer(CallingConvention.ThisCall)] private delegate float NativeControlResourceDeviceRate(IntPtr self, float deltaSeconds);
[UnmanagedFunctionPointer(CallingConvention.ThisCall)] private delegate void NativeControlResourceTag9Update(IntPtr self, float deltaSeconds, float allocation);
[UnmanagedFunctionPointer(CallingConvention.ThisCall)] private delegate int NativeControlResourceDeviceGate(IntPtr self);
[UnmanagedFunctionPointer(CallingConvention.ThisCall)] private delegate float NativeControlResourceAvailability(IntPtr self, byte flags);
[UnmanagedFunctionPointer(CallingConvention.ThisCall)] private delegate IntPtr NativeControlDeviceFactory(IntPtr self, uint componentId, uint keyOffset, IntPtr record);
@@ -706,6 +712,8 @@ internal static class BehaviorDistributorTickOracle {
RunNativeControlTimedUpdateBaselineCases(controlModule);
RunNativeControlAggregateResourceCases(controlModule);
RunNativeControlResourceBudgetTag15Case(controlModule);
RunNativeControlResourceBudgetClass9Case(controlModule);
RunNativeControlGenericDefaultBudgetCase(controlModule);
RunNativeControlActivationCase(controlModule);
RunNativeBehaviorProfileMapCases(module);
RunNativeBehaviorVarSyntheticCase(module);
@@ -1790,6 +1798,198 @@ internal static class BehaviorDistributorTickOracle {
return device;
}
private static void RunNativeControlResourceBudgetClass9Case(IntPtr module) {
NativeControlOwnerConstructor constructOwner = (NativeControlOwnerConstructor)
Marshal.GetDelegateForFunctionPointer(IntPtr.Add(module, ControlOwnerConstructorRva),
typeof(NativeControlOwnerConstructor));
NativeControlResourceDeviceConstructor constructDevice = (NativeControlResourceDeviceConstructor)
Marshal.GetDelegateForFunctionPointer(IntPtr.Add(module, ControlResourceTag9ConstructorRva),
typeof(NativeControlResourceDeviceConstructor));
NativeControlProviderRowConstructor constructProvider = (NativeControlProviderRowConstructor)
Marshal.GetDelegateForFunctionPointer(IntPtr.Add(module, ControlProviderRowConstructorRva),
typeof(NativeControlProviderRowConstructor));
NativeControlResourceDeviceRate rate = (NativeControlResourceDeviceRate)
Marshal.GetDelegateForFunctionPointer(IntPtr.Add(module, ControlResourceTag9RateRva),
typeof(NativeControlResourceDeviceRate));
NativeControlResourceTag9Update update = (NativeControlResourceTag9Update)
Marshal.GetDelegateForFunctionPointer(IntPtr.Add(module, ControlResourceTag9UpdateRva),
typeof(NativeControlResourceTag9Update));
NativeControlContactRateUpdate adjust = (NativeControlContactRateUpdate)
Marshal.GetDelegateForFunctionPointer(IntPtr.Add(module, ControlResourceTag9AdjustRva),
typeof(NativeControlContactRateUpdate));
using (Fixture fixture = NewFixture()) {
IntPtr owner = fixture.Allocate(0x664);
Expect(constructOwner(owner, IntPtr.Zero, 4) == owner, "native class-9 budget owner constructor");
IntPtr ndp = fixture.Allocate(0x4c);
Marshal.WriteInt32(ndp, 4, FloatBits(100.0f));
IntPtr provider = fixture.Allocate(0x2c);
constructProvider(provider, ndp);
Marshal.WriteInt32(provider, 0x14, FloatBits(0.4f));
Marshal.WriteIntPtr(owner, 0x55c, provider);
Marshal.WriteInt32(owner, 0x560, 1);
IntPtr device = fixture.Allocate(0x120);
Expect(constructDevice(device) == device &&
Marshal.ReadIntPtr(device) == IntPtr.Add(module, ControlResourceTag9VtableRva),
"native class-9 constructor installs its original vtable");
Expect(Marshal.ReadInt32(device, 0x50) == 0x20,
"native class-9 constructor enables its budget callback");
for (int i = 0; i < 6; i++) {
Expect(Marshal.ReadInt32(device, 0x98 + i * 4) == FloatBits(1.0f) &&
Marshal.ReadInt32(device, 0xb0 + i * 4) == 0,
"native class-9 constructor initializes value/delta row " + i);
}
IntPtr descriptor = fixture.Allocate(0xb4);
Marshal.WriteInt32(descriptor, 0, 9);
Marshal.WriteInt32(descriptor, 0x20, FloatBits(0.2f));
Marshal.WriteIntPtr(device, 0x3c, owner);
Marshal.WriteIntPtr(device, 0x44, IntPtr.Add(owner, 4));
Marshal.WriteIntPtr(device, 0x48, descriptor);
Marshal.WriteInt32(device, 0x54, FloatBits(0.75f));
Marshal.WriteInt32(device, 0x58, FloatBits(0.6f));
Marshal.WriteInt32(device, 0x5c, FloatBits(2.0f));
Marshal.WriteInt32(device, 0x11c, FloatBits(1.25f));
float[] values = { 0.0f, 0.25f, 0.5f, 0.75f, 1.0f, 0.9f };
float[] deltas = { 0.1f, -0.2f, 0.0f, 0.3f, -0.4f, 0.5f };
for (int i = 0; i < 6; i++) {
Marshal.WriteInt32(device, 0x98 + i * 4, FloatBits(values[i]));
Marshal.WriteInt32(device, 0xb0 + i * 4, FloatBits(deltas[i]));
}
Expect(FloatBits(rate(device, 0.5f)) == unchecked((int)0xbeae147b),
"native class-9 rate uses six values and selector-0 scale");
update(device, 0.5f, 1.0f);
int[] expectedValues = {
unchecked((int)0x3d49a637), unchecked((int)0x3e92e795),
unchecked((int)0x3f064d32), unchecked((int)0x3f432699),
unchecked((int)0x3f800000), unchecked((int)0x3f67a90a),
};
int[] expectedDeltas = {
unchecked((int)0x3e18cff4), unchecked((int)0xbe26fda3),
unchecked((int)0x3cc9a637), unchecked((int)0x3e9fe6cc),
unchecked((int)0xbecccccd), unchecked((int)0x3f0142a4),
};
Expect(Marshal.ReadInt32(device, 0x4c) == FloatBits(1.0f),
"native class-9 update stores its allocation multiplier");
for (int i = 0; i < 6; i++) {
Expect(Marshal.ReadInt32(device, 0x98 + i * 4) == expectedValues[i] &&
Marshal.ReadInt32(device, 0xb0 + i * 4) == expectedDeltas[i],
"native class-9 exact value/delta vector row " + i);
}
Console.WriteLine("native-control-class9-budget: controlHash=" + ExpectedControlSha256 +
" rateRva=0x25700 updateRva=0x257b0 adjustRva=0x25a90 dt=0.5" +
" rate=0xbeae147b values=" + String.Join(",", Array.ConvertAll(expectedValues,
value => Hex(unchecked((uint)value)))) +
" deltas=" + String.Join(",", Array.ConvertAll(expectedDeltas,
value => Hex(unchecked((uint)value)))));
IntPtr decreasingDevice = fixture.Allocate(0x120);
Expect(constructDevice(decreasingDevice) == decreasingDevice,
"native class-9 negative-update constructor");
IntPtr decreasingDescriptor = fixture.Allocate(0xb4);
Marshal.WriteInt32(decreasingDescriptor, 0, 9);
Marshal.WriteInt32(decreasingDescriptor, 0x20, FloatBits(0.2f));
Marshal.WriteIntPtr(decreasingDevice, 0x3c, owner);
Marshal.WriteIntPtr(decreasingDevice, 0x44, IntPtr.Add(owner, 4));
Marshal.WriteIntPtr(decreasingDevice, 0x48, decreasingDescriptor);
Marshal.WriteInt32(decreasingDevice, 0x54, FloatBits(10.0f));
Marshal.WriteInt32(decreasingDevice, 0x58, FloatBits(0.6f));
Marshal.WriteInt32(decreasingDevice, 0x5c, FloatBits(2.0f));
Marshal.WriteInt32(decreasingDevice, 0x11c, FloatBits(1.0f));
Expect(FloatBits(rate(decreasingDevice, 0.5f)) == unchecked((int)0xbdcccccd),
"native class-9 negative case rate");
update(decreasingDevice, 0.5f, 0.5f);
Expect(Marshal.ReadInt32(decreasingDevice, 0x4c) == FloatBits(0.5f),
"native class-9 negative case allocation multiplier");
for (int i = 0; i < 6; i++) {
Expect(Marshal.ReadInt32(decreasingDevice, 0x98 + i * 4) == unchecked((int)0x3f7fe4b1) &&
Marshal.ReadInt32(decreasingDevice, 0xb0 + i * 4) == unchecked((int)0xb9da740e),
"native class-9 negative value/delta row " + i);
}
Console.WriteLine("native-control-class9-negative: rate=0xbdcccccd M=0x3f000000" +
" values=0x3f7fe4b1x6 deltas=0xb9da740ex6");
IntPtr averageDevice = fixture.Allocate(0x120);
Expect(constructDevice(averageDevice) == averageDevice, "native class-9 average constructor");
for (int i = 0; i < 6; i++) {
Marshal.WriteInt32(averageDevice, 0x98 + i * 4, FloatBits(i == 0 ? 0.0f : 1.0f));
Marshal.WriteInt32(averageDevice, 0xb0 + i * 4, 0);
}
adjust(averageDevice, 0.1f);
Expect(Marshal.ReadInt32(averageDevice, 0x98) == unchecked((int)0x3f19999c) &&
Marshal.ReadInt32(averageDevice, 0xb0) == unchecked((int)0x3f19999c),
"native class-9 adjustment multiplies by the stored 1/6 constant");
for (int i = 1; i < 6; i++) {
Expect(Marshal.ReadInt32(averageDevice, 0x98 + i * 4) == FloatBits(1.0f) &&
Marshal.ReadInt32(averageDevice, 0xb0 + i * 4) == 0,
"native class-9 constant-average leaves full rows unchanged");
}
Console.WriteLine("native-control-class9-average: first=0x3f19999c delta=0x3f19999c");
}
GC.KeepAlive(rate);
GC.KeepAlive(update);
GC.KeepAlive(adjust);
}
private static void RunNativeControlGenericDefaultBudgetCase(IntPtr module) {
NativeControlOwnerConstructor constructOwner = (NativeControlOwnerConstructor)
Marshal.GetDelegateForFunctionPointer(IntPtr.Add(module, ControlOwnerConstructorRva),
typeof(NativeControlOwnerConstructor));
NativeControlResourceDeviceConstructor constructDefault = (NativeControlResourceDeviceConstructor)
Marshal.GetDelegateForFunctionPointer(IntPtr.Add(module, ControlResourceTag25ConstructorRva),
typeof(NativeControlResourceDeviceConstructor));
NativeControlResourceDeviceRate rate = (NativeControlResourceDeviceRate)
Marshal.GetDelegateForFunctionPointer(IntPtr.Add(module, ControlResourceDefaultRateRva),
typeof(NativeControlResourceDeviceRate));
NativeControlResourceTag9Update update = (NativeControlResourceTag9Update)
Marshal.GetDelegateForFunctionPointer(IntPtr.Add(module, ControlResourceDefaultUpdateRva),
typeof(NativeControlResourceTag9Update));
NativeControlProviderRowConstructor constructProvider = (NativeControlProviderRowConstructor)
Marshal.GetDelegateForFunctionPointer(IntPtr.Add(module, ControlProviderRowConstructorRva),
typeof(NativeControlProviderRowConstructor));
using (Fixture fixture = NewFixture()) {
IntPtr owner = fixture.Allocate(0x664);
Expect(constructOwner(owner, IntPtr.Zero, 4) == owner,
"native generic-budget owner constructor");
IntPtr ndp = fixture.Allocate(0x4c);
Marshal.WriteInt32(ndp, 4, FloatBits(100.0f));
IntPtr provider = fixture.Allocate(0x2c);
constructProvider(provider, ndp);
Marshal.WriteInt32(provider, 0x14, FloatBits(0.4f));
Marshal.WriteIntPtr(owner, 0x55c, provider);
Marshal.WriteInt32(owner, 0x560, 1);
IntPtr device = fixture.Allocate(0xa4);
Expect(constructDefault(device) == device, "native generic default-family constructor");
IntPtr vtable = Marshal.ReadIntPtr(device);
Expect(vtable == IntPtr.Add(module, ControlResourceTag25VtableRva) &&
Marshal.ReadIntPtr(vtable, 0x14) == IntPtr.Add(module, ControlResourceDefaultRateRva) &&
Marshal.ReadIntPtr(vtable, 0x18) == IntPtr.Add(module, ControlResourceDefaultUpdateRva),
"generic default-family vtable installs native rate/update callbacks");
Expect(Marshal.ReadInt32(device, 0x50) == 5 &&
Marshal.ReadInt32(device, 0x4c) == FloatBits(1.0f),
"generic default-family constructor defaults");
IntPtr descriptor = fixture.Allocate(0xb4);
Marshal.WriteInt32(descriptor, 0, 12);
Marshal.WriteInt32(descriptor, 0x20, FloatBits(0.2f));
Marshal.WriteIntPtr(device, 0x3c, owner);
Marshal.WriteIntPtr(device, 0x44, IntPtr.Add(owner, 4));
Marshal.WriteIntPtr(device, 0x48, descriptor);
Expect(FloatBits(rate(device, 0.5f)) == FloatBits(-0.1f),
"generic native callback rate is negative descriptor rate times dt");
update(device, 0.5f, 0.375f);
Expect(Marshal.ReadInt32(device, 0x4c) == FloatBits(0.375f),
"generic native callback stores allocation multiplier");
Console.WriteLine("native-control-generic-default-budget: controlHash=" + ExpectedControlSha256 +
" constructorRva=0x20800 vtable=0x3c448 rateRva=0x21860 updateRva=0x21890" +
" descriptor=12 B=0.2 dt=0.5 rate=-0.1 allocation=0.375");
}
GC.KeepAlive(rate);
GC.KeepAlive(update);
}
private static void RunNativeControlResourceBudgetTag15Case(IntPtr module) {
RunNativeControlResourceBudgetEmptyCases(module);
NativeControlOwnerConstructor constructOwner = (NativeControlOwnerConstructor)Marshal.GetDelegateForFunctionPointer(
@@ -2533,6 +2733,10 @@ internal static class BehaviorDistributorTickOracle {
0x3cbd8, 0x29940, applyOverride);
RunNativeControlOverrideReceiverCase(module, 3, 0xa4, 0x20800,
0x3c448, ControlResourceNoOpStringPairRva, applyOverride);
RunNativeControlOverrideReceiverCase(module, 12, 0xa4, 0x20800,
0x3c448, ControlResourceNoOpStringPairRva, applyOverride);
RunNativeControlOverrideReceiverCase(module, 13, 0xa4, 0x20800,
0x3c448, ControlResourceNoOpStringPairRva, applyOverride);
GC.KeepAlive(applyOverride);
}
@@ -2546,14 +2750,21 @@ internal static class BehaviorDistributorTickOracle {
"tag-" + tag + " vtable reader resolves to its native implementation");
Expect(Marshal.ReadIntPtr(expectedVtable, 0x24) == IntPtr.Add(module, stringPairRva),
"tag-" + tag + " vtable string-pair slot matches its native callback");
if (vtableRva == 0x3c448 || vtableRva == 0x3c720 ||
vtableRva == 0x3c800 || vtableRva == 0x3c528) {
Expect(Marshal.ReadIntPtr(expectedVtable, 0x14) == IntPtr.Add(module, ControlResourceDefaultRateRva) &&
Marshal.ReadIntPtr(expectedVtable, 0x18) == IntPtr.Add(module, ControlResourceDefaultUpdateRva),
"tag-" + tag + " vtable uses the shared default budget callbacks");
}
using (Fixture fixture = NewFixture()) {
IntPtr owner = fixture.Allocate(0x5c8);
IntPtr deviceArray = fixture.Allocate(2 * IntPtr.Size);
IntPtr targetDevice = (tag == 3 || tag == 5) ? IntPtr.Zero : fixture.Allocate(objectSize);
bool defaultFactory = tag == 3 || tag == 5 || tag == 12 || tag == 13;
IntPtr targetDevice = defaultFactory ? IntPtr.Zero : fixture.Allocate(objectSize);
bool variableTail = tag == 2 || tag == 3 || tag == 4 || tag == 5 || tag == 8 || tag == 10 || tag == 21 || tag == 27;
IntPtr typedRecord = fixture.Allocate(variableTail ? 0xc0 : 0xb4);
if (tag == 3 || tag == 5) {
// Tag 3 follows the default factory; case 5 also assigns a derived vtable.
if (defaultFactory) {
// Tags 3/12/13 follow the default factory; case 5 assigns a derived vtable.
Marshal.WriteIntPtr(owner, 0x5bc, deviceArray);
Marshal.WriteInt32(owner, 0x5c4, 2);
Marshal.WriteInt32(typedRecord, 0, tag);
@@ -2573,6 +2784,10 @@ internal static class BehaviorDistributorTickOracle {
Marshal.ReadInt32(targetDevice, 0x4c) == FloatBits(1.0f),
"native extended factory constructor defaults");
}
if (tag == 12 || tag == 13)
Expect(Marshal.ReadInt32(targetDevice, 0x50) == 5 &&
Marshal.ReadInt32(targetDevice, 0x4c) == FloatBits(1.0f),
"native default-factory tag " + tag + " constructor defaults");
Marshal.WriteIntPtr(deviceArray, 0, targetDevice);
Marshal.WriteIntPtr(owner, 0x5bc, deviceArray);
Marshal.WriteInt32(owner, 0x5c0, 1);