ProcessTimeline.java

Go to the documentation of this file.

package edu.rice.cs.hpc.traceviewer.data.timeline;

import java.util.HashMap;

import org.eclipse.core.runtime.Assert;

import edu.rice.cs.hpc.data.experiment.extdata.AbstractBaseData;
import edu.rice.cs.hpc.data.experiment.extdata.IBaseData;
import edu.rice.cs.hpc.traceviewer.data.db.TraceDataByRank;
import edu.rice.cs.hpc.traceviewer.data.db.DataRecord;
import edu.rice.cs.hpc.traceviewer.data.graph.CallPath;

public class ProcessTimeline {

    private HashMap<Integer, CallPath> scopeMap;

    private int lineNum;

    private long startingTime;

    private long timeRange;

    private double pixelLength;

    final TraceDataByRank data;

    /*************************************************************************
     * Reads in the call-stack trace data from the binary traceFile in the form:
     * double time-stamp int Call-Path ID double time-stamp int Call-Path ID ...
     ************************************************************************/

    public ProcessTimeline(int _lineNum, HashMap<Integer, CallPath> _scopeMap, IBaseData dataTrace, 
            int _processNumber, int _numPixelH, long _timeRange, long _startingTime)
    {

        lineNum = _lineNum;
        scopeMap = _scopeMap;

        timeRange = _timeRange;
        startingTime = _startingTime;

        pixelLength = timeRange / (double) _numPixelH;
        
        //TODO: Beautify
        if (dataTrace instanceof AbstractBaseData)
            data = new TraceDataByRank((AbstractBaseData) dataTrace, _processNumber, _numPixelH);
        else
            data = new TraceDataByRank(new DataRecord[0]);
    }

    //Remote version
    public ProcessTimeline(TraceDataByRank _data,
            HashMap<Integer, CallPath> _scopeMap, int _processNumber,
            int _numPixelH, long _timeRange, long _startingTime) {
        lineNum = _processNumber;
        scopeMap = _scopeMap;

        timeRange = _timeRange;
        startingTime = _startingTime;

        pixelLength = timeRange / (double) _numPixelH;
        if (_data == null)
            data = new TraceDataByRank(new DataRecord[0]);
        else
            data = _data;
    }

    public void readInData() {

        data.getData(startingTime, timeRange,
                pixelLength);
    }

    public long getTime(int sample) {
        return data.getTime(sample);
    }

    private int getCpid(int sample) {
        return data.getCpid(sample);
    }

    public void shiftTimeBy(long lowestStartingTime) {
        data.shiftTimeBy(lowestStartingTime);
    }

    public CallPath getCallPath(int sample, int depth) {
        Assert.isTrue(sample>=0, "sample number is negative");
        int cpid = getCpid(sample);

        CallPath cp = scopeMap.get(cpid);
        if (cp == null) {
            System.err.println("ERROR: No sample found for cpid " + cpid
                    + " in trace sample: " + sample);
            System.err
                    .println("\tThere was most likely an error in the data collection; the display may be inaccurate.");
        }
        return cp;
    }
    public void copyDataFrom(ProcessTimeline another) {
        this.data.setListOfData(another.data.getListOfData());
    }

    public int size() {
        return data.size();
    }

    public int line() {
        return lineNum;
    }

    public int findMidpointBefore(long time, boolean usingMidpoint)
    {
        return data.findMidpointBefore(time, usingMidpoint);
    }

    /****
     * retrieve the trace data of this process time line
     * @return
     */
    public TraceDataByRank getData() 
    {
        return data;
    }
    // These are potentially useful for debugging, but otherwise serve no use.
//  @Override
//  public String toString() {
//      return hashCode() + "#" + data.getRank();
//  }
//
//  @Override
//  public int hashCode() {
//      double hash = 0.0;
//      for (Record r : data.getListOfData()) {
//          hash += r.cpId + Math.log(r.timestamp);
//      }
//      return (int) Math.round(hash);
//  }

}