Fix mi: add support for Jul loglevel
[lttng-tools.git] / src / common / mi-lttng.c
1 /*
2 * Copyright (C) 2014 - Jonathan Rajotte <jonathan.r.julien@gmail.com>
3 * - Olivier Cotte <olivier.cotte@polymtl.ca>
4 *
5 * This program is free software; you can redistribute it and/or modify it
6 * under the terms of the GNU General Public License, version 2 only, as
7 * published by the Free Software Foundation.
8 *
9 * This program is distributed in the hope that it will be useful, but WITHOUT
10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
12 * more details.
13 *
14 * You should have received a copy of the GNU General Public License along with
15 * this program; if not, write to the Free Software Foundation, Inc., 51
16 * Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
17 */
18
19
20 #include <include/config.h>
21 #include <common/config/config.h>
22 #include <lttng/snapshot-internal.h>
23 #include "mi-lttng.h"
24
25 #include <assert.h>
26
27 /* Strings related to command */
28 const char * const mi_lttng_element_command = "command";
29 const char * const mi_lttng_element_command_action = "snapshot_action";
30 const char * const mi_lttng_element_command_add_context = "add-context";
31 const char * const mi_lttng_element_command_calibrate = "calibrate";
32 const char * const mi_lttng_element_command_create = "create";
33 const char * const mi_lttng_element_command_destroy = "destroy";
34 const char * const mi_lttng_element_command_disable_channel = "disable-channel";
35 const char * const mi_lttng_element_command_disable_event = "disable-event";
36 const char * const mi_lttng_element_command_enable_channels = "enable-channel";
37 const char * const mi_lttng_element_command_enable_event = "enable-event";
38 const char * const mi_lttng_element_command_list = "list";
39 const char * const mi_lttng_element_command_load = "load";
40 const char * const mi_lttng_element_command_name = "name";
41 const char * const mi_lttng_element_command_output = "output";
42 const char * const mi_lttng_element_command_save = "save";
43 const char * const mi_lttng_element_command_set_session = "set-session";
44 const char * const mi_lttng_element_command_snapshot = "snapshot";
45 const char * const mi_lttng_element_command_snapshot_add = "add_snapshot";
46 const char * const mi_lttng_element_command_snapshot_del = "del_snapshot";
47 const char * const mi_lttng_element_command_snapshot_list = "list_snapshot";
48 const char * const mi_lttng_element_command_snapshot_record = "record_snapshot";
49 const char * const mi_lttng_element_command_start = "start";
50 const char * const mi_lttng_element_command_stop = "stop";
51 const char * const mi_lttng_element_command_success = "success";
52 const char * const mi_lttng_element_command_version = "version";
53
54 /* Strings related to version command */
55 const char * const mi_lttng_element_version = "version";
56 const char * const mi_lttng_element_version_commit = "commit";
57 const char * const mi_lttng_element_version_description = "description";
58 const char * const mi_lttng_element_version_license = "license";
59 const char * const mi_lttng_element_version_major = "major";
60 const char * const mi_lttng_element_version_minor = "minor";
61 const char * const mi_lttng_element_version_patch_level = "patchLevel";
62 const char * const mi_lttng_element_version_str = "string";
63 const char * const mi_lttng_element_version_web = "url";
64
65 /* String related to a lttng_event_field */
66 const char * const mi_lttng_element_event_field = "event_field";
67 const char * const mi_lttng_element_event_fields = "event_fields";
68
69 /* String related to lttng_event_context */
70 const char * const mi_lttng_context_type_perf_counter = "PERF_COUNTER";
71 const char * const mi_lttng_context_type_perf_cpu_counter = "PERF_CPU_COUNTER";
72 const char * const mi_lttng_context_type_perf_thread_counter = "PERF_THREAD_COUNTER";
73
74 /* String related to lttng_event_perf_counter_ctx */
75 const char * const mi_lttng_element_perf_counter_context = "perf_counter_context";
76
77 /* Strings related to pid */
78 const char * const mi_lttng_element_pids = "pids";
79 const char * const mi_lttng_element_pid = "pid";
80 const char * const mi_lttng_element_pid_id = "id";
81
82 /* Strings related to save command */
83 const char * const mi_lttng_element_save = "save";
84
85 /* Strings related to load command */
86 const char * const mi_lttng_element_load = "load";
87
88 /* General elements of mi_lttng */
89 const char * const mi_lttng_element_empty = "";
90 const char * const mi_lttng_element_id = "id";
91 const char * const mi_lttng_element_nowrite = "nowrite";
92 const char * const mi_lttng_element_success = "success";
93 const char * const mi_lttng_element_type_enum = "ENUM";
94 const char * const mi_lttng_element_type_float = "FLOAT";
95 const char * const mi_lttng_element_type_integer = "INTEGER";
96 const char * const mi_lttng_element_type_other = "OTHER";
97 const char * const mi_lttng_element_type_string = "STRING";
98
99 /* String related to loglevel */
100 const char * const mi_lttng_loglevel_str_alert = "TRACE_ALERT";
101 const char * const mi_lttng_loglevel_str_crit = "TRACE_CRIT";
102 const char * const mi_lttng_loglevel_str_debug = "TRACE_DEBUG";
103 const char * const mi_lttng_loglevel_str_debug_function = "TRACE_DEBUG_FUNCTION";
104 const char * const mi_lttng_loglevel_str_debug_line = "TRACE_DEBUG_LINE";
105 const char * const mi_lttng_loglevel_str_debug_module = "TRACE_DEBUG_MODULE";
106 const char * const mi_lttng_loglevel_str_debug_process = "TRACE_DEBUG_PROCESS";
107 const char * const mi_lttng_loglevel_str_debug_program = "TRACE_DEBUG_PROGRAM";
108 const char * const mi_lttng_loglevel_str_debug_system = "TRACE_DEBUG_SYSTEM";
109 const char * const mi_lttng_loglevel_str_debug_unit = "TRACE_DEBUG_UNIT";
110 const char * const mi_lttng_loglevel_str_emerg = "TRACE_EMERG";
111 const char * const mi_lttng_loglevel_str_err = "TRACE_ERR";
112 const char * const mi_lttng_loglevel_str_info = "TRACE_INFO";
113 const char * const mi_lttng_loglevel_str_notice = "TRACE_NOTICE";
114 const char * const mi_lttng_loglevel_str_unknown = "UNKNOWN";
115 const char * const mi_lttng_loglevel_str_warning = "TRACE_WARNING";
116
117 /* String related to loglevel JUL */
118 const char * const mi_lttng_loglevel_str_jul_all = "JUL_ALL";
119 const char * const mi_lttng_loglevel_str_jul_config = "JUL_CONFIG";
120 const char * const mi_lttng_loglevel_str_jul_fine = "JUL_FINE";
121 const char * const mi_lttng_loglevel_str_jul_finer = "JUL_FINER";
122 const char * const mi_lttng_loglevel_str_jul_finest = "JUL_FINEST";
123 const char * const mi_lttng_loglevel_str_jul_info = "JUL_INFO";
124 const char * const mi_lttng_loglevel_str_jul_off = "JUL_OFF";
125 const char * const mi_lttng_loglevel_str_jul_severe = "JUL_SEVERE";
126 const char * const mi_lttng_loglevel_str_jul_warning = "JUL_WARNING";
127
128 /* String related to loglevel type */
129 const char * const mi_lttng_loglevel_type_all = "ALL";
130 const char * const mi_lttng_loglevel_type_range = "RANGE";
131 const char * const mi_lttng_loglevel_type_single = "SINGLE";
132 const char * const mi_lttng_loglevel_type_unknown = "UNKNOWN";
133
134 /* String related to lttng_calibrate */
135 const char * const mi_lttng_element_calibrate = "calibrate";
136 const char * const mi_lttng_element_calibrate_function = "FUNCTION";
137
138 /* String related to a lttng_snapshot_output */
139 const char * const mi_lttng_element_snapshot_ctrl_url = "ctrl_url";
140 const char * const mi_lttng_element_snapshot_data_url = "data_url";
141 const char * const mi_lttng_element_snapshot_max_size = "max_size";
142 const char * const mi_lttng_element_snapshot_n_ptr = "n_ptr";
143 const char * const mi_lttng_element_snapshot_session_name = "session_name";
144 const char * const mi_lttng_element_snapshots = "snapshots";
145
146 /* This is a merge of jul loglevel and regular loglevel
147 * Those should never overlap by definition
148 * (see struct lttng_event loglevel)
149 */
150 const char *mi_lttng_loglevel_string(int value)
151 {
152 switch (value) {
153 case -1:
154 return mi_lttng_element_empty;
155 case LTTNG_LOGLEVEL_EMERG:
156 return mi_lttng_loglevel_str_emerg;
157 case LTTNG_LOGLEVEL_ALERT:
158 return mi_lttng_loglevel_str_alert;
159 case LTTNG_LOGLEVEL_CRIT:
160 return mi_lttng_loglevel_str_crit;
161 case LTTNG_LOGLEVEL_ERR:
162 return mi_lttng_loglevel_str_err;
163 case LTTNG_LOGLEVEL_WARNING:
164 return mi_lttng_loglevel_str_warning;
165 case LTTNG_LOGLEVEL_NOTICE:
166 return mi_lttng_loglevel_str_notice;
167 case LTTNG_LOGLEVEL_INFO:
168 return mi_lttng_loglevel_str_info;
169 case LTTNG_LOGLEVEL_DEBUG_SYSTEM:
170 return mi_lttng_loglevel_str_debug_system;
171 case LTTNG_LOGLEVEL_DEBUG_PROGRAM:
172 return mi_lttng_loglevel_str_debug_program;
173 case LTTNG_LOGLEVEL_DEBUG_PROCESS:
174 return mi_lttng_loglevel_str_debug_process;
175 case LTTNG_LOGLEVEL_DEBUG_MODULE:
176 return mi_lttng_loglevel_str_debug_module;
177 case LTTNG_LOGLEVEL_DEBUG_UNIT:
178 return mi_lttng_loglevel_str_debug_unit;
179 case LTTNG_LOGLEVEL_DEBUG_FUNCTION:
180 return mi_lttng_loglevel_str_debug_function;
181 case LTTNG_LOGLEVEL_DEBUG_LINE:
182 return mi_lttng_loglevel_str_debug_line;
183 case LTTNG_LOGLEVEL_DEBUG:
184 return mi_lttng_loglevel_str_debug;
185 case LTTNG_LOGLEVEL_JUL_OFF:
186 return mi_lttng_loglevel_str_jul_off;
187 case LTTNG_LOGLEVEL_JUL_SEVERE:
188 return mi_lttng_loglevel_str_jul_severe;
189 case LTTNG_LOGLEVEL_JUL_WARNING:
190 return mi_lttng_loglevel_str_jul_warning;
191 case LTTNG_LOGLEVEL_JUL_INFO:
192 return mi_lttng_loglevel_str_jul_info;
193 case LTTNG_LOGLEVEL_JUL_CONFIG:
194 return mi_lttng_loglevel_str_jul_config;
195 case LTTNG_LOGLEVEL_JUL_FINE:
196 return mi_lttng_loglevel_str_jul_fine;
197 case LTTNG_LOGLEVEL_JUL_FINER:
198 return mi_lttng_loglevel_str_jul_finer;
199 case LTTNG_LOGLEVEL_JUL_FINEST:
200 return mi_lttng_loglevel_str_jul_finest;
201 case LTTNG_LOGLEVEL_JUL_ALL:
202 return mi_lttng_loglevel_str_jul_all;
203 default:
204 return mi_lttng_loglevel_str_unknown;
205 }
206 }
207
208 const char *mi_lttng_logleveltype_string(enum lttng_loglevel_type value)
209 {
210 switch (value) {
211 case LTTNG_EVENT_LOGLEVEL_ALL:
212 return mi_lttng_loglevel_type_all;
213 case LTTNG_EVENT_LOGLEVEL_RANGE:
214 return mi_lttng_loglevel_type_range;
215 case LTTNG_EVENT_LOGLEVEL_SINGLE:
216 return mi_lttng_loglevel_type_single;
217 default:
218 return mi_lttng_loglevel_type_unknown;
219 }
220 }
221
222 const char *mi_lttng_eventtype_string(enum lttng_event_type value)
223 {
224 switch (value) {
225 case LTTNG_EVENT_ALL:
226 return config_event_type_all;
227 case LTTNG_EVENT_TRACEPOINT:
228 return config_event_type_tracepoint;
229 case LTTNG_EVENT_PROBE:
230 return config_event_type_probe;
231 case LTTNG_EVENT_FUNCTION:
232 return config_event_type_function;
233 case LTTNG_EVENT_FUNCTION_ENTRY:
234 return config_event_type_function_entry;
235 case LTTNG_EVENT_SYSCALL:
236 return config_event_type_syscall;
237 case LTTNG_EVENT_NOOP:
238 return config_event_type_noop;
239 default:
240 return mi_lttng_element_empty;
241 }
242 }
243
244 const char *mi_lttng_event_contexttype_string(enum lttng_event_context_type val)
245 {
246 switch (val) {
247 case LTTNG_EVENT_CONTEXT_PID:
248 return config_event_context_pid;
249 case LTTNG_EVENT_CONTEXT_PERF_COUNTER:
250 return mi_lttng_context_type_perf_counter;
251 case LTTNG_EVENT_CONTEXT_PERF_THREAD_COUNTER:
252 return mi_lttng_context_type_perf_thread_counter;
253 case LTTNG_EVENT_CONTEXT_PERF_CPU_COUNTER:
254 return mi_lttng_context_type_perf_cpu_counter;
255 case LTTNG_EVENT_CONTEXT_PROCNAME:
256 return config_event_context_procname;
257 case LTTNG_EVENT_CONTEXT_PRIO:
258 return config_event_context_prio;
259 case LTTNG_EVENT_CONTEXT_NICE:
260 return config_event_context_nice;
261 case LTTNG_EVENT_CONTEXT_VPID:
262 return config_event_context_vpid;
263 case LTTNG_EVENT_CONTEXT_TID:
264 return config_event_context_tid;
265 case LTTNG_EVENT_CONTEXT_VTID:
266 return config_event_context_vtid;
267 case LTTNG_EVENT_CONTEXT_PPID:
268 return config_event_context_ppid;
269 case LTTNG_EVENT_CONTEXT_VPPID:
270 return config_event_context_vppid;
271 case LTTNG_EVENT_CONTEXT_PTHREAD_ID:
272 return config_event_context_pthread_id;
273 case LTTNG_EVENT_CONTEXT_HOSTNAME:
274 return config_event_context_hostname;
275 case LTTNG_EVENT_CONTEXT_IP:
276 return config_event_context_ip;
277 default:
278 return NULL;
279 }
280 }
281
282 const char *mi_lttng_eventfieldtype_string(enum lttng_event_field_type val)
283 {
284 switch (val) {
285 case(LTTNG_EVENT_FIELD_INTEGER):
286 return mi_lttng_element_type_integer;
287 case(LTTNG_EVENT_FIELD_ENUM):
288 return mi_lttng_element_type_enum;
289 case(LTTNG_EVENT_FIELD_FLOAT):
290 return mi_lttng_element_type_float;
291 case(LTTNG_EVENT_FIELD_STRING):
292 return mi_lttng_element_type_string;
293 default:
294 return mi_lttng_element_type_other;
295 }
296 }
297
298 const char *mi_lttng_domaintype_string(enum lttng_domain_type value)
299 {
300 /* Note: This is a *duplicate* of get_domain_str from bin/lttng/utils.c */
301 switch (value) {
302 case LTTNG_DOMAIN_KERNEL:
303 return config_domain_type_kernel;
304 case LTTNG_DOMAIN_UST:
305 return config_domain_type_ust;
306 case LTTNG_DOMAIN_JUL:
307 return config_domain_type_jul;
308 default:
309 /* Should not have an unknown domain */
310 assert(0);
311 }
312 }
313
314 const char *mi_lttng_buffertype_string(enum lttng_buffer_type value)
315 {
316 switch (value) {
317 case LTTNG_BUFFER_PER_PID:
318 return config_buffer_type_per_pid;
319 case LTTNG_BUFFER_PER_UID:
320 return config_buffer_type_per_uid;
321 case LTTNG_BUFFER_GLOBAL:
322 return config_buffer_type_global;
323 default:
324 /* Should not have an unknow buffer type */
325 assert(0);
326 }
327 }
328
329 const char *mi_lttng_calibratetype_string(enum lttng_calibrate_type val)
330 {
331 const char *ret;
332
333 switch (val) {
334 case LTTNG_CALIBRATE_FUNCTION:
335 ret = mi_lttng_element_calibrate_function;
336 break;
337 default:
338 ret = mi_lttng_element_empty;
339 break;
340 }
341 return ret;
342 }
343
344 LTTNG_HIDDEN
345 struct mi_writer *mi_lttng_writer_create(int fd_output, int mi_output_type)
346 {
347 struct mi_writer *mi_writer;
348
349 mi_writer = zmalloc(sizeof(struct mi_writer));
350 if (!mi_writer) {
351 PERROR("zmalloc mi_writer_create");
352 goto end;
353 }
354 if (mi_output_type == LTTNG_MI_XML) {
355 mi_writer->writer = config_writer_create(fd_output);
356 if (!mi_writer->writer) {
357 goto err_destroy;
358 }
359 mi_writer->type = LTTNG_MI_XML;
360 } else {
361 goto err_destroy;
362 }
363
364 end:
365 return mi_writer;
366
367 err_destroy:
368 free(mi_writer);
369 return NULL;
370 }
371
372 LTTNG_HIDDEN
373 int mi_lttng_writer_destroy(struct mi_writer *writer)
374 {
375 int ret;
376
377 if (!writer) {
378 ret = -EINVAL;
379 goto end;
380 }
381
382 ret = config_writer_destroy(writer->writer);
383 if (ret < 0) {
384 goto end;
385 }
386
387 free(writer);
388 end:
389 return ret;
390 }
391
392 LTTNG_HIDDEN
393 int mi_lttng_writer_command_open(struct mi_writer *writer, const char *command)
394 {
395 int ret;
396
397 ret = mi_lttng_writer_open_element(writer, mi_lttng_element_command);
398 if (ret) {
399 goto end;
400 }
401 ret = mi_lttng_writer_write_element_string(writer,
402 mi_lttng_element_command_name, command);
403 end:
404 return ret;
405 }
406
407 LTTNG_HIDDEN
408 int mi_lttng_writer_command_close(struct mi_writer *writer)
409 {
410 return mi_lttng_writer_close_element(writer);
411 }
412
413 LTTNG_HIDDEN
414 int mi_lttng_writer_open_element(struct mi_writer *writer,
415 const char *element_name)
416 {
417 return config_writer_open_element(writer->writer, element_name);
418 }
419
420 LTTNG_HIDDEN
421 int mi_lttng_writer_close_element(struct mi_writer *writer)
422 {
423 return config_writer_close_element(writer->writer);
424 }
425
426 LTTNG_HIDDEN
427 int mi_lttng_close_multi_element(struct mi_writer *writer,
428 unsigned int nb_element)
429 {
430 int ret, i;
431
432 if (nb_element < 1) {
433 ret = 0;
434 goto end;
435 }
436 for (i = 0; i < nb_element; i++) {
437 ret = mi_lttng_writer_close_element(writer);
438 if (ret) {
439 goto end;
440 }
441 }
442 end:
443 return ret;
444 }
445
446 LTTNG_HIDDEN
447 int mi_lttng_writer_write_element_unsigned_int(struct mi_writer *writer,
448 const char *element_name, uint64_t value)
449 {
450 return config_writer_write_element_unsigned_int(writer->writer,
451 element_name, value);
452 }
453
454 LTTNG_HIDDEN
455 int mi_lttng_writer_write_element_signed_int(struct mi_writer *writer,
456 const char *element_name, int64_t value)
457 {
458 return config_writer_write_element_signed_int(writer->writer,
459 element_name, value);
460 }
461
462 LTTNG_HIDDEN
463 int mi_lttng_writer_write_element_bool(struct mi_writer *writer,
464 const char *element_name, int value)
465 {
466 return config_writer_write_element_bool(writer->writer,
467 element_name, value);
468 }
469
470 LTTNG_HIDDEN
471 int mi_lttng_writer_write_element_string(struct mi_writer *writer,
472 const char *element_name, const char *value)
473 {
474 return config_writer_write_element_string(writer->writer,
475 element_name, value);
476 }
477
478 LTTNG_HIDDEN
479 int mi_lttng_version(struct mi_writer *writer, struct mi_lttng_version *version,
480 const char *lttng_description, const char *lttng_license)
481 {
482 int ret;
483
484 /* Open version */
485 ret = mi_lttng_writer_open_element(writer, mi_lttng_element_version);
486 if (ret) {
487 goto end;
488 }
489
490 /* Version string (contain info like rc etc.) */
491 ret = mi_lttng_writer_write_element_string(writer,
492 mi_lttng_element_version_str, VERSION);
493 if (ret) {
494 goto end;
495 }
496
497 /* Major version number */
498 ret = mi_lttng_writer_write_element_unsigned_int(writer,
499 mi_lttng_element_version_major, version->version_major);
500 if (ret) {
501 goto end;
502 }
503
504 /* Minor version number */
505 ret = mi_lttng_writer_write_element_unsigned_int(writer,
506 mi_lttng_element_version_minor, version->version_minor);
507 if (ret) {
508 goto end;
509 }
510
511 /* Commit version number */
512 ret = mi_lttng_writer_write_element_string(writer,
513 mi_lttng_element_version_commit, version->version_commit);
514 if (ret) {
515 goto end;
516 }
517
518 /* Patch number */
519 ret = mi_lttng_writer_write_element_unsigned_int(writer,
520 mi_lttng_element_version_patch_level, version->version_patchlevel);
521 if (ret) {
522 goto end;
523 }
524
525 /* Name of the version */
526 ret = mi_lttng_writer_write_element_string(writer,
527 config_element_name, version->version_name);
528 if (ret) {
529 goto end;
530 }
531
532 /* Description mostly related to beer... */
533 ret = mi_lttng_writer_write_element_string(writer,
534 mi_lttng_element_version_description, lttng_description);
535 if (ret) {
536 goto end;
537 }
538
539 /* url */
540 ret = mi_lttng_writer_write_element_string(writer,
541 mi_lttng_element_version_web, version->package_url);
542 if (ret) {
543 goto end;
544 }
545
546 /* License: free as in free beer...no...*speech* */
547 ret = mi_lttng_writer_write_element_string(writer,
548 mi_lttng_element_version_license, lttng_license);
549 if (ret) {
550 goto end;
551 }
552
553 /* Close version element */
554 ret = mi_lttng_writer_close_element(writer);
555
556 end:
557 return ret;
558 }
559
560 LTTNG_HIDDEN
561 int mi_lttng_sessions_open(struct mi_writer *writer)
562 {
563 return mi_lttng_writer_open_element(writer, config_element_sessions);
564 }
565
566 LTTNG_HIDDEN
567 int mi_lttng_session(struct mi_writer *writer,
568 struct lttng_session *session, int is_open)
569 {
570 int ret;
571
572 assert(session);
573
574 /* Open sessions element */
575 ret = mi_lttng_writer_open_element(writer,
576 config_element_session);
577 if (ret) {
578 goto end;
579 }
580
581 /* Name of the session */
582 ret = mi_lttng_writer_write_element_string(writer,
583 config_element_name, session->name);
584 if (ret) {
585 goto end;
586 }
587
588 /* Path */
589 ret = mi_lttng_writer_write_element_string(writer,
590 config_element_path, session->path);
591 if (ret) {
592 goto end;
593 }
594
595 /* Enabled ? */
596 ret = mi_lttng_writer_write_element_bool(writer,
597 config_element_enabled, session->enabled);
598 if (ret) {
599 goto end;
600 }
601
602 /* Snapshot mode */
603 ret = mi_lttng_writer_write_element_unsigned_int(writer,
604 config_element_snapshot_mode, session->snapshot_mode);
605 if (ret) {
606 goto end;
607 }
608
609 /* Live timer interval in usec */
610 ret = mi_lttng_writer_write_element_unsigned_int(writer,
611 config_element_live_timer_interval,
612 session->live_timer_interval);
613 if (ret) {
614 goto end;
615 }
616
617 if (!is_open) {
618 /* Closing session element */
619 ret = mi_lttng_writer_close_element(writer);
620 }
621 end:
622 return ret;
623
624 }
625
626 LTTNG_HIDDEN
627 int mi_lttng_domains_open(struct mi_writer *writer)
628 {
629 return mi_lttng_writer_open_element(writer, config_element_domains);
630 }
631
632 LTTNG_HIDDEN
633 int mi_lttng_domain(struct mi_writer *writer,
634 struct lttng_domain *domain, int is_open)
635 {
636 int ret = 0;
637 const char *str_domain;
638 const char *str_buffer;
639
640 assert(domain);
641
642 /* Open domain element */
643 ret = mi_lttng_writer_open_element(writer, config_element_domain);
644 if (ret) {
645 goto end;
646 }
647
648 /* Domain Type */
649 str_domain = mi_lttng_domaintype_string(domain->type);
650 ret = mi_lttng_writer_write_element_string(writer, config_element_type,
651 str_domain);
652 if (ret) {
653 goto end;
654 }
655
656 /* Buffer Type */
657 str_buffer= mi_lttng_buffertype_string(domain->buf_type);
658 ret = mi_lttng_writer_write_element_string(writer,
659 config_element_buffer_type, str_buffer);
660 if (ret) {
661 goto end;
662 }
663
664 /* TODO: attr... not sure how to use the union.... */
665
666 if (!is_open) {
667 /* Closing domain element */
668 ret = mi_lttng_writer_close_element(writer);
669 }
670
671 end:
672 return ret;
673
674 }
675
676 LTTNG_HIDDEN
677 int mi_lttng_channels_open(struct mi_writer *writer)
678 {
679 return mi_lttng_writer_open_element(writer, config_element_channels);
680 }
681
682 LTTNG_HIDDEN
683 int mi_lttng_channel(struct mi_writer *writer,
684 struct lttng_channel *channel, int is_open)
685 {
686 int ret = 0;
687
688 assert(channel);
689
690 /* Opening channel element */
691 ret = mi_lttng_writer_open_element(writer, config_element_channel);
692 if (ret) {
693 goto end;
694 }
695
696 /* Name */
697 ret = mi_lttng_writer_write_element_string(writer, config_element_name,
698 channel->name);
699 if (ret) {
700 goto end;
701 }
702
703 /* Enabled ? */
704 ret = mi_lttng_writer_write_element_bool(writer,
705 config_element_enabled, channel->enabled);
706 if (ret) {
707 goto end;
708 }
709
710 /* Attribute */
711 ret = mi_lttng_channel_attr(writer, &channel->attr);
712 if (ret) {
713 goto end;
714 }
715
716 if (!is_open) {
717 /* Closing channel element */
718 ret = mi_lttng_writer_close_element(writer);
719 if (ret) {
720 goto end;
721 }
722 }
723 end:
724 return ret;
725 }
726
727 LTTNG_HIDDEN
728 int mi_lttng_channel_attr(struct mi_writer *writer,
729 struct lttng_channel_attr *attr)
730 {
731 int ret = 0;
732
733 assert(attr);
734
735 /* Opening Attributes */
736 ret = mi_lttng_writer_open_element(writer, config_element_attributes);
737 if (ret) {
738 goto end;
739 }
740
741 /* Overwrite */
742 ret = mi_lttng_writer_write_element_string(writer,
743 config_element_overwrite_mode,
744 attr->overwrite ? config_overwrite_mode_overwrite :
745 config_overwrite_mode_discard);
746 if (ret) {
747 goto end;
748 }
749
750 /* Sub buffer size in byte */
751 ret = mi_lttng_writer_write_element_unsigned_int(writer,
752 config_element_subbuf_size, attr->subbuf_size);
753 if (ret) {
754 goto end;
755 }
756
757 /* Number of subbuffer (power of two) */
758 ret = mi_lttng_writer_write_element_unsigned_int(writer,
759 config_element_num_subbuf,
760 attr->num_subbuf);
761 if (ret) {
762 goto end;
763 }
764
765 /* Switch timer interval in usec */
766 ret = mi_lttng_writer_write_element_unsigned_int(writer,
767 config_element_switch_timer_interval,
768 attr->switch_timer_interval);
769 if (ret) {
770 goto end;
771 }
772
773 /* Read timer interval in usec */
774 ret = mi_lttng_writer_write_element_unsigned_int(writer,
775 config_element_read_timer_interval,
776 attr->read_timer_interval);
777 if (ret) {
778 goto end;
779 }
780
781 /* Event output */
782 ret = mi_lttng_writer_write_element_string(writer,
783 config_element_output_type,
784 attr->output == LTTNG_EVENT_SPLICE ?
785 config_output_type_splice : config_output_type_mmap);
786 if (ret) {
787 goto end;
788 }
789
790 /* Tracefile size in bytes */
791 ret = mi_lttng_writer_write_element_unsigned_int(writer,
792 config_element_tracefile_size, attr->tracefile_size);
793 if (ret) {
794 goto end;
795 }
796
797 /* Count of tracefiles */
798 ret = mi_lttng_writer_write_element_unsigned_int(writer,
799 config_element_tracefile_count,
800 attr->tracefile_count);
801 if (ret) {
802 goto end;
803 }
804
805 /* Live timer interval in usec*/
806 ret = mi_lttng_writer_write_element_unsigned_int(writer,
807 config_element_live_timer_interval,
808 attr->live_timer_interval);
809 if (ret) {
810 goto end;
811 }
812
813 /* Closing attributes */
814 ret = mi_lttng_writer_close_element(writer);
815 if (ret) {
816 goto end;
817 }
818 end:
819 return ret;
820
821 }
822
823 LTTNG_HIDDEN
824 int mi_lttng_event_common_attributes(struct mi_writer *writer,
825 struct lttng_event *event)
826 {
827 int ret;
828
829 /* Open event element */
830 ret = mi_lttng_writer_open_element(writer, config_element_event);
831 if (ret) {
832 goto end;
833 }
834
835 /* Event name */
836 ret = mi_lttng_writer_write_element_string(writer,
837 config_element_name, event->name);
838 if (ret) {
839 goto end;
840 }
841
842 /* Event type */
843 ret = mi_lttng_writer_write_element_string(writer,
844 config_element_type, mi_lttng_eventtype_string(event->type));
845 if (ret) {
846 goto end;
847 }
848
849 /* Is event enabled */
850 ret = mi_lttng_writer_write_element_bool(writer,
851 config_element_enabled, event->enabled);
852 if (ret) {
853 goto end;
854 }
855
856 /* Event filter enabled? */
857 ret = mi_lttng_writer_write_element_bool(writer,
858 config_element_filter, event->filter);
859
860 end:
861 return ret;
862 }
863
864 LTTNG_HIDDEN
865 int mi_lttng_event_tracepoint_loglevel(struct mi_writer *writer,
866 struct lttng_event *event)
867 {
868 int ret;
869
870 /* Event loglevel */
871 ret = mi_lttng_writer_write_element_string(writer,
872 config_element_loglevel, mi_lttng_loglevel_string(event->loglevel));
873 if (ret) {
874 goto end;
875 }
876
877 /* Log level type */
878 ret = mi_lttng_writer_write_element_string(writer,
879 config_element_loglevel_type,
880 mi_lttng_logleveltype_string(event->loglevel_type));
881 if (ret) {
882 goto end;
883 }
884
885 /* event exclusion filter */
886 ret = mi_lttng_writer_write_element_bool(writer,
887 config_element_exclusion, event->exclusion);
888 if (ret) {
889 goto end;
890 }
891
892 end:
893 return ret;
894 }
895
896 LTTNG_HIDDEN
897 int mi_lttng_event_tracepoint_no_loglevel(struct mi_writer *writer,
898 struct lttng_event *event)
899 {
900 /* event exclusion filter */
901 return mi_lttng_writer_write_element_bool(writer,
902 config_element_exclusion, event->exclusion);
903 }
904
905 LTTNG_HIDDEN
906 int mi_lttng_event_function_probe(struct mi_writer *writer,
907 struct lttng_event *event)
908 {
909 int ret;
910
911 if (event->attr.probe.addr != 0) {
912 /* event probe address */
913 ret = mi_lttng_writer_write_element_unsigned_int(writer,
914 config_element_address, event->attr.probe.addr);
915 if (ret) {
916 goto end;
917 }
918 } else {
919 /* event probe offset */
920 ret = mi_lttng_writer_write_element_unsigned_int(writer,
921 config_element_offset, event->attr.probe.offset);
922 if (ret) {
923 goto end;
924 }
925
926 /* event probe symbol_name */
927 ret = mi_lttng_writer_write_element_string(writer,
928 config_element_symbol_name, event->attr.probe.symbol_name);
929 if (ret) {
930 goto end;
931 }
932 }
933 end:
934 return ret;
935 }
936
937 LTTNG_HIDDEN
938 int mi_lttng_event_function_entry(struct mi_writer *writer,
939 struct lttng_event *event)
940 {
941 /* event probe symbol_name */
942 return mi_lttng_writer_write_element_string(writer,
943 config_element_symbol_name, event->attr.ftrace.symbol_name);
944 }
945
946 LTTNG_HIDDEN
947 int mi_lttng_events_open(struct mi_writer *writer)
948 {
949 return mi_lttng_writer_open_element(writer, config_element_events);
950 }
951
952 LTTNG_HIDDEN
953 int mi_lttng_event(struct mi_writer *writer,
954 struct lttng_event *event, int is_open)
955 {
956 int ret;
957
958 ret = mi_lttng_event_common_attributes(writer, event);
959 if (ret) {
960 goto end;
961 }
962
963 switch (event->type) {
964 case LTTNG_EVENT_TRACEPOINT:
965 {
966 if (event->loglevel != -1) {
967 ret = mi_lttng_event_tracepoint_loglevel(writer, event);
968 } else {
969 ret = mi_lttng_event_tracepoint_no_loglevel(writer, event);
970 }
971 break;
972 }
973 case LTTNG_EVENT_PROBE:
974 ret = mi_lttng_event_function_probe(writer, event);
975 break;
976 case LTTNG_EVENT_FUNCTION_ENTRY:
977 ret = mi_lttng_event_function_entry(writer, event);
978 break;
979 case LTTNG_EVENT_ALL:
980 /* Fallthrough */
981 default:
982 break;
983 }
984
985 if (!is_open) {
986 ret = mi_lttng_writer_close_element(writer);
987 }
988
989 end:
990 return ret;
991 }
992
993 LTTNG_HIDDEN
994 int mi_lttng_pids_open(struct mi_writer *writer)
995 {
996 return mi_lttng_writer_open_element(writer, mi_lttng_element_pids);
997 }
998
999 LTTNG_HIDDEN
1000 int mi_lttng_pid(struct mi_writer *writer, pid_t pid , const char *cmdline,
1001 int is_open)
1002 {
1003 int ret;
1004
1005 /* Open element pid */
1006 ret = mi_lttng_writer_open_element(writer, mi_lttng_element_pid);
1007 if (ret) {
1008 goto end;
1009 }
1010
1011 /* Writing pid number */
1012 ret = mi_lttng_writer_write_element_signed_int(writer,
1013 mi_lttng_element_pid_id, (int)pid);
1014 if (ret) {
1015 goto end;
1016 }
1017
1018 /* Writing name of the process */
1019 ret = mi_lttng_writer_write_element_string(writer, config_element_name,
1020 cmdline);
1021 if (ret) {
1022 goto end;
1023 }
1024
1025 if (!is_open) {
1026 /* Closing Pid */
1027 ret = mi_lttng_writer_close_element(writer);
1028 }
1029
1030 end:
1031 return ret;
1032 }
1033
1034 LTTNG_HIDDEN
1035 int mi_lttng_event_fields_open(struct mi_writer *writer)
1036 {
1037 return mi_lttng_writer_open_element(writer, mi_lttng_element_event_fields);
1038 }
1039
1040 LTTNG_HIDDEN
1041 int mi_lttng_event_field(struct mi_writer *writer,
1042 struct lttng_event_field *field)
1043 {
1044 int ret;
1045
1046 if (!field->field_name[0]) {
1047 ret = 0;
1048 goto end;
1049 }
1050
1051 /* Open field */
1052 ret = mi_lttng_writer_open_element(writer, mi_lttng_element_event_field);
1053 if (ret) {
1054 goto end;
1055 }
1056
1057 if (!field->field_name[0]) {
1058 goto close;
1059 }
1060
1061 /* Name */
1062 ret = mi_lttng_writer_write_element_string(writer, config_element_name,
1063 field->field_name);
1064 if (ret) {
1065 goto end;
1066 }
1067
1068 /* Type */
1069 ret = mi_lttng_writer_write_element_string(writer, config_element_type,
1070 mi_lttng_eventfieldtype_string(field->type));
1071 if (ret) {
1072 goto end;
1073 }
1074
1075 /* nowrite */
1076 ret = mi_lttng_writer_write_element_signed_int(writer,
1077 mi_lttng_element_nowrite, field->nowrite);
1078 if (ret) {
1079 goto end;
1080 }
1081
1082 close:
1083 /* Close field element */
1084 ret = mi_lttng_writer_close_element(writer);
1085
1086 end:
1087 return ret;
1088 }
1089
1090 LTTNG_HIDDEN
1091 int mi_lttng_calibrate(struct mi_writer *writer,
1092 struct lttng_calibrate *calibrate)
1093 {
1094 int ret;
1095
1096 /* Open calibrate element */
1097 ret = mi_lttng_writer_open_element(writer, mi_lttng_element_calibrate);
1098 if (ret) {
1099 goto end;
1100 }
1101
1102 /* Calibration type */
1103 ret = mi_lttng_writer_write_element_string(writer, config_element_type,
1104 mi_lttng_calibratetype_string(calibrate->type));
1105 if (ret) {
1106 goto end;
1107 }
1108
1109 /* Closing calibrate element */
1110 ret = mi_lttng_writer_close_element(writer);
1111 end:
1112 return ret;
1113 }
1114 LTTNG_HIDDEN
1115 int mi_lttng_context(struct mi_writer *writer,
1116 struct lttng_event_context *context, int is_open)
1117 {
1118 int ret;
1119 const char *type_string;
1120 struct lttng_event_perf_counter_ctx *perf_context;
1121 /* Open context */
1122 ret = mi_lttng_writer_open_element(writer , config_element_context);
1123 if (ret) {
1124 goto end;
1125 }
1126
1127 type_string = mi_lttng_event_contexttype_string(context->ctx);
1128 if (!type_string) {
1129 ret = -LTTNG_ERR_INVALID;
1130 goto end;
1131 }
1132
1133 /* Print context type */
1134 ret = mi_lttng_writer_write_element_string(writer, config_element_type,
1135 type_string);
1136
1137 /* Special case for PERF_*_COUNTER
1138 * print the lttng_event_perf_counter_ctx*/
1139 switch (context->ctx) {
1140 case LTTNG_EVENT_CONTEXT_PERF_COUNTER:
1141 case LTTNG_EVENT_CONTEXT_PERF_THREAD_COUNTER:
1142 case LTTNG_EVENT_CONTEXT_PERF_CPU_COUNTER:
1143 perf_context = &context->u.perf_counter;
1144 ret = mi_lttng_perf_counter_context(writer, perf_context);
1145 if (ret) {
1146 goto end;
1147 }
1148 break;
1149 default:
1150 break;
1151 }
1152
1153 /* Close context */
1154 if (!is_open) {
1155 ret = mi_lttng_writer_close_element(writer);
1156 }
1157
1158 end:
1159 return ret;
1160 }
1161
1162 LTTNG_HIDDEN
1163 int mi_lttng_perf_counter_context(struct mi_writer *writer,
1164 struct lttng_event_perf_counter_ctx *perf_context)
1165 {
1166 int ret;
1167
1168 /* Open perf_counter_context */
1169 ret = mi_lttng_writer_open_element(writer,
1170 mi_lttng_element_perf_counter_context);
1171 if (ret) {
1172 goto end;
1173 }
1174
1175 /* Type */
1176 ret = mi_lttng_writer_write_element_unsigned_int(writer,
1177 config_element_type, perf_context->type);
1178 if (ret) {
1179 goto end;
1180 }
1181
1182 /* Config */
1183 ret = mi_lttng_writer_write_element_unsigned_int(writer,
1184 config_element_config, perf_context->config);
1185 if (ret) {
1186 goto end;
1187 }
1188
1189 /* Name of the perf counter */
1190 ret = mi_lttng_writer_write_element_string(writer,
1191 config_element_name, perf_context->name);
1192 if (ret) {
1193 goto end;
1194 }
1195
1196 /* Close perf_counter_context */
1197 ret = mi_lttng_writer_close_element(writer);
1198 end:
1199 return ret;
1200 }
1201
1202 LTTNG_HIDDEN
1203 int mi_lttng_snapshot_output_session_name(struct mi_writer *writer,
1204 const char *session_name)
1205 {
1206 int ret;
1207
1208 /* Open session element */
1209 ret = mi_lttng_writer_open_element(writer, config_element_session);
1210 if (ret) {
1211 goto end;
1212 }
1213
1214 /* Snapshot output list for current session name */
1215 ret = mi_lttng_writer_write_element_string(writer, config_element_name,
1216 session_name);
1217
1218 /* Open element snapshots (sequence one snapshot) */
1219 ret = mi_lttng_writer_open_element(writer, mi_lttng_element_snapshots);
1220 if (ret) {
1221 goto end;
1222 }
1223
1224 end:
1225 return ret;
1226 }
1227
1228 LTTNG_HIDDEN
1229 int mi_lttng_snapshot_list_output(struct mi_writer *writer,
1230 struct lttng_snapshot_output *output)
1231 {
1232 int ret;
1233
1234 /* Open element snapshot output */
1235 ret = mi_lttng_writer_open_element(writer,
1236 mi_lttng_element_command_snapshot);
1237 if (ret) {
1238 goto end;
1239 }
1240
1241 /* ID of the snapshot output */
1242 ret = mi_lttng_writer_write_element_unsigned_int(writer,
1243 mi_lttng_element_id, output->id);
1244 if (ret) {
1245 goto end;
1246 }
1247
1248 /* Name of the output */
1249 ret = mi_lttng_writer_write_element_string(writer, config_element_name,
1250 output->name);
1251 if (ret) {
1252 goto end;
1253 }
1254
1255 /* Destination of the output (ctrl_url)*/
1256 ret = mi_lttng_writer_write_element_string(writer,
1257 mi_lttng_element_snapshot_ctrl_url, output->ctrl_url);
1258 if (ret) {
1259 goto end;
1260 }
1261
1262 /* Destination of the output (data_url) */
1263 ret = mi_lttng_writer_write_element_string(writer,
1264 mi_lttng_element_snapshot_data_url, output->data_url);
1265 if (ret) {
1266 goto end;
1267 }
1268
1269 /* total size of all stream combined */
1270 ret = mi_lttng_writer_write_element_unsigned_int(writer,
1271 mi_lttng_element_snapshot_max_size, output->max_size);
1272 if (ret) {
1273 goto end;
1274 }
1275
1276 /* Close snapshot output element */
1277 ret = mi_lttng_writer_close_element(writer);
1278
1279 end:
1280 return ret;
1281 }
1282
1283 LTTNG_HIDDEN
1284 int mi_lttng_snapshot_del_output(struct mi_writer *writer, int id,
1285 const char *name, const char *current_session_name)
1286 {
1287 int ret;
1288
1289 /* Open element del_snapshot */
1290 ret = mi_lttng_writer_open_element(writer,
1291 mi_lttng_element_command_snapshot);
1292 if (ret) {
1293 goto end;
1294 }
1295
1296
1297 if (id != UINT32_MAX) {
1298 /* "Snapshot output "id" successfully deleted
1299 * for "current_session_name"
1300 * ID of the snapshot output
1301 */
1302 ret = mi_lttng_writer_write_element_unsigned_int(writer,
1303 mi_lttng_element_id, id);
1304 if (ret) {
1305 goto end;
1306 }
1307 } else {
1308 /* "Snapshot output "name" successfully deleted
1309 * for session "current_session_name"
1310 * Name of the output
1311 */
1312 ret = mi_lttng_writer_write_element_string(writer, config_element_name,
1313 name);
1314 if (ret) {
1315 goto end;
1316 }
1317 }
1318
1319 /* Snapshot was deleted for session "current_session_name"*/
1320 ret = mi_lttng_writer_write_element_string(writer,
1321 mi_lttng_element_snapshot_session_name,
1322 current_session_name);
1323 if (ret) {
1324 goto end;
1325 }
1326
1327 /* Close snapshot element */
1328 ret = mi_lttng_writer_close_element(writer);
1329
1330 end:
1331 return ret;
1332 }
1333
1334 LTTNG_HIDDEN
1335 int mi_lttng_snapshot_add_output(struct mi_writer *writer,
1336 const char *current_session_name, const char *n_ptr,
1337 struct lttng_snapshot_output *output)
1338 {
1339 int ret;
1340
1341 /* Open element snapshot */
1342 ret = mi_lttng_writer_open_element(writer,
1343 mi_lttng_element_command_snapshot);
1344 if (ret) {
1345 goto end;
1346 }
1347
1348 /* Snapshot output id */
1349 ret = mi_lttng_writer_write_element_unsigned_int(writer,
1350 mi_lttng_element_id, output->id);
1351 if (ret) {
1352 goto end;
1353 }
1354
1355 /* Snapshot output names */
1356 ret = mi_lttng_writer_write_element_string(writer,
1357 config_element_name, n_ptr);
1358 if (ret) {
1359 goto end;
1360 }
1361
1362 /* Destination of the output (ctrl_url)*/
1363 ret = mi_lttng_writer_write_element_string(writer,
1364 mi_lttng_element_snapshot_ctrl_url, output->ctrl_url);
1365 if (ret) {
1366 goto end;
1367 }
1368
1369 /* Snapshot added for session "current_session_name"*/
1370 ret = mi_lttng_writer_write_element_string(writer,
1371 mi_lttng_element_snapshot_session_name, current_session_name);
1372 if (ret) {
1373 goto end;
1374 }
1375
1376 /* total size of all stream combined */
1377 ret = mi_lttng_writer_write_element_unsigned_int(writer,
1378 mi_lttng_element_snapshot_max_size, output->max_size);
1379 if (ret) {
1380 goto end;
1381 }
1382
1383 /* Close snapshot element */
1384 ret = mi_lttng_writer_close_element(writer);
1385
1386 end:
1387 return ret;
1388 }
1389
1390 LTTNG_HIDDEN
1391 int mi_lttng_snapshot_record(struct mi_writer *writer,
1392 const char *current_session_name, const char *url,
1393 const char *cmdline_ctrl_url, const char *cmdline_data_url)
1394 {
1395 int ret;
1396
1397 /* Open element snapshot */
1398 ret = mi_lttng_writer_open_element(writer,
1399 mi_lttng_element_command_snapshot);
1400 if (ret) {
1401 goto end;
1402 }
1403
1404 /*
1405 * If a valid an URL was given, serialize it,
1406 * else take the command line data and ctrl urls*/
1407 if (url) {
1408 /* Destination of the output (ctrl_url)*/
1409 ret = mi_lttng_writer_write_element_string(writer,
1410 mi_lttng_element_snapshot_ctrl_url, url);
1411 if (ret) {
1412 goto end;
1413 }
1414 } else if (cmdline_ctrl_url) {
1415 /* Destination of the output (ctrl_url)*/
1416 ret = mi_lttng_writer_write_element_string(writer,
1417 mi_lttng_element_snapshot_ctrl_url, cmdline_ctrl_url);
1418 if (ret) {
1419 goto end;
1420 }
1421
1422 /* Destination of the output (data_url) */
1423 ret = mi_lttng_writer_write_element_string(writer,
1424 mi_lttng_element_snapshot_data_url, cmdline_data_url);
1425 if (ret) {
1426 goto end;
1427 }
1428 }
1429
1430 /* Close record_snapshot element */
1431 ret = mi_lttng_writer_close_element(writer);
1432
1433 end:
1434 return ret;
1435 }
This page took 0.081502 seconds and 6 git commands to generate.