/**********************************************************************
* Copyright (c) 2012 Ericsson
- *
+ *
* All rights reserved. This program and the accompanying materials are
* made available under the terms of the Eclipse Public License v1.0 which
* accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
+ *
+ * Contributors:
* Bernd Hufmann - Initial API and implementation
**********************************************************************/
package org.eclipse.linuxtools.lttng2.ui.tests.control.service;
import org.eclipse.core.runtime.FileLocator;
import org.eclipse.core.runtime.NullProgressMonitor;
import org.eclipse.core.runtime.Path;
+import org.eclipse.linuxtools.internal.lttng2.core.control.model.IBaseEventInfo;
+import org.eclipse.linuxtools.internal.lttng2.core.control.model.IChannelInfo;
+import org.eclipse.linuxtools.internal.lttng2.core.control.model.IDomainInfo;
+import org.eclipse.linuxtools.internal.lttng2.core.control.model.IEventInfo;
+import org.eclipse.linuxtools.internal.lttng2.core.control.model.IFieldInfo;
+import org.eclipse.linuxtools.internal.lttng2.core.control.model.ISessionInfo;
+import org.eclipse.linuxtools.internal.lttng2.core.control.model.IUstProviderInfo;
+import org.eclipse.linuxtools.internal.lttng2.core.control.model.LogLevelType;
+import org.eclipse.linuxtools.internal.lttng2.core.control.model.TraceEnablement;
+import org.eclipse.linuxtools.internal.lttng2.core.control.model.TraceEventType;
+import org.eclipse.linuxtools.internal.lttng2.core.control.model.TraceLogLevel;
+import org.eclipse.linuxtools.internal.lttng2.core.control.model.TraceSessionState;
+import org.eclipse.linuxtools.internal.lttng2.core.control.model.impl.ChannelInfo;
import org.eclipse.linuxtools.internal.lttng2.stubs.service.CommandShellFactory;
import org.eclipse.linuxtools.internal.lttng2.stubs.shells.LTTngToolsFileShell;
-import org.eclipse.linuxtools.internal.lttng2.ui.views.control.model.IBaseEventInfo;
-import org.eclipse.linuxtools.internal.lttng2.ui.views.control.model.IChannelInfo;
-import org.eclipse.linuxtools.internal.lttng2.ui.views.control.model.IDomainInfo;
-import org.eclipse.linuxtools.internal.lttng2.ui.views.control.model.IEventInfo;
-import org.eclipse.linuxtools.internal.lttng2.ui.views.control.model.ISessionInfo;
-import org.eclipse.linuxtools.internal.lttng2.ui.views.control.model.IUstProviderInfo;
-import org.eclipse.linuxtools.internal.lttng2.ui.views.control.model.LogLevelType;
-import org.eclipse.linuxtools.internal.lttng2.ui.views.control.model.TraceEnablement;
-import org.eclipse.linuxtools.internal.lttng2.ui.views.control.model.TraceEventType;
-import org.eclipse.linuxtools.internal.lttng2.ui.views.control.model.TraceLogLevel;
-import org.eclipse.linuxtools.internal.lttng2.ui.views.control.model.TraceSessionState;
-import org.eclipse.linuxtools.internal.lttng2.ui.views.control.model.impl.ChannelInfo;
import org.eclipse.linuxtools.internal.lttng2.ui.views.control.service.ILttngControlService;
import org.eclipse.linuxtools.internal.lttng2.ui.views.control.service.LTTngControlService;
import org.eclipse.linuxtools.internal.lttng2.ui.views.control.service.LTTngControlServiceFactory;
/**
* The class <code>LTTngControlServiceTest</code> contains test for the class <code>{@link LTTngControlService}</code>.
*/
-@SuppressWarnings("nls")
+@SuppressWarnings({"nls", "javadoc"})
public class LTTngControlServiceTest extends TestCase {
private static final String DIRECTORY = "testfiles";
private static final String TEST_STREAM = "LTTngServiceTest.cfg";
-
+
private static final String SCEN_LTTNG_NOT_INSTALLED = "LttngNotInstalled";
private static final String SCEN_LTTNG_VERSION = "LttngVersion";
+ private static final String SCEN_LTTNG_VERSION_WITH_PROMPT = "LttngVersionWithPrompt";
private static final String SCEN_LTTNG_UNSUPPORTED_VERSION = "LttngUnsupportedVersion";
private static final String SCEN_LTTNG_NO_VERSION = "LttngNoVersion";
private static final String SCEN_NO_SESSION_AVAILABLE = "NoSessionAvailable";
private static final String SCEN_GET_SESSION_GARBAGE_OUT = "GetSessionGarbageOut";
private static final String SCEN_GET_SESSION1 = "GetSession1";
private static final String SCEN_GET_KERNEL_PROVIDER1 = "GetKernelProvider1";
+ private static final String SCEN_LIST_WITH_NO_KERNEL1 = "ListWithNoKernel1";
+ private static final String SCEN_LIST_WITH_NO_KERNEL2 = "ListWithNoKernel2";
private static final String SCEN_GET_UST_PROVIDER1 = "GetUstProvider1";
private static final String SCEN_GET_UST_PROVIDER2 = "GetUstProvider2";
+ private static final String SCEN_GET_UST_PROVIDER3 = "GetUstProvider3";
private static final String SCEN_CREATE_SESSION1 = "CreateSession1";
+ private static final String SCEN_CREATE_SESSION_WITH_PROMPT = "CreateSessionWithPrompt";
private static final String SCEN_CREATE_SESSION_VARIANTS = "CreateSessionVariants";
private static final String SCEN_DESTROY_SESSION1 = "DestroySession1";
private static final String SCEN_CHANNEL_HANDLING = "ChannelHandling";
private LTTngToolsFileShell fShell;
private ILttngControlService fService;
-
+
// ------------------------------------------------------------------------
// Static methods
// ------------------------------------------------------------------------
URL location = FileLocator.find(FrameworkUtil.getBundle(this.getClass()), new Path(DIRECTORY + File.separator + TEST_STREAM), null);
File testfile = new File(FileLocator.toFileURL(location).toURI());
fTestfile = testfile.getAbsolutePath();
-
+
fShell = fShellFactory.getFileShell();
fShell.loadScenarioFile(fTestfile);
fService = new LTTngControlService(fShell);
// ------------------------------------------------------------------------
// Test Cases
// ------------------------------------------------------------------------
-
+
public void testVersion() {
try {
fShell.setScenario(SCEN_LTTNG_VERSION);
- ILttngControlService service = LTTngControlServiceFactory.getInstance().getLttngControlService(fShell);
+ ILttngControlService service = LTTngControlServiceFactory.getInstance().getLttngControlService(fShell);
+ assertNotNull(service);
+ assertEquals("2.1.0", service.getVersion());
+ } catch (ExecutionException e) {
+ fail("Exeption thrown " + e);
+ }
+ }
+
+ public void testVersionWithPrompt() {
+ try {
+ fShell.setScenario(SCEN_LTTNG_VERSION_WITH_PROMPT);
+ ILttngControlService service = LTTngControlServiceFactory.getInstance().getLttngControlService(fShell);
assertNotNull(service);
assertEquals("2.0.0", service.getVersion());
} catch (ExecutionException e) {
fail("Exeption thrown " + e);
}
}
-
+
public void testUnsupportedVersion() {
try {
fShell.setScenario(SCEN_LTTNG_UNSUPPORTED_VERSION);
- LTTngControlServiceFactory.getInstance().getLttngControlService(fShell);
+ LTTngControlServiceFactory.getInstance().getLttngControlService(fShell);
fail("No exeption thrown");
} catch (ExecutionException e) {
// success
public void testNoVersion() {
try {
fShell.setScenario(SCEN_LTTNG_NO_VERSION);
- LTTngControlServiceFactory.getInstance().getLttngControlService(fShell);
+ LTTngControlServiceFactory.getInstance().getLttngControlService(fShell);
fail("No exeption thrown");
} catch (ExecutionException e) {
// success
// success
}
}
-
+
public void testGetSessionNames1() {
try {
fShell.setScenario(SCEN_NO_SESSION_AVAILABLE);
assertNotNull(result);
assertEquals(0, result.length);
-
+
} catch (ExecutionException e) {
fail(e.toString());
}
assertEquals(2, result.length);
assertEquals("mysession1", result[0]);
assertEquals("mysession", result[1]);
-
+
} catch (ExecutionException e) {
fail(e.toString());
}
fShell.setScenario(SCEN_GET_SESSION_NAME_NOT_EXIST);
fService.getSessionNames(new NullProgressMonitor());
fail("No exeption thrown");
-
+
} catch (ExecutionException e) {
// success
}
}
-
+
public void testGetSessionNameGarbage() {
try {
fShell.setScenario(SCEN_GET_SESSION_GARBAGE_OUT);
assertNotNull(result);
assertEquals(0, result.length);
-
+
} catch (ExecutionException e) {
fail(e.toString());
}
}
-
+
public void testGetSession1() {
try {
fShell.setScenario(SCEN_GET_SESSION1);
assertEquals("mysession", session.getName());
assertEquals("/home/user/lttng-traces/mysession-20120129-084256", session.getSessionPath());
assertEquals(TraceSessionState.ACTIVE, session.getSessionState());
-
+
IDomainInfo[] domains = session.getDomains();
assertNotNull(domains);
assertEquals(2, domains.length);
-
+
// Verify Kernel domain
assertEquals("Kernel", domains[0].getName());
IChannelInfo[] channels = domains[0].getChannels();
assertNotNull(channels);
assertEquals(2, channels.length);
- // Verify Kernel's channel0
+ // Verify Kernel's channel0
assertEquals("channel0", channels[0].getName());
assertEquals(4, channels[0].getNumberOfSubBuffers());
assertEquals("splice()", channels[0].getOutputType());
assertEquals(TraceEnablement.ENABLED, channels[0].getState());
assertEquals(262144, channels[0].getSubBufferSize());
assertEquals(0, channels[0].getSwitchTimer());
-
+
// Verify event info
IEventInfo[] channel0Events = channels[0].getEvents();
assertNotNull(channel0Events);
assertEquals(TraceLogLevel.TRACE_EMERG, channel0Events[0].getLogLevel());
assertEquals(TraceEventType.TRACEPOINT, channel0Events[0].getEventType());
assertEquals(TraceEnablement.ENABLED, channel0Events[0].getState());
-
+
assertEquals("block_bio_remap", channel0Events[1].getName());
assertEquals(TraceLogLevel.TRACE_EMERG, channel0Events[1].getLogLevel());
assertEquals(TraceEventType.TRACEPOINT, channel0Events[1].getEventType());
assertEquals(TraceEnablement.DISABLED, channel0Events[1].getState());
-
- // Verify Kernel's channel1
+
+ // Verify Kernel's channel1
assertEquals("channel1", channels[1].getName());
assertEquals(4, channels[1].getNumberOfSubBuffers());
assertEquals("splice()", channels[1].getOutputType());
assertEquals(TraceEnablement.DISABLED, channels[1].getState());
assertEquals(524288, channels[1].getSubBufferSize());
assertEquals(100, channels[1].getSwitchTimer());
-
+
// Verify event info
IEventInfo[] channel1Events = channels[1].getEvents();
assertEquals(0, channel1Events.length);
-
+
// Verify domain UST global
assertEquals("UST global", domains[1].getName());
-
+
IChannelInfo[] ustChannels = domains[1].getChannels();
-
- // Verify UST global's mychannel1
+
+ // Verify UST global's mychannel1
assertEquals("mychannel1", ustChannels[0].getName());
assertEquals(8, ustChannels[0].getNumberOfSubBuffers());
assertEquals("mmap()", ustChannels[0].getOutputType());
assertEquals(TraceEnablement.DISABLED, ustChannels[0].getState());
assertEquals(8192, ustChannels[0].getSubBufferSize());
assertEquals(200, ustChannels[0].getSwitchTimer());
-
+
// Verify event info
IEventInfo[] ustEvents = ustChannels[0].getEvents();
assertEquals(0, ustEvents.length);
- // Verify UST global's channel0
+ // Verify UST global's channel0
assertEquals("channel0", ustChannels[1].getName());
assertEquals(4, ustChannels[1].getNumberOfSubBuffers());
assertEquals("mmap()", ustChannels[1].getOutputType());
assertEquals(TraceEnablement.ENABLED, ustChannels[1].getState());
assertEquals(4096, ustChannels[1].getSubBufferSize());
assertEquals(0, ustChannels[1].getSwitchTimer());
-
+
// Verify event info
ustEvents = ustChannels[1].getEvents();
assertEquals(2, ustEvents.length);
-
+
assertEquals("ust_tests_hello:tptest_sighandler", ustEvents[0].getName());
assertEquals(TraceLogLevel.TRACE_DEBUG_LINE, ustEvents[0].getLogLevel());
assertEquals(TraceEventType.TRACEPOINT, ustEvents[0].getEventType());
assertEquals(TraceEnablement.DISABLED, ustEvents[0].getState());
-
+
assertEquals("*", ustEvents[1].getName());
assertEquals(TraceLogLevel.LEVEL_UNKNOWN, ustEvents[1].getLogLevel());
assertEquals(TraceEventType.TRACEPOINT, ustEvents[1].getEventType());
assertEquals(TraceEnablement.ENABLED, ustEvents[1].getState());
-
+
// next session (no detailed information available)
session = fService.getSession("mysession1", new NullProgressMonitor());
assertNotNull(session);
assertEquals("mysession1", session.getName());
assertEquals("/home/user/lttng-traces/mysession1-20120203-133225", session.getSessionPath());
assertEquals(TraceSessionState.INACTIVE, session.getSessionState());
-
+
domains = session.getDomains();
assertNotNull(domains);
assertEquals(0, domains.length);
// Verify event info
assertNotNull(events);
assertEquals(3, events.size());
-
- IBaseEventInfo baseEventInfo = (IBaseEventInfo) events.get(0);
+
+ IBaseEventInfo baseEventInfo = events.get(0);
assertNotNull(baseEventInfo);
assertEquals("sched_kthread_stop", baseEventInfo.getName());
assertEquals(TraceLogLevel.TRACE_EMERG, baseEventInfo.getLogLevel());
assertEquals(TraceEventType.TRACEPOINT, baseEventInfo.getEventType());
-
- baseEventInfo = (IBaseEventInfo) events.get(1);
+
+ baseEventInfo = events.get(1);
assertEquals("sched_kthread_stop_ret", baseEventInfo.getName());
assertEquals(TraceLogLevel.TRACE_EMERG, baseEventInfo.getLogLevel());
assertEquals(TraceEventType.TRACEPOINT, baseEventInfo.getEventType());
-
- baseEventInfo = (IBaseEventInfo) events.get(2);
+
+ baseEventInfo = events.get(2);
assertEquals("sched_wakeup_new", baseEventInfo.getName());
assertEquals(TraceLogLevel.TRACE_EMERG, baseEventInfo.getLogLevel());
assertEquals(TraceEventType.TRACEPOINT, baseEventInfo.getEventType());
}
}
+ public void testGetKernelProviderNoKernel1() {
+ try {
+ fShell.setScenario(SCEN_LIST_WITH_NO_KERNEL1);
+ List<IBaseEventInfo> events = fService.getKernelProvider(new NullProgressMonitor());
+
+ // Verify event info
+ assertNotNull(events);
+ assertEquals(0, events.size());
+
+ } catch (ExecutionException e) {
+ fail(e.toString());
+ }
+ }
+
+ public void testGetKernelProviderNoKernel2() {
+ try {
+ fShell.setScenario(SCEN_LIST_WITH_NO_KERNEL2);
+ List<IBaseEventInfo> events = fService.getKernelProvider(new NullProgressMonitor());
+
+ // Verify event info
+ assertNotNull(events);
+ assertEquals(0, events.size());
+
+ } catch (ExecutionException e) {
+ fail(e.toString());
+ }
+ }
+
+
public void testGetUstProvider() {
try {
fShell.setScenario(SCEN_GET_UST_PROVIDER1);
// Check all providers
assertNotNull(providers);
assertEquals(2, providers.size());
-
+
//Verify first provider
assertEquals("/home/user/git/lttng-ust/tests/hello.cxx/.libs/lt-hello", providers.get(0).getName());
assertEquals(9379, providers.get(0).getPid());
-
+
// Verify event info
IBaseEventInfo[] events = providers.get(0).getEvents();
assertNotNull(events);
assertEquals(2, events.length);
- IBaseEventInfo baseEventInfo = (IBaseEventInfo) events[0];
+ IBaseEventInfo baseEventInfo = events[0];
assertNotNull(baseEventInfo);
assertEquals("ust_tests_hello:tptest_sighandler", baseEventInfo.getName());
assertEquals(TraceLogLevel.TRACE_DEBUG_MODULE, baseEventInfo.getLogLevel());
assertEquals(TraceEventType.TRACEPOINT, baseEventInfo.getEventType());
-
- baseEventInfo = (IBaseEventInfo) events[1];
+
+ baseEventInfo = events[1];
assertEquals("ust_tests_hello:tptest", baseEventInfo.getName());
assertEquals(TraceLogLevel.TRACE_INFO, baseEventInfo.getLogLevel());
assertEquals(TraceEventType.TRACEPOINT, baseEventInfo.getEventType());
//Verify second provider
assertEquals("/home/user/git/lttng-ust/tests/hello.cxx/.libs/lt-hello", providers.get(1).getName());
assertEquals(4852, providers.get(1).getPid());
-
+
// Verify event info
events = providers.get(1).getEvents();
assertNotNull(events);
assertEquals(2, events.length);
- baseEventInfo = (IBaseEventInfo) events[0];
+ baseEventInfo = events[0];
assertNotNull(baseEventInfo);
assertEquals("ust_tests_hello:tptest_sighandler", baseEventInfo.getName());
assertEquals(TraceLogLevel.TRACE_WARNING, baseEventInfo.getLogLevel());
assertEquals(TraceEventType.TRACEPOINT, baseEventInfo.getEventType());
-
- baseEventInfo = (IBaseEventInfo) events[1];
+
+ baseEventInfo = events[1];
assertEquals("ust_tests_hello:tptest", baseEventInfo.getName());
assertEquals(TraceLogLevel.TRACE_DEBUG_FUNCTION, baseEventInfo.getLogLevel());
assertEquals(TraceEventType.TRACEPOINT, baseEventInfo.getEventType());
assertNotNull(providers);
assertEquals(0, providers.size());
-
+
+ } catch (ExecutionException e) {
+ fail(e.toString());
+ }
+ }
+
+ public void testGetUstProvider3() {
+ try {
+ fShell.setScenario(SCEN_GET_UST_PROVIDER3);
+ // Set version
+ ((LTTngControlService)fService).setVersion("2.1.0");
+ List<IUstProviderInfo> providers = fService.getUstProvider();
+
+ // Check all providers
+ assertNotNull(providers);
+ assertEquals(2, providers.size());
+
+ //Verify first provider
+ assertEquals("/home/user/git/lttng-ust/tests/hello.cxx/.libs/lt-hello", providers.get(0).getName());
+ assertEquals(9379, providers.get(0).getPid());
+
+ // Verify event info
+ IBaseEventInfo[] events = providers.get(0).getEvents();
+ assertNotNull(events);
+ assertEquals(2, events.length);
+
+ IBaseEventInfo baseEventInfo = events[0];
+ assertNotNull(baseEventInfo);
+ IFieldInfo[] fields = baseEventInfo.getFields();
+ assertNotNull(fields);
+ assertEquals(0, fields.length);
+
+ baseEventInfo = events[1];
+ fields = baseEventInfo.getFields();
+ assertNotNull(fields);
+ assertEquals(3, fields.length);
+ assertEquals("doublefield", fields[0].getName());
+ assertEquals("float", fields[0].getFieldType());
+
+ assertEquals("floatfield", fields[1].getName());
+ assertEquals("float", fields[1].getFieldType());
+
+ assertEquals("stringfield", fields[2].getName());
+ assertEquals("string", fields[2].getFieldType());
+
+ //Verify second provider
+ assertEquals("/home/user/git/lttng-ust/tests/hello.cxx/.libs/lt-hello", providers.get(1).getName());
+ assertEquals(4852, providers.get(1).getPid());
+
+ // Verify event info
+ events = providers.get(1).getEvents();
+ assertNotNull(events);
+ assertEquals(2, events.length);
+
+ baseEventInfo = events[0];
+ assertNotNull(baseEventInfo);
+ fields = baseEventInfo.getFields();
+ assertNotNull(fields);
+ assertEquals(0, fields.length);
+
+ baseEventInfo = events[1];
+ fields = baseEventInfo.getFields();
+ assertNotNull(fields);
+ assertEquals(3, fields.length);
+
+ assertEquals("doublefield", fields[0].getName());
+ assertEquals("float", fields[0].getFieldType());
+
+ assertEquals("floatfield", fields[1].getName());
+ assertEquals("float", fields[1].getFieldType());
+
+ assertEquals("stringfield", fields[2].getName());
+ assertEquals("string", fields[2].getFieldType());
+
+ // Reset version
+ ((LTTngControlService)fService).setVersion("2.0.0");
+
} catch (ExecutionException e) {
fail(e.toString());
}
}
}
+ public void testCreateSessionWithPrompt() {
+ try {
+ // First line has the shell prompt before the command output
+ // This can happen in a real application if the command line is not echoed by the shell.
+ fShell.setScenario(SCEN_CREATE_SESSION_WITH_PROMPT);
+
+ // First line has no shell prompt before the output
+ ISessionInfo info = fService.createSession("mysession2", null, new NullProgressMonitor());
+ assertNotNull(info);
+ assertEquals("mysession2", info.getName());
+ assertNotNull(info.getSessionPath());
+ assertTrue(info.getSessionPath().contains("mysession2"));
+ assertEquals(TraceSessionState.INACTIVE, info.getSessionState());
+ } catch (ExecutionException e) {
+ fail(e.toString());
+ }
+ }
+
+
public void testCreateSessionVariants() {
fShell.setScenario(SCEN_CREATE_SESSION_VARIANTS);
} catch (ExecutionException e) {
// success
}
-
+
try {
fService.createSession("wrongName", null, new NullProgressMonitor());
fail("No exeption thrown");
} catch (ExecutionException e) {
// success
- }
+ }
try {
fService.createSession("withPath", "/home/user/hallo", new NullProgressMonitor());
fail("No exeption thrown");
} catch (ExecutionException e) {
// success
- }
+ }
try {
ISessionInfo info = fService.createSession("session with spaces", null, new NullProgressMonitor());
assertNotNull(info.getSessionPath());
assertTrue(info.getSessionPath().contains("session with spaces"));
assertEquals(TraceSessionState.INACTIVE, info.getSessionState());
-
+
} catch (ExecutionException e) {
fail(e.toString());
- }
+ }
try {
ISessionInfo info = fService.createSession("pathWithSpaces", "/home/user/hallo user/here", new NullProgressMonitor());
assertNotNull(info.getSessionPath());
assertTrue(info.getSessionPath().contains("/home/user/hallo user/here"));
assertEquals(TraceSessionState.INACTIVE, info.getSessionState());
-
+
} catch (ExecutionException e) {
fail(e.toString());
- }
+ }
}
public void testDestroySession() {
fService.destroySession("mysession2", new NullProgressMonitor());
} catch (ExecutionException e) {
fail(e.toString());
- }
+ }
}
public void testCreateChannel() {
String kernelChannel1 = "mychannel1";
list.add(kernelChannel0);
list.add(kernelChannel1);
-
+
fShell.setScenario(SCEN_CHANNEL_HANDLING);
-
+
// Create/enable/configure 2 kernel channels
ChannelInfo chanInfo = new ChannelInfo("");
chanInfo.setOverwriteMode(true);
chanInfo.setSwitchTimer(200);
chanInfo.setNumberOfSubBuffers(2);
fService.enableChannels(sessionName, list, true, chanInfo, new NullProgressMonitor());
-
+
// Create/enable/configure 1 UST channel
list.clear();
list.add("ustChannel");
-
+
chanInfo = new ChannelInfo("");
chanInfo.setOverwriteMode(true);
chanInfo.setSubBufferSize(32768);
String kernelChannel1 = "mychannel1";
list.add(kernelChannel0);
list.add(kernelChannel1);
-
+
fShell.setScenario(SCEN_CHANNEL_HANDLING);
fService.disableChannels(sessionName, list, true, new NullProgressMonitor());
-
+
list.clear();
list.add("ustChannel");
fService.disableChannels(sessionName, list, false, new NullProgressMonitor());
fail(e.toString());
}
}
-
+
public void testEnableChannel() {
try {
String kernelChannel1 = "mychannel1";
list.add(kernelChannel0);
list.add(kernelChannel1);
-
+
fShell.setScenario(SCEN_CHANNEL_HANDLING);
fService.enableChannels(sessionName, list, true, null, new NullProgressMonitor());
-
+
// Create/enable/configure 1 UST channel
list.clear();
list.add("ustChannel");
-
+
fService.enableChannels(sessionName, list, false, null, new NullProgressMonitor());
} catch (ExecutionException e) {
fail(e.toString());
}
}
-
+
// public void tesEnableChannelNoTracer() {
// try {
// ILttngControlService service = new LTTngControlService(fShellFactory.getShellForChannelNoTracer());
// service.getSessionNames(new NullProgressMonitor());
// fail("No exeption thrown");
-//
+//
// } catch (ExecutionException e) {
// // success
// }
-// }
-
+// }
+
public void testEnableEvents() {
try {
// 1) session name, channel = null, 3 event names, kernel
list.add(eventName1);
list.add(eventName2);
fShell.setScenario(SCEN_EVENT_HANDLING);
- fService.enableEvents(sessionName, null, list, true, new NullProgressMonitor());
-
+ fService.enableEvents(sessionName, null, list, true, null, new NullProgressMonitor());
+
// 2) session name, channel=mychannel, event name= null, kernel
String channelName = "mychannel";
- fService.enableEvents(sessionName, channelName, null, true, new NullProgressMonitor());
+ fService.enableEvents(sessionName, channelName, null, true, null, new NullProgressMonitor());
- // 3) session name, channel=mychannel, 1 event name, ust
+ // 3) session name, channel=mychannel, 1 event name, ust, no filter
String ustEventName = "ust_tests_hello:tptest_sighandler";
list.clear();
list.add(ustEventName);
- fService.enableEvents(sessionName, channelName, list, false, new NullProgressMonitor());
-
- // 4) session name, channel = mychannel, no event name, ust
+ fService.enableEvents(sessionName, channelName, list, false, null, new NullProgressMonitor());
+
+ // 4) session name, channel = mychannel, no event name, ust, with filter
+ fService.enableEvents(sessionName, channelName, list, false, "intfield==10", new NullProgressMonitor());
+
+ // 5) session name, channel = mychannel, no event name, ust, no filter
list.clear();
- fService.enableEvents(sessionName, channelName, list, false, new NullProgressMonitor());
-
+ fService.enableEvents(sessionName, channelName, list, false, null, new NullProgressMonitor());
+
+ // TODO add test with filters
+
} catch (ExecutionException e) {
fail(e.toString());
}
}
-
+
public void testEnableSyscalls() {
try {
// 1) session name, channel = null, 3 event names, kernel
String sessionName = "mysession2";
String channelName = "mychannel";
-
+
fShell.setScenario(SCEN_EVENT_HANDLING);
- // 1) session name, channel = null
+ // 1) session name, channel = null
fService.enableSyscalls(sessionName, null, new NullProgressMonitor());
// 2) session name, channel = mychannel
fService.enableSyscalls(sessionName, channelName, new NullProgressMonitor());
-
+
} catch (ExecutionException e) {
fail(e.toString());
}
String eventName1 = "myevent1";
String functionProbe = "0xc0101340";
String dynProbe = "init_post";
-
+
fShell.setScenario(SCEN_EVENT_HANDLING);
- // 1) session name, channel = null, event name, function probe, probe
+ // 1) session name, channel = null, event name, function probe, probe
fService.enableProbe(sessionName, null, eventName0, true, functionProbe, new NullProgressMonitor());
// 2) session name, channel = mychannel
fService.enableProbe(sessionName, channelName, eventName1, false, dynProbe, new NullProgressMonitor());
-
+
} catch (ExecutionException e) {
fail(e.toString());
}
String channelName = "mychannel";
String eventName4 = "myevent4";
String eventName5 = "myevent5";
-
+
fShell.setScenario(SCEN_EVENT_HANDLING);
-
+
// 1) session name, channel = null, event name, loglevel-only, TRACE_DEBUG
- fService.enableLogLevel(sessionName, null, eventName4, LogLevelType.LOGLEVEL_ONLY, TraceLogLevel.TRACE_DEBUG, new NullProgressMonitor());
+ fService.enableLogLevel(sessionName, null, eventName4, LogLevelType.LOGLEVEL_ONLY, TraceLogLevel.TRACE_DEBUG, null, new NullProgressMonitor());
// 2) session name, channel = mychannel, null, loglevel, TRACE_DEBUG_FUNCTION
- fService.enableLogLevel(sessionName, channelName, eventName5, LogLevelType.LOGLEVEL, TraceLogLevel.TRACE_DEBUG_FUNCTION, new NullProgressMonitor());
+ fService.enableLogLevel(sessionName, channelName, eventName5, LogLevelType.LOGLEVEL, TraceLogLevel.TRACE_DEBUG_FUNCTION, null, new NullProgressMonitor());
+
+ // TODO add test with filters
} catch (ExecutionException e) {
fail(e.toString());
}
}
-
+
public void testAddContext() {
try {
// 1) session name, channel = null, 3 event names, kernel
assertNotNull(availContexts);
assertEquals(12, availContexts.size());
- // A very "hard-coded" way to verify but it works ...
+ // A very "hard-coded" way to verify but it works ...
Set<String> expectedContexts = new HashSet<String>();
expectedContexts.add("pid");
expectedContexts.add("procname");
expectedContexts.add("vppid");
expectedContexts.add("perf:cpu-cycles");
expectedContexts.add("perf:cycles");
-
+
assertTrue(expectedContexts.containsAll(availContexts));
-
+
// 1) session name, channel = null, event name, loglevel-only, TRACE_DEBUG
fService.addContexts(sessionName, channelName, eventName, false, contexts, new NullProgressMonitor());
fail("No exeption generated");
} catch (ExecutionException e) {
// success
- }
+ }
try {
// 1) session name, channel = null, event name, loglevel-only, TRACE_DEBUG
fService.addContexts(sessionName, channelName, eventName, false, contexts, new NullProgressMonitor());
fail("No exeption generated");
} catch (ExecutionException e) {
// success
- }
+ }
}
public void testCalibrate() {
fail("No exeption generated");
} catch (ExecutionException e) {
// success
- }
+ }
}
-
+
}
projects / deliverable / tracecompass.git / blobdiff