- enum bt_component_status ret;
- struct bt_notification *notification = NULL;
- struct bt_notification_iterator *it;
- struct pretty_component *pretty =
- bt_private_component_get_user_data(component);
- enum bt_notification_iterator_status it_ret;
-
- if (unlikely(pretty->error)) {
- ret = BT_COMPONENT_STATUS_ERROR;
- goto end;
- }
-
- it = pretty->input_iterator;
- it_ret = bt_notification_iterator_next(it);
+ bt_self_component_status ret;
+ bt_message_array_const msgs;
+ bt_self_component_port_input_message_iterator *it;
+ struct pretty_component *pretty = bt_self_component_get_data(
+ bt_self_component_sink_as_self_component(comp));
+ bt_message_iterator_status it_ret;
+ uint64_t count = 0;
+ uint64_t i = 0;
+
+ it = pretty->iterator;
+ it_ret = bt_self_component_port_input_message_iterator_next(it,
+ &msgs, &count);