bt2: by-pass distutils changed file check
[babeltrace.git] / include / babeltrace / graph / component-internal.h
CommitLineData
33b34c43
PP
1#ifndef BABELTRACE_COMPONENT_COMPONENT_INTERNAL_H
2#define BABELTRACE_COMPONENT_COMPONENT_INTERNAL_H
90354d3a
JG
3
4/*
633edee0 5 * BabelTrace - Component internal
90354d3a
JG
6 *
7 * Copyright 2015 Jérémie Galarneau <jeremie.galarneau@efficios.com>
8 *
9 * Author: Jérémie Galarneau <jeremie.galarneau@efficios.com>
10 *
11 * Permission is hereby granted, free of charge, to any person obtaining a copy
12 * of this software and associated documentation files (the "Software"), to deal
13 * in the Software without restriction, including without limitation the rights
14 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
15 * copies of the Software, and to permit persons to whom the Software is
16 * furnished to do so, subject to the following conditions:
17 *
18 * The above copyright notice and this permission notice shall be included in
19 * all copies or substantial portions of the Software.
20 *
21 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
22 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
23 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
24 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
25 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
26 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
27 * SOFTWARE.
28 */
29
0db5ca2c 30#include <babeltrace/babeltrace-internal.h>
b2e0c907
PP
31#include <babeltrace/graph/component.h>
32#include <babeltrace/graph/component-class-internal.h>
33#include <babeltrace/graph/port-internal.h>
b8a06801 34#include <babeltrace/object-internal.h>
c55a9f58 35#include <babeltrace/types.h>
f6ccaed9 36#include <babeltrace/assert-internal.h>
0db5ca2c 37#include <glib.h>
38d02a17 38#include <stdio.h>
90354d3a 39
3230ee6b
PP
40typedef void (*bt_component_destroy_listener_func)(
41 struct bt_component *class, void *data);
42
43struct bt_component_destroy_listener {
44 bt_component_destroy_listener_func func;
45 void *data;
46};
47
633edee0 48struct bt_component {
b8a06801 49 struct bt_object base;
fb2dcc52 50 struct bt_component_class *class;
0db5ca2c 51 GString *name;
584e4e78 52
72b913fb 53 /*
d3e4dcd8
PP
54 * Internal destroy function specific to a source, filter, or
55 * sink component object.
56 */
890882ef 57 void (*destroy)(struct bt_component *);
d3e4dcd8 58
72b913fb 59 /* User-defined data */
0777b693 60 void *user_data;
fec2a9f2 61
72b913fb
PP
62 /* Input and output ports (weak references) */
63 GPtrArray *input_ports;
64 GPtrArray *output_ports;
3230ee6b
PP
65
66 /* Array of struct bt_component_destroy_listener */
67 GArray *destroy_listeners;
36712f1d
PP
68
69 bool initialized;
72b913fb 70};
38b48196 71
890882ef 72static inline
6d137876 73struct bt_component *bt_component_borrow_from_private(
890882ef
PP
74 struct bt_private_component *private_component)
75{
76 return (void *) private_component;
77}
78
79static inline
80struct bt_private_component *bt_private_component_from_component(
81 struct bt_component *component)
82{
83 return (void *) component;
84}
5645cd95 85
4dc8c91f
PP
86static inline
87struct bt_graph *bt_component_borrow_graph(struct bt_component *comp)
88{
f6ccaed9 89 BT_ASSERT(comp);
4dc8c91f
PP
90 return (void *) comp->base.parent;
91}
92
36712f1d
PP
93BT_HIDDEN
94enum bt_component_status bt_component_create(
95 struct bt_component_class *component_class,
96 const char *name, struct bt_component **component);
97
2d41b99e 98BT_HIDDEN
72b913fb 99enum bt_component_status bt_component_accept_port_connection(
8f4799f7
PP
100 struct bt_component *component, struct bt_port *self_port,
101 struct bt_port *other_port);
72b913fb 102
0d8b4d8e
PP
103BT_HIDDEN
104void bt_component_port_connected(struct bt_component *comp,
105 struct bt_port *self_port, struct bt_port *other_port);
106
72b913fb
PP
107BT_HIDDEN
108void bt_component_port_disconnected(struct bt_component *comp,
109 struct bt_port *port);
2d41b99e 110
366e034f 111BT_HIDDEN
f60c8b34 112void bt_component_set_graph(struct bt_component *component,
366e034f
JG
113 struct bt_graph *graph);
114
115BT_HIDDEN
544d0515 116int64_t bt_component_get_input_port_count(struct bt_component *comp);
366e034f
JG
117
118BT_HIDDEN
544d0515 119int64_t bt_component_get_output_port_count(struct bt_component *comp);
366e034f
JG
120
121BT_HIDDEN
9ac68eb1
PP
122struct bt_port *bt_component_get_input_port_by_index(struct bt_component *comp,
123 uint64_t index);
366e034f
JG
124
125BT_HIDDEN
9ac68eb1
PP
126struct bt_port *bt_component_get_output_port_by_index(struct bt_component *comp,
127 uint64_t index);
366e034f
JG
128
129BT_HIDDEN
9ac68eb1 130struct bt_port *bt_component_get_input_port_by_name(struct bt_component *comp,
72b913fb 131 const char *name);
366e034f
JG
132
133BT_HIDDEN
9ac68eb1 134struct bt_port *bt_component_get_output_port_by_name(struct bt_component *comp,
366e034f
JG
135 const char *name);
136
72b913fb
PP
137BT_HIDDEN
138struct bt_port *bt_component_add_input_port(
3e9b0023
PP
139 struct bt_component *component, const char *name,
140 void *user_data);
72b913fb
PP
141
142BT_HIDDEN
143struct bt_port *bt_component_add_output_port(
3e9b0023
PP
144 struct bt_component *component, const char *name,
145 void *user_data);
72b913fb
PP
146
147BT_HIDDEN
148enum bt_component_status bt_component_remove_port(
149 struct bt_component *component, struct bt_port *port);
150
3230ee6b
PP
151BT_HIDDEN
152void bt_component_add_destroy_listener(struct bt_component *component,
153 bt_component_destroy_listener_func func, void *data);
154
155BT_HIDDEN
156void bt_component_remove_destroy_listener(struct bt_component *component,
157 bt_component_destroy_listener_func func, void *data);
158
262e5473
PP
159static inline
160const char *bt_component_status_string(enum bt_component_status status)
161{
162 switch (status) {
163 case BT_COMPONENT_STATUS_OK:
164 return "BT_COMPONENT_STATUS_OK";
165 case BT_COMPONENT_STATUS_END:
166 return "BT_COMPONENT_STATUS_END";
167 case BT_COMPONENT_STATUS_AGAIN:
168 return "BT_COMPONENT_STATUS_AGAIN";
169 case BT_COMPONENT_STATUS_REFUSE_PORT_CONNECTION:
170 return "BT_COMPONENT_STATUS_REFUSE_PORT_CONNECTION";
171 case BT_COMPONENT_STATUS_ERROR:
172 return "BT_COMPONENT_STATUS_ERROR";
173 case BT_COMPONENT_STATUS_UNSUPPORTED:
174 return "BT_COMPONENT_STATUS_UNSUPPORTED";
175 case BT_COMPONENT_STATUS_INVALID:
176 return "BT_COMPONENT_STATUS_INVALID";
177 case BT_COMPONENT_STATUS_NOMEM:
178 return "BT_COMPONENT_STATUS_NOMEM";
179 case BT_COMPONENT_STATUS_NOT_FOUND:
180 return "BT_COMPONENT_STATUS_NOT_FOUND";
bd7cc15b
PP
181 case BT_COMPONENT_STATUS_GRAPH_IS_CANCELED:
182 return "BT_COMPONENT_STATUS_GRAPH_IS_CANCELED";
262e5473
PP
183 default:
184 return "(unknown)";
185 }
186}
187
33b34c43 188#endif /* BABELTRACE_COMPONENT_COMPONENT_INTERNAL_H */
This page took 0.045977 seconds and 4 git commands to generate.