super();
}
+ @Override
public void init(String name, Class<T> eventType) {
super.init(name, eventType);
}
e.printStackTrace();
}
- if (startIndex == 0 && nbRead[0] == CHUNK_SIZE[0]) { // do this only once if the event request index is unknown
+ if (startIndex == 0 && nbRead[0].equals(CHUNK_SIZE[0])) { // do this only once if the event request index is unknown
startIndex = subRequest.getIndex(); // update the start index with the index of the first subrequest's
} // start time event which was set during the arm request
CHUNK_SIZE[0] = Math.min(request.getNbRequested() - nbRead[0], blockSize);