live_stream_iter->current_inactivity_ts); \
} while (0);
-BT_HIDDEN
bool lttng_live_graph_is_canceled(struct lttng_live_msg_iter *msg_iter)
{
bool ret;
return trace;
}
-BT_HIDDEN
struct lttng_live_trace *
lttng_live_session_borrow_or_create_trace_by_id(struct lttng_live_session *session,
uint64_t trace_id)
return trace;
}
-BT_HIDDEN
int lttng_live_add_session(struct lttng_live_msg_iter *lttng_live_msg_iter, uint64_t session_id,
const char *hostname, const char *session_name)
{
return;
}
-BT_HIDDEN
void lttng_live_msg_iter_finalize(bt_self_message_iterator *self_msg_iter)
{
struct lttng_live_msg_iter *lttng_live_msg_iter;
if (orig_state == LTTNG_LIVE_STREAM_QUIESCENT_NO_DATA && last_inact_ts == curr_inact_ts) {
/*
- * Because the stream is in the QUIESCENT_NO_DATA
- * state, we can assert that the last_inactivity_ts was
- * set and can be safely used in the `if` above.
- */
+ * Because the stream is in the QUIESCENT_NO_DATA
+ * state, we can assert that the last_inactivity_ts was
+ * set and can be safely used in the `if` above.
+ */
BT_ASSERT(lttng_live_stream->last_inactivity_ts.is_set);
ret = LTTNG_LIVE_ITERATOR_STATUS_AGAIN;
return ret;
}
-static int live_get_msg_ts_ns(struct lttng_live_stream_iterator *stream_iter,
+static int live_get_msg_ts_ns(struct lttng_live_stream_iterator *,
struct lttng_live_msg_iter *lttng_live_msg_iter,
const bt_message *msg, int64_t last_msg_ts_ns, int64_t *ts_ns)
{
- const bt_clock_class *clock_class = NULL;
const bt_clock_snapshot *clock_snapshot = NULL;
int ret = 0;
bt_logging_level log_level = lttng_live_msg_iter->log_level;
switch (bt_message_get_type(msg)) {
case BT_MESSAGE_TYPE_EVENT:
- clock_class = bt_message_event_borrow_stream_class_default_clock_class_const(msg);
- BT_ASSERT_DBG(clock_class);
-
clock_snapshot = bt_message_event_borrow_default_clock_snapshot_const(msg);
break;
case BT_MESSAGE_TYPE_PACKET_BEGINNING:
- clock_class =
- bt_message_packet_beginning_borrow_stream_class_default_clock_class_const(msg);
- BT_ASSERT(clock_class);
-
clock_snapshot = bt_message_packet_beginning_borrow_default_clock_snapshot_const(msg);
break;
case BT_MESSAGE_TYPE_PACKET_END:
- clock_class = bt_message_packet_end_borrow_stream_class_default_clock_class_const(msg);
- BT_ASSERT(clock_class);
-
clock_snapshot = bt_message_packet_end_borrow_default_clock_snapshot_const(msg);
break;
case BT_MESSAGE_TYPE_DISCARDED_EVENTS:
- clock_class =
- bt_message_discarded_events_borrow_stream_class_default_clock_class_const(msg);
- BT_ASSERT(clock_class);
-
clock_snapshot =
bt_message_discarded_events_borrow_beginning_default_clock_snapshot_const(msg);
break;
case BT_MESSAGE_TYPE_DISCARDED_PACKETS:
- clock_class =
- bt_message_discarded_packets_borrow_stream_class_default_clock_class_const(msg);
- BT_ASSERT(clock_class);
-
clock_snapshot =
bt_message_discarded_packets_borrow_beginning_default_clock_snapshot_const(msg);
break;
goto end;
}
- clock_class = bt_clock_snapshot_borrow_clock_class_const(clock_snapshot);
- BT_ASSERT_DBG(clock_class);
-
ret = bt_clock_snapshot_get_ns_from_origin(clock_snapshot, ts_ns);
if (ret) {
BT_COMP_LOGE_APPEND_CAUSE(self_comp,
}
}
-BT_HIDDEN
bt_message_iterator_class_next_method_status
lttng_live_msg_iter_next(bt_self_message_iterator *self_msg_it, bt_message_array_const msgs,
uint64_t capacity, uint64_t *count)
return lttng_live_msg_iter;
}
-BT_HIDDEN
bt_message_iterator_class_initialize_method_status
lttng_live_msg_iter_init(bt_self_message_iterator *self_msg_it,
- bt_self_message_iterator_configuration *config,
- bt_self_component_port_output *self_port)
+ bt_self_message_iterator_configuration *,
+ bt_self_component_port_output *)
{
bt_message_iterator_class_initialize_method_status status;
struct lttng_live_component *lttng_live;
const bt_value *input_type_value;
const bt_value *input_value;
double weight = 0;
- struct bt_common_lttng_live_url_parts parts = {0};
+ struct bt_common_lttng_live_url_parts parts = {};
/* Used by the logging macros */
__attribute__((unused)) bt_self_component *self_comp = NULL;
return status;
}
-BT_HIDDEN
bt_component_class_query_method_status lttng_live_query(bt_self_component_class_source *comp_class,
bt_private_query_executor *priv_query_exec,
const char *object, const bt_value *params,
g_free(lttng_live);
}
-BT_HIDDEN
void lttng_live_component_finalize(bt_self_component_source *component)
{
lttng_live_component *data = (lttng_live_component *) bt_self_component_get_data(
return status;
}
-BT_HIDDEN
bt_component_class_initialize_method_status
lttng_live_component_init(bt_self_component_source *self_comp_src,
- bt_self_component_source_configuration *config, const bt_value *params,
- __attribute__((unused)) void *init_method_data)
+ bt_self_component_source_configuration *, const bt_value *params,
+ void *)
{
struct lttng_live_component *lttng_live;
bt_component_class_initialize_method_status ret;