#include <unistd.h>
#include <glib.h>
-typedef void (*port_added_func_t)(const void *, const void *, void *);
+typedef enum bt_graph_listener_status (*port_added_func_t)(
+ const void *, const void *, void *);
-typedef void (*ports_connected_func_t)(const void *, const void *, const void *,
- const void *, void *);
+typedef enum bt_graph_listener_status (*ports_connected_func_t)(
+ const void *, const void *, const void *, const void *, void *);
typedef enum bt_self_component_status (*comp_init_method_t)(const void *,
const void *, void *);
do { \
size_t i; \
\
+ if (!_listeners) { \
+ break; \
+ } \
for (i = 0; i < (_listeners)->len; i++) { \
_type *listener = \
&g_array_index((_listeners), _type, i); \
const struct bt_connection **user_connection)
{
enum bt_graph_status status = BT_GRAPH_STATUS_OK;
+ enum bt_graph_listener_status listener_status;
struct bt_connection *connection = NULL;
struct bt_port *upstream_port = (void *) upstream_port_out;
struct bt_port *downstream_port = (void *) downstream_port_in;
* Notify the graph's creator that both ports are connected.
*/
BT_LOGD_STR("Notifying graph's user that new component ports are connected.");
- bt_graph_notify_ports_connected(graph, upstream_port, downstream_port);
+ listener_status = bt_graph_notify_ports_connected(graph, upstream_port, downstream_port);
+ if (listener_status != BT_GRAPH_LISTENER_STATUS_OK) {
+ status = (int) listener_status;
+ goto end;
+ }
+
connection->notified_graph_ports_connected = true;
BT_LIB_LOGD("Connected component ports within graph: "
"%![graph-]+g, %![up-comp-]+c, %![down-comp-]+c, "
end:
if (status != BT_GRAPH_STATUS_OK) {
- graph->config_state = BT_GRAPH_CONFIGURATION_STATE_FAULTY;
+ bt_graph_make_faulty(graph);
}
bt_object_put_ref(connection);
"Graph is in a faulty state: %!+g", graph);
bt_graph_set_can_consume(graph, false);
status = bt_graph_configure(graph);
- if (status) {
+ if (unlikely(status)) {
/* bt_graph_configure() logs errors */
goto end;
}
"Graph is in a faulty state: %!+g", graph);
bt_graph_set_can_consume(graph, false);
status = bt_graph_configure(graph);
- if (status) {
+ if (unlikely(status)) {
/* bt_graph_configure() logs errors */
goto end;
}
if (graph->sinks_to_consume->length > 1) {
status = BT_GRAPH_STATUS_OK;
}
- } else if (status == BT_GRAPH_STATUS_NO_SINK) {
- goto end;
}
} while (status == BT_GRAPH_STATUS_OK);
}
BT_HIDDEN
-void bt_graph_notify_port_added(struct bt_graph *graph, struct bt_port *port)
+enum bt_graph_listener_status bt_graph_notify_port_added(
+ struct bt_graph *graph, struct bt_port *port)
{
uint64_t i;
GArray *listeners;
struct bt_component *comp;
+ enum bt_graph_listener_status status = BT_GRAPH_LISTENER_STATUS_OK;
BT_ASSERT(graph);
BT_ASSERT(port);
&g_array_index(listeners,
struct bt_graph_listener_port_added, i);
+
BT_ASSERT(listener->func);
- listener->func(comp, port, listener->base.data);
+ status = listener->func(comp, port, listener->base.data);
+ if (status != BT_GRAPH_LISTENER_STATUS_OK) {
+ goto end;
+ }
}
+
+end:
+ return status;
}
BT_HIDDEN
-void bt_graph_notify_ports_connected(struct bt_graph *graph,
- struct bt_port *upstream_port, struct bt_port *downstream_port)
+enum bt_graph_listener_status bt_graph_notify_ports_connected(
+ struct bt_graph *graph, struct bt_port *upstream_port,
+ struct bt_port *downstream_port)
{
uint64_t i;
GArray *listeners;
struct bt_component *upstream_comp;
struct bt_component *downstream_comp;
+ enum bt_graph_listener_status status = BT_GRAPH_LISTENER_STATUS_OK;
BT_ASSERT(graph);
BT_ASSERT(upstream_port);
struct bt_graph_listener_ports_connected, i);
BT_ASSERT(listener->func);
- listener->func(upstream_comp, downstream_comp,
+ status = listener->func(upstream_comp, downstream_comp,
upstream_port, downstream_port, listener->base.data);
+ if (status != BT_GRAPH_LISTENER_STATUS_OK) {
+ goto end;
+ }
}
+
+end:
+ return status;
}
enum bt_graph_status bt_graph_cancel(struct bt_graph *graph)
*/
g_ptr_array_add(graph->components, component);
bt_component_set_graph(component, graph);
+ bt_value_freeze(params);
if (init_method) {
BT_LOGD_STR("Calling user's initialization method.");
end:
if (graph_status != BT_GRAPH_STATUS_OK) {
- graph->config_state = BT_GRAPH_CONFIGURATION_STATE_FAULTY;
+ bt_graph_make_faulty(graph);
}
bt_object_put_ref(component);