pub(super) struct CurrentDepGraph<D: Deps> {
    encoder: Steal<GraphEncoder<D>>,
    new_node_to_index: Sharded<FxHashMap<DepNode, DepNodeIndex>>,
    prev_index_to_index: Lock<IndexVec<SerializedDepNodeIndex, Option<DepNodeIndex>>>,
    fingerprints: Lock<IndexVec<DepNodeIndex, Option<Fingerprint>>>,
    forbidden_edge: Option<EdgeFilter>,
    anon_id_seed: Fingerprint,
    total_read_count: AtomicU64,
    total_duplicate_read_count: AtomicU64,
    node_intern_event_id: Option<EventId>,
}
Expand description

CurrentDepGraph stores the dependency graph for the current session. It will be populated as we run queries or tasks. We never remove nodes from the graph: they are only added.

The nodes in it are identified by a DepNodeIndex. We avoid keeping the nodes in memory. This is important, because these graph structures are some of the largest in the compiler.

For this reason, we avoid storing DepNodes more than once as map keys. The new_node_to_index map only contains nodes not in the previous graph, and we map nodes in the previous graph to indices via a two-step mapping. SerializedDepGraph maps from DepNode to SerializedDepNodeIndex, and the prev_index_to_index vector (which is more compact and faster than using a map) maps from SerializedDepNodeIndex to DepNodeIndex.

This struct uses three locks internally. The data, new_node_to_index, and prev_index_to_index fields are locked separately. Operations that take a DepNodeIndex typically just access the data field.

We only need to manipulate at most two locks simultaneously: new_node_to_index and data, or prev_index_to_index and data. When manipulating both, we acquire new_node_to_index or prev_index_to_index first, and data second.

Fields§

§encoder: Steal<GraphEncoder<D>>§new_node_to_index: Sharded<FxHashMap<DepNode, DepNodeIndex>>§prev_index_to_index: Lock<IndexVec<SerializedDepNodeIndex, Option<DepNodeIndex>>>§fingerprints: Lock<IndexVec<DepNodeIndex, Option<Fingerprint>>>

This is used to verify that fingerprints do not change between the creation of a node and its recomputation.

§forbidden_edge: Option<EdgeFilter>

Used to trap when a specific edge is added to the graph. This is used for debug purposes and is only active with debug_assertions.

§anon_id_seed: Fingerprint

Anonymous DepNodes are nodes whose IDs we compute from the list of their edges. This has the beneficial side-effect that multiple anonymous nodes can be coalesced into one without changing the semantics of the dependency graph. However, the merging of nodes can lead to a subtle problem during red-green marking: The color of an anonymous node from the current session might “shadow” the color of the node with the same ID from the previous session. In order to side-step this problem, we make sure that anonymous NodeIds allocated in different sessions don’t overlap. This is implemented by mixing a session-key into the ID fingerprint of each anon node. The session-key is just a random number generated when the DepGraph is created.

§total_read_count: AtomicU64

These are simple counters that are for profiling and debugging and only active with debug_assertions.

§total_duplicate_read_count: AtomicU64§node_intern_event_id: Option<EventId>

The cached event id for profiling node interning. This saves us from having to look up the event id every time we intern a node which may incur too much overhead. This will be None if self-profiling is disabled.

Implementations§

source§

impl<D: Deps> CurrentDepGraph<D>

source

fn new( profiler: &SelfProfilerRef, prev_graph_node_count: usize, encoder: FileEncoder, record_graph: bool, record_stats: bool ) -> Self

source

fn record_edge( &self, dep_node_index: DepNodeIndex, key: DepNode, fingerprint: Fingerprint )

source

fn intern_new_node( &self, profiler: &SelfProfilerRef, key: DepNode, edges: EdgesVec, current_fingerprint: Fingerprint ) -> DepNodeIndex

Writes the node to the current dep-graph and allocates a DepNodeIndex for it. Assumes that this is a node that has no equivalent in the previous dep-graph.

source

fn intern_node( &self, profiler: &SelfProfilerRef, prev_graph: &SerializedDepGraph, key: DepNode, edges: EdgesVec, fingerprint: Option<Fingerprint>, print_status: bool ) -> (DepNodeIndex, Option<(SerializedDepNodeIndex, DepNodeColor)>)

source

fn promote_node_and_deps_to_current( &self, profiler: &SelfProfilerRef, prev_graph: &SerializedDepGraph, prev_index: SerializedDepNodeIndex ) -> DepNodeIndex

source

fn debug_assert_not_in_new_nodes( &self, prev_graph: &SerializedDepGraph, prev_index: SerializedDepNodeIndex )

Auto Trait Implementations§

§

impl<D> !RefUnwindSafe for CurrentDepGraph<D>

§

impl<D> Send for CurrentDepGraph<D>where D: Send,

§

impl<D> !Sync for CurrentDepGraph<D>

§

impl<D> Unpin for CurrentDepGraph<D>where D: Unpin,

§

impl<D> !UnwindSafe for CurrentDepGraph<D>

Blanket Implementations§

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<Tcx, T> Value<Tcx> for Twhere Tcx: DepContext,

source§

default fn from_cycle_error( tcx: Tcx, cycle: &[QueryInfo], _guar: ErrorGuaranteed ) -> T

Layout§

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 480 bytes