style: cargo fmt --all
Formatting only. cargo fmt --check was already failing on main (accel SIMD kernels, agent, format, migrate, bench); CI now enforces it. Co-Authored-By: Claude Fable 5.1 <[email protected]>
This commit is contained in:
co-authored by
Claude Fable 5.1
parent
bbe1baa208
commit
a3f7c6fe89
@@ -437,7 +437,11 @@ mod tests {
|
||||
fn rate_anomaly_names_offending_session() {
|
||||
let mut det = WriteAnomalyDetector::new(cfg());
|
||||
for i in 0..11 {
|
||||
det.record_write(event(1.0 + i as f64 * 0.1, "flood-session", MemorySource::User));
|
||||
det.record_write(event(
|
||||
1.0 + i as f64 * 0.1,
|
||||
"flood-session",
|
||||
MemorySource::User,
|
||||
));
|
||||
}
|
||||
let alert = det.check_rate_anomaly().unwrap();
|
||||
assert!(
|
||||
@@ -454,11 +458,19 @@ mod tests {
|
||||
let mut det = WriteAnomalyDetector::new(cfg());
|
||||
// 5 sessions with 1 write each (below any per-session limit)...
|
||||
for i in 0..5 {
|
||||
det.record_write(event(1.0 + i as f64 * 0.1, "minor-session", MemorySource::User));
|
||||
det.record_write(event(
|
||||
1.0 + i as f64 * 0.1,
|
||||
"minor-session",
|
||||
MemorySource::User,
|
||||
));
|
||||
}
|
||||
// ...plus one session responsible for the majority of the flood.
|
||||
for i in 0..8 {
|
||||
det.record_write(event(2.0 + i as f64 * 0.1, "major-session", MemorySource::User));
|
||||
det.record_write(event(
|
||||
2.0 + i as f64 * 0.1,
|
||||
"major-session",
|
||||
MemorySource::User,
|
||||
));
|
||||
}
|
||||
let alert = det.check_rate_anomaly().unwrap();
|
||||
assert!(
|
||||
|
||||
@@ -799,7 +799,12 @@ mod tests {
|
||||
#[test]
|
||||
fn test_access_memory_reactivation() {
|
||||
let mut engine = ConsolidationEngine::new(ConsolidationConfig::default());
|
||||
let id = engine.add_memory("chunk".to_string(), unit_vec(4, 0), UntrustedSource::User, 0.0);
|
||||
let id = engine.add_memory(
|
||||
"chunk".to_string(),
|
||||
unit_vec(4, 0),
|
||||
UntrustedSource::User,
|
||||
0.0,
|
||||
);
|
||||
|
||||
engine.access_memory(id, 5000.0);
|
||||
let rec = engine.get_by_id(id).unwrap();
|
||||
|
||||
@@ -427,7 +427,10 @@ impl HDF5Memory {
|
||||
if self.provenance.get(record_id as u64).is_none() {
|
||||
return; // nothing recorded yet this session — nothing to check
|
||||
}
|
||||
if !self.provenance.verify_integrity(record_id as u64, current_chunk) {
|
||||
if !self
|
||||
.provenance
|
||||
.verify_integrity(record_id as u64, current_chunk)
|
||||
{
|
||||
self.anomaly_alerts.push(anomaly::AnomalyAlert {
|
||||
severity: anomaly::Severity::High,
|
||||
message: format!(
|
||||
|
||||
@@ -1228,8 +1228,7 @@ mod tests {
|
||||
drop(wal); // simulate a restart without ever truncating the WAL
|
||||
|
||||
let mut wal2 = WalFile::open(&wal_path).unwrap();
|
||||
wal2.append_save(&make_wal_entry("second", &[2.0]))
|
||||
.unwrap();
|
||||
wal2.append_save(&make_wal_entry("second", &[2.0])).unwrap();
|
||||
drop(wal2);
|
||||
|
||||
let entries = WalFile::read_entries(&wal_path).unwrap();
|
||||
|
||||
Reference in New Issue
Block a user