import org.eclipse.linuxtools.internal.tmf.core.component.TmfProviderManager;
import org.eclipse.linuxtools.tmf.core.component.ITmfDataProvider;
import org.eclipse.linuxtools.tmf.core.component.TmfEventProvider;
+import org.eclipse.linuxtools.tmf.core.event.ITmfEvent;
import org.eclipse.linuxtools.tmf.core.event.TmfEvent;
import org.eclipse.linuxtools.tmf.core.event.TmfTimeRange;
import org.eclipse.linuxtools.tmf.core.request.ITmfDataRequest;
* TODO: Implement me. Please.
*/
@SuppressWarnings({"nls","javadoc"})
-public class TmfSyntheticEventProviderStub extends TmfEventProvider<TmfSyntheticEventStub> {
+public class TmfSyntheticEventProviderStub extends TmfEventProvider {
public static final int BLOCK_SIZE = 100;
public static final int NB_EVENTS = 1000;
}
@Override
- public ITmfContext armRequest(final ITmfDataRequest<TmfSyntheticEventStub> request) {
+ public ITmfContext armRequest(final ITmfDataRequest request) {
// Get the TmfSyntheticEventStub provider
- final ITmfDataProvider<TmfEvent>[] eventProviders = (ITmfDataProvider<TmfEvent>[]) TmfProviderManager.getProviders(TmfEvent.class, TmfEventProviderStub.class);
- final ITmfDataProvider<TmfEvent> provider = eventProviders[0];
+ final ITmfDataProvider[] eventProviders = TmfProviderManager.getProviders(TmfEvent.class, TmfEventProviderStub.class);
+ final ITmfDataProvider provider = eventProviders[0];
// make sure we have the right type of request
- if (!(request instanceof ITmfEventRequest<?>)) {
+ if (!(request instanceof ITmfEventRequest)) {
request.cancel();
return null;
}
- final TmfEventRequest<TmfSyntheticEventStub> eventRequest = (TmfEventRequest<TmfSyntheticEventStub>) request;
+ final TmfEventRequest eventRequest = (TmfEventRequest) request;
final TmfTimeRange range = eventRequest.getRange();
- final TmfEventRequest<TmfEvent> subRequest =
- new TmfEventRequest<TmfEvent>(TmfEvent.class, range, NB_EVENTS, BLOCK_SIZE) {
+ final TmfEventRequest subRequest =
+ new TmfEventRequest(TmfEvent.class, range, NB_EVENTS, BLOCK_SIZE) {
@Override
- public void handleData(final TmfEvent event) {
+ public void handleData(final ITmfEvent event) {
super.handleData(event);
if (event != null) {
handleIncomingData(event);
}
// Queue 2 synthetic events per base event
- private void handleIncomingData(final TmfEvent e) {
+ private void handleIncomingData(final ITmfEvent e) {
queueResult(new TmfSyntheticEventStub(e));
queueResult(new TmfSyntheticEventStub(e));
}
public TmfSyntheticEventStub getNext(final ITmfContext context) {
TmfSyntheticEventStub data = null;
try {
- data = fDataQueue.poll(TIMEOUT, TimeUnit.MILLISECONDS);
+ data = (TmfSyntheticEventStub) fDataQueue.poll(TIMEOUT, TimeUnit.MILLISECONDS);
if (data == null) {
throw new InterruptedException();
}