Fix: use pid element instead of process element
[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 */
f4a088f7
JRJ
81const char * const mi_lttng_element_pid_id = "id";
82
83/* Strings related to save command */
84const char * const mi_lttng_element_save = "save";
85
86/* Strings related to load command */
87const char * const mi_lttng_element_load = "load";
88
5e18ec73 89/* General elements of mi_lttng */
f4a088f7
JRJ
90const char * const mi_lttng_element_empty = "";
91const char * const mi_lttng_element_id = "id";
92const char * const mi_lttng_element_nowrite = "nowrite";
93const char * const mi_lttng_element_success = "success";
5e18ec73
JR
94const char * const mi_lttng_element_type_enum = "ENUM";
95const char * const mi_lttng_element_type_float = "FLOAT";
f4a088f7
JRJ
96const char * const mi_lttng_element_type_integer = "INTEGER";
97const char * const mi_lttng_element_type_other = "OTHER";
5e18ec73 98const char * const mi_lttng_element_type_string = "STRING";
5e18ec73
JR
99
100/* String related to loglevel */
101const char * const mi_lttng_loglevel_str_alert = "TRACE_ALERT";
102const char * const mi_lttng_loglevel_str_crit = "TRACE_CRIT";
103const char * const mi_lttng_loglevel_str_debug = "TRACE_DEBUG";
104const char * const mi_lttng_loglevel_str_debug_function = "TRACE_DEBUG_FUNCTION";
105const char * const mi_lttng_loglevel_str_debug_line = "TRACE_DEBUG_LINE";
106const char * const mi_lttng_loglevel_str_debug_module = "TRACE_DEBUG_MODULE";
107const char * const mi_lttng_loglevel_str_debug_process = "TRACE_DEBUG_PROCESS";
108const char * const mi_lttng_loglevel_str_debug_program = "TRACE_DEBUG_PROGRAM";
109const char * const mi_lttng_loglevel_str_debug_system = "TRACE_DEBUG_SYSTEM";
110const char * const mi_lttng_loglevel_str_debug_unit = "TRACE_DEBUG_UNIT";
111const char * const mi_lttng_loglevel_str_emerg = "TRACE_EMERG";
112const char * const mi_lttng_loglevel_str_err = "TRACE_ERR";
113const char * const mi_lttng_loglevel_str_info = "TRACE_INFO";
114const char * const mi_lttng_loglevel_str_notice = "TRACE_NOTICE";
115const char * const mi_lttng_loglevel_str_unknown = "UNKNOWN";
116const char * const mi_lttng_loglevel_str_warning = "TRACE_WARNING";
117
136f2f81
JRJ
118/* String related to loglevel JUL */
119const char * const mi_lttng_loglevel_str_jul_all = "JUL_ALL";
120const char * const mi_lttng_loglevel_str_jul_config = "JUL_CONFIG";
121const char * const mi_lttng_loglevel_str_jul_fine = "JUL_FINE";
122const char * const mi_lttng_loglevel_str_jul_finer = "JUL_FINER";
123const char * const mi_lttng_loglevel_str_jul_finest = "JUL_FINEST";
124const char * const mi_lttng_loglevel_str_jul_info = "JUL_INFO";
125const char * const mi_lttng_loglevel_str_jul_off = "JUL_OFF";
126const char * const mi_lttng_loglevel_str_jul_severe = "JUL_SEVERE";
127const char * const mi_lttng_loglevel_str_jul_warning = "JUL_WARNING";
128
970d848b
DG
129/* String related to loglevel LOG4J */
130const char * const mi_lttng_loglevel_str_log4j_off = "LOG4J_OFF";
131const char * const mi_lttng_loglevel_str_log4j_fatal = "LOG4J_FATAL";
132const char * const mi_lttng_loglevel_str_log4j_error = "LOG4J_ERROR";
133const char * const mi_lttng_loglevel_str_log4j_warn = "LOG4J_WARN";
134const char * const mi_lttng_loglevel_str_log4j_info = "LOG4J_INFO";
135const char * const mi_lttng_loglevel_str_log4j_debug = "LOG4J_DEBUG";
136const char * const mi_lttng_loglevel_str_log4j_trace = "LOG4J_TRACE";
137const char * const mi_lttng_loglevel_str_log4j_all = "LOG4J_ALL";
138
0e115563
DG
139/* String related to loglevel Python */
140const char * const mi_lttng_loglevel_str_python_critical = "PYTHON_CRITICAL";
141const char * const mi_lttng_loglevel_str_python_error = "PYTHON_ERROR";
142const char * const mi_lttng_loglevel_str_python_warning = "PYTHON_WARNING";
143const char * const mi_lttng_loglevel_str_python_info = "PYTHON_INFO";
144const char * const mi_lttng_loglevel_str_python_debug = "PYTHON_DEBUG";
145const char * const mi_lttng_loglevel_str_python_notset = "PYTHON_NOTSET";
146
1734c658 147/* String related to loglevel type */
5e18ec73
JR
148const char * const mi_lttng_loglevel_type_all = "ALL";
149const char * const mi_lttng_loglevel_type_range = "RANGE";
150const char * const mi_lttng_loglevel_type_single = "SINGLE";
151const char * const mi_lttng_loglevel_type_unknown = "UNKNOWN";
152
7e66b1b0
JRJ
153/* String related to lttng_calibrate */
154const char * const mi_lttng_element_calibrate = "calibrate";
155const char * const mi_lttng_element_calibrate_function = "FUNCTION";
156
50534d6f 157/* String related to a lttng_snapshot_output */
50534d6f 158const char * const mi_lttng_element_snapshot_ctrl_url = "ctrl_url";
f4a088f7 159const char * const mi_lttng_element_snapshot_data_url = "data_url";
50534d6f 160const char * const mi_lttng_element_snapshot_max_size = "max_size";
f4a088f7
JRJ
161const char * const mi_lttng_element_snapshot_n_ptr = "n_ptr";
162const char * const mi_lttng_element_snapshot_session_name = "session_name";
163const char * const mi_lttng_element_snapshots = "snapshots";
5e18ec73 164
a585578f
JR
165/* String related to track/untrack command */
166const char * const mi_lttng_element_track_untrack_targets = "targets";
167const char * const mi_lttng_element_track_untrack_pid_target = "pid_target";
168const char * const mi_lttng_element_track_untrack_all_wildcard = "*";
169
170
136f2f81
JRJ
171/* This is a merge of jul loglevel and regular loglevel
172 * Those should never overlap by definition
173 * (see struct lttng_event loglevel)
174 */
ea75976a 175LTTNG_HIDDEN
970d848b 176const char *mi_lttng_loglevel_string(int value, enum lttng_domain_type domain)
5e18ec73 177{
970d848b
DG
178 switch (domain) {
179 case LTTNG_DOMAIN_KERNEL:
180 case LTTNG_DOMAIN_UST:
181 switch (value) {
182 case -1:
183 return mi_lttng_element_empty;
184 case LTTNG_LOGLEVEL_EMERG:
185 return mi_lttng_loglevel_str_emerg;
186 case LTTNG_LOGLEVEL_ALERT:
187 return mi_lttng_loglevel_str_alert;
188 case LTTNG_LOGLEVEL_CRIT:
189 return mi_lttng_loglevel_str_crit;
190 case LTTNG_LOGLEVEL_ERR:
191 return mi_lttng_loglevel_str_err;
192 case LTTNG_LOGLEVEL_WARNING:
193 return mi_lttng_loglevel_str_warning;
194 case LTTNG_LOGLEVEL_NOTICE:
195 return mi_lttng_loglevel_str_notice;
196 case LTTNG_LOGLEVEL_INFO:
197 return mi_lttng_loglevel_str_info;
198 case LTTNG_LOGLEVEL_DEBUG_SYSTEM:
199 return mi_lttng_loglevel_str_debug_system;
200 case LTTNG_LOGLEVEL_DEBUG_PROGRAM:
201 return mi_lttng_loglevel_str_debug_program;
202 case LTTNG_LOGLEVEL_DEBUG_PROCESS:
203 return mi_lttng_loglevel_str_debug_process;
204 case LTTNG_LOGLEVEL_DEBUG_MODULE:
205 return mi_lttng_loglevel_str_debug_module;
206 case LTTNG_LOGLEVEL_DEBUG_UNIT:
207 return mi_lttng_loglevel_str_debug_unit;
208 case LTTNG_LOGLEVEL_DEBUG_FUNCTION:
209 return mi_lttng_loglevel_str_debug_function;
210 case LTTNG_LOGLEVEL_DEBUG_LINE:
211 return mi_lttng_loglevel_str_debug_line;
212 case LTTNG_LOGLEVEL_DEBUG:
213 return mi_lttng_loglevel_str_debug;
214 default:
215 return mi_lttng_loglevel_str_unknown;
216 }
217 break;
218 case LTTNG_DOMAIN_LOG4J:
219 switch (value) {
220 case -1:
221 return mi_lttng_element_empty;
222 case LTTNG_LOGLEVEL_LOG4J_OFF:
223 return mi_lttng_loglevel_str_log4j_off;
224 case LTTNG_LOGLEVEL_LOG4J_FATAL:
225 return mi_lttng_loglevel_str_log4j_fatal;
226 case LTTNG_LOGLEVEL_LOG4J_ERROR:
227 return mi_lttng_loglevel_str_log4j_error;
228 case LTTNG_LOGLEVEL_LOG4J_WARN:
229 return mi_lttng_loglevel_str_log4j_warn;
230 case LTTNG_LOGLEVEL_LOG4J_INFO:
231 return mi_lttng_loglevel_str_log4j_info;
232 case LTTNG_LOGLEVEL_LOG4J_DEBUG:
233 return mi_lttng_loglevel_str_log4j_debug;
234 case LTTNG_LOGLEVEL_LOG4J_TRACE:
235 return mi_lttng_loglevel_str_log4j_trace;
236 case LTTNG_LOGLEVEL_LOG4J_ALL:
237 return mi_lttng_loglevel_str_log4j_all;
238 default:
239 return mi_lttng_loglevel_str_unknown;
240 }
241 break;
242 case LTTNG_DOMAIN_JUL:
243 switch (value) {
244 case -1:
245 return mi_lttng_element_empty;
246 case LTTNG_LOGLEVEL_JUL_OFF:
247 return mi_lttng_loglevel_str_jul_off;
248 case LTTNG_LOGLEVEL_JUL_SEVERE:
249 return mi_lttng_loglevel_str_jul_severe;
250 case LTTNG_LOGLEVEL_JUL_WARNING:
251 return mi_lttng_loglevel_str_jul_warning;
252 case LTTNG_LOGLEVEL_JUL_INFO:
253 return mi_lttng_loglevel_str_jul_info;
254 case LTTNG_LOGLEVEL_JUL_CONFIG:
255 return mi_lttng_loglevel_str_jul_config;
256 case LTTNG_LOGLEVEL_JUL_FINE:
257 return mi_lttng_loglevel_str_jul_fine;
258 case LTTNG_LOGLEVEL_JUL_FINER:
259 return mi_lttng_loglevel_str_jul_finer;
260 case LTTNG_LOGLEVEL_JUL_FINEST:
261 return mi_lttng_loglevel_str_jul_finest;
262 case LTTNG_LOGLEVEL_JUL_ALL:
263 return mi_lttng_loglevel_str_jul_all;
264 default:
265 return mi_lttng_loglevel_str_unknown;
266 }
267 break;
0e115563
DG
268 case LTTNG_DOMAIN_PYTHON:
269 switch (value) {
270 case LTTNG_LOGLEVEL_PYTHON_CRITICAL:
271 return mi_lttng_loglevel_str_python_critical;
272 case LTTNG_LOGLEVEL_PYTHON_ERROR:
273 return mi_lttng_loglevel_str_python_error;
274 case LTTNG_LOGLEVEL_PYTHON_WARNING:
275 return mi_lttng_loglevel_str_python_warning;
276 case LTTNG_LOGLEVEL_PYTHON_INFO:
277 return mi_lttng_loglevel_str_python_info;
278 case LTTNG_LOGLEVEL_PYTHON_DEBUG:
279 return mi_lttng_loglevel_str_python_debug;
280 case LTTNG_LOGLEVEL_PYTHON_NOTSET:
281 return mi_lttng_loglevel_str_python_notset;
282 default:
283 return mi_lttng_loglevel_str_unknown;
284 }
285 break;
5e18ec73 286 }
970d848b
DG
287
288 /* Reaching this means the domain is unknown. */
289 return mi_lttng_loglevel_str_unknown;
5e18ec73
JR
290}
291
ea75976a 292LTTNG_HIDDEN
5e18ec73
JR
293const char *mi_lttng_logleveltype_string(enum lttng_loglevel_type value)
294{
295 switch (value) {
296 case LTTNG_EVENT_LOGLEVEL_ALL:
297 return mi_lttng_loglevel_type_all;
298 case LTTNG_EVENT_LOGLEVEL_RANGE:
299 return mi_lttng_loglevel_type_range;
300 case LTTNG_EVENT_LOGLEVEL_SINGLE:
301 return mi_lttng_loglevel_type_single;
302 default:
303 return mi_lttng_loglevel_type_unknown;
304 }
305}
306
ea75976a 307LTTNG_HIDDEN
5e18ec73
JR
308const char *mi_lttng_eventtype_string(enum lttng_event_type value)
309{
310 switch (value) {
311 case LTTNG_EVENT_ALL:
312 return config_event_type_all;
313 case LTTNG_EVENT_TRACEPOINT:
314 return config_event_type_tracepoint;
315 case LTTNG_EVENT_PROBE:
316 return config_event_type_probe;
317 case LTTNG_EVENT_FUNCTION:
318 return config_event_type_function;
319 case LTTNG_EVENT_FUNCTION_ENTRY:
320 return config_event_type_function_entry;
321 case LTTNG_EVENT_SYSCALL:
322 return config_event_type_syscall;
323 case LTTNG_EVENT_NOOP:
324 return config_event_type_noop;
325 default:
326 return mi_lttng_element_empty;
327 }
328}
329
ea75976a 330LTTNG_HIDDEN
89b72577
JRJ
331const char *mi_lttng_event_contexttype_string(enum lttng_event_context_type val)
332{
333 switch (val) {
334 case LTTNG_EVENT_CONTEXT_PID:
335 return config_event_context_pid;
336 case LTTNG_EVENT_CONTEXT_PERF_COUNTER:
337 return mi_lttng_context_type_perf_counter;
338 case LTTNG_EVENT_CONTEXT_PERF_THREAD_COUNTER:
339 return mi_lttng_context_type_perf_thread_counter;
340 case LTTNG_EVENT_CONTEXT_PERF_CPU_COUNTER:
341 return mi_lttng_context_type_perf_cpu_counter;
342 case LTTNG_EVENT_CONTEXT_PROCNAME:
343 return config_event_context_procname;
344 case LTTNG_EVENT_CONTEXT_PRIO:
345 return config_event_context_prio;
346 case LTTNG_EVENT_CONTEXT_NICE:
347 return config_event_context_nice;
348 case LTTNG_EVENT_CONTEXT_VPID:
349 return config_event_context_vpid;
350 case LTTNG_EVENT_CONTEXT_TID:
351 return config_event_context_tid;
352 case LTTNG_EVENT_CONTEXT_VTID:
353 return config_event_context_vtid;
354 case LTTNG_EVENT_CONTEXT_PPID:
355 return config_event_context_ppid;
356 case LTTNG_EVENT_CONTEXT_VPPID:
357 return config_event_context_vppid;
358 case LTTNG_EVENT_CONTEXT_PTHREAD_ID:
359 return config_event_context_pthread_id;
360 case LTTNG_EVENT_CONTEXT_HOSTNAME:
361 return config_event_context_hostname;
362 case LTTNG_EVENT_CONTEXT_IP:
363 return config_event_context_ip;
364 default:
365 return NULL;
366 }
367}
368
ea75976a 369LTTNG_HIDDEN
5e18ec73
JR
370const char *mi_lttng_eventfieldtype_string(enum lttng_event_field_type val)
371{
372 switch (val) {
373 case(LTTNG_EVENT_FIELD_INTEGER):
374 return mi_lttng_element_type_integer;
375 case(LTTNG_EVENT_FIELD_ENUM):
376 return mi_lttng_element_type_enum;
377 case(LTTNG_EVENT_FIELD_FLOAT):
378 return mi_lttng_element_type_float;
379 case(LTTNG_EVENT_FIELD_STRING):
380 return mi_lttng_element_type_string;
381 default:
382 return mi_lttng_element_type_other;
383 }
384}
385
ea75976a 386LTTNG_HIDDEN
5e18ec73
JR
387const char *mi_lttng_domaintype_string(enum lttng_domain_type value)
388{
389 /* Note: This is a *duplicate* of get_domain_str from bin/lttng/utils.c */
390 switch (value) {
391 case LTTNG_DOMAIN_KERNEL:
392 return config_domain_type_kernel;
393 case LTTNG_DOMAIN_UST:
394 return config_domain_type_ust;
395 case LTTNG_DOMAIN_JUL:
396 return config_domain_type_jul;
5cdb6027
DG
397 case LTTNG_DOMAIN_LOG4J:
398 return config_domain_type_log4j;
dce783e3
PP
399 case LTTNG_DOMAIN_PYTHON:
400 return config_domain_type_python;
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
a585578f
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{
a585578f
JR
1154 return mi_lttng_writer_open_element(writer, config_element_pids);
1155}
1156
103d0bfb
JR
1157/*
1158 * TODO: move the listing of pid for user agent to process semantic on
1159 * mi api bump. The use of process element break the mi api.
1160 */
a585578f 1161LTTNG_HIDDEN
103d0bfb 1162int mi_lttng_pid(struct mi_writer *writer, pid_t pid , const char *name,
5e18ec73
JR
1163 int is_open)
1164{
1165 int ret;
1166
103d0bfb
JR
1167 /* Open pid process */
1168 ret = mi_lttng_writer_open_element(writer, config_element_pid);
5e18ec73
JR
1169 if (ret) {
1170 goto end;
1171 }
1172
1173 /* Writing pid number */
1174 ret = mi_lttng_writer_write_element_signed_int(writer,
103d0bfb 1175 mi_lttng_element_pid_id, (int)pid);
5e18ec73
JR
1176 if (ret) {
1177 goto end;
1178 }
1179
1180 /* Writing name of the process */
a585578f
JR
1181 if (name) {
1182 ret = mi_lttng_writer_write_element_string(writer, config_element_name,
1183 name);
1184 if (ret) {
1185 goto end;
1186 }
1187 }
1188
1189 if (!is_open) {
1190 /* Closing Pid */
1191 ret = mi_lttng_writer_close_element(writer);
1192 }
1193
1194end:
1195 return ret;
1196}
1197
1198LTTNG_HIDDEN
1199int mi_lttng_targets_open(struct mi_writer *writer)
1200{
1201 return mi_lttng_writer_open_element(writer,
1202 mi_lttng_element_track_untrack_targets);
1203}
1204
1205LTTNG_HIDDEN
1206int mi_lttng_pid_target(struct mi_writer *writer, pid_t pid, int is_open)
1207{
1208 int ret;
1209
1210 ret = mi_lttng_writer_open_element(writer,
1211 mi_lttng_element_track_untrack_pid_target);
1212 if (ret) {
1213 goto end;
1214 }
1215
1216 /* Writing pid number
1217 * Special case for element all on track untrack command
1218 * All pid is represented as wildcard *
1219 */
1220 if ((int) pid == -1) {
1221 ret = mi_lttng_writer_write_element_string(writer,
1222 config_element_pid,
1223 mi_lttng_element_track_untrack_all_wildcard);
1224 } else {
1225 ret = mi_lttng_writer_write_element_signed_int(writer,
1226 config_element_pid, (int) pid);
1227 }
5e18ec73
JR
1228 if (ret) {
1229 goto end;
1230 }
1231
1232 if (!is_open) {
5e18ec73 1233 ret = mi_lttng_writer_close_element(writer);
a585578f
JR
1234 if (ret) {
1235 goto end;
1236 }
5e18ec73
JR
1237 }
1238
1239end:
1240 return ret;
1241}
1242
1243LTTNG_HIDDEN
1244int mi_lttng_event_fields_open(struct mi_writer *writer)
1245{
1246 return mi_lttng_writer_open_element(writer, mi_lttng_element_event_fields);
1247}
1248
1249LTTNG_HIDDEN
1250int mi_lttng_event_field(struct mi_writer *writer,
1251 struct lttng_event_field *field)
1252{
1253 int ret;
1254
1255 if (!field->field_name[0]) {
5e18ec73
JR
1256 ret = 0;
1257 goto end;
1258 }
1259
1260 /* Open field */
1261 ret = mi_lttng_writer_open_element(writer, mi_lttng_element_event_field);
1262 if (ret) {
1263 goto end;
1264 }
1265
1266 if (!field->field_name[0]) {
1267 goto close;
1268 }
1269
1270 /* Name */
1271 ret = mi_lttng_writer_write_element_string(writer, config_element_name,
1272 field->field_name);
1273 if (ret) {
1274 goto end;
1275 }
1276
1277 /* Type */
1278 ret = mi_lttng_writer_write_element_string(writer, config_element_type,
1279 mi_lttng_eventfieldtype_string(field->type));
1280 if (ret) {
1281 goto end;
1282 }
1283
1284 /* nowrite */
1285 ret = mi_lttng_writer_write_element_signed_int(writer,
1286 mi_lttng_element_nowrite, field->nowrite);
1287 if (ret) {
1288 goto end;
1289 }
1290
1291close:
1292 /* Close field element */
1293 ret = mi_lttng_writer_close_element(writer);
1294
1295end:
1296 return ret;
1297}
7e66b1b0
JRJ
1298
1299LTTNG_HIDDEN
1300int mi_lttng_calibrate(struct mi_writer *writer,
1301 struct lttng_calibrate *calibrate)
1302{
1303 int ret;
1304
1305 /* Open calibrate element */
1306 ret = mi_lttng_writer_open_element(writer, mi_lttng_element_calibrate);
1307 if (ret) {
1308 goto end;
1309 }
1310
1311 /* Calibration type */
1312 ret = mi_lttng_writer_write_element_string(writer, config_element_type,
1313 mi_lttng_calibratetype_string(calibrate->type));
1314 if (ret) {
1315 goto end;
1316 }
1317
1318 /* Closing calibrate element */
1319 ret = mi_lttng_writer_close_element(writer);
1320end:
1321 return ret;
1322}
ccf10263 1323
89b72577
JRJ
1324LTTNG_HIDDEN
1325int mi_lttng_context(struct mi_writer *writer,
1326 struct lttng_event_context *context, int is_open)
1327{
1328 int ret;
1329 const char *type_string;
1330 struct lttng_event_perf_counter_ctx *perf_context;
1331 /* Open context */
1332 ret = mi_lttng_writer_open_element(writer , config_element_context);
1333 if (ret) {
1334 goto end;
1335 }
1336
1337 type_string = mi_lttng_event_contexttype_string(context->ctx);
1338 if (!type_string) {
1339 ret = -LTTNG_ERR_INVALID;
1340 goto end;
1341 }
1342
1343 /* Print context type */
1344 ret = mi_lttng_writer_write_element_string(writer, config_element_type,
1345 type_string);
1346
1347 /* Special case for PERF_*_COUNTER
1348 * print the lttng_event_perf_counter_ctx*/
1349 switch (context->ctx) {
1350 case LTTNG_EVENT_CONTEXT_PERF_COUNTER:
1351 case LTTNG_EVENT_CONTEXT_PERF_THREAD_COUNTER:
1352 case LTTNG_EVENT_CONTEXT_PERF_CPU_COUNTER:
1353 perf_context = &context->u.perf_counter;
1354 ret = mi_lttng_perf_counter_context(writer, perf_context);
1355 if (ret) {
1356 goto end;
1357 }
1358 break;
1359 default:
1360 break;
1361 }
1362
1363 /* Close context */
1364 if (!is_open) {
1365 ret = mi_lttng_writer_close_element(writer);
1366 }
1367
1368end:
1369 return ret;
1370}
1371
1372LTTNG_HIDDEN
1373int mi_lttng_perf_counter_context(struct mi_writer *writer,
1374 struct lttng_event_perf_counter_ctx *perf_context)
1375{
1376 int ret;
1377
1378 /* Open perf_counter_context */
1379 ret = mi_lttng_writer_open_element(writer,
1380 mi_lttng_element_perf_counter_context);
1381 if (ret) {
1382 goto end;
1383 }
1384
1385 /* Type */
1386 ret = mi_lttng_writer_write_element_unsigned_int(writer,
1387 config_element_type, perf_context->type);
1388 if (ret) {
1389 goto end;
1390 }
1391
1392 /* Config */
1393 ret = mi_lttng_writer_write_element_unsigned_int(writer,
1394 config_element_config, perf_context->config);
1395 if (ret) {
1396 goto end;
1397 }
1398
1399 /* Name of the perf counter */
1400 ret = mi_lttng_writer_write_element_string(writer,
1401 config_element_name, perf_context->name);
1402 if (ret) {
1403 goto end;
1404 }
1405
1406 /* Close perf_counter_context */
1407 ret = mi_lttng_writer_close_element(writer);
1408end:
1409 return ret;
1410}
50534d6f
JRJ
1411
1412LTTNG_HIDDEN
1413int mi_lttng_snapshot_output_session_name(struct mi_writer *writer,
1414 const char *session_name)
1415{
1416 int ret;
1417
1418 /* Open session element */
1419 ret = mi_lttng_writer_open_element(writer, config_element_session);
1420 if (ret) {
1421 goto end;
1422 }
1423
1424 /* Snapshot output list for current session name */
1425 ret = mi_lttng_writer_write_element_string(writer, config_element_name,
1426 session_name);
01defc26
JR
1427 if (ret) {
1428 goto end;
1429 }
50534d6f
JRJ
1430
1431 /* Open element snapshots (sequence one snapshot) */
1432 ret = mi_lttng_writer_open_element(writer, mi_lttng_element_snapshots);
1433 if (ret) {
1434 goto end;
1435 }
1436
1437end:
1438 return ret;
1439}
1440
1441LTTNG_HIDDEN
1442int mi_lttng_snapshot_list_output(struct mi_writer *writer,
1443 struct lttng_snapshot_output *output)
1444{
1445 int ret;
1446
1447 /* Open element snapshot output */
1448 ret = mi_lttng_writer_open_element(writer,
1449 mi_lttng_element_command_snapshot);
1450 if (ret) {
1451 goto end;
1452 }
1453
1454 /* ID of the snapshot output */
1455 ret = mi_lttng_writer_write_element_unsigned_int(writer,
1456 mi_lttng_element_id, output->id);
1457 if (ret) {
1458 goto end;
1459 }
1460
1461 /* Name of the output */
1462 ret = mi_lttng_writer_write_element_string(writer, config_element_name,
1463 output->name);
1464 if (ret) {
1465 goto end;
1466 }
1467
1468 /* Destination of the output (ctrl_url)*/
1469 ret = mi_lttng_writer_write_element_string(writer,
1470 mi_lttng_element_snapshot_ctrl_url, output->ctrl_url);
1471 if (ret) {
1472 goto end;
1473 }
1474
1475 /* Destination of the output (data_url) */
1476 ret = mi_lttng_writer_write_element_string(writer,
1477 mi_lttng_element_snapshot_data_url, output->data_url);
1478 if (ret) {
1479 goto end;
1480 }
1481
1482 /* total size of all stream combined */
1483 ret = mi_lttng_writer_write_element_unsigned_int(writer,
1484 mi_lttng_element_snapshot_max_size, output->max_size);
1485 if (ret) {
1486 goto end;
1487 }
1488
1489 /* Close snapshot output element */
1490 ret = mi_lttng_writer_close_element(writer);
1491
1492end:
1493 return ret;
1494}
1495
1496LTTNG_HIDDEN
1497int mi_lttng_snapshot_del_output(struct mi_writer *writer, int id,
1498 const char *name, const char *current_session_name)
1499{
1500 int ret;
1501
1502 /* Open element del_snapshot */
1503 ret = mi_lttng_writer_open_element(writer,
1504 mi_lttng_element_command_snapshot);
1505 if (ret) {
1506 goto end;
1507 }
1508
1509
1510 if (id != UINT32_MAX) {
1511 /* "Snapshot output "id" successfully deleted
1512 * for "current_session_name"
1513 * ID of the snapshot output
1514 */
1515 ret = mi_lttng_writer_write_element_unsigned_int(writer,
1516 mi_lttng_element_id, id);
1517 if (ret) {
1518 goto end;
1519 }
1520 } else {
1521 /* "Snapshot output "name" successfully deleted
1522 * for session "current_session_name"
1523 * Name of the output
1524 */
1525 ret = mi_lttng_writer_write_element_string(writer, config_element_name,
1526 name);
1527 if (ret) {
1528 goto end;
1529 }
1530 }
1531
1532 /* Snapshot was deleted for session "current_session_name"*/
1533 ret = mi_lttng_writer_write_element_string(writer,
1534 mi_lttng_element_snapshot_session_name,
1535 current_session_name);
1536 if (ret) {
1537 goto end;
1538 }
1539
1540 /* Close snapshot element */
1541 ret = mi_lttng_writer_close_element(writer);
1542
1543end:
1544 return ret;
1545}
1546
1547LTTNG_HIDDEN
1548int mi_lttng_snapshot_add_output(struct mi_writer *writer,
1549 const char *current_session_name, const char *n_ptr,
1550 struct lttng_snapshot_output *output)
1551{
1552 int ret;
1553
1554 /* Open element snapshot */
1555 ret = mi_lttng_writer_open_element(writer,
1556 mi_lttng_element_command_snapshot);
1557 if (ret) {
1558 goto end;
1559 }
1560
1561 /* Snapshot output id */
1562 ret = mi_lttng_writer_write_element_unsigned_int(writer,
1563 mi_lttng_element_id, output->id);
1564 if (ret) {
1565 goto end;
1566 }
1567
1568 /* Snapshot output names */
1569 ret = mi_lttng_writer_write_element_string(writer,
1570 config_element_name, n_ptr);
1571 if (ret) {
1572 goto end;
1573 }
1574
1575 /* Destination of the output (ctrl_url)*/
1576 ret = mi_lttng_writer_write_element_string(writer,
1577 mi_lttng_element_snapshot_ctrl_url, output->ctrl_url);
1578 if (ret) {
1579 goto end;
1580 }
1581
1582 /* Snapshot added for session "current_session_name"*/
1583 ret = mi_lttng_writer_write_element_string(writer,
1584 mi_lttng_element_snapshot_session_name, current_session_name);
1585 if (ret) {
1586 goto end;
1587 }
1588
1589 /* total size of all stream combined */
1590 ret = mi_lttng_writer_write_element_unsigned_int(writer,
1591 mi_lttng_element_snapshot_max_size, output->max_size);
1592 if (ret) {
1593 goto end;
1594 }
1595
1596 /* Close snapshot element */
1597 ret = mi_lttng_writer_close_element(writer);
1598
1599end:
1600 return ret;
1601}
1602
1603LTTNG_HIDDEN
1604int mi_lttng_snapshot_record(struct mi_writer *writer,
1605 const char *current_session_name, const char *url,
1606 const char *cmdline_ctrl_url, const char *cmdline_data_url)
1607{
1608 int ret;
1609
1610 /* Open element snapshot */
1611 ret = mi_lttng_writer_open_element(writer,
1612 mi_lttng_element_command_snapshot);
1613 if (ret) {
1614 goto end;
1615 }
1616
1617 /*
1618 * If a valid an URL was given, serialize it,
1619 * else take the command line data and ctrl urls*/
1620 if (url) {
1621 /* Destination of the output (ctrl_url)*/
1622 ret = mi_lttng_writer_write_element_string(writer,
1623 mi_lttng_element_snapshot_ctrl_url, url);
1624 if (ret) {
1625 goto end;
1626 }
1627 } else if (cmdline_ctrl_url) {
1628 /* Destination of the output (ctrl_url)*/
1629 ret = mi_lttng_writer_write_element_string(writer,
1630 mi_lttng_element_snapshot_ctrl_url, cmdline_ctrl_url);
1631 if (ret) {
1632 goto end;
1633 }
1634
1635 /* Destination of the output (data_url) */
1636 ret = mi_lttng_writer_write_element_string(writer,
1637 mi_lttng_element_snapshot_data_url, cmdline_data_url);
1638 if (ret) {
1639 goto end;
1640 }
1641 }
1642
1643 /* Close record_snapshot element */
1644 ret = mi_lttng_writer_close_element(writer);
1645
1646end:
1647 return ret;
1648}
This page took 0.093204 seconds and 4 git commands to generate.