src/vs/platform/agentHost/node/agentHostChangesetStateCache.ts
126 LOC · 112 covered · 14 uncovered · 29 ranges · 3131 concepts · 10 introducers · 1399 tests
File neighbourhood
The centred file is linked to every concept that introduces one of its ranges, every test that runs code from the file, and the gray connector concepts standing between those tests and the file's own introducer concepts. Undirected links join concepts to every file where they introduce source and concepts to the tests they introduce; arrows show specialization between the displayed concepts and bridge only concepts omitted from this view. Concept colors match the source ranges below; connector concepts have no source color and are shown in gray.
Focused file, its introducer and connector concepts, their introduced files, and tests that run code from the file
In the embedded map, ordinary wheel input scrolls the page; use the visible controls to zoom and drag to pan. Open the full-screen map for canvas navigation: wheel pans, Ctrl/Command plus wheel zooms, and arrow keys pan when this region is focused. On touch screens, open the full-screen map to pan or pinch. If JavaScript or WebGL is unavailable, use the related-file, concept, and source links on this page.
Graph controls are ready.
Interactive rendering requires JavaScript and WebGL. Use the related-file, concept, and source links on this page while the interactive map is unavailable.
/*---------------------------------------------------------------------------------------------
agentHostStateManager.ts ×60
* Copyright (c) Microsoft Corporation. All rights reserved.
* Licensed under the MIT License. See License.txt in the project root for license information.
*--------------------------------------------------------------------------------------------*/
import { LinkedMap, Touch } from '../../../base/common/map.js';
import { ChangesetStatus, type ChangesetState, type URI } from '../common/state/sessionState.js';
/**
* Default number of expanded changeset states kept hot in memory.
*
* This cache only stores the subscribable `ChangesetState` payloads. The
* lightweight catalogue on `SessionSummary.changesets` remains on the session
* summary, and static changesets can be rehydrated from persisted metadata or
* recomputed on demand. The limit is intentionally a soft cap: subscribed or
* actively-computing changesets may pin the cache above this value until they
* become evictable.
*/
const DEFAULT_CHANGESET_STATE_SOFT_LIMIT = 500;
export interface IAgentHostChangesetStateRetentionOptions {
/**
* Number of expanded changeset states kept hot in memory. The limit is soft:
* entries for which {@link canEvict} returns false may temporarily keep the
* cache above this value.
*/
readonly softLimit?: number;
/**
* Returns whether a changeset state can be silently evicted from the cache.
* Production callers should provide this from `AgentService`, which owns
* protocol subscription refcounts and can ask the changeset service about
* active producers. Return false for changesets that are subscribed or have
* an active producer that may still publish into the changeset URI.
*/
readonly canEvict?: (changeset: URI) => boolean;
}
/**
* Owns the memory policy for expanded changeset states.
*
* The state manager owns protocol sequencing and reducer application; this
* helper owns the cache mechanics needed to keep dormant changesets bounded.
* Eviction here is deliberately silent: protocol-visible teardown still goes
* through `AgentHostStateManager.disposeChangeset`, which emits
* `ChangesetCleared` before removing state.
*/
export class AgentHostChangesetStateCache {
private readonly _states = new Map<string, ChangesetState>();
private readonly _lru = new LinkedMap<string, true>();
private readonly _softLimit: number;
private readonly _canEvict: (changeset: URI) => boolean;
constructor(options: IAgentHostChangesetStateRetentionOptions = {}) {
this._softLimit = Math.max(0, options.softLimit ?? DEFAULT_CHANGESET_STATE_SOFT_LIMIT);
agentHostStateManager.ts ×4
this._canEvict = options.canEvict ?? (() => true);
}
keys(): IterableIterator<string> {
}
has(changeset: URI): boolean {
}
get(changeset: URI): ChangesetState | undefined {
return this._states.get(changeset);
}
set(changeset: URI, state: ChangesetState): void {
this._touch(changeset);
this._evictIfOverLimit();
}
delete(changeset: URI): void {
this._lru.delete(changeset);
}
register(changeset: URI, initialStatus: ChangesetStatus = ChangesetStatus.Computing): void {
return;
}
}
/** Re-runs eviction after external liveness changes, such as unsubscribe or compute completion. */
trimEvictableEntries(): void {
}
private _touch(changeset: URI): void {
}
private _evictIfOverLimit(): void {
for (const changeset of [...this._lru.keys()]) {
if (this._canEvict(changeset)) {
this.delete(changeset);
}
}
return;
}
for (const changeset of [...this._lru.keys()]) {
return;
}
if (!this._states.has(changeset)) {
this._lru.delete(changeset);
continue;
}
if (this._canEvict(changeset)) {
this.delete(changeset);
}