X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=src%2Flib%2Fgraph%2Fmessage%2Fiterator.h;h=d28a88102ac0be6dc53cdb44aae8c8dc88baa7d6;hb=d24d56638469189904fb6ddbb3c725817b3e9417;hp=1ecaa95a991d29329a2816d1ffcc6dd0ca160bca;hpb=da9c4c5260242efe4e3c2ff4a15201f7cbd1c89a;p=babeltrace.git

diff --git a/src/lib/graph/message/iterator.h b/src/lib/graph/message/iterator.h
index 1ecaa95a..d28a8810 100644
--- a/src/lib/graph/message/iterator.h
+++ b/src/lib/graph/message/iterator.h
@@ -28,10 +28,10 @@
 #include "lib/object.h"
 #include <babeltrace2/graph/connection-const.h>
 #include <babeltrace2/graph/message-const.h>
-#include <babeltrace2/graph/message-iterator-const.h>
 #include <babeltrace2/types.h>
 #include "common/assert.h"
 #include <stdbool.h>
+#include <compat/uuid.h>
 
 struct bt_port;
 struct bt_graph;
@@ -76,15 +76,15 @@ struct bt_message_iterator {
 	GPtrArray *msgs;
 };
 
-typedef enum bt_self_message_iterator_status
+typedef enum bt_component_class_message_iterator_next_method_status
 (*bt_self_component_port_input_message_iterator_next_method)(
 		void *, bt_message_array_const, uint64_t, uint64_t *);
 
-typedef enum bt_self_message_iterator_status
+typedef enum bt_component_class_message_iterator_seek_ns_from_origin_method_status
 (*bt_self_component_port_input_message_iterator_seek_ns_from_origin_method)(
 		void *, int64_t);
 
-typedef enum bt_self_message_iterator_status
+typedef enum bt_component_class_message_iterator_seek_beginning_method_status
 (*bt_self_component_port_input_message_iterator_seek_beginning_method)(
 		void *);
 
@@ -113,6 +113,40 @@ struct bt_self_component_port_input_message_iterator {
 
 	enum bt_self_component_port_input_message_iterator_state state;
 
+	/*
+	 * Timestamp of the last received message (or INT64_MIN in the
+	 * beginning, or after a seek to beginning).
+	 */
+	int64_t last_ns_from_origin;
+
+	struct {
+		enum {
+			/* We haven't recorded clock properties yet. */
+			CLOCK_EXPECTATION_UNSET,
+
+			/* Expect to have no clock. */
+			CLOCK_EXPECTATION_NONE,
+
+			/* Clock with origin_is_unix_epoch true.*/
+			CLOCK_EXPECTATION_ORIGIN_UNIX,
+
+			/* Clock with origin_is_unix_epoch false, with a UUID.*/
+			CLOCK_EXPECTATION_ORIGIN_OTHER_UUID,
+
+			/* Clock with origin_is_unix_epoch false, without a UUID.*/
+			CLOCK_EXPECTATION_ORIGIN_OTHER_NO_UUID,
+		} type;
+
+		/*
+		 * Expected UUID of the clock, if `type`is CLOCK_EXPECTATION_ORIGIN_OTHER_UUID.
+		 *
+		 * If the clock's origin is the unix epoch, the UUID is
+		 * irrelevant (as the clock will be correlatable with other
+		 * clocks having the same origin).
+		 */
+		uint8_t uuid[BABELTRACE_UUID_LEN];
+	} clock_expectation;
+
 	/*
 	 * Data necessary for auto seek (the seek-to-beginning then fast-forward
 	 * seek strategy).
@@ -131,6 +165,14 @@ struct bt_self_component_port_input_message_iterator {
 		 * send is the first of the queue).
 		 */
 		GQueue *msgs;
+
+		/*
+		 * After auto-seeking, we replace the iterator's `next` callback
+		 * with our own, which returns the contents of the `msgs` queue.
+		 * This field is where we save the original callback, so we can
+		 * restore it.
+		 */
+		void *original_next_callback;
 	} auto_seek;
 
 	void *user_data;