* @param range
*/
public TmfEventRequest(Class<T> dataType) {
- this(dataType, TmfTimeRange.Eternity, ALL_DATA, DEFAULT_BLOCK_SIZE, ExecutionType.FOREGROUND);
+ this(dataType, TmfTimeRange.Eternity, 0, ALL_DATA, DEFAULT_BLOCK_SIZE, ExecutionType.FOREGROUND);
}
public TmfEventRequest(Class<T> dataType, ExecutionType execType) {
- this(dataType, TmfTimeRange.Eternity, ALL_DATA, DEFAULT_BLOCK_SIZE, execType);
+ this(dataType, TmfTimeRange.Eternity, 0, ALL_DATA, DEFAULT_BLOCK_SIZE, execType);
}
/**
* @param range
*/
public TmfEventRequest(Class<T> dataType, TmfTimeRange range) {
- this(dataType, range, ALL_DATA, DEFAULT_BLOCK_SIZE, ExecutionType.FOREGROUND);
+ this(dataType, range, 0, ALL_DATA, DEFAULT_BLOCK_SIZE, ExecutionType.FOREGROUND);
}
public TmfEventRequest(Class<T> dataType, TmfTimeRange range, ExecutionType execType) {
- this(dataType, range, ALL_DATA, DEFAULT_BLOCK_SIZE, execType);
+ this(dataType, range, 0, ALL_DATA, DEFAULT_BLOCK_SIZE, execType);
}
/**
* @param nbRequested
*/
public TmfEventRequest(Class<T> dataType, TmfTimeRange range, int nbRequested) {
- this(dataType, range, nbRequested, DEFAULT_BLOCK_SIZE, ExecutionType.FOREGROUND);
+ this(dataType, range, 0, nbRequested, DEFAULT_BLOCK_SIZE, ExecutionType.FOREGROUND);
}
public TmfEventRequest(Class<T> dataType, TmfTimeRange range, int nbRequested, ExecutionType execType) {
- this(dataType, range, nbRequested, DEFAULT_BLOCK_SIZE, execType);
+ this(dataType, range, 0, nbRequested, DEFAULT_BLOCK_SIZE, execType);
}
/**
* @param blockSize Size of the largest blocks expected
*/
public TmfEventRequest(Class<T> dataType, TmfTimeRange range, int nbRequested, int blockSize) {
- super(dataType, 0, nbRequested, blockSize, ExecutionType.FOREGROUND);
- fRange = range;
+ this(dataType, range, 0, nbRequested, blockSize, ExecutionType.FOREGROUND);
}
public TmfEventRequest(Class<T> dataType, TmfTimeRange range, int nbRequested, int blockSize, ExecutionType execType) {
- super(dataType, 0, nbRequested, blockSize, execType);
+ this(dataType, range, 0, nbRequested, blockSize, execType);
+ }
+
+ public TmfEventRequest(Class<T> dataType, TmfTimeRange range, int index, int nbRequested, int blockSize, ExecutionType execType) {
+ super(dataType, index, nbRequested, blockSize, execType);
fRange = range;
}
return fRange;
}
+ // ------------------------------------------------------------------------
+ // Setters
+ // ------------------------------------------------------------------------
+
+ /**
+ * this method is called by the event provider to set the index corresponding
+ * to the time range start time once it is known
+ * @param index the start time index
+ */
+ @Override
+ public void setStartIndex(int index) {
+ setIndex(index);
+ }
+
// ------------------------------------------------------------------------
// Object
// ------------------------------------------------------------------------
@SuppressWarnings("nls")
public String toString() {
return "[TmfEventRequest(" + getRequestId() + "," + getDataType().getSimpleName()
- + "," + getRange() + "," + getNbRequested() + ")]";
+ + "," + getRange() + "," + getIndex() + "," + getNbRequested() + "," + getBlockSize() + ")]";
}
}