1 /*******************************************************************************
2 * Copyright (c) 2013, 2014 Ericsson
3 * All rights reserved. This program and the accompanying materials
4 * are made available under the terms of the Eclipse Public License v1.0
5 * which accompanies this distribution, and is available at
6 * http://www.eclipse.org/legal/epl-v10.html
9 * Matthew Khouzam - Initial API and implementation
10 * Simon Delisle - Generate dummy trace
11 *******************************************************************************/
13 package org
.eclipse
.linuxtools
.ctf
.core
.tests
.trace
;
15 import static org
.junit
.Assert
.assertEquals
;
16 import static org
.junit
.Assert
.assertNotNull
;
19 import java
.io
.FileOutputStream
;
20 import java
.io
.FileWriter
;
21 import java
.io
.IOException
;
22 import java
.nio
.ByteBuffer
;
23 import java
.nio
.ByteOrder
;
24 import java
.util
.ArrayList
;
25 import java
.util
.List
;
27 import org
.eclipse
.linuxtools
.ctf
.core
.event
.IEventDeclaration
;
28 import org
.eclipse
.linuxtools
.ctf
.core
.tests
.CtfCoreTestPlugin
;
29 import org
.eclipse
.linuxtools
.ctf
.core
.trace
.CTFReaderException
;
30 import org
.eclipse
.linuxtools
.ctf
.core
.trace
.CTFTrace
;
31 import org
.eclipse
.linuxtools
.internal
.ctf
.core
.event
.EventDeclaration
;
32 import org
.eclipse
.linuxtools
.internal
.ctf
.core
.event
.metadata
.IOStructGen
;
33 import org
.junit
.After
;
34 import org
.junit
.Test
;
37 * Unit tests for {@link IOStructGen}
39 * @author Matthew Khouzam
41 public class IOstructgenTest
{
43 private static final String metadataDecs
= "typealias integer { size = 8; align = 8; signed = false; } := uint8_t;\n"
44 + "typealias integer { size = 16; align = 8; signed = false; } := uint16_t;\n"
45 + "typealias integer { size = 32; align = 8; signed = false; } := uint32_t;\n"
46 + "typealias integer { size = 64; align = 8; signed = false; } := uint64_t;\n"
47 + "typealias integer { size = 64; align = 8; signed = false; } := unsigned long;\n"
48 + "typealias integer { size = 5; align = 1; signed = false; } := uint5_t;\n"
49 + "typealias integer { size = 27; align = 1; signed = false; } := uint27_t;\n"
50 + "typealias integer { size = 32; align = 1; signed = true; base = decimal; } := int32_t;\n"
51 + "typealias integer { size = 31; align = 1; signed = true; base = dec; } := int31_t;\n"
52 + "typealias integer { size = 30; align = 1; signed = true; base = d; } := int30_t;\n"
53 + "typealias integer { size = 29; align = 1; signed = true; base = i; } := int29_t;\n"
54 + "typealias integer { size = 28; align = 1; signed = true; base = u; } := int28_t;\n"
55 + "typealias integer { size = 27; align = 1; signed = true; base = hexadecimal; } := int27_t;\n"
56 + "typealias integer { size = 26; align = 1; signed = true; base = hex; } := int26_t;\n"
57 + "typealias integer { size = 25; align = 1; signed = true; base = x; } := int25_t;\n"
58 + "typealias integer { size = 24; align = 1; signed = true; base = X; } := int24_t;\n"
59 + "typealias integer { size = 23; align = 1; signed = true; base = p; } := int23_t;\n"
60 + "typealias integer { size = 22; align = 1; signed = true; base = 16; } := int22_t;\n"
61 + "typealias integer { size = 21; align = 1; signed = true; base = oct; } := int21_t;\n"
62 + "typealias integer { size = 20; align = 1; signed = true; base = b; } := int20_t;\n"
63 + "typealias integer { size = 19; align = 1; signed = true; base = octal; } := int19_t;\n"
64 + "typealias integer { size = 18; align = 1; signed = true; base = o; } := int18_t;\n"
65 + "typealias integer { size = 17; align = 1; signed = true; base = binary; } := int17_t;\n"
70 + " uuid = \"b04d391b-e736-44c1-8d89-4bb438857f8d\";\n"
71 + " byte_order = le;\n"
72 + " packet.header := struct {\n"
73 + " uint32_t magic;\n"
74 + " uint8_t uuid[16];\n"
75 + " uint32_t stream_id;\n" + " };\n" + "};\n" + "\n";
76 private static final String environmentMD
= "env {\n"
77 + " hostname = \"DemoSystem\";\n"
79 + " procname = \"demo\";\n"
80 + " domain = \"autogenerated\";\n"
81 + " tracer_name = \"tmf\";\n"
82 + " tracer_major = 2;\n"
83 + " tracer_minor = 0x01;\n"
84 + " tracer_patchlevel = 0;\n"
86 private static final String clockMD
= "clock {\n" + " name = monotonic;\n"
87 + " uuid = \"cbf9f42e-9be7-4798-a96f-11db556e2ebb\";\n"
88 + " description = \"Monotonic Clock\";\n"
89 + " freq = 1000000000; /* Frequency, in Hz */\n"
90 + " /* clock value offset from Epoch is: offset * (1/freq) */\n"
91 + " offset = 1350310657466295832;\n" + "};\n"
94 private static final String ctfStart
=
95 "typealias integer {\n"
96 + " size = 27; align = 1; signed = false;\n"
97 + " map = clock.monotonic.value;\n"
98 + "} := uint27_clock_monotonic_t;\n"
100 + "typealias integer {\n"
101 + " size = 32; align = 8; signed = false;\n"
102 + " map = clock.monotonic.value;\n"
103 + "} := uint32_clock_monotonic_t;\n"
105 + "typealias integer {\n"
106 + " size = 64; align = 8; signed = false;\n"
107 + " map = clock.monotonic.value;\n"
108 + "} := uint64_clock_monotonic_t;\n"
111 private static final String ctfHeaders
=
112 "struct packet_context {\n"
113 + " uint64_clock_monotonic_t timestamp_begin;\n"
114 + " uint64_clock_monotonic_t timestamp_end;\n"
115 + " uint64_t content_size;\n"
116 + " uint64_t packet_size;\n"
117 + " unsigned long events_discarded;\n"
118 + " uint32_t cpu_id;\n"
121 + "struct event_header_compact {\n"
122 + " enum : uint5_t { compact = 0 ... 30, extended = 31 } id;\n"
123 + " variant <id> {\n"
125 + " uint27_clock_monotonic_t timestamp;\n"
129 + " uint64_clock_monotonic_t timestamp;\n"
134 + "struct event_header_large {\n"
135 + " enum : uint16_t { compact = 0 ... 65534, extended = 65535 } id;\n"
136 + " variant <id> {\n" + " struct {\n"
137 + " uint32_clock_monotonic_t timestamp;\n"
138 + " } compact;\n" + " struct {\n"
140 + " uint64_clock_monotonic_t timestamp;\n"
141 + " } extended;\n" + " } v;\n" + "} align(8);\n" + "\n";
143 private static final String ctfBody
= "stream {\n"
145 + " event.header := struct event_header_compact;\n"
146 + " packet.context := struct packet_context;\n"
147 + " event.context := struct {\n"
148 + " integer { size = 64; align = 8; signed = 0; encoding = none; base = 16; } _ip;\n"
153 + " name = \"ust_tests_demo3:done\";\n"
155 + " stream_id = 0;\n"
157 + " fields := struct {\n"
158 + " integer { size = 32; align = 8; signed = 1; encoding = none; base = 10; } _value;\n"
163 + " name = \"ust_tests_demo:starting\";\n"
165 + " stream_id = 0;\n"
167 + " model.emf.uri = \"http://example.com/path_to_model?q=ust_tests_demo:starting\";\n"
168 + " fields := struct {\n"
169 + " integer { size = 32; align = 8; signed = 1; encoding = none; base = 10; } _value;\n"
174 + " name = \"ust_tests_demo:done\";\n"
176 + " stream_id = 0;\n"
178 + " model.emf.uri = \"http://example.com/path_to_model?q=ust_tests_demo:done\";\n"
179 + " fields := struct {\n"
180 + " integer { size = 32; align = 8; signed = 1; encoding = none; base = 10; } _value;\n"
185 + " name = \"ust_tests_demo2:loop\";\n"
187 + " stream_id = 0;\n"
189 + " fields := struct {\n"
190 + " integer { size = 32; align = 8; signed = 1; encoding = none; base = 10; } _intfield;\n"
191 + " integer { size = 32; align = 8; signed = 1; encoding = none; base = 16; } _intfield2;\n"
192 + " integer { size = 64; align = 8; signed = 1; encoding = none; base = 10; } _longfield;\n"
193 + " integer { size = 32; align = 8; signed = 1; encoding = none; base = 10; byte_order = be; } _netintfield;\n"
194 + " integer { size = 32; align = 8; signed = 1; encoding = none; base = 16; byte_order = be; } _netintfieldhex;\n"
195 + " integer { size = 64; align = 8; signed = 1; encoding = none; base = 10; } _arrfield1[3];\n"
196 + " integer { size = 8; align = 8; signed = 1; encoding = UTF8; base = 10; } _arrfield2[10];\n"
197 + " integer { size = 64; align = 8; signed = 0; encoding = none; base = 10; } __seqfield1_length;\n"
198 + " integer { size = 8; align = 8; signed = 1; encoding = none; base = 10; } _seqfield1[ __seqfield1_length ];\n"
199 + " integer { size = 64; align = 8; signed = 0; encoding = none; base = 10; } __seqfield2_length;\n"
200 + " integer { size = 8; align = 8; signed = 1; encoding = UTF8; base = 10; } _seqfield2[ __seqfield2_length ];\n"
201 + " string _stringfield;\n"
202 + " floating_point { exp_dig = 8; mant_dig = 24; align = 8; } _floatfield;\n"
203 + " floating_point { exp_dig = 11; mant_dig = 53; align = 8; } _doublefield;\n"
208 private static final String enumMd
=
209 "typealias integer { size = 32; align = 8; signed = false; } := int;\n"
210 + "typealias enum { ONE = 0, a,b,c=10, d} := useless_enum;\n"
211 + "struct useless{ \n"
212 + " enum : uint8_t { A=0, \"B\",} enum3;\n"
213 + " useless_enum enum2;"
214 + " enum { C, D, E } enum4;\n"
219 + " name = \"enumEvent\";\n"
221 + " stream_id = 0;\n"
223 + " fields := struct{\n"
224 + " uint16_t _some_field;\n"
225 // + " useless junk;\n"
226 // + " bad_enum a;\n"
227 + " enum {A, B, C = 3 , } _other_enum;\n"
232 private final static String contextMD
=
234 " name = \"someOtherEvent\";\n" +
236 " stream_id = 0;\n" +
238 " context := struct{\n" +
239 " uint16_t _someContext;\n" +
241 " fields := struct{\n" +
242 " uint16_t _somefield;\n" +
247 private static final String callsiteMD
=
249 + " name = \"ust_tests_demo2:loop\";\n"
250 + " func = \"main\";\n" + " ip = 0x400a29;\n"
251 + " file = \"demo.c\";\n" + " line = 59;\n" + "};\n" + "\n"
252 + "callsite {\n" + " name = \"ust_tests_demo3:done\";\n"
253 + " func = \"main\";\n" + " ip = 0x400a6c;\n"
254 + " file = \"demo.c\";\n" + " line = 62;\n" + "};\n" + "\n"
255 + "callsite {\n" + " name = \"ust_tests_demo:done\";\n"
256 + " func = \"main\";\n" + " ip = 0x400aaf;\n"
257 + " file = \"demo.c\";\n" + " line = 61;\n" + "};\n" + "\n"
258 + "callsite {\n" + " name = \"ust_tests_demo:starting\";\n"
259 + " func = \"main\";\n" + " ip = 0x400af2;\n"
260 + " file = \"demo.c\";\n" + " line = 55;\n" + "};\n";
262 private static final String simpleTSDL
= metadataDecs
+ ctfStart
+ ctfHeaders
264 private static final String enumTSDL
= metadataDecs
+ ctfStart
+ ctfHeaders
266 private static final String clockTSDL
= metadataDecs
+ clockMD
+ ctfStart
267 + ctfHeaders
+ ctfBody
;
268 private static final String envTSDL
= metadataDecs
+ environmentMD
+ ctfStart
269 + ctfHeaders
+ ctfBody
;
270 private static final String contextTSDL
= metadataDecs
+ environmentMD
+ ctfStart
271 + ctfHeaders
+ ctfBody
+ contextMD
;
272 private static final String callsiteTSDL
= metadataDecs
+ ctfStart
+ ctfHeaders
273 + ctfBody
+ callsiteMD
;
274 private static final String allDressedTSDL
= metadataDecs
+ environmentMD
+ clockMD
275 + ctfStart
+ ctfHeaders
+ ctfBody
+ enumMd
+ callsiteMD
;
277 static final String tempTraceDir
= CtfCoreTestPlugin
.getTemporaryDirPath()
278 + File
.separator
+ "tempTrace";
280 private static final int DATA_SIZE
= 4096;
282 private static final int HEADER_SIZE
= 68;
284 private static final int PACKET_SIZE
= DATA_SIZE
+ HEADER_SIZE
+ 512;
286 private CTFTrace trace
;
288 private static class Event
{
289 private static final int EVENT_SIZE
= 16;
291 private int eventTimestamp
;
292 private int eventContent
;
294 public Event(int id
, int content
) {
297 eventContent
= content
;
300 public void setEventTimestamp(int eventTimestamp
) {
301 this.eventTimestamp
= eventTimestamp
;
304 public void setEventContent(int eventContent
) {
305 this.eventContent
= eventContent
;
308 public void writeEvent(ByteBuffer data
) {
310 int timeId
= eventTimestamp
<< 5;
311 timeId
|= eventId
& 0x1f;
315 long ip
= 0x0000facedecafe00L
+ ((data
.position() /
320 data
.putInt(eventContent
);
324 public int getSize() {
330 private static void deltree(File f
) {
331 for (File elem
: f
.listFiles()) {
332 if (elem
.isDirectory()) {
340 private static void createDummyTrace(String metadata
) {
341 File dir
= new File(tempTraceDir
);
347 File metadataFile
= new File(tempTraceDir
+ "/metadata");
348 try (FileWriter fw
= new FileWriter(metadataFile
);) {
350 } catch (IOException e
) {
354 byte magicLE
[] = { (byte) 0xC1, (byte) 0x1F, (byte) 0xFC,
356 byte uuid
[] = { (byte) 0xb0, 0x4d, 0x39, 0x1b, (byte) 0xe7,
357 0x36, 0x44, (byte) 0xc1, (byte) 0x8d, (byte) 0x89, 0x4b,
358 (byte) 0xb4, 0x38, (byte) 0x85, 0x7f, (byte) 0x8d };
360 Event ev
= new Event(2, 2);
362 final int nbEvents
= (DATA_SIZE
/ ev
.getSize()) - 1;
363 final int contentSize
= (nbEvents
* ev
.getSize() +
366 ByteBuffer data
= ByteBuffer
.allocate(PACKET_SIZE
);
367 data
.order(ByteOrder
.LITTLE_ENDIAN
);
380 data
.putLong(0xa500);
383 data
.putLong(nbEvents
* 0x10000 + 0xa5a6);
386 data
.putLong(contentSize
);
389 data
.putLong(PACKET_SIZE
* 8);
391 // events_discarded 8
398 for (int i
= 0; i
< nbEvents
; i
++) {
399 ev
.setEventTimestamp(i
* 0x10000 + 0xa5a5);
400 ev
.setEventContent(i
);
404 // The byteBuffer needs to be flipped in file writing mode
407 File dummyFile
= new File(tempTraceDir
+ "/dummyChan");
408 try (FileOutputStream fos
= new FileOutputStream(dummyFile
);) {
409 fos
.getChannel().write(data
);
410 } catch (IOException e
) {
420 public void tearDown(){
425 * Simple test (only the minimum)
427 * @throws CTFReaderException
428 * something wrong happened
431 public void TSDLSimpleTest() throws CTFReaderException
{
432 createDummyTrace(simpleTSDL
);
433 trace
= new CTFTrace(tempTraceDir
);
434 assertNotNull(trace
);
438 * Test with environment variables
440 * @throws CTFReaderException
441 * something wrong happened
444 public void TSDLEnvironmentTest() throws CTFReaderException
{
445 createDummyTrace(envTSDL
);
446 trace
= new CTFTrace(tempTraceDir
);
447 assertNotNull(trace
);
453 * @throws CTFReaderException
454 * something wrong happened
457 public void TSDLEnumTest() throws CTFReaderException
{
458 createDummyTrace(enumTSDL
);
459 trace
= new CTFTrace(tempTraceDir
);
460 assertNotNull(trace
);
466 * @throws CTFReaderException
467 * something wrong happened
470 public void TSDLClockTest() throws CTFReaderException
{
471 createDummyTrace(clockTSDL
);
472 trace
= new CTFTrace(tempTraceDir
);
473 assertNotNull(trace
);
479 * @throws CTFReaderException
480 * something wrong happened
483 public void TSDLContextTest() throws CTFReaderException
{
484 createDummyTrace(contextTSDL
);
485 trace
= new CTFTrace(tempTraceDir
);
486 assertNotNull(trace
);
490 * Test with Callsites
492 * @throws CTFReaderException
493 * something wrong happened
496 public void TSDLCallsiteTest() throws CTFReaderException
{
497 createDummyTrace(callsiteTSDL
);
498 trace
= new CTFTrace(tempTraceDir
);
499 assertNotNull(trace
);
505 * @throws CTFReaderException
506 * something wrong happened
509 public void TSDLAllTest() throws CTFReaderException
{
510 createDummyTrace(allDressedTSDL
);
511 trace
= new CTFTrace(tempTraceDir
);
512 assertNotNull(trace
);
514 final List
<IEventDeclaration
> eventDeclarations
= new ArrayList
<>(trace
.getEventDeclarations(0L));
515 final EventDeclaration eventDeclaration
= (EventDeclaration
) eventDeclarations
.get(2);
516 assertEquals("http://example.com/path_to_model?q=ust_tests_demo:done",
517 eventDeclaration
.getCustomAttribute("model.emf.uri"));