using System.Collections.Concurrent; using System.Collections.Generic; using System.Security; namespace System.Diagnostics.Metrics { [SecurityCritical] internal sealed class LabelInstructionInterpreter<TObjectSequence, TAggregator> where TObjectSequence : struct, IObjectSequence, IEquatable<TObjectSequence> where TAggregator : Aggregator { private readonly int _expectedLabelCount; private readonly LabelInstruction[] _instructions; private readonly ConcurrentDictionary<TObjectSequence, TAggregator> _valuesDict; private readonly Func<TObjectSequence, TAggregator> _createAggregator; public LabelInstructionInterpreter(int expectedLabelCount, LabelInstruction[] instructions, ConcurrentDictionary<TObjectSequence, TAggregator> valuesDict, Func<TAggregator> createAggregator) { _expectedLabelCount = expectedLabelCount; _instructions = instructions; _valuesDict = valuesDict; _createAggregator = ((TObjectSequence _) => createAggregator()); } public bool GetAggregator(ReadOnlySpan<KeyValuePair<string, object>> labels, out TAggregator aggregator) { aggregator = null; if (labels.Length != _expectedLabelCount) return false; TObjectSequence val = default(TObjectSequence); if (((object)val) is ObjectSequenceMany) val = (TObjectSequence)(object)new ObjectSequenceMany(new object[_expectedLabelCount]); for (int i = 0; i < _instructions.Length; i++) { LabelInstruction labelInstruction = _instructions[i]; string labelName = labelInstruction.LabelName; KeyValuePair<string, object> keyValuePair = labels[labelInstruction.SourceIndex]; if (labelName != keyValuePair.Key) return false; ref TObjectSequence reference = ref val; int i2 = i; keyValuePair = labels[labelInstruction.SourceIndex]; reference[i2] = keyValuePair.Value; } if (!_valuesDict.TryGetValue(val, out aggregator)) { aggregator = _createAggregator(val); if (aggregator == null) return true; aggregator = _valuesDict.GetOrAdd(val, aggregator); } return true; } } }