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