* Default constructor
*/
public TmfCoalescedDataRequest(Class<T> dataType) {
- this(dataType, 0, ALL_DATA, DEFAULT_BLOCK_SIZE);
+ this(dataType, 0, ALL_DATA, DEFAULT_BLOCK_SIZE, ExecutionType.SHORT);
+ }
+
+ public TmfCoalescedDataRequest(Class<T> dataType, ExecutionType execType) {
+ this(dataType, 0, ALL_DATA, DEFAULT_BLOCK_SIZE, execType);
}
/**
* @param nbRequested
*/
public TmfCoalescedDataRequest(Class<T> dataType, int index) {
- this(dataType, index, ALL_DATA, DEFAULT_BLOCK_SIZE);
+ this(dataType, index, ALL_DATA, DEFAULT_BLOCK_SIZE, ExecutionType.SHORT);
+ }
+
+ public TmfCoalescedDataRequest(Class<T> dataType, int index, ExecutionType execType) {
+ this(dataType, index, ALL_DATA, DEFAULT_BLOCK_SIZE, execType);
}
/**
* @param nbRequested
*/
public TmfCoalescedDataRequest(Class<T> dataType, int index, int nbRequested) {
- this(dataType, index, nbRequested, DEFAULT_BLOCK_SIZE);
+ this(dataType, index, nbRequested, DEFAULT_BLOCK_SIZE, ExecutionType.SHORT);
+ }
+
+ public TmfCoalescedDataRequest(Class<T> dataType, int index, int nbRequested, ExecutionType execType) {
+ this(dataType, index, nbRequested, DEFAULT_BLOCK_SIZE, execType);
}
/**
* @param blockSize
*/
public TmfCoalescedDataRequest(Class<T> dataType, int index, int nbRequested, int blockSize) {
- super(dataType, index, nbRequested, blockSize);
+ super(dataType, index, nbRequested, blockSize, ExecutionType.SHORT);
+ }
+
+ public TmfCoalescedDataRequest(Class<T> dataType, int index, int nbRequested, int blockSize, ExecutionType execType) {
+ super(dataType, index, nbRequested, blockSize, execType);
}
// ------------------------------------------------------------------------
public boolean isCompatible(ITmfDataRequest<T> request) {
boolean ok = request.getIndex() == getIndex();
- ok &= request.getNbRequested() == getNbRequested();
- ok &= request.getBlockize() == getBlockize();
+ ok &= request.getNbRequested() == getNbRequested();
+ ok &= request.getBlockize() == getBlockize();
+ ok &= request.getExecType() == getExecType();
return ok;
}
public boolean equals(Object other) {
if (other instanceof TmfCoalescedDataRequest<?>) {
TmfCoalescedDataRequest<?> request = (TmfCoalescedDataRequest<?>) other;
- return (request.getDataType() == getDataType()) &&
- (request.getIndex() == getIndex()) &&
- (request.getNbRequested() == getNbRequested());
+ return (request.getDataType() == getDataType()) &&
+ (request.getIndex() == getIndex()) &&
+ (request.getNbRequested() == getNbRequested() &&
+ (request.getExecType() == getExecType()));
}
return false;
}