#include <babeltrace2/babeltrace.h>
#include "common/common.h"
#include "common/assert.h"
#include <babeltrace2/babeltrace.h>
#include "common/common.h"
#include "common/assert.h"
struct bt_param_validation_map_value_entry_descr trimmer_params[] = {
{ "gmt", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
{ "begin", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .validation_func = validate_bound_type } },
struct bt_param_validation_map_value_entry_descr trimmer_params[] = {
{ "gmt", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
{ "begin", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .validation_func = validate_bound_type } },
ns_from_origin != INT64_MAX);
put_messages(msgs, count);
goto found;
ns_from_origin != INT64_MAX);
put_messages(msgs, count);
goto found;
* class has a clock class. And we know it has, otherwise we
* couldn't be using the trimmer component.
*/
* class has a clock class. And we know it has, otherwise we
* couldn't be using the trimmer component.
*/
for (i = 0; i < my_count; i++) {
status = handle_message(trimmer_it, my_msgs[i],
for (i = 0; i < my_count; i++) {
status = handle_message(trimmer_it, my_msgs[i],
* There's at least one message in the output message queue:
* move the messages to the output message array.
*/
* There's at least one message in the output message queue:
* move the messages to the output message array.
*/
bt_component_class_message_iterator_next_method_status status =
BT_COMPONENT_CLASS_MESSAGE_ITERATOR_NEXT_METHOD_STATUS_OK;
bt_component_class_message_iterator_next_method_status status =
BT_COMPONENT_CLASS_MESSAGE_ITERATOR_NEXT_METHOD_STATUS_OK;
if (G_LIKELY(trimmer_it->state == TRIMMER_ITERATOR_STATE_TRIM)) {
status = state_trim(trimmer_it, msgs, capacity, count);
if (G_LIKELY(trimmer_it->state == TRIMMER_ITERATOR_STATE_TRIM)) {
status = state_trim(trimmer_it, msgs, capacity, count);