lib: add bt_{graph,query_executor}_add_interrupter()
[babeltrace.git] / include / babeltrace2 / graph / graph.h
CommitLineData
924dc299
PP
1#ifndef BABELTRACE2_GRAPH_GRAPH_H
2#define BABELTRACE2_GRAPH_GRAPH_H
c0418dd9
JG
3
4/*
bbb7b5f0 5 * Copyright (c) 2010-2019 EfficiOS Inc. and Linux Foundation
c0418dd9 6 *
c0418dd9
JG
7 * Permission is hereby granted, free of charge, to any person obtaining a copy
8 * of this software and associated documentation files (the "Software"), to deal
9 * in the Software without restriction, including without limitation the rights
10 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
11 * copies of the Software, and to permit persons to whom the Software is
12 * furnished to do so, subject to the following conditions:
13 *
14 * The above copyright notice and this permission notice shall be included in
15 * all copies or substantial portions of the Software.
16 *
17 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
18 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
19 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
20 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
21 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
22 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
23 * SOFTWARE.
24 */
25
4fa90f32
PP
26#ifndef __BT_IN_BABELTRACE_H
27# error "Please include <babeltrace2/babeltrace.h> instead."
28#endif
29
3fadfbc0 30#include <babeltrace2/types.h>
e874da19
PP
31#include <babeltrace2/logging.h>
32
c0418dd9
JG
33#ifdef __cplusplus
34extern "C" {
35#endif
36
d24d5663
PP
37typedef enum bt_graph_listener_func_status {
38 BT_GRAPH_LISTENER_FUNC_STATUS_OK = __BT_FUNC_STATUS_OK,
39 BT_GRAPH_LISTENER_FUNC_STATUS_ERROR = __BT_FUNC_STATUS_ERROR,
40 BT_GRAPH_LISTENER_FUNC_STATUS_MEMORY_ERROR = __BT_FUNC_STATUS_MEMORY_ERROR,
41} bt_graph_listener_func_status;
8cc56726 42
d24d5663 43typedef bt_graph_listener_func_status
8cc56726 44(*bt_graph_filter_component_input_port_added_listener_func)(
b19ff26f
PP
45 const bt_component_filter *component,
46 const bt_port_input *port, void *data);
0d72b8c3 47
d24d5663 48typedef bt_graph_listener_func_status
8cc56726 49(*bt_graph_sink_component_input_port_added_listener_func)(
b19ff26f
PP
50 const bt_component_sink *component,
51 const bt_port_input *port, void *data);
0d72b8c3 52
d24d5663 53typedef bt_graph_listener_func_status
8cc56726 54(*bt_graph_source_component_output_port_added_listener_func)(
b19ff26f
PP
55 const bt_component_source *component,
56 const bt_port_output *port, void *data);
0d72b8c3 57
d24d5663 58typedef bt_graph_listener_func_status
8cc56726 59(*bt_graph_filter_component_output_port_added_listener_func)(
b19ff26f
PP
60 const bt_component_filter *component,
61 const bt_port_output *port, void *data);
0d72b8c3 62
d24d5663 63typedef bt_graph_listener_func_status
8cc56726 64(*bt_graph_source_filter_component_ports_connected_listener_func)(
b19ff26f
PP
65 const bt_component_source *source_component,
66 const bt_component_filter *filter_component,
67 const bt_port_output *upstream_port,
68 const bt_port_input *downstream_port, void *data);
0d72b8c3 69
d24d5663 70typedef bt_graph_listener_func_status
8cc56726 71(*bt_graph_source_sink_component_ports_connected_listener_func)(
b19ff26f
PP
72 const bt_component_source *source_component,
73 const bt_component_sink *sink_component,
74 const bt_port_output *upstream_port,
75 const bt_port_input *downstream_port, void *data);
0d72b8c3 76
d24d5663 77typedef bt_graph_listener_func_status
8cc56726 78(*bt_graph_filter_filter_component_ports_connected_listener_func)(
9c0a126a
PP
79 const bt_component_filter *filter_component_upstream,
80 const bt_component_filter *filter_component_downstream,
81 const bt_port_output *upstream_port,
82 const bt_port_input *downstream_port,
83 void *data);
84
d24d5663 85typedef bt_graph_listener_func_status
8cc56726 86(*bt_graph_filter_sink_component_ports_connected_listener_func)(
b19ff26f
PP
87 const bt_component_filter *filter_component,
88 const bt_component_sink *sink_component,
89 const bt_port_output *upstream_port,
90 const bt_port_input *downstream_port, void *data);
0d72b8c3 91
0d72b8c3
PP
92typedef void (* bt_graph_listener_removed_func)(void *data);
93
b19ff26f 94extern bt_graph *bt_graph_create(void);
0d72b8c3 95
d24d5663
PP
96typedef enum bt_graph_add_component_status {
97 BT_GRAPH_ADD_COMPONENT_STATUS_OK = __BT_FUNC_STATUS_OK,
98 BT_GRAPH_ADD_COMPONENT_STATUS_ERROR = __BT_FUNC_STATUS_ERROR,
99 BT_GRAPH_ADD_COMPONENT_STATUS_MEMORY_ERROR = __BT_FUNC_STATUS_MEMORY_ERROR,
100} bt_graph_add_component_status;
101
102extern bt_graph_add_component_status
103bt_graph_add_source_component(bt_graph *graph,
b19ff26f
PP
104 const bt_component_class_source *component_class,
105 const char *name, const bt_value *params,
e874da19 106 bt_logging_level log_level, const bt_component_source **component);
0d72b8c3 107
d24d5663
PP
108extern bt_graph_add_component_status
109bt_graph_add_source_component_with_init_method_data(
b19ff26f
PP
110 bt_graph *graph,
111 const bt_component_class_source *component_class,
112 const char *name, const bt_value *params,
e874da19 113 void *init_method_data, bt_logging_level log_level,
b19ff26f 114 const bt_component_source **component);
0d72b8c3 115
d24d5663
PP
116extern bt_graph_add_component_status
117bt_graph_add_filter_component(bt_graph *graph,
b19ff26f
PP
118 const bt_component_class_filter *component_class,
119 const char *name, const bt_value *params,
e874da19 120 bt_logging_level log_level,
b19ff26f 121 const bt_component_filter **component);
0d72b8c3 122
d24d5663
PP
123extern bt_graph_add_component_status
124bt_graph_add_filter_component_with_init_method_data(
b19ff26f
PP
125 bt_graph *graph,
126 const bt_component_class_filter *component_class,
127 const char *name, const bt_value *params,
e874da19 128 void *init_method_data, bt_logging_level log_level,
b19ff26f 129 const bt_component_filter **component);
0d72b8c3 130
d24d5663
PP
131extern bt_graph_add_component_status
132bt_graph_add_sink_component(
4cdfc5e8 133 bt_graph *graph, const bt_component_class_sink *component_class,
b19ff26f 134 const char *name, const bt_value *params,
e874da19 135 bt_logging_level log_level,
b19ff26f 136 const bt_component_sink **component);
0d72b8c3 137
d24d5663
PP
138extern bt_graph_add_component_status
139bt_graph_add_sink_component_with_init_method_data(
4cdfc5e8 140 bt_graph *graph, const bt_component_class_sink *component_class,
b19ff26f 141 const char *name, const bt_value *params,
e874da19 142 void *init_method_data, bt_logging_level log_level,
b19ff26f 143 const bt_component_sink **component);
0d72b8c3 144
d24d5663
PP
145typedef enum bt_graph_connect_ports_status {
146 BT_GRAPH_CONNECT_PORTS_STATUS_OK = __BT_FUNC_STATUS_OK,
147 BT_GRAPH_CONNECT_PORTS_STATUS_ERROR = __BT_FUNC_STATUS_ERROR,
d24d5663
PP
148 BT_GRAPH_CONNECT_PORTS_STATUS_MEMORY_ERROR = __BT_FUNC_STATUS_MEMORY_ERROR,
149} bt_graph_connect_ports_status;
150
151extern bt_graph_connect_ports_status bt_graph_connect_ports(bt_graph *graph,
b19ff26f
PP
152 const bt_port_output *upstream,
153 const bt_port_input *downstream,
154 const bt_connection **connection);
0d72b8c3 155
d24d5663
PP
156typedef enum bt_graph_run_status {
157 BT_GRAPH_RUN_STATUS_OK = __BT_FUNC_STATUS_OK,
158 BT_GRAPH_RUN_STATUS_ERROR = __BT_FUNC_STATUS_ERROR,
159 BT_GRAPH_RUN_STATUS_MEMORY_ERROR = __BT_FUNC_STATUS_MEMORY_ERROR,
160 BT_GRAPH_RUN_STATUS_AGAIN = __BT_FUNC_STATUS_AGAIN,
161 BT_GRAPH_RUN_STATUS_END = __BT_FUNC_STATUS_END,
d24d5663
PP
162} bt_graph_run_status;
163
164extern bt_graph_run_status bt_graph_run(bt_graph *graph);
165
166typedef enum bt_graph_consume_status {
167 BT_GRAPH_CONSUME_STATUS_OK = __BT_FUNC_STATUS_OK,
168 BT_GRAPH_CONSUME_STATUS_ERROR = __BT_FUNC_STATUS_ERROR,
169 BT_GRAPH_CONSUME_STATUS_MEMORY_ERROR = __BT_FUNC_STATUS_MEMORY_ERROR,
170 BT_GRAPH_CONSUME_STATUS_AGAIN = __BT_FUNC_STATUS_AGAIN,
171 BT_GRAPH_CONSUME_STATUS_END = __BT_FUNC_STATUS_END,
d24d5663
PP
172} bt_graph_consume_status;
173
174extern bt_graph_consume_status bt_graph_consume(bt_graph *graph);
175
176typedef enum bt_graph_add_listener_status {
177 BT_GRAPH_ADD_LISTENER_STATUS_OK = __BT_FUNC_STATUS_OK,
178 BT_GRAPH_ADD_LISTENER_STATUS_MEMORY_ERROR = __BT_FUNC_STATUS_MEMORY_ERROR,
179} bt_graph_add_listener_status;
180
181extern bt_graph_add_listener_status
182bt_graph_add_filter_component_input_port_added_listener(
b19ff26f 183 bt_graph *graph,
0d72b8c3
PP
184 bt_graph_filter_component_input_port_added_listener_func listener,
185 bt_graph_listener_removed_func listener_removed, void *data,
186 int *listener_id);
187
d24d5663
PP
188extern bt_graph_add_listener_status
189bt_graph_add_sink_component_input_port_added_listener(
b19ff26f 190 bt_graph *graph,
0d72b8c3
PP
191 bt_graph_sink_component_input_port_added_listener_func listener,
192 bt_graph_listener_removed_func listener_removed, void *data,
193 int *listener_id);
194
d24d5663
PP
195extern bt_graph_add_listener_status
196bt_graph_add_source_component_output_port_added_listener(
b19ff26f 197 bt_graph *graph,
0d72b8c3
PP
198 bt_graph_source_component_output_port_added_listener_func listener,
199 bt_graph_listener_removed_func listener_removed, void *data,
200 int *listener_id);
201
d24d5663
PP
202extern bt_graph_add_listener_status
203bt_graph_add_filter_component_output_port_added_listener(
b19ff26f 204 bt_graph *graph,
0d72b8c3
PP
205 bt_graph_filter_component_output_port_added_listener_func listener,
206 bt_graph_listener_removed_func listener_removed, void *data,
207 int *listener_id);
208
d24d5663 209extern bt_graph_add_listener_status
0d72b8c3 210bt_graph_add_source_filter_component_ports_connected_listener(
b19ff26f 211 bt_graph *graph,
0d72b8c3
PP
212 bt_graph_source_filter_component_ports_connected_listener_func listener,
213 bt_graph_listener_removed_func listener_removed, void *data,
214 int *listener_id);
215
d24d5663 216extern bt_graph_add_listener_status
9c0a126a
PP
217bt_graph_add_filter_filter_component_ports_connected_listener(
218 bt_graph *graph,
219 bt_graph_filter_filter_component_ports_connected_listener_func listener,
220 bt_graph_listener_removed_func listener_removed, void *data,
221 int *listener_id);
222
d24d5663 223extern bt_graph_add_listener_status
0d72b8c3 224bt_graph_add_source_sink_component_ports_connected_listener(
b19ff26f 225 bt_graph *graph,
0d72b8c3
PP
226 bt_graph_source_sink_component_ports_connected_listener_func listener,
227 bt_graph_listener_removed_func listener_removed, void *data,
228 int *listener_id);
229
d24d5663 230extern bt_graph_add_listener_status
0d72b8c3 231bt_graph_add_filter_sink_component_ports_connected_listener(
b19ff26f 232 bt_graph *graph,
0d72b8c3
PP
233 bt_graph_filter_sink_component_ports_connected_listener_func listener,
234 bt_graph_listener_removed_func listener_removed, void *data,
235 int *listener_id);
236
9b4f9b42
PP
237typedef enum bt_graph_add_interrupter_status {
238 BT_GRAPH_ADD_INTERRUPTER_STATUS_OK = __BT_FUNC_STATUS_OK,
239 BT_GRAPH_ADD_INTERRUPTER_MEMORY_ERROR = __BT_FUNC_STATUS_MEMORY_ERROR,
240} bt_graph_add_interrupter_status;
d24d5663 241
9b4f9b42
PP
242extern bt_graph_add_interrupter_status bt_graph_add_interrupter(bt_graph *graph,
243 const bt_interrupter *interrupter);
244
245extern void bt_graph_interrupt(bt_graph *graph);
202a3a13 246
c0418dd9
JG
247#ifdef __cplusplus
248}
249#endif
250
924dc299 251#endif /* BABELTRACE2_GRAPH_GRAPH_H */
This page took 0.067334 seconds and 4 git commands to generate.