Make bt_graph_connect_ports() return a status code

[babeltrace.git] / include / babeltrace / graph / graph-internal.h

diff --git a/include/babeltrace/graph/graph-internal.h b/include/babeltrace/graph/graph-internal.h
index e8e9e7f6e3f1d03d325aa5de35a829f2e99e3e2f..f8f0d1a17475f27cb7a783567eaa43134d2e9981 100644 (file)
--- a/include/babeltrace/graph/graph-internal.h
+++ b/include/babeltrace/graph/graph-internal.h
@@ -28,8 +28,10 @@
  */
 
 #include <babeltrace/graph/graph.h>
+#include <babeltrace/graph/component-status.h>
 #include <babeltrace/babeltrace-internal.h>
 #include <babeltrace/object-internal.h>
+#include <stdlib.h>
 #include <glib.h>
 
 struct bt_component;
@@ -55,11 +57,13 @@ struct bt_graph {
        /* Queue of pointers (weak references) to sink bt_components. */
        GQueue *sinks_to_consume;
 
+       bt_bool canceled;
+
        struct {
                GArray *port_added;
                GArray *port_removed;
-               GArray *port_connected;
-               GArray *port_disconnected;
+               GArray *ports_connected;
+               GArray *ports_disconnected;
        } listeners;
 };
 
@@ -71,11 +75,78 @@ void bt_graph_notify_port_removed(struct bt_graph *graph,
                struct bt_component *comp, struct bt_port *port);
 
 BT_HIDDEN
-void bt_graph_notify_port_connected(struct bt_graph *graph,
-               struct bt_port *port);
+void bt_graph_notify_ports_connected(struct bt_graph *graph,
+               struct bt_port *upstream_port, struct bt_port *downstream_port);
 
 BT_HIDDEN
-void bt_graph_notify_port_disconnected(struct bt_graph *graph,
-               struct bt_component *comp, struct bt_port *port);
+void bt_graph_notify_ports_disconnected(struct bt_graph *graph,
+               struct bt_component *upstream_comp,
+               struct bt_component *downstream_comp,
+               struct bt_port *upstream_port,
+               struct bt_port *downstream_port);
+
+BT_HIDDEN
+void bt_graph_remove_connection(struct bt_graph *graph,
+               struct bt_connection *connection);
+
+static inline
+const char *bt_graph_status_string(enum bt_graph_status status)
+{
+       switch (status) {
+       case BT_GRAPH_STATUS_CANCELED:
+               return "BT_GRAPH_STATUS_CANCELED";
+       case BT_GRAPH_STATUS_AGAIN:
+               return "BT_GRAPH_STATUS_AGAIN";
+       case BT_GRAPH_STATUS_END:
+               return "BT_GRAPH_STATUS_END";
+       case BT_GRAPH_STATUS_OK:
+               return "BT_GRAPH_STATUS_OK";
+       case BT_GRAPH_STATUS_ALREADY_IN_A_GRAPH:
+               return "BT_GRAPH_STATUS_ALREADY_IN_A_GRAPH";
+       case BT_GRAPH_STATUS_INVALID:
+               return "BT_GRAPH_STATUS_INVALID";
+       case BT_GRAPH_STATUS_NO_SINK:
+               return "BT_GRAPH_STATUS_NO_SINK";
+       case BT_GRAPH_STATUS_ERROR:
+               return "BT_GRAPH_STATUS_ERROR";
+       case BT_GRAPH_STATUS_COMPONENT_REFUSES_PORT_CONNECTION:
+               return "BT_GRAPH_STATUS_COMPONENT_REFUSES_PORT_CONNECTION";
+       case BT_GRAPH_STATUS_NOMEM:
+               return "BT_GRAPH_STATUS_NOMEM";
+       default:
+               return "(unknown)";
+       }
+}
+
+static inline
+enum bt_graph_status bt_graph_status_from_component_status(
+               enum bt_component_status comp_status)
+{
+       switch (comp_status) {
+       case BT_COMPONENT_STATUS_OK:
+               return BT_GRAPH_STATUS_OK;
+       case BT_COMPONENT_STATUS_END:
+               return BT_GRAPH_STATUS_END;
+       case BT_COMPONENT_STATUS_AGAIN:
+               return BT_GRAPH_STATUS_AGAIN;
+       case BT_COMPONENT_STATUS_REFUSE_PORT_CONNECTION:
+               return BT_GRAPH_STATUS_COMPONENT_REFUSES_PORT_CONNECTION;
+       case BT_COMPONENT_STATUS_ERROR:
+               return BT_GRAPH_STATUS_ERROR;
+       case BT_COMPONENT_STATUS_UNSUPPORTED:
+               return BT_GRAPH_STATUS_ERROR;
+       case BT_COMPONENT_STATUS_INVALID:
+               return BT_GRAPH_STATUS_INVALID;
+       case BT_COMPONENT_STATUS_NOMEM:
+               return BT_GRAPH_STATUS_NOMEM;
+       case BT_COMPONENT_STATUS_NOT_FOUND:
+               return BT_GRAPH_STATUS_ERROR;
+       default:
+#ifdef BT_LOGF
+               BT_LOGF("Unknown component status: status=%d", comp_status);
+#endif
+               abort();
+       }
+}
 
 #endif /* BABELTRACE_COMPONENT_COMPONENT_GRAPH_INTERNAL_H */