org.eclipse.linuxtools.tmf/src/org/eclipse/linuxtools/tmf/experiment/TmfExperimentContext.java

   1 /*******************************************************************************
   2  * Copyright (c) 2009, 2010 Ericsson
   3  *
   4  * All rights reserved. This program and the accompanying materials are
   5  * made available under the terms of the Eclipse Public License v1.0 which
   6  * accompanies this distribution, and is available at
   7  * http://www.eclipse.org/legal/epl-v10.html
   8  *
   9  * Contributors:
  10  *   Francois Chouinard - Initial API and implementation
  11  *******************************************************************************/
  12
  13 package org.eclipse.linuxtools.tmf.experiment;
  14
  15 import org.eclipse.linuxtools.tmf.event.TmfEvent;
  16 import org.eclipse.linuxtools.tmf.trace.ITmfLocation;
  17 import org.eclipse.linuxtools.tmf.trace.ITmfTrace;
  18 import org.eclipse.linuxtools.tmf.trace.TmfContext;
  19
  20 /**
  21  * <b><u>TmfExperimentContext</u></b>
  22  * <p>
  23  * The experiment keeps track of the next event from each of its traces so
  24  * it can pick the next one in chronological order.
  25  * <p>
  26  * This implies that the "next" event from each trace has already been
  27  * read and that we at least know its timestamp. This doesn't imply that a
  28  * full parse of the event content was performed (read: LTTng works like
  29  * this).
  30  * <p>
  31  * The last trace refers to the trace from which the last event was
  32  * "consumed" at the experiment level.
  33  */
  34 public class TmfExperimentContext extends TmfContext {
  35
  36         // ------------------------------------------------------------------------
  37         // Constants
  38         // ------------------------------------------------------------------------
  39
  40          public static final int NO_TRACE = -1;
  41
  42         // ------------------------------------------------------------------------
  43         // Attributes
  44         // ------------------------------------------------------------------------
  45
  46         private ITmfTrace[]  fTraces = new ITmfTrace[0];
  47         private TmfContext[] fContexts;
  48         private TmfEvent[]   fEvents;
  49         private int lastTraceRead;
  50
  51         // ------------------------------------------------------------------------
  52         // Constructors
  53         // ------------------------------------------------------------------------
  54
  55         public TmfExperimentContext(ITmfTrace[] traces, TmfContext[] contexts) {
  56                 super();
  57                 fTraces   = traces;
  58                 fContexts = contexts;
  59                 fEvents   = new TmfEvent[fTraces.length];
  60
  61                 ITmfLocation<?>[] locations = new ITmfLocation[fTraces.length];
  62                 long[] ranks = new long[fTraces.length];
  63                 long rank = 0;
  64                 for (int i = 0; i < fTraces.length; i++) {
  65                         if (contexts[i] != null) {
  66                                 locations[i] = contexts[i].getLocation();
  67                                 ranks[i] = contexts[i].getRank();
  68                                 rank += contexts[i].getRank();
  69                         }
  70                 }
  71
  72                 setLocation(new TmfExperimentLocation(new TmfLocationArray(locations), ranks));
  73                 setRank(rank);
  74                 lastTraceRead = NO_TRACE;
  75         }
  76
  77         public TmfExperimentContext(ITmfTrace[] traces) {
  78                 this(traces, new TmfContext[traces.length]);
  79         }
  80
  81         public TmfExperimentContext(TmfExperimentContext other) {
  82                 this(other.fTraces, other.cloneContexts());
  83                 fEvents = other.fEvents;
  84                 if (other.getLocation() != null)
  85                         setLocation(other.getLocation().clone());
  86                 setRank(other.getRank());
  87                 setLastTrace(other.lastTraceRead);
  88         }
  89
  90         private TmfContext[] cloneContexts() {
  91                 TmfContext[] contexts = new TmfContext[fContexts.length];
  92                 for (int i = 0; i < fContexts.length; i++)
  93                         contexts[i] = fContexts[i].clone();
  94                 return contexts;
  95         }
  96
  97         // ------------------------------------------------------------------------
  98         // Accessors
  99         // ------------------------------------------------------------------------
 100
 101         public ITmfTrace[] getTraces() {
 102                 return fTraces;
 103         }
 104
 105         public TmfContext[] getContexts() {
 106                 return fContexts;
 107         }
 108
 109         public TmfEvent[] getEvents() {
 110                 return fEvents;
 111         }
 112
 113         public int getLastTrace() {
 114                 return lastTraceRead;
 115         }
 116
 117         public void setLastTrace(int newIndex) {
 118                 lastTraceRead = newIndex;
 119         }
 120
 121         // ------------------------------------------------------------------------
 122         // Object
 123         // ------------------------------------------------------------------------
 124
 125     @Override
 126     public int hashCode() {
 127                 int result = 17;
 128         for (int i = 0; i < fTraces.length; i++) {
 129                 result = 37 * result + fTraces[i].hashCode();
 130                 result = 37 * result + fContexts[i].hashCode();
 131         }
 132         return result;
 133     }
 134
 135     @Override
 136     public boolean equals(Object other) {
 137         if (!(other instanceof TmfExperimentContext)) {
 138                 return false;
 139         }
 140         TmfExperimentContext o = (TmfExperimentContext) other;
 141         boolean isEqual = true;
 142         int i = 0;
 143         while (isEqual && i < fTraces.length) {
 144                 isEqual &= fTraces[i].equals(o.fTraces[i]);
 145                 isEqual &= fContexts[i].equals(o.fContexts[i]);
 146                 i++;
 147         }
 148         return isEqual;
 149     }
 150
 151 }