projects / babeltrace.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
lib: add aliases for Babeltrace structure types
[babeltrace.git] / plugins / utils / muxer / muxer.c
diff --git a/plugins/utils/muxer/muxer.c b/plugins/utils/muxer/muxer.c
index 7c5991abb3685806638fbae0f57f26d9dacfb91a..9aa69223dc8bdf9d44a06827bce090f250da7810 100644 (file)
--- a/plugins/utils/muxer/muxer.c
+++ b/plugins/utils/muxer/muxer.c
@@ -26,7 +26,7 @@
 #include <babeltrace/babeltrace-internal.h>
 #include <babeltrace/compat/uuid-internal.h>
 #include <babeltrace/babeltrace.h>
-#include <babeltrace/values-internal.h>
+#include <babeltrace/value-internal.h>
 #include <babeltrace/graph/component-internal.h>
 #include <babeltrace/graph/notification-iterator-internal.h>
 #include <babeltrace/graph/connection-internal.h>
@@ -50,7 +50,7 @@ struct muxer_comp {
        GPtrArray *muxer_notif_iters;
 
        /* Weak ref */
-       struct bt_self_component_filter *self_comp;
+       bt_self_component_filter *self_comp;
 
        unsigned int next_port_num;
        size_t available_input_ports;
@@ -60,9 +60,9 @@ struct muxer_comp {
 
 struct muxer_upstream_notif_iter {
        /* Owned by this, NULL if ended */
-       struct bt_self_component_port_input_notification_iterator *notif_iter;
+       bt_self_component_port_input_notification_iterator *notif_iter;
 
-       /* Contains `struct bt_notification *`, owned by this */
+       /* Contains `const bt_notification *`, owned by this */
        GQueue *notifs;
 };
 
@@ -122,14 +122,14 @@ void destroy_muxer_upstream_notif_iter(
                muxer_upstream_notif_iter,
                muxer_upstream_notif_iter->notif_iter,
                muxer_upstream_notif_iter->notifs->length);
-       bt_object_put_ref(muxer_upstream_notif_iter->notif_iter);
+       bt_self_component_port_input_notification_iterator_put_ref(muxer_upstream_notif_iter->notif_iter);
 
        if (muxer_upstream_notif_iter->notifs) {
-               struct bt_notification *notif;
+               const bt_notification *notif;
 
                while ((notif = g_queue_pop_head(
                                muxer_upstream_notif_iter->notifs))) {
-                       bt_object_put_ref(notif);
+                       bt_notification_put_ref(notif);
                }
 
                g_queue_free(muxer_upstream_notif_iter->notifs);
@@ -141,7 +141,7 @@ void destroy_muxer_upstream_notif_iter(
 static
 struct muxer_upstream_notif_iter *muxer_notif_iter_add_upstream_notif_iter(
                struct muxer_notif_iter *muxer_notif_iter,
-               struct bt_self_component_port_input_notification_iterator *self_notif_iter)
+               bt_self_component_port_input_notification_iterator *self_notif_iter)
 {
        struct muxer_upstream_notif_iter *muxer_upstream_notif_iter =
                g_new0(struct muxer_upstream_notif_iter, 1);
@@ -152,7 +152,7 @@ struct muxer_upstream_notif_iter *muxer_notif_iter_add_upstream_notif_iter(
        }
 
        muxer_upstream_notif_iter->notif_iter = self_notif_iter;
-       bt_object_get_ref(muxer_upstream_notif_iter->notif_iter);
+       bt_self_component_port_input_notification_iterator_get_ref(muxer_upstream_notif_iter->notif_iter);
        muxer_upstream_notif_iter->notifs = g_queue_new();
        if (!muxer_upstream_notif_iter->notifs) {
                BT_LOGE_STR("Failed to allocate a GQueue.");
@@ -172,7 +172,7 @@ end:
 
 static
 enum bt_self_component_status ensure_available_input_port(
-               struct bt_self_component_filter *self_comp)
+               bt_self_component_filter *self_comp)
 {
        struct muxer_comp *muxer_comp = bt_self_component_get_data(
                bt_self_component_filter_as_self_component(self_comp));
@@ -218,7 +218,7 @@ end:
 
 static
 enum bt_self_component_status create_output_port(
-               struct bt_self_component_filter *self_comp)
+               bt_self_component_filter *self_comp)
 {
        return bt_self_component_filter_add_output_port(
                self_comp, "out", NULL, NULL);
@@ -244,9 +244,9 @@ void destroy_muxer_comp(struct muxer_comp *muxer_comp)
 }
 
 static
-struct bt_value *get_default_params(void)
+bt_value *get_default_params(void)
 {
-       struct bt_value *params;
+       bt_value *params;
        int ret;
 
        params = bt_value_map_create();
@@ -265,7 +265,7 @@ struct bt_value *get_default_params(void)
        goto end;
 
 error:
-       BT_OBJECT_PUT_REF_AND_RESET(params);
+       BT_VALUE_PUT_REF_AND_RESET(params);
 
 end:
        return params;
@@ -273,11 +273,11 @@ end:
 
 static
 int configure_muxer_comp(struct muxer_comp *muxer_comp,
-               const struct bt_value *params)
+               const bt_value *params)
 {
-       struct bt_value *default_params = NULL;
-       struct bt_value *real_params = NULL;
-       const struct bt_value *assume_absolute_clock_classes = NULL;
+       bt_value *default_params = NULL;
+       bt_value *real_params = NULL;
+       const bt_value *assume_absolute_clock_classes = NULL;
        int ret = 0;
        bt_bool bool_val;
 
@@ -288,8 +288,7 @@ int configure_muxer_comp(struct muxer_comp *muxer_comp,
                goto error;
        }
 
-       ret = bt_value_map_extend(&real_params,
-               default_params, params);
+       ret = bt_value_map_extend(default_params, params, &real_params);
        if (ret) {
                BT_LOGE("Cannot extend default parameters map value: "
                        "muxer-comp-addr=%p, def-params-addr=%p, "
@@ -321,15 +320,15 @@ error:
        ret = -1;
 
 end:
-       bt_object_put_ref(default_params);
-       bt_object_put_ref(real_params);
+       bt_value_put_ref(default_params);
+       bt_value_put_ref(real_params);
        return ret;
 }
 
 BT_HIDDEN
 enum bt_self_component_status muxer_init(
-               struct bt_self_component_filter *self_comp,
-               struct bt_value *params, void *init_data)
+               bt_self_component_filter *self_comp,
+               bt_value *params, void *init_data)
 {
        int ret;
        enum bt_self_component_status status = BT_SELF_COMPONENT_STATUS_OK;
@@ -400,7 +399,7 @@ end:
 }
 
 BT_HIDDEN
-void muxer_finalize(struct bt_self_component_filter *self_comp)
+void muxer_finalize(bt_self_component_filter *self_comp)
 {
        struct muxer_comp *muxer_comp = bt_self_component_get_data(
                bt_self_component_filter_as_self_component(self_comp));
@@ -411,14 +410,14 @@ void muxer_finalize(struct bt_self_component_filter *self_comp)
 }
 
 static
-struct bt_self_component_port_input_notification_iterator *
+bt_self_component_port_input_notification_iterator *
 create_notif_iter_on_input_port(
-               struct bt_self_component_port_input *self_port, int *ret)
+               bt_self_component_port_input *self_port, int *ret)
 {
-       struct bt_port *port = bt_self_component_port_as_port(
+       const bt_port *port = bt_self_component_port_as_port(
                bt_self_component_port_input_as_self_component_port(
                        self_port));
-       struct bt_self_component_port_input_notification_iterator *notif_iter =
+       bt_self_component_port_input_notification_iterator *notif_iter =
                NULL;
 
        BT_ASSERT(ret);
@@ -452,7 +451,7 @@ enum bt_notification_iterator_status muxer_upstream_notif_iter_next(
                struct muxer_upstream_notif_iter *muxer_upstream_notif_iter)
 {
        enum bt_notification_iterator_status status;
-       bt_notification_array notifs;
+       bt_notification_array_const notifs;
        uint64_t i;
        uint64_t count;
 
@@ -482,7 +481,7 @@ enum bt_notification_iterator_status muxer_upstream_notif_iter_next(
                         * from the head first.
                         */
                        g_queue_push_tail(muxer_upstream_notif_iter->notifs,
-                               notifs[i]);
+                               (void *) notifs[i]);
                }
                break;
        case BT_NOTIFICATION_ITERATOR_STATUS_AGAIN:
@@ -499,7 +498,7 @@ enum bt_notification_iterator_status muxer_upstream_notif_iter_next(
                 * won't be considered again to find the youngest
                 * notification.
                 */
-               BT_OBJECT_PUT_REF_AND_RESET(muxer_upstream_notif_iter->notif_iter);
+               BT_SELF_COMPONENT_PORT_INPUT_NOTIFICATION_ITERATOR_PUT_REF_AND_RESET(muxer_upstream_notif_iter->notif_iter);
                status = BT_NOTIFICATION_ITERATOR_STATUS_OK;
                break;
        default:
@@ -532,9 +531,9 @@ int muxer_notif_iter_handle_newly_connected_ports(
         */
        while (true) {
                GList *node = muxer_notif_iter->newly_connected_self_ports;
-               struct bt_self_component_port_input *self_port;
-               struct bt_port *port;
-               struct bt_self_component_port_input_notification_iterator *
+               bt_self_component_port_input *self_port;
+               const bt_port *port;
+               bt_self_component_port_input_notification_iterator *
                        upstream_notif_iter = NULL;
                struct muxer_upstream_notif_iter *muxer_upstream_notif_iter;
 
@@ -569,7 +568,7 @@ int muxer_notif_iter_handle_newly_connected_ports(
                muxer_upstream_notif_iter =
                        muxer_notif_iter_add_upstream_notif_iter(
                                muxer_notif_iter, upstream_notif_iter);
-               BT_OBJECT_PUT_REF_AND_RESET(upstream_notif_iter);
+               BT_SELF_COMPONENT_PORT_INPUT_NOTIFICATION_ITERATOR_PUT_REF_AND_RESET(upstream_notif_iter);
                if (!muxer_upstream_notif_iter) {
                        /*
                         * muxer_notif_iter_add_upstream_notif_iter()
@@ -579,7 +578,7 @@ int muxer_notif_iter_handle_newly_connected_ports(
                }
 
 remove_node:
-               bt_object_put_ref(upstream_notif_iter);
+               bt_self_component_port_input_notification_iterator_put_ref(upstream_notif_iter);
                muxer_notif_iter->newly_connected_self_ports =
                        g_list_delete_link(
                                muxer_notif_iter->newly_connected_self_ports,
@@ -600,12 +599,12 @@ end:
 static
 int get_notif_ts_ns(struct muxer_comp *muxer_comp,
                struct muxer_notif_iter *muxer_notif_iter,
-               struct bt_notification *notif, int64_t last_returned_ts_ns,
+               const bt_notification *notif, int64_t last_returned_ts_ns,
                int64_t *ts_ns)
 {
-       const struct bt_clock_class *clock_class = NULL;
-       const struct bt_clock_value *clock_value = NULL;
-       const struct bt_event *event = NULL;
+       const bt_clock_class *clock_class = NULL;
+       const bt_clock_value *clock_value = NULL;
+       const bt_event *event = NULL;
        int ret = 0;
        const unsigned char *cc_uuid;
        const char *cc_name;
@@ -621,7 +620,7 @@ int get_notif_ts_ns(struct muxer_comp *muxer_comp,
 
        switch (bt_notification_get_type(notif)) {
        case BT_NOTIFICATION_TYPE_EVENT:
-               event = bt_notification_event_borrow_event(notif);
+               event = bt_notification_event_borrow_event_const(notif);
                BT_ASSERT(event);
                cv_status = bt_event_borrow_default_clock_value_const(event,
                        &clock_value);
@@ -629,7 +628,7 @@ int get_notif_ts_ns(struct muxer_comp *muxer_comp,
 
        case BT_NOTIFICATION_TYPE_INACTIVITY:
                clock_value =
-                       bt_notification_inactivity_borrow_default_clock_value(
+                       bt_notification_inactivity_borrow_default_clock_value_const(
                                notif);
                break;
        default:
@@ -871,7 +870,7 @@ muxer_notif_iter_youngest_upstream_notif_iter(
        *muxer_upstream_notif_iter = NULL;
 
        for (i = 0; i < muxer_notif_iter->muxer_upstream_notif_iters->len; i++) {
-               struct bt_notification *notif;
+               const bt_notification *notif;
                struct muxer_upstream_notif_iter *cur_muxer_upstream_notif_iter =
                        g_ptr_array_index(muxer_notif_iter->muxer_upstream_notif_iters, i);
                int64_t notif_ts_ns;
@@ -1005,7 +1004,7 @@ static inline
 enum bt_notification_iterator_status muxer_notif_iter_do_next_one(
                struct muxer_comp *muxer_comp,
                struct muxer_notif_iter *muxer_notif_iter,
-               struct bt_notification **notif)
+               const bt_notification **notif)
 {
        enum bt_notification_iterator_status status =
                BT_NOTIFICATION_ITERATOR_STATUS_OK;
@@ -1106,7 +1105,7 @@ static
 enum bt_notification_iterator_status muxer_notif_iter_do_next(
                struct muxer_comp *muxer_comp,
                struct muxer_notif_iter *muxer_notif_iter,
-               bt_notification_array notifs, uint64_t capacity,
+               bt_notification_array_const notifs, uint64_t capacity,
                uint64_t *count)
 {
        enum bt_notification_iterator_status status =
@@ -1185,10 +1184,10 @@ int muxer_notif_iter_init_newly_connected_ports(struct muxer_comp *muxer_comp,
        }
 
        for (i = 0; i < count; i++) {
-               struct bt_self_component_port_input *self_port =
+               bt_self_component_port_input *self_port =
                        bt_self_component_filter_borrow_input_port_by_index(
                                muxer_comp->self_comp, i);
-               struct bt_port *port;
+               const bt_port *port;
 
                BT_ASSERT(self_port);
                port = bt_self_component_port_as_port(
@@ -1228,9 +1227,9 @@ end:
 
 BT_HIDDEN
 enum bt_self_notification_iterator_status muxer_notif_iter_init(
-               struct bt_self_notification_iterator *self_notif_iter,
-               struct bt_self_component_filter *self_comp,
-               struct bt_self_component_port_output *port)
+               bt_self_notification_iterator *self_notif_iter,
+               bt_self_component_filter *self_comp,
+               bt_self_component_port_output *port)
 {
        struct muxer_comp *muxer_comp = NULL;
        struct muxer_notif_iter *muxer_notif_iter = NULL;
@@ -1320,11 +1319,11 @@ end:
 
 BT_HIDDEN
 void muxer_notif_iter_finalize(
-               struct bt_self_notification_iterator *self_notif_iter)
+               bt_self_notification_iterator *self_notif_iter)
 {
        struct muxer_notif_iter *muxer_notif_iter =
                bt_self_notification_iterator_get_data(self_notif_iter);
-       struct bt_self_component *self_comp = NULL;
+       bt_self_component *self_comp = NULL;
        struct muxer_comp *muxer_comp = NULL;
 
        self_comp = bt_self_notification_iterator_borrow_component(
@@ -1345,14 +1344,14 @@ void muxer_notif_iter_finalize(
 
 BT_HIDDEN
 enum bt_notification_iterator_status muxer_notif_iter_next(
-               struct bt_self_notification_iterator *self_notif_iter,
-               bt_notification_array notifs, uint64_t capacity,
+               bt_self_notification_iterator *self_notif_iter,
+               bt_notification_array_const notifs, uint64_t capacity,
                uint64_t *count)
 {
        enum bt_notification_iterator_status status;
        struct muxer_notif_iter *muxer_notif_iter =
                bt_self_notification_iterator_get_data(self_notif_iter);
-       struct bt_self_component *self_comp = NULL;
+       bt_self_component *self_comp = NULL;
        struct muxer_comp *muxer_comp = NULL;
 
        BT_ASSERT(muxer_notif_iter);
@@ -1385,12 +1384,12 @@ enum bt_notification_iterator_status muxer_notif_iter_next(
 
 BT_HIDDEN
 enum bt_self_component_status muxer_input_port_connected(
-               struct bt_self_component_filter *self_comp,
-               struct bt_self_component_port_input *self_port,
-               struct bt_port_output *other_port)
+               bt_self_component_filter *self_comp,
+               bt_self_component_port_input *self_port,
+               const bt_port_output *other_port)
 {
        enum bt_self_component_status status = BT_SELF_COMPONENT_STATUS_OK;
-       struct bt_port *port = bt_self_component_port_as_port(
+       const bt_port *port = bt_self_component_port_as_port(
                bt_self_component_port_input_as_self_component_port(
                        self_port));
        struct muxer_comp *muxer_comp =
@@ -1408,7 +1407,7 @@ enum bt_self_component_status muxer_input_port_connected(
                "other-port-addr=%p, other-port-name=\"%s\"",
                self_comp, muxer_comp, self_port, bt_port_get_name(port),
                other_port,
-               bt_port_get_name(bt_port_output_as_port(other_port)));
+               bt_port_get_name(bt_port_output_as_port_const(other_port)));
 
        for (i = 0; i < muxer_comp->muxer_notif_iters->len; i++) {
                struct muxer_notif_iter *muxer_notif_iter =
@@ -1461,14 +1460,14 @@ end:
 
 BT_HIDDEN
 void muxer_input_port_disconnected(
-               struct bt_self_component_filter *self_component,
-               struct bt_self_component_port_input *self_port)
+               bt_self_component_filter *self_component,
+               bt_self_component_port_input *self_port)
 {
        struct muxer_comp *muxer_comp =
                bt_self_component_get_data(
                        bt_self_component_filter_as_self_component(
                                self_component));
-       struct bt_port *port =
+       const bt_port *port =
                bt_self_component_port_as_port(
                        bt_self_component_port_input_as_self_component_port(
                                self_port));
BabelTrace - Trace Format Babel Tower
This page took 0.050784 seconds and 4 git commands to generate.