bt_self_message_iterator *self_msg_iter,
bt_self_component_source *self_comp,
bt_self_component_port_output *self_port)
bt_self_message_iterator *self_msg_iter,
bt_self_component_source *self_comp,
bt_self_component_port_output *self_port)
bt_self_message_iterator *msg_iter,
struct src_iter_user_data *user_data,
bt_message_array_const msgs, uint64_t capacity,
uint64_t *count)
{
bt_self_message_iterator *msg_iter,
struct src_iter_user_data *user_data,
bt_message_array_const msgs, uint64_t capacity,
uint64_t *count)
{
bt_self_message_iterator *self_msg_iter,
bt_message_array_const msgs, uint64_t capacity,
uint64_t *count)
bt_self_message_iterator *self_msg_iter,
bt_message_array_const msgs, uint64_t capacity,
uint64_t *count)
bt_self_component_source *self_comp,
const bt_value *params, void *init_method_data)
{
bt_self_component_source *self_comp,
const bt_value *params, void *init_method_data)
{
struct sink_user_data *user_data =
bt_self_component_get_data(
bt_self_component_sink_as_self_component(
self_comp));
struct sink_user_data *user_data =
bt_self_component_get_data(
bt_self_component_sink_as_self_component(
self_comp));
BT_ASSERT(user_data && user_data->msg_iter);
it_ret = common_consume(user_data->msg_iter, false);
BT_ASSERT(user_data && user_data->msg_iter);
it_ret = common_consume(user_data->msg_iter, false);
bt_self_component_sink *self_comp,
bt_self_component_port_input *self_port,
const bt_port_output *other_port)
bt_self_component_sink *self_comp,
bt_self_component_port_input *self_port,
const bt_port_output *other_port)
bt_self_component_sink *self_comp,
const bt_value *params, void *init_method_data)
{
bt_self_component_sink *self_comp,
const bt_value *params, void *init_method_data)
{
const bt_component_sink *sink_comp;
const bt_port_output *upstream_port;
const bt_port_input *downstream_port;
const bt_component_sink *sink_comp;
const bt_port_output *upstream_port;
const bt_port_input *downstream_port;