Fix -Wmissing-prototypes/-Wmissing-declarations warnings
[babeltrace.git] / src / plugins / utils / dummy / dummy.c
CommitLineData
e0dfa761
PP
1/*
2 * Copyright 2017 Philippe Proulx <pproulx@efficios.com>
3 *
4 * Permission is hereby granted, free of charge, to any person obtaining a copy
5 * of this software and associated documentation files (the "Software"), to deal
6 * in the Software without restriction, including without limitation the rights
7 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
8 * copies of the Software, and to permit persons to whom the Software is
9 * furnished to do so, subject to the following conditions:
10 *
11 * The above copyright notice and this permission notice shall be included in
12 * all copies or substantial portions of the Software.
13 *
14 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
15 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
16 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
17 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
18 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
19 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
20 * SOFTWARE.
21 */
22
b7045dd7
SM
23#define BT_COMP_LOG_SELF_COMP self_comp
24#define BT_LOG_OUTPUT_LEVEL log_level
25#define BT_LOG_TAG "PLUGIN/SINK.UTILS.DUMMY"
26#include "logging/comp-logging.h"
27
3fadfbc0 28#include <babeltrace2/babeltrace.h>
91d81473 29#include "common/macros.h"
578e048b 30#include "common/assert.h"
c2b71c92 31#include "dummy.h"
b7045dd7 32#include "plugins/common/param-validation/param-validation.h"
c2b71c92 33
5badd463
PP
34static
35const char * const in_port_name = "in";
36
7c7301d5 37static
c2b71c92
JG
38void destroy_private_dummy_data(struct dummy *dummy)
39{
d6e69534 40 bt_self_component_port_input_message_iterator_put_ref(dummy->msg_iter);
c2b71c92 41 g_free(dummy);
d94d92ac 42
c2b71c92
JG
43}
44
d94d92ac 45BT_HIDDEN
b19ff26f 46void dummy_finalize(bt_self_component_sink *comp)
c2b71c92
JG
47{
48 struct dummy *dummy;
49
d94d92ac
PP
50 BT_ASSERT(comp);
51 dummy = bt_self_component_get_data(
707b7d35 52 bt_self_component_sink_as_self_component(comp));
f6ccaed9 53 BT_ASSERT(dummy);
c2b71c92
JG
54 destroy_private_dummy_data(dummy);
55}
56
b7045dd7
SM
57struct bt_param_validation_map_value_entry_descr dummy_params[] = {
58 BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_END
59};
60
d94d92ac 61BT_HIDDEN
21a9f056 62bt_component_class_initialize_method_status dummy_init(
b7045dd7 63 bt_self_component_sink *self_comp_sink,
59225a3e 64 bt_self_component_sink_configuration *config,
b19ff26f 65 const bt_value *params,
c88dd1cb 66 __attribute__((unused)) void *init_method_data)
c2b71c92 67{
b7045dd7
SM
68 bt_self_component *self_comp =
69 bt_self_component_sink_as_self_component(self_comp_sink);
70 const bt_component *comp = bt_self_component_as_component(self_comp);
71 bt_logging_level log_level = bt_component_get_logging_level(comp);
72 bt_component_class_initialize_method_status status;
d24d5663 73 bt_self_component_add_port_status add_port_status;
c2b71c92 74 struct dummy *dummy = g_new0(struct dummy, 1);
b7045dd7
SM
75 enum bt_param_validation_status validation_status;
76 gchar *validate_error = NULL;
c2b71c92
JG
77
78 if (!dummy) {
21a9f056 79 status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR;
c2b71c92
JG
80 goto end;
81 }
82
b7045dd7
SM
83 validation_status = bt_param_validation_validate(params,
84 dummy_params, &validate_error);
85 if (validation_status == BT_PARAM_VALIDATION_STATUS_MEMORY_ERROR) {
86 status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR;
87 goto error;
88 } else if (validation_status == BT_PARAM_VALIDATION_STATUS_VALIDATION_ERROR) {
21a9f056 89 status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_ERROR;
b7045dd7 90 BT_COMP_LOGE_APPEND_CAUSE(self_comp, "%s", validate_error);
c2b71c92 91 goto error;
b7045dd7
SM
92 }
93
94 add_port_status = bt_self_component_sink_add_input_port(self_comp_sink,
95 "in", NULL, NULL);
96 if (add_port_status != BT_SELF_COMPONENT_ADD_PORT_STATUS_OK) {
97 status = (int) add_port_status;
d24d5663 98 goto error;
c2b71c92 99 }
d19348b6 100
b7045dd7
SM
101 bt_self_component_set_data(self_comp, dummy);
102
103 status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_OK;
d19348b6
PP
104 goto end;
105
c2b71c92
JG
106error:
107 destroy_private_dummy_data(dummy);
d19348b6
PP
108
109end:
b7045dd7
SM
110 g_free(validate_error);
111
d24d5663 112 return status;
c2b71c92
JG
113}
114
d94d92ac 115BT_HIDDEN
d24d5663 116bt_component_class_sink_graph_is_configured_method_status dummy_graph_is_configured(
5badd463 117 bt_self_component_sink *comp)
c2b71c92 118{
e803df70
SM
119 bt_component_class_sink_graph_is_configured_method_status status;
120 bt_self_component_port_input_message_iterator_create_from_sink_component_status
121 msg_iter_status;
c2b71c92 122 struct dummy *dummy;
d6e69534 123 bt_self_component_port_input_message_iterator *iterator;
c2b71c92 124
d94d92ac 125 dummy = bt_self_component_get_data(
707b7d35 126 bt_self_component_sink_as_self_component(comp));
f6ccaed9 127 BT_ASSERT(dummy);
e803df70 128 msg_iter_status = bt_self_component_port_input_message_iterator_create_from_sink_component(
ca02df0a 129 comp, bt_self_component_sink_borrow_input_port_by_name(comp,
e803df70
SM
130 in_port_name), &iterator);
131 if (msg_iter_status != BT_SELF_COMPONENT_PORT_INPUT_MESSAGE_ITERATOR_CREATE_FROM_SINK_COMPONENT_STATUS_OK) {
132 status = (int) msg_iter_status;
c2b71c92
JG
133 goto end;
134 }
135
d6e69534
PP
136 BT_SELF_COMPONENT_PORT_INPUT_MESSAGE_ITERATOR_MOVE_REF(
137 dummy->msg_iter, iterator);
0d8b4d8e 138
e803df70
SM
139 status = BT_COMPONENT_CLASS_SINK_GRAPH_IS_CONFIGURED_METHOD_STATUS_OK;
140
c2b71c92 141end:
bf55043c 142 return status;
c2b71c92 143}
e0dfa761 144
d94d92ac 145BT_HIDDEN
d24d5663 146bt_component_class_sink_consume_method_status dummy_consume(
b19ff26f 147 bt_self_component_sink *component)
e0dfa761 148{
d24d5663
PP
149 bt_component_class_sink_consume_method_status status =
150 BT_COMPONENT_CLASS_SINK_CONSUME_METHOD_STATUS_OK;
d6e69534 151 bt_message_array_const msgs;
d4393e08 152 uint64_t count;
c2b71c92 153 struct dummy *dummy;
d24d5663 154 bt_message_iterator_next_status next_status;
d4393e08 155 uint64_t i;
e0dfa761 156
d94d92ac 157 dummy = bt_self_component_get_data(
707b7d35 158 bt_self_component_sink_as_self_component(component));
98b15851 159 BT_ASSERT_DBG(dummy);
e0dfa761 160
91d81473 161 if (G_UNLIKELY(!dummy->msg_iter)) {
d24d5663 162 status = BT_COMPONENT_CLASS_SINK_CONSUME_METHOD_STATUS_END;
d19348b6 163 goto end;
e0dfa761
PP
164 }
165
d6e69534 166 /* Consume one message */
d24d5663 167 next_status = bt_self_component_port_input_message_iterator_next(
d6e69534 168 dummy->msg_iter, &msgs, &count);
d24d5663
PP
169 switch (next_status) {
170 case BT_MESSAGE_ITERATOR_NEXT_STATUS_OK:
171 status = BT_COMPONENT_CLASS_SINK_CONSUME_METHOD_STATUS_OK;
d4393e08
PP
172
173 for (i = 0; i < count; i++) {
d6e69534 174 bt_message_put_ref(msgs[i]);
d4393e08
PP
175 }
176
177 break;
d24d5663
PP
178 case BT_MESSAGE_ITERATOR_NEXT_STATUS_AGAIN:
179 status = BT_COMPONENT_CLASS_SINK_CONSUME_METHOD_STATUS_AGAIN;
d19348b6 180 goto end;
d24d5663
PP
181 case BT_MESSAGE_ITERATOR_NEXT_STATUS_END:
182 status = BT_COMPONENT_CLASS_SINK_CONSUME_METHOD_STATUS_END;
d19348b6 183 goto end;
d24d5663
PP
184 case BT_MESSAGE_ITERATOR_NEXT_STATUS_ERROR:
185 status = BT_COMPONENT_CLASS_SINK_CONSUME_METHOD_STATUS_ERROR;
d94d92ac 186 goto end;
d24d5663
PP
187 case BT_MESSAGE_ITERATOR_NEXT_STATUS_MEMORY_ERROR:
188 status = BT_COMPONENT_CLASS_SINK_CONSUME_METHOD_STATUS_MEMORY_ERROR;
d4393e08 189 goto end;
d19348b6
PP
190 default:
191 break;
e0dfa761 192 }
d19348b6 193
e0dfa761 194end:
d24d5663 195 return status;
e0dfa761 196}
This page took 0.065886 seconds and 4 git commands to generate.