llm_agent_runtime/
util.rs

1//! Shared utility functions used across modules.
2
3/// Acquire a mutex guard, recovering from a poisoned mutex rather than
4/// propagating an error.  A panicking thread does not permanently break a
5/// shared resource; we simply take ownership of the inner value and log a
6/// warning so that contention hot-spots can be identified.
7pub fn recover_lock<'a, T>(
8    result: std::sync::LockResult<std::sync::MutexGuard<'a, T>>,
9    ctx: &str,
10) -> std::sync::MutexGuard<'a, T>
11where
12    T: ?Sized,
13{
14    match result {
15        Ok(guard) => guard,
16        Err(poisoned) => {
17            tracing::warn!("mutex poisoned in {ctx}, recovering inner value");
18            poisoned.into_inner()
19        }
20    }
21}
22
23/// Acquire a mutex guard with timing and poison recovery.
24///
25/// Logs a warning if acquisition takes > 5 ms (contention hot-spot indicator).
26/// Recovers from a poisoned mutex rather than propagating the error.
27pub fn timed_lock<'a, T>(mutex: &'a std::sync::Mutex<T>, ctx: &str) -> std::sync::MutexGuard<'a, T>
28where
29    T: ?Sized,
30{
31    let start = std::time::Instant::now();
32    let result = mutex.lock();
33    let elapsed = start.elapsed();
34    if elapsed > std::time::Duration::from_millis(5) {
35        tracing::warn!(
36            duration_ms = elapsed.as_millis(),
37            ctx = ctx,
38            "slow mutex acquisition"
39        );
40    }
41    match result {
42        Ok(guard) => guard,
43        Err(poisoned) => {
44            tracing::warn!("mutex poisoned in {ctx}, recovering inner value");
45            poisoned.into_inner()
46        }
47    }
48}
49
50/// Simple djb2 hash of a byte string — collision-resistant but not
51/// cryptographic. Used to produce stable, unique file-name suffixes.
52pub fn djb2(s: &str) -> u64 {
53    let mut h: u64 = 5381;
54    for b in s.bytes() {
55        h = h.wrapping_mul(33).wrapping_add(b as u64);
56    }
57    h
58}
llm_agent_runtime/util.rs

llm_agent_runtime/
util.rs
