projects / deliverable / tracecompass.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
tmf: lttngControl: show error output first when handling error
[deliverable/tracecompass.git] / org.eclipse.linuxtools.lttng2.control.ui.tests / src / org / eclipse / linuxtools / lttng2 / control / ui / tests / service / LTTngControlServiceTest.java
CommitLineData
eb1bab5b 1/**********************************************************************
60ae41e1 2 * Copyright (c) 2012, 2014 Ericsson
cfdb727a 3 *
eb1bab5b
BH		 4 * All rights reserved. This program and the accompanying materials are
5 * made available under the terms of the Eclipse Public License v1.0 which
6 * accompanies this distribution, and is available at
7 * http://www.eclipse.org/legal/epl-v10.html
cfdb727a
AM		 8 *
9 * Contributors:
eb1bab5b 10 * Bernd Hufmann - Initial API and implementation
2ba3d0a1 11 * Alexandre Montplaisir - Port to JUnit4
81d5dc3a 12 * Marc-Andre Laperle - Support for creating a live session
eb1bab5b 13 **********************************************************************/
2ba3d0a1 14
8e8c0226 15package org.eclipse.linuxtools.lttng2.control.ui.tests.service;
eb1bab5b 16
d128c979
BH		 17import static org.junit.Assert.assertEquals;
18import static org.junit.Assert.assertNotNull;
19import static org.junit.Assert.assertTrue;
20import static org.junit.Assert.fail;
2ba3d0a1 21
d132bcc7
BH		 22import java.io.File;
23import java.net.URL;
24import java.util.ArrayList;
4ea599a5 25import java.util.HashSet;
eb1bab5b 26import java.util.List;
4ea599a5 27import java.util.Set;
eb1bab5b 28
eb1bab5b 29import org.eclipse.core.commands.ExecutionException;
d132bcc7 30import org.eclipse.core.runtime.FileLocator;
bbb3538a 31import org.eclipse.core.runtime.NullProgressMonitor;
d132bcc7 32import org.eclipse.core.runtime.Path;
8e8c0226
AM		 33import org.eclipse.linuxtools.internal.lttng2.control.stubs.service.CommandShellFactory;
34import org.eclipse.linuxtools.internal.lttng2.control.stubs.shells.LTTngToolsFileShell;
35import org.eclipse.linuxtools.internal.lttng2.control.core.model.IBaseEventInfo;
36import org.eclipse.linuxtools.internal.lttng2.control.core.model.IChannelInfo;
37import org.eclipse.linuxtools.internal.lttng2.control.core.model.IDomainInfo;
38import org.eclipse.linuxtools.internal.lttng2.control.core.model.IEventInfo;
39import org.eclipse.linuxtools.internal.lttng2.control.core.model.IFieldInfo;
40import org.eclipse.linuxtools.internal.lttng2.control.core.model.ISessionInfo;
41import org.eclipse.linuxtools.internal.lttng2.control.core.model.ISnapshotInfo;
42import org.eclipse.linuxtools.internal.lttng2.control.core.model.IUstProviderInfo;
43import org.eclipse.linuxtools.internal.lttng2.control.core.model.LogLevelType;
44import org.eclipse.linuxtools.internal.lttng2.control.core.model.TraceEnablement;
45import org.eclipse.linuxtools.internal.lttng2.control.core.model.TraceEventType;
46import org.eclipse.linuxtools.internal.lttng2.control.core.model.TraceLogLevel;
47import org.eclipse.linuxtools.internal.lttng2.control.core.model.TraceSessionState;
48import org.eclipse.linuxtools.internal.lttng2.control.core.model.impl.BufferType;
49import org.eclipse.linuxtools.internal.lttng2.control.core.model.impl.ChannelInfo;
50import org.eclipse.linuxtools.internal.lttng2.control.core.model.impl.SessionInfo;
51import org.eclipse.linuxtools.internal.lttng2.control.ui.Activator;
52import org.eclipse.linuxtools.internal.lttng2.control.ui.views.logging.ControlCommandLogger;
53import org.eclipse.linuxtools.internal.lttng2.control.ui.views.preferences.ControlPreferences;
54import org.eclipse.linuxtools.internal.lttng2.control.ui.views.service.ILttngControlService;
55import org.eclipse.linuxtools.internal.lttng2.control.ui.views.service.LTTngControlService;
56import org.eclipse.linuxtools.internal.lttng2.control.ui.views.service.LTTngControlServiceFactory;
d128c979 57import org.junit.After;
2ba3d0a1
AM		 58import org.junit.Before;
59import org.junit.Test;
9269df72 60import org.osgi.framework.FrameworkUtil;
2ba3d0a1 61
eb1bab5b 62/**
2ba3d0a1
AM		 63 * The class <code>LTTngControlServiceTest</code> contains test for the class
64 * <code>{@link LTTngControlService}</code>.
eb1bab5b 65 */
4e0b52e0 66@SuppressWarnings("javadoc")
2ba3d0a1 67public class LTTngControlServiceTest {
d132bcc7
BH		 68
69 private static final String DIRECTORY = "testfiles";
70 private static final String TEST_STREAM = "LTTngServiceTest.cfg";
cfdb727a 71
d132bcc7 72 private static final String SCEN_LTTNG_NOT_INSTALLED = "LttngNotInstalled";
276c17e7 73 private static final String SCEN_LTTNG_VERSION = "LttngVersion";
d6fc6e1b 74 private static final String SCEN_LTTNG_VERSION_WITH_PROMPT = "LttngVersionWithPrompt";
276c17e7
BH		 75 private static final String SCEN_LTTNG_UNSUPPORTED_VERSION = "LttngUnsupportedVersion";
76 private static final String SCEN_LTTNG_NO_VERSION = "LttngNoVersion";
d132bcc7
BH		 77 private static final String SCEN_NO_SESSION_AVAILABLE = "NoSessionAvailable";
78 private static final String SCEN_GET_SESSION_NAMES1 = "GetSessionNames1";
79 private static final String SCEN_GET_SESSION_NAME_NOT_EXIST = "GetSessionNameNotExist";
d128c979 80 private static final String SCEN_GET_SESSION_NAME_NOT_EXIST_VERBOSE = "GetSessionNameNotExistVerbose";
d132bcc7
BH		 81 private static final String SCEN_GET_SESSION_GARBAGE_OUT = "GetSessionGarbageOut";
82 private static final String SCEN_GET_SESSION1 = "GetSession1";
83 private static final String SCEN_GET_KERNEL_PROVIDER1 = "GetKernelProvider1";
a07c7629
BH		 84 private static final String SCEN_LIST_WITH_NO_KERNEL1 = "ListWithNoKernel1";
85 private static final String SCEN_LIST_WITH_NO_KERNEL2 = "ListWithNoKernel2";
d128c979 86 private static final String SCEN_LIST_WITH_NO_KERNEL_VERBOSE = "ListWithNoKernelVerbose";
d132bcc7
BH		 87 private static final String SCEN_GET_UST_PROVIDER1 = "GetUstProvider1";
88 private static final String SCEN_GET_UST_PROVIDER2 = "GetUstProvider2";
d4514365 89 private static final String SCEN_GET_UST_PROVIDER3 = "GetUstProvider3";
f3e2f354
BH		 90 private static final String SCEN_LIST_WITH_NO_UST1 = "ListWithNoUst1";
91 private static final String SCEN_LIST_WITH_NO_UST2 = "ListWithNoUst2";
92 private static final String SCEN_LIST_WITH_NO_UST3 = "ListWithNoUst3";
93 private static final String SCEN_LIST_WITH_NO_UST_VERBOSE = "ListWithNoUstVerbose";
d132bcc7 94 private static final String SCEN_CREATE_SESSION1 = "CreateSession1";
d6fc6e1b 95 private static final String SCEN_CREATE_SESSION_WITH_PROMPT = "CreateSessionWithPrompt";
d132bcc7
BH		 96 private static final String SCEN_CREATE_SESSION_VARIANTS = "CreateSessionVariants";
97 private static final String SCEN_DESTROY_SESSION1 = "DestroySession1";
d128c979 98 private static final String SCEN_DESTROY_SESSION_VERBOSE = "DestroySessionVerbose";
d132bcc7
BH		 99 private static final String SCEN_CHANNEL_HANDLING = "ChannelHandling";
100 private static final String SCEN_EVENT_HANDLING = "EventHandling";
4ea599a5
BH		 101 private static final String SCEN_CONTEXT_HANDLING = "ContextHandling";
102 private static final String SCEN_CONTEXT_ERROR_HANDLING = "ContextErrorHandling";
103 private static final String SCEN_CALIBRATE_HANDLING = "CalibrateHandling";
f3b33d40 104 private static final String SCEN_CREATE_SESSION_2_1 = "CreateSessionLttng2.1";
d128c979 105 private static final String SCEN_CREATE_SESSION_VERBOSE_2_1 = "CreateSessionLttngVerbose2.1";
589d0d33
BH		 106 private static final String SCEN_CREATE_SNAPSHOT_SESSION = "CreateSessionSnapshot";
107 private static final String SCEN_CREATE_STREAMED_SNAPSHOT_SESSION = "CreateSessionStreamedSnapshot";
108 private static final String SCEN_CREATE_SNAPSHOT_SESSION_ERRORS = "CreateSessionSnapshotErrors";
81d5dc3a
MAL		 109 private static final String SCEN_CREATE_LIVE_SESSION = "CreateSessionLive";
110 private static final String SCEN_CREATE_LIVE_SESSION_ERRORS = "CreateSessionLiveErrors";
d132bcc7 111
eb1bab5b
BH		 112 // ------------------------------------------------------------------------
113 // Test data
114 // ------------------------------------------------------------------------
2ba3d0a1 115
d132bcc7
BH		 116 private CommandShellFactory fShellFactory;
117 private String fTestfile;
118 private LTTngToolsFileShell fShell;
119 private ILttngControlService fService;
120
eb1bab5b
BH		 121 // ------------------------------------------------------------------------
122 // Housekeeping
123 // ------------------------------------------------------------------------
2ba3d0a1 124
eb1bab5b
BH		 125 /**
126 * Perform pre-test initialization.
127 *
2ba3d0a1
AM		 128 * @throws Exception
129 * if the initialization fails for some reason
eb1bab5b 130 */
2ba3d0a1 131 @Before
eb1bab5b 132 public void setUp() throws Exception {
eb1bab5b 133 fShellFactory = CommandShellFactory.getInstance();
d132bcc7 134
9269df72 135 URL location = FileLocator.find(FrameworkUtil.getBundle(this.getClass()), new Path(DIRECTORY + File.separator + TEST_STREAM), null);
d132bcc7
BH		 136 File testfile = new File(FileLocator.toFileURL(location).toURI());
137 fTestfile = testfile.getAbsolutePath();
cfdb727a 138
d132bcc7
BH		 139 fShell = fShellFactory.getFileShell();
140 fShell.loadScenarioFile(fTestfile);
141 fService = new LTTngControlService(fShell);
d128c979
BH		 142
143 ControlPreferences.getInstance().init(Activator.getDefault().getPreferenceStore());
144 }
145
146 @After
147 public void tearDown() {
148 disableVerbose();
149 ControlPreferences.getInstance().dispose();
eb1bab5b
BH		 150 }
151
eb1bab5b
BH		 152 // ------------------------------------------------------------------------
153 // Test Cases
154 // ------------------------------------------------------------------------
cfdb727a 155
2ba3d0a1 156 @Test
276c17e7
BH		 157 public void testVersion() {
158 try {
159 fShell.setScenario(SCEN_LTTNG_VERSION);
cfdb727a 160 ILttngControlService service = LTTngControlServiceFactory.getInstance().getLttngControlService(fShell);
276c17e7 161 assertNotNull(service);
0df4af5f 162 assertEquals("2.1.0", service.getVersionString());
276c17e7
BH		 163 } catch (ExecutionException e) {
164 fail("Exeption thrown " + e);
165 }
166 }
cfdb727a 167
2ba3d0a1 168 @Test
d6fc6e1b
BH		 169 public void testVersionWithPrompt() {
170 try {
171 fShell.setScenario(SCEN_LTTNG_VERSION_WITH_PROMPT);
172 ILttngControlService service = LTTngControlServiceFactory.getInstance().getLttngControlService(fShell);
173 assertNotNull(service);
0df4af5f 174 assertEquals("2.0.0", service.getVersionString());
d6fc6e1b
BH		 175 } catch (ExecutionException e) {
176 fail("Exeption thrown " + e);
177 }
178 }
a07c7629 179
2ba3d0a1 180 @Test
276c17e7
BH		 181 public void testUnsupportedVersion() {
182 try {
183 fShell.setScenario(SCEN_LTTNG_UNSUPPORTED_VERSION);
cfdb727a 184 LTTngControlServiceFactory.getInstance().getLttngControlService(fShell);
276c17e7
BH		 185 fail("No exeption thrown");
186 } catch (ExecutionException e) {
187 // success
188 }
189 }
190
2ba3d0a1 191 @Test
276c17e7
BH		 192 public void testNoVersion() {
193 try {
194 fShell.setScenario(SCEN_LTTNG_NO_VERSION);
cfdb727a 195 LTTngControlServiceFactory.getInstance().getLttngControlService(fShell);
276c17e7
BH		 196 fail("No exeption thrown");
197 } catch (ExecutionException e) {
198 // success
199 }
200 }
201
2ba3d0a1 202 @Test
276c17e7 203 public void testLttngNotInstalled() {
eb1bab5b 204 try {
d132bcc7
BH		 205 fShell.setScenario(SCEN_LTTNG_NOT_INSTALLED);
206 fService.getSessionNames(new NullProgressMonitor());
eb1bab5b 207 fail("No exeption thrown");
eb1bab5b
BH		 208 } catch (ExecutionException e) {
209 // success
210 }
211 }
cfdb727a 212
2ba3d0a1 213 @Test
eb1bab5b
BH		 214 public void testGetSessionNames1() {
215 try {
d132bcc7
BH		 216 fShell.setScenario(SCEN_NO_SESSION_AVAILABLE);
217 String[] result = fService.getSessionNames(new NullProgressMonitor());
eb1bab5b
BH		 218
219 assertNotNull(result);
220 assertEquals(0, result.length);
cfdb727a 221
eb1bab5b
BH		 222 } catch (ExecutionException e) {
223 fail(e.toString());
224 }
225 }
d132bcc7 226
2ba3d0a1 227 @Test
eb1bab5b
BH		 228 public void testGetSessionNames2() {
229 try {
d132bcc7
BH		 230 fShell.setScenario(SCEN_GET_SESSION_NAMES1);
231 String[] result = fService.getSessionNames(new NullProgressMonitor());
eb1bab5b
BH		 232
233 assertNotNull(result);
234 assertEquals(2, result.length);
235 assertEquals("mysession1", result[0]);
236 assertEquals("mysession", result[1]);
cfdb727a 237
eb1bab5b
BH		 238 } catch (ExecutionException e) {
239 fail(e.toString());
240 }
241 }
d132bcc7 242
2ba3d0a1 243 @Test
eb1bab5b
BH		 244 public void testGetSessionNotExist() {
245 try {
d132bcc7
BH		 246 fShell.setScenario(SCEN_GET_SESSION_NAME_NOT_EXIST);
247 fService.getSessionNames(new NullProgressMonitor());
eb1bab5b 248 fail("No exeption thrown");
cfdb727a 249
eb1bab5b
BH		 250 } catch (ExecutionException e) {
251 // success
252 }
253 }
cfdb727a 254
d128c979
BH		 255 @Test
256 public void testGetSessionNotExistVerbose() {
257 try {
258 enableVerbose();
259 fShell.setScenario(SCEN_GET_SESSION_NAME_NOT_EXIST_VERBOSE);
260 fService.getSessionNames(new NullProgressMonitor());
261 fail("No exeption thrown");
262
263 } catch (ExecutionException e) {
264 // success
265 } finally {
266 disableVerbose();
267 }
268 }
269
2ba3d0a1 270 @Test
eb1bab5b
BH		 271 public void testGetSessionNameGarbage() {
272 try {
d132bcc7
BH		 273 fShell.setScenario(SCEN_GET_SESSION_GARBAGE_OUT);
274 String[] result = fService.getSessionNames(new NullProgressMonitor());
eb1bab5b
BH		 275
276 assertNotNull(result);
277 assertEquals(0, result.length);
cfdb727a 278
eb1bab5b
BH		 279 } catch (ExecutionException e) {
280 fail(e.toString());
281 }
282 }
cfdb727a 283
2ba3d0a1 284 @Test
eb1bab5b
BH		 285 public void testGetSession1() {
286 try {
d132bcc7
BH		 287 fShell.setScenario(SCEN_GET_SESSION1);
288 ISessionInfo session = fService.getSession("mysession", new NullProgressMonitor());
eb1bab5b
BH		 289
290 // Verify Session
291 assertNotNull(session);
292 assertEquals("mysession", session.getName());
293 assertEquals("/home/user/lttng-traces/mysession-20120129-084256", session.getSessionPath());
294 assertEquals(TraceSessionState.ACTIVE, session.getSessionState());
cfdb727a 295
eb1bab5b
BH		 296 IDomainInfo[] domains = session.getDomains();
297 assertNotNull(domains);
298 assertEquals(2, domains.length);
cfdb727a 299
eb1bab5b
BH		 300 // Verify Kernel domain
301 assertEquals("Kernel", domains[0].getName());
302 IChannelInfo[] channels = domains[0].getChannels();
303 assertNotNull(channels);
304 assertEquals(2, channels.length);
305
cfdb727a 306 // Verify Kernel's channel0
eb1bab5b
BH		 307 assertEquals("channel0", channels[0].getName());
308 assertEquals(4, channels[0].getNumberOfSubBuffers());
309 assertEquals("splice()", channels[0].getOutputType());
310 assertEquals(false, channels[0].isOverwriteMode());
311 assertEquals(200, channels[0].getReadTimer());
312 assertEquals(TraceEnablement.ENABLED, channels[0].getState());
313 assertEquals(262144, channels[0].getSubBufferSize());
314 assertEquals(0, channels[0].getSwitchTimer());
cfdb727a 315
eb1bab5b
BH		 316 // Verify event info
317 IEventInfo[] channel0Events = channels[0].getEvents();
318 assertNotNull(channel0Events);
319 assertEquals(2, channel0Events.length);
320 assertEquals("block_rq_remap", channel0Events[0].getName());
321 assertEquals(TraceLogLevel.TRACE_EMERG, channel0Events[0].getLogLevel());
322 assertEquals(TraceEventType.TRACEPOINT, channel0Events[0].getEventType());
323 assertEquals(TraceEnablement.ENABLED, channel0Events[0].getState());
cfdb727a 324
eb1bab5b
BH		 325 assertEquals("block_bio_remap", channel0Events[1].getName());
326 assertEquals(TraceLogLevel.TRACE_EMERG, channel0Events[1].getLogLevel());
327 assertEquals(TraceEventType.TRACEPOINT, channel0Events[1].getEventType());
328 assertEquals(TraceEnablement.DISABLED, channel0Events[1].getState());
cfdb727a
AM		 329
330 // Verify Kernel's channel1
eb1bab5b
BH		 331 assertEquals("channel1", channels[1].getName());
332 assertEquals(4, channels[1].getNumberOfSubBuffers());
333 assertEquals("splice()", channels[1].getOutputType());
334 assertEquals(true, channels[1].isOverwriteMode());
335 assertEquals(400, channels[1].getReadTimer());
336 assertEquals(TraceEnablement.DISABLED, channels[1].getState());
337 assertEquals(524288, channels[1].getSubBufferSize());
338 assertEquals(100, channels[1].getSwitchTimer());
cfdb727a 339
eb1bab5b
BH		 340 // Verify event info
341 IEventInfo[] channel1Events = channels[1].getEvents();
342 assertEquals(0, channel1Events.length);
cfdb727a 343
eb1bab5b
BH		 344 // Verify domain UST global
345 assertEquals("UST global", domains[1].getName());
cfdb727a 346
eb1bab5b 347 IChannelInfo[] ustChannels = domains[1].getChannels();
cfdb727a
AM		 348
349 // Verify UST global's mychannel1
eb1bab5b
BH		 350 assertEquals("mychannel1", ustChannels[0].getName());
351 assertEquals(8, ustChannels[0].getNumberOfSubBuffers());
352 assertEquals("mmap()", ustChannels[0].getOutputType());
353 assertEquals(true, ustChannels[0].isOverwriteMode());
354 assertEquals(100, ustChannels[0].getReadTimer());
355 assertEquals(TraceEnablement.DISABLED, ustChannels[0].getState());
356 assertEquals(8192, ustChannels[0].getSubBufferSize());
357 assertEquals(200, ustChannels[0].getSwitchTimer());
cfdb727a 358
eb1bab5b
BH		 359 // Verify event info
360 IEventInfo[] ustEvents = ustChannels[0].getEvents();
361 assertEquals(0, ustEvents.length);
362
cfdb727a 363 // Verify UST global's channel0
eb1bab5b
BH		 364 assertEquals("channel0", ustChannels[1].getName());
365 assertEquals(4, ustChannels[1].getNumberOfSubBuffers());
366 assertEquals("mmap()", ustChannels[1].getOutputType());
367 assertEquals(false, ustChannels[1].isOverwriteMode());
368 assertEquals(200, ustChannels[1].getReadTimer());
369 assertEquals(TraceEnablement.ENABLED, ustChannels[1].getState());
370 assertEquals(4096, ustChannels[1].getSubBufferSize());
371 assertEquals(0, ustChannels[1].getSwitchTimer());
cfdb727a 372
eb1bab5b
BH		 373 // Verify event info
374 ustEvents = ustChannels[1].getEvents();
375 assertEquals(2, ustEvents.length);
cfdb727a 376
eb1bab5b 377 assertEquals("ust_tests_hello:tptest_sighandler", ustEvents[0].getName());
4775bcbf 378 assertEquals(TraceLogLevel.TRACE_DEBUG_LINE, ustEvents[0].getLogLevel());
eb1bab5b
BH		 379 assertEquals(TraceEventType.TRACEPOINT, ustEvents[0].getEventType());
380 assertEquals(TraceEnablement.DISABLED, ustEvents[0].getState());
cfdb727a 381
eb1bab5b 382 assertEquals("*", ustEvents[1].getName());
4775bcbf 383 assertEquals(TraceLogLevel.LEVEL_UNKNOWN, ustEvents[1].getLogLevel());
eb1bab5b
BH		 384 assertEquals(TraceEventType.TRACEPOINT, ustEvents[1].getEventType());
385 assertEquals(TraceEnablement.ENABLED, ustEvents[1].getState());
cfdb727a 386
eb1bab5b 387 // next session (no detailed information available)
d132bcc7 388 session = fService.getSession("mysession1", new NullProgressMonitor());
eb1bab5b
BH		 389 assertNotNull(session);
390 assertEquals("mysession1", session.getName());
391 assertEquals("/home/user/lttng-traces/mysession1-20120203-133225", session.getSessionPath());
392 assertEquals(TraceSessionState.INACTIVE, session.getSessionState());
cfdb727a 393
eb1bab5b
BH		 394 domains = session.getDomains();
395 assertNotNull(domains);
396 assertEquals(0, domains.length);
397 } catch (ExecutionException e) {
398 fail(e.toString());
399 }
400 }
401
402 public void testGetKernelProvider() {
403 try {
d132bcc7
BH		 404 fShell.setScenario(SCEN_GET_KERNEL_PROVIDER1);
405 List<IBaseEventInfo> events = fService.getKernelProvider(new NullProgressMonitor());
eb1bab5b
BH		 406
407 // Verify event info
408 assertNotNull(events);
409 assertEquals(3, events.size());
cfdb727a
AM		 410
411 IBaseEventInfo baseEventInfo = events.get(0);
eb1bab5b
BH		 412 assertNotNull(baseEventInfo);
413 assertEquals("sched_kthread_stop", baseEventInfo.getName());
414 assertEquals(TraceLogLevel.TRACE_EMERG, baseEventInfo.getLogLevel());
415 assertEquals(TraceEventType.TRACEPOINT, baseEventInfo.getEventType());
cfdb727a
AM		 416
417 baseEventInfo = events.get(1);
eb1bab5b
BH		 418 assertEquals("sched_kthread_stop_ret", baseEventInfo.getName());
419 assertEquals(TraceLogLevel.TRACE_EMERG, baseEventInfo.getLogLevel());
420 assertEquals(TraceEventType.TRACEPOINT, baseEventInfo.getEventType());
cfdb727a
AM		 421
422 baseEventInfo = events.get(2);
eb1bab5b
BH		 423 assertEquals("sched_wakeup_new", baseEventInfo.getName());
424 assertEquals(TraceLogLevel.TRACE_EMERG, baseEventInfo.getLogLevel());
425 assertEquals(TraceEventType.TRACEPOINT, baseEventInfo.getEventType());
426
427 } catch (ExecutionException e) {
428 fail(e.toString());
429 }
430 }
431
2ba3d0a1 432 @Test
a07c7629
BH		 433 public void testGetKernelProviderNoKernel1() {
434 try {
435 fShell.setScenario(SCEN_LIST_WITH_NO_KERNEL1);
436 List<IBaseEventInfo> events = fService.getKernelProvider(new NullProgressMonitor());
437
438 // Verify event info
439 assertNotNull(events);
440 assertEquals(0, events.size());
441
442 } catch (ExecutionException e) {
443 fail(e.toString());
444 }
445 }
446
2ba3d0a1 447 @Test
a07c7629
BH		 448 public void testGetKernelProviderNoKernel2() {
449 try {
450 fShell.setScenario(SCEN_LIST_WITH_NO_KERNEL2);
451 List<IBaseEventInfo> events = fService.getKernelProvider(new NullProgressMonitor());
452
453 // Verify event info
454 assertNotNull(events);
455 assertEquals(0, events.size());
456
457 } catch (ExecutionException e) {
458 fail(e.toString());
459 }
460 }
461
d128c979
BH		 462 @Test
463 public void testGetKernelProviderNoKernelVerbose() {
464 try {
465 enableVerbose();
466 fShell.setScenario(SCEN_LIST_WITH_NO_KERNEL_VERBOSE);
467 List<IBaseEventInfo> events = fService.getKernelProvider(new NullProgressMonitor());
468
469 // Verify event info
470 assertNotNull(events);
471 assertEquals(0, events.size());
472
473 } catch (ExecutionException e) {
474 fail(e.toString());
475 } finally {
476 disableVerbose();
477 }
478 }
479
2ba3d0a1 480 @Test
eb1bab5b
BH		 481 public void testGetUstProvider() {
482 try {
d132bcc7
BH		 483 fShell.setScenario(SCEN_GET_UST_PROVIDER1);
484 List<IUstProviderInfo> providers = fService.getUstProvider();
eb1bab5b
BH		 485
486 // Check all providers
487 assertNotNull(providers);
488 assertEquals(2, providers.size());
cfdb727a 489
eb1bab5b
BH		 490 //Verify first provider
491 assertEquals("/home/user/git/lttng-ust/tests/hello.cxx/.libs/lt-hello", providers.get(0).getName());
492 assertEquals(9379, providers.get(0).getPid());
cfdb727a 493
eb1bab5b
BH		 494 // Verify event info
495 IBaseEventInfo[] events = providers.get(0).getEvents();
496 assertNotNull(events);
497 assertEquals(2, events.length);
498
cfdb727a 499 IBaseEventInfo baseEventInfo = events[0];
eb1bab5b
BH		 500 assertNotNull(baseEventInfo);
501 assertEquals("ust_tests_hello:tptest_sighandler", baseEventInfo.getName());
4775bcbf 502 assertEquals(TraceLogLevel.TRACE_DEBUG_MODULE, baseEventInfo.getLogLevel());
eb1bab5b 503 assertEquals(TraceEventType.TRACEPOINT, baseEventInfo.getEventType());
cfdb727a
AM		 504
505 baseEventInfo = events[1];
eb1bab5b
BH		 506 assertEquals("ust_tests_hello:tptest", baseEventInfo.getName());
507 assertEquals(TraceLogLevel.TRACE_INFO, baseEventInfo.getLogLevel());
508 assertEquals(TraceEventType.TRACEPOINT, baseEventInfo.getEventType());
509
510 //Verify second provider
511 assertEquals("/home/user/git/lttng-ust/tests/hello.cxx/.libs/lt-hello", providers.get(1).getName());
512 assertEquals(4852, providers.get(1).getPid());
cfdb727a 513
eb1bab5b
BH		 514 // Verify event info
515 events = providers.get(1).getEvents();
516 assertNotNull(events);
517 assertEquals(2, events.length);
518
cfdb727a 519 baseEventInfo = events[0];
eb1bab5b
BH		 520 assertNotNull(baseEventInfo);
521 assertEquals("ust_tests_hello:tptest_sighandler", baseEventInfo.getName());
522 assertEquals(TraceLogLevel.TRACE_WARNING, baseEventInfo.getLogLevel());
523 assertEquals(TraceEventType.TRACEPOINT, baseEventInfo.getEventType());
cfdb727a
AM		 524
525 baseEventInfo = events[1];
eb1bab5b 526 assertEquals("ust_tests_hello:tptest", baseEventInfo.getName());
4775bcbf 527 assertEquals(TraceLogLevel.TRACE_DEBUG_FUNCTION, baseEventInfo.getLogLevel());
eb1bab5b
BH		 528 assertEquals(TraceEventType.TRACEPOINT, baseEventInfo.getEventType());
529
530 } catch (ExecutionException e) {
531 fail(e.toString());
532 }
533 }
d132bcc7 534
2ba3d0a1 535 @Test
eb1bab5b
BH		 536 public void testUstProvider2() {
537 try {
d132bcc7
BH		 538 fShell.setScenario(SCEN_GET_UST_PROVIDER2);
539 List<IUstProviderInfo> providers = fService.getUstProvider();
eb1bab5b
BH		 540
541 assertNotNull(providers);
542 assertEquals(0, providers.size());
cfdb727a 543
eb1bab5b
BH		 544 } catch (ExecutionException e) {
545 fail(e.toString());
546 }
547 }
d132bcc7 548
2ba3d0a1 549 @Test
d4514365
BH		 550 public void testGetUstProvider3() {
551 try {
552 fShell.setScenario(SCEN_GET_UST_PROVIDER3);
553 // Set version
554 ((LTTngControlService)fService).setVersion("2.1.0");
555 List<IUstProviderInfo> providers = fService.getUstProvider();
556
557 // Check all providers
558 assertNotNull(providers);
559 assertEquals(2, providers.size());
560
561 //Verify first provider
562 assertEquals("/home/user/git/lttng-ust/tests/hello.cxx/.libs/lt-hello", providers.get(0).getName());
563 assertEquals(9379, providers.get(0).getPid());
564
565 // Verify event info
566 IBaseEventInfo[] events = providers.get(0).getEvents();
567 assertNotNull(events);
568 assertEquals(2, events.length);
569
570 IBaseEventInfo baseEventInfo = events[0];
571 assertNotNull(baseEventInfo);
572 IFieldInfo[] fields = baseEventInfo.getFields();
573 assertNotNull(fields);
574 assertEquals(0, fields.length);
575
576 baseEventInfo = events[1];
577 fields = baseEventInfo.getFields();
578 assertNotNull(fields);
579 assertEquals(3, fields.length);
580 assertEquals("doublefield", fields[0].getName());
581 assertEquals("float", fields[0].getFieldType());
582
583 assertEquals("floatfield", fields[1].getName());
584 assertEquals("float", fields[1].getFieldType());
585
586 assertEquals("stringfield", fields[2].getName());
587 assertEquals("string", fields[2].getFieldType());
588
589 //Verify second provider
590 assertEquals("/home/user/git/lttng-ust/tests/hello.cxx/.libs/lt-hello", providers.get(1).getName());
591 assertEquals(4852, providers.get(1).getPid());
592
593 // Verify event info
594 events = providers.get(1).getEvents();
595 assertNotNull(events);
596 assertEquals(2, events.length);
597
598 baseEventInfo = events[0];
599 assertNotNull(baseEventInfo);
600 fields = baseEventInfo.getFields();
601 assertNotNull(fields);
602 assertEquals(0, fields.length);
603
604 baseEventInfo = events[1];
605 fields = baseEventInfo.getFields();
606 assertNotNull(fields);
607 assertEquals(3, fields.length);
608
609 assertEquals("doublefield", fields[0].getName());
610 assertEquals("float", fields[0].getFieldType());
611
612 assertEquals("floatfield", fields[1].getName());
613 assertEquals("float", fields[1].getFieldType());
614
615 assertEquals("stringfield", fields[2].getName());
616 assertEquals("string", fields[2].getFieldType());
617
618 // Reset version
619 ((LTTngControlService)fService).setVersion("2.0.0");
620
621 } catch (ExecutionException e) {
622 fail(e.toString());
623 }
624 }
625
f3e2f354
BH		 626
627 @Test
628 public void testGetKernelProviderNoUst1() {
629 try {
630 fShell.setScenario(SCEN_LIST_WITH_NO_UST1);
631 List<IUstProviderInfo> providerList = fService.getUstProvider(new NullProgressMonitor());
632
633 // Verify Provider info
634 assertNotNull(providerList);
635 assertEquals(0, providerList.size());
636
637 } catch (ExecutionException e) {
638 fail(e.toString());
639 }
640 }
641
642
643 @Test
644 public void testGetKernelProviderNoUst2() {
645 try {
646 // Set version
647 ((LTTngControlService)fService).setVersion("2.1.0");
648
649 fShell.setScenario(SCEN_LIST_WITH_NO_UST2);
650 List<IUstProviderInfo> providerList = fService.getUstProvider(new NullProgressMonitor());
651
652 // Verify Provider info
653 assertNotNull(providerList);
654 assertEquals(0, providerList.size());
655
656 // Reset version
657 ((LTTngControlService)fService).setVersion("2.0.0");
658
659 } catch (ExecutionException e) {
660 fail(e.toString());
661 }
662 }
663
664 @Test
665 public void testGetKernelProviderNoUst3() {
666 try {
667
668 // Set version
669 ((LTTngControlService)fService).setVersion("2.1.0");
670
671 fShell.setScenario(SCEN_LIST_WITH_NO_UST3);
672 List<IUstProviderInfo> providerList = fService.getUstProvider(new NullProgressMonitor());
673
674 // Verify provider info
675 assertNotNull(providerList);
676 assertEquals(0, providerList.size());
677
678 // Reset version
679 ((LTTngControlService)fService).setVersion("2.0.0");
680
681 } catch (ExecutionException e) {
682 fail(e.toString());
683 }
684 }
685
686 @Test
687 public void testGetKernelProviderNoUstVerbose() {
688 try {
689 enableVerbose();
690
691 // Set version
692 ((LTTngControlService)fService).setVersion("2.1.0");
693
694 fShell.setScenario(SCEN_LIST_WITH_NO_UST_VERBOSE);
695 List<IUstProviderInfo> providerList = fService.getUstProvider(new NullProgressMonitor());
696
697 // Verify provider info
698 assertNotNull(providerList);
699 assertEquals(0, providerList.size());
700
701 // Reset version
702 ((LTTngControlService)fService).setVersion("2.0.0");
703
704 } catch (ExecutionException e) {
705 fail(e.toString());
706 } finally {
707 disableVerbose();
708 }
709 }
710
711
712
2ba3d0a1 713 @Test
bbb3538a
BH		 714 public void testCreateSession() {
715 try {
d132bcc7
BH		 716 fShell.setScenario(SCEN_CREATE_SESSION1);
717
f7d4d450 718 ISessionInfo info = fService.createSession(new SessionInfo("mysession2"), new NullProgressMonitor());
bbb3538a
BH		 719 assertNotNull(info);
720 assertEquals("mysession2", info.getName());
721 assertNotNull(info.getSessionPath());
722 assertTrue(info.getSessionPath().contains("mysession2"));
723 assertEquals(TraceSessionState.INACTIVE, info.getSessionState());
724 } catch (ExecutionException e) {
725 fail(e.toString());
726 }
727 }
d132bcc7 728
2ba3d0a1 729 @Test
d6fc6e1b
BH		 730 public void testCreateSessionWithPrompt() {
731 try {
a07c7629 732 // First line has the shell prompt before the command output
d6fc6e1b
BH		 733 // This can happen in a real application if the command line is not echoed by the shell.
734 fShell.setScenario(SCEN_CREATE_SESSION_WITH_PROMPT);
735
736 // First line has no shell prompt before the output
f7d4d450 737 ISessionInfo info = fService.createSession(new SessionInfo("mysession2"), new NullProgressMonitor());
d6fc6e1b
BH		 738 assertNotNull(info);
739 assertEquals("mysession2", info.getName());
740 assertNotNull(info.getSessionPath());
741 assertTrue(info.getSessionPath().contains("mysession2"));
742 assertEquals(TraceSessionState.INACTIVE, info.getSessionState());
743 } catch (ExecutionException e) {
744 fail(e.toString());
745 }
746 }
747
2ba3d0a1 748 @Test
d132bcc7
BH		 749 public void testCreateSessionVariants() {
750
751 fShell.setScenario(SCEN_CREATE_SESSION_VARIANTS);
752
bbb3538a 753 try {
f7d4d450 754 fService.createSession(new SessionInfo("alreadyExist"), new NullProgressMonitor());
bbb3538a
BH		 755 fail("No exeption thrown");
756 } catch (ExecutionException e) {
757 // success
758 }
cfdb727a 759
bbb3538a 760 try {
f7d4d450 761 fService.createSession(new SessionInfo("wrongName"), new NullProgressMonitor());
bbb3538a
BH		 762 fail("No exeption thrown");
763 } catch (ExecutionException e) {
764 // success
cfdb727a 765 }
bbb3538a
BH		 766
767 try {
f7d4d450
MAL		 768 ISessionInfo sessionInfo = new SessionInfo("withPath");
769 sessionInfo.setSessionPath("/home/user/hallo");
770 fService.createSession(sessionInfo, new NullProgressMonitor());
bbb3538a
BH		 771 fail("No exeption thrown");
772 } catch (ExecutionException e) {
773 // success
cfdb727a 774 }
bbb3538a
BH		 775
776 try {
f7d4d450 777 ISessionInfo info = fService.createSession(new SessionInfo("session with spaces"), new NullProgressMonitor());
bbb3538a
BH		 778 assertNotNull(info);
779 assertEquals("session with spaces", info.getName());
780 assertNotNull(info.getSessionPath());
781 assertTrue(info.getSessionPath().contains("session with spaces"));
782 assertEquals(TraceSessionState.INACTIVE, info.getSessionState());
cfdb727a 783
bbb3538a
BH		 784 } catch (ExecutionException e) {
785 fail(e.toString());
cfdb727a 786 }
bbb3538a
BH		 787
788 try {
f7d4d450
MAL		 789 ISessionInfo sessionInfo = new SessionInfo("pathWithSpaces");
790 sessionInfo.setSessionPath("/home/user/hallo user/here");
791 ISessionInfo info = fService.createSession(sessionInfo, new NullProgressMonitor());
bbb3538a
BH		 792 assertNotNull(info);
793 assertEquals("pathWithSpaces", info.getName());
794 assertNotNull(info.getSessionPath());
795 assertTrue(info.getSessionPath().contains("/home/user/hallo user/here"));
796 assertEquals(TraceSessionState.INACTIVE, info.getSessionState());
cfdb727a 797
bbb3538a
BH		 798 } catch (ExecutionException e) {
799 fail(e.toString());
cfdb727a 800 }
bbb3538a
BH		 801 }
802
2ba3d0a1 803 @Test
9d8a90ad 804 public void testDestroySession() {
bbb3538a 805 try {
d132bcc7
BH		 806 fShell.setScenario(SCEN_DESTROY_SESSION1);
807 fService.destroySession("mysession2", new NullProgressMonitor());
bbb3538a
BH		 808 } catch (ExecutionException e) {
809 fail(e.toString());
cfdb727a 810 }
bbb3538a 811 }
d132bcc7 812
d128c979
BH		 813 @Test
814 public void testDestroySessionVerbose() {
815 try {
816 enableVerbose();
817 fShell.setScenario(SCEN_DESTROY_SESSION_VERBOSE);
818 fService.destroySession("mysession2", new NullProgressMonitor());
819 } catch (ExecutionException e) {
820 fail(e.toString());
821 } finally {
822 disableVerbose();
823 }
824 }
825
2ba3d0a1 826 @Test
d132bcc7
BH		 827 public void testCreateChannel() {
828 try {
83051fc3 829 ((LTTngControlService)fService).setVersion("2.2.0");
d132bcc7 830 String sessionName = "mysession2";
e0838ca1 831 List<String> list = new ArrayList<>();
d132bcc7
BH		 832 String kernelChannel0 = "mychannel0";
833 String kernelChannel1 = "mychannel1";
834 list.add(kernelChannel0);
835 list.add(kernelChannel1);
cfdb727a 836
d132bcc7 837 fShell.setScenario(SCEN_CHANNEL_HANDLING);
cfdb727a 838
d132bcc7
BH		 839 // Create/enable/configure 2 kernel channels
840 ChannelInfo chanInfo = new ChannelInfo("");
841 chanInfo.setOverwriteMode(true);
842 chanInfo.setSubBufferSize(16384);
843 chanInfo.setReadTimer(100);
844 chanInfo.setSwitchTimer(200);
845 chanInfo.setNumberOfSubBuffers(2);
e799e5f3
SD		 846 chanInfo.setMaxNumberTraceFiles(10);
847 chanInfo.setMaxSizeTraceFiles(0);
d132bcc7 848 fService.enableChannels(sessionName, list, true, chanInfo, new NullProgressMonitor());
cfdb727a 849
d132bcc7
BH		 850 // Create/enable/configure 1 UST channel
851 list.clear();
852 list.add("ustChannel");
cfdb727a 853
d132bcc7
BH		 854 chanInfo = new ChannelInfo("");
855 chanInfo.setOverwriteMode(true);
856 chanInfo.setSubBufferSize(32768);
857 chanInfo.setReadTimer(200);
858 chanInfo.setSwitchTimer(100);
859 chanInfo.setNumberOfSubBuffers(1);
e799e5f3
SD		 860 chanInfo.setMaxNumberTraceFiles(20);
861 chanInfo.setMaxSizeTraceFiles(0);
862 fService.enableChannels(sessionName, list, false, chanInfo, new NullProgressMonitor());
83051fc3 863 ((LTTngControlService)fService).setVersion("2.0.0");
e799e5f3
SD		 864
865 } catch (ExecutionException e) {
866 fail(e.toString());
867 }
868 }
869
870 @Test
871 public void testCreateChannelUIDBuffer() {
872 try {
83051fc3 873 ((LTTngControlService)fService).setVersion("2.2.0");
e799e5f3 874 String sessionName = "mysession2";
e0838ca1 875 List<String> list = new ArrayList<>();
e799e5f3
SD		 876 String USTChannel = "ustChannel";
877 list.add(USTChannel);
878 fShell.setScenario(SCEN_CHANNEL_HANDLING);
879
880 ChannelInfo chanInfo = new ChannelInfo("");
881 chanInfo.setOverwriteMode(true);
882 chanInfo.setSubBufferSize(32768);
883 chanInfo.setReadTimer(200);
884 chanInfo.setSwitchTimer(100);
885 chanInfo.setNumberOfSubBuffers(1);
886 chanInfo.setMaxNumberTraceFiles(20);
887 chanInfo.setMaxSizeTraceFiles(0);
83051fc3 888 chanInfo.setBufferType(BufferType.BUFFER_PER_UID);
d132bcc7 889 fService.enableChannels(sessionName, list, false, chanInfo, new NullProgressMonitor());
83051fc3
BH		 890 ((LTTngControlService)fService).setVersion("2.0.0");
891
892 } catch (ExecutionException e) {
893 fail(e.toString());
894 }
895 }
896
897 @Test
898 public void testCreateChannelPIDBuffer() {
899 try {
900 ((LTTngControlService)fService).setVersion("2.2.0");
901 String sessionName = "mysession2";
e0838ca1 902 List<String> list = new ArrayList<>();
83051fc3
BH		 903 String USTChannel = "ustChannel";
904 list.add(USTChannel);
905 fShell.setScenario(SCEN_CHANNEL_HANDLING);
906
907
908 ChannelInfo chanInfo = new ChannelInfo("");
909 chanInfo.setOverwriteMode(true);
910 chanInfo.setSubBufferSize(-1);
911 chanInfo.setReadTimer(-1);
912 chanInfo.setSwitchTimer(-1);
913 chanInfo.setNumberOfSubBuffers(-1);
914 chanInfo.setMaxNumberTraceFiles(-1);
915 chanInfo.setMaxSizeTraceFiles(-1);
916 chanInfo.setBufferType(BufferType.BUFFER_PER_PID);
917
918 fService.enableChannels(sessionName, list, false, chanInfo, new NullProgressMonitor());
919 ((LTTngControlService)fService).setVersion("2.0.0");
d132bcc7
BH		 920
921 } catch (ExecutionException e) {
922 fail(e.toString());
923 }
924 }
925
2ba3d0a1 926 @Test
d132bcc7
BH		 927 public void testDisableChannel() {
928 try {
929
930 String sessionName = "mysession2";
e0838ca1 931 List<String> list = new ArrayList<>();
d132bcc7
BH		 932 String kernelChannel0 = "mychannel0";
933 String kernelChannel1 = "mychannel1";
934 list.add(kernelChannel0);
935 list.add(kernelChannel1);
cfdb727a 936
d132bcc7
BH		 937 fShell.setScenario(SCEN_CHANNEL_HANDLING);
938 fService.disableChannels(sessionName, list, true, new NullProgressMonitor());
cfdb727a 939
d132bcc7
BH		 940 list.clear();
941 list.add("ustChannel");
942 fService.disableChannels(sessionName, list, false, new NullProgressMonitor());
943
944 } catch (ExecutionException e) {
945 fail(e.toString());
946 }
947 }
cfdb727a 948
2ba3d0a1 949 @Test
d132bcc7
BH		 950 public void testEnableChannel() {
951 try {
952
953 String sessionName = "mysession2";
e0838ca1 954 List<String> list = new ArrayList<>();
d132bcc7
BH		 955 String kernelChannel0 = "mychannel0";
956 String kernelChannel1 = "mychannel1";
957 list.add(kernelChannel0);
958 list.add(kernelChannel1);
cfdb727a 959
d132bcc7
BH		 960 fShell.setScenario(SCEN_CHANNEL_HANDLING);
961 fService.enableChannels(sessionName, list, true, null, new NullProgressMonitor());
cfdb727a 962
d132bcc7
BH		 963 // Create/enable/configure 1 UST channel
964 list.clear();
965 list.add("ustChannel");
cfdb727a 966
d132bcc7
BH		 967 fService.enableChannels(sessionName, list, false, null, new NullProgressMonitor());
968
969 } catch (ExecutionException e) {
970 fail(e.toString());
971 }
972 }
cfdb727a 973
2ba3d0a1 974 @Test
d132bcc7
BH		 975 public void testEnableEvents() {
976 try {
977 // 1) session name, channel = null, 3 event names, kernel
978 String sessionName = "mysession2";
e0838ca1 979 List<String> list = new ArrayList<>();
d132bcc7
BH		 980 String eventName0 = "block_rq_remap";
981 String eventName1 = "block_bio_remap";
982 String eventName2 = "softirq_entry";
983 list.add(eventName0);
984 list.add(eventName1);
985 list.add(eventName2);
986 fShell.setScenario(SCEN_EVENT_HANDLING);
d4514365 987 fService.enableEvents(sessionName, null, list, true, null, new NullProgressMonitor());
cfdb727a 988
d132bcc7
BH		 989 // 2) session name, channel=mychannel, event name= null, kernel
990 String channelName = "mychannel";
d4514365 991 fService.enableEvents(sessionName, channelName, null, true, null, new NullProgressMonitor());
bbb3538a 992
d4514365 993 // 3) session name, channel=mychannel, 1 event name, ust, no filter
d132bcc7
BH		 994 String ustEventName = "ust_tests_hello:tptest_sighandler";
995 list.clear();
996 list.add(ustEventName);
d4514365 997 fService.enableEvents(sessionName, channelName, list, false, null, new NullProgressMonitor());
cfdb727a 998
d4514365
BH		 999 // 4) session name, channel = mychannel, no event name, ust, with filter
1000 fService.enableEvents(sessionName, channelName, list, false, "intfield==10", new NullProgressMonitor());
1001
1002 // 5) session name, channel = mychannel, no event name, ust, no filter
d132bcc7 1003 list.clear();
d4514365
BH		 1004 fService.enableEvents(sessionName, channelName, list, false, null, new NullProgressMonitor());
1005
1006 // TODO add test with filters
cfdb727a 1007
d132bcc7
BH		 1008 } catch (ExecutionException e) {
1009 fail(e.toString());
1010 }
1011 }
cfdb727a 1012
2ba3d0a1 1013 @Test
d132bcc7
BH		 1014 public void testEnableSyscalls() {
1015 try {
1016 // 1) session name, channel = null, 3 event names, kernel
1017 String sessionName = "mysession2";
1018 String channelName = "mychannel";
cfdb727a 1019
d132bcc7
BH		 1020 fShell.setScenario(SCEN_EVENT_HANDLING);
1021
cfdb727a 1022 // 1) session name, channel = null
d132bcc7
BH		 1023 fService.enableSyscalls(sessionName, null, new NullProgressMonitor());
1024
1025 // 2) session name, channel = mychannel
1026 fService.enableSyscalls(sessionName, channelName, new NullProgressMonitor());
cfdb727a 1027
d132bcc7
BH		 1028 } catch (ExecutionException e) {
1029 fail(e.toString());
1030 }
1031 }
1032
2ba3d0a1 1033 @Test
d132bcc7
BH		 1034 public void testDynamicProbe() {
1035 try {
1036 // 1) session name, channel = null, 3 event names, kernel
1037 String sessionName = "mysession2";
1038 String channelName = "mychannel";
1039 String eventName0 = "myevent0";
1040 String eventName1 = "myevent1";
1041 String functionProbe = "0xc0101340";
1042 String dynProbe = "init_post";
cfdb727a 1043
d132bcc7
BH		 1044 fShell.setScenario(SCEN_EVENT_HANDLING);
1045
cfdb727a 1046 // 1) session name, channel = null, event name, function probe, probe
d132bcc7
BH		 1047 fService.enableProbe(sessionName, null, eventName0, true, functionProbe, new NullProgressMonitor());
1048
1049 // 2) session name, channel = mychannel
1050 fService.enableProbe(sessionName, channelName, eventName1, false, dynProbe, new NullProgressMonitor());
cfdb727a 1051
d132bcc7
BH		 1052 } catch (ExecutionException e) {
1053 fail(e.toString());
1054 }
1055 }
1056
2ba3d0a1 1057 @Test
d132bcc7
BH		 1058 public void testEnableLogLevel() {
1059 try {
1060 // 1) session name, channel = null, 3 event names, kernel
1061 String sessionName = "mysession2";
1062 String channelName = "mychannel";
1063 String eventName4 = "myevent4";
1064 String eventName5 = "myevent5";
cfdb727a 1065
d132bcc7 1066 fShell.setScenario(SCEN_EVENT_HANDLING);
cfdb727a 1067
d132bcc7 1068 // 1) session name, channel = null, event name, loglevel-only, TRACE_DEBUG
d4514365 1069 fService.enableLogLevel(sessionName, null, eventName4, LogLevelType.LOGLEVEL_ONLY, TraceLogLevel.TRACE_DEBUG, null, new NullProgressMonitor());
d132bcc7
BH		 1070
1071 // 2) session name, channel = mychannel, null, loglevel, TRACE_DEBUG_FUNCTION
d4514365
BH		 1072 fService.enableLogLevel(sessionName, channelName, eventName5, LogLevelType.LOGLEVEL, TraceLogLevel.TRACE_DEBUG_FUNCTION, null, new NullProgressMonitor());
1073
1074 // TODO add test with filters
d132bcc7
BH		 1075
1076 } catch (ExecutionException e) {
1077 fail(e.toString());
1078 }
1079 }
cfdb727a 1080
2ba3d0a1 1081 @Test
4ea599a5
BH		 1082 public void testAddContext() {
1083 try {
1084 // 1) session name, channel = null, 3 event names, kernel
1085 String sessionName = "mysession2";
1086 String channelName = "mychannel";
1087 String eventName = "ust_tests_hello:tptest_sighandler";
e0838ca1 1088 List<String> contexts = new ArrayList<>();
4ea599a5
BH		 1089 contexts.add("prio");
1090 contexts.add("pid");
1091
1092 fShell.setScenario(SCEN_CONTEXT_HANDLING);
1093
1094 List<String> availContexts = fService.getContextList(new NullProgressMonitor());
1095 assertNotNull(availContexts);
1096 assertEquals(12, availContexts.size());
1097
cfdb727a 1098 // A very "hard-coded" way to verify but it works ...
e0838ca1 1099 Set<String> expectedContexts = new HashSet<>();
4ea599a5
BH		 1100 expectedContexts.add("pid");
1101 expectedContexts.add("procname");
1102 expectedContexts.add("prio");
1103 expectedContexts.add("nice");
1104 expectedContexts.add("vpid");
1105 expectedContexts.add("tid");
1106 expectedContexts.add("pthread_id");
1107 expectedContexts.add("vtid");
1108 expectedContexts.add("ppid");
1109 expectedContexts.add("vppid");
1110 expectedContexts.add("perf:cpu-cycles");
1111 expectedContexts.add("perf:cycles");
cfdb727a 1112
4ea599a5 1113 assertTrue(expectedContexts.containsAll(availContexts));
cfdb727a 1114
4ea599a5
BH		 1115 // 1) session name, channel = null, event name, loglevel-only, TRACE_DEBUG
1116 fService.addContexts(sessionName, channelName, eventName, false, contexts, new NullProgressMonitor());
1117
1118 } catch (ExecutionException e) {
1119 fail(e.toString());
1120 }
1121 }
1122
2ba3d0a1 1123 @Test
4ea599a5
BH		 1124 public void testAddContextFailure() {
1125
1126 // 1) session name, channel = null, 3 event names, kernel
1127 String sessionName = "mysession2";
1128 String channelName = "mychannel";
1129 String eventName = "ust_tests_hello:tptest_sighandler";
e0838ca1 1130 List<String> contexts = new ArrayList<>();
4ea599a5
BH		 1131 contexts.add("prio");
1132 contexts.add("pid");
1133 fShell.setScenario(SCEN_CONTEXT_ERROR_HANDLING);
1134 try {
1135 fService.getContextList(new NullProgressMonitor());
1136 fail("No exeption generated");
1137 } catch (ExecutionException e) {
1138 // success
cfdb727a 1139 }
4ea599a5
BH		 1140 try {
1141 // 1) session name, channel = null, event name, loglevel-only, TRACE_DEBUG
1142 fService.addContexts(sessionName, channelName, eventName, false, contexts, new NullProgressMonitor());
1143 fail("No exeption generated");
1144 } catch (ExecutionException e) {
1145 // success
cfdb727a 1146 }
4ea599a5
BH		 1147 }
1148
2ba3d0a1 1149 @Test
4ea599a5
BH		 1150 public void testCalibrate() {
1151 try {
1152 fShell.setScenario(SCEN_CALIBRATE_HANDLING);
1153 fService.calibrate(true, new NullProgressMonitor());
1154
1155 } catch (ExecutionException e) {
1156 fail(e.toString());
1157 }
1158 }
1159
2ba3d0a1 1160 @Test
4ea599a5 1161 public void testCalibrateFailure() {
4ea599a5
BH		 1162 try {
1163 fShell.setScenario(SCEN_CALIBRATE_HANDLING);
1164 fService.calibrate(false, new NullProgressMonitor());
1165 fail("No exeption generated");
1166 } catch (ExecutionException e) {
1167 // success
cfdb727a 1168 }
4ea599a5 1169 }
cfdb727a 1170
a30e79fe 1171 @Test
f3b33d40
BH		 1172 public void testCreateSession2_1() {
1173
1174 try {
1175 fShell.setScenario(SCEN_CREATE_SESSION_2_1);
1176
f7d4d450
MAL		 1177 ISessionInfo sessionInfo = new SessionInfo("mysession");
1178 sessionInfo.setNetworkUrl("net://172.0.0.1");
1179 sessionInfo.setStreamedTrace(true);
1180 ISessionInfo info = fService.createSession(sessionInfo, new NullProgressMonitor());
f3b33d40
BH		 1181 assertNotNull(info);
1182 assertEquals("mysession", info.getName());
1183 assertEquals("net://172.0.0.1", info.getSessionPath());
1184 assertTrue(info.isStreamedTrace());
1185 fService.destroySession("mysession", new NullProgressMonitor());
1186
f7d4d450
MAL		 1187 sessionInfo = new SessionInfo("mysession");
1188 sessionInfo.setStreamedTrace(true);
1189 sessionInfo.setNetworkUrl("file:///tmp");
1190 info = fService.createSession(sessionInfo, new NullProgressMonitor());
f3b33d40
BH		 1191 assertNotNull(info);
1192 assertEquals("mysession", info.getName());
1193 assertEquals("file:///tmp", info.getSessionPath());
d128c979 1194 assertTrue(!info.isStreamedTrace());
f3b33d40
BH		 1195 fService.destroySession("mysession", new NullProgressMonitor());
1196
f7d4d450
MAL		 1197 sessionInfo = new SessionInfo("mysession");
1198 sessionInfo.setStreamedTrace(true);
1199 sessionInfo.setNetworkUrl("file:///tmp");
1200 info = fService.createSession(sessionInfo, new NullProgressMonitor());
f3b33d40
BH		 1201 assertNotNull(info);
1202 assertEquals("mysession", info.getName());
1203 assertEquals("file:///tmp", info.getSessionPath());
d128c979 1204 assertTrue(!info.isStreamedTrace());
f3b33d40
BH		 1205 fService.destroySession("mysession", new NullProgressMonitor());
1206
f7d4d450
MAL		 1207 sessionInfo = new SessionInfo("mysession");
1208 sessionInfo.setStreamedTrace(true);
1209 sessionInfo.setControlUrl("tcp://172.0.0.1");
1210 sessionInfo.setDataUrl("tcp://172.0.0.1:5343");
1211 info = fService.createSession(sessionInfo, new NullProgressMonitor());
f3b33d40
BH		 1212 assertNotNull(info);
1213 assertEquals("mysession", info.getName());
d128c979 1214 assertEquals("", info.getSessionPath()); // the complete network path is not available at this point
f3b33d40
BH		 1215 assertTrue(info.isStreamedTrace());
1216 fService.destroySession("mysession", new NullProgressMonitor());
1217
f7d4d450
MAL		 1218 sessionInfo = new SessionInfo("mysession");
1219 sessionInfo.setStreamedTrace(true);
1220 sessionInfo.setNetworkUrl("net://172.0.0.1:1234:2345");
1221 info = fService.createSession(sessionInfo, new NullProgressMonitor());
f3b33d40
BH		 1222 assertNotNull(info);
1223 assertEquals("mysession", info.getName());
1224 assertEquals("net://172.0.0.1:1234:2345", info.getSessionPath());
1225 assertTrue(info.isStreamedTrace());
1226 fService.destroySession("mysession", new NullProgressMonitor());
1227
d128c979
BH		 1228 // verbose
1229 enableVerbose();
f7d4d450
MAL		 1230 sessionInfo = new SessionInfo("mysession");
1231 sessionInfo.setStreamedTrace(true);
1232 sessionInfo.setNetworkUrl("net://172.0.0.1");
1233 info = fService.createSession(sessionInfo, new NullProgressMonitor());
d128c979
BH		 1234 assertNotNull(info);
1235 assertEquals("mysession", info.getName());
1236 assertEquals("net://172.0.0.1", info.getSessionPath());
1237 assertTrue(info.isStreamedTrace());
1238 disableVerbose();
1239 fService.destroySession("mysession", new NullProgressMonitor());
1240
1241
1242 } catch (ExecutionException e) {
1243 fail(e.toString());
1244 }
1245 }
1246
1247 @Test
1248 public void testCreateSessionVerbose2_1() {
1249 try {
1250 fShell.setScenario(SCEN_CREATE_SESSION_VERBOSE_2_1);
1251
1252 enableVerbose();
f7d4d450
MAL		 1253 ISessionInfo sessionInfo = new SessionInfo("mysession");
1254 sessionInfo.setStreamedTrace(true);
1255 sessionInfo.setNetworkUrl("net://172.0.0.1");
1256 ISessionInfo info = fService.createSession(sessionInfo, new NullProgressMonitor());
d128c979
BH		 1257 assertNotNull(info);
1258 assertEquals("mysession", info.getName());
1259 assertEquals("net://172.0.0.1", info.getSessionPath());
1260 assertTrue(info.isStreamedTrace());
1261 fService.destroySession("mysession", new NullProgressMonitor());
f3b33d40
BH		 1262 } catch (ExecutionException e) {
1263 fail(e.toString());
d128c979
BH		 1264 } finally {
1265 disableVerbose();
f3b33d40
BH		 1266 }
1267 }
d128c979 1268
589d0d33
BH		 1269 @Test
1270 public void testCreateSnapshotSession() {
1271 try {
1272 fShell.setScenario(SCEN_CREATE_SNAPSHOT_SESSION);
f7d4d450
MAL		 1273 ISessionInfo params = new SessionInfo("mysession");
1274 params.setSnapshot(true);
1275 ISessionInfo sessionInfo = fService.createSession(params, new NullProgressMonitor());
589d0d33
BH		 1276 assertNotNull(sessionInfo);
1277 assertEquals("mysession", sessionInfo.getName());
1278 assertTrue(sessionInfo.isSnapshotSession());
1279 assertEquals("", sessionInfo.getSessionPath());
1280 assertTrue(!sessionInfo.isStreamedTrace());
1281
1282 assertEquals(TraceSessionState.INACTIVE, sessionInfo.getSessionState());
1283
1284 String[] names = fService.getSessionNames(new NullProgressMonitor());
1285 assertEquals(names[0], "mysession");
1286
1287 ISnapshotInfo snapshotInfo = fService.getSnapshotInfo("mysession", new NullProgressMonitor());
1288 assertNotNull(snapshotInfo);
1289 assertEquals("snapshot-1", snapshotInfo.getName());
1290 assertEquals("/home/user/lttng-traces/mysession-20130913-141651", snapshotInfo.getSnapshotPath());
1291 assertEquals(1, snapshotInfo.getId());
1292 assertTrue(!snapshotInfo.isStreamedSnapshot());
1293
1294 // we need to set the snapshotInfo to so that the session path is set correctly
1295 sessionInfo.setSnapshotInfo(snapshotInfo);
1296 assertEquals("/home/user/lttng-traces/mysession-20130913-141651", sessionInfo.getSessionPath());
1297
1298 fService.recordSnapshot("mysession", new NullProgressMonitor());
1299
1300 fService.destroySession("mysession", new NullProgressMonitor());
1301
1302 } catch (ExecutionException e) {
1303 fail(e.toString());
1304 }
1305 }
1306
1307 public void testCreateStreamedSnapshotSession() {
1308 try {
1309 fShell.setScenario(SCEN_CREATE_STREAMED_SNAPSHOT_SESSION);
1310
f7d4d450
MAL		 1311 ISessionInfo params = new SessionInfo("mysession");
1312 params.setNetworkUrl("net://172.0.0.1");
1313 ISessionInfo sessionInfo = fService.createSession(params, new NullProgressMonitor());
589d0d33
BH		 1314 assertNotNull(sessionInfo);
1315 assertEquals("mysession", sessionInfo.getName());
1316 assertTrue(sessionInfo.isSnapshotSession());
1317
1318 assertEquals(TraceSessionState.INACTIVE, sessionInfo.getSessionState());
1319 assertTrue(sessionInfo.isStreamedTrace());
1320
1321 String[] names = fService.getSessionNames(new NullProgressMonitor());
1322 assertEquals(names[0], "mysession");
1323
589d0d33
BH		 1324 ISnapshotInfo snapshotInfo = sessionInfo.getSnapshotInfo();
1325 assertNotNull(sessionInfo);
1326 assertEquals("snapshot-2", snapshotInfo.getName());
1327 assertEquals("net4://172.0.0.1:5342/", snapshotInfo.getSnapshotPath());
1328 assertEquals(2, snapshotInfo.getId());
1329 assertTrue(snapshotInfo.isStreamedSnapshot());
1330
1331 // we need to set the snapshotInfo to so that the session path is set correctly
1332 sessionInfo.setSnapshotInfo(snapshotInfo);
1333 assertEquals("net4://172.0.0.1:5342/", sessionInfo.getSessionPath());
1334
1335 fService.recordSnapshot("mysession", new NullProgressMonitor());
1336
1337 fService.destroySession("mysession", new NullProgressMonitor());
1338
1339 } catch (ExecutionException e) {
1340 fail(e.toString());
1341 }
1342 }
1343
589d0d33
BH		 1344 @Test
1345 public void testCreateSnapshotSessionErrors() {
1346 try {
1347 fShell.setScenario(SCEN_CREATE_SNAPSHOT_SESSION_ERRORS);
1348
1349 String[] names = fService.getSessionNames(new NullProgressMonitor());
1350 assertEquals(names[0], "mysession");
1351 } catch (ExecutionException e) {
1352 fail(e.toString());
1353 }
1354
1355 try {
1356 fService.getSnapshotInfo("blabla", new NullProgressMonitor());
1357 fail("getSnapshoInfo() didn't fail");
1358 } catch (ExecutionException e) {
1359 // successful
1360 }
1361
1362 try {
1363 fService.recordSnapshot("blabla", new NullProgressMonitor());
1364 fail("getSnapshoInfo() didn't fail");
1365 } catch (ExecutionException e) {
1366 // successful
1367 }
1368
1369 try {
1370 fService.recordSnapshot("mysession", new NullProgressMonitor());
1371 fail("getSnapshoInfo() didn't fail");
1372 } catch (ExecutionException e) {
1373 // successful
1374 }
1375 }
1376
81d5dc3a
MAL		 1377 @Test
1378 public void testCreateLiveSession() throws ExecutionException {
1379 fShell.setScenario(SCEN_CREATE_LIVE_SESSION);
1380
1381 ISessionInfo params = new SessionInfo("mysession");
1382 params.setLive(true);
1383 params.setStreamedTrace(true);
1384 params.setNetworkUrl("net://127.0.0.1");
1385 ISessionInfo sessionInfo = fService.createSession(params, new NullProgressMonitor());
1386 assertNotNull(sessionInfo);
1387 assertEquals("mysession", sessionInfo.getName());
1388 assertEquals(TraceSessionState.INACTIVE, sessionInfo.getSessionState());
1389 assertTrue(sessionInfo.isStreamedTrace());
1390 assertTrue(sessionInfo.isLive());
1391 assertEquals("net://127.0.0.1", sessionInfo.getSessionPath());
1392 String[] names = fService.getSessionNames(new NullProgressMonitor());
1393 assertEquals(names[0], "mysession");
1394 fService.destroySession("mysession", new NullProgressMonitor());
1395 }
1396
1397 @Test
1398 public void testCreateLiveSessionErrors() {
1399 try {
1400 fShell.setScenario(SCEN_CREATE_LIVE_SESSION_ERRORS);
1401
1402 ISessionInfo parameters = new SessionInfo("mysession");
1403 parameters.setLive(true);
1404 parameters.setSnapshot(true);
1405 fService.createSession(parameters, new NullProgressMonitor());
1406 fail("createSession() didn't fail");
1407 } catch (ExecutionException e) {
1408 // successful
1409 }
1410
1411 try {
1412 ISessionInfo parameters = new SessionInfo("mysession");
1413 parameters.setNetworkUrl("blah");
1414 parameters.setLive(true);
1415 fService.createSession(parameters, new NullProgressMonitor());
1416 fail("createSession() didn't fail");
1417 } catch (ExecutionException e) {
1418 // successful
1419 }
1420
1421 try {
1422 ISessionInfo parameters = new SessionInfo("mysession");
1423 parameters.setControlUrl("net://127.0.0.1");
1424 parameters.setLive(true);
1425 fService.createSession(parameters, new NullProgressMonitor());
1426 fail("createSession() didn't fail");
1427 } catch (ExecutionException e) {
1428 // successful
1429 }
1430 }
1431
d128c979
BH		 1432 private static void enableVerbose() {
1433 // verbose
1434 ControlCommandLogger.init(ControlPreferences.getInstance().getLogfilePath(), false);
1435 ControlPreferences.getInstance().getPreferenceStore().setDefault(ControlPreferences.TRACE_CONTROL_LOG_COMMANDS_PREF, true);
1436 ControlPreferences.getInstance().getPreferenceStore().setDefault(ControlPreferences.TRACE_CONTROL_VERBOSE_LEVEL_PREF, ControlPreferences.TRACE_CONTROL_VERBOSE_LEVEL_V_V_VERBOSE);
1437 }
1438
1439 private static void disableVerbose() {
1440 ControlPreferences.getInstance().getPreferenceStore().setDefault(ControlPreferences.TRACE_CONTROL_LOG_COMMANDS_PREF, false);
1441 }
1442
1443
eb1bab5b 1444}
Tracecompass - Deliverables
This page took 0.133835 seconds and 5 git commands to generate.