lib: graph: add "self" and some "private" APIs
[babeltrace.git] / 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
9d408fca 23#include <babeltrace/babeltrace.h>
0d8b4d8e 24#include <babeltrace/babeltrace-internal.h>
c2b71c92 25#include <plugins-common.h>
f6ccaed9 26#include <babeltrace/assert-internal.h>
c2b71c92
JG
27#include "dummy.h"
28
c2b71c92
JG
29void destroy_private_dummy_data(struct dummy *dummy)
30{
65300d60 31 bt_object_put_ref(dummy->notif_iter);
c2b71c92 32 g_free(dummy);
d94d92ac 33
c2b71c92
JG
34}
35
d94d92ac
PP
36BT_HIDDEN
37void dummy_finalize(struct bt_self_component_sink *comp)
c2b71c92
JG
38{
39 struct dummy *dummy;
40
d94d92ac
PP
41 BT_ASSERT(comp);
42 dummy = bt_self_component_get_data(
43 bt_self_component_sink_borrow_self_component(comp));
f6ccaed9 44 BT_ASSERT(dummy);
c2b71c92
JG
45 destroy_private_dummy_data(dummy);
46}
47
d94d92ac
PP
48BT_HIDDEN
49enum bt_self_component_status dummy_init(
50 struct bt_self_component_sink *component,
c2b71c92
JG
51 struct bt_value *params, UNUSED_VAR void *init_method_data)
52{
d94d92ac 53 enum bt_self_component_status ret;
c2b71c92
JG
54 struct dummy *dummy = g_new0(struct dummy, 1);
55
56 if (!dummy) {
d94d92ac 57 ret = BT_SELF_COMPONENT_STATUS_NOMEM;
c2b71c92
JG
58 goto end;
59 }
60
d94d92ac 61 ret = bt_self_component_sink_add_input_port(component,
147337a3 62 "in", NULL, NULL);
d94d92ac 63 if (ret != BT_SELF_COMPONENT_STATUS_OK) {
c2b71c92
JG
64 goto error;
65 }
d19348b6 66
d94d92ac
PP
67 bt_self_component_set_data(
68 bt_self_component_sink_borrow_self_component(component), dummy);
d19348b6
PP
69 goto end;
70
c2b71c92
JG
71error:
72 destroy_private_dummy_data(dummy);
d19348b6
PP
73
74end:
c2b71c92
JG
75 return ret;
76}
77
d94d92ac
PP
78BT_HIDDEN
79enum bt_self_component_status dummy_port_connected(
80 struct bt_self_component_sink *comp,
81 struct bt_self_component_port_input *self_port,
82 struct bt_port_output *other_port)
c2b71c92 83{
d94d92ac 84 enum bt_self_component_status status = BT_SELF_COMPONENT_STATUS_OK;
c2b71c92 85 struct dummy *dummy;
d94d92ac 86 struct bt_self_component_port_input_notification_iterator *iterator;
c2b71c92 87
d94d92ac
PP
88 dummy = bt_self_component_get_data(
89 bt_self_component_sink_borrow_self_component(comp));
f6ccaed9 90 BT_ASSERT(dummy);
d94d92ac
PP
91 iterator = bt_self_component_port_input_notification_iterator_create(
92 self_port);
93 if (!iterator) {
94 status = BT_SELF_COMPONENT_STATUS_NOMEM;
c2b71c92
JG
95 goto end;
96 }
97
65300d60 98 BT_OBJECT_MOVE_REF(dummy->notif_iter, iterator);
0d8b4d8e 99
c2b71c92 100end:
bf55043c 101 return status;
c2b71c92 102}
e0dfa761 103
d94d92ac
PP
104BT_HIDDEN
105enum bt_self_component_status dummy_consume(
106 struct bt_self_component_sink *component)
e0dfa761 107{
d94d92ac 108 enum bt_self_component_status ret = BT_SELF_COMPONENT_STATUS_OK;
d4393e08
PP
109 bt_notification_array notifs;
110 uint64_t count;
c2b71c92 111 struct dummy *dummy;
d19348b6 112 enum bt_notification_iterator_status it_ret;
d4393e08 113 uint64_t i;
e0dfa761 114
d94d92ac
PP
115 dummy = bt_self_component_get_data(
116 bt_self_component_sink_borrow_self_component(component));
f6ccaed9 117 BT_ASSERT(dummy);
e0dfa761 118
d19348b6 119 if (unlikely(!dummy->notif_iter)) {
d94d92ac 120 ret = BT_SELF_COMPONENT_STATUS_END;
d19348b6 121 goto end;
e0dfa761
PP
122 }
123
d19348b6 124 /* Consume one notification */
d94d92ac 125 it_ret = bt_self_component_port_input_notification_iterator_next(
d4393e08 126 dummy->notif_iter, &notifs, &count);
d19348b6 127 switch (it_ret) {
d4393e08 128 case BT_NOTIFICATION_ITERATOR_STATUS_OK:
d94d92ac 129 ret = BT_SELF_COMPONENT_STATUS_OK;
d4393e08
PP
130
131 for (i = 0; i < count; i++) {
65300d60 132 bt_object_put_ref(notifs[i]);
d4393e08
PP
133 }
134
135 break;
d19348b6 136 case BT_NOTIFICATION_ITERATOR_STATUS_AGAIN:
d94d92ac 137 ret = BT_SELF_COMPONENT_STATUS_AGAIN;
d19348b6
PP
138 goto end;
139 case BT_NOTIFICATION_ITERATOR_STATUS_END:
d94d92ac 140 ret = BT_SELF_COMPONENT_STATUS_END;
d19348b6 141 goto end;
d4393e08 142 case BT_NOTIFICATION_ITERATOR_STATUS_ERROR:
d94d92ac
PP
143 ret = BT_SELF_COMPONENT_STATUS_ERROR;
144 goto end;
145 case BT_NOTIFICATION_ITERATOR_STATUS_NOMEM:
146 ret = BT_SELF_COMPONENT_STATUS_NOMEM;
d4393e08 147 goto end;
d19348b6
PP
148 default:
149 break;
e0dfa761 150 }
d19348b6 151
e0dfa761 152end:
e0dfa761
PP
153 return ret;
154}
This page took 0.043991 seconds and 4 git commands to generate.