@Test
public void testViewerConnection() throws IOException {
InetAddress addr = InetAddress.getByName(ADDRESS);
- try (Socket connection = new Socket(addr, PORT)) {
- ILttngRelaydConnector relayD = LttngRelaydConnectorFactory.getNewConnector(connection);
+ try (Socket connection = new Socket(addr, PORT);
+ ILttngRelaydConnector relayD = LttngRelaydConnectorFactory.getNewConnector(connection);) {
+
List<SessionResponse> sessions = relayD.getSessions();
assertTrue(sessions.size() > 0);
SessionResponse lttngViewerSession = sessions.get(0);
}
private static CtfTmfEvent getEvent(int rank) {
- CtfTmfTrace trace = CtfTmfTestTrace.SYNTHETIC_TRACE.getTrace();
- ITmfContext ctx = trace.seekEvent(0);
- for (int i = 0; i < rank; i++) {
- trace.getNext(ctx);
+ try (CtfTmfTrace trace = CtfTmfTestTrace.SYNTHETIC_TRACE.getTrace()) {
+ ITmfContext ctx = trace.seekEvent(0);
+ for (int i = 0; i < rank; i++) {
+ trace.getNext(ctx);
+ }
+ return trace.getNext(ctx);
}
- final CtfTmfEvent retVal = trace.getNext(ctx);
- trace.dispose();
- return retVal;
+
}
private static IViewPart getViewPart(final String viewTile) {
import org.eclipse.linuxtools.tmf.core.statesystem.ITmfStateProvider;
import org.eclipse.linuxtools.tmf.core.statesystem.TmfStateSystemAnalysisModule;
import org.eclipse.linuxtools.tmf.core.timestamp.ITmfTimestamp;
-import org.eclipse.linuxtools.tmf.core.trace.ITmfTrace;
import org.eclipse.linuxtools.tmf.core.trace.TmfTraceManager;
import org.eclipse.linuxtools.tmf.ctf.core.CtfTmfTrace;
import org.eclipse.linuxtools.tmf.ctf.core.tests.shared.CtfTmfTestTrace;
@Test
public void testOtherUstTrace() {
/* Initialize the trace and analysis module */
- final ITmfTrace ustTrace = otherUstTrace.getTrace();
- try (TestLttngCallStackModule module = new TestLttngCallStackModule();) {
- try {
- module.setTrace(ustTrace);
- } catch (TmfAnalysisException e) {
- fail();
+ try (CtfTmfTrace ustTrace = otherUstTrace.getTrace();) {
+ try (TestLttngCallStackModule module = new TestLttngCallStackModule();) {
+ try {
+ module.setTrace(ustTrace);
+ } catch (TmfAnalysisException e) {
+ fail();
+ }
+ module.schedule();
+ assertTrue(module.waitForCompletion());
+
+ /* Make sure the generated state system exists, but is empty */
+ ITmfStateSystem ss = module.getStateSystem();
+ assertNotNull(ss);
+ assertTrue(ss.getStartTime() >= ustTrace.getStartTime().normalize(0, ITmfTimestamp.NANOSECOND_SCALE).getValue());
+ assertEquals(0, ss.getNbAttributes());
}
- module.schedule();
- assertTrue(module.waitForCompletion());
-
- /* Make sure the generated state system exists, but is empty */
- ITmfStateSystem ss = module.getStateSystem();
- assertNotNull(ss);
- assertTrue(ss.getStartTime() >= ustTrace.getStartTime().normalize(0, ITmfTimestamp.NANOSECOND_SCALE).getValue());
- assertEquals(0, ss.getNbAttributes());
+ /* Dispose the trace */
+ File suppDir = new File(TmfTraceManager.getSupplementaryFileDir(ustTrace));
+ deleteDirectory(suppDir);
+ assertFalse(suppDir.exists());
}
- /* Dispose the trace */
- ustTrace.dispose();
- File suppDir = new File(TmfTraceManager.getSupplementaryFileDir(ustTrace));
- deleteDirectory(suppDir);
- assertFalse(suppDir.exists());
}
/**
import org.eclipse.linuxtools.tmf.analysis.xml.core.stateprovider.XmlStateSystemModule;
import org.eclipse.linuxtools.tmf.analysis.xml.core.tests.common.TmfXmlTestFiles;
import org.eclipse.linuxtools.tmf.core.exceptions.TmfAnalysisException;
-import org.eclipse.linuxtools.tmf.core.trace.ITmfTrace;
+import org.eclipse.linuxtools.tmf.ctf.core.CtfTmfTrace;
import org.eclipse.linuxtools.tmf.ctf.core.tests.shared.CtfTmfTestTrace;
import org.junit.Test;
import org.w3c.dom.Document;
fModule.setXmlFile(new Path(TmfXmlTestFiles.VALID_FILE.getFile().getAbsolutePath()));
- try {
- ITmfTrace trace = CtfTmfTestTrace.KERNEL.getTrace();
+ try (CtfTmfTrace trace = CtfTmfTestTrace.KERNEL.getTrace();) {
fModule.setTrace(trace);
fModule.schedule();
+
assertTrue(fModule.waitForCompletion(new NullProgressMonitor()));
} catch (TmfAnalysisException e) {
fail("Cannot set trace " + e.getMessage());
- } finally {
- CtfTmfTestTrace.KERNEL.dispose();
}
}
public void testNewModule() {
/* Test analysis module with traceStub */
Exception exception = null;
- IAnalysisModule module = null;
- try {
- module = fModule.newModule(TmfTestTrace.A_TEST_10K.getTrace());
+ try (IAnalysisModule module = fModule.newModule(TmfTestTrace.A_TEST_10K.getTrace());) {
+ assertNotNull(module);
+ assertTrue(module instanceof TestAnalysis);
} catch (TmfAnalysisException e) {
exception = e;
}
assertNull(exception);
- assertNotNull(module);
- assertTrue(module instanceof TestAnalysis);
/* TestAnalysis2 module with trace, should return an exception */
- module = null;
- try {
- module = fModuleOther.newModule(TmfTestTrace.A_TEST_10K.getTrace());
+ try (IAnalysisModule module = fModuleOther.newModule(TmfTestTrace.A_TEST_10K.getTrace());) {
} catch (TmfAnalysisException e) {
exception = e;
}
/* TestAnalysis2 module with a TraceStub2 */
exception = null;
- module = null;
- try {
- module = fModuleOther.newModule(fTrace);
+ try (IAnalysisModule module = fModuleOther.newModule(fTrace);) {
+ assertNotNull(module);
+ assertTrue(module instanceof TestAnalysis2);
} catch (TmfAnalysisException e) {
exception = e;
}
assertNull(exception);
- assertNotNull(module);
- assertTrue(module instanceof TestAnalysis2);
}
/**
* able to set the parameter
*/
IAnalysisModuleHelper helper = TmfAnalysisManager.getAnalysisModule(AnalysisManagerTest.MODULE_PARAM);
- IAnalysisModule module;
- try {
- module = helper.newModule(trace);
+ try (IAnalysisModule module = helper.newModule(trace);) {
+ assertNull(module.getParameter(TestAnalysis.PARAM_TEST));
+ module.setParameter(TestAnalysis.PARAM_TEST, 1);
+ assertEquals(1, module.getParameter(TestAnalysis.PARAM_TEST));
+
} catch (TmfAnalysisException e1) {
fail(e1.getMessage());
return;
}
- assertNull(module.getParameter(TestAnalysis.PARAM_TEST));
- module.setParameter(TestAnalysis.PARAM_TEST, 1);
- assertEquals(1, module.getParameter(TestAnalysis.PARAM_TEST));
-
/* This module has a parameter with default value */
helper = TmfAnalysisManager.getAnalysisModule(AnalysisManagerTest.MODULE_PARAM_DEFAULT);
- try {
- module = helper.newModule(trace);
+ try (IAnalysisModule module = helper.newModule(trace);) {
+ assertEquals(3, module.getParameter(TestAnalysis.PARAM_TEST));
+ module.setParameter(TestAnalysis.PARAM_TEST, 1);
+ assertEquals(1, module.getParameter(TestAnalysis.PARAM_TEST));
+
} catch (TmfAnalysisException e1) {
fail(e1.getMessage());
return;
}
- assertEquals(3, module.getParameter(TestAnalysis.PARAM_TEST));
- module.setParameter(TestAnalysis.PARAM_TEST, 1);
- assertEquals(1, module.getParameter(TestAnalysis.PARAM_TEST));
/*
* This module does not have a parameter so setting it should throw an
* error
*/
helper = TmfAnalysisManager.getAnalysisModule(AnalysisManagerTest.MODULE_SECOND);
- try {
- module = helper.newModule(fTrace);
+ Exception exception = null;
+ try (IAnalysisModule module = helper.newModule(fTrace);) {
+
+ assertNull(module.getParameter(TestAnalysis.PARAM_TEST));
+
+ try {
+ module.setParameter(TestAnalysis.PARAM_TEST, 1);
+ } catch (RuntimeException e) {
+ exception = e;
+ }
} catch (TmfAnalysisException e1) {
fail(e1.getMessage());
return;
}
- assertNull(module.getParameter(TestAnalysis.PARAM_TEST));
- Exception exception = null;
- try {
- module.setParameter(TestAnalysis.PARAM_TEST, 1);
- } catch (RuntimeException e) {
- exception = e;
- }
assertNotNull(exception);
}
*/
@Test
public void testWaitForCompletionSuccess() {
- TestAnalysis module = setUpAnalysis();
+ try (TestAnalysis module = setUpAnalysis();) {
- IStatus status = module.schedule();
- assertEquals(IStatus.ERROR, status.getSeverity());
+ IStatus status = module.schedule();
+ assertEquals(IStatus.ERROR, status.getSeverity());
- /* Set a stub trace for analysis */
- try {
- module.setTrace(TmfTestTrace.A_TEST_10K.getTrace());
- } catch (TmfAnalysisException e) {
- fail(e.getMessage());
- }
+ /* Set a stub trace for analysis */
+ try {
+ module.setTrace(TmfTestTrace.A_TEST_10K.getTrace());
+ } catch (TmfAnalysisException e) {
+ fail(e.getMessage());
+ }
- /* Default execution, with output 1 */
- module.setParameter(TestAnalysis.PARAM_TEST, 1);
- status = module.schedule();
- assertEquals(Status.OK_STATUS, status);
- boolean completed = module.waitForCompletion();
+ /* Default execution, with output 1 */
+ module.setParameter(TestAnalysis.PARAM_TEST, 1);
+ status = module.schedule();
+ assertEquals(Status.OK_STATUS, status);
+ boolean completed = module.waitForCompletion();
- assertTrue(completed);
- assertEquals(1, module.getAnalysisOutput());
+ assertTrue(completed);
+ assertEquals(1, module.getAnalysisOutput());
+ }
}
/**
*/
@Test
public void testWaitForCompletionCancelled() {
- TestAnalysis module = setUpAnalysis();
-
- /* Set a stub trace for analysis */
- ITmfTrace trace = TmfTestTrace.A_TEST_10K.getTrace();
- try {
- module.setTrace(trace);
- } catch (TmfAnalysisException e) {
- fail(e.getMessage());
- }
+ try (TestAnalysis module = setUpAnalysis();) {
- module.setParameter(TestAnalysis.PARAM_TEST, 0);
- IStatus status = module.schedule();
- assertEquals(Status.OK_STATUS, status);
- boolean completed = module.waitForCompletion();
+ /* Set a stub trace for analysis */
+ ITmfTrace trace = TmfTestTrace.A_TEST_10K.getTrace();
+ try {
+ module.setTrace(trace);
+ } catch (TmfAnalysisException e) {
+ fail(e.getMessage());
+ }
- assertFalse(completed);
- assertEquals(0, module.getAnalysisOutput());
+ module.setParameter(TestAnalysis.PARAM_TEST, 0);
+ IStatus status = module.schedule();
+ assertEquals(Status.OK_STATUS, status);
+ boolean completed = module.waitForCompletion();
+
+ assertFalse(completed);
+ assertEquals(0, module.getAnalysisOutput());
+ }
}
/**
*/
@Test
public void testCancel() {
- TestAnalysis module = setUpAnalysis();
+ try (TestAnalysis module = setUpAnalysis();) {
- module.setParameter(TestAnalysis.PARAM_TEST, 999);
- try {
- module.setTrace(TmfTestTrace.A_TEST_10K.getTrace());
- } catch (TmfAnalysisException e) {
- fail(e.getMessage());
- }
+ module.setParameter(TestAnalysis.PARAM_TEST, 999);
+ try {
+ module.setTrace(TmfTestTrace.A_TEST_10K.getTrace());
+ } catch (TmfAnalysisException e) {
+ fail(e.getMessage());
+ }
- assertEquals(Status.OK_STATUS, module.schedule());
+ assertEquals(Status.OK_STATUS, module.schedule());
- /* Give the job a chance to start */
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e) {
- fail(e.getMessage());
- }
+ /* Give the job a chance to start */
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e) {
+ fail(e.getMessage());
+ }
- module.cancel();
- assertFalse(module.waitForCompletion());
- assertEquals(-1, module.getAnalysisOutput());
+ module.cancel();
+ assertFalse(module.waitForCompletion());
+ assertEquals(-1, module.getAnalysisOutput());
+ }
}
/**
*/
@Test
public void testParameterChanged() {
- TestAnalysis module = setUpAnalysis();
+ try (TestAnalysis module = setUpAnalysis();) {
- try {
- module.setTrace(TmfTestTrace.A_TEST_10K.getTrace());
- } catch (TmfAnalysisException e) {
- fail(e.getMessage());
- }
+ try {
+ module.setTrace(TmfTestTrace.A_TEST_10K.getTrace());
+ } catch (TmfAnalysisException e) {
+ fail(e.getMessage());
+ }
- /* Check exception if no wrong parameter name */
- Exception exception = null;
- try {
- module.notifyParameterChanged("aaa");
- } catch (RuntimeException e) {
- exception = e;
- }
- assertNotNull(exception);
+ /* Check exception if no wrong parameter name */
+ Exception exception = null;
+ try {
+ module.notifyParameterChanged("aaa");
+ } catch (RuntimeException e) {
+ exception = e;
+ }
+ assertNotNull(exception);
- /*
- * Cannot test anymore of this method, need a parameter provider to do
- * this
- */
+ /*
+ * Cannot test anymore of this method, need a parameter provider to
+ * do this
+ */
+ }
}
/**
*/
@Test
public void testHelper() {
- TestAnalysis module = setUpAnalysis();
+ try (TestAnalysis module = setUpAnalysis();) {
- try {
- module.setTrace(TmfTestTrace.A_TEST_10K.getTrace());
- } catch (TmfAnalysisException e) {
- fail(e.getMessage());
- }
+ try {
+ module.setTrace(TmfTestTrace.A_TEST_10K.getTrace());
+ } catch (TmfAnalysisException e) {
+ fail(e.getMessage());
+ }
- module.setParameter(TestAnalysis.PARAM_TEST, 1);
- boolean res = TmfTestHelper.executeAnalysis(module);
- assertTrue(res);
+ module.setParameter(TestAnalysis.PARAM_TEST, 1);
+ boolean res = TmfTestHelper.executeAnalysis(module);
+ assertTrue(res);
- module.setParameter(TestAnalysis.PARAM_TEST, 0);
- res = TmfTestHelper.executeAnalysis(module);
- assertFalse(res);
+ module.setParameter(TestAnalysis.PARAM_TEST, 0);
+ res = TmfTestHelper.executeAnalysis(module);
+ assertFalse(res);
+ }
}
}
ITmfTrace trace = TmfTestTrace.A_TEST_10K.getTrace();
/* Make sure the value is set to null */
IAnalysisModuleHelper helper = TmfAnalysisManager.getAnalysisModule(AnalysisManagerTest.MODULE_PARAM);
- IAnalysisModule module;
- try {
- module = helper.newModule(trace);
+ try (IAnalysisModule module = helper.newModule(trace);) {
+
+ assertEquals(10, module.getParameter(TestAnalysis.PARAM_TEST));
+
+ /* Change the value of the parameter in the provider */
+ List<IAnalysisParameterProvider> providers = TmfAnalysisManager.getParameterProviders(module, trace);
+ assertEquals(1, providers.size());
+ TestAnalysisParameterProvider provider = (TestAnalysisParameterProvider) providers.get(0);
+ provider.setValue(5);
+ assertEquals(5, module.getParameter(TestAnalysis.PARAM_TEST));
+
} catch (TmfAnalysisException e) {
fail(e.getMessage());
return;
}
- assertEquals(10, module.getParameter(TestAnalysis.PARAM_TEST));
-
- /* Change the value of the parameter in the provider */
- List<IAnalysisParameterProvider> providers = TmfAnalysisManager.getParameterProviders(module, trace);
- assertEquals(1, providers.size());
- TestAnalysisParameterProvider provider = (TestAnalysisParameterProvider) providers.get(0);
- provider.setValue(5);
- assertEquals(5, module.getParameter(TestAnalysis.PARAM_TEST));
}
}
if (sync_file.exists()) {
sync_file.delete();
}
- FileOutputStream fos;
- ObjectOutputStream oos;
/* Save the header of the file */
- try {
- fos = new FileOutputStream(sync_file, false);
- oos = new ObjectOutputStream(fos);
+ try (FileOutputStream fos = new FileOutputStream(sync_file, false);
+ ObjectOutputStream oos = new ObjectOutputStream(fos);) {
oos.writeObject(fTsTransform);
- oos.close();
- fos.close();
} catch (IOException e1) {
Activator.logError("Error writing timestamp transform for trace", e1); //$NON-NLS-1$
}
* @return the event at given rank
*/
protected CtfTmfEvent getEvent(int rank) {
- CtfTmfTrace trace = fTrace.getTrace();
- ITmfContext ctx = trace.seekEvent(0);
- for (int i = 0; i < rank; i++) {
- trace.getNext(ctx);
+ try (CtfTmfTrace trace = fTrace.getTrace()) {
+ ITmfContext ctx = trace.seekEvent(0);
+ for (int i = 0; i < rank; i++) {
+ trace.getNext(ctx);
+ }
+ return trace.getNext(ctx);
}
- final CtfTmfEvent retVal = trace.getNext(ctx);
- trace.dispose();
- return retVal;
}
/**
protected String getProjectName() {
return TRACE_PROJECT_NAME;
}
-
}
import java.io.File;
import java.io.FileInputStream;
-import java.io.FileNotFoundException;
+import java.io.IOException;
import java.io.InputStream;
import java.lang.reflect.InvocationTargetException;
import java.util.Arrays;
IRunnableWithProgress runnable = new IRunnableWithProgress() {
@Override
public void run(IProgressMonitor monitor) throws InvocationTargetException, InterruptedException {
- try {
- InputStream inputStream = new FileInputStream(source);
+ try (InputStream inputStream = new FileInputStream(source);) {
IFile targetFile = folder.getFile(targetName);
targetFile.create(inputStream, IResource.NONE, monitor);
- } catch (CoreException e) {
- displayException(e);
- } catch (FileNotFoundException e) {
+ } catch (CoreException | IOException e) {
displayException(e);
}
}
import java.util.Enumeration;
import java.util.Vector;
import java.util.zip.ZipEntry;
-import java.util.zip.ZipException;
import java.util.zip.ZipFile;
import org.eclipse.core.runtime.IProgressMonitor;
}
try {
- ZipFile zipFile = new ZipFile(fFileName);
- return new ZipArchiveFile(zipFile);
- } catch (ZipException e) {
- // ignore
+ return new ZipArchiveFile(new ZipFile(fFileName));
} catch (IOException e) {
// ignore
}
try {
- TarFile tarFile = new TarFile(fFileName);
- return new TarArchiveFile(tarFile);
- } catch (TarException e) {
- // ignore
- } catch (IOException e) {
+ return new TarArchiveFile(new TarFile(fFileName));
+ } catch (TarException | IOException e) {
// ignore
}
projects / deliverable / tracecompass.git / commitdiff
