/*
+ * SPDX-License-Identifier: MIT
+ *
* Copyright 2016 Jérémie Galarneau <jeremie.galarneau@efficios.com>
* Copyright 2019 Philippe Proulx <pproulx@efficios.com>
- *
- * Permission is hereby granted, free of charge, to any person obtaining a copy
- * of this software and associated documentation files (the "Software"), to deal
- * in the Software without restriction, including without limitation the rights
- * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
- * copies of the Software, and to permit persons to whom the Software is
- * furnished to do so, subject to the following conditions:
- *
- * The above copyright notice and this permission notice shall be included in
- * all copies or substantial portions of the Software.
- *
- * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
- * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
- * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
- * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
- * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
- * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
- * SOFTWARE.
*/
#define BT_LOG_OUTPUT_LEVEL (trimmer_comp->log_level)
return g_new0(struct trimmer_comp, 1);
}
-BT_HIDDEN
void trimmer_finalize(bt_self_component_filter *self_comp)
{
struct trimmer_comp *trimmer_comp =
*/
static
int set_bound_from_param(struct trimmer_comp *trimmer_comp,
- const char *param_name, const bt_value *param,
+ const bt_value *param,
struct trimmer_bound *bound, bool is_gmt)
{
int ret;
* Just convert it to a temporary string to handle
* everything the same way.
*/
- sprintf(tmp_arg, "%" PRId64, value);
+ snprintf(tmp_arg, sizeof(tmp_arg), "%" PRId64, value);
arg = tmp_arg;
} else {
BT_ASSERT(bt_value_is_string(param));
value = bt_value_map_borrow_entry_value_const(params, "begin");
if (value) {
- if (set_bound_from_param(trimmer_comp, "begin", value,
+ if (set_bound_from_param(trimmer_comp, value,
&trimmer_comp->begin, trimmer_comp->is_gmt)) {
/* set_bound_from_param() logs errors */
status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_ERROR;
value = bt_value_map_borrow_entry_value_const(params, "end");
if (value) {
- if (set_bound_from_param(trimmer_comp, "end", value,
+ if (set_bound_from_param(trimmer_comp, value,
&trimmer_comp->end, trimmer_comp->is_gmt)) {
/* set_bound_from_param() logs errors */
status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_ERROR;
bt_component_class_initialize_method_status trimmer_init(
bt_self_component_filter *self_comp_flt,
- bt_self_component_filter_configuration *config,
- const bt_value *params, void *init_data)
+ bt_self_component_filter_configuration *config __attribute__((unused)),
+ const bt_value *params,
+ void *init_data __attribute__((unused)))
{
bt_component_class_initialize_method_status status;
bt_self_component_add_port_status add_port_status;
g_free(sstate);
}
-BT_HIDDEN
bt_message_iterator_class_initialize_method_status trimmer_msg_iter_init(
bt_self_message_iterator *self_msg_iter,
bt_self_message_iterator_configuration *config,
- bt_self_component_port_output *port)
+ bt_self_component_port_output *port __attribute__((unused)))
{
bt_message_iterator_class_initialize_method_status status;
bt_message_iterator_create_from_message_iterator_status
msg);
break;
case BT_MESSAGE_TYPE_PACKET_BEGINNING:
- clock_class =
- bt_message_packet_beginning_borrow_stream_class_default_clock_class_const(
- msg);
- if (G_UNLIKELY(!clock_class)) {
- goto error;
+ {
+ const bt_packet *packet = bt_message_packet_beginning_borrow_packet_const(msg);
+ const bt_stream *stream = bt_packet_borrow_stream_const(packet);
+ const bt_stream_class *stream_class = bt_stream_borrow_class_const(stream);
+
+ if (!bt_stream_class_packets_have_beginning_default_clock_snapshot(stream_class)) {
+ goto no_clock_snapshot;
}
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);
- if (G_UNLIKELY(!clock_class)) {
- goto error;
+ {
+ const bt_packet *packet = bt_message_packet_end_borrow_packet_const(msg);
+ const bt_stream *stream = bt_packet_borrow_stream_const(packet);
+ const bt_stream_class *stream_class = bt_stream_borrow_class_const(stream);
+
+ if (!bt_stream_class_packets_have_end_default_clock_snapshot(stream_class)) {
+ goto no_clock_snapshot;
}
clock_snapshot = bt_message_packet_end_borrow_default_clock_snapshot_const(
msg);
break;
+ }
case BT_MESSAGE_TYPE_STREAM_BEGINNING:
{
enum bt_message_stream_clock_snapshot_state cs_state;
break;
}
case BT_MESSAGE_TYPE_DISCARDED_EVENTS:
- clock_class =
- bt_message_discarded_events_borrow_stream_class_default_clock_class_const(
- msg);
- if (G_UNLIKELY(!clock_class)) {
- goto error;
+ {
+ const bt_stream *stream = bt_message_discarded_events_borrow_stream_const(msg);
+ const bt_stream_class *stream_class = bt_stream_borrow_class_const(stream);
+
+ if (!bt_stream_class_discarded_events_have_default_clock_snapshots(stream_class)) {
+ goto no_clock_snapshot;
}
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);
- if (G_UNLIKELY(!clock_class)) {
- goto error;
+ {
+ const bt_stream *stream = bt_message_discarded_packets_borrow_stream_const(msg);
+ const bt_stream_class *stream_class = bt_stream_borrow_class_const(stream);
+
+ if (!bt_stream_class_discarded_packets_have_default_clock_snapshots(stream_class)) {
+ goto no_clock_snapshot;
}
clock_snapshot = bt_message_discarded_packets_borrow_beginning_default_clock_snapshot_const(
msg);
break;
+ }
case BT_MESSAGE_TYPE_MESSAGE_ITERATOR_INACTIVITY:
clock_snapshot =
bt_message_message_iterator_inactivity_borrow_clock_snapshot_const(
return status;
}
-BT_HIDDEN
bt_message_iterator_class_next_method_status trimmer_msg_iter_next(
bt_self_message_iterator *self_msg_iter,
bt_message_array_const msgs, uint64_t capacity,
return status;
}
-BT_HIDDEN
void trimmer_msg_iter_finalize(bt_self_message_iterator *self_msg_iter)
{
struct trimmer_iterator *trimmer_it =
projects / babeltrace.git / blobdiff