Struct WatcherState 

pub struct WatcherState {
    pub Entries: Arc<Mutex<HashMap<String, WatcherEntry>>>,
    pub EventSender: UnboundedSender<WatchEvent>,
    pub DedupIndex: Arc<Mutex<HashMap<(PathBuf, bool, Option<String>), String>>>,
    pub Aliases: Arc<Mutex<HashMap<String, Vec<String>>>>,
    pub HandleToPrimary: Arc<Mutex<HashMap<String, String>>>,
}

Lazily-initialised process-wide state for file watching. Instances of the event-forwarder task are singletons keyed on the MountainEnvironment handle. Access through WatcherState::Get.

Fields

Entries: Arc<Mutex<HashMap<String, WatcherEntry>>>

EventSender: UnboundedSender<WatchEvent>

DedupIndex: Arc<Mutex<HashMap<(PathBuf, bool, Option<String>), String>>>

Maps (root, recursive, pattern) to the primary handle that owns the live OS watcher. Subsequent registrations matching the same triple are aliased to the primary; only the primary creates a notify::Watcher.

Aliases: Arc<Mutex<HashMap<String, Vec<String>>>>

Reverse index: primary handle → all aliased handles. When the forwarder task gets an event for a primary, it fans the same event out to every aliased handle so each extension’s vscode.workspace.createFileSystemWatcher callback fires once.

HandleToPrimary: Arc<Mutex<HashMap<String, String>>>

Reverse lookup for unregister: any handle (primary or alias) → its primary. Lets UnregisterWatcher clean up alias entries without scanning the entire Aliases map.

Implementations

impl WatcherState

pub fn Get(env: &MountainEnvironment) -> Arc<WatcherState>

Obtain (or create) the global WatcherState. The forwarder task is spawned on first access. Must be called from within a tokio runtime.