*/
#include "trimmer.h"
-#include <babeltrace/component/notification/notification.h>
-#include <babeltrace/component/notification/iterator.h>
-#include <babeltrace/component/private-component.h>
-#include <babeltrace/component/private-port.h>
+#include <babeltrace/babeltrace.h>
struct trimmer_iterator {
/* Input iterator associated with this output iterator. */
- struct bt_notification_iterator *input_iterator;
+ bt_message_iterator *input_iterator;
+ const bt_message *current_message;
+ FILE *err;
+ /* Map between reader and writer packets. */
+ GHashTable *packet_map;
};
BT_HIDDEN
-enum bt_notification_iterator_status trimmer_iterator_init(
- struct bt_private_component *component,
- struct bt_private_port *port,
- struct bt_private_notification_iterator *iterator);
+bt_message_iterator_status trimmer_iterator_init(
+ bt_self_message_iterator *iterator,
+ struct bt_private_port *port);
BT_HIDDEN
-void trimmer_iterator_finalize(struct bt_private_notification_iterator *it);
+void trimmer_iterator_finalize(bt_self_message_iterator *it);
BT_HIDDEN
-struct bt_notification_iterator_next_return trimmer_iterator_next(
- struct bt_private_notification_iterator *iterator);
-
-BT_HIDDEN
-enum bt_notification_iterator_status trimmer_iterator_seek_time(
- struct bt_private_notification_iterator *iterator,
- int64_t time);
+bt_message_iterator_next_method_return trimmer_iterator_next(
+ bt_self_message_iterator *iterator);
#endif /* BABELTRACE_PLUGIN_TRIMMER_ITERATOR_H */