registry.rs

 1use parking_lot::RwLock;
 2
 3use crate::adapters::{DebugAdapter, DebugAdapterName};
 4use std::{collections::BTreeMap, sync::Arc};
 5
 6#[derive(Default)]
 7struct DapRegistryState {
 8    adapters: BTreeMap<DebugAdapterName, Arc<dyn DebugAdapter>>,
 9}
10
11#[derive(Clone, Default)]
12/// Stores available debug adapters.
13pub struct DapRegistry(Arc<RwLock<DapRegistryState>>);
14
15impl DapRegistry {
16    pub fn add_adapter(&self, adapter: Arc<dyn DebugAdapter>) {
17        let name = adapter.name();
18        let _previous_value = self.0.write().adapters.insert(name, adapter);
19        debug_assert!(
20            _previous_value.is_none(),
21            "Attempted to insert a new debug adapter when one is already registered"
22        );
23    }
24    pub fn adapter(&self, name: &str) -> Option<Arc<dyn DebugAdapter>> {
25        self.0.read().adapters.get(name).cloned()
26    }
27    pub fn enumerate_adapters(&self) -> Vec<DebugAdapterName> {
28        self.0.read().adapters.keys().cloned().collect()
29    }
30
31    #[cfg(any(test, feature = "test-support"))]
32    pub fn fake() -> Self {
33        use crate::FakeAdapter;
34
35        let register = Self::default();
36        register.add_adapter(Arc::new(FakeAdapter::new()));
37        register
38    }
39}