* SOFTWARE.
*/
-#define BT_LOG_TAG "PLUGIN-UTILS-MUXER-FLT"
+#define BT_LOG_TAG "PLUGIN/FLT.UTILS.MUXER"
#include "logging.h"
#include "common/macros.h"
#include "lib/graph/component.h"
#include "lib/graph/message/iterator.h"
#include "lib/graph/connection.h"
-#include "plugins/plugins-common.h"
#include <glib.h>
#include <stdbool.h>
#include <inttypes.h>
muxer_comp->available_input_ports++;
muxer_comp->next_port_num++;
- BT_LOGD("Added one input port to muxer component: "
+ BT_LOGI("Added one input port to muxer component: "
"port-name=\"%s\", comp-addr=%p",
port_name->str, self_comp);
bool_val = bt_value_bool_get(assume_absolute_clock_classes);
muxer_comp->assume_absolute_clock_classes = (bool) bool_val;
- BT_LOGD("Configured muxer component: muxer-comp-addr=%p, "
+ BT_LOGI("Configured muxer component: muxer-comp-addr=%p, "
"assume-absolute-clock-classes=%d",
muxer_comp, muxer_comp->assume_absolute_clock_classes);
goto end;
bt_self_component_status status = BT_SELF_COMPONENT_STATUS_OK;
struct muxer_comp *muxer_comp = g_new0(struct muxer_comp, 1);
- BT_LOGD("Initializing muxer component: "
+ BT_LOGI("Initializing muxer component: "
"comp-addr=%p, params-addr=%p", self_comp, params);
if (!muxer_comp) {
goto error;
}
- BT_LOGD("Initialized muxer component: "
+ BT_LOGI("Initialized muxer component: "
"comp-addr=%p, params-addr=%p, muxer-comp-addr=%p",
self_comp, params, muxer_comp);
struct muxer_comp *muxer_comp = bt_self_component_get_data(
bt_self_component_filter_as_self_component(self_comp));
- BT_LOGD("Finalizing muxer component: comp-addr=%p",
+ BT_LOGI("Finalizing muxer component: comp-addr=%p",
self_comp);
destroy_muxer_comp(muxer_comp);
}
goto end;
}
- BT_LOGD("Created upstream message iterator on input port: "
+ BT_LOGI("Created upstream message iterator on input port: "
"port-addr=%p, port-name=\"%s\", msg-iter-addr=%p",
port, bt_port_get_name(port), msg_iter);
uint64_t i;
uint64_t count;
- BT_LOGV("Calling upstream message iterator's \"next\" method: "
+ BT_LOGD("Calling upstream message iterator's \"next\" method: "
"muxer-upstream-msg-iter-wrap-addr=%p, msg-iter-addr=%p",
muxer_upstream_msg_iter,
muxer_upstream_msg_iter->msg_iter);
input_port_iter_status = bt_self_component_port_input_message_iterator_next(
muxer_upstream_msg_iter->msg_iter, &msgs, &count);
- BT_LOGV("Upstream message iterator's \"next\" method returned: "
+ BT_LOGD("Upstream message iterator's \"next\" method returned: "
"status=%s", bt_message_iterator_status_string(input_port_iter_status));
switch (input_port_iter_status) {
* Message iterator's current message is
* valid: it must be considered for muxing operations.
*/
- BT_LOGV_STR("Validated upstream message iterator wrapper.");
+ BT_LOGD_STR("Validated upstream message iterator wrapper.");
BT_ASSERT(count > 0);
/* Move messages to our queue */
BT_ASSERT(msg);
BT_ASSERT(ts_ns);
- BT_LOGV("Getting message's timestamp: "
+ BT_LOGD("Getting message's timestamp: "
"muxer-msg-iter-addr=%p, msg-addr=%p, "
"last-returned-ts=%" PRId64,
muxer_msg_iter, msg, last_returned_ts_ns);
break;
default:
/* All the other messages have a higher priority */
- BT_LOGV_STR("Message has no timestamp: using the last returned timestamp.");
+ BT_LOGD_STR("Message has no timestamp: using the last returned timestamp.");
*ts_ns = last_returned_ts_ns;
goto end;
}
goto end;
no_clock_snapshot:
- BT_LOGV_STR("Message's default clock snapshot is missing: "
+ BT_LOGD_STR("Message's default clock snapshot is missing: "
"using the last returned timestamp.");
*ts_ns = last_returned_ts_ns;
goto end;
end:
if (ret == 0) {
- BT_LOGV("Found message's timestamp: "
+ BT_LOGD("Found message's timestamp: "
"muxer-msg-iter-addr=%p, msg-addr=%p, "
"last-returned-ts=%" PRId64 ", ts=%" PRId64,
muxer_msg_iter, msg, last_returned_ts_ns,
bt_self_message_iterator_status status =
BT_SELF_MESSAGE_ITERATOR_STATUS_OK;
- BT_LOGV("Validating muxer's upstream message iterator wrapper: "
+ BT_LOGD("Validating muxer's upstream message iterator wrapper: "
"muxer-upstream-msg-iter-wrap-addr=%p",
muxer_upstream_msg_iter);
if (muxer_upstream_msg_iter->msgs->length > 0 ||
!muxer_upstream_msg_iter->msg_iter) {
- BT_LOGV("Already valid or not considered: "
+ BT_LOGD("Already valid or not considered: "
"queue-len=%u, upstream-msg-iter-addr=%p",
muxer_upstream_msg_iter->msgs->length,
muxer_upstream_msg_iter->msg_iter);
BT_SELF_MESSAGE_ITERATOR_STATUS_OK;
size_t i;
- BT_LOGV("Validating muxer's upstream message iterator wrappers: "
+ BT_LOGD("Validating muxer's upstream message iterator wrappers: "
"muxer-msg-iter-addr=%p", muxer_msg_iter);
for (i = 0; i < muxer_msg_iter->active_muxer_upstream_msg_iters->len;
muxer_msg_iter,
muxer_upstream_msg_iter);
} else {
- BT_LOGV("Cannot validate muxer's upstream message iterator wrapper: "
+ BT_LOGD("Cannot validate muxer's upstream message iterator wrapper: "
"muxer-msg-iter-addr=%p, "
"muxer-upstream-msg-iter-wrap-addr=%p",
muxer_msg_iter,
* array of ended iterators if it's ended.
*/
if (G_UNLIKELY(is_ended)) {
- BT_LOGV("Muxer's upstream message iterator wrapper: ended or canceled: "
+ BT_LOGD("Muxer's upstream message iterator wrapper: ended or canceled: "
"muxer-msg-iter-addr=%p, "
"muxer-upstream-msg-iter-wrap-addr=%p",
muxer_msg_iter, muxer_upstream_msg_iter);
"status=%s",
bt_common_self_message_iterator_status_string(status));
} else {
- BT_LOGV("Cannot find the youngest upstream message iterator wrapper: "
+ BT_LOGD("Cannot find the youngest upstream message iterator wrapper: "
"status=%s",
bt_common_self_message_iterator_status_string(status));
}
goto end;
}
- BT_LOGV("Found youngest upstream message iterator wrapper: "
+ BT_LOGD("Found youngest upstream message iterator wrapper: "
"muxer-msg-iter-addr=%p, "
"muxer-upstream-msg-iter-wrap-addr=%p, "
"ts=%" PRId64,