ConcurrentSet

CommandLine\TouchedFileLogger.cs (2)

23_readFiles = new ConcurrentSet<string>(); 24_writtenFiles = new ConcurrentSet<string>();

DiagnosticAnalyzer\AnalyzerDriver.cs (3)

379_programmaticSuppressions = _hasDiagnosticSuppressors ? new ConcurrentSet<Suppression>() : null; 380_diagnosticsProcessedForProgrammaticSuppressions = _hasDiagnosticSuppressors ? new ConcurrentSet<Diagnostic>(ReferenceEqualityComparer.Instance) : null; 465var suppressedDiagnosticIds = trackSuppressedDiagnosticIds ? new ConcurrentSet<string>() : null;

DiagnosticAnalyzer\CompilationWithAnalyzers.cs (1)

46private readonly ConcurrentSet<Diagnostic> _exceptionDiagnostics = new ConcurrentSet<Diagnostic>();

Compilation\CSharpCompilation.cs (1)

2750builder.DependenciesBag is object ? new ConcurrentSet<AssemblySymbol>() : null);

Compiler\ClsComplianceChecker.cs (1)

75var queue = new BindingDiagnosticBag(diagnostics.DiagnosticBag, diagnostics.AccumulatesDependencies ? new ConcurrentSet<AssemblySymbol>() : null);

Emitter\Model\PEModuleBuilder.cs (1)

33private readonly ConcurrentSet<TypeSymbol> _reportedErrorTypesMap = new ConcurrentSet<TypeSymbol>();

Symbols\Compilation_UsedAssemblies.cs (2)

70var diagnostics = new BindingDiagnosticBag(DiagnosticBag.GetInstance(), new ConcurrentSet<AssemblySymbol>()); 247Interlocked.CompareExchange(ref _lazyUsedAssemblyReferences, new ConcurrentSet<AssemblySymbol>(), null);

Symbols\Source\SourceAssemblySymbol.cs (3)

103private readonly ConcurrentSet<FieldSymbol> _unreadFields = new ConcurrentSet<FieldSymbol>(); 110internal ConcurrentSet<TypeSymbol> TypesReferencedInExternalMethods = new ConcurrentSet<TypeSymbol>(); 1172Interlocked.CompareExchange(ref _lazyOmittedAttributeIndices, new ConcurrentSet<int>(), null);

Diagnostics\CommonDiagnosticAnalyzers.cs (6)

672internal readonly ConcurrentSet<ISymbol> CallbackSymbols = new(); 1039var pendingSymbols = new ConcurrentSet<INamedTypeSymbol>(); 1772SymbolsStarted = new ConcurrentSet<ISymbol>(); 1869var symbolsEnded = new ConcurrentSet<ISymbol>(); 2257_symbolCallbacks = new ConcurrentSet<ISymbol>(); 2590CanceledCompilations = new ConcurrentSet<Compilation>();

Compilation\ClsComplianceChecker.vb (1)

73Dim queue = New BindingDiagnosticBag(diagnostics.DiagnosticBag, New ConcurrentSet(Of AssemblySymbol))

Compilation\MethodCompiler.vb (1)

348Dim processedSymbols As New ConcurrentSet(Of Symbol)(ReferenceEqualityComparer.Instance)

Compilation\VisualBasicCompilation.vb (1)

2194If(builder.AccumulatesDependencies, New ConcurrentSet(Of AssemblySymbol), Nothing))

Emit\SymbolTranslator.vb (2)

21Private ReadOnly _reportedErrorTypesMap As New ConcurrentSet(Of TypeSymbol)() 43Interlocked.CompareExchange(_addedEmbeddedSymbols, New ConcurrentSet(Of Symbol)(ReferenceEqualityComparer.Instance), Nothing)

Symbols\EmbeddedSymbols\EmbeddedSymbolManager.SymbolsCollection.vb (1)

148MarkSymbolAsReferenced(symbol, New ConcurrentSet(Of Symbol)(ReferenceEqualityComparer.Instance))

Symbols\UsedAssemblies.vb (2)

45Dim diagnostics = New BindingDiagnosticBag(DiagnosticBag.GetInstance(), New ConcurrentSet(Of AssemblySymbol)()) 196Interlocked.CompareExchange(_lazyUsedAssemblyReferences, New ConcurrentSet(Of AssemblySymbol)(), Nothing)

CommandLine\TouchedFileLogger.cs (4)

18private ConcurrentSet<string> _readFiles; 19private ConcurrentSet<string> _writtenFiles; 67var readFiles = Interlocked.Exchange( 92var writtenFiles = Interlocked.Exchange(

DiagnosticAnalyzer\AnalyzerDriver.cs (13)

43private readonly ConcurrentSet<Suppression>? _programmaticSuppressions; 48private readonly ConcurrentSet<Diagnostic>? _diagnosticsProcessedForProgrammaticSuppressions; 273private ConcurrentSet<string>? _lazySuppressedDiagnosticIdsForUnsuppressedAnalyzers; 280private ConcurrentSet<string> SuppressedDiagnosticIdsForUnsuppressedAnalyzers 389private void Initialize(AnalyzerExecutor analyzerExecutor, DiagnosticQueue diagnosticQueue, CompilationData compilationData, ConcurrentSet<string>? suppressedDiagnosticIds, CancellationToken cancellationToken) 465var suppressedDiagnosticIds = trackSuppressedDiagnosticIds ? new ConcurrentSet<string>() : null; 625/// <remarks>Driver must be initialized before invoking this method, i.e. <see cref="Initialize(AnalyzerExecutor, DiagnosticQueue, CompilationData, ConcurrentSet{string}, CancellationToken)"/> method must have been invoked and <see cref="WhenInitializedTask"/> must be non-null.</remarks> 657/// <remarks>Driver must be initialized before invoking this method, i.e. <see cref="Initialize(AnalyzerExecutor, DiagnosticQueue, CompilationData, ConcurrentSet{string}, CancellationToken)"/> method must have been invoked and <see cref="WhenInitializedTask"/> must be non-null.</remarks> 1076static ImmutableDictionary<Diagnostic, ProgrammaticSuppressionInfo> createProgrammaticSuppressionsByDiagnosticMap(ConcurrentSet<Suppression> programmaticSuppressions) 1864internal static Action<Diagnostic, CancellationToken> GetDiagnosticSink(Action<Diagnostic> addDiagnosticCore, Compilation compilation, AnalyzerOptions? analyzerOptions, SeverityFilter severityFilter, ConcurrentSet<string>? suppressedDiagnosticIds) 1876internal static Action<Diagnostic, DiagnosticAnalyzer, bool, CancellationToken> GetDiagnosticSink(Action<Diagnostic, DiagnosticAnalyzer, bool> addLocalDiagnosticCore, Compilation compilation, AnalyzerOptions? analyzerOptions, SeverityFilter severityFilter, ConcurrentSet<string>? suppressedDiagnosticIds) 1888internal static Action<Diagnostic, DiagnosticAnalyzer, CancellationToken> GetDiagnosticSink(Action<Diagnostic, DiagnosticAnalyzer> addDiagnosticCore, Compilation compilation, AnalyzerOptions? analyzerOptions, SeverityFilter severityFilter, ConcurrentSet<string>? suppressedDiagnosticIds) 1900private static Diagnostic? GetFilteredDiagnostic(Diagnostic diagnostic, Compilation compilation, AnalyzerOptions? analyzerOptions, SeverityFilter severityFilter, ConcurrentSet<string>? suppressedDiagnosticIds, CancellationToken cancellationToken)

DiagnosticAnalyzer\CompilationWithAnalyzers.cs (1)

46private readonly ConcurrentSet<Diagnostic> _exceptionDiagnostics = new ConcurrentSet<Diagnostic>();

Compilation\CSharpCompilation.cs (1)

2242private ConcurrentSet<MethodSymbol>? _moduleInitializerMethods;

Compiler\ClsComplianceChecker.cs (1)

44Debug.Assert(diagnostics.DependenciesBag is null || diagnostics.DependenciesBag is ConcurrentSet<AssemblySymbol>);

Compiler\MethodCompiler.cs (1)

93Debug.Assert(diagnostics.DependenciesBag == null || diagnostics.DependenciesBag is ConcurrentSet<AssemblySymbol>);

Emitter\Model\PEModuleBuilder.cs (1)

33private readonly ConcurrentSet<TypeSymbol> _reportedErrorTypesMap = new ConcurrentSet<TypeSymbol>();

FlowAnalysis\DefiniteAssignment.cs (1)

2482var seen = assembly.TypesReferencedInExternalMethods;

Symbols\Compilation_UsedAssemblies.cs (4)

22private ConcurrentSet<AssemblySymbol>? _lazyUsedAssemblyReferences; 27ConcurrentSet<AssemblySymbol>? usedAssemblies = GetCompleteSetOfUsedAssemblies(cancellationToken); 66private ConcurrentSet<AssemblySymbol>? GetCompleteSetOfUsedAssemblies(CancellationToken cancellationToken) 162ConcurrentSet<AssemblySymbol>? usedAssemblies;

Symbols\Source\SourceAssemblySymbol.cs (3)

88private ConcurrentSet<int> _lazyOmittedAttributeIndices; 103private readonly ConcurrentSet<FieldSymbol> _unreadFields = new ConcurrentSet<FieldSymbol>(); 110internal ConcurrentSet<TypeSymbol> TypesReferencedInExternalMethods = new ConcurrentSet<TypeSymbol>();

Diagnostics\CommonDiagnosticAnalyzers.cs (6)

672internal readonly ConcurrentSet<ISymbol> CallbackSymbols = new(); 1039var pendingSymbols = new ConcurrentSet<INamedTypeSymbol>(); 1775internal ConcurrentSet<ISymbol> SymbolsStarted { get; } 1869var symbolsEnded = new ConcurrentSet<ISymbol>(); 2251private readonly ConcurrentSet<ISymbol> _symbolCallbacks; 2594public ConcurrentSet<Compilation> CanceledCompilations { get; }

Compilation\ClsComplianceChecker.vb (1)

41Debug.Assert(TypeOf diagnostics.DependenciesBag Is ConcurrentSet(Of AssemblySymbol))

Compilation\MethodCompiler.vb (1)

96Debug.Assert(diagnostics.DependenciesBag Is Nothing OrElse TypeOf diagnostics.DependenciesBag Is ConcurrentSet(Of AssemblySymbol))

Emit\SymbolTranslator.vb (1)

31Private _addedEmbeddedSymbols As ConcurrentSet(Of Symbol) = Nothing

Symbols\EmbeddedSymbols\EmbeddedSymbolManager.SymbolsCollection.vb (4)

115Friend Sub GetCurrentReferencedSymbolsSnapshot(builder As ArrayBuilder(Of Symbol), filter As ConcurrentSet(Of Symbol)) 134Public Sub MarkSymbolAsReferenced(symbol As Symbol, allSymbols As ConcurrentSet(Of Symbol)) 202Private Sub AddReferencedSymbolWithDependents(symbol As Symbol, allSymbols As ConcurrentSet(Of Symbol)) 306Private Sub AddReferencedSymbolRaw(symbol As Symbol, allSymbols As ConcurrentSet(Of Symbol))

Symbols\UsedAssemblies.vb (4)

15Private _lazyUsedAssemblyReferences As ConcurrentSet(Of AssemblySymbol) 19Dim usedAssemblies As ConcurrentSet(Of AssemblySymbol) = GetCompleteSetOfUsedAssemblies(cancellationToken) 41Private Function GetCompleteSetOfUsedAssemblies(cancellationToken As CancellationToken) As ConcurrentSet(Of AssemblySymbol) 120Dim usedAssemblies As ConcurrentSet(Of AssemblySymbol)