Struct TensorChecksumEngine 

pub struct TensorChecksumEngine {
    pub records: HashMap<u64, ChecksumRecord>,
    pub stats: ChecksumEngineStats,
}

Stateful engine that manages per-tensor checksum records.

Thread Safety

TensorChecksumEngine is not Send/Sync by default because it owns a HashMap. Wrap in Arc<Mutex<…>> or parking_lot::Mutex for shared access across threads.

Examples

use ipfrs_tensorlogic::tensor_checksum::{ChecksumAlgorithm, TensorChecksumEngine};

let mut engine = TensorChecksumEngine::new();
let data = b"layer weights";

engine.compute(42, "fc1".to_string(), data, ChecksumAlgorithm::Adler32, 1_000_000);

assert_eq!(engine.verify(42, data), Some(true));
assert_eq!(engine.verify(99, data), None); // unknown id

assert!(engine.remove(42));
assert!(!engine.remove(42)); // already gone

Fields

records: HashMap<u64, ChecksumRecord>

Per-tensor checksum records, keyed by tensor_id.

stats: ChecksumEngineStats

Cumulative operational statistics.

Implementations

impl TensorChecksumEngine

pub fn new() -> Self

Create a new, empty engine with zeroed statistics.

pub fn compute( &mut self, tensor_id: u64, layer_name: String, data: &[u8], algorithm: ChecksumAlgorithm, now_secs: u64, ) -> &ChecksumRecord

Compute a checksum for data, store the resulting ChecksumRecord, increment stats.total_computed, and return a reference to the record.

If a record already exists for tensor_id, it is replaced.

Parameters

• tensor_id — Unique identifier for the tensor.
• layer_name — Human-readable layer name (e.g. "encoder.layer1").
• data — Raw bytes of the tensor payload.
• algorithm — Checksum algorithm to use.
• now_secs — Current time as Unix seconds (caller-supplied for determinism in tests and embedded environments).

pub fn verify(&mut self, tensor_id: u64, data: &[u8]) -> Option<bool>

Verify the stored checksum for tensor_id against data.

• Returns None if tensor_id is not registered.
• Returns Some(true) if the data matches.
• Returns Some(false) if the data does not match.

Both total_verified and (on failure) total_failures are updated.

pub fn remove(&mut self, tensor_id: u64) -> bool

Remove the record for tensor_id.

Returns true if the record existed and was removed, false if no record was found for the given id.

pub fn stats(&self) -> &ChecksumEngineStats

Return a reference to the current engine statistics.

Trait Implementations

impl Default for TensorChecksumEngine

fn default() -> Self

Returns the “default value” for a type.