* </p>
*
* @author Francois Chouinard
- * @since 3.0
*/
public abstract class TmfEventProvider extends TmfComponent implements ITmfEventProvider, ITmfFilter {
// Constants
// ------------------------------------------------------------------------
- /** Default amount of events per request "chunk"
- * @since 3.0 */
+ /** Default amount of events per request "chunk" */
public static final int DEFAULT_BLOCK_SIZE = 50000;
/** Delay for coalescing background requests (in milli-seconds) */
// ITmfRequestHandler
// ------------------------------------------------------------------------
- /**
- * @since 3.0
- */
@Override
public void sendRequest(final ITmfEventRequest request) {
synchronized (fLock) {
*
* @param request
* The request to copy
- * @since 3.0
*/
protected void newCoalescedEventRequest(ITmfEventRequest request) {
synchronized (fLock) {
*
* @param request
* The request to add to the list
- * @since 3.0
*/
protected void coalesceEventRequest(ITmfEventRequest request) {
synchronized (fLock) {
*
* @param request
* The data request
- * @since 3.0
*/
protected void queueRequest(final ITmfEventRequest request) {
* The request
* @return An application specific context; null if request can't be
* serviced
- * @since 3.0
*/
public abstract ITmfContext armRequest(ITmfEventRequest request);
* @param nbRead
* The number of events read so far
* @return true if completion criteria is met
- * @since 3.0
*/
public boolean isCompleted(ITmfEventRequest request, ITmfEvent event, int nbRead) {
boolean requestCompleted = isCompleted2(request, nbRead);
/**
* @return the shutdown state (i.e. if it is accepting new requests)
- * @since 2.0
*/
protected boolean executorIsShutdown() {
return fExecutor.isShutdown();
/**
* @return the termination state
- * @since 2.0
*/
protected boolean executorIsTerminated() {
return fExecutor.isTerminated();