+ if (cmd_run_ctx_connect_upstream_port(ctx, port)) {
+ BT_LOGF_STR("Cannot connect upstream port.");
+ fprintf(stderr, "Added port could not be connected: aborting\n");
+ abort();
+ }
+
+end:
+ bt_put(comp);
+ return;
+}
+
+static
+void graph_port_removed_listener(struct bt_component *component,
+ struct bt_port *port, void *data)
+{
+ BT_LOGI("Port removed from a graph's component: comp-addr=%p, "
+ "comp-name=\"%s\", port-addr=%p, port-name=\"%s\"",
+ component, bt_component_get_name(component),
+ port, bt_port_get_name(port));
+}
+
+static
+void graph_ports_connected_listener(struct bt_port *upstream_port,
+ struct bt_port *downstream_port, void *data)
+{
+ struct bt_component *upstream_comp = bt_port_get_component(upstream_port);
+ struct bt_component *downstream_comp = bt_port_get_component(downstream_port);
+
+ assert(upstream_comp);
+ assert(downstream_comp);
+ BT_LOGI("Graph's component ports connected: "
+ "upstream-comp-addr=%p, upstream-comp-name=\"%s\", "
+ "upstream-port-addr=%p, upstream-port-name=\"%s\", "
+ "downstream-comp-addr=%p, downstream-comp-name=\"%s\", "
+ "downstream-port-addr=%p, downstream-port-name=\"%s\"",
+ upstream_comp, bt_component_get_name(upstream_comp),
+ upstream_port, bt_port_get_name(upstream_port),
+ downstream_comp, bt_component_get_name(downstream_comp),
+ downstream_port, bt_port_get_name(downstream_port));
+ bt_put(upstream_comp);
+ bt_put(downstream_comp);
+}
+
+static
+void graph_ports_disconnected_listener(
+ struct bt_component *upstream_component,
+ struct bt_component *downstream_component,
+ struct bt_port *upstream_port, struct bt_port *downstream_port,
+ void *data)
+{
+ BT_LOGI("Graph's component ports disconnected: "
+ "upstream-port-addr=%p, upstream-port-name=\"%s\", "
+ "downstream-port-addr=%p, downstream-port-name=\"%s\"",
+ upstream_port, bt_port_get_name(upstream_port),
+ downstream_port, bt_port_get_name(downstream_port));
+}
+
+static
+void cmd_run_ctx_destroy(struct cmd_run_ctx *ctx)
+{
+ if (!ctx) {
+ return;
+ }
+
+ if (ctx->components) {
+ g_hash_table_destroy(ctx->components);
+ ctx->components = NULL;
+ }
+
+ BT_PUT(ctx->graph);
+ the_graph = NULL;
+ ctx->cfg = NULL;
+}
+
+static
+int cmd_run_ctx_init(struct cmd_run_ctx *ctx, struct bt_config *cfg)
+{
+ int ret = 0;
+
+ ctx->cfg = cfg;
+ ctx->connect_ports = false;
+ ctx->components = g_hash_table_new_full(g_direct_hash, g_direct_equal,
+ NULL, bt_put);
+ if (!ctx->components) {
+ goto error;
+ }
+
+ ctx->graph = bt_graph_create();
+ if (!ctx->graph) {
+ goto error;
+ }
+
+ the_graph = ctx->graph;
+ ret = bt_graph_add_port_added_listener(ctx->graph,
+ graph_port_added_listener, ctx);
+ if (ret < 0) {
+ BT_LOGE_STR("Cannot add \"port added\" listener to graph.");
+ goto error;
+ }
+
+ ret = bt_graph_add_port_removed_listener(ctx->graph,
+ graph_port_removed_listener, ctx);
+ if (ret < 0) {
+ BT_LOGE_STR("Cannot add \"port removed\" listener to graph.");
+ goto error;
+ }
+
+ ret = bt_graph_add_ports_connected_listener(ctx->graph,
+ graph_ports_connected_listener, ctx);
+ if (ret < 0) {
+ BT_LOGE_STR("Cannot add \"ports connected\" listener to graph.");
+ goto error;
+ }
+
+ ret = bt_graph_add_ports_disconnected_listener(ctx->graph,
+ graph_ports_disconnected_listener, ctx);
+ if (ret < 0) {
+ BT_LOGE_STR("Cannot add \"ports disconnected\" listener to graph.");
+ goto error;
+ }
+
+ goto end;
+
+error:
+ cmd_run_ctx_destroy(ctx);
+ ret = -1;
+
+end:
+ return ret;
+}
+
+static
+int cmd_run_ctx_create_components_from_config_components(
+ struct cmd_run_ctx *ctx, GPtrArray *cfg_components)
+{
+ size_t i;
+ struct bt_component_class *comp_cls = NULL;
+ struct bt_component *comp = NULL;
+ int ret = 0;
+
+ for (i = 0; i < cfg_components->len; i++) {
+ struct bt_config_component *cfg_comp =
+ g_ptr_array_index(cfg_components, i);
+ GQuark quark;
+
+ comp_cls = find_component_class(cfg_comp->plugin_name->str,
+ cfg_comp->comp_cls_name->str, cfg_comp->type);
+ if (!comp_cls) {
+ BT_LOGE("Cannot find component class: plugin-name=\"%s\", "
+ "comp-cls-name=\"%s\", comp-cls-type=%d",
+ cfg_comp->plugin_name->str,
+ cfg_comp->comp_cls_name->str,
+ cfg_comp->type);
+ fprintf(stderr, "%s%sCannot find component class %s",
+ bt_common_color_bold(),
+ bt_common_color_fg_red(),
+ bt_common_color_reset());
+ print_plugin_comp_cls_opt(stderr,
+ cfg_comp->plugin_name->str,
+ cfg_comp->comp_cls_name->str,
+ cfg_comp->type);
+ fprintf(stderr, "\n");
+ goto error;
+ }
+
+ comp = bt_component_create(comp_cls,
+ cfg_comp->instance_name->str, cfg_comp->params);
+ if (!comp) {
+ BT_LOGE("Cannot create component: plugin-name=\"%s\", "
+ "comp-cls-name=\"%s\", comp-cls-type=%d, "
+ "comp-name=\"%s\"",
+ cfg_comp->plugin_name->str,
+ cfg_comp->comp_cls_name->str,
+ cfg_comp->type, cfg_comp->instance_name->str);
+ fprintf(stderr, "%s%sCannot create component `%s`%s\n",
+ bt_common_color_bold(),
+ bt_common_color_fg_red(),
+ cfg_comp->instance_name->str,
+ bt_common_color_reset());
+ goto error;
+ }
+
+ BT_LOGI("Created and inserted component: comp-addr=%p, comp-name=\"%s\"",
+ comp, cfg_comp->instance_name->str);
+ quark = g_quark_from_string(cfg_comp->instance_name->str);
+ assert(quark > 0);
+ g_hash_table_insert(ctx->components,
+ (gpointer) (long) quark, comp);
+ comp = NULL;
+ BT_PUT(comp_cls);
+ }
+
+ goto end;
+
+error:
+ ret = -1;
+
+end:
+ bt_put(comp);
+ bt_put(comp_cls);
+ return ret;
+}
+
+static
+int cmd_run_ctx_create_components(struct cmd_run_ctx *ctx)
+{
+ int ret = 0;
+
+ /*
+ * Make sure that, during this phase, our graph's "port added"
+ * listener does not connect ports while we are creating the
+ * components because we have a special, initial phase for
+ * this.
+ */
+ ctx->connect_ports = false;
+
+ ret = cmd_run_ctx_create_components_from_config_components(
+ ctx, ctx->cfg->cmd_data.run.sources);
+ if (ret) {