modulecheck-parsing:kotlin-compiler:impl/modulecheck.parsing.kotlin.compiler.impl/SafeAnalysisResultAccessImpl

SafeAnalysisResultAccessImpl

class SafeAnalysisResultAccessImpl @Inject constructor(val projectCache: ProjectCache) : SafeAnalysisResultAccess(source)

The only implementation of SafeAnalysisResultAccess

Constructors

SafeAnalysisResultAccessImpl

@Inject

constructor(projectCache: ProjectCache)

Types

private class DifferentList(delegate: List<SafeAnalysisResultAccessImpl.PendingRequest>) : List<SafeAnalysisResultAccessImpl.PendingRequest>

This is a hack to get around the de-duping behavior of a StateFlow. Two lists with identical contents will never be equal, so

internal data class PendingRequest(val requester: HasAnalysisResult, val dependencies: Set<HasAnalysisResult>) : Comparable<SafeAnalysisResultAccessImpl.PendingRequest>

Properties

private val locks: MutableMap<HasAnalysisResult, Boolean>

private val locksCacheLock: Mutex

private val projectCache: ProjectCache

private val queue: MutableStateFlow<SafeAnalysisResultAccessImpl.DifferentList>

Functions

private suspend fun addToQueue(pendingRequest: SafeAnalysisResultAccessImpl.PendingRequest, sort: Boolean)

asDifferentList

private fun List<SafeAnalysisResultAccessImpl.PendingRequest>.asDifferentList(): SafeAnalysisResultAccessImpl.DifferentList

private fun maybeLockAll(pendingRequest: SafeAnalysisResultAccessImpl.PendingRequest): Boolean

upstreamEnvironments

private suspend fun SourceSetName.upstreamEnvironments(project: McProject): List<KotlinEnvironment>

private suspend fun <T> withLeases(pendingRequest: SafeAnalysisResultAccessImpl.PendingRequest, action: suspend () -> T): T

open suspend override fun <T> withLeases(requester: HasAnalysisResult, projectPath: ProjectPath, sourceSetName: SourceSetName, action: suspend (Collection<HasAnalysisResult>) -> T): T

Suspends until all dependency module descriptors are available for use, then acquires locks for all of them and performs action. No other project/source set will be able to read from those analysis results, binding contexts, or module descriptors until action has completed.