Cleanup: enforce const-correctness in notification thread
[lttng-tools.git] / src / common / evaluation.c
1 /*
2 * Copyright (C) 2017 - Jérémie Galarneau <jeremie.galarneau@efficios.com>
3 *
4 * This library is free software; you can redistribute it and/or modify it
5 * under the terms of the GNU Lesser General Public License, version 2.1 only,
6 * as published by the Free Software Foundation.
7 *
8 * This library 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 Lesser General Public License
11 * for more details.
12 *
13 * You should have received a copy of the GNU Lesser General Public License
14 * along with this library; if not, write to the Free Software Foundation,
15 * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
16 */
17
18 #include <lttng/condition/evaluation-internal.h>
19 #include <lttng/condition/buffer-usage-internal.h>
20 #include <lttng/condition/session-consumed-size-internal.h>
21 #include <lttng/condition/session-rotation-internal.h>
22 #include <common/macros.h>
23 #include <common/error.h>
24 #include <stdbool.h>
25 #include <assert.h>
26
27 LTTNG_HIDDEN
28 void lttng_evaluation_init(struct lttng_evaluation *evaluation,
29 enum lttng_condition_type type)
30 {
31 evaluation->type = type;
32 }
33
34 LTTNG_HIDDEN
35 int lttng_evaluation_serialize(const struct lttng_evaluation *evaluation,
36 struct lttng_dynamic_buffer *buf)
37 {
38 int ret;
39 struct lttng_evaluation_comm evaluation_comm = {
40 .type = (int8_t) evaluation->type
41 };
42
43 ret = lttng_dynamic_buffer_append(buf, &evaluation_comm,
44 sizeof(evaluation_comm));
45 if (ret) {
46 goto end;
47 }
48
49 if (evaluation->serialize) {
50 ret = evaluation->serialize(evaluation, buf);
51 if (ret) {
52 goto end;
53 }
54 }
55 end:
56 return ret;
57 }
58
59 LTTNG_HIDDEN
60 ssize_t lttng_evaluation_create_from_buffer(
61 const struct lttng_buffer_view *src_view,
62 struct lttng_evaluation **evaluation)
63 {
64 ssize_t ret, evaluation_size = 0;
65 const struct lttng_evaluation_comm *evaluation_comm;
66 const struct lttng_buffer_view evaluation_view =
67 lttng_buffer_view_from_view(src_view,
68 sizeof(*evaluation_comm), -1);
69
70 if (!src_view || !evaluation) {
71 ret = -1;
72 goto end;
73 }
74
75 evaluation_comm = (const struct lttng_evaluation_comm *) src_view->data;
76 evaluation_size += sizeof(*evaluation_comm);
77
78 switch ((enum lttng_condition_type) evaluation_comm->type) {
79 case LTTNG_CONDITION_TYPE_BUFFER_USAGE_LOW:
80 ret = lttng_evaluation_buffer_usage_low_create_from_buffer(
81 &evaluation_view, evaluation);
82 if (ret < 0) {
83 goto end;
84 }
85 evaluation_size += ret;
86 break;
87 case LTTNG_CONDITION_TYPE_BUFFER_USAGE_HIGH:
88 ret = lttng_evaluation_buffer_usage_high_create_from_buffer(
89 &evaluation_view, evaluation);
90 if (ret < 0) {
91 goto end;
92 }
93 evaluation_size += ret;
94 break;
95 case LTTNG_CONDITION_TYPE_SESSION_CONSUMED_SIZE:
96 ret = lttng_evaluation_session_consumed_size_create_from_buffer(
97 &evaluation_view, evaluation);
98 if (ret < 0) {
99 goto end;
100 }
101 evaluation_size += ret;
102 break;
103 case LTTNG_CONDITION_TYPE_SESSION_ROTATION_ONGOING:
104 ret = lttng_evaluation_session_rotation_ongoing_create_from_buffer(
105 &evaluation_view, evaluation);
106 if (ret < 0) {
107 goto end;
108 }
109 evaluation_size += ret;
110 break;
111 case LTTNG_CONDITION_TYPE_SESSION_ROTATION_COMPLETED:
112 ret = lttng_evaluation_session_rotation_completed_create_from_buffer(
113 &evaluation_view, evaluation);
114 if (ret < 0) {
115 goto end;
116 }
117 evaluation_size += ret;
118 break;
119 default:
120 ERR("Attempted to create evaluation of unknown type (%i)",
121 (int) evaluation_comm->type);
122 ret = -1;
123 goto end;
124 }
125 ret = evaluation_size;
126 end:
127 return ret;
128 }
129
130 enum lttng_condition_type lttng_evaluation_get_type(
131 const struct lttng_evaluation *evaluation)
132 {
133 return evaluation ? evaluation->type : LTTNG_CONDITION_TYPE_UNKNOWN;
134 }
135
136 void lttng_evaluation_destroy(struct lttng_evaluation *evaluation)
137 {
138 if (!evaluation) {
139 return;
140 }
141
142 assert(evaluation->destroy);
143 evaluation->destroy(evaluation);
144 }
This page took 0.046534 seconds and 4 git commands to generate.