codetether-agent 4.7.0-a-002.4

A2A-native AI coding agent for the CodeTether ecosystem
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

//! Per-agent execution state for spawned child sessions.

use std::{collections::HashSet, sync::Mutex};

lazy_static::lazy_static! {
    static ref RUNNING: Mutex<HashSet<String>> = Mutex::new(HashSet::new());
}

/// Guard representing the active message run for one sub-agent.
pub(super) struct AgentRunGuard {
    name: String,
}

impl Drop for AgentRunGuard {
    fn drop(&mut self) {
        if let Ok(mut running) = RUNNING.lock() {
            running.remove(&self.name);
        }
    }
}

/// Tries to mark a sub-agent as busy.
pub(super) fn try_start(name: &str) -> Option<AgentRunGuard> {
    let mut running = RUNNING.lock().ok()?;
    if !running.insert(name.to_string()) {
        return None;
    }
    Some(AgentRunGuard {
        name: name.to_string(),
    })
}