Commit | Line | Data |
---|---|---|
8e68d1c8 | 1 | /* |
21cf9b6b | 2 | * Copyright (C) 2011 EfficiOS Inc. |
ab5be9fa | 3 | * Copyright (C) 2011 Mathieu Desnoyers <mathieu.desnoyers@efficios.com> |
8e68d1c8 | 4 | * |
ab5be9fa | 5 | * SPDX-License-Identifier: GPL-2.0-only |
8e68d1c8 | 6 | * |
8e68d1c8 DG |
7 | */ |
8 | ||
6c1c0768 | 9 | #define _LGPL_SOURCE |
8e68d1c8 | 10 | #include <stdlib.h> |
8e68d1c8 DG |
11 | #include <unistd.h> |
12 | ||
c9e313bc | 13 | #include <common/error.hpp> |
7272acf5 | 14 | |
c9e313bc SM |
15 | #include "utils.hpp" |
16 | #include "snapshot.hpp" | |
17 | #include "lttng-sessiond.hpp" | |
0b2dc8df | 18 | |
54d01ffb DG |
19 | /* |
20 | * Write to writable pipe used to notify a thread. | |
21 | */ | |
22 | int notify_thread_pipe(int wpipe) | |
23 | { | |
6cd525e8 | 24 | ssize_t ret; |
54d01ffb | 25 | |
2f77fc4b DG |
26 | /* Ignore if the pipe is invalid. */ |
27 | if (wpipe < 0) { | |
28 | return 0; | |
29 | } | |
30 | ||
6cd525e8 MD |
31 | ret = lttng_write(wpipe, "!", 1); |
32 | if (ret < 1) { | |
7272acf5 | 33 | PERROR("write poll pipe"); |
54d01ffb DG |
34 | } |
35 | ||
6cd525e8 | 36 | return (int) ret; |
54d01ffb DG |
37 | } |
38 | ||
19a97244 PP |
39 | int loglevels_match(int a_loglevel_type, int a_loglevel_value, |
40 | int b_loglevel_type, int b_loglevel_value, int loglevel_all_type) | |
41 | { | |
42 | int match = 1; | |
43 | ||
44 | if (a_loglevel_type == b_loglevel_type) { | |
45 | /* Same loglevel type. */ | |
46 | if (b_loglevel_type != loglevel_all_type) { | |
47 | /* | |
48 | * Loglevel value must also match since the loglevel | |
49 | * type is not all. | |
50 | */ | |
51 | if (a_loglevel_value != b_loglevel_value) { | |
52 | match = 0; | |
53 | } | |
54 | } | |
55 | } else { | |
56 | /* Loglevel type is different: no match. */ | |
57 | match = 0; | |
58 | } | |
59 | ||
60 | return match; | |
61 | } | |
a1ae2ea5 JD |
62 | |
63 | const char *session_get_base_path(const struct ltt_session *session) | |
64 | { | |
348a81dc | 65 | return consumer_output_get_base_path(session->consumer); |
a1ae2ea5 | 66 | } |
d2956687 | 67 | |
348a81dc | 68 | const char *consumer_output_get_base_path(const struct consumer_output *output) |
d2956687 | 69 | { |
348a81dc JG |
70 | return output->type == CONSUMER_DST_LOCAL ? |
71 | output->dst.session_root_path : | |
72 | output->dst.net.base_dir; | |
d2956687 | 73 | } |