sharplib/prof/ProcessAllocations.cs

using System;
using System.Collections.Generic;

namespace Tracing
{

    public class ProcessAllocations
    {
        private readonly int _pid;
        private readonly Dictionary<string, AllocationInfo> _allocations;
        private readonly Dictionary<int, AllocationInfo> _perThreadLastAllocation;

        public ProcessAllocations( int pid )
        {
            _pid = pid;
            _allocations = new Dictionary<string, AllocationInfo>();
            _perThreadLastAllocation = new Dictionary<int, AllocationInfo>();
        }

        public int Pid => _pid;

        public AllocationInfo GetAllocations( string typeName )
        {
            return ( _allocations.TryGetValue( typeName, out var info ) ) ? info : null;
        }

        public IEnumerable<AllocationInfo> GetAllAllocations()
        {
            return _allocations.Values;
        }

        public AllocationInfo AddAllocation( int threadID, ulong size, ulong count, string typeName )
        {
            if( !_allocations.TryGetValue( typeName, out var info ) )
            {
                info = new AllocationInfo( typeName );
                _allocations[typeName] = info;
            }

            info.AddAllocation( size, count );

            // the last allocation is still here without the corresponding stack
            if( _perThreadLastAllocation.TryGetValue( threadID, out var lastAlloc ) )
            {
                Console.WriteLine( "no stack for the last allocation" );
            }

            // keep track of the allocation for the given thread
            // --> will be used when the corresponding call stack event will be received
            _perThreadLastAllocation[threadID] = info;

            return info;
        }

        public void AddStack( int threadID, AddressStack stack )
        {
            if( _perThreadLastAllocation.TryGetValue( threadID, out var lastAlloc ) )
            {
                lastAlloc.AddStack( stack );
                _perThreadLastAllocation.Remove( threadID );
                return;
            }

            //Console.WriteLine("no last allocation for the stack event");
        }
    }


    public class AllocationInfo
    {
        private readonly string _typeName;
        private ulong _size;
        private ulong _count;
        private List<StackInfo> _stacks;

        internal AllocationInfo( string typeName )
        {
            _typeName = typeName;
            _stacks = new List<StackInfo>();
        }

        public string TypeName => _typeName;
        public ulong Count => _count;
        public ulong Size => _size;
        public IReadOnlyList<StackInfo> Stacks => _stacks;

        internal void AddAllocation( ulong size, ulong count )
        {
            _count += count;
            _size += size;
        }

        internal void AddStack( AddressStack stack )
        {
            var info = GetInfo( stack );
            if( info == null )
            {
                info = new StackInfo( stack );
                _stacks.Add( info );
            }

            info.Count++;
        }

        private StackInfo GetInfo( AddressStack stack )
        {
            for( int i = 0; i < _stacks.Count; i++ )
            {
                var info = _stacks[i];
                if( stack.Equals( info.Stack ) )
                    return info;
            }

            return null;
        }
    }

    public class StackInfo
    {
        private readonly AddressStack _stack;
        public ulong Count;

        internal StackInfo( AddressStack stack )
        {
            Count = 0;
            _stack = stack;
        }

        public AddressStack Stack => _stack;
    }
}