throw new PartInitException(Messages.OpenExperimentHandler_NoTraceType);\r
}\r
try {\r
- trace.initTrace(traceElement.getName(), traceElement.getLocation().getPath(), traceEvent.getClass());\r
- } catch (FileNotFoundException e) {\r
+ trace.initTrace(traceElement.getResource(), traceElement.getLocation().getPath(), traceEvent.getClass());\r
+ } catch (final FileNotFoundException e) {\r
}\r
- trace.setResource(traceElement.getResource());\r
- cacheSize = Math.min(cacheSize, trace.getIndexPageSize());\r
+ cacheSize = Math.min(cacheSize, trace.getCacheSize());\r
traces[i] = trace;\r
}\r
- final TmfExperiment experiment = new TmfExperiment(TmfEvent.class, experimentElement.getName(), traces, cacheSize);\r
- TmfExperiment experiment = new TmfExperiment(ITmfEvent.class, experimentElement.getName(), traces, cacheSize);\r
++ final TmfExperiment experiment = new TmfExperiment(ITmfEvent.class, experimentElement.getName(), traces, cacheSize);\r
experiment.setBookmarksFile(fFile);\r
fTrace = experiment;\r
experiment.initTrace(null, null, null);\r
if (signal.getTraceResource().equals(fFile)) {\r
broadcast(new TmfTraceClosedSignal(this, fTrace));\r
try {\r
- String name = fTrace.getName();\r
+ fTrace.getName();\r
fTrace = null;\r
- String traceTypeId = fFile.getPersistentProperty(TmfTraceElement.TRACETYPE);\r
- if (traceTypeId != null) {\r
- for (IConfigurationElement ce : TmfTraceType.getTypeElements()) {\r
+ final String traceTypeId = fFile.getPersistentProperty(TmfTraceElement.TRACETYPE);\r
+ if (traceTypeId != null)\r
+ for (final IConfigurationElement ce : TmfTraceType.getTypeElements())\r
if (traceTypeId.equals(ce.getAttribute(TmfTraceType.ID_ATTR))) {\r
fTrace = (ITmfTrace<?>) ce.createExecutableExtension(TmfTraceType.TRACE_TYPE_ATTR);\r
- final TmfEvent event = (TmfEvent) ce.createExecutableExtension(TmfTraceType.EVENT_TYPE_ATTR);\r
- ITmfEvent event = (TmfEvent) ce.createExecutableExtension(TmfTraceType.EVENT_TYPE_ATTR);\r
- String path = fFile.getLocationURI().getPath();\r
- fTrace.initTrace(name, path, event.getClass());\r
- fTrace.indexTrace(false);\r
++ final ITmfEvent event = (TmfEvent) ce.createExecutableExtension(TmfTraceType.EVENT_TYPE_ATTR);\r
+ final String path = fFile.getLocationURI().getPath();\r
+ fTrace.initTrace(null, path, event.getClass());\r
break;\r
}\r
- }\r
- }\r
- } catch (InvalidRegistryObjectException e) {\r
+ } catch (final InvalidRegistryObjectException e) {\r
e.printStackTrace();\r
- } catch (FileNotFoundException e) {\r
+ } catch (final FileNotFoundException e) {\r
e.printStackTrace();\r
- } catch (CoreException e) {\r
+ } catch (final CoreException e) {\r
e.printStackTrace();\r
}\r
fEventsTable.dispose();\r
@SuppressWarnings("unchecked")\r
@Override\r
public void run() {\r
- if (fTrace == null) {\r
+ if (fTrace == null)\r
return;\r
- }\r
- int nbRequested = (int) (fTrace.getNbEvents() - fFilterCheckCount);\r
- if (nbRequested <= 0) {\r
+ final int nbRequested = (int) (fTrace.getNbEvents() - fFilterCheckCount);\r
+ if (nbRequested <= 0)\r
return;\r
- request = new TmfEventRequest<TmfEvent>(TmfEvent.class, TmfTimeRange.ETERNITY, (int) fFilterCheckCount,\r
- }\r
+ request = new TmfEventRequest<ITmfEvent>(ITmfEvent.class, TmfTimeRange.ETERNITY, (int) fFilterCheckCount,\r
- nbRequested, fTrace.getIndexPageSize(), ExecutionType.BACKGROUND) {\r
+ nbRequested, fTrace.getCacheSize(), ExecutionType.BACKGROUND) {\r
@Override\r
- public void handleData(final TmfEvent event) {\r
- public void handleData(ITmfEvent event) {\r
++ public void handleData(final ITmfEvent event) {\r
super.handleData(event);\r
- if (request.isCancelled()) {\r
+ if (request.isCancelled())\r
return;\r
- }\r
if (filter.matches(event)) {\r
- long rank = fFilterCheckCount;\r
- int index = (int) fFilterMatchCount;\r
+ final long rank = fFilterCheckCount;\r
+ final int index = (int) fFilterMatchCount;\r
fFilterMatchCount++;\r
fCache.storeEvent(event.clone(), rank, index);\r
refreshTable();\r
fFilterCheckCount++;\r
}\r
};\r
- ((ITmfDataProvider<TmfEvent>) fTrace).sendRequest(request);\r
+ ((ITmfDataProvider<ITmfEvent>) fTrace).sendRequest(request);\r
try {\r
request.waitForCompletion();\r
- } catch (InterruptedException e) {\r
+ } catch (final InterruptedException e) {\r
}\r
refreshTable();\r
}\r
protected int direction;\r
protected long rank;\r
protected long foundRank = -1;\r
- protected TmfDataRequest<TmfEvent> request;\r
+ protected TmfDataRequest<ITmfEvent> request;\r
\r
- public SearchThread(ITmfFilterTreeNode searchFilter, ITmfFilterTreeNode eventFilter, int startIndex,\r
- long currentRank, int direction) {\r
+ public SearchThread(final ITmfFilterTreeNode searchFilter, final ITmfFilterTreeNode eventFilter, final int startIndex,\r
+ final long currentRank, final int direction) {\r
super(Messages.TmfEventsTable_SearchingJobName);\r
this.searchFilter = searchFilter;\r
this.eventFilter = eventFilter;\r
foundRank = event.rank;\r
break;\r
}\r
- if (direction == Direction.FORWARD) {\r
+ if (direction == Direction.FORWARD)\r
idx++;\r
- } else {\r
+ else\r
idx--;\r
- }\r
}\r
- if (foundRank == -1) {\r
+ if (foundRank == -1)\r
if (direction == Direction.FORWARD) {\r
rank++;\r
- if (rank > (fTrace.getNbEvents() - 1)) {\r
+ if (rank > (fTrace.getNbEvents() - 1))\r
rank = 0;\r
- }\r
} else {\r
rank--;\r
- if (rank < 0) {\r
+ if (rank < 0)\r
rank = (int) fTrace.getNbEvents() - 1;\r
- }\r
}\r
- }\r
}\r
- int startRank = (int) rank;\r
+ final int startRank = (int) rank;\r
boolean wrapped = false;\r
while (!monitor.isCanceled() && (foundRank == -1) && (fTrace != null)) {\r
-- int nbRequested = (direction == Direction.FORWARD ? Integer.MAX_VALUE : Math.min((int) rank + 1,\r
- fTrace.getCacheSize()));\r
- if (direction == Direction.BACKWARD)\r
- fTrace.getIndexPageSize()));\r
++ int nbRequested = (direction == Direction.FORWARD ? Integer.MAX_VALUE : Math.min((int) rank + 1, fTrace.getCacheSize()));\r
+ if (direction == Direction.BACKWARD) {\r
- rank = Math.max(0, rank - fTrace.getIndexPageSize() + 1);\r
-\r
+ rank = Math.max(0, rank - fTrace.getCacheSize() + 1);\r
- request = new TmfDataRequest<TmfEvent>(TmfEvent.class, (int) rank, nbRequested) {\r
+ }\r
+ request = new TmfDataRequest<ITmfEvent>(ITmfEvent.class, (int) rank, nbRequested) {\r
long currentRank = rank;\r
\r
@Override\r
- public void handleData(final TmfEvent event) {\r
- public void handleData(ITmfEvent event) {\r
++ public void handleData(final ITmfEvent event) {\r
super.handleData(event);\r
if (searchFilter.matches(event) && ((eventFilter == null) || eventFilter.matches(event))) {\r
foundRank = currentRank;\r
currentRank++;\r
}\r
};\r
- ((ITmfDataProvider<TmfEvent>) fTrace).sendRequest(request);\r
+ ((ITmfDataProvider<ITmfEvent>) fTrace).sendRequest(request);\r
try {\r
request.waitForCompletion();\r
- if (request.isCancelled()) {\r
+ if (request.isCancelled())\r
return Status.OK_STATUS;\r
- }\r
- } catch (InterruptedException e) {\r
+ } catch (final InterruptedException e) {\r
synchronized (fSearchSyncObj) {\r
fSearchThread = null;\r
}\r
TmfTimestamp ts = new TmfTimestamp(signal.getCurrentTime());\r
\r
@Override\r
- public void handleData(final TmfEvent event) {\r
- public void handleData(ITmfEvent event) {\r
++ public void handleData(final ITmfEvent event) {\r
super.handleData(event);\r
}\r
\r
projects / deliverable / tracecompass.git / commitdiff
