[Bug292967] Second part of request coalescing + unit tests + minor fixes.

[deliverable/tracecompass.git] / org.eclipse.linuxtools.tmf / src / org / eclipse / linuxtools / tmf / component / TmfEventProvider.java

diff --git a/org.eclipse.linuxtools.tmf/src/org/eclipse/linuxtools/tmf/component/TmfEventProvider.java b/org.eclipse.linuxtools.tmf/src/org/eclipse/linuxtools/tmf/component/TmfEventProvider.java
index 1654b786393843c7c2ae81393637d70ca6613ac1..ae9a16a5ade2d15c45d50ab914f25a47f26d0dad 100644 (file)
--- a/org.eclipse.linuxtools.tmf/src/org/eclipse/linuxtools/tmf/component/TmfEventProvider.java
+++ b/org.eclipse.linuxtools.tmf/src/org/eclipse/linuxtools/tmf/component/TmfEventProvider.java
@@ -14,6 +14,7 @@ package org.eclipse.linuxtools.tmf.component;
 
 import org.eclipse.linuxtools.tmf.event.TmfEvent;
 import org.eclipse.linuxtools.tmf.event.TmfTimestamp;
+import org.eclipse.linuxtools.tmf.request.TmfCoalescedEventRequest;
 import org.eclipse.linuxtools.tmf.request.TmfDataRequest;
 import org.eclipse.linuxtools.tmf.request.TmfEventRequest;
 
@@ -42,4 +43,15 @@ public abstract class TmfEventProvider<T extends TmfEvent> extends TmfDataProvid
                return dataRequestCompleted;
        }
 
+       @Override
+       protected synchronized void newCoalescedDataRequest(TmfDataRequest<T> request) {
+               if (request instanceof TmfEventRequest<?>) {
+                       TmfEventRequest<T> eventRequest = (TmfEventRequest<T>) request;
+                       TmfCoalescedEventRequest<T> coalescedRequest = 
+                               new TmfCoalescedEventRequest<T>(fType, eventRequest.getRange(), eventRequest.getNbRequested(), eventRequest.getBlockize());
+                       coalescedRequest.addRequest(eventRequest);
+                       fPendingCoalescedRequests.add(coalescedRequest);
+               }
+       }
+
 }