BT_GRAPH_STATUS_OK = 0,
BT_GRAPH_STATUS_INVALID = -22,
BT_GRAPH_STATUS_NO_SINK = -6,
+ BT_GRAPH_STATUS_CANNOT_CONSUME = -2,
BT_GRAPH_STATUS_ERROR = -1,
BT_GRAPH_STATUS_NOMEM = -12,
};
}
py_res = PyObject_CallFunction(py_callable, "(O)", py_port_ptr);
- assert(py_res == Py_None);
+ BT_ASSERT(py_res == Py_None);
Py_DECREF(py_port_ptr);
Py_DECREF(py_res);
}
}
py_res = PyObject_CallFunction(py_callable, "(O)", py_port_ptr);
- assert(py_res == Py_None);
+ BT_ASSERT(py_res == Py_None);
Py_DECREF(py_port_ptr);
Py_DECREF(py_res);
}
py_res = PyObject_CallFunction(py_callable, "(OO)",
py_upstream_port_ptr, py_downstream_port_ptr);
- assert(py_res == Py_None);
+ BT_ASSERT(py_res == Py_None);
Py_DECREF(py_upstream_port_ptr);
Py_DECREF(py_downstream_port_ptr);
Py_DECREF(py_res);
py_res = PyObject_CallFunction(py_callable, "(OOOO)",
py_upstream_comp_ptr, py_downstream_comp_ptr,
py_upstream_port_ptr, py_downstream_port_ptr);
- assert(py_res == Py_None);
+ BT_ASSERT(py_res == Py_None);
Py_DECREF(py_upstream_comp_ptr);
Py_DECREF(py_downstream_comp_ptr);
Py_DECREF(py_upstream_port_ptr);
static void graph_listener_removed(void *py_callable)
{
- assert(py_callable);
+ BT_ASSERT(py_callable);
Py_DECREF(py_callable);
}
{
int ret = 0;
- assert(graph);
- assert(py_callable);
+ BT_ASSERT(graph);
+ BT_ASSERT(py_callable);
ret = bt_graph_add_port_added_listener(graph, port_added_listener,
graph_listener_removed, py_callable);
if (ret >= 0) {
{
int ret = 0;
- assert(graph);
- assert(py_callable);
+ BT_ASSERT(graph);
+ BT_ASSERT(py_callable);
ret = bt_graph_add_port_removed_listener(graph, port_removed_listener,
graph_listener_removed, py_callable);
if (ret >= 0) {
{
int ret = 0;
- assert(graph);
- assert(py_callable);
+ BT_ASSERT(graph);
+ BT_ASSERT(py_callable);
ret = bt_graph_add_ports_connected_listener(graph,
ports_connected_listener, graph_listener_removed, py_callable);
if (ret >= 0) {
{
int ret = 0;
- assert(graph);
- assert(py_callable);
+ BT_ASSERT(graph);
+ BT_ASSERT(py_callable);
ret = bt_graph_add_ports_disconnected_listener(graph,
ports_disconnected_listener, graph_listener_removed,
py_callable);