Fix: event leak during event load
[lttng-tools.git] / src / common / config / session-config.c
CommitLineData
1501a7f3
JG
1/*
2 * Copyright (C) 2013 - Jérémie Galarneau <jeremie.galarneau@efficios.com>
3 *
4 * This program is free software; you can redistribute it and/or modify it
5 * under the terms of the GNU General Public License, version 2 only, as
6 * published by the Free Software Foundation.
7 *
8 * This program is distributed in the hope that it will be useful, but WITHOUT
9 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
10 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
11 * more details.
12 *
13 * You should have received a copy of the GNU General Public License along with
14 * this program; if not, write to the Free Software Foundation, Inc., 51
15 * Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
16 */
17
6c1c0768 18#define _LGPL_SOURCE
1501a7f3 19#include <assert.h>
1501a7f3 20#include <ctype.h>
1501a7f3
JG
21#include <stdio.h>
22#include <stdlib.h>
23#include <string.h>
36f2332b 24#include <inttypes.h>
dcf266c0
JG
25#include <dirent.h>
26#include <unistd.h>
27#include <sys/types.h>
28#include <sys/stat.h>
6c66fa0f 29#include <stdbool.h>
1501a7f3
JG
30
31#include <common/defaults.h>
32#include <common/error.h>
33#include <common/macros.h>
34#include <common/utils.h>
cce35f91 35#include <common/dynamic-buffer.h>
e8fa9fb0 36#include <common/compat/getenv.h>
fb198a11
JG
37#include <lttng/lttng-error.h>
38#include <libxml/parser.h>
39#include <libxml/valid.h>
40#include <libxml/xmlschemas.h>
dcf266c0
JG
41#include <libxml/tree.h>
42#include <lttng/lttng.h>
43#include <lttng/snapshot.h>
259c2674 44#include <lttng/rotation.h>
c1e83fb4 45#include <lttng/userspace-probe.h>
1501a7f3 46
f40ef1d5 47#include "session-config.h"
36f2332b 48#include "config-internal.h"
1501a7f3 49
c1e83fb4
FD
50#define CONFIG_USERSPACE_PROBE_LOOKUP_METHOD_NAME_MAX_LEN 7
51
1501a7f3
JG
52struct handler_filter_args {
53 const char* section;
54 config_entry_handler_cb handler;
55 void *user_data;
56};
57
dcf266c0
JG
58struct session_config_validation_ctx {
59 xmlSchemaParserCtxtPtr parser_ctx;
60 xmlSchemaPtr schema;
61 xmlSchemaValidCtxtPtr schema_validation_ctx;
62};
63
1501a7f3
JG
64const char * const config_str_yes = "yes";
65const char * const config_str_true = "true";
66const char * const config_str_on = "on";
67const char * const config_str_no = "no";
68const char * const config_str_false = "false";
69const char * const config_str_off = "off";
36f2332b 70const char * const config_xml_encoding = "UTF-8";
fb198a11 71const size_t config_xml_encoding_bytes_per_char = 2; /* Size of the encoding's largest character */
36f2332b
JG
72const char * const config_xml_indent_string = "\t";
73const char * const config_xml_true = "true";
74const char * const config_xml_false = "false";
1501a7f3 75
fb198a11
JG
76const char * const config_element_channel = "channel";
77const char * const config_element_channels = "channels";
78const char * const config_element_domain = "domain";
79const char * const config_element_domains = "domains";
80const char * const config_element_event = "event";
81const char * const config_element_events = "events";
82const char * const config_element_context = "context";
83const char * const config_element_contexts = "contexts";
84const char * const config_element_attributes = "attributes";
85const char * const config_element_exclusion = "exclusion";
86const char * const config_element_exclusions = "exclusions";
87const char * const config_element_function_attributes = "function_attributes";
88const char * const config_element_probe_attributes = "probe_attributes";
89const char * const config_element_symbol_name = "symbol_name";
90const char * const config_element_address = "address";
91const char * const config_element_offset = "offset";
c1e83fb4 92
d0687332
JG
93LTTNG_HIDDEN const char * const config_element_userspace_probe_lookup = "lookup_method";
94LTTNG_HIDDEN const char * const config_element_userspace_probe_lookup_function_default = "DEFAULT";
95LTTNG_HIDDEN const char * const config_element_userspace_probe_lookup_function_elf = "ELF";
96LTTNG_HIDDEN const char * const config_element_userspace_probe_lookup_tracepoint_sdt = "SDT";
97LTTNG_HIDDEN const char * const config_element_userspace_probe_location_binary_path = "binary_path";
98LTTNG_HIDDEN const char * const config_element_userspace_probe_function_attributes = "userspace_probe_function_attributes";
99LTTNG_HIDDEN const char * const config_element_userspace_probe_function_location_function_name = "function_name";
100LTTNG_HIDDEN const char * const config_element_userspace_probe_tracepoint_attributes = "userspace_probe_tracepoint_attributes";
101LTTNG_HIDDEN const char * const config_element_userspace_probe_tracepoint_location_provider_name = "provider_name";
102LTTNG_HIDDEN const char * const config_element_userspace_probe_tracepoint_location_probe_name = "probe_name";
c1e83fb4 103
fb198a11
JG
104const char * const config_element_name = "name";
105const char * const config_element_enabled = "enabled";
106const char * const config_element_overwrite_mode = "overwrite_mode";
107const char * const config_element_subbuf_size = "subbuffer_size";
108const char * const config_element_num_subbuf = "subbuffer_count";
109const char * const config_element_switch_timer_interval = "switch_timer_interval";
110const char * const config_element_read_timer_interval = "read_timer_interval";
6ab3e98b
JG
111LTTNG_HIDDEN const char * const config_element_monitor_timer_interval = "monitor_timer_interval";
112LTTNG_HIDDEN const char * const config_element_blocking_timeout = "blocking_timeout";
fb198a11
JG
113const char * const config_element_output = "output";
114const char * const config_element_output_type = "output_type";
115const char * const config_element_tracefile_size = "tracefile_size";
116const char * const config_element_tracefile_count = "tracefile_count";
117const char * const config_element_live_timer_interval = "live_timer_interval";
ec2ed7da
JG
118LTTNG_HIDDEN const char * const config_element_discarded_events = "discarded_events";
119LTTNG_HIDDEN const char * const config_element_lost_packets = "lost_packets";
fb198a11
JG
120const char * const config_element_type = "type";
121const char * const config_element_buffer_type = "buffer_type";
122const char * const config_element_session = "session";
123const char * const config_element_sessions = "sessions";
ec2ed7da
JG
124LTTNG_HIDDEN const char * const config_element_context_perf = "perf";
125LTTNG_HIDDEN const char * const config_element_context_app = "app";
126LTTNG_HIDDEN const char * const config_element_context_app_provider_name = "provider_name";
127LTTNG_HIDDEN const char * const config_element_context_app_ctx_name = "ctx_name";
fb198a11
JG
128const char * const config_element_config = "config";
129const char * const config_element_started = "started";
130const char * const config_element_snapshot_mode = "snapshot_mode";
131const char * const config_element_loglevel = "loglevel";
132const char * const config_element_loglevel_type = "loglevel_type";
133const char * const config_element_filter = "filter";
ec2ed7da 134LTTNG_HIDDEN const char * const config_element_filter_expression = "filter_expression";
fb198a11
JG
135const char * const config_element_snapshot_outputs = "snapshot_outputs";
136const char * const config_element_consumer_output = "consumer_output";
137const char * const config_element_destination = "destination";
138const char * const config_element_path = "path";
139const char * const config_element_net_output = "net_output";
140const char * const config_element_control_uri = "control_uri";
141const char * const config_element_data_uri = "data_uri";
142const char * const config_element_max_size = "max_size";
ccf10263
MD
143const char * const config_element_pid = "pid";
144const char * const config_element_pids = "pids";
9e7c9f56 145const char * const config_element_shared_memory_path = "shared_memory_path";
ebbf5ab7
JR
146const char * const config_element_pid_tracker = "pid_tracker";
147const char * const config_element_trackers = "trackers";
847a5916
JR
148const char * const config_element_targets = "targets";
149const char * const config_element_target_pid = "pid_target";
fb198a11 150
ce6176f2
JG
151LTTNG_HIDDEN const char * const config_element_rotation_schedules = "rotation_schedules";
152LTTNG_HIDDEN const char * const config_element_rotation_schedule_periodic = "periodic";
153LTTNG_HIDDEN const char * const config_element_rotation_schedule_periodic_time_us = "time_us";
154LTTNG_HIDDEN const char * const config_element_rotation_schedule_size_threshold = "size_threshold";
155LTTNG_HIDDEN const char * const config_element_rotation_schedule_size_threshold_bytes = "bytes";
259c2674 156
fb198a11
JG
157const char * const config_domain_type_kernel = "KERNEL";
158const char * const config_domain_type_ust = "UST";
159const char * const config_domain_type_jul = "JUL";
5cdb6027 160const char * const config_domain_type_log4j = "LOG4J";
0e115563 161const char * const config_domain_type_python = "PYTHON";
fb198a11
JG
162
163const char * const config_buffer_type_per_pid = "PER_PID";
164const char * const config_buffer_type_per_uid = "PER_UID";
165const char * const config_buffer_type_global = "GLOBAL";
166
167const char * const config_overwrite_mode_discard = "DISCARD";
168const char * const config_overwrite_mode_overwrite = "OVERWRITE";
169
170const char * const config_output_type_splice = "SPLICE";
171const char * const config_output_type_mmap = "MMAP";
172
173const char * const config_loglevel_type_all = "ALL";
174const char * const config_loglevel_type_range = "RANGE";
175const char * const config_loglevel_type_single = "SINGLE";
176
177const char * const config_event_type_all = "ALL";
178const char * const config_event_type_tracepoint = "TRACEPOINT";
179const char * const config_event_type_probe = "PROBE";
c1e83fb4 180const char * const config_event_type_userspace_probe = "USERSPACE_PROBE";
fb198a11
JG
181const char * const config_event_type_function = "FUNCTION";
182const char * const config_event_type_function_entry = "FUNCTION_ENTRY";
183const char * const config_event_type_noop = "NOOP";
184const char * const config_event_type_syscall = "SYSCALL";
185const char * const config_event_type_kprobe = "KPROBE";
186const char * const config_event_type_kretprobe = "KRETPROBE";
187
188const char * const config_event_context_pid = "PID";
189const char * const config_event_context_procname = "PROCNAME";
190const char * const config_event_context_prio = "PRIO";
191const char * const config_event_context_nice = "NICE";
192const char * const config_event_context_vpid = "VPID";
193const char * const config_event_context_tid = "TID";
194const char * const config_event_context_vtid = "VTID";
195const char * const config_event_context_ppid = "PPID";
196const char * const config_event_context_vppid = "VPPID";
197const char * const config_event_context_pthread_id = "PTHREAD_ID";
198const char * const config_event_context_hostname = "HOSTNAME";
199const char * const config_event_context_ip = "IP";
e885a367 200const char * const config_event_context_perf_thread_counter = "PERF_THREAD_COUNTER";
ec2ed7da
JG
201LTTNG_HIDDEN const char * const config_event_context_app = "APP";
202LTTNG_HIDDEN const char * const config_event_context_interruptible = "INTERRUPTIBLE";
203LTTNG_HIDDEN const char * const config_event_context_preemptible = "PREEMPTIBLE";
204LTTNG_HIDDEN const char * const config_event_context_need_reschedule = "NEED_RESCHEDULE";
205LTTNG_HIDDEN const char * const config_event_context_migratable = "MIGRATABLE";
16c4c991
FD
206LTTNG_HIDDEN const char * const config_event_context_callstack_user= "CALLSTACK_USER";
207LTTNG_HIDDEN const char * const config_event_context_callstack_kernel = "CALLSTACK_KERNEL";
fb198a11 208
fbd987c9
JG
209/* Deprecated symbols */
210const char * const config_element_perf;
211
d7b645e2
JR
212enum process_event_node_phase {
213 CREATION = 0,
214 ENABLE = 1,
215};
216
dcf266c0
JG
217struct consumer_output {
218 int enabled;
219 char *path;
220 char *control_uri;
221 char *data_uri;
222};
223
1501a7f3
JG
224static int config_entry_handler_filter(struct handler_filter_args *args,
225 const char *section, const char *name, const char *value)
226{
227 int ret = 0;
228 struct config_entry entry = { section, name, value };
229
230 assert(args);
231
232 if (!section || !name || !value) {
233 ret = -EIO;
234 goto end;
235 }
236
237 if (args->section) {
238 if (strcmp(args->section, section)) {
239 goto end;
240 }
241 }
242
243 ret = args->handler(&entry, args->user_data);
244end:
245 return ret;
246}
247
248LTTNG_HIDDEN
249int config_get_section_entries(const char *override_path, const char *section,
250 config_entry_handler_cb handler, void *user_data)
251{
252 int ret = 0;
7ab02a27 253 char *path;
1501a7f3
JG
254 FILE *config_file = NULL;
255 struct handler_filter_args filter = { section, handler, user_data };
256
7ab02a27
DG
257 /* First, try system-wide conf. file. */
258 path = DEFAULT_DAEMON_SYSTEM_CONFIGPATH;
259
260 config_file = fopen(path, "r");
261 if (config_file) {
262 DBG("Loading daemon conf file at %s", path);
263 /*
264 * Return value is not very important here since error or not, we
265 * continue and try the next possible conf. file.
266 */
267 (void) ini_parse_file(config_file,
268 (ini_entry_handler) config_entry_handler_filter,
269 (void *) &filter);
270 fclose(config_file);
271 }
272
273 /* Second is the user local configuration. */
274 path = utils_get_home_dir();
275 if (path) {
276 char fullpath[PATH_MAX];
277
278 ret = snprintf(fullpath, sizeof(fullpath),
279 DEFAULT_DAEMON_HOME_CONFIGPATH, path);
280 if (ret < 0) {
281 PERROR("snprintf user conf. path");
282 goto error;
283 }
284
285 config_file = fopen(fullpath, "r");
286 if (config_file) {
287 DBG("Loading daemon user conf file at %s", path);
288 /*
289 * Return value is not very important here since error or not, we
290 * continue and try the next possible conf. file.
291 */
292 (void) ini_parse_file(config_file,
293 (ini_entry_handler) config_entry_handler_filter,
294 (void *) &filter);
295 fclose(config_file);
296 }
297 }
298
299 /* Final path is the one that the user might have provided. */
1501a7f3
JG
300 if (override_path) {
301 config_file = fopen(override_path, "r");
302 if (config_file) {
7ab02a27
DG
303 DBG("Loading daemon command line conf file at %s", override_path);
304 (void) ini_parse_file(config_file,
305 (ini_entry_handler) config_entry_handler_filter,
306 (void *) &filter);
307 fclose(config_file);
1501a7f3
JG
308 } else {
309 ERR("Failed to open daemon configuration file at %s",
310 override_path);
311 ret = -ENOENT;
7ab02a27 312 goto error;
1501a7f3
JG
313 }
314 }
315
7ab02a27
DG
316 /* Everything went well. */
317 ret = 0;
1501a7f3 318
7ab02a27 319error:
1501a7f3
JG
320 return ret;
321}
322
323LTTNG_HIDDEN
324int config_parse_value(const char *value)
325{
326 int i, ret = 0;
327 char *endptr, *lower_str;
328 size_t len;
329 unsigned long v;
330
331 len = strlen(value);
332 if (!len) {
333 ret = -1;
334 goto end;
335 }
336
337 v = strtoul(value, &endptr, 10);
338 if (endptr != value) {
339 ret = v;
340 goto end;
341 }
342
343 lower_str = zmalloc(len + 1);
344 if (!lower_str) {
345 PERROR("zmalloc");
346 ret = -errno;
347 goto end;
348 }
349
350 for (i = 0; i < len; i++) {
351 lower_str[i] = tolower(value[i]);
352 }
353
354 if (!strcmp(lower_str, config_str_yes) ||
355 !strcmp(lower_str, config_str_true) ||
356 !strcmp(lower_str, config_str_on)) {
357 ret = 1;
358 } else if (!strcmp(lower_str, config_str_no) ||
359 !strcmp(lower_str, config_str_false) ||
360 !strcmp(lower_str, config_str_off)) {
361 ret = 0;
362 } else {
363 ret = -1;
364 }
365
366 free(lower_str);
367end:
368 return ret;
369}
36f2332b
JG
370
371/*
372 * Returns a xmlChar string which must be released using xmlFree().
373 */
374static xmlChar *encode_string(const char *in_str)
375{
376 xmlChar *out_str = NULL;
377 xmlCharEncodingHandlerPtr handler;
378 int out_len, ret, in_len;
379
380 assert(in_str);
381
382 handler = xmlFindCharEncodingHandler(config_xml_encoding);
383 if (!handler) {
384 ERR("xmlFindCharEncodingHandler return NULL!. Configure issue!");
385 goto end;
386 }
387
388 in_len = strlen(in_str);
389 /*
f76d886f
JG
390 * Add 1 byte for the NULL terminted character. The factor 4 here is
391 * used because UTF-8 characters can take up to 4 bytes.
36f2332b 392 */
f76d886f 393 out_len = (in_len * 4) + 1;
36f2332b
JG
394 out_str = xmlMalloc(out_len);
395 if (!out_str) {
396 goto end;
397 }
398
399 ret = handler->input(out_str, &out_len, (const xmlChar *) in_str, &in_len);
400 if (ret < 0) {
401 xmlFree(out_str);
402 out_str = NULL;
403 goto end;
404 }
405
406 /* out_len is now the size of out_str */
407 out_str[out_len] = '\0';
408end:
409 return out_str;
410}
411
412LTTNG_HIDDEN
705bb62f 413struct config_writer *config_writer_create(int fd_output, int indent)
36f2332b
JG
414{
415 int ret;
416 struct config_writer *writer;
417 xmlOutputBufferPtr buffer;
418
419 writer = zmalloc(sizeof(struct config_writer));
420 if (!writer) {
421 PERROR("zmalloc config_writer_create");
422 goto end;
423 }
424
425 buffer = xmlOutputBufferCreateFd(fd_output, NULL);
426 if (!buffer) {
427 goto error_destroy;
428 }
429
430 writer->writer = xmlNewTextWriter(buffer);
431 ret = xmlTextWriterStartDocument(writer->writer, NULL,
432 config_xml_encoding, NULL);
433 if (ret < 0) {
434 goto error_destroy;
435 }
436
437 ret = xmlTextWriterSetIndentString(writer->writer,
438 BAD_CAST config_xml_indent_string);
705bb62f 439 if (ret) {
36f2332b
JG
440 goto error_destroy;
441 }
442
705bb62f
JRJ
443 ret = xmlTextWriterSetIndent(writer->writer, indent);
444 if (ret) {
36f2332b
JG
445 goto error_destroy;
446 }
447
448end:
449 return writer;
450error_destroy:
451 config_writer_destroy(writer);
452 return NULL;
453}
454
455LTTNG_HIDDEN
456int config_writer_destroy(struct config_writer *writer)
457{
458 int ret = 0;
459
460 if (!writer) {
461 ret = -EINVAL;
462 goto end;
463 }
464
465 if (xmlTextWriterEndDocument(writer->writer) < 0) {
466 WARN("Could not close XML document");
467 ret = -EIO;
468 }
469
470 if (writer->writer) {
471 xmlFreeTextWriter(writer->writer);
472 }
473
474 free(writer);
475end:
476 return ret;
477}
478
479LTTNG_HIDDEN
480int config_writer_open_element(struct config_writer *writer,
481 const char *element_name)
482{
483 int ret;
484 xmlChar *encoded_element_name;
485
486 if (!writer || !writer->writer || !element_name || !element_name[0]) {
487 ret = -1;
488 goto end;
489 }
490
491 encoded_element_name = encode_string(element_name);
492 if (!encoded_element_name) {
493 ret = -1;
494 goto end;
495 }
496
497 ret = xmlTextWriterStartElement(writer->writer, encoded_element_name);
498 xmlFree(encoded_element_name);
499end:
28676a1d 500 return ret >= 0 ? 0 : ret;
36f2332b
JG
501}
502
e10b6a1c
JG
503LTTNG_HIDDEN
504int config_writer_write_attribute(struct config_writer *writer,
505 const char *name, const char *value)
506{
507 int ret;
508 xmlChar *encoded_name = NULL;
509 xmlChar *encoded_value = NULL;
510
511 if (!writer || !writer->writer || !name || !name[0]) {
512 ret = -1;
513 goto end;
514 }
515
516 encoded_name = encode_string(name);
517 if (!encoded_name) {
518 ret = -1;
519 goto end;
520 }
521
522 encoded_value = encode_string(value);
523 if (!encoded_value) {
524 ret = -1;
525 goto end;
526 }
527
528 ret = xmlTextWriterWriteAttribute(writer->writer, encoded_name,
529 encoded_value);
530end:
531 xmlFree(encoded_name);
532 xmlFree(encoded_value);
533 return ret >= 0 ? 0 : ret;
534}
535
36f2332b
JG
536LTTNG_HIDDEN
537int config_writer_close_element(struct config_writer *writer)
538{
539 int ret;
540
541 if (!writer || !writer->writer) {
542 ret = -1;
543 goto end;
544 }
545
546 ret = xmlTextWriterEndElement(writer->writer);
547end:
28676a1d 548 return ret >= 0 ? 0 : ret;
36f2332b
JG
549}
550
551LTTNG_HIDDEN
552int config_writer_write_element_unsigned_int(struct config_writer *writer,
553 const char *element_name, uint64_t value)
554{
555 int ret;
556 xmlChar *encoded_element_name;
557
558 if (!writer || !writer->writer || !element_name || !element_name[0]) {
559 ret = -1;
560 goto end;
561 }
562
563 encoded_element_name = encode_string(element_name);
564 if (!encoded_element_name) {
565 ret = -1;
566 goto end;
567 }
568
569 ret = xmlTextWriterWriteFormatElement(writer->writer,
570 encoded_element_name, "%" PRIu64, value);
571 xmlFree(encoded_element_name);
572end:
28676a1d 573 return ret >= 0 ? 0 : ret;
36f2332b
JG
574}
575
576LTTNG_HIDDEN
577int config_writer_write_element_signed_int(struct config_writer *writer,
578 const char *element_name, int64_t value)
579{
580 int ret;
581 xmlChar *encoded_element_name;
582
583 if (!writer || !writer->writer || !element_name || !element_name[0]) {
584 ret = -1;
585 goto end;
586 }
587
588 encoded_element_name = encode_string(element_name);
589 if (!encoded_element_name) {
590 ret = -1;
591 goto end;
592 }
593
594 ret = xmlTextWriterWriteFormatElement(writer->writer,
595 encoded_element_name, "%" PRIi64, value);
596 xmlFree(encoded_element_name);
597end:
28676a1d 598 return ret >= 0 ? 0 : ret;
36f2332b
JG
599}
600
601LTTNG_HIDDEN
602int config_writer_write_element_bool(struct config_writer *writer,
603 const char *element_name, int value)
604{
605 return config_writer_write_element_string(writer, element_name,
606 value ? config_xml_true : config_xml_false);
607}
608
609LTTNG_HIDDEN
610int config_writer_write_element_string(struct config_writer *writer,
611 const char *element_name, const char *value)
612{
613 int ret;
614 xmlChar *encoded_element_name = NULL;
615 xmlChar *encoded_value = NULL;
616
617 if (!writer || !writer->writer || !element_name || !element_name[0] ||
618 !value) {
619 ret = -1;
620 goto end;
621 }
622
623 encoded_element_name = encode_string(element_name);
624 if (!encoded_element_name) {
625 ret = -1;
626 goto end;
627 }
628
629 encoded_value = encode_string(value);
630 if (!encoded_value) {
631 ret = -1;
632 goto end;
633 }
634
635 ret = xmlTextWriterWriteElement(writer->writer, encoded_element_name,
dcf266c0 636 encoded_value);
36f2332b
JG
637end:
638 xmlFree(encoded_element_name);
639 xmlFree(encoded_value);
28676a1d 640 return ret >= 0 ? 0 : ret;
36f2332b 641}
dcf266c0
JG
642
643static
644void xml_error_handler(void *ctx, const char *format, ...)
645{
646 char *errMsg;
647 va_list args;
648 int ret;
649
650 va_start(args, format);
651 ret = vasprintf(&errMsg, format, args);
6c043b48 652 va_end(args);
dcf266c0
JG
653 if (ret == -1) {
654 ERR("String allocation failed in xml error handler");
655 return;
656 }
dcf266c0
JG
657
658 fprintf(stderr, "XML Error: %s", errMsg);
659 free(errMsg);
660}
661
662static
663void fini_session_config_validation_ctx(
664 struct session_config_validation_ctx *ctx)
665{
666 if (ctx->parser_ctx) {
667 xmlSchemaFreeParserCtxt(ctx->parser_ctx);
668 }
669
670 if (ctx->schema) {
671 xmlSchemaFree(ctx->schema);
672 }
673
674 if (ctx->schema_validation_ctx) {
675 xmlSchemaFreeValidCtxt(ctx->schema_validation_ctx);
676 }
677
678 memset(ctx, 0, sizeof(struct session_config_validation_ctx));
679}
680
54e399cb
JG
681static
682char *get_session_config_xsd_path()
683{
684 char *xsd_path;
e8fa9fb0 685 const char *base_path = lttng_secure_getenv(DEFAULT_SESSION_CONFIG_XSD_PATH_ENV);
54e399cb
JG
686 size_t base_path_len;
687 size_t max_path_len;
688
689 if (!base_path) {
690 base_path = DEFAULT_SESSION_CONFIG_XSD_PATH;
691 }
692
693 base_path_len = strlen(base_path);
694 max_path_len = base_path_len +
695 sizeof(DEFAULT_SESSION_CONFIG_XSD_FILENAME) + 1;
696 xsd_path = zmalloc(max_path_len);
697 if (!xsd_path) {
698 goto end;
699 }
700
00a7f6f8 701 strcpy(xsd_path, base_path);
54e399cb
JG
702 if (xsd_path[base_path_len - 1] != '/') {
703 xsd_path[base_path_len++] = '/';
704 }
705
00a7f6f8 706 strcpy(xsd_path + base_path_len, DEFAULT_SESSION_CONFIG_XSD_FILENAME);
54e399cb
JG
707end:
708 return xsd_path;
709}
710
dcf266c0
JG
711static
712int init_session_config_validation_ctx(
713 struct session_config_validation_ctx *ctx)
714{
715 int ret;
54e399cb
JG
716 char *xsd_path = get_session_config_xsd_path();
717
718 if (!xsd_path) {
719 ret = -LTTNG_ERR_NOMEM;
720 goto end;
721 }
dcf266c0 722
54e399cb 723 ctx->parser_ctx = xmlSchemaNewParserCtxt(xsd_path);
dcf266c0
JG
724 if (!ctx->parser_ctx) {
725 ERR("XSD parser context creation failed");
726 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
727 goto end;
728 }
729 xmlSchemaSetParserErrors(ctx->parser_ctx, xml_error_handler,
730 xml_error_handler, NULL);
731
732 ctx->schema = xmlSchemaParse(ctx->parser_ctx);
733 if (!ctx->schema) {
734 ERR("XSD parsing failed");
735 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
736 goto end;
737 }
738
739 ctx->schema_validation_ctx = xmlSchemaNewValidCtxt(ctx->schema);
740 if (!ctx->schema_validation_ctx) {
741 ERR("XSD validation context creation failed");
742 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
743 goto end;
744 }
745
746 xmlSchemaSetValidErrors(ctx->schema_validation_ctx, xml_error_handler,
747 xml_error_handler, NULL);
748 ret = 0;
749
750end:
751 if (ret) {
752 fini_session_config_validation_ctx(ctx);
753 }
754
54e399cb 755 free(xsd_path);
dcf266c0
JG
756 return ret;
757}
758
759static
760int parse_uint(xmlChar *str, uint64_t *val)
761{
762 int ret;
763 char *endptr;
764
765 if (!str || !val) {
766 ret = -1;
767 goto end;
768 }
769
770 *val = strtoull((const char *) str, &endptr, 10);
771 if (!endptr || *endptr) {
772 ret = -1;
773 } else {
774 ret = 0;
775 }
776
777end:
778 return ret;
779}
780
781static
782int parse_int(xmlChar *str, int64_t *val)
783{
784 int ret;
785 char *endptr;
786
787 if (!str || !val) {
788 ret = -1;
789 goto end;
790 }
791
792 *val = strtoll((const char *) str, &endptr, 10);
793 if (!endptr || *endptr) {
794 ret = -1;
795 } else {
796 ret = 0;
797 }
798
799end:
800 return ret;
801}
802
803static
804int parse_bool(xmlChar *str, int *val)
805{
806 int ret = 0;
807
808 if (!str || !val) {
809 ret = -1;
810 goto end;
811 }
812
813 if (!strcmp((const char *) str, config_xml_true)) {
814 *val = 1;
815 } else if (!strcmp((const char *) str, config_xml_false)) {
816 *val = 0;
817 } else {
818 WARN("Invalid boolean value encoutered (%s).",
819 (const char *) str);
820 ret = -1;
821 }
822end:
823 return ret;
824}
825
826static
827int get_domain_type(xmlChar *domain)
828{
829 int ret;
830
831 if (!domain) {
832 goto error;
833 }
834
835 if (!strcmp((char *) domain, config_domain_type_kernel)) {
836 ret = LTTNG_DOMAIN_KERNEL;
837 } else if (!strcmp((char *) domain, config_domain_type_ust)) {
838 ret = LTTNG_DOMAIN_UST;
839 } else if (!strcmp((char *) domain, config_domain_type_jul)) {
840 ret = LTTNG_DOMAIN_JUL;
5cdb6027
DG
841 } else if (!strcmp((char *) domain, config_domain_type_log4j)) {
842 ret = LTTNG_DOMAIN_LOG4J;
0e115563
DG
843 } else if (!strcmp((char *) domain, config_domain_type_python)) {
844 ret = LTTNG_DOMAIN_PYTHON;
dcf266c0
JG
845 } else {
846 goto error;
847 }
848
849 return ret;
850error:
851 return -1;
852}
853
854static
855int get_buffer_type(xmlChar *buffer_type)
856{
857 int ret;
858
859 if (!buffer_type) {
860 goto error;
861 }
862
863 if (!strcmp((char *) buffer_type, config_buffer_type_global)) {
864 ret = LTTNG_BUFFER_GLOBAL;
865 } else if (!strcmp((char *) buffer_type, config_buffer_type_per_uid)) {
866 ret = LTTNG_BUFFER_PER_UID;
867 } else if (!strcmp((char *) buffer_type, config_buffer_type_per_pid)) {
868 ret = LTTNG_BUFFER_PER_PID;
869 } else {
870 goto error;
871 }
872
873 return ret;
874error:
875 return -1;
876}
877
878static
879int get_overwrite_mode(xmlChar *overwrite_mode)
880{
881 int ret;
882
883 if (!overwrite_mode) {
884 goto error;
885 }
886
887 if (!strcmp((char *) overwrite_mode, config_overwrite_mode_overwrite)) {
888 ret = 1;
889 } else if (!strcmp((char *) overwrite_mode,
890 config_overwrite_mode_discard)) {
891 ret = 0;
892 } else {
893 goto error;
894 }
895
896 return ret;
897error:
898 return -1;
899}
900
901static
902int get_output_type(xmlChar *output_type)
903{
904 int ret;
905
906 if (!output_type) {
907 goto error;
908 }
909
910 if (!strcmp((char *) output_type, config_output_type_mmap)) {
911 ret = LTTNG_EVENT_MMAP;
912 } else if (!strcmp((char *) output_type, config_output_type_splice)) {
913 ret = LTTNG_EVENT_SPLICE;
914 } else {
915 goto error;
916 }
917
918 return ret;
919error:
920 return -1;
921}
922
923static
924int get_event_type(xmlChar *event_type)
925{
926 int ret;
927
928 if (!event_type) {
929 goto error;
930 }
931
932 if (!strcmp((char *) event_type, config_event_type_all)) {
933 ret = LTTNG_EVENT_ALL;
934 } else if (!strcmp((char *) event_type, config_event_type_tracepoint)) {
935 ret = LTTNG_EVENT_TRACEPOINT;
936 } else if (!strcmp((char *) event_type, config_event_type_probe)) {
937 ret = LTTNG_EVENT_PROBE;
c1e83fb4
FD
938 } else if (!strcmp((char *) event_type,
939 config_event_type_userspace_probe)) {
940 ret = LTTNG_EVENT_USERSPACE_PROBE;
dcf266c0
JG
941 } else if (!strcmp((char *) event_type, config_event_type_function)) {
942 ret = LTTNG_EVENT_FUNCTION;
943 } else if (!strcmp((char *) event_type,
c1e83fb4 944 config_event_type_function_entry)) {
dcf266c0
JG
945 ret = LTTNG_EVENT_FUNCTION_ENTRY;
946 } else if (!strcmp((char *) event_type, config_event_type_noop)) {
947 ret = LTTNG_EVENT_NOOP;
948 } else if (!strcmp((char *) event_type, config_event_type_syscall)) {
949 ret = LTTNG_EVENT_SYSCALL;
950 } else {
951 goto error;
952 }
953
954 return ret;
955error:
956 return -1;
957}
958
959static
960int get_loglevel_type(xmlChar *loglevel_type)
961{
962 int ret;
963
964 if (!loglevel_type) {
965 goto error;
966 }
967
968 if (!strcmp((char *) loglevel_type, config_loglevel_type_all)) {
969 ret = LTTNG_EVENT_LOGLEVEL_ALL;
970 } else if (!strcmp((char *) loglevel_type,
971 config_loglevel_type_range)) {
972 ret = LTTNG_EVENT_LOGLEVEL_RANGE;
973 } else if (!strcmp((char *) loglevel_type,
974 config_loglevel_type_single)) {
975 ret = LTTNG_EVENT_LOGLEVEL_SINGLE;
976 } else {
977 goto error;
978 }
979
980 return ret;
981error:
982 return -1;
983}
984
985/*
986 * Return the context type or -1 on error.
987 */
988static
989int get_context_type(xmlChar *context_type)
990{
991 int ret;
992
993 if (!context_type) {
994 goto error;
995 }
996
997 if (!strcmp((char *) context_type, config_event_context_pid)) {
998 ret = LTTNG_EVENT_CONTEXT_PID;
999 } else if (!strcmp((char *) context_type,
1000 config_event_context_procname)) {
1001 ret = LTTNG_EVENT_CONTEXT_PROCNAME;
1002 } else if (!strcmp((char *) context_type,
1003 config_event_context_prio)) {
1004 ret = LTTNG_EVENT_CONTEXT_PRIO;
1005 } else if (!strcmp((char *) context_type,
1006 config_event_context_nice)) {
1007 ret = LTTNG_EVENT_CONTEXT_NICE;
1008 } else if (!strcmp((char *) context_type,
1009 config_event_context_vpid)) {
1010 ret = LTTNG_EVENT_CONTEXT_VPID;
1011 } else if (!strcmp((char *) context_type,
1012 config_event_context_tid)) {
1013 ret = LTTNG_EVENT_CONTEXT_TID;
1014 } else if (!strcmp((char *) context_type,
1015 config_event_context_vtid)) {
1016 ret = LTTNG_EVENT_CONTEXT_VTID;
1017 } else if (!strcmp((char *) context_type,
1018 config_event_context_ppid)) {
1019 ret = LTTNG_EVENT_CONTEXT_PPID;
1020 } else if (!strcmp((char *) context_type,
1021 config_event_context_vppid)) {
1022 ret = LTTNG_EVENT_CONTEXT_VPPID;
1023 } else if (!strcmp((char *) context_type,
1024 config_event_context_pthread_id)) {
1025 ret = LTTNG_EVENT_CONTEXT_PTHREAD_ID;
1026 } else if (!strcmp((char *) context_type,
1027 config_event_context_hostname)) {
1028 ret = LTTNG_EVENT_CONTEXT_HOSTNAME;
1029 } else if (!strcmp((char *) context_type,
1030 config_event_context_ip)) {
1031 ret = LTTNG_EVENT_CONTEXT_IP;
1ae5e83e
JD
1032 } else if (!strcmp((char *) context_type,
1033 config_event_context_interruptible)) {
1034 ret = LTTNG_EVENT_CONTEXT_INTERRUPTIBLE;
1035 } else if (!strcmp((char *) context_type,
1036 config_event_context_preemptible)) {
1037 ret = LTTNG_EVENT_CONTEXT_PREEMPTIBLE;
1038 } else if (!strcmp((char *) context_type,
1039 config_event_context_need_reschedule)) {
1040 ret = LTTNG_EVENT_CONTEXT_NEED_RESCHEDULE;
1041 } else if (!strcmp((char *) context_type,
1042 config_event_context_migratable)) {
1043 ret = LTTNG_EVENT_CONTEXT_MIGRATABLE;
16c4c991
FD
1044 } else if (!strcmp((char *) context_type,
1045 config_event_context_callstack_user)) {
1046 ret = LTTNG_EVENT_CONTEXT_CALLSTACK_USER;
1047 } else if (!strcmp((char *) context_type,
1048 config_event_context_callstack_kernel)) {
1049 ret = LTTNG_EVENT_CONTEXT_CALLSTACK_KERNEL;
dcf266c0
JG
1050 } else {
1051 goto error;
1052 }
1053
1054 return ret;
1055error:
1056 return -1;
1057}
1058
1059static
1060int init_domain(xmlNodePtr domain_node, struct lttng_domain *domain)
1061{
1062 int ret;
1063 xmlNodePtr node;
1064
1065 for (node = xmlFirstElementChild(domain_node); node;
1066 node = xmlNextElementSibling(node)) {
1067 if (!strcmp((const char *) node->name, config_element_type)) {
1068 /* domain type */
1069 xmlChar *node_content = xmlNodeGetContent(node);
1070 if (!node_content) {
1071 ret = -LTTNG_ERR_NOMEM;
1072 goto end;
1073 }
1074
1075 ret = get_domain_type(node_content);
1076 free(node_content);
1077 if (ret < 0) {
1078 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1079 goto end;
1080 }
1081
1082 domain->type = ret;
1083 } else if (!strcmp((const char *) node->name,
1084 config_element_buffer_type)) {
1085 /* buffer type */
1086 xmlChar *node_content = xmlNodeGetContent(node);
1087 if (!node_content) {
1088 ret = -LTTNG_ERR_NOMEM;
1089 goto end;
1090 }
1091
1092 ret = get_buffer_type(node_content);
1093 free(node_content);
1094 if (ret < 0) {
1095 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1096 goto end;
1097 }
1098
1099 domain->buf_type = ret;
1100 }
1101 }
1102 ret = 0;
1103end:
1104 return ret;
1105}
1106
1107static
1108int get_net_output_uris(xmlNodePtr net_output_node, char **control_uri,
1109 char **data_uri)
1110{
1111 xmlNodePtr node;
1112
1113 for (node = xmlFirstElementChild(net_output_node); node;
1114 node = xmlNextElementSibling(node)) {
1115 if (!strcmp((const char *) node->name, config_element_control_uri)) {
1116 /* control_uri */
1117 *control_uri = (char *) xmlNodeGetContent(node);
1118 if (!*control_uri) {
1119 break;
1120 }
1121 } else {
1122 /* data_uri */
1123 *data_uri = (char *) xmlNodeGetContent(node);
1124 if (!*data_uri) {
1125 break;
1126 }
1127 }
1128 }
1129
1130 return *control_uri || *data_uri ? 0 : -LTTNG_ERR_LOAD_INVALID_CONFIG;
1131}
1132
1133static
1134int process_consumer_output(xmlNodePtr consumer_output_node,
1135 struct consumer_output *output)
1136{
1137 int ret;
1138 xmlNodePtr node;
1139
1140 assert(output);
1141
1142 for (node = xmlFirstElementChild(consumer_output_node); node;
1143 node = xmlNextElementSibling(node)) {
1144 if (!strcmp((const char *) node->name, config_element_enabled)) {
1145 xmlChar *enabled_str = xmlNodeGetContent(node);
1146
1147 /* enabled */
1148 if (!enabled_str) {
1149 ret = -LTTNG_ERR_NOMEM;
1150 goto end;
1151 }
1152
1153 ret = parse_bool(enabled_str, &output->enabled);
1154 free(enabled_str);
1155 if (ret) {
1156 goto end;
1157 }
1158 } else {
1159 xmlNodePtr output_type_node;
1160
1161 /* destination */
1162 output_type_node = xmlFirstElementChild(node);
1163 if (!output_type_node) {
1164 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1165 goto end;
1166 }
1167
1168 if (!strcmp((const char *) output_type_node->name,
1169 config_element_path)) {
1170 /* path */
1171 output->path = (char *) xmlNodeGetContent(output_type_node);
1172 if (!output->path) {
1173 ret = -LTTNG_ERR_NOMEM;
1174 goto end;
1175 }
1176 } else {
1177 /* net_output */
1178 ret = get_net_output_uris(output_type_node,
1179 &output->control_uri, &output->data_uri);
1180 if (ret) {
1181 goto end;
1182 }
1183 }
1184 }
1185 }
1186 ret = 0;
1187
1188end:
1189 if (ret) {
1190 free(output->path);
1191 free(output->control_uri);
1192 free(output->data_uri);
1193 memset(output, 0, sizeof(struct consumer_output));
1194 }
1195 return ret;
1196}
1197
1198static
95681498
JG
1199int create_session_net_output(const char *name, const char *control_uri,
1200 const char *data_uri)
dcf266c0
JG
1201{
1202 int ret;
1203 struct lttng_handle *handle;
1204 const char *uri = NULL;
1205
1206 assert(name);
dcf266c0 1207
95681498 1208 handle = lttng_create_handle(name, NULL);
dcf266c0
JG
1209 if (!handle) {
1210 ret = -LTTNG_ERR_NOMEM;
1211 goto end;
1212 }
1213
1214 if (!control_uri || !data_uri) {
1215 uri = control_uri ? control_uri : data_uri;
1216 control_uri = uri;
1217 data_uri = uri;
1218 }
1219
1220 ret = lttng_set_consumer_url(handle, control_uri, data_uri);
1221 lttng_destroy_handle(handle);
1222end:
1223 return ret;
1224}
1225
1226static
1b08cbce
JR
1227int create_snapshot_session(const char *session_name, xmlNodePtr output_node,
1228 const struct config_load_session_override_attr *overrides)
dcf266c0
JG
1229{
1230 int ret;
1231 xmlNodePtr node = NULL;
1232 xmlNodePtr snapshot_output_list_node;
1233 xmlNodePtr snapshot_output_node;
1234
1235 assert(session_name);
1236
1237 ret = lttng_create_session_snapshot(session_name, NULL);
1238 if (ret) {
1239 goto end;
1240 }
1241
1242 if (!output_node) {
1243 goto end;
1244 }
1245
1246 snapshot_output_list_node = xmlFirstElementChild(output_node);
1247
1248 /* Parse and create snapshot outputs */
1249
1250 for (snapshot_output_node =
1251 xmlFirstElementChild(snapshot_output_list_node);
1252 snapshot_output_node; snapshot_output_node =
1253 xmlNextElementSibling(snapshot_output_node)) {
1254 char *name = NULL;
1255 uint64_t max_size = UINT64_MAX;
1256 struct consumer_output output = { 0 };
1257 struct lttng_snapshot_output *snapshot_output = NULL;
1b08cbce
JR
1258 const char *control_uri = NULL;
1259 const char *data_uri = NULL;
1260 const char *path = NULL;
dcf266c0
JG
1261
1262 for (node = xmlFirstElementChild(snapshot_output_node); node;
1263 node = xmlNextElementSibling(node)) {
1264 if (!strcmp((const char *) node->name,
1265 config_element_name)) {
1266 /* name */
1267 name = (char *) xmlNodeGetContent(node);
1268 if (!name) {
1269 ret = -LTTNG_ERR_NOMEM;
1270 goto error_snapshot_output;
1271 }
1272 } else if (!strcmp((const char *) node->name,
1273 config_element_max_size)) {
1274 xmlChar *content = xmlNodeGetContent(node);
1275
1276 /* max_size */
1277 if (!content) {
1278 ret = -LTTNG_ERR_NOMEM;
1279 goto error_snapshot_output;
1280 }
1281 ret = parse_uint(content, &max_size);
1282 free(content);
1283 if (ret) {
1284 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1285 goto error_snapshot_output;
1286 }
1287 } else {
1288 /* consumer_output */
1289 ret = process_consumer_output(node, &output);
1290 if (ret) {
1291 goto error_snapshot_output;
1292 }
1293 }
1294 }
1295
21a3f144
JR
1296 control_uri = output.control_uri;
1297 data_uri = output.data_uri;
1298 path = output.path;
1299
1b08cbce
JR
1300 if (overrides) {
1301 if (overrides->path_url) {
1b08cbce 1302 path = overrides->path_url;
21a3f144
JR
1303 /* Control/data_uri are null */
1304 control_uri = NULL;
1305 data_uri = NULL;
1b08cbce
JR
1306 } else {
1307 if (overrides->ctrl_url) {
1b08cbce 1308 control_uri = overrides->ctrl_url;
21a3f144
JR
1309 /* path is null */
1310 path = NULL;
1b08cbce
JR
1311 }
1312 if (overrides->data_url) {
1b08cbce 1313 data_uri = overrides->data_url;
21a3f144
JR
1314 /* path is null */
1315 path = NULL;
1b08cbce
JR
1316 }
1317 }
1b08cbce
JR
1318 }
1319
dcf266c0
JG
1320 snapshot_output = lttng_snapshot_output_create();
1321 if (!snapshot_output) {
1322 ret = -LTTNG_ERR_NOMEM;
1323 goto error_snapshot_output;
1324 }
1325
1326 ret = lttng_snapshot_output_set_name(name, snapshot_output);
1327 if (ret) {
1328 goto error_snapshot_output;
1329 }
1330
1331 ret = lttng_snapshot_output_set_size(max_size, snapshot_output);
1332 if (ret) {
1333 goto error_snapshot_output;
1334 }
1335
1b08cbce
JR
1336 if (path) {
1337 ret = lttng_snapshot_output_set_ctrl_url(path,
dcf266c0
JG
1338 snapshot_output);
1339 if (ret) {
1340 goto error_snapshot_output;
1341 }
1342 } else {
1b08cbce
JR
1343 if (control_uri) {
1344 ret = lttng_snapshot_output_set_ctrl_url(control_uri,
dcf266c0
JG
1345 snapshot_output);
1346 if (ret) {
1347 goto error_snapshot_output;
1348 }
1349 }
1350
1b08cbce
JR
1351 if (data_uri) {
1352 ret = lttng_snapshot_output_set_data_url(data_uri,
dcf266c0
JG
1353 snapshot_output);
1354 if (ret) {
1355 goto error_snapshot_output;
1356 }
1357 }
1358 }
1359
1360 ret = lttng_snapshot_add_output(session_name, snapshot_output);
1361error_snapshot_output:
1362 free(name);
1363 free(output.path);
1364 free(output.control_uri);
1365 free(output.data_uri);
1366 lttng_snapshot_output_destroy(snapshot_output);
1367 if (ret) {
1368 goto end;
1369 }
1370 }
1371end:
1372 return ret;
1373}
1374
1375static
1376int create_session(const char *name,
dcf266c0 1377 xmlNodePtr output_node,
1b08cbce
JR
1378 uint64_t live_timer_interval,
1379 const struct config_load_session_override_attr *overrides)
dcf266c0
JG
1380{
1381 int ret;
1382 struct consumer_output output = { 0 };
1383 xmlNodePtr consumer_output_node;
1b08cbce
JR
1384 const char *control_uri = NULL;
1385 const char *data_uri = NULL;
1386 const char *path = NULL;
dcf266c0
JG
1387
1388 assert(name);
dcf266c0
JG
1389
1390 if (output_node) {
1391 consumer_output_node = xmlFirstElementChild(output_node);
1392 if (!consumer_output_node) {
1393 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1394 goto end;
1395 }
1396
1397 if (strcmp((const char *) consumer_output_node->name,
1398 config_element_consumer_output)) {
1399 WARN("Invalid output type, expected %s node",
1400 config_element_consumer_output);
1401 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1402 goto end;
1403 }
1404
1405 ret = process_consumer_output(consumer_output_node, &output);
1406 if (ret) {
1407 goto end;
1408 }
1409 }
1410
21a3f144
JR
1411 control_uri = output.control_uri;
1412 data_uri = output.data_uri;
1413 path = output.path;
1414
1b08cbce
JR
1415 /* Check for override and apply them */
1416 if (overrides) {
1417 if (overrides->path_url) {
1b08cbce 1418 path = overrides->path_url;
21a3f144
JR
1419 /* control/data_uri are null */;
1420 control_uri = NULL;
1421 data_uri = NULL;
1b08cbce
JR
1422 } else {
1423 if (overrides->ctrl_url) {
1b08cbce 1424 control_uri = overrides->ctrl_url;
21a3f144
JR
1425 /* path is null */
1426 path = NULL;
1b08cbce
JR
1427 }
1428 if (overrides->data_url) {
1b08cbce 1429 data_uri = overrides->data_url;
21a3f144
JR
1430 /* path is null */
1431 path = NULL;
1b08cbce
JR
1432 }
1433 }
1b08cbce
JR
1434 }
1435
21a3f144 1436
1b08cbce 1437 if (live_timer_interval != UINT64_MAX && !control_uri && !data_uri) {
dcf266c0
JG
1438 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1439 goto end;
1440 }
1441
1b08cbce 1442 if (control_uri || data_uri) {
dcf266c0
JG
1443 /* network destination */
1444 if (live_timer_interval && live_timer_interval != UINT64_MAX) {
b664f89a
DG
1445 /*
1446 * URLs are provided for sure since the test above make sure that
1447 * with a live timer the data and control URIs are provided. So,
1448 * NULL is passed here and will be set right after.
1449 */
1450 ret = lttng_create_session_live(name, NULL, live_timer_interval);
dcf266c0
JG
1451 } else {
1452 ret = lttng_create_session(name, NULL);
1453 }
1454 if (ret) {
1455 goto end;
1456 }
1457
1b08cbce 1458 ret = create_session_net_output(name, control_uri, data_uri);
95681498
JG
1459 if (ret) {
1460 goto end;
dcf266c0 1461 }
95681498 1462
dcf266c0
JG
1463 } else {
1464 /* either local output or no output */
1b08cbce 1465 ret = lttng_create_session(name, path);
dcf266c0
JG
1466 if (ret) {
1467 goto end;
1468 }
1469 }
1470end:
1471 free(output.path);
1472 free(output.control_uri);
1473 free(output.data_uri);
1474 return ret;
1475}
c1e83fb4
FD
1476
1477static
1478struct lttng_userspace_probe_location *
1479process_userspace_probe_function_attribute_node(
1480 xmlNodePtr attribute_node)
1481{
c1e83fb4 1482 xmlNodePtr function_attribute_node;
717d2dba 1483 char *function_name = NULL, *binary_path = NULL;
c1e83fb4
FD
1484 struct lttng_userspace_probe_location *location = NULL;
1485 struct lttng_userspace_probe_location_lookup_method *lookup_method = NULL;
1486
1487 /*
1488 * Process userspace probe location function attributes. The order of
1489 * the fields are not guaranteed so we need to iterate over all fields
1490 * and check at the end if everything we need for this location type is
1491 * there.
1492 */
1493 for (function_attribute_node =
1494 xmlFirstElementChild(attribute_node);
1495 function_attribute_node;
1496 function_attribute_node = xmlNextElementSibling(
1497 function_attribute_node)) {
1498 /* Handle function name, binary path and lookup method. */
1499 if (!strcmp((const char *) function_attribute_node->name,
1500 config_element_userspace_probe_function_location_function_name)) {
717d2dba 1501 function_name = (char *) xmlNodeGetContent(function_attribute_node);
c1e83fb4 1502 if (!function_name) {
c1e83fb4
FD
1503 goto error;
1504 }
1505 } else if (!strcmp((const char *) function_attribute_node->name,
1506 config_element_userspace_probe_location_binary_path)) {
717d2dba 1507 binary_path = (char *) xmlNodeGetContent(function_attribute_node);
c1e83fb4 1508 if (!binary_path) {
c1e83fb4
FD
1509 goto error;
1510 }
1511 } else if (!strcmp((const char *) function_attribute_node->name,
1512 config_element_userspace_probe_lookup)) {
717d2dba 1513 char *lookup_method_name;
c1e83fb4 1514
717d2dba
JG
1515 lookup_method_name = (char *) xmlNodeGetContent(
1516 function_attribute_node);
c1e83fb4 1517 if (!lookup_method_name) {
c1e83fb4
FD
1518 goto error;
1519 }
1520
1521 /*
1522 * function_default lookup method defaults to
1523 * function_elf lookup method at the moment.
1524 */
1525 if (!strcmp(lookup_method_name, config_element_userspace_probe_lookup_function_elf)
1526 || !strcmp(lookup_method_name, config_element_userspace_probe_lookup_function_default)) {
1527 lookup_method = lttng_userspace_probe_location_lookup_method_function_elf_create();
1528 if (!lookup_method) {
1529 PERROR("Error creating function default/ELF lookup method");
c1e83fb4
FD
1530 }
1531 } else {
717d2dba
JG
1532 WARN("Unknown function lookup method");
1533 }
1534
1535 free(lookup_method_name);
1536 if (!lookup_method) {
c1e83fb4
FD
1537 goto error;
1538 }
1539 } else {
1540 goto error;
1541 }
1542
1543 /* Check if all the necessary fields were found. */
1544 if (binary_path && function_name && lookup_method) {
717d2dba 1545 /* Ownership of lookup_method is transferred. */
c1e83fb4
FD
1546 location =
1547 lttng_userspace_probe_location_function_create(
1548 binary_path, function_name,
1549 lookup_method);
717d2dba
JG
1550 lookup_method = NULL;
1551 goto error;
c1e83fb4
FD
1552 }
1553 }
1554error:
717d2dba 1555 lttng_userspace_probe_location_lookup_method_destroy(lookup_method);
c1e83fb4
FD
1556 free(binary_path);
1557 free(function_name);
c1e83fb4
FD
1558 return location;
1559}
1560
1561static
1562struct lttng_userspace_probe_location *
1563process_userspace_probe_tracepoint_attribute_node(
1564 xmlNodePtr attribute_node)
1565{
c1e83fb4 1566 xmlNodePtr tracepoint_attribute_node;
c1e83fb4
FD
1567 char *probe_name = NULL, *provider_name = NULL, *binary_path = NULL;
1568 struct lttng_userspace_probe_location *location = NULL;
1569 struct lttng_userspace_probe_location_lookup_method *lookup_method = NULL;
1570
1571 /*
1572 * Process userspace probe location tracepoint attributes. The order of
1573 * the fields are not guaranteed so we need to iterate over all fields
1574 * and check at the end if everything we need for this location type is
1575 * there.
1576 */
1577 for (tracepoint_attribute_node =
1578 xmlFirstElementChild(attribute_node); tracepoint_attribute_node;
1579 tracepoint_attribute_node = xmlNextElementSibling(
1580 tracepoint_attribute_node)) {
1581 if (!strcmp((const char *) tracepoint_attribute_node->name,
1582 config_element_userspace_probe_tracepoint_location_probe_name)) {
717d2dba 1583 probe_name = (char *) xmlNodeGetContent(tracepoint_attribute_node);
c1e83fb4 1584 if (!probe_name) {
c1e83fb4
FD
1585 goto error;
1586 }
1587 } else if (!strcmp((const char *) tracepoint_attribute_node->name,
1588 config_element_userspace_probe_tracepoint_location_provider_name)) {
717d2dba 1589 provider_name = (char *) xmlNodeGetContent(tracepoint_attribute_node);
c1e83fb4 1590 if (!provider_name) {
c1e83fb4
FD
1591 goto error;
1592 }
1593 } else if (!strcmp((const char *) tracepoint_attribute_node->name,
1594 config_element_userspace_probe_location_binary_path)) {
717d2dba 1595 binary_path = (char *) xmlNodeGetContent(tracepoint_attribute_node);
c1e83fb4 1596 if (!binary_path) {
c1e83fb4
FD
1597 goto error;
1598 }
1599 } else if (!strcmp((const char *) tracepoint_attribute_node->name,
1600 config_element_userspace_probe_lookup)) {
717d2dba 1601 char *lookup_method_name;
c1e83fb4 1602
717d2dba
JG
1603 lookup_method_name = (char *) xmlNodeGetContent(
1604 tracepoint_attribute_node);
c1e83fb4 1605 if (!lookup_method_name) {
c1e83fb4
FD
1606 goto error;
1607 }
1608
1609 if (!strcmp(lookup_method_name,
1610 config_element_userspace_probe_lookup_tracepoint_sdt)) {
1611 lookup_method =
1612 lttng_userspace_probe_location_lookup_method_tracepoint_sdt_create();
1613 if (!lookup_method) {
1614 PERROR("Error creating tracepoint SDT lookup method");
c1e83fb4
FD
1615 }
1616 } else {
717d2dba
JG
1617 WARN("Unknown tracepoint lookup method");
1618 }
1619
1620 free(lookup_method_name);
1621 if (!lookup_method) {
c1e83fb4
FD
1622 goto error;
1623 }
1624 } else {
717d2dba 1625 WARN("Unknown tracepoint attribute");
c1e83fb4
FD
1626 goto error;
1627 }
1628
1629 /* Check if all the necessary fields were found. */
1630 if (binary_path && provider_name && probe_name && lookup_method) {
717d2dba 1631 /* Ownership of lookup_method is transferred. */
c1e83fb4
FD
1632 location =
1633 lttng_userspace_probe_location_tracepoint_create(
1634 binary_path, provider_name,
1635 probe_name, lookup_method);
717d2dba 1636 goto error;
c1e83fb4
FD
1637 }
1638 }
1639error:
717d2dba 1640 lttng_userspace_probe_location_lookup_method_destroy(lookup_method);
c1e83fb4 1641 free(binary_path);
c1e83fb4 1642 free(provider_name);
717d2dba 1643 free(probe_name);
c1e83fb4
FD
1644 return location;
1645}
1646
dcf266c0
JG
1647static
1648int process_probe_attribute_node(xmlNodePtr probe_attribute_node,
1649 struct lttng_event_probe_attr *attr)
1650{
1651 int ret;
1652
1653 assert(probe_attribute_node);
1654 assert(attr);
1655
1656 if (!strcmp((const char *) probe_attribute_node->name,
1657 config_element_address)) {
1658 xmlChar *content;
1659 uint64_t addr = 0;
1660
1661 /* addr */
1662 content = xmlNodeGetContent(probe_attribute_node);
1663 if (!content) {
1664 ret = -LTTNG_ERR_NOMEM;
1665 goto end;
1666 }
1667
1668 ret = parse_uint(content, &addr);
1669 free(content);
1670 if (ret) {
1671 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1672 goto end;
1673 }
1674
1675 attr->addr = addr;
1676 } else if (!strcmp((const char *) probe_attribute_node->name,
1677 config_element_offset)) {
1678 xmlChar *content;
1679 uint64_t offset = 0;
1680
1681 /* offset */
1682 content = xmlNodeGetContent(probe_attribute_node);
1683 if (!content) {
1684 ret = -LTTNG_ERR_NOMEM;
1685 goto end;
1686 }
1687
1688 ret = parse_uint(content, &offset);
1689 free(content);
1690 if (ret) {
1691 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1692 goto end;
1693 }
1694
1695 attr->offset = offset;
1696 } else if (!strcmp((const char *) probe_attribute_node->name,
1697 config_element_symbol_name)) {
1698 xmlChar *content;
dcf266c0
JG
1699
1700 /* symbol_name */
1701 content = xmlNodeGetContent(probe_attribute_node);
1702 if (!content) {
1703 ret = -LTTNG_ERR_NOMEM;
1704 goto end;
1705 }
1706
d2e67842
JG
1707 ret = lttng_strncpy(attr->symbol_name,
1708 (const char *) content,
1709 LTTNG_SYMBOL_NAME_LEN);
1710 if (ret == -1) {
1711 ERR("symbol name \"%s\"'s length (%zu) exceeds the maximal permitted length (%d) in session configuration",
1712 (const char *) content,
1713 strlen((const char *) content),
1714 LTTNG_SYMBOL_NAME_LEN);
dcf266c0
JG
1715 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1716 free(content);
1717 goto end;
1718 }
dcf266c0
JG
1719 free(content);
1720 }
1721 ret = 0;
1722end:
1723 return ret;
1724}
1725
1726static
1727int process_event_node(xmlNodePtr event_node, struct lttng_handle *handle,
d7b645e2 1728 const char *channel_name, const enum process_event_node_phase phase)
dcf266c0 1729{
d7b645e2 1730 int ret = 0, i;
dcf266c0 1731 xmlNodePtr node;
91744e14 1732 struct lttng_event *event;
dcf266c0
JG
1733 char **exclusions = NULL;
1734 unsigned long exclusion_count = 0;
1735 char *filter_expression = NULL;
1736
1737 assert(event_node);
1738 assert(handle);
1739 assert(channel_name);
1740
91744e14
FD
1741 event = lttng_event_create();
1742 if (!event) {
1743 ret = -LTTNG_ERR_NOMEM;
1744 goto end;
1745 }
dcf266c0 1746
f40eba3d
JG
1747 /* Initialize default log level which varies by domain */
1748 switch (handle->domain.type)
1749 {
1750 case LTTNG_DOMAIN_JUL:
91744e14 1751 event->loglevel = LTTNG_LOGLEVEL_JUL_ALL;
f40eba3d
JG
1752 break;
1753 case LTTNG_DOMAIN_LOG4J:
91744e14 1754 event->loglevel = LTTNG_LOGLEVEL_LOG4J_ALL;
f40eba3d
JG
1755 break;
1756 case LTTNG_DOMAIN_PYTHON:
91744e14 1757 event->loglevel = LTTNG_LOGLEVEL_PYTHON_DEBUG;
f40eba3d
JG
1758 break;
1759 case LTTNG_DOMAIN_UST:
1760 case LTTNG_DOMAIN_KERNEL:
91744e14 1761 event->loglevel = LTTNG_LOGLEVEL_DEBUG;
f40eba3d
JG
1762 break;
1763 default:
1764 assert(0);
1765 }
1766
dcf266c0
JG
1767 for (node = xmlFirstElementChild(event_node); node;
1768 node = xmlNextElementSibling(node)) {
1769 if (!strcmp((const char *) node->name, config_element_name)) {
1770 xmlChar *content;
dcf266c0
JG
1771
1772 /* name */
1773 content = xmlNodeGetContent(node);
1774 if (!content) {
1775 ret = -LTTNG_ERR_NOMEM;
1776 goto end;
1777 }
1778
91744e14 1779 ret = lttng_strncpy(event->name,
d2e67842
JG
1780 (const char *) content,
1781 LTTNG_SYMBOL_NAME_LEN);
1782 if (ret == -1) {
1783 WARN("Event \"%s\"'s name length (%zu) exceeds the maximal permitted length (%d) in session configuration",
1784 (const char *) content,
1785 strlen((const char *) content),
1786 LTTNG_SYMBOL_NAME_LEN);
dcf266c0
JG
1787 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1788 free(content);
1789 goto end;
1790 }
dcf266c0
JG
1791 free(content);
1792 } else if (!strcmp((const char *) node->name,
1793 config_element_enabled)) {
1794 xmlChar *content = xmlNodeGetContent(node);
1795
1796 /* enabled */
1797 if (!content) {
1798 ret = -LTTNG_ERR_NOMEM;
1799 goto end;
1800 }
1801
91744e14 1802 ret = parse_bool(content, &event->enabled);
dcf266c0
JG
1803 free(content);
1804 if (ret) {
1805 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1806 goto end;
1807 }
1808 } else if (!strcmp((const char *) node->name,
1809 config_element_type)) {
1810 xmlChar *content = xmlNodeGetContent(node);
1811
1812 /* type */
1813 if (!content) {
1814 ret = -LTTNG_ERR_NOMEM;
1815 goto end;
1816 }
1817
1818 ret = get_event_type(content);
1819 free(content);
1820 if (ret < 0) {
1821 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1822 goto end;
1823 }
1824
91744e14 1825 event->type = ret;
dcf266c0
JG
1826 } else if (!strcmp((const char *) node->name,
1827 config_element_loglevel_type)) {
1828 xmlChar *content = xmlNodeGetContent(node);
1829
1830 /* loglevel_type */
1831 if (!content) {
1832 ret = -LTTNG_ERR_NOMEM;
1833 goto end;
1834 }
1835
1836 ret = get_loglevel_type(content);
1837 free(content);
1838 if (ret < 0) {
1839 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1840 goto end;
1841 }
1842
91744e14 1843 event->loglevel_type = ret;
dcf266c0
JG
1844 } else if (!strcmp((const char *) node->name,
1845 config_element_loglevel)) {
1846 xmlChar *content;
1847 int64_t loglevel = 0;
1848
1849 /* loglevel */
1850 content = xmlNodeGetContent(node);
1851 if (!content) {
1852 ret = -LTTNG_ERR_NOMEM;
1853 goto end;
1854 }
1855
1856 ret = parse_int(content, &loglevel);
1857 free(content);
1858 if (ret) {
1859 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1860 goto end;
1861 }
1862
1863 if (loglevel > INT_MAX || loglevel < INT_MIN) {
1864 WARN("loglevel out of range.");
1865 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1866 goto end;
1867 }
1868
91744e14 1869 event->loglevel = loglevel;
dcf266c0
JG
1870 } else if (!strcmp((const char *) node->name,
1871 config_element_filter)) {
1872 xmlChar *content =
1873 xmlNodeGetContent(node);
1874
1875 /* filter */
1876 if (!content) {
1877 ret = -LTTNG_ERR_NOMEM;
1878 goto end;
1879 }
1880
02d8ac3d 1881 free(filter_expression);
dcf266c0
JG
1882 filter_expression = strdup((char *) content);
1883 free(content);
1884 if (!filter_expression) {
1885 ret = -LTTNG_ERR_NOMEM;
1886 goto end;
1887 }
1888 } else if (!strcmp((const char *) node->name,
1889 config_element_exclusions)) {
1890 xmlNodePtr exclusion_node;
1891 int exclusion_index = 0;
1892
1893 /* exclusions */
1894 if (exclusions) {
1895 /*
1896 * Exclusions has already been initialized,
1897 * invalid file.
1898 */
1899 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1900 goto end;
1901 }
1902
1903 exclusion_count = xmlChildElementCount(node);
1904 if (!exclusion_count) {
1905 continue;
1906 }
1907
1908 exclusions = zmalloc(exclusion_count * sizeof(char *));
1909 if (!exclusions) {
1910 exclusion_count = 0;
1911 ret = -LTTNG_ERR_NOMEM;
1912 goto end;
1913 }
1914
1915 for (exclusion_node = xmlFirstElementChild(node); exclusion_node;
1916 exclusion_node = xmlNextElementSibling(exclusion_node)) {
1917 xmlChar *content =
1918 xmlNodeGetContent(exclusion_node);
1919
1920 if (!content) {
1921 ret = -LTTNG_ERR_NOMEM;
1922 goto end;
1923 }
1924
1925 exclusions[exclusion_index] = strdup((const char *) content);
1926 free(content);
1927 if (!exclusions[exclusion_index]) {
1928 ret = -LTTNG_ERR_NOMEM;
1929 goto end;
1930 }
1931 exclusion_index++;
1932 }
1933
91744e14 1934 event->exclusion = 1;
dcf266c0
JG
1935 } else if (!strcmp((const char *) node->name,
1936 config_element_attributes)) {
1937 xmlNodePtr attribute_node = xmlFirstElementChild(node);
1938
1939 /* attributes */
1940 if (!attribute_node) {
1941 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1942 goto end;
1943 }
1944
c1e83fb4 1945 if (!strcmp((const char *) attribute_node->name,
dcf266c0
JG
1946 config_element_probe_attributes)) {
1947 xmlNodePtr probe_attribute_node;
1948
1949 /* probe_attributes */
1950 for (probe_attribute_node =
1951 xmlFirstElementChild(attribute_node); probe_attribute_node;
1952 probe_attribute_node = xmlNextElementSibling(
1953 probe_attribute_node)) {
1954
1955 ret = process_probe_attribute_node(probe_attribute_node,
91744e14 1956 &event->attr.probe);
dcf266c0
JG
1957 if (ret) {
1958 goto end;
1959 }
1960 }
c1e83fb4
FD
1961 } else if (!strcmp((const char *) attribute_node->name,
1962 config_element_function_attributes)) {
dcf266c0
JG
1963 size_t sym_len;
1964 xmlChar *content;
1965 xmlNodePtr symbol_node = xmlFirstElementChild(attribute_node);
1966
1967 /* function_attributes */
1968 content = xmlNodeGetContent(symbol_node);
1969 if (!content) {
1970 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1971 goto end;
1972 }
1973
1974 sym_len = strlen((char *) content);
1975 if (sym_len >= LTTNG_SYMBOL_NAME_LEN) {
1976 WARN("Function name too long.");
1977 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1978 free(content);
1979 goto end;
1980 }
1981
d2e67842 1982 ret = lttng_strncpy(
91744e14 1983 event->attr.ftrace.symbol_name,
d2e67842
JG
1984 (char *) content, sym_len);
1985 if (ret == -1) {
1986 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1987 free(content);
1988 goto end;
1989 }
dcf266c0 1990 free(content);
c1e83fb4
FD
1991 } else if (!strcmp((const char *) attribute_node->name,
1992 config_element_userspace_probe_tracepoint_attributes)) {
1993 struct lttng_userspace_probe_location *location;
1994
1995 location = process_userspace_probe_tracepoint_attribute_node(attribute_node);
1996 if (!location) {
1997 WARN("Error processing userspace probe tracepoint attribute");
1998 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
1999 goto end;
2000 }
2001 ret = lttng_event_set_userspace_probe_location(
2002 event, location);
2003 if (ret) {
2004 WARN("Error setting userspace probe location field");
2005 lttng_userspace_probe_location_destroy(
2006 location);
2007 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2008 goto end;
2009 }
2010 } else if (!strcmp((const char *) attribute_node->name,
2011 config_element_userspace_probe_function_attributes)) {
2012 struct lttng_userspace_probe_location *location;
2013
2014 location =
2015 process_userspace_probe_function_attribute_node(
2016 attribute_node);
2017 if (!location) {
2018 WARN("Error processing userspace probe function attribute");
2019 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2020 goto end;
2021 }
2022
2023 ret = lttng_event_set_userspace_probe_location(
2024 event, location);
2025 if (ret) {
2026 WARN("Error setting userspace probe location field");
2027 lttng_userspace_probe_location_destroy(
2028 location);
2029 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2030 goto end;
2031 }
2032 } else {
2033 /* Unknown event attribute. */
2034 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2035 goto end;
dcf266c0
JG
2036 }
2037 }
2038 }
2039
91744e14
FD
2040 if ((event->enabled && phase == ENABLE) || phase == CREATION) {
2041 ret = lttng_enable_event_with_exclusions(handle, event, channel_name,
d7b645e2
JR
2042 filter_expression, exclusion_count, exclusions);
2043 if (ret < 0) {
91744e14 2044 WARN("Enabling event (name:%s) on load failed.", event->name);
d7b645e2
JR
2045 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2046 goto end;
2047 }
065321e9 2048 }
d2e67842 2049 ret = 0;
dcf266c0
JG
2050end:
2051 for (i = 0; i < exclusion_count; i++) {
2052 free(exclusions[i]);
2053 }
2054
b33f872b 2055 lttng_event_destroy(event);
dcf266c0
JG
2056 free(exclusions);
2057 free(filter_expression);
2058 return ret;
2059}
2060
2061static
2062int process_events_node(xmlNodePtr events_node, struct lttng_handle *handle,
2063 const char *channel_name)
2064{
2065 int ret = 0;
d7b645e2 2066 struct lttng_event event;
dcf266c0
JG
2067 xmlNodePtr node;
2068
2069 assert(events_node);
2070 assert(handle);
2071 assert(channel_name);
2072
2073 for (node = xmlFirstElementChild(events_node); node;
2074 node = xmlNextElementSibling(node)) {
d7b645e2 2075 ret = process_event_node(node, handle, channel_name, CREATION);
dcf266c0
JG
2076 if (ret) {
2077 goto end;
2078 }
2079 }
d7b645e2
JR
2080
2081 /*
2082 * Disable all events to enable only the necessary events.
2083 * Limitations regarding lttng_disable_events and tuple descriptor
2084 * force this approach.
2085 */
2086 memset(&event, 0, sizeof(event));
2087 event.loglevel = -1;
2088 event.type = LTTNG_EVENT_ALL;
2089 ret = lttng_disable_event_ext(handle, &event, channel_name, NULL);
2090 if (ret) {
2091 goto end;
2092 }
2093
2094 for (node = xmlFirstElementChild(events_node); node;
2095 node = xmlNextElementSibling(node)) {
2096 ret = process_event_node(node, handle, channel_name, ENABLE);
2097 if (ret) {
2098 goto end;
2099 }
2100 }
2101
dcf266c0
JG
2102end:
2103 return ret;
2104}
2105
2106static
2107int process_channel_attr_node(xmlNodePtr attr_node,
2108 struct lttng_channel *channel, xmlNodePtr *contexts_node,
2109 xmlNodePtr *events_node)
2110{
2111 int ret;
2112
2113 assert(attr_node);
2114 assert(channel);
2115 assert(contexts_node);
2116 assert(events_node);
2117
2118 if (!strcmp((const char *) attr_node->name, config_element_name)) {
2119 xmlChar *content;
dcf266c0
JG
2120
2121 /* name */
2122 content = xmlNodeGetContent(attr_node);
2123 if (!content) {
2124 ret = -LTTNG_ERR_NOMEM;
2125 goto end;
2126 }
2127
d2e67842
JG
2128 ret = lttng_strncpy(channel->name,
2129 (const char *) content,
2130 LTTNG_SYMBOL_NAME_LEN);
2131 if (ret == -1) {
2132 WARN("Channel \"%s\"'s name length (%zu) exceeds the maximal permitted length (%d) in session configuration",
2133 (const char *) content,
2134 strlen((const char *) content),
2135 LTTNG_SYMBOL_NAME_LEN);
dcf266c0
JG
2136 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2137 free(content);
2138 goto end;
2139 }
dcf266c0
JG
2140 free(content);
2141 } else if (!strcmp((const char *) attr_node->name,
2142 config_element_enabled)) {
2143 xmlChar *content;
2144 int enabled;
2145
2146 /* enabled */
2147 content = xmlNodeGetContent(attr_node);
2148 if (!content) {
2149 ret = -LTTNG_ERR_NOMEM;
2150 goto end;
2151 }
2152
2153 ret = parse_bool(content, &enabled);
2154 free(content);
2155 if (ret) {
2156 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2157 goto end;
2158 }
2159
2160 channel->enabled = enabled;
2161 } else if (!strcmp((const char *) attr_node->name,
2162 config_element_overwrite_mode)) {
2163 xmlChar *content;
2164
2165 /* overwrite_mode */
2166 content = xmlNodeGetContent(attr_node);
2167 if (!content) {
2168 ret = -LTTNG_ERR_NOMEM;
2169 goto end;
2170 }
2171
2172 ret = get_overwrite_mode(content);
2173 free(content);
2174 if (ret < 0) {
2175 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2176 goto end;
2177 }
2178
2179 channel->attr.overwrite = ret;
2180 } else if (!strcmp((const char *) attr_node->name,
2181 config_element_subbuf_size)) {
2182 xmlChar *content;
2183
2184 /* subbuffer_size */
2185 content = xmlNodeGetContent(attr_node);
2186 if (!content) {
2187 ret = -LTTNG_ERR_NOMEM;
2188 goto end;
2189 }
2190
2191 ret = parse_uint(content, &channel->attr.subbuf_size);
2192 free(content);
2193 if (ret) {
2194 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2195 goto end;
2196 }
2197 } else if (!strcmp((const char *) attr_node->name,
2198 config_element_num_subbuf)) {
2199 xmlChar *content;
2200
2201 /* subbuffer_count */
2202 content = xmlNodeGetContent(attr_node);
2203 if (!content) {
2204 ret = -LTTNG_ERR_NOMEM;
2205 goto end;
2206 }
2207
2208 ret = parse_uint(content, &channel->attr.num_subbuf);
2209 free(content);
2210 if (ret) {
2211 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2212 goto end;
2213 }
2214 } else if (!strcmp((const char *) attr_node->name,
2215 config_element_switch_timer_interval)) {
2216 xmlChar *content;
2217 uint64_t switch_timer_interval = 0;
2218
2219 /* switch_timer_interval */
2220 content = xmlNodeGetContent(attr_node);
2221 if (!content) {
2222 ret = -LTTNG_ERR_NOMEM;
2223 goto end;
2224 }
2225
2226 ret = parse_uint(content, &switch_timer_interval);
2227 free(content);
2228 if (ret) {
2229 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2230 goto end;
2231 }
2232
2233 if (switch_timer_interval > UINT_MAX) {
2234 WARN("switch_timer_interval out of range.");
2235 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2236 goto end;
2237 }
2238
2239 channel->attr.switch_timer_interval =
2240 switch_timer_interval;
2241 } else if (!strcmp((const char *) attr_node->name,
2242 config_element_read_timer_interval)) {
2243 xmlChar *content;
2244 uint64_t read_timer_interval = 0;
2245
2246 /* read_timer_interval */
2247 content = xmlNodeGetContent(attr_node);
2248 if (!content) {
2249 ret = -LTTNG_ERR_NOMEM;
2250 goto end;
2251 }
2252
2253 ret = parse_uint(content, &read_timer_interval);
2254 free(content);
2255 if (ret) {
2256 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2257 goto end;
2258 }
2259
2260 if (read_timer_interval > UINT_MAX) {
2261 WARN("read_timer_interval out of range.");
2262 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2263 goto end;
2264 }
2265
2266 channel->attr.read_timer_interval =
2267 read_timer_interval;
2268 } else if (!strcmp((const char *) attr_node->name,
2269 config_element_output_type)) {
2270 xmlChar *content;
2271
2272 /* output_type */
2273 content = xmlNodeGetContent(attr_node);
2274 if (!content) {
2275 ret = -LTTNG_ERR_NOMEM;
2276 goto end;
2277 }
2278
2279 ret = get_output_type(content);
2280 free(content);
2281 if (ret < 0) {
2282 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2283 goto end;
2284 }
2285
2286 channel->attr.output = ret;
2287 } else if (!strcmp((const char *) attr_node->name,
2288 config_element_tracefile_size)) {
2289 xmlChar *content;
2290
2291 /* tracefile_size */
2292 content = xmlNodeGetContent(attr_node);
2293 if (!content) {
2294 ret = -LTTNG_ERR_NOMEM;
2295 goto end;
2296 }
2297
2298 ret = parse_uint(content, &channel->attr.tracefile_size);
2299 free(content);
2300 if (ret) {
2301 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2302 goto end;
2303 }
2304 } else if (!strcmp((const char *) attr_node->name,
2305 config_element_tracefile_count)) {
2306 xmlChar *content;
2307
2308 /* tracefile_count */
2309 content = xmlNodeGetContent(attr_node);
2310 if (!content) {
2311 ret = -LTTNG_ERR_NOMEM;
2312 goto end;
2313 }
2314
2315 ret = parse_uint(content, &channel->attr.tracefile_count);
2316 free(content);
2317 if (ret) {
2318 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2319 goto end;
2320 }
2321 } else if (!strcmp((const char *) attr_node->name,
2322 config_element_live_timer_interval)) {
2323 xmlChar *content;
2324 uint64_t live_timer_interval = 0;
2325
2326 /* live_timer_interval */
2327 content = xmlNodeGetContent(attr_node);
2328 if (!content) {
2329 ret = -LTTNG_ERR_NOMEM;
2330 goto end;
2331 }
2332
2333 ret = parse_uint(content, &live_timer_interval);
2334 free(content);
2335 if (ret) {
2336 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2337 goto end;
2338 }
2339
2340 if (live_timer_interval > UINT_MAX) {
2341 WARN("live_timer_interval out of range.");
2342 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2343 goto end;
2344 }
2345
2346 channel->attr.live_timer_interval =
2347 live_timer_interval;
4fc2b126
JR
2348 } else if (!strcmp((const char *) attr_node->name,
2349 config_element_monitor_timer_interval)) {
2350 xmlChar *content;
2351 uint64_t monitor_timer_interval = 0;
2352
2353 /* monitor_timer_interval */
2354 content = xmlNodeGetContent(attr_node);
2355 if (!content) {
2356 ret = -LTTNG_ERR_NOMEM;
2357 goto end;
2358 }
2359
2360 ret = parse_uint(content, &monitor_timer_interval);
2361 free(content);
2362 if (ret) {
2363 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2364 goto end;
2365 }
2366
2367 ret = lttng_channel_set_monitor_timer_interval(channel,
2368 monitor_timer_interval);
2369 if (ret) {
2370 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2371 goto end;
2372 }
275472aa
JR
2373 } else if (!strcmp((const char *) attr_node->name,
2374 config_element_blocking_timeout)) {
2375 xmlChar *content;
2376 int64_t blocking_timeout = 0;
2377
2378 /* blocking_timeout */
2379 content = xmlNodeGetContent(attr_node);
2380 if (!content) {
2381 ret = -LTTNG_ERR_NOMEM;
2382 goto end;
2383 }
2384
2385 ret = parse_int(content, &blocking_timeout);
2386 free(content);
2387 if (ret) {
2388 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2389 goto end;
2390 }
2391
2392 ret = lttng_channel_set_blocking_timeout(channel,
2393 blocking_timeout);
2394 if (ret) {
2395 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2396 goto end;
2397 }
dcf266c0
JG
2398 } else if (!strcmp((const char *) attr_node->name,
2399 config_element_events)) {
2400 /* events */
2401 *events_node = attr_node;
2402 } else {
2403 /* contexts */
2404 *contexts_node = attr_node;
2405 }
2406 ret = 0;
2407end:
2408 return ret;
2409}
2410
2411static
2412int process_context_node(xmlNodePtr context_node,
2413 struct lttng_handle *handle, const char *channel_name)
2414{
2415 int ret;
2416 struct lttng_event_context context;
2417 xmlNodePtr context_child_node = xmlFirstElementChild(context_node);
2418
2419 assert(handle);
2420 assert(channel_name);
2421
2422 if (!context_child_node) {
2423 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2424 goto end;
2425 }
2426
2427 memset(&context, 0, sizeof(context));
2428
2429 if (!strcmp((const char *) context_child_node->name,
2430 config_element_type)) {
2431 /* type */
2432 xmlChar *content = xmlNodeGetContent(context_child_node);
045fc617 2433
dcf266c0
JG
2434 if (!content) {
2435 ret = -LTTNG_ERR_NOMEM;
2436 goto end;
2437 }
2438
2439 ret = get_context_type(content);
2440 free(content);
2441 if (ret < 0) {
2442 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2443 goto end;
2444 }
2445
2446 context.ctx = ret;
045fc617
JG
2447 } else if (!strcmp((const char *) context_child_node->name,
2448 config_element_context_perf)) {
2449 /* perf */
dcf266c0
JG
2450 xmlNodePtr perf_attr_node;
2451
14ce5bd8
JG
2452 context.ctx = handle->domain.type == LTTNG_DOMAIN_KERNEL ?
2453 LTTNG_EVENT_CONTEXT_PERF_CPU_COUNTER :
2454 LTTNG_EVENT_CONTEXT_PERF_THREAD_COUNTER;
dcf266c0
JG
2455 for (perf_attr_node = xmlFirstElementChild(context_child_node);
2456 perf_attr_node; perf_attr_node =
2457 xmlNextElementSibling(perf_attr_node)) {
2458 if (!strcmp((const char *) perf_attr_node->name,
2459 config_element_type)) {
2460 xmlChar *content;
2461 uint64_t type = 0;
2462
2463 /* type */
2464 content = xmlNodeGetContent(perf_attr_node);
2465 if (!content) {
2466 ret = -LTTNG_ERR_NOMEM;
2467 goto end;
2468 }
2469
2470 ret = parse_uint(content, &type);
2471 free(content);
2472 if (ret) {
2473 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2474 goto end;
2475 }
2476
2477 if (type > UINT32_MAX) {
2478 WARN("perf context type out of range.");
2479 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2480 goto end;
2481 }
2482
2483 context.u.perf_counter.type = type;
2484 } else if (!strcmp((const char *) perf_attr_node->name,
2485 config_element_config)) {
2486 xmlChar *content;
2487 uint64_t config = 0;
2488
2489 /* config */
2490 content = xmlNodeGetContent(perf_attr_node);
2491 if (!content) {
2492 ret = -LTTNG_ERR_NOMEM;
2493 goto end;
2494 }
2495
2496 ret = parse_uint(content, &config);
2497 free(content);
2498 if (ret) {
2499 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2500 goto end;
2501 }
2502
2503 context.u.perf_counter.config = config;
2504 } else if (!strcmp((const char *) perf_attr_node->name,
2505 config_element_name)) {
2506 xmlChar *content;
dcf266c0
JG
2507
2508 /* name */
2509 content = xmlNodeGetContent(perf_attr_node);
2510 if (!content) {
2511 ret = -LTTNG_ERR_NOMEM;
2512 goto end;
2513 }
2514
d2e67842
JG
2515 ret = lttng_strncpy(context.u.perf_counter.name,
2516 (const char *) content,
2517 LTTNG_SYMBOL_NAME_LEN);
2518 if (ret == -1) {
2519 WARN("Perf counter \"%s\"'s name length (%zu) exceeds the maximal permitted length (%d) in session configuration",
2520 (const char *) content,
2521 strlen((const char *) content),
2522 LTTNG_SYMBOL_NAME_LEN);
dcf266c0
JG
2523 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2524 free(content);
2525 goto end;
2526 }
dcf266c0
JG
2527 free(content);
2528 }
2529 }
045fc617
JG
2530 } else if (!strcmp((const char *) context_child_node->name,
2531 config_element_context_app)) {
2532 /* application context */
2533 xmlNodePtr app_ctx_node;
2534
2535 context.ctx = LTTNG_EVENT_CONTEXT_APP_CONTEXT;
2536 for (app_ctx_node = xmlFirstElementChild(context_child_node);
2537 app_ctx_node; app_ctx_node =
2538 xmlNextElementSibling(app_ctx_node)) {
2539 xmlChar *content;
2540 char **target = strcmp(
2541 (const char *) app_ctx_node->name,
2542 config_element_context_app_provider_name) == 0 ?
2543 &context.u.app_ctx.provider_name :
2544 &context.u.app_ctx.ctx_name;
2545
2546 content = xmlNodeGetContent(app_ctx_node);
2547 if (!content) {
2548 ret = -LTTNG_ERR_NOMEM;
2549 goto end;
2550 }
2551
2552 *target = (char *) content;
2553 }
2554 } else {
2555 /* Unrecognized context type */
2556 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2557 goto end;
dcf266c0
JG
2558 }
2559
2560 ret = lttng_add_context(handle, &context, NULL, channel_name);
045fc617
JG
2561 if (context.ctx == LTTNG_EVENT_CONTEXT_APP_CONTEXT) {
2562 free(context.u.app_ctx.provider_name);
2563 free(context.u.app_ctx.ctx_name);
2564 }
dcf266c0
JG
2565end:
2566 return ret;
2567}
2568
2569static
2570int process_contexts_node(xmlNodePtr contexts_node,
2571 struct lttng_handle *handle, const char *channel_name)
2572{
2573 int ret = 0;
2574 xmlNodePtr context_node;
2575
2576 for (context_node = xmlFirstElementChild(contexts_node); context_node;
2577 context_node = xmlNextElementSibling(context_node)) {
2578 ret = process_context_node(context_node, handle, channel_name);
2579 if (ret) {
2580 goto end;
2581 }
2582 }
2583end:
2584 return ret;
2585}
2586
847a5916
JR
2587static
2588int process_pid_tracker_node(xmlNodePtr pid_tracker_node,
2589 struct lttng_handle *handle)
2590{
dd49e13f 2591 int ret = 0, child;
847a5916
JR
2592 xmlNodePtr targets_node = NULL;
2593 xmlNodePtr node;
2594
2595 assert(handle);
2596 assert(pid_tracker_node);
2597 /* get the targets node */
2598 for (node = xmlFirstElementChild(pid_tracker_node); node;
2599 node = xmlNextElementSibling(node)) {
2600 if (!strcmp((const char *) node->name,
2601 config_element_targets)) {
2602 targets_node = node;
2603 break;
2604 }
2605 }
2606
2607 if (!targets_node) {
2608 ret = LTTNG_ERR_INVALID;
2609 goto end;
2610 }
2611
2612 /* Go through all pid_target node */
2613 child = xmlChildElementCount(targets_node);
2614 if (child == 0) {
2615 /* The session is explicitly set to target nothing. */
2616 ret = lttng_untrack_pid(handle, -1);
2617 if (ret) {
2618 goto end;
2619 }
2620 }
2621 for (node = xmlFirstElementChild(targets_node); node;
2622 node = xmlNextElementSibling(node)) {
2623 xmlNodePtr pid_target_node = node;
2624
2625 /* get pid node and track it */
2626 for (node = xmlFirstElementChild(pid_target_node); node;
2627 node = xmlNextElementSibling(node)) {
2628 if (!strcmp((const char *) node->name,
2629 config_element_pid)) {
2630 int64_t pid;
2631 xmlChar *content = NULL;
2632
2633 content = xmlNodeGetContent(node);
2634 if (!content) {
2635 ret = LTTNG_ERR_LOAD_INVALID_CONFIG;
2636 goto end;
2637 }
2638
2639 ret = parse_int(content, &pid);
2640 free(content);
2641 if (ret) {
2642 ret = LTTNG_ERR_LOAD_INVALID_CONFIG;
2643 goto end;
2644 }
2645
2646 ret = lttng_track_pid(handle, (int) pid);
2647 if (ret) {
2648 goto end;
2649 }
2650 }
2651 }
2652 node = pid_target_node;
2653 }
2654
2655end:
2656 return ret;
2657}
2658
dcf266c0
JG
2659static
2660int process_domain_node(xmlNodePtr domain_node, const char *session_name)
2661{
2662 int ret;
2663 struct lttng_domain domain = { 0 };
2664 struct lttng_handle *handle = NULL;
4fc2b126 2665 struct lttng_channel *channel = NULL;
dcf266c0 2666 xmlNodePtr channels_node = NULL;
847a5916
JR
2667 xmlNodePtr trackers_node = NULL;
2668 xmlNodePtr pid_tracker_node = NULL;
dcf266c0
JG
2669 xmlNodePtr node;
2670
2671 assert(session_name);
2672
2673 ret = init_domain(domain_node, &domain);
2674 if (ret) {
2675 goto end;
2676 }
2677
2678 handle = lttng_create_handle(session_name, &domain);
2679 if (!handle) {
2680 ret = -LTTNG_ERR_NOMEM;
2681 goto end;
2682 }
2683
2684 /* get the channels node */
2685 for (node = xmlFirstElementChild(domain_node); node;
2686 node = xmlNextElementSibling(node)) {
2687 if (!strcmp((const char *) node->name,
2688 config_element_channels)) {
2689 channels_node = node;
2690 break;
2691 }
2692 }
2693
2694 if (!channels_node) {
2695 goto end;
2696 }
2697
2698 /* create all channels */
2699 for (node = xmlFirstElementChild(channels_node); node;
2700 node = xmlNextElementSibling(node)) {
36d1687c 2701 const enum lttng_domain_type original_domain = domain.type;
dcf266c0
JG
2702 xmlNodePtr contexts_node = NULL;
2703 xmlNodePtr events_node = NULL;
2704 xmlNodePtr channel_attr_node;
2705
36d1687c
JG
2706 /*
2707 * Channels of the "agent" types cannot be created directly.
2708 * They are meant to be created implicitly through the
2709 * activation of events in their domain. However, a user
2710 * can override the default channel configuration attributes
2711 * by creating the underlying UST channel _before_ enabling
2712 * an agent domain event.
2713 *
2714 * Hence, the channel's type is substituted before the creation
2715 * and restored by the time the events are created.
2716 */
2717 switch (domain.type) {
2718 case LTTNG_DOMAIN_JUL:
2719 case LTTNG_DOMAIN_LOG4J:
2720 case LTTNG_DOMAIN_PYTHON:
2721 domain.type = LTTNG_DOMAIN_UST;
2722 default:
2723 break;
2724 }
2725
4fc2b126
JR
2726 channel = lttng_channel_create(&domain);
2727 if (!channel) {
2728 ret = -1;
2729 goto end;
2730 }
dcf266c0
JG
2731
2732 for (channel_attr_node = xmlFirstElementChild(node);
2733 channel_attr_node; channel_attr_node =
2734 xmlNextElementSibling(channel_attr_node)) {
2735 ret = process_channel_attr_node(channel_attr_node,
4fc2b126 2736 channel, &contexts_node, &events_node);
dcf266c0
JG
2737 if (ret) {
2738 goto end;
2739 }
2740 }
2741
4fc2b126 2742 ret = lttng_enable_channel(handle, channel);
dcf266c0
JG
2743 if (ret < 0) {
2744 goto end;
2745 }
2746
36d1687c
JG
2747 /* Restore the original channel domain. */
2748 domain.type = original_domain;
2749
4fc2b126 2750 ret = process_events_node(events_node, handle, channel->name);
dcf266c0
JG
2751 if (ret) {
2752 goto end;
2753 }
2754
2755 ret = process_contexts_node(contexts_node, handle,
4fc2b126 2756 channel->name);
dcf266c0
JG
2757 if (ret) {
2758 goto end;
2759 }
4fc2b126
JR
2760
2761 lttng_channel_destroy(channel);
dcf266c0 2762 }
4fc2b126 2763 channel = NULL;
847a5916
JR
2764
2765 /* get the trackers node */
2766 for (node = xmlFirstElementChild(domain_node); node;
2767 node = xmlNextElementSibling(node)) {
2768 if (!strcmp((const char *) node->name,
2769 config_element_trackers)) {
2770 trackers_node = node;
2771 break;
2772 }
2773 }
2774
2775 if (!trackers_node) {
2776 goto end;
2777 }
2778
2779 for (node = xmlFirstElementChild(trackers_node); node;
2780 node = xmlNextElementSibling(node)) {
2781 if (!strcmp((const char *)node->name,config_element_pid_tracker)) {
2782 pid_tracker_node = node;
2783 ret = process_pid_tracker_node(pid_tracker_node, handle);
2784 if (ret) {
2785 goto end;
2786 }
2787 }
2788 }
2789
2790 if (!pid_tracker_node) {
2791 lttng_track_pid(handle, -1);
2792 }
2793
dcf266c0 2794end:
4fc2b126 2795 lttng_channel_destroy(channel);
dcf266c0
JG
2796 lttng_destroy_handle(handle);
2797 return ret;
2798}
2799
66ea93b1
JG
2800static
2801int add_periodic_rotation(const char *name, uint64_t time_us)
2802{
2803 int ret;
2804 enum lttng_rotation_status status;
2805 struct lttng_rotation_schedule *periodic =
2806 lttng_rotation_schedule_periodic_create();
2807
2808 if (!periodic) {
2809 ret = -LTTNG_ERR_NOMEM;
2810 goto error;
2811 }
2812
2813 status = lttng_rotation_schedule_periodic_set_period(periodic,
2814 time_us);
2815 if (status != LTTNG_ROTATION_STATUS_OK) {
2816 ret = -LTTNG_ERR_INVALID;
2817 goto error;
2818 }
2819
2820 status = lttng_session_add_rotation_schedule(name, periodic);
2821 switch (status) {
2822 case LTTNG_ROTATION_STATUS_OK:
ce6176f2 2823 ret = 0;
66ea93b1
JG
2824 break;
2825 case LTTNG_ROTATION_STATUS_SCHEDULE_ALREADY_SET:
2826 case LTTNG_ROTATION_STATUS_INVALID:
2827 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2828 break;
2829 default:
2830 ret = -LTTNG_ERR_UNK;
2831 break;
2832 }
2833error:
2834 lttng_rotation_schedule_destroy(periodic);
2835 return ret;
2836}
2837
2838static
2839int add_size_rotation(const char *name, uint64_t size_bytes)
2840{
2841 int ret;
2842 enum lttng_rotation_status status;
2843 struct lttng_rotation_schedule *size =
2844 lttng_rotation_schedule_size_threshold_create();
2845
2846 if (!size) {
2847 ret = -LTTNG_ERR_NOMEM;
2848 goto error;
2849 }
2850
2851 status = lttng_rotation_schedule_size_threshold_set_threshold(size,
2852 size_bytes);
2853 if (status != LTTNG_ROTATION_STATUS_OK) {
2854 ret = -LTTNG_ERR_INVALID;
2855 goto error;
2856 }
2857
2858 status = lttng_session_add_rotation_schedule(name, size);
2859 switch (status) {
2860 case LTTNG_ROTATION_STATUS_OK:
ce6176f2 2861 ret = 0;
66ea93b1
JG
2862 break;
2863 case LTTNG_ROTATION_STATUS_SCHEDULE_ALREADY_SET:
2864 case LTTNG_ROTATION_STATUS_INVALID:
2865 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2866 break;
2867 default:
2868 ret = -LTTNG_ERR_UNK;
2869 break;
2870 }
2871error:
2872 lttng_rotation_schedule_destroy(size);
2873 return ret;
2874}
2875
ce6176f2
JG
2876static
2877int process_session_rotation_schedules_node(
2878 xmlNodePtr schedules_node,
2879 uint64_t *rotation_timer_interval,
2880 uint64_t *rotation_size)
2881{
2882 int ret = 0;
2883 xmlNodePtr child;
2884
2885 for (child = xmlFirstElementChild(schedules_node);
2886 child;
2887 child = xmlNextElementSibling(child)) {
2888 if (!strcmp((const char *) child->name,
2889 config_element_rotation_schedule_periodic)) {
2890 xmlChar *content;
2891 xmlNodePtr time_us_node;
2892
2893 /* periodic rotation schedule */
2894 time_us_node = xmlFirstElementChild(child);
2895 if (!time_us_node ||
2896 strcmp((const char *) time_us_node->name,
2897 config_element_rotation_schedule_periodic_time_us)) {
2898 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2899 goto end;
2900 }
2901
2902 /* time_us child */
2903 content = xmlNodeGetContent(time_us_node);
2904 if (!content) {
2905 ret = -LTTNG_ERR_NOMEM;
2906 goto end;
2907 }
2908 ret = parse_uint(content, rotation_timer_interval);
2909 free(content);
2910 if (ret) {
2911 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2912 goto end;
2913 }
2914 } else if (!strcmp((const char *) child->name,
2915 config_element_rotation_schedule_size_threshold)) {
2916 xmlChar *content;
2917 xmlNodePtr bytes_node;
2918
2919 /* size_threshold rotation schedule */
2920 bytes_node = xmlFirstElementChild(child);
2921 if (!bytes_node ||
2922 strcmp((const char *) bytes_node->name,
2923 config_element_rotation_schedule_size_threshold_bytes)) {
2924 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2925 goto end;
2926 }
2927
2928 /* bytes child */
2929 content = xmlNodeGetContent(bytes_node);
2930 if (!content) {
2931 ret = -LTTNG_ERR_NOMEM;
2932 goto end;
2933 }
2934 ret = parse_uint(content, rotation_size);
2935 free(content);
2936 if (ret) {
2937 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
2938 goto end;
2939 }
2940 }
2941 }
2942
2943end:
2944 return ret;
2945}
2946
dcf266c0
JG
2947static
2948int process_session_node(xmlNodePtr session_node, const char *session_name,
1b08cbce
JR
2949 int overwrite,
2950 const struct config_load_session_override_attr *overrides)
dcf266c0
JG
2951{
2952 int ret, started = -1, snapshot_mode = -1;
259c2674 2953 uint64_t live_timer_interval = UINT64_MAX,
90936dcf
JD
2954 rotation_timer_interval = 0,
2955 rotation_size = 0;
d324faf7 2956 xmlChar *name = NULL;
9e7c9f56 2957 xmlChar *shm_path = NULL;
dcf266c0
JG
2958 xmlNodePtr domains_node = NULL;
2959 xmlNodePtr output_node = NULL;
2960 xmlNodePtr node;
90936dcf 2961 xmlNodePtr attributes_child;
dcf266c0
JG
2962 struct lttng_domain *kernel_domain = NULL;
2963 struct lttng_domain *ust_domain = NULL;
2964 struct lttng_domain *jul_domain = NULL;
5cdb6027 2965 struct lttng_domain *log4j_domain = NULL;
0e115563 2966 struct lttng_domain *python_domain = NULL;
dcf266c0
JG
2967
2968 for (node = xmlFirstElementChild(session_node); node;
2969 node = xmlNextElementSibling(node)) {
2970 if (!name && !strcmp((const char *) node->name,
2971 config_element_name)) {
2972 /* name */
2973 xmlChar *node_content = xmlNodeGetContent(node);
2974 if (!node_content) {
2975 ret = -LTTNG_ERR_NOMEM;
c2da8cde 2976 goto error;
dcf266c0
JG
2977 }
2978
d324faf7 2979 name = node_content;
dcf266c0
JG
2980 } else if (!domains_node && !strcmp((const char *) node->name,
2981 config_element_domains)) {
2982 /* domains */
2983 domains_node = node;
2984 } else if (started == -1 && !strcmp((const char *) node->name,
2985 config_element_started)) {
2986 /* started */
2987 xmlChar *node_content = xmlNodeGetContent(node);
2988 if (!node_content) {
2989 ret = -LTTNG_ERR_NOMEM;
c2da8cde 2990 goto error;
dcf266c0
JG
2991 }
2992
2993 ret = parse_bool(node_content, &started);
2994 free(node_content);
2995 if (ret) {
2996 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
c2da8cde 2997 goto error;
dcf266c0
JG
2998 }
2999 } else if (!output_node && !strcmp((const char *) node->name,
3000 config_element_output)) {
3001 /* output */
3002 output_node = node;
9e7c9f56
JR
3003 } else if (!shm_path && !strcmp((const char *) node->name,
3004 config_element_shared_memory_path)) {
3005 /* shared memory path */
3006 xmlChar *node_content = xmlNodeGetContent(node);
3007 if (!node_content) {
3008 ret = -LTTNG_ERR_NOMEM;
3009 goto error;
3010 }
3011
3012 shm_path = node_content;
dcf266c0 3013 } else {
259c2674
JD
3014 /*
3015 * attributes, snapshot_mode, live_timer_interval, rotation_size,
90936dcf
JD
3016 * rotation_timer_interval.
3017 */
3018 for (attributes_child = xmlFirstElementChild(node); attributes_child;
3019 attributes_child = xmlNextElementSibling(attributes_child)) {
3020 if (!strcmp((const char *) attributes_child->name,
3021 config_element_snapshot_mode)) {
3022 /* snapshot_mode */
3023 xmlChar *snapshot_mode_content =
3024 xmlNodeGetContent(attributes_child);
3025 if (!snapshot_mode_content) {
3026 ret = -LTTNG_ERR_NOMEM;
3027 goto error;
3028 }
dcf266c0 3029
90936dcf
JD
3030 ret = parse_bool(snapshot_mode_content, &snapshot_mode);
3031 free(snapshot_mode_content);
3032 if (ret) {
3033 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
3034 goto error;
3035 }
3036 } else if (!strcmp((const char *) attributes_child->name,
3037 config_element_live_timer_interval)) {
3038 /* live_timer_interval */
3039 xmlChar *timer_interval_content =
3040 xmlNodeGetContent(attributes_child);
3041 if (!timer_interval_content) {
3042 ret = -LTTNG_ERR_NOMEM;
3043 goto error;
3044 }
dcf266c0 3045
90936dcf
JD
3046 ret = parse_uint(timer_interval_content, &live_timer_interval);
3047 free(timer_interval_content);
3048 if (ret) {
3049 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
3050 goto error;
3051 }
ce6176f2
JG
3052 } else if (!strcmp((const char *) attributes_child->name,
3053 config_element_rotation_schedules)) {
3054 ret = process_session_rotation_schedules_node(
3055 attributes_child,
3056 &rotation_timer_interval,
3057 &rotation_size);
90936dcf
JD
3058 if (ret) {
3059 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
3060 goto error;
3061 }
259c2674 3062
259c2674
JD
3063 }
3064 }
dcf266c0
JG
3065 }
3066 }
3067
3068 if (!name) {
3069 /* Mandatory attribute, as defined in the session XSD */
3070 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
c2da8cde 3071 goto error;
dcf266c0
JG
3072 }
3073
d324faf7 3074 if (session_name && strcmp((char *) name, session_name)) {
dcf266c0 3075 /* This is not the session we are looking for */
c2da8cde
DG
3076 ret = -LTTNG_ERR_NO_SESSION;
3077 goto error;
dcf266c0
JG
3078 }
3079
3080 /* Init domains to create the session handles */
3081 for (node = xmlFirstElementChild(domains_node); node;
3082 node = xmlNextElementSibling(node)) {
3083 struct lttng_domain *domain;
3084
3085 domain = zmalloc(sizeof(*domain));
3086 if (!domain) {
3087 ret = -LTTNG_ERR_NOMEM;
c2da8cde 3088 goto error;
dcf266c0
JG
3089 }
3090
3091 ret = init_domain(node, domain);
3092 if (ret) {
3093 goto domain_init_error;
3094 }
3095
3096 switch (domain->type) {
3097 case LTTNG_DOMAIN_KERNEL:
c33e6729
DG
3098 if (kernel_domain) {
3099 /* Same domain seen twice, invalid! */
3100 goto domain_init_error;
3101 }
dcf266c0
JG
3102 kernel_domain = domain;
3103 break;
3104 case LTTNG_DOMAIN_UST:
c33e6729
DG
3105 if (ust_domain) {
3106 /* Same domain seen twice, invalid! */
3107 goto domain_init_error;
3108 }
dcf266c0
JG
3109 ust_domain = domain;
3110 break;
3111 case LTTNG_DOMAIN_JUL:
c33e6729
DG
3112 if (jul_domain) {
3113 /* Same domain seen twice, invalid! */
3114 goto domain_init_error;
3115 }
dcf266c0
JG
3116 jul_domain = domain;
3117 break;
5cdb6027
DG
3118 case LTTNG_DOMAIN_LOG4J:
3119 if (log4j_domain) {
3120 /* Same domain seen twice, invalid! */
3121 goto domain_init_error;
3122 }
3123 log4j_domain = domain;
3124 break;
0e115563
DG
3125 case LTTNG_DOMAIN_PYTHON:
3126 if (python_domain) {
3127 /* Same domain seen twice, invalid! */
3128 goto domain_init_error;
3129 }
3130 python_domain = domain;
3131 break;
dcf266c0
JG
3132 default:
3133 WARN("Invalid domain type");
3134 goto domain_init_error;
3135 }
3136 continue;
3137domain_init_error:
3138 free(domain);
3139 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
c2da8cde 3140 goto error;
dcf266c0
JG
3141 }
3142
2aaf5fc7
JR
3143 /* Apply overrides */
3144 if (overrides) {
3145 if (overrides->session_name) {
3146 xmlChar *name_override = xmlStrdup(BAD_CAST(overrides->session_name));
3147 if (!name_override) {
3148 ret = -LTTNG_ERR_NOMEM;
3149 goto error;
3150 }
3151
3152 /* Overrides the session name to the provided name */
3153 xmlFree(name);
3154 name = name_override;
3155 }
3156 }
3157
40b4155f 3158 if (overwrite) {
dcf266c0 3159 /* Destroy session if it exists */
d324faf7 3160 ret = lttng_destroy_session((const char *) name);
dcf266c0
JG
3161 if (ret && ret != -LTTNG_ERR_SESS_NOT_FOUND) {
3162 ERR("Failed to destroy existing session.");
c2da8cde 3163 goto error;
dcf266c0
JG
3164 }
3165 }
3166
3167 /* Create session type depending on output type */
3168 if (snapshot_mode && snapshot_mode != -1) {
1b08cbce
JR
3169 ret = create_snapshot_session((const char *) name, output_node,
3170 overrides);
dcf266c0
JG
3171 } else if (live_timer_interval &&
3172 live_timer_interval != UINT64_MAX) {
194dfca0 3173 ret = create_session((const char *) name,
1b08cbce 3174 output_node, live_timer_interval, overrides);
dcf266c0
JG
3175 } else {
3176 /* regular session */
194dfca0 3177 ret = create_session((const char *) name,
1b08cbce 3178 output_node, UINT64_MAX, overrides);
dcf266c0 3179 }
dcf266c0 3180 if (ret) {
c2da8cde 3181 goto error;
dcf266c0
JG
3182 }
3183
9e7c9f56
JR
3184 if (shm_path) {
3185 ret = lttng_set_session_shm_path((const char *) name,
d324faf7 3186 (const char *) shm_path);
9e7c9f56
JR
3187 if (ret) {
3188 goto error;
3189 }
3190 }
3191
dcf266c0
JG
3192 for (node = xmlFirstElementChild(domains_node); node;
3193 node = xmlNextElementSibling(node)) {
d324faf7 3194 ret = process_domain_node(node, (const char *) name);
dcf266c0
JG
3195 if (ret) {
3196 goto end;
3197 }
3198 }
3199
66ea93b1
JG
3200 if (rotation_timer_interval) {
3201 ret = add_periodic_rotation((const char *) name,
3202 rotation_timer_interval);
3203 if (ret < 0) {
259c2674
JD
3204 goto error;
3205 }
66ea93b1
JG
3206 }
3207 if (rotation_size) {
3208 ret = add_size_rotation((const char *) name,
dbd512ea 3209 rotation_size);
66ea93b1 3210 if (ret < 0) {
259c2674
JD
3211 goto error;
3212 }
3213 }
3214
dcf266c0 3215 if (started) {
d324faf7 3216 ret = lttng_start_tracing((const char *) name);
dcf266c0
JG
3217 if (ret) {
3218 goto end;
3219 }
3220 }
c2da8cde 3221
dcf266c0 3222end:
b2579dc1 3223 if (ret < 0) {
d324faf7
JG
3224 ERR("Failed to load session %s: %s", (const char *) name,
3225 lttng_strerror(ret));
3226 lttng_destroy_session((const char *) name);
b2579dc1
JG
3227 }
3228
c2da8cde 3229error:
dcf266c0
JG
3230 free(kernel_domain);
3231 free(ust_domain);
3232 free(jul_domain);
5cdb6027 3233 free(log4j_domain);
135a3893 3234 free(python_domain);
d324faf7 3235 xmlFree(name);
9e7c9f56 3236 xmlFree(shm_path);
dcf266c0
JG
3237 return ret;
3238}
3239
cf53c06d
DG
3240/*
3241 * Return 1 if the given path is readable by the current UID or 0 if not.
3242 * Return -1 if the path is EPERM.
3243 */
3244static int validate_file_read_creds(const char *path)
3245{
3246 int ret;
3247
3248 assert(path);
3249
3250 /* Can we read the file. */
3251 ret = access(path, R_OK);
3252 if (!ret) {
3253 goto valid;
3254 }
3255 if (errno == EACCES) {
3256 return -1;
3257 } else {
3258 /* Invalid. */
3259 return 0;
3260 }
3261valid:
3262 return 1;
3263}
3264
dcf266c0
JG
3265static
3266int load_session_from_file(const char *path, const char *session_name,
1b08cbce
JR
3267 struct session_config_validation_ctx *validation_ctx, int overwrite,
3268 const struct config_load_session_override_attr *overrides)
dcf266c0
JG
3269{
3270 int ret, session_found = !session_name;
3271 xmlDocPtr doc = NULL;
3272 xmlNodePtr sessions_node;
3273 xmlNodePtr session_node;
dcf266c0
JG
3274
3275 assert(path);
3276 assert(validation_ctx);
3277
cf53c06d
DG
3278 ret = validate_file_read_creds(path);
3279 if (ret != 1) {
3280 if (ret == -1) {
3281 ret = -LTTNG_ERR_EPERM;
3282 } else {
3283 ret = -LTTNG_ERR_LOAD_SESSION_NOENT;
3284 }
dcf266c0
JG
3285 goto end;
3286 }
3287
3288 doc = xmlParseFile(path);
3289 if (!doc) {
3290 ret = -LTTNG_ERR_LOAD_IO_FAIL;
3291 goto end;
3292 }
3293
3294 ret = xmlSchemaValidateDoc(validation_ctx->schema_validation_ctx, doc);
3295 if (ret) {
3296 ERR("Session configuration file validation failed");
3297 ret = -LTTNG_ERR_LOAD_INVALID_CONFIG;
3298 goto end;
3299 }
3300
3301 sessions_node = xmlDocGetRootElement(doc);
3302 if (!sessions_node) {
3303 goto end;
3304 }
3305
3306 for (session_node = xmlFirstElementChild(sessions_node);
3307 session_node; session_node =
3308 xmlNextElementSibling(session_node)) {
3309 ret = process_session_node(session_node,
1b08cbce 3310 session_name, overwrite, overrides);
dcf266c0
JG
3311 if (session_name && ret == 0) {
3312 /* Target session found and loaded */
3313 session_found = 1;
3314 break;
3315 }
3316 }
3317end:
3318 xmlFreeDoc(doc);
3319 if (!ret) {
a96bc65d 3320 ret = session_found ? 0 : -LTTNG_ERR_LOAD_SESSION_NOENT;
dcf266c0
JG
3321 }
3322 return ret;
3323}
3324
3325static
3326int load_session_from_path(const char *path, const char *session_name,
1b08cbce
JR
3327 struct session_config_validation_ctx *validation_ctx, int overwrite,
3328 const struct config_load_session_override_attr *overrides)
dcf266c0
JG
3329{
3330 int ret, session_found = !session_name;
dcf266c0 3331 DIR *directory = NULL;
cce35f91
JG
3332 struct lttng_dynamic_buffer file_path;
3333 size_t path_len;
dcf266c0
JG
3334
3335 assert(path);
3336 assert(validation_ctx);
cce35f91
JG
3337 path_len = strlen(path);
3338 lttng_dynamic_buffer_init(&file_path);
3339 if (path_len >= LTTNG_PATH_MAX) {
3340 ERR("Session configuration load path \"%s\" length (%zu) exceeds the maximal length allowed (%d)",
3341 path, path_len, LTTNG_PATH_MAX);
3342 ret = -LTTNG_ERR_INVALID;
3343 goto end;
3344 }
dcf266c0 3345
4af16958
DG
3346 directory = opendir(path);
3347 if (!directory) {
11143783
DG
3348 switch (errno) {
3349 case ENOTDIR:
0f0a81b5
DG
3350 /* Try the file loading. */
3351 break;
11143783
DG
3352 case ENOENT:
3353 ret = -LTTNG_ERR_LOAD_SESSION_NOENT;
3354 goto end;
3355 default:
0f0a81b5
DG
3356 ret = -LTTNG_ERR_LOAD_IO_FAIL;
3357 goto end;
4af16958 3358 }
dcf266c0 3359 }
4af16958 3360 if (directory) {
cce35f91 3361 size_t file_path_root_len;
dcf266c0 3362
cce35f91
JG
3363 ret = lttng_dynamic_buffer_set_capacity(&file_path,
3364 LTTNG_PATH_MAX);
3365 if (ret) {
3366 ret = -LTTNG_ERR_NOMEM;
dcf266c0
JG
3367 goto end;
3368 }
3369
cce35f91
JG
3370 ret = lttng_dynamic_buffer_append(&file_path, path, path_len);
3371 if (ret) {
dcf266c0 3372 ret = -LTTNG_ERR_NOMEM;
dcf266c0
JG
3373 goto end;
3374 }
3375
cce35f91
JG
3376 if (file_path.data[file_path.size - 1] != '/') {
3377 ret = lttng_dynamic_buffer_append(&file_path, "/", 1);
3378 if (ret) {
3379 ret = -LTTNG_ERR_NOMEM;
3380 goto end;
3381 }
dcf266c0 3382 }
cce35f91 3383 file_path_root_len = file_path.size;
dcf266c0
JG
3384
3385 /* Search for *.lttng files */
9a2df626
MJ
3386 for (;;) {
3387 size_t file_name_len;
3388 struct dirent *result;
3389
3390 /*
3391 * When the end of the directory stream is reached, NULL
3392 * is returned and errno is kept unchanged. When an
3393 * error occurs, NULL is returned and errno is set
3394 * accordingly. To distinguish between the two, set
3395 * errno to zero before calling readdir().
3396 *
3397 * On success, readdir() returns a pointer to a dirent
3398 * structure. This structure may be statically
3399 * allocated, do not attempt to free(3) it.
3400 */
3401 errno = 0;
3402 result = readdir(directory);
3403
ff86d8d0 3404 /* Reached end of dir stream or error out. */
9a2df626
MJ
3405 if (!result) {
3406 if (errno) {
3407 PERROR("Failed to enumerate the contents of path \"%s\" while loading session, readdir returned", path);
3408 ret = -LTTNG_ERR_LOAD_IO_FAIL;
3409 goto end;
3410 }
3411 break;
3412 }
3413
3414 file_name_len = strlen(result->d_name);
dcf266c0
JG
3415
3416 if (file_name_len <=
3417 sizeof(DEFAULT_SESSION_CONFIG_FILE_EXTENSION)) {
3418 continue;
3419 }
3420
cce35f91
JG
3421 if (file_path.size + file_name_len >= LTTNG_PATH_MAX) {
3422 WARN("Ignoring file \"%s\" since the path's length (%zu) would exceed the maximal permitted size (%d)",
3423 result->d_name,
3424 /* +1 to account for NULL terminator. */
3425 file_path.size + file_name_len + 1,
3426 LTTNG_PATH_MAX);
dcf266c0
JG
3427 continue;
3428 }
3429
cce35f91 3430 /* Does the file end with .lttng? */
dcf266c0 3431 if (strcmp(DEFAULT_SESSION_CONFIG_FILE_EXTENSION,
cce35f91
JG
3432 result->d_name + file_name_len - sizeof(
3433 DEFAULT_SESSION_CONFIG_FILE_EXTENSION) + 1)) {
dcf266c0
JG
3434 continue;
3435 }
3436
cce35f91
JG
3437 ret = lttng_dynamic_buffer_append(&file_path, result->d_name,
3438 file_name_len + 1);
3439 if (ret) {
3440 ret = -LTTNG_ERR_NOMEM;
3441 goto end;
3442 }
dcf266c0 3443
cce35f91 3444 ret = load_session_from_file(file_path.data, session_name,
1b08cbce 3445 validation_ctx, overwrite, overrides);
dcf266c0
JG
3446 if (session_name && !ret) {
3447 session_found = 1;
3448 break;
3449 }
cce35f91
JG
3450 /*
3451 * Reset the buffer's size to the location of the
3452 * path's trailing '/'.
3453 */
3454 ret = lttng_dynamic_buffer_set_size(&file_path,
3455 file_path_root_len);
3456 if (ret) {
3457 ret = -LTTNG_ERR_UNK;
3458 goto end;
3459 }
dcf266c0
JG
3460 }
3461
dcf266c0
JG
3462 } else {
3463 ret = load_session_from_file(path, session_name,
1b08cbce 3464 validation_ctx, overwrite, overrides);
dcf266c0
JG
3465 if (ret) {
3466 goto end;
3467 } else {
3468 session_found = 1;
3469 }
3470 }
3471
3472end:
3473 if (directory) {
3474 if (closedir(directory)) {
3475 PERROR("closedir");
3476 }
3477 }
464133ea 3478 if (session_found && !ret) {
6c66fa0f 3479 ret = 0;
dcf266c0 3480 }
cce35f91 3481 lttng_dynamic_buffer_reset(&file_path);
dcf266c0
JG
3482 return ret;
3483}
3484
ab38c13f
DG
3485/*
3486 * Validate that the given path's credentials and the current process have the
cf53c06d 3487 * same UID. If so, return 1 else return 0 if it does NOT match.
ab38c13f
DG
3488 */
3489static int validate_path_creds(const char *path)
3490{
3491 int ret, uid = getuid();
3492 struct stat buf;
3493
3494 assert(path);
3495
cf53c06d 3496 if (uid == 0) {
ab38c13f
DG
3497 goto valid;
3498 }
3499
3500 ret = stat(path, &buf);
3501 if (ret < 0) {
3502 if (errno != ENOENT) {
3503 PERROR("stat");
3504 }
ab38c13f
DG
3505 goto valid;
3506 }
3507
3508 if (buf.st_uid != uid) {
3509 goto invalid;
3510 }
3511
3512valid:
ab38c13f 3513 return 1;
cf53c06d
DG
3514invalid:
3515 return 0;
ab38c13f
DG
3516}
3517
dcf266c0
JG
3518LTTNG_HIDDEN
3519int config_load_session(const char *path, const char *session_name,
1b08cbce
JR
3520 int overwrite, unsigned int autoload,
3521 const struct config_load_session_override_attr *overrides)
dcf266c0
JG
3522{
3523 int ret;
6c66fa0f 3524 bool session_loaded = false;
cf53c06d 3525 const char *path_ptr = NULL;
dcf266c0
JG
3526 struct session_config_validation_ctx validation_ctx = { 0 };
3527
3528 ret = init_session_config_validation_ctx(&validation_ctx);
3529 if (ret) {
3530 goto end;
3531 }
3532
3533 if (!path) {
ab38c13f
DG
3534 char *home_path;
3535 const char *sys_path;
3536
dcf266c0 3537 /* Try home path */
ab38c13f 3538 home_path = utils_get_home_dir();
dcf266c0 3539 if (home_path) {
ab38c13f 3540 char path[PATH_MAX];
dcf266c0 3541
d4fcf703
DG
3542 /*
3543 * Try user session configuration path. Ignore error here so we can
3544 * continue loading the system wide sessions.
3545 */
ab38c13f
DG
3546 if (autoload) {
3547 ret = snprintf(path, sizeof(path),
3548 DEFAULT_SESSION_HOME_CONFIGPATH "/"
3549 DEFAULT_SESSION_CONFIG_AUTOLOAD, home_path);
cf53c06d
DG
3550 if (ret < 0) {
3551 PERROR("snprintf session autoload home config path");
3552 goto end;
3553 }
3554
3555 /*
3556 * Credentials are only validated for the autoload in order to
3557 * avoid any user session daemon to try to load kernel sessions
3558 * automatically and failing all the times.
3559 */
3560 ret = validate_path_creds(path);
3561 if (ret) {
3562 path_ptr = path;
3563 }
ab38c13f
DG
3564 } else {
3565 ret = snprintf(path, sizeof(path),
3566 DEFAULT_SESSION_HOME_CONFIGPATH, home_path);
cf53c06d
DG
3567 if (ret < 0) {
3568 PERROR("snprintf session home config path");
3569 goto end;
3570 }
3571 path_ptr = path;
ab38c13f 3572 }
cf53c06d
DG
3573 if (path_ptr) {
3574 ret = load_session_from_path(path_ptr, session_name,
1b08cbce 3575 &validation_ctx, overwrite, overrides);
d4fcf703
DG
3576 if (ret && ret != -LTTNG_ERR_LOAD_SESSION_NOENT) {
3577 goto end;
3578 }
3579 /*
3580 * Continue even if the session was found since we have to try
3581 * the system wide sessions.
3582 */
6c66fa0f 3583 session_loaded = true;
ab38c13f 3584 }
d4fcf703 3585 }
ab38c13f 3586
cf53c06d
DG
3587 /* Reset path pointer for the system wide dir. */
3588 path_ptr = NULL;
3589
d4fcf703
DG
3590 /* Try system wide configuration directory. */
3591 if (autoload) {
3592 sys_path = DEFAULT_SESSION_SYSTEM_CONFIGPATH "/"
3593 DEFAULT_SESSION_CONFIG_AUTOLOAD;
cf53c06d
DG
3594 ret = validate_path_creds(sys_path);
3595 if (ret) {
3596 path_ptr = sys_path;
3597 }
d4fcf703 3598 } else {
cf53c06d
DG
3599 sys_path = DEFAULT_SESSION_SYSTEM_CONFIGPATH;
3600 path_ptr = sys_path;
d4fcf703
DG
3601 }
3602
cf53c06d
DG
3603 if (path_ptr) {
3604 ret = load_session_from_path(path_ptr, session_name,
1b08cbce 3605 &validation_ctx, overwrite, overrides);
6c66fa0f
JG
3606 if (!ret) {
3607 session_loaded = true;
3608 }
dcf266c0
JG
3609 }
3610 } else {
3611 ret = access(path, F_OK);
3612 if (ret < 0) {
3613 PERROR("access");
3614 switch (errno) {
3615 case ENOENT:
3616 ret = -LTTNG_ERR_INVALID;
3617 WARN("Session configuration path does not exist.");
3618 break;
3619 case EACCES:
3620 ret = -LTTNG_ERR_EPERM;
3621 break;
3622 default:
3623 ret = -LTTNG_ERR_UNK;
3624 break;
3625 }
3626 goto end;
3627 }
3628
3629 ret = load_session_from_path(path, session_name,
1b08cbce 3630 &validation_ctx, overwrite, overrides);
dcf266c0
JG
3631 }
3632end:
3633 fini_session_config_validation_ctx(&validation_ctx);
d2b6efff
JG
3634 if (ret == -LTTNG_ERR_LOAD_SESSION_NOENT && !session_name && !path) {
3635 /*
3636 * Don't report an error if no sessions are found when called
3637 * without a session_name or a search path.
3638 */
3639 ret = 0;
3640 }
6c66fa0f
JG
3641
3642 if (session_loaded && ret == -LTTNG_ERR_LOAD_SESSION_NOENT) {
3643 /* A matching session was found in one of the search paths. */
3644 ret = 0;
3645 }
dcf266c0
JG
3646 return ret;
3647}
56766c75
JG
3648
3649static
3650void __attribute__((destructor)) session_config_exit(void)
3651{
3652 xmlCleanupParser();
3653}
This page took 0.205539 seconds and 4 git commands to generate.