projects / babeltrace.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
bt2: Adapt test_graph.py and make it pass
[babeltrace.git] / bindings / python / bt2 / bt2 / native_bt_graph.i
CommitLineData
6945df9a
SM		 1/*
2 * The MIT License (MIT)
3 *
4 * Copyright (c) 2017 Philippe Proulx <pproulx@efficios.com>
5 *
6 * Permission is hereby granted, free of charge, to any person obtaining a copy
7 * of this software and associated documentation files (the "Software"), to deal
8 * in the Software without restriction, including without limitation the rights
9 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
10 * copies of the Software, and to permit persons to whom the Software is
11 * furnished to do so, subject to the following conditions:
12 *
13 * The above copyright notice and this permission notice shall be included in
14 * all copies or substantial portions of the Software.
15 *
16 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
19 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
22 * THE SOFTWARE.
23 */
24
25/* Output argument typemap for connection output (always appends) */
26%typemap(in, numinputs=0)
27 (const bt_connection **BTOUTCONN)
28 (bt_connection *temp_conn = NULL) {
29 $1 = &temp_conn;
30}
31
32%typemap(argout)
33 (const bt_connection **BTOUTCONN) {
34 if (*$1) {
35 /* SWIG_Python_AppendOutput() steals the created object */
36 $result = SWIG_Python_AppendOutput($result,
37 SWIG_NewPointerObj(SWIG_as_voidptr(*$1),
38 SWIGTYPE_p_bt_connection, 0));
39 } else {
40 /* SWIG_Python_AppendOutput() steals Py_None */
41 Py_INCREF(Py_None);
42 $result = SWIG_Python_AppendOutput($result, Py_None);
43 }
44}
45
46/* Output argument typemap for component output (always appends) */
47%typemap(in, numinputs=0)
48 (const bt_component_source **OUT)
49 (bt_component_source *temp_comp = NULL) {
50 $1 = &temp_comp;
51}
52
53%typemap(in, numinputs=0)
54 (const bt_component_filter **OUT)
55 (bt_component_filter *temp_comp = NULL) {
56 $1 = &temp_comp;
57}
58
59%typemap(in, numinputs=0)
60 (const bt_component_sink **OUT)
61 (bt_component_sink *temp_comp = NULL) {
62 $1 = &temp_comp;
63}
64
65%typemap(argout) (const bt_component_source **OUT) {
66 if (*$1) {
67 /* SWIG_Python_AppendOutput() steals the created object */
68 $result = SWIG_Python_AppendOutput($result,
69 SWIG_NewPointerObj(SWIG_as_voidptr(*$1),
70 SWIGTYPE_p_bt_component_source, 0));
71 } else {
72 /* SWIG_Python_AppendOutput() steals Py_None */
73 Py_INCREF(Py_None);
74 $result = SWIG_Python_AppendOutput($result, Py_None);
75 }
76}
77
78%typemap(argout) (const bt_component_filter **OUT) {
79 if (*$1) {
80 /* SWIG_Python_AppendOutput() steals the created object */
81 $result = SWIG_Python_AppendOutput($result,
82 SWIG_NewPointerObj(SWIG_as_voidptr(*$1),
83 SWIGTYPE_p_bt_component_filter, 0));
84 } else {
85 /* SWIG_Python_AppendOutput() steals Py_None */
86 Py_INCREF(Py_None);
87 $result = SWIG_Python_AppendOutput($result, Py_None);
88 }
89}
90
91%typemap(argout) (const bt_component_sink **OUT) {
92 if (*$1) {
93 /* SWIG_Python_AppendOutput() steals the created object */
94 $result = SWIG_Python_AppendOutput($result,
95 SWIG_NewPointerObj(SWIG_as_voidptr(*$1),
96 SWIGTYPE_p_bt_component_sink, 0));
97 } else {
98 /* SWIG_Python_AppendOutput() steals Py_None */
99 Py_INCREF(Py_None);
100 $result = SWIG_Python_AppendOutput($result, Py_None);
101 }
102}
103
104/* From graph-const.h */
105
106typedef enum bt_graph_status {
107 BT_GRAPH_STATUS_OK = 0,
108 BT_GRAPH_STATUS_END = 1,
109 BT_GRAPH_STATUS_AGAIN = 11,
110 BT_GRAPH_STATUS_COMPONENT_REFUSES_PORT_CONNECTION = 111,
111 BT_GRAPH_STATUS_CANCELED = 125,
112 BT_GRAPH_STATUS_ERROR = -1,
113 BT_GRAPH_STATUS_NOMEM = -12,
114} bt_graph_status;
115
116extern bt_bool bt_graph_is_canceled(const bt_graph *graph);
117
118extern void bt_graph_get_ref(const bt_graph *graph);
119
120extern void bt_graph_put_ref(const bt_graph *graph);
121
122/* From graph.h */
123
8cc56726
SM		 124typedef enum bt_graph_listener_status {
125 BT_GRAPH_LISTENER_STATUS_OK = 0,
126 BT_GRAPH_LISTENER_STATUS_ERROR = -1,
127 BT_GRAPH_LISTENER_STATUS_NOMEM = -12,
128} bt_graph_listener_status;
129
130
131typedef bt_graph_listener_status
132(*bt_graph_filter_component_input_port_added_listener_func)(
6945df9a
SM		 133 const bt_component_filter *component,
134 const bt_port_input *port, void *data);
135
8cc56726
SM		 136typedef bt_graph_listener_status
137(*bt_graph_sink_component_input_port_added_listener_func)(
6945df9a
SM		 138 const bt_component_sink *component,
139 const bt_port_input *port, void *data);
140
8cc56726
SM		 141typedef bt_graph_listener_status
142(*bt_graph_source_component_output_port_added_listener_func)(
6945df9a
SM		 143 const bt_component_source *component,
144 const bt_port_output *port, void *data);
145
8cc56726
SM		 146typedef bt_graph_listener_status
147(*bt_graph_filter_component_output_port_added_listener_func)(
6945df9a
SM		 148 const bt_component_filter *component,
149 const bt_port_output *port, void *data);
150
8cc56726
SM		 151typedef bt_graph_listener_status
152(*bt_graph_source_filter_component_ports_connected_listener_func)(
6945df9a
SM		 153 const bt_component_source *source_component,
154 const bt_component_filter *filter_component,
155 const bt_port_output *upstream_port,
156 const bt_port_input *downstream_port, void *data);
157
8cc56726
SM		 158typedef bt_graph_listener_status
159(*bt_graph_source_sink_component_ports_connected_listener_func)(
6945df9a
SM		 160 const bt_component_source *source_component,
161 const bt_component_sink *sink_component,
162 const bt_port_output *upstream_port,
163 const bt_port_input *downstream_port, void *data);
164
8cc56726
SM		 165typedef bt_graph_listener_status
166(*bt_graph_filter_filter_component_ports_connected_listener_func)(
6945df9a
SM		 167 const bt_component_filter *filter_component_upstream,
168 const bt_component_filter *filter_component_downstream,
169 const bt_port_output *upstream_port,
170 const bt_port_input *downstream_port,
171 void *data);
172
8cc56726
SM		 173typedef bt_graph_listener_status
174(*bt_graph_filter_sink_component_ports_connected_listener_func)(
6945df9a
SM		 175 const bt_component_filter *filter_component,
176 const bt_component_sink *sink_component,
177 const bt_port_output *upstream_port,
178 const bt_port_input *downstream_port, void *data);
179
180typedef void (* bt_graph_listener_removed_func)(void *data);
181
182extern bt_graph *bt_graph_create(void);
183
184extern bt_graph_status bt_graph_add_source_component(bt_graph *graph,
185 const bt_component_class_source *component_class,
186 const char *name, const bt_value *params,
187 const bt_component_source **OUT);
188
189extern bt_graph_status bt_graph_add_source_component_with_init_method_data(
190 bt_graph *graph,
191 const bt_component_class_source *component_class,
192 const char *name, const bt_value *params,
193 void *init_method_data,
194 const bt_component_source **OUT);
195
196extern bt_graph_status bt_graph_add_filter_component(bt_graph *graph,
197 const bt_component_class_filter *component_class,
198 const char *name, const bt_value *params,
199 const bt_component_filter **OUT);
200
201extern bt_graph_status bt_graph_add_filter_component_with_init_method_data(
202 bt_graph *graph,
203 const bt_component_class_filter *component_class,
204 const char *name, const bt_value *params,
205 void *init_method_data,
206 const bt_component_filter **OUT);
207
208extern bt_graph_status bt_graph_add_sink_component(
209 bt_graph *graph, const bt_component_class_sink *component_class,
210 const char *name, const bt_value *params,
211 const bt_component_sink **OUT);
212
213extern bt_graph_status bt_graph_add_sink_component_with_init_method_data(
214 bt_graph *graph, const bt_component_class_sink *component_class,
215 const char *name, const bt_value *params,
216 void *init_method_data,
217 const bt_component_sink **OUT);
218
219extern bt_graph_status bt_graph_connect_ports(bt_graph *graph,
220 const bt_port_output *upstream,
221 const bt_port_input *downstream,
222 const bt_connection **BTOUTCONN);
223
224extern bt_graph_status bt_graph_run(bt_graph *graph);
225
226extern bt_graph_status bt_graph_consume(bt_graph *graph);
227
228extern bt_graph_status bt_graph_add_filter_component_input_port_added_listener(
229 bt_graph *graph,
230 bt_graph_filter_component_input_port_added_listener_func listener,
231 bt_graph_listener_removed_func listener_removed, void *data,
232 int *listener_id);
233
234extern bt_graph_status bt_graph_add_sink_component_input_port_added_listener(
235 bt_graph *graph,
236 bt_graph_sink_component_input_port_added_listener_func listener,
237 bt_graph_listener_removed_func listener_removed, void *data,
238 int *listener_id);
239
240extern bt_graph_status bt_graph_add_source_component_output_port_added_listener(
241 bt_graph *graph,
242 bt_graph_source_component_output_port_added_listener_func listener,
243 bt_graph_listener_removed_func listener_removed, void *data,
244 int *listener_id);
245
246extern bt_graph_status bt_graph_add_filter_component_output_port_added_listener(
247 bt_graph *graph,
248 bt_graph_filter_component_output_port_added_listener_func listener,
249 bt_graph_listener_removed_func listener_removed, void *data,
250 int *listener_id);
251
252extern bt_graph_status
253bt_graph_add_source_filter_component_ports_connected_listener(
254 bt_graph *graph,
255 bt_graph_source_filter_component_ports_connected_listener_func listener,
256 bt_graph_listener_removed_func listener_removed, void *data,
257 int *listener_id);
258
259extern bt_graph_status
260bt_graph_add_filter_filter_component_ports_connected_listener(
261 bt_graph *graph,
262 bt_graph_filter_filter_component_ports_connected_listener_func listener,
263 bt_graph_listener_removed_func listener_removed, void *data,
264 int *listener_id);
265
266extern bt_graph_status
267bt_graph_add_source_sink_component_ports_connected_listener(
268 bt_graph *graph,
269 bt_graph_source_sink_component_ports_connected_listener_func listener,
270 bt_graph_listener_removed_func listener_removed, void *data,
271 int *listener_id);
272
273extern bt_graph_status
274bt_graph_add_filter_sink_component_ports_connected_listener(
275 bt_graph *graph,
276 bt_graph_filter_sink_component_ports_connected_listener_func listener,
277 bt_graph_listener_removed_func listener_removed, void *data,
278 int *listener_id);
279
280extern bt_graph_status bt_graph_cancel(bt_graph *graph);
281
282/* Helper functions for Python */
283
284%{
285
286static void graph_listener_removed(void *py_callable)
287{
288 BT_ASSERT(py_callable);
289 Py_DECREF(py_callable);
290}
291
8cc56726 292static bt_graph_listener_status
6945df9a
SM		 293port_added_listener(
294 const void *component,
295 swig_type_info *component_swig_type,
8cc56726 296 bt_component_class_type component_class_type,
6945df9a
SM		 297 const void *port,
298 swig_type_info *port_swig_type,
299 bt_port_type port_type,
300 void *py_callable)
301{
302 PyObject *py_component_ptr = NULL;
303 PyObject *py_port_ptr = NULL;
304 PyObject *py_res = NULL;
5f25509b 305 bt_graph_listener_status status;
6945df9a
SM		 306
307 py_component_ptr = SWIG_NewPointerObj(SWIG_as_voidptr(component), component_swig_type, 0);
308 if (!py_component_ptr) {
309 BT_LOGF_STR("Failed to create component SWIG pointer object.");
5f25509b 310 status = BT_GRAPH_LISTENER_STATUS_NOMEM;
6945df9a
SM		 311 goto end;
312 }
313
314 py_port_ptr = SWIG_NewPointerObj(SWIG_as_voidptr(port), port_swig_type, 0);
315 if (!py_port_ptr) {
316 BT_LOGF_STR("Failed to create port SWIG pointer object.");
5f25509b 317 status = BT_GRAPH_LISTENER_STATUS_NOMEM;
6945df9a
SM		 318 goto end;
319 }
320
321 py_res = PyObject_CallFunction(py_callable, "(OiOi)",
322 py_component_ptr, component_class_type, py_port_ptr, port_type);
323 if (!py_res) {
324 bt2_py_loge_exception();
325 PyErr_Clear();
5f25509b
SM		 326 status = BT_GRAPH_LISTENER_STATUS_ERROR;
327 goto end;
6945df9a 328 }
5f25509b
SM		 329
330 BT_ASSERT(py_res == Py_None);
331 status = BT_GRAPH_LISTENER_STATUS_OK;
6945df9a
SM		 332
333end:
334 Py_XDECREF(py_res);
335 Py_XDECREF(py_port_ptr);
336 Py_XDECREF(py_component_ptr);
8cc56726
SM		 337
338 return status;
6945df9a
SM		 339}
340
8cc56726 341static bt_graph_listener_status
6945df9a
SM		 342source_component_output_port_added_listener(const bt_component_source *component_source,
343 const bt_port_output *port_output, void *py_callable)
344{
8cc56726 345 return port_added_listener(
6945df9a
SM		 346 component_source, SWIGTYPE_p_bt_component_source, BT_COMPONENT_CLASS_TYPE_SOURCE,
347 port_output, SWIGTYPE_p_bt_port_output, BT_PORT_TYPE_OUTPUT, py_callable);
348}
349
8cc56726 350static bt_graph_listener_status
6945df9a
SM		 351filter_component_input_port_added_listener(const bt_component_filter *component_filter,
352 const bt_port_input *port_input, void *py_callable)
353{
8cc56726 354 return port_added_listener(
6945df9a
SM		 355 component_filter, SWIGTYPE_p_bt_component_filter, BT_COMPONENT_CLASS_TYPE_FILTER,
356 port_input, SWIGTYPE_p_bt_port_input, BT_PORT_TYPE_INPUT, py_callable);
357}
358
8cc56726 359static bt_graph_listener_status
6945df9a
SM		 360filter_component_output_port_added_listener(const bt_component_filter *component_filter,
361 const bt_port_output *port_output, void *py_callable)
362{
8cc56726 363 return port_added_listener(
6945df9a
SM		 364 component_filter, SWIGTYPE_p_bt_component_filter, BT_COMPONENT_CLASS_TYPE_FILTER,
365 port_output, SWIGTYPE_p_bt_port_output, BT_PORT_TYPE_OUTPUT, py_callable);
366}
367
8cc56726 368static bt_graph_listener_status
6945df9a
SM		 369sink_component_input_port_added_listener(const bt_component_sink *component_sink,
370 const bt_port_input *port_input, void *py_callable)
371{
8cc56726 372 return port_added_listener(
6945df9a
SM		 373 component_sink, SWIGTYPE_p_bt_component_sink, BT_COMPONENT_CLASS_TYPE_SINK,
374 port_input, SWIGTYPE_p_bt_port_input, BT_PORT_TYPE_INPUT, py_callable);
375}
376
377static PyObject *
378bt_py3_graph_add_port_added_listener(struct bt_graph *graph,
379 PyObject *py_callable)
380{
381 PyObject *py_listener_ids = NULL;
382 PyObject *py_listener_id = NULL;
383 int listener_id;
384 bt_graph_status status;
385
386 BT_ASSERT(graph);
387 BT_ASSERT(py_callable);
388
389 /*
390 * Behind the scene, we will be registering 4 different listeners and
391 * return all of their ids.
392 */
393 py_listener_ids = PyTuple_New(4);
394 if (!py_listener_ids) {
395 goto error;
396 }
397
398 /* source output port */
399 status = bt_graph_add_source_component_output_port_added_listener(
400 graph, source_component_output_port_added_listener,
401 graph_listener_removed, py_callable, &listener_id);
402 if (status != BT_GRAPH_STATUS_OK) {
403 goto error;
404 }
405
406 py_listener_id = PyLong_FromLong(listener_id);
407 if (!py_listener_id) {
408 goto error;
409 }
410
411 PyTuple_SET_ITEM(py_listener_ids, 0, py_listener_id);
412 py_listener_id = NULL;
413
414 /* filter input port */
415 status = bt_graph_add_filter_component_input_port_added_listener(
416 graph, filter_component_input_port_added_listener,
417 graph_listener_removed, py_callable, &listener_id);
418 if (status != BT_GRAPH_STATUS_OK) {
419 goto error;
420 }
421
422 py_listener_id = PyLong_FromLong(listener_id);
423 if (!py_listener_id) {
424 goto error;
425 }
426
427 PyTuple_SET_ITEM(py_listener_ids, 1, py_listener_id);
428 py_listener_id = NULL;
429
430 /* filter output port */
431 status = bt_graph_add_filter_component_output_port_added_listener(
432 graph, filter_component_output_port_added_listener,
433 graph_listener_removed, py_callable, &listener_id);
434 if (status != BT_GRAPH_STATUS_OK) {
435 goto error;
436 }
437
438 py_listener_id = PyLong_FromLong(listener_id);
439 if (!py_listener_id) {
440 goto error;
441 }
442
443 PyTuple_SET_ITEM(py_listener_ids, 2, py_listener_id);
444 py_listener_id = NULL;
445
446 /* sink input port */
447 status = bt_graph_add_sink_component_input_port_added_listener(
448 graph, sink_component_input_port_added_listener,
449 graph_listener_removed, py_callable, &listener_id);
450 if (status != BT_GRAPH_STATUS_OK) {
451 goto error;
452 }
453
454 py_listener_id = PyLong_FromLong(listener_id);
455 if (!py_listener_id) {
456 goto error;
457 }
458
459
460 PyTuple_SET_ITEM(py_listener_ids, 3, py_listener_id);
461 py_listener_id = NULL;
462
463 Py_INCREF(py_callable);
464 Py_INCREF(py_callable);
465 Py_INCREF(py_callable);
466 Py_INCREF(py_callable);
467
468 goto end;
469
470error:
471 Py_XDECREF(py_listener_ids);
472 py_listener_ids = Py_None;
473 Py_INCREF(py_listener_ids);
474
475end:
476
477 Py_XDECREF(py_listener_id);
478 return py_listener_ids;
479}
480
8cc56726 481static bt_graph_listener_status
5f25509b
SM		 482ports_connected_listener(
483 const void *upstream_component,
484 swig_type_info *upstream_component_swig_type,
485 bt_component_class_type upstream_component_class_type,
486 const bt_port_output *upstream_port,
487 const void *downstream_component,
488 swig_type_info *downstream_component_swig_type,
489 bt_component_class_type downstream_component_class_type,
490 const bt_port_input *downstream_port,
491 void *py_callable)
6945df9a 492{
5f25509b 493 PyObject *py_upstream_component_ptr = NULL;
6945df9a 494 PyObject *py_upstream_port_ptr = NULL;
5f25509b 495 PyObject *py_downstream_component_ptr = NULL;
6945df9a
SM		 496 PyObject *py_downstream_port_ptr = NULL;
497 PyObject *py_res = NULL;
5f25509b
SM		 498 bt_graph_listener_status status;
499
500 py_upstream_component_ptr = SWIG_NewPointerObj(SWIG_as_voidptr(upstream_component),
501 upstream_component_swig_type, 0);
502 if (!py_upstream_component_ptr) {
503 BT_LOGF_STR("Failed to create upstream component SWIG pointer object.");
504 status = BT_GRAPH_LISTENER_STATUS_NOMEM;
505 goto end;
506 }
6945df9a
SM		 507
508 py_upstream_port_ptr = SWIG_NewPointerObj(
509 SWIG_as_voidptr(upstream_port), SWIGTYPE_p_bt_port_output, 0);
510 if (!py_upstream_port_ptr) {
5f25509b
SM		 511 BT_LOGF_STR("Failed to create upstream port SWIG pointer object.");
512 status = BT_GRAPH_LISTENER_STATUS_NOMEM;
513 goto end;
514 }
515
516 py_downstream_component_ptr = SWIG_NewPointerObj(SWIG_as_voidptr(downstream_component),
517 downstream_component_swig_type, 0);
518 if (!py_downstream_component_ptr) {
519 BT_LOGF_STR("Failed to create downstream component SWIG pointer object.");
520 status = BT_GRAPH_LISTENER_STATUS_NOMEM;
521 goto end;
6945df9a
SM		 522 }
523
524 py_downstream_port_ptr = SWIG_NewPointerObj(
525 SWIG_as_voidptr(downstream_port), SWIGTYPE_p_bt_port_input, 0);
526 if (!py_downstream_port_ptr) {
5f25509b
SM		 527 BT_LOGF_STR("Failed to create downstream port SWIG pointer object.");
528 status = BT_GRAPH_LISTENER_STATUS_NOMEM;
529 goto end;
6945df9a
SM		 530 }
531
5f25509b
SM		 532 py_res = PyObject_CallFunction(py_callable, "(OiOOiO)",
533 py_upstream_component_ptr, upstream_component_class_type,
534 py_upstream_port_ptr,
535 py_downstream_component_ptr, downstream_component_class_type,
536 py_downstream_port_ptr);
6945df9a
SM		 537 if (!py_res) {
538 bt2_py_loge_exception();
539 PyErr_Clear();
5f25509b
SM		 540 status = BT_GRAPH_LISTENER_STATUS_ERROR;
541 goto end;
6945df9a 542 }
5f25509b
SM		 543
544 BT_ASSERT(py_res == Py_None);
545 status = BT_GRAPH_LISTENER_STATUS_OK;
6945df9a 546
5f25509b
SM		 547end:
548 Py_XDECREF(py_upstream_component_ptr);
549 Py_XDECREF(py_upstream_port_ptr);
550 Py_XDECREF(py_downstream_component_ptr);
551 Py_XDECREF(py_downstream_port_ptr);
6945df9a 552 Py_XDECREF(py_res);
8cc56726
SM		 553
554 return status;
6945df9a
SM		 555}
556
8cc56726 557static bt_graph_listener_status
6945df9a
SM		 558source_filter_component_ports_connected_listener(
559 const bt_component_source *source_component,
560 const bt_component_filter *filter_component,
561 const bt_port_output *upstream_port,
562 const bt_port_input *downstream_port, void *py_callable)
563{
5f25509b
SM		 564 return ports_connected_listener(
565 source_component, SWIGTYPE_p_bt_component_source, BT_COMPONENT_CLASS_TYPE_SOURCE,
566 upstream_port,
567 filter_component, SWIGTYPE_p_bt_component_filter, BT_COMPONENT_CLASS_TYPE_FILTER,
568 downstream_port,
569 py_callable);
6945df9a
SM		 570}
571
8cc56726 572static bt_graph_listener_status
6945df9a
SM		 573source_sink_component_ports_connected_listener(
574 const bt_component_source *source_component,
575 const bt_component_sink *sink_component,
576 const bt_port_output *upstream_port,
577 const bt_port_input *downstream_port, void *py_callable)
578{
5f25509b
SM		 579 return ports_connected_listener(
580 source_component, SWIGTYPE_p_bt_component_source, BT_COMPONENT_CLASS_TYPE_SOURCE,
581 upstream_port,
582 sink_component, SWIGTYPE_p_bt_component_sink, BT_COMPONENT_CLASS_TYPE_SINK,
583 downstream_port,
584 py_callable);
6945df9a
SM		 585}
586
8cc56726 587static bt_graph_listener_status
6945df9a
SM		 588filter_filter_component_ports_connected_listener(
589 const bt_component_filter *filter_component_left,
590 const bt_component_filter *filter_component_right,
591 const bt_port_output *upstream_port,
592 const bt_port_input *downstream_port, void *py_callable)
593{
5f25509b
SM		 594 return ports_connected_listener(
595 filter_component_left, SWIGTYPE_p_bt_component_filter, BT_COMPONENT_CLASS_TYPE_FILTER,
596 upstream_port,
597 filter_component_right, SWIGTYPE_p_bt_component_filter, BT_COMPONENT_CLASS_TYPE_FILTER,
598 downstream_port,
599 py_callable);
6945df9a
SM		 600}
601
8cc56726 602static bt_graph_listener_status
6945df9a
SM		 603filter_sink_component_ports_connected_listener(
604 const bt_component_filter *filter_component,
605 const bt_component_sink *sink_component,
606 const bt_port_output *upstream_port,
607 const bt_port_input *downstream_port, void *py_callable)
608{
5f25509b
SM		 609 return ports_connected_listener(
610 filter_component, SWIGTYPE_p_bt_component_filter, BT_COMPONENT_CLASS_TYPE_FILTER,
611 upstream_port,
612 sink_component, SWIGTYPE_p_bt_component_sink, BT_COMPONENT_CLASS_TYPE_SINK,
613 downstream_port,
614 py_callable);
6945df9a
SM		 615}
616
6945df9a
SM		 617static PyObject*
618bt_py3_graph_add_ports_connected_listener(struct bt_graph *graph,
619 PyObject *py_callable)
620{
621 PyObject *py_listener_ids = NULL;
622 PyObject *py_listener_id = NULL;
623 int listener_id;
624 bt_graph_status status;
625
626 BT_ASSERT(graph);
627 BT_ASSERT(py_callable);
628
629 /* Behind the scene, we will be registering 4 different listeners and
630 * return all of their ids. */
631 py_listener_ids = PyTuple_New(4);
632 if (!py_listener_ids) {
633 goto error;
634 }
635
636 /* source -> filter connection */
637 status = bt_graph_add_source_filter_component_ports_connected_listener(
638 graph, source_filter_component_ports_connected_listener,
639 graph_listener_removed, py_callable, &listener_id);
640 if (status != BT_GRAPH_STATUS_OK) {
641 goto error;
642 }
643
644 py_listener_id = PyLong_FromLong(listener_id);
645 if (!py_listener_id) {
646 goto error;
647 }
648
649 PyTuple_SET_ITEM(py_listener_ids, 0, py_listener_id);
650 py_listener_id = NULL;
651
652 /* source -> sink connection */
653 status = bt_graph_add_source_sink_component_ports_connected_listener(
654 graph, source_sink_component_ports_connected_listener,
655 graph_listener_removed, py_callable, &listener_id);
656 if (status != BT_GRAPH_STATUS_OK) {
657 goto error;
658 }
659
660 py_listener_id = PyLong_FromLong(listener_id);
661 if (!py_listener_id) {
662 goto error;
663 }
664
665 PyTuple_SET_ITEM(py_listener_ids, 1, py_listener_id);
666 py_listener_id = NULL;
667
668 /* filter -> filter connection */
669 status = bt_graph_add_filter_filter_component_ports_connected_listener(
670 graph, filter_filter_component_ports_connected_listener,
671 graph_listener_removed, py_callable, &listener_id);
672 if (status != BT_GRAPH_STATUS_OK) {
673 goto error;
674 }
675
676 py_listener_id = PyLong_FromLong(listener_id);
677 if (!py_listener_id) {
678 goto error;
679 }
680
681 PyTuple_SET_ITEM(py_listener_ids, 2, py_listener_id);
682 py_listener_id = NULL;
683
684 /* filter -> sink connection */
685 status = bt_graph_add_filter_sink_component_ports_connected_listener(
686 graph, filter_sink_component_ports_connected_listener,
687 graph_listener_removed, py_callable, &listener_id);
688 if (status != BT_GRAPH_STATUS_OK) {
689 goto error;
690 }
691
692 py_listener_id = PyLong_FromLong(listener_id);
693 if (!py_listener_id) {
694 goto error;
695 }
696
697 PyTuple_SET_ITEM(py_listener_ids, 3, py_listener_id);
698 py_listener_id = NULL;
699
700 Py_INCREF(py_callable);
701 Py_INCREF(py_callable);
702 Py_INCREF(py_callable);
703 Py_INCREF(py_callable);
704
705 goto end;
706
707error:
708 Py_XDECREF(py_listener_ids);
709 py_listener_ids = Py_None;
710 Py_INCREF(py_listener_ids);
711
712end:
713
714 Py_XDECREF(py_listener_id);
715 return py_listener_ids;
716}
717
718%}
719
720PyObject *bt_py3_graph_add_port_added_listener(struct bt_graph *graph,
721 PyObject *py_callable);
722PyObject *bt_py3_graph_add_ports_connected_listener(struct bt_graph *graph,
723 PyObject *py_callable);
BabelTrace - Trace Format Babel Tower
This page took 0.0515679999999999 seconds and 4 git commands to generate.