Method observe_hook_event

core/src/ahp/runtime_state.rs:87–111

(&self, event: &HookEvent)

    }

    pub(super) fn observe_hook_event(&self, event: &HookEvent) {
        if self.runtime_tokens_seen.load(Ordering::Relaxed) {
            return;
        }

        match event {
            HookEvent::GenerateEnd(e) => {
                let tokens = e.usage.total_tokens.max(0);
                let _ = self.hook_token_fallback.fetch_update(
                    Ordering::Relaxed,
                    Ordering::Relaxed,
                    |current| Some(current.saturating_add(tokens)),
                );
            }
            HookEvent::PostResponse(e) => {
                let tokens = e.usage.total_tokens.max(0);
                let _ = self.hook_token_fallback.fetch_update(
                    Ordering::Relaxed,
                    Ordering::Relaxed,
                    |current| Some(current.max(tokens)),
                );
            }
            _ => {}
        }
    }

    pub(super) fn clear_runtime_actions(&self) {
        write_or_recover(&self.active_tools).clear();