GetAggregator()

bool System.Diagnostics.Metrics.LabelInstructionInterpretter< TObjectSequence, TAggregator >.GetAggregator ( ReadOnlySpan< KeyValuePair< string, object > > labels, out TAggregator aggregator )

inline

Definition at line 24 of file LabelInstructionInterpretter.cs.

    {
        aggregator = null;
        if (labels.Length != _expectedLabelCount)
        {
            return false;
        }
        TObjectSequence val = default(TObjectSequence);
        if (val is ObjectSequenceMany)
        {
            val = (TObjectSequence)(object)new ObjectSequenceMany(new object[_expectedLabelCount]);
        }
        Span<object> span = val.AsSpan();
        for (int i = 0; i < _instructions.Length; i++)
        {
            LabelInstruction labelInstruction = _instructions[i];
            if (labelInstruction.LabelName != labels[labelInstruction.SourceIndex].Key)
            {
                return false;
            }
            span[i] = labels[labelInstruction.SourceIndex].Value;
        }
        if (!_valuesDict.TryGetValue(val, out aggregator))
        {
            aggregator = _createAggregator(val);
            if (aggregator == null)
            {
                return true;
            }
            aggregator = _valuesDict.GetOrAdd(val, aggregator);
        }
        return true;
    }

References System.Diagnostics.Metrics.LabelInstructionInterpretter< TObjectSequence, TAggregator >._createAggregator, System.Diagnostics.Metrics.LabelInstructionInterpretter< TObjectSequence, TAggregator >._expectedLabelCount, System.Diagnostics.Metrics.LabelInstructionInterpretter< TObjectSequence, TAggregator >._instructions, System.Diagnostics.Metrics.LabelInstructionInterpretter< TObjectSequence, TAggregator >._valuesDict, System.Collections.Concurrent.ConcurrentDictionary< TKey, TValue >.GetOrAdd(), and System.Collections.Concurrent.ConcurrentDictionary< TKey, TValue >.TryGetValue().