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