-
- if (!colander_data->msg_iter) {
- BT_LIB_LOGW("Trying to consume without an "
- "upstream message iterator: %![comp-]+c",
- self_comp);
- goto end;
- }
-
- msg_iter_status =
- bt_self_component_port_input_message_iterator_next(
- colander_data->msg_iter, &msgs,
- colander_data->count_addr);
- switch (msg_iter_status) {
- case BT_MESSAGE_ITERATOR_STATUS_AGAIN:
- status = BT_SELF_COMPONENT_STATUS_AGAIN;
+ BT_ASSERT(colander_data->msg_iter);
+ next_status = bt_self_component_port_input_message_iterator_next(
+ colander_data->msg_iter, &msgs,
+ colander_data->count_addr);
+ switch (next_status) {
+ case BT_FUNC_STATUS_AGAIN:
+ status = BT_FUNC_STATUS_AGAIN;