"Input port is not connected: %![port-]+p", port);
BT_ASSERT_PRE(comp, "Input port is not part of a component: %![port-]+p",
port);
- BT_ASSERT_PRE(!bt_component_graph_is_canceled(comp),
- "Input port's component's graph is canceled: "
- "%![port-]+p, %![comp-]+c", port, comp);
BT_ASSERT(port->connection);
upstream_port = port->connection->upstream_port;
BT_ASSERT(upstream_port);
upstream_comp = bt_port_borrow_component_inline(upstream_port);
BT_ASSERT(upstream_comp);
BT_ASSERT_PRE(
- bt_component_borrow_graph(upstream_comp)->config_state !=
- BT_GRAPH_CONFIGURATION_STATE_CONFIGURING,
+ bt_component_borrow_graph(upstream_comp)->config_state ==
+ BT_GRAPH_CONFIGURATION_STATE_PARTIALLY_CONFIGURED ||
+ bt_component_borrow_graph(upstream_comp)->config_state ==
+ BT_GRAPH_CONFIGURATION_STATE_CONFIGURED,
"Graph is not configured: %!+g",
bt_component_borrow_graph(upstream_comp));
upstream_comp_cls = upstream_comp->class;
graph_status = bt_graph_consume_sink_no_check(iterator->graph,
iterator->colander);
switch (graph_status) {
- case BT_FUNC_STATUS_CANCELED:
case BT_FUNC_STATUS_AGAIN:
case BT_FUNC_STATUS_END:
case BT_FUNC_STATUS_MEMORY_ERROR:
iterator));
}
+bt_bool bt_self_message_iterator_is_interrupted(
+ const struct bt_self_message_iterator *self_msg_iter)
+{
+ const struct bt_self_component_port_input_message_iterator *iterator =
+ (const void *) self_msg_iter;
+
+ BT_ASSERT_PRE_NON_NULL(iterator, "Message iterator");
+ return (bt_bool) bt_graph_is_interrupted(iterator->graph);
+}
+
void bt_port_output_message_iterator_get_ref(
const struct bt_port_output_message_iterator *iterator)
{