VmTraceData.java

package com.mmt.travel.app.NFR.Latency;

import android.support.annotation.NonNull;
import android.util.SparseArray;

import com.google.common.collect.ImmutableList;
import com.google.common.collect.Iterables;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;

import java.util.Collection;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;

/**
 * Created by mmt6054 on 09/10/18.
 */

public class VmTraceData {
    private final int mVersion;
    private final boolean mDataFileOverflow;
    private final VmClockType mVmClockType;
    private final String mVm;
    private final Map<String, String> mTraceProperties;
    private final long mStartTimeUs;
    private final long mElapsedTimeUs;
    /** Map from method id to method info. */
    private final Map<Long, MethodInfo> mMethods;
    /** Map from thread name to thread info. */
    private final Map<String, ThreadInfo> mThreadInfo;
    private VmTraceData(Builder b) {
        mVersion = b.mVersion;
        mDataFileOverflow = b.mDataFileOverflow;
        mVmClockType = b.mVmClockType;
        mVm = b.mVm;
        mTraceProperties = b.mProperties;
        mMethods = b.mMethods;
        mStartTimeUs = b.mStartTimeUs;
        mElapsedTimeUs = b.mElapsedTimeUs;
        mThreadInfo = Maps.newHashMapWithExpectedSize(b.mThreads.size());
        for (int i = 0; i < b.mThreads.size(); i++) {
            int id = b.mThreads.keyAt(i);
            String name = b.mThreads.valueAt(i);
            ThreadInfo info = mThreadInfo.get(name);
            if (info != null) {
                // there is alread a thread with the same name
                name = String.format("%1$s-%2$d", name, id);
            }
            info = new ThreadInfo(id, name, b.mTopLevelCalls.get(id));
            mThreadInfo.put(name, info);
        }
    }
    public int getVersion() {
        return mVersion;
    }
    public boolean isDataFileOverflow() {
        return mDataFileOverflow;
    }
    public VmClockType getVmClockType() {
        return mVmClockType;
    }
    public String getVm() {
        return mVm;
    }
    public Map<String, String> getTraceProperties() {
        return mTraceProperties;
    }
    public static TimeUnit getDefaultTimeUnits() {
        // The traces from the VM currently use microseconds.
        // TODO: figure out if this can be obtained/inferred from the trace itself
        return TimeUnit.MICROSECONDS;
    }
    public Collection<ThreadInfo> getThreads() {
        return mThreadInfo.values();
    }
    public List<ThreadInfo> getThreads(boolean excludeThreadsWithNoActivity) {
        Collection<ThreadInfo> allThreads = getThreads();
        if (!excludeThreadsWithNoActivity) {
            return ImmutableList.copyOf(allThreads);
        }
        return Lists.newArrayList(
                Iterables.filter(allThreads, input -> input.getTopLevelCall() != null));
    }
    public ThreadInfo getThread(String name) {
        return mThreadInfo.get(name);
    }
    public Map<Long,MethodInfo> getMethods() {
        return mMethods;
    }
    public MethodInfo getMethod(long methodId) {
        return mMethods.get(methodId);
    }
    public long getStartTimeUs() {
        return mStartTimeUs;
    }
    public long getElapsedTimeUs() {
        return mElapsedTimeUs;
    }
    /** Returns the duration of this call as a percentage of the duration of the top level call. */
    public double getDurationPercentage(Call call, ThreadInfo thread, ClockType clockType,
                                        boolean inclusiveTime) {
        MethodInfo methodInfo = getMethod(call.getMethodId());
        TimeSelector selector = TimeSelector.create(clockType, inclusiveTime);
        long methodTime = selector.get(methodInfo, thread, TimeUnit.NANOSECONDS);
        return getDurationPercentage(methodTime, thread, clockType);
    }
    /**
     * Returns the given duration as a percentage of the duration of the top level call
     * in given thread.
     */
    public double getDurationPercentage(long methodTime, ThreadInfo thread, ClockType clockType) {
        Call topCall = getThread(thread.getName()).getTopLevelCall();
        if (topCall == null) {
            return 100.;
        }
        MethodInfo topInfo = getMethod(topCall.getMethodId());
        // always use inclusive time to obtain the top level's time when computing percentages
        TimeSelector selector = TimeSelector.create(clockType, true);
        long topLevelTime = selector.get(topInfo, thread, TimeUnit.NANOSECONDS);
        return (double) methodTime/topLevelTime * 100;
    }
    public SearchResult searchFor(String pattern, ThreadInfo thread) {
        pattern = pattern.toLowerCase(Locale.US);
        Set<MethodInfo> methods = new HashSet<MethodInfo>();
        Set<Call> calls = new HashSet<Call>();
        Call topLevelCall = getThread(thread.getName()).getTopLevelCall();
        if (topLevelCall == null) {
            // no matches
            return new SearchResult(methods, calls);
        }
        // Find all methods matching given pattern called on given thread
        for (MethodInfo method: getMethods().values()) {
            String fullName = method.getFullName().toLowerCase(Locale.US);
            if (fullName.contains(pattern)) { // method name matches
                long inclusiveTime = method.getProfileData()
                        .getInclusiveTime(thread, ClockType.GLOBAL, TimeUnit.NANOSECONDS);
                if (inclusiveTime > 0) {
                    // method was called in this thread
                    methods.add(method);
                }
            }
        }
        // Find all invocations of the matched methods
        Iterator<Call> iterator = topLevelCall.getCallHierarchyIterator();
        while (iterator.hasNext()) {
            Call c = iterator.next();
            MethodInfo method = getMethod(c.getMethodId());
            if (methods.contains(method)) {
                calls.add(c);
            }
        }
        return new SearchResult(methods, calls);
    }
    public static class Builder implements VmTraceHandler {
        private static final String KEY_CLOCK = "clock";
        private static final String KEY_DATA_OVERFLOW = "data-file-overflow";
        private static final String KEY_VM = "vm";
        private static final String KEY_ELAPSED_TIME_US = "elapsed-time-usec";
        private static final boolean DEBUG = false;
        private int mVersion;
        private long mStartTimeUs;
        private long mElapsedTimeUs;
        private boolean mDataFileOverflow;
        private VmClockType mVmClockType = VmClockType.THREAD_CPU;
        private String mVm = "";
        private final Map<String, String> mProperties = new HashMap<String, String>(10);
        /** Map from thread ids to thread names. */
        public final SparseArray<String> mThreads = new SparseArray<String>(10);
        /** Map from method id to method info. */
        public final Map<Long,MethodInfo> mMethods = new HashMap<Long, MethodInfo>(100);
        /** Map from thread id to per thread stack call reconstructor. */
        public final SparseArray<CallStackReconstructor> mStackReconstructors
                = new SparseArray<CallStackReconstructor>(10);
        /** Map from thread id to the top level call for that thread. */
        private final SparseArray<Call> mTopLevelCalls = new SparseArray<Call>(10);
        @Override
        public void setVersion(int version) {
            mVersion = version;
        }
        @Override
        public void setProperty(String key, String value) {
            if (key.equals(KEY_CLOCK)) {
                if (value.equals("thread-cpu")) {
                    mVmClockType = VmClockType.THREAD_CPU;
                } else if (value.equals("wall")) {
                    mVmClockType = VmClockType.WALL;
                } else if (value.equals("dual")) {
                    mVmClockType = VmClockType.DUAL;
                }
            } else if (key.equals(KEY_DATA_OVERFLOW)) {
                mDataFileOverflow = Boolean.parseBoolean(value);
            } else if (key.equals(KEY_VM)) {
                mVm = value;
            } else if (key.equals(KEY_ELAPSED_TIME_US)) {
                mElapsedTimeUs = Long.parseLong(value);
            } else {
                mProperties.put(key, value);
            }
        }
        @Override
        public void addThread(int id, String name) {
            mThreads.put(id, name);
        }
        @Override
        public void addMethod(long id, MethodInfo info) {
            mMethods.put(id, info);
        }
        @Override
        public void addMethodAction(
                int threadId,
                long methodId,
                TraceAction methodAction,
                int threadTime,
                int globalTime) {
            // create thread info if it doesn't exist
            if (mThreads.get(threadId) == null) {
                mThreads.put(threadId, String.format("Thread id: %1$d", threadId));
            }
            // create method info if it doesn't exist
            if (mMethods.get(methodId) == null) {
                MethodInfo info = new MethodInfo(methodId, "unknown", "unknown", "unknown",
                        "unknown", -1);
                mMethods.put(methodId, info);
            }
            if (DEBUG) {
                MethodInfo methodInfo = mMethods.get(methodId);
                System.out.printf("Thread %1$30s: (%2$8x) %3$-40s %4$20s\n",
                        mThreads.get(threadId), methodId, methodInfo.getShortName(), methodAction);
            }
            CallStackReconstructor reconstructor = mStackReconstructors.get(threadId);
            if (reconstructor == null) {
                long topLevelCallId = createUniqueMethodIdForThread(threadId);
                reconstructor = new CallStackReconstructor(topLevelCallId);
                mStackReconstructors.put(threadId, reconstructor);
            }
            reconstructor.addTraceAction(methodId, methodAction, threadTime, globalTime);
        }
        private long createUniqueMethodIdForThread(int threadId) {
            long id = Long.MAX_VALUE - threadId;
            assert mMethods.get(id) == null :
                    "Unexpected error while attempting to create a unique key - key already exists";
            MethodInfo info = new MethodInfo(id, mThreads.get(threadId), "", "", "", 0);
            mMethods.put(id, info);
            return id;
        }
        public VmTraceData build() {
            for (int i = 0; i < mStackReconstructors.size(); i++) {
                int threadId = mStackReconstructors.keyAt(i);
                CallStackReconstructor reconstructor = mStackReconstructors.valueAt(i);
                mTopLevelCalls.put(threadId, reconstructor.getTopLevel());
            }
            VmTraceData data = new VmTraceData(this);
            computeTimingStatistics(data);
            return data;
        }
        @Override
        public void setStartTimeUs(long startTimeUs) {
            mStartTimeUs =  startTimeUs;
        }
        private void computeTimingStatistics(VmTraceData data) {
            ProfileDataBuilder builder = new ProfileDataBuilder();
            for (ThreadInfo thread : data.getThreads()) {
                Call c = thread.getTopLevelCall();
                if (c == null) {
                    continue;
                }
                builder.computeCallStats(c, null, thread);
            }
            for (Long methodId : builder.getMethodsWithProfileData()) {
                MethodInfo method = data.getMethod(methodId);
                method.setProfileData(builder.getProfileData(methodId));
            }
        }
    }
    private static class ProfileDataBuilder {
        /** Maps method ids to their corresponding method data builders */
        private final Map<Long, MethodProfileData.Builder> mBuilderMap = Maps.newHashMap();
        public void computeCallStats(Call c, Call parent, ThreadInfo thread) {
            long methodId = c.getMethodId();
            MethodProfileData.Builder builder = getProfileDataBuilder(methodId);
            builder.addCallTime(c, parent, thread);
            builder.incrementInvocationCount(c, parent, thread);
            if (c.isRecursive()) {
                builder.setRecursive();
            }
            for (Call callee : c.getCallees()) {
                computeCallStats(callee, c, thread);
            }
        }
        @NonNull
        private MethodProfileData.Builder getProfileDataBuilder(long methodId) {
            MethodProfileData.Builder builder = mBuilderMap.get(methodId);
            if (builder == null) {
                builder = new MethodProfileData.Builder();
                mBuilderMap.put(methodId, builder);
            }
            return builder;
        }
        public Set<Long> getMethodsWithProfileData() {
            return mBuilderMap.keySet();
        }
        public MethodProfileData getProfileData(Long methodId) {
            return mBuilderMap.get(methodId).build();
        }
    }
}