1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
|
/*******************************************************************************
* Copyright (c) 2010 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:
* Alvaro Sanchez-Leon (alvsan09@gmail.com) - Initial API and implementation
*******************************************************************************/
package org.eclipse.linuxtools.lttng.control;
import org.eclipse.linuxtools.lttng.LttngTestPreparation;
public class LTTngSyntheticEventProviderTest extends LttngTestPreparation {
// ========================================================================
// Tests
// ========================================================================
public void testPlainDataRequest() {
// // prepare
// init();
// TmfExperiment<LttngEvent> experiment = prepareExperimentToTest();
// TmfEventRequest<LttngEvent> request = prepareEventRequest(
// LttngEvent.class, 0, 31);
//
// // execute
// experiment.sendRequest(request);
// try {
// request.waitForCompletion();
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
//
// // finish
// assertEquals("Unexpected eventCount", 15316, feventCount);
// boolean expected = true;
// assertEquals("Events received out of expected order", expected,
// validSequence);
}
/**
*
*/
public void testSyntheticEventRequest() {
// init();
// // Create a new Experiment manager context
// IStateExperimentManager expManager = prepareExperimentContext(false);
//
// // make sure a TmfExperiment instance is registered as provider and
// // selected as current
// TmfExperiment<LttngEvent> experiment = prepareExperimentToTest();
//
// // experiment selected, build experiment selection context and trigger
// // check point creation
// expManager.experimentSelected_prep(experiment);
// // builds check points in parallel
// expManager.experimentSelected(this, experiment);
//
// // Obtain the singleton event provider
// LttngSyntheticEventProvider synProvider = LttngCoreProviderFactory
// .getEventProvider();
//
// // prepare synthetic event requests
// boolean printExpectedEvents = false;
// TmfEventRequest<LttngSyntheticEvent> request1 = prepareEventRequest(LttngSyntheticEvent.class, 5, 9,
// printExpectedEvents); /* 2001 events */
// TmfEventRequest<LttngSyntheticEvent> request2 = prepareEventRequest(LttngSyntheticEvent.class, 11, 13,
// printExpectedEvents); /* 1001 events */
//
// // execute
// synProvider.sendRequest(request1);
// try {
// request1.waitForCompletion();
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
// System.out.println("EventCount " + feventCount);
//
// synProvider.sendRequest(request2);
// try {
// request2.waitForCompletion();
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
// System.out.println("EventCount " + feventCount);
//
//// try {
//// request1.waitForCompletion();
//// request2.waitForCompletion();
//// } catch (InterruptedException e) {
//// e.printStackTrace();
//// }
//// System.out.println("EventCount " + feventCount);
//
// // finish
// assertEquals("Unexpected eventCount", 3002, feventCount);
}
}
|
