lib: notification iterator: transfer a batch of notifications
[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{
d19348b6 31 bt_put(dummy->notif_iter);
c2b71c92
JG
32 g_free(dummy);
33}
34
64cadc66 35void dummy_finalize(struct bt_private_component *component)
c2b71c92
JG
36{
37 struct dummy *dummy;
38
f6ccaed9 39 BT_ASSERT(component);
890882ef 40 dummy = bt_private_component_get_user_data(component);
f6ccaed9 41 BT_ASSERT(dummy);
c2b71c92
JG
42 destroy_private_dummy_data(dummy);
43}
44
890882ef 45enum bt_component_status dummy_init(struct bt_private_component *component,
c2b71c92
JG
46 struct bt_value *params, UNUSED_VAR void *init_method_data)
47{
48 enum bt_component_status ret;
49 struct dummy *dummy = g_new0(struct dummy, 1);
50
51 if (!dummy) {
52 ret = BT_COMPONENT_STATUS_NOMEM;
53 goto end;
54 }
55
147337a3
PP
56 ret = bt_private_component_sink_add_input_private_port(component,
57 "in", NULL, NULL);
58 if (ret != BT_COMPONENT_STATUS_OK) {
b9d103be
PP
59 goto end;
60 }
61
890882ef 62 ret = bt_private_component_set_user_data(component, dummy);
c2b71c92
JG
63 if (ret != BT_COMPONENT_STATUS_OK) {
64 goto error;
65 }
d19348b6
PP
66
67 goto end;
68
c2b71c92
JG
69error:
70 destroy_private_dummy_data(dummy);
d19348b6
PP
71
72end:
c2b71c92
JG
73 return ret;
74}
75
0d8b4d8e 76void dummy_port_connected(
890882ef 77 struct bt_private_component *component,
8f4799f7
PP
78 struct bt_private_port *self_port,
79 struct bt_port *other_port)
c2b71c92 80{
c2b71c92
JG
81 struct dummy *dummy;
82 struct bt_notification_iterator *iterator;
890882ef 83 struct bt_private_connection *connection;
73d5c1ad 84 enum bt_connection_status conn_status;
c2b71c92 85
890882ef 86 dummy = bt_private_component_get_user_data(component);
f6ccaed9 87 BT_ASSERT(dummy);
890882ef 88 connection = bt_private_port_get_private_connection(self_port);
f6ccaed9 89 BT_ASSERT(connection);
73d5c1ad 90 conn_status = bt_private_connection_create_notification_iterator(
f42867e2 91 connection, &iterator);
73d5c1ad 92 if (conn_status != BT_CONNECTION_STATUS_OK) {
0d8b4d8e 93 dummy->error = true;
c2b71c92
JG
94 goto end;
95 }
96
d19348b6 97 BT_MOVE(dummy->notif_iter, iterator);
0d8b4d8e 98
c2b71c92 99end:
72b913fb 100 bt_put(connection);
c2b71c92 101}
e0dfa761 102
890882ef 103enum bt_component_status dummy_consume(struct bt_private_component *component)
e0dfa761 104{
8812600c 105 enum bt_component_status ret = BT_COMPONENT_STATUS_OK;
d4393e08
PP
106 bt_notification_array notifs;
107 uint64_t count;
c2b71c92 108 struct dummy *dummy;
d19348b6 109 enum bt_notification_iterator_status it_ret;
d4393e08 110 uint64_t i;
e0dfa761 111
890882ef 112 dummy = bt_private_component_get_user_data(component);
f6ccaed9 113 BT_ASSERT(dummy);
e0dfa761 114
0d8b4d8e
PP
115 if (unlikely(dummy->error)) {
116 ret = BT_COMPONENT_STATUS_ERROR;
117 goto end;
118 }
119
d19348b6
PP
120 if (unlikely(!dummy->notif_iter)) {
121 ret = BT_COMPONENT_STATUS_END;
122 goto end;
e0dfa761
PP
123 }
124
d19348b6 125 /* Consume one notification */
07245ac2 126 it_ret = bt_private_connection_notification_iterator_next(
d4393e08 127 dummy->notif_iter, &notifs, &count);
d19348b6 128 switch (it_ret) {
d4393e08
PP
129 case BT_NOTIFICATION_ITERATOR_STATUS_OK:
130 ret = BT_COMPONENT_STATUS_OK;
131
132 for (i = 0; i < count; i++) {
133 bt_put(notifs[i]);
134 }
135
136 break;
d19348b6
PP
137 case BT_NOTIFICATION_ITERATOR_STATUS_AGAIN:
138 ret = BT_COMPONENT_STATUS_AGAIN;
139 goto end;
140 case BT_NOTIFICATION_ITERATOR_STATUS_END:
e0dfa761 141 ret = BT_COMPONENT_STATUS_END;
d19348b6 142 goto end;
d4393e08
PP
143 case BT_NOTIFICATION_ITERATOR_STATUS_ERROR:
144 ret = BT_COMPONENT_STATUS_ERROR;
145 goto end;
d19348b6
PP
146 default:
147 break;
e0dfa761 148 }
d19348b6 149
e0dfa761 150end:
e0dfa761
PP
151 return ret;
152}
This page took 0.051832 seconds and 4 git commands to generate.