2 * Copyright (C) 2017 - Jérémie Galarneau <jeremie.galarneau@efficios.com>
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.
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
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
18 #include <lttng/condition/condition-internal.h>
19 #include <lttng/condition/buffer-usage-internal.h>
20 #include <lttng/condition/session-consumed-size-internal.h>
21 #include <common/macros.h>
22 #include <common/error.h>
23 #include <common/dynamic-buffer.h>
24 #include <common/buffer-view.h>
28 enum lttng_condition_type
lttng_condition_get_type(
29 const struct lttng_condition
*condition
)
31 return condition
? condition
->type
: LTTNG_CONDITION_TYPE_UNKNOWN
;
34 void lttng_condition_destroy(struct lttng_condition
*condition
)
40 assert(condition
->destroy
);
41 condition
->destroy(condition
);
45 bool lttng_condition_validate(const struct lttng_condition
*condition
)
54 if (!condition
->validate
) {
55 /* Sub-class guarantees that it can never be invalid. */
60 valid
= condition
->validate(condition
);
66 int lttng_condition_serialize(const struct lttng_condition
*condition
,
67 struct lttng_dynamic_buffer
*buf
)
70 struct lttng_condition_comm condition_comm
= { 0 };
77 condition_comm
.condition_type
= (int8_t) condition
->type
;
79 ret
= lttng_dynamic_buffer_append(buf
, &condition_comm
,
80 sizeof(condition_comm
));
85 ret
= condition
->serialize(condition
, buf
);
94 bool lttng_condition_is_equal(const struct lttng_condition
*a
,
95 const struct lttng_condition
*b
)
97 bool is_equal
= false;
103 if (a
->type
!= b
->type
) {
112 is_equal
= a
->equal
? a
->equal(a
, b
) : true;
118 ssize_t
lttng_condition_create_from_buffer(
119 const struct lttng_buffer_view
*buffer
,
120 struct lttng_condition
**condition
)
122 ssize_t ret
, condition_size
= 0;
123 const struct lttng_condition_comm
*condition_comm
;
124 condition_create_from_buffer_cb create_from_buffer
= NULL
;
126 if (!buffer
|| !condition
) {
131 DBG("Deserializing condition from buffer");
132 condition_comm
= (const struct lttng_condition_comm
*) buffer
->data
;
133 condition_size
+= sizeof(*condition_comm
);
135 switch ((enum lttng_condition_type
) condition_comm
->condition_type
) {
136 case LTTNG_CONDITION_TYPE_BUFFER_USAGE_LOW
:
137 create_from_buffer
= lttng_condition_buffer_usage_low_create_from_buffer
;
139 case LTTNG_CONDITION_TYPE_BUFFER_USAGE_HIGH
:
140 create_from_buffer
= lttng_condition_buffer_usage_high_create_from_buffer
;
142 case LTTNG_CONDITION_TYPE_SESSION_CONSUMED_SIZE
:
143 create_from_buffer
= lttng_condition_session_consumed_size_create_from_buffer
;
146 ERR("Attempted to create condition of unknown type (%i)",
147 (int) condition_comm
->condition_type
);
152 if (create_from_buffer
) {
153 const struct lttng_buffer_view view
=
154 lttng_buffer_view_from_view(buffer
,
155 sizeof(*condition_comm
), -1);
157 ret
= create_from_buffer(&view
, condition
);
161 condition_size
+= ret
;
167 ret
= condition_size
;
173 void lttng_condition_init(struct lttng_condition
*condition
,
174 enum lttng_condition_type type
)
176 condition
->type
= type
;