2 * Copyright (C) 2017 Jérémie Galarneau <jeremie.galarneau@efficios.com>
4 * SPDX-License-Identifier: LGPL-2.1-only
8 #include <lttng/condition/condition-internal.h>
9 #include <lttng/condition/evaluation-internal.h>
10 #include <lttng/condition/buffer-usage-internal.h>
11 #include <lttng/condition/session-consumed-size-internal.h>
12 #include <lttng/condition/session-rotation-internal.h>
13 #include <lttng/condition/event-rule-internal.h>
14 #include <common/macros.h>
15 #include <common/error.h>
20 void lttng_evaluation_init(struct lttng_evaluation
*evaluation
,
21 enum lttng_condition_type type
)
23 evaluation
->type
= type
;
27 int lttng_evaluation_serialize(const struct lttng_evaluation
*evaluation
,
28 struct lttng_dynamic_buffer
*buf
)
31 struct lttng_evaluation_comm evaluation_comm
= {
32 .type
= (int8_t) evaluation
->type
35 ret
= lttng_dynamic_buffer_append(buf
, &evaluation_comm
,
36 sizeof(evaluation_comm
));
41 if (evaluation
->serialize
) {
42 ret
= evaluation
->serialize(evaluation
, buf
);
52 ssize_t
lttng_evaluation_create_from_buffer(
53 const struct lttng_condition
*condition
,
54 const struct lttng_buffer_view
*src_view
,
55 struct lttng_evaluation
**evaluation
)
57 ssize_t ret
, evaluation_size
= 0;
58 const struct lttng_evaluation_comm
*evaluation_comm
;
59 const struct lttng_buffer_view evaluation_view
=
60 lttng_buffer_view_from_view(src_view
,
61 sizeof(*evaluation_comm
), -1);
63 if (!src_view
|| !evaluation
) {
68 evaluation_comm
= (const struct lttng_evaluation_comm
*) src_view
->data
;
69 evaluation_size
+= sizeof(*evaluation_comm
);
71 switch ((enum lttng_condition_type
) evaluation_comm
->type
) {
72 case LTTNG_CONDITION_TYPE_BUFFER_USAGE_LOW
:
73 ret
= lttng_evaluation_buffer_usage_low_create_from_buffer(
74 &evaluation_view
, evaluation
);
78 evaluation_size
+= ret
;
80 case LTTNG_CONDITION_TYPE_BUFFER_USAGE_HIGH
:
81 ret
= lttng_evaluation_buffer_usage_high_create_from_buffer(
82 &evaluation_view
, evaluation
);
86 evaluation_size
+= ret
;
88 case LTTNG_CONDITION_TYPE_SESSION_CONSUMED_SIZE
:
89 ret
= lttng_evaluation_session_consumed_size_create_from_buffer(
90 &evaluation_view
, evaluation
);
94 evaluation_size
+= ret
;
96 case LTTNG_CONDITION_TYPE_SESSION_ROTATION_ONGOING
:
97 ret
= lttng_evaluation_session_rotation_ongoing_create_from_buffer(
98 &evaluation_view
, evaluation
);
102 evaluation_size
+= ret
;
104 case LTTNG_CONDITION_TYPE_SESSION_ROTATION_COMPLETED
:
105 ret
= lttng_evaluation_session_rotation_completed_create_from_buffer(
106 &evaluation_view
, evaluation
);
110 evaluation_size
+= ret
;
112 case LTTNG_CONDITION_TYPE_EVENT_RULE_HIT
:
114 assert(condition
->type
== LTTNG_CONDITION_TYPE_EVENT_RULE_HIT
);
115 ret
= lttng_evaluation_event_rule_create_from_buffer(
116 container_of(condition
,
117 struct lttng_condition_event_rule
,
119 &evaluation_view
, evaluation
);
123 evaluation_size
+= ret
;
126 ERR("Attempted to create evaluation of unknown type (%i)",
127 (int) evaluation_comm
->type
);
131 ret
= evaluation_size
;
136 enum lttng_condition_type
lttng_evaluation_get_type(
137 const struct lttng_evaluation
*evaluation
)
139 return evaluation
? evaluation
->type
: LTTNG_CONDITION_TYPE_UNKNOWN
;
142 void lttng_evaluation_destroy(struct lttng_evaluation
*evaluation
)
148 assert(evaluation
->destroy
);
149 evaluation
->destroy(evaluation
);