X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=src%2Flib%2Fgraph%2Fiterator.c;h=4dd69c6ae69477c26b54ac35e3c22b2033c79ef0;hb=a3f0c7db90f4cfc81090a83a7442b7bc624d5789;hp=cb0c6523fbca9cd7605e5523bb35d5a53a9a16e7;hpb=21a9f056fd7d86d18aa7a1700c7f47d93eb1adeb;p=babeltrace.git

diff --git a/src/lib/graph/iterator.c b/src/lib/graph/iterator.c
index cb0c6523..4dd69c6a 100644
--- a/src/lib/graph/iterator.c
+++ b/src/lib/graph/iterator.c
@@ -60,6 +60,7 @@
 #include "lib/assert-post.h"
 #include <stdint.h>
 #include <inttypes.h>
+#include <stdbool.h>
 #include <stdlib.h>
 
 #include "component-class.h"
@@ -68,6 +69,7 @@
 #include "component-source.h"
 #include "connection.h"
 #include "graph.h"
+#include "message-iterator-class.h"
 #include "message/discarded-items.h"
 #include "message/event.h"
 #include "message/iterator.h"
@@ -95,7 +97,7 @@ void set_self_comp_port_input_msg_iterator_state(
 		struct bt_self_component_port_input_message_iterator *iterator,
 		enum bt_self_component_port_input_message_iterator_state state)
 {
-	BT_ASSERT(iterator);
+	BT_ASSERT_DBG(iterator);
 	BT_LIB_LOGD("Updating message iterator's state: new-state=%s",
 		bt_self_component_port_input_message_iterator_state_string(state));
 	iterator->state = state;
@@ -137,7 +139,7 @@ void bt_self_component_port_input_message_iterator_destroy(struct bt_object *obj
 
 	if (iterator->auto_seek.msgs) {
 		while (!g_queue_is_empty(iterator->auto_seek.msgs)) {
-			bt_object_put_no_null_check(
+			bt_object_put_ref_no_null_check(
 				g_queue_pop_tail(iterator->auto_seek.msgs));
 		}
 
@@ -168,19 +170,24 @@ void bt_self_component_port_input_message_iterator_try_finalize(
 		struct bt_self_component_port_input_message_iterator *iterator)
 {
 	uint64_t i;
-	typedef void (*method_t)(void *);
-
-	struct bt_component_class *comp_class = NULL;
-	method_t method = NULL;
+	bool call_user_finalize = true;
 
 	BT_ASSERT(iterator);
 
 	switch (iterator->state) {
 	case BT_SELF_COMPONENT_PORT_INPUT_MESSAGE_ITERATOR_STATE_NON_INITIALIZED:
-		/* Skip user finalization if user initialization failed */
-		BT_LIB_LOGD("Not finalizing non-initialized message iterator: "
-			"%!+i", iterator);
-		goto end;
+		/*
+		 * If this function is called while the iterator is in the
+		 * NON_INITIALIZED state, it means the user initialization
+		 * method has either not been called, or has failed.  We
+		 * therefore don't want to call the user finalization method.
+		 * However, the initialization method might have created some
+		 * upstream message iterators before failing, so we want to
+		 * execute the rest of this function, which unlinks the related
+		 * iterators.
+		 */
+		call_user_finalize = false;
+		break;
 	case BT_SELF_COMPONENT_PORT_INPUT_MESSAGE_ITERATOR_STATE_FINALIZED:
 		/* Already finalized */
 		BT_LIB_LOGD("Not finalizing message iterator: already finalized: "
@@ -190,7 +197,7 @@ void bt_self_component_port_input_message_iterator_try_finalize(
 		/* Finalizing */
 		BT_LIB_LOGF("Message iterator is already being finalized: "
 			"%!+i", iterator);
-		abort();
+		bt_common_abort();
 	default:
 		break;
 	}
@@ -199,35 +206,49 @@ void bt_self_component_port_input_message_iterator_try_finalize(
 	set_self_comp_port_input_msg_iterator_state(iterator,
 		BT_SELF_COMPONENT_PORT_INPUT_MESSAGE_ITERATOR_STATE_FINALIZING);
 	BT_ASSERT(iterator->upstream_component);
-	comp_class = iterator->upstream_component->class;
 
 	/* Call user-defined destroy method */
-	switch (comp_class->type) {
-	case BT_COMPONENT_CLASS_TYPE_SOURCE:
-	{
-		struct bt_component_class_source *src_comp_cls =
-			(void *) comp_class;
+	if (call_user_finalize) {
+		typedef void (*method_t)(void *);
+		method_t method = NULL;
+		struct bt_component_class *comp_class =
+			iterator->upstream_component->class;
+
+		switch (comp_class->type) {
+		case BT_COMPONENT_CLASS_TYPE_SOURCE:
+		{
+			struct bt_component_class_source *src_comp_cls =
+				(void *) comp_class;
 
-		method = (method_t) src_comp_cls->methods.msg_iter_finalize;
-		break;
-	}
-	case BT_COMPONENT_CLASS_TYPE_FILTER:
-	{
-		struct bt_component_class_filter *flt_comp_cls =
-			(void *) comp_class;
+			method = (method_t) src_comp_cls->msg_iter_cls->methods.finalize;
+			break;
+		}
+		case BT_COMPONENT_CLASS_TYPE_FILTER:
+		{
+			struct bt_component_class_filter *flt_comp_cls =
+				(void *) comp_class;
 
-		method = (method_t) flt_comp_cls->methods.msg_iter_finalize;
-		break;
-	}
-	default:
-		/* Unreachable */
-		abort();
-	}
+			method = (method_t) flt_comp_cls->msg_iter_cls->methods.finalize;
+			break;
+		}
+		default:
+			/* Unreachable */
+			bt_common_abort();
+		}
 
-	if (method) {
-		BT_LIB_LOGD("Calling user's finalization method: %!+i",
-			iterator);
-		method(iterator);
+		if (method) {
+			const bt_error *saved_error;
+
+			saved_error = bt_current_thread_take_error();
+
+			BT_LIB_LOGD("Calling user's finalization method: %!+i",
+				iterator);
+			method(iterator);
+
+			if (saved_error) {
+				BT_CURRENT_THREAD_MOVE_ERROR_AND_RESET(saved_error);
+			}
+		}
 	}
 
 	/* Detach upstream message iterators */
@@ -298,10 +319,7 @@ int create_self_component_input_port_message_iterator(
 		struct bt_self_component_port_input *self_port,
 		struct bt_self_component_port_input_message_iterator **message_iterator)
 {
-	typedef enum bt_component_class_message_iterator_initialize_method_status (*init_method_t)(
-			void *, void *, void *, void *);
-
-	init_method_t init_method = NULL;
+	bt_message_iterator_class_initialize_method init_method = NULL;
 	struct bt_self_component_port_input_message_iterator *iterator =
 		NULL;
 	struct bt_self_component_port_input_message_iterator *downstream_msg_iter =
@@ -389,19 +407,19 @@ int create_self_component_input_port_message_iterator(
 
 		iterator->methods.next =
 			(bt_self_component_port_input_message_iterator_next_method)
-				src_comp_cls->methods.msg_iter_next;
+				src_comp_cls->msg_iter_cls->methods.next;
 		iterator->methods.seek_ns_from_origin =
 			(bt_self_component_port_input_message_iterator_seek_ns_from_origin_method)
-				src_comp_cls->methods.msg_iter_seek_ns_from_origin;
+				src_comp_cls->msg_iter_cls->methods.seek_ns_from_origin;
 		iterator->methods.seek_beginning =
 			(bt_self_component_port_input_message_iterator_seek_beginning_method)
-				src_comp_cls->methods.msg_iter_seek_beginning;
+				src_comp_cls->msg_iter_cls->methods.seek_beginning;
 		iterator->methods.can_seek_ns_from_origin =
 			(bt_self_component_port_input_message_iterator_can_seek_ns_from_origin_method)
-				src_comp_cls->methods.msg_iter_can_seek_ns_from_origin;
+				src_comp_cls->msg_iter_cls->methods.can_seek_ns_from_origin;
 		iterator->methods.can_seek_beginning =
 			(bt_self_component_port_input_message_iterator_can_seek_beginning_method)
-				src_comp_cls->methods.msg_iter_can_seek_beginning;
+				src_comp_cls->msg_iter_cls->methods.can_seek_beginning;
 		break;
 	}
 	case BT_COMPONENT_CLASS_TYPE_FILTER:
@@ -411,23 +429,23 @@ int create_self_component_input_port_message_iterator(
 
 		iterator->methods.next =
 			(bt_self_component_port_input_message_iterator_next_method)
-				flt_comp_cls->methods.msg_iter_next;
+				flt_comp_cls->msg_iter_cls->methods.next;
 		iterator->methods.seek_ns_from_origin =
 			(bt_self_component_port_input_message_iterator_seek_ns_from_origin_method)
-				flt_comp_cls->methods.msg_iter_seek_ns_from_origin;
+				flt_comp_cls->msg_iter_cls->methods.seek_ns_from_origin;
 		iterator->methods.seek_beginning =
 			(bt_self_component_port_input_message_iterator_seek_beginning_method)
-				flt_comp_cls->methods.msg_iter_seek_beginning;
+				flt_comp_cls->msg_iter_cls->methods.seek_beginning;
 		iterator->methods.can_seek_ns_from_origin =
 			(bt_self_component_port_input_message_iterator_can_seek_ns_from_origin_method)
-				flt_comp_cls->methods.msg_iter_can_seek_ns_from_origin;
+				flt_comp_cls->msg_iter_cls->methods.can_seek_ns_from_origin;
 		iterator->methods.can_seek_beginning =
 			(bt_self_component_port_input_message_iterator_can_seek_beginning_method)
-				flt_comp_cls->methods.msg_iter_can_seek_beginning;
+				flt_comp_cls->msg_iter_cls->methods.can_seek_beginning;
 		break;
 	}
 	default:
-		abort();
+		bt_common_abort();
 	}
 
 	if (iterator->methods.seek_ns_from_origin &&
@@ -450,8 +468,7 @@ int create_self_component_input_port_message_iterator(
 		struct bt_component_class_source *src_comp_cls =
 			(void *) upstream_comp_cls;
 
-		init_method =
-			(init_method_t) src_comp_cls->methods.msg_iter_initialize;
+		init_method = src_comp_cls->msg_iter_cls->methods.initialize;
 		break;
 	}
 	case BT_COMPONENT_CLASS_TYPE_FILTER:
@@ -459,23 +476,26 @@ int create_self_component_input_port_message_iterator(
 		struct bt_component_class_filter *flt_comp_cls =
 			(void *) upstream_comp_cls;
 
-		init_method =
-			(init_method_t) flt_comp_cls->methods.msg_iter_initialize;
+		init_method = flt_comp_cls->msg_iter_cls->methods.initialize;
 		break;
 	}
 	default:
 		/* Unreachable */
-		abort();
+		bt_common_abort();
 	}
 
 	if (init_method) {
-		enum bt_component_class_message_iterator_initialize_method_status iter_status;
+		enum bt_message_iterator_class_initialize_method_status iter_status;
 
 		BT_LIB_LOGD("Calling user's initialization method: %!+i", iterator);
-		iter_status = init_method(iterator, &iterator->config, upstream_comp,
-			upstream_port);
+		iter_status = init_method(
+			(struct bt_self_message_iterator *) iterator,
+			&iterator->config,
+			(struct bt_self_component *) upstream_comp,
+			(struct bt_self_component_port_output *) upstream_port);
 		BT_LOGD("User method returned: status=%s",
 			bt_common_func_status_string(iter_status));
+		BT_ASSERT_POST_NO_ERROR_IF_NO_ERROR_STATUS(iter_status);
 		if (iter_status != BT_FUNC_STATUS_OK) {
 			BT_LIB_LOGW_APPEND_CAUSE(
 				"Component input port message iterator initialization method failed: "
@@ -525,6 +545,7 @@ bt_self_component_port_input_message_iterator_create_from_message_iterator(
 		struct bt_self_component_port_input *input_port,
 		struct bt_self_component_port_input_message_iterator **message_iterator)
 {
+	BT_ASSERT_PRE_NO_ERROR();
 	BT_ASSERT_PRE_NON_NULL(self_msg_iter, "Message iterator");
 	return create_self_component_input_port_message_iterator(self_msg_iter,
 		input_port, message_iterator);
@@ -536,6 +557,7 @@ bt_self_component_port_input_message_iterator_create_from_sink_component(
 		struct bt_self_component_port_input *input_port,
 		struct bt_self_component_port_input_message_iterator **message_iterator)
 {
+	BT_ASSERT_PRE_NO_ERROR();
 	BT_ASSERT_PRE_NON_NULL(self_comp, "Sink component");
 	return create_self_component_input_port_message_iterator(NULL,
 		input_port, message_iterator);
@@ -642,8 +664,15 @@ bool clock_snapshots_are_monotonic_one(
 		goto end;
 	}
 
-	clock_snapshot_status = bt_clock_snapshot_get_ns_from_origin(clock_snapshot, &ns_from_origin);
+	clock_snapshot_status = bt_clock_snapshot_get_ns_from_origin(
+		clock_snapshot, &ns_from_origin);
 	if (clock_snapshot_status != BT_FUNC_STATUS_OK) {
+		/*
+		 * bt_clock_snapshot_get_ns_from_origin can return
+		 * OVERFLOW_ERROR.  We don't really want to report an error to
+		 * our caller, so just clear it.
+		 */
+		bt_current_thread_clear_error();
 		goto end;
 	}
 
@@ -841,14 +870,14 @@ end:
  */
 
 static
-enum bt_component_class_message_iterator_next_method_status
+enum bt_message_iterator_class_next_method_status
 call_iterator_next_method(
 		struct bt_self_component_port_input_message_iterator *iterator,
 		bt_message_array_const msgs, uint64_t capacity, uint64_t *user_count)
 {
-	enum bt_component_class_message_iterator_next_method_status status;
+	enum bt_message_iterator_class_next_method_status status;
 
-	BT_ASSERT(iterator->methods.next);
+	BT_ASSERT_DBG(iterator->methods.next);
 	BT_LOGD_STR("Calling user's \"next\" method.");
 	status = iterator->methods.next(iterator, msgs, capacity, user_count);
 	BT_LOGD("User method returned: status=%s, msg-count=%" PRIu64,
@@ -861,6 +890,8 @@ call_iterator_next_method(
 			"Clock snapshots are not monotonic");
 	}
 
+	BT_ASSERT_POST_DEV_NO_ERROR_IF_NO_ERROR_STATUS(status);
+
 	return status;
 }
 
@@ -871,6 +902,7 @@ bt_self_component_port_input_message_iterator_next(
 {
 	enum bt_message_iterator_next_status status = BT_FUNC_STATUS_OK;
 
+	BT_ASSERT_PRE_DEV_NO_ERROR();
 	BT_ASSERT_PRE_DEV_NON_NULL(iterator, "Message iterator");
 	BT_ASSERT_PRE_DEV_NON_NULL(msgs, "Message array (output)");
 	BT_ASSERT_PRE_DEV_NON_NULL(user_count, "Message count (output)");
@@ -878,8 +910,8 @@ bt_self_component_port_input_message_iterator_next(
 		BT_SELF_COMPONENT_PORT_INPUT_MESSAGE_ITERATOR_STATE_ACTIVE,
 		"Message iterator's \"next\" called, but "
 		"message iterator is in the wrong state: %!+i", iterator);
-	BT_ASSERT(iterator->upstream_component);
-	BT_ASSERT(iterator->upstream_component->class);
+	BT_ASSERT_DBG(iterator->upstream_component);
+	BT_ASSERT_DBG(iterator->upstream_component->class);
 	BT_ASSERT_PRE_DEV(
 		bt_component_borrow_graph(iterator->upstream_component)->config_state !=
 			BT_GRAPH_CONFIGURATION_STATE_CONFIGURING,
@@ -916,7 +948,7 @@ bt_self_component_port_input_message_iterator_next(
 	 * For the same reason, there is no way that this iterator could
 	 * have seeked (cannot seek a self message iterator).
 	 */
-	BT_ASSERT(iterator->state ==
+	BT_ASSERT_DBG(iterator->state ==
 		BT_SELF_COMPONENT_PORT_INPUT_MESSAGE_ITERATOR_STATE_ACTIVE);
 
 	switch (status) {
@@ -935,7 +967,7 @@ bt_self_component_port_input_message_iterator_next(
 		goto end;
 	default:
 		/* Unknown non-error status */
-		abort();
+		bt_common_abort();
 	}
 
 end:
@@ -950,14 +982,6 @@ bt_self_component_port_input_message_iterator_borrow_component(
 	return iterator->upstream_component;
 }
 
-const struct bt_component *
-bt_self_component_port_input_message_iterator_borrow_component_const(
-		const struct bt_self_component_port_input_message_iterator *iterator)
-{
-	BT_ASSERT_PRE_DEV_NON_NULL(iterator, "Message iterator");
-	return iterator->upstream_component;
-}
-
 struct bt_self_component *bt_self_message_iterator_borrow_component(
 		struct bt_self_message_iterator *self_iterator)
 {
@@ -985,6 +1009,7 @@ bt_self_component_port_input_message_iterator_can_seek_ns_from_origin(
 {
 	enum bt_message_iterator_can_seek_ns_from_origin_status status;
 
+	BT_ASSERT_PRE_NO_ERROR();
 	BT_ASSERT_PRE_NON_NULL(iterator, "Message iterator");
 	BT_ASSERT_PRE_NON_NULL(can_seek, "Result (output)");
 	BT_ASSERT_PRE_ITER_HAS_STATE_TO_SEEK(iterator);
@@ -1001,25 +1026,48 @@ bt_self_component_port_input_message_iterator_can_seek_ns_from_origin(
 		 */
 		*can_seek = -1;
 
+		BT_LIB_LOGD("Calling user's \"can seek nanoseconds from origin\" method: %!+i",
+			iterator);
+
 		status = (int) iterator->methods.can_seek_ns_from_origin(iterator,
 			ns_from_origin, can_seek);
 
-		BT_ASSERT_POST(
-			status != BT_FUNC_STATUS_OK ||
-				*can_seek == BT_TRUE ||
-				*can_seek == BT_FALSE,
+		BT_ASSERT_POST_NO_ERROR_IF_NO_ERROR_STATUS(status);
+
+		if (status != BT_FUNC_STATUS_OK) {
+			BT_LIB_LOGW_APPEND_CAUSE(
+				"Component input port message iterator's \"can seek nanoseconds from origin\" method failed: "
+				"%![iter-]+i, status=%s",
+				iterator, bt_common_func_status_string(status));
+			goto end;
+		}
+
+		BT_ASSERT_POST(*can_seek == BT_TRUE || *can_seek == BT_FALSE,
 			"Unexpected boolean value returned from user's \"can seek ns from origin\" method: val=%d, %![iter-]+i",
 			*can_seek, iterator);
 
-		goto end;
+		BT_LIB_LOGD(
+			"User's \"can seek nanoseconds from origin\" returned successfully: "
+			"%![iter-]+i, can-seek=%d",
+			iterator, *can_seek);
+
+		if (*can_seek) {
+			goto end;
+		}
 	}
 
 	/*
-	 * Automatic seeking fall back: if we can seek to the beginning,
-	 * then we can automatically seek to any message.
+	 * Automatic seeking fall back: if we can seek to the beginning and the
+	 * iterator supports forward seeking then we can automatically seek to
+	 * any timestamp.
 	 */
 	status = (int) bt_self_component_port_input_message_iterator_can_seek_beginning(
 		iterator, can_seek);
+	if (status != BT_FUNC_STATUS_OK) {
+		goto end;
+	}
+
+	*can_seek = *can_seek && iterator->config.can_seek_forward;
 
 end:
 	return status;
@@ -1032,6 +1080,7 @@ bt_self_component_port_input_message_iterator_can_seek_beginning(
 {
 	enum bt_message_iterator_can_seek_beginning_status status;
 
+	BT_ASSERT_PRE_NO_ERROR();
 	BT_ASSERT_PRE_NON_NULL(iterator, "Message iterator");
 	BT_ASSERT_PRE_NON_NULL(can_seek, "Result (output)");
 	BT_ASSERT_PRE_ITER_HAS_STATE_TO_SEEK(iterator);
@@ -1056,6 +1105,7 @@ bt_self_component_port_input_message_iterator_can_seek_beginning(
 				*can_seek == BT_FALSE,
 			"Unexpected boolean value returned from user's \"can seek beginning\" method: val=%d, %![iter-]+i",
 			*can_seek, iterator);
+		BT_ASSERT_POST_NO_ERROR_IF_NO_ERROR_STATUS(status);
 	} else {
 		*can_seek = BT_FALSE;
 		status = BT_FUNC_STATUS_OK;
@@ -1087,7 +1137,7 @@ void set_iterator_state_after_seeking(
 		new_state = BT_SELF_COMPONENT_PORT_INPUT_MESSAGE_ITERATOR_STATE_ENDED;
 		break;
 	default:
-		abort();
+		bt_common_abort();
 	}
 
 	set_self_comp_port_input_msg_iterator_state(iterator, new_state);
@@ -1123,6 +1173,7 @@ bt_self_component_port_input_message_iterator_seek_beginning(
 {
 	int status;
 
+	BT_ASSERT_PRE_NO_ERROR();
 	BT_ASSERT_PRE_NON_NULL(iterator, "Message iterator");
 	BT_ASSERT_PRE_ITER_HAS_STATE_TO_SEEK(iterator);
 	BT_ASSERT_PRE(
@@ -1151,6 +1202,7 @@ bt_self_component_port_input_message_iterator_seek_beginning(
 		status == BT_FUNC_STATUS_AGAIN,
 		"Unexpected status: %![iter-]+i, status=%s",
 		iterator, bt_common_func_status_string(status));
+	BT_ASSERT_POST_NO_ERROR_IF_NO_ERROR_STATUS(status);
 	if (status < 0) {
 		BT_LIB_LOGW_APPEND_CAUSE(
 			"Component input port message iterator's \"seek beginning\" method failed: "
@@ -1254,8 +1306,8 @@ int auto_seek_handle_message(
 	const struct bt_clock_snapshot *clk_snapshot = NULL;
 	int ret;
 
-	BT_ASSERT(msg);
-	BT_ASSERT(got_first);
+	BT_ASSERT_DBG(msg);
+	BT_ASSERT_DBG(got_first);
 
 	switch (msg->type) {
 	case BT_MESSAGE_TYPE_EVENT:
@@ -1275,7 +1327,7 @@ int auto_seek_handle_message(
 			(const void *) msg;
 
 		clk_snapshot = inactivity_msg->default_cs;
-		BT_ASSERT(clk_snapshot);
+		BT_ASSERT_DBG(clk_snapshot);
 		break;
 	}
 	case BT_MESSAGE_TYPE_PACKET_BEGINNING:
@@ -1371,10 +1423,10 @@ int auto_seek_handle_message(
 		break;
 	}
 	default:
-		abort();
+		bt_common_abort();
 	}
 
-	BT_ASSERT(clk_snapshot);
+	BT_ASSERT_DBG(clk_snapshot);
 	ret = bt_clock_snapshot_get_ns_from_origin(clk_snapshot,
 		&msg_ns_from_origin);
 	if (ret) {
@@ -1408,7 +1460,7 @@ skip_msg:
 			stream_state->seen_clock_snapshot = true;
 		}
 
-		BT_ASSERT(!bt_g_hash_table_contains(stream_states, stream_msg->stream));
+		BT_ASSERT_DBG(!bt_g_hash_table_contains(stream_states, stream_msg->stream));
 		g_hash_table_insert(stream_states, stream_msg->stream, stream_state);
 		break;
 	}
@@ -1420,11 +1472,10 @@ skip_msg:
 
 		/* Update stream's state: packet began. */
 		stream_state = g_hash_table_lookup(stream_states, packet_msg->packet->stream);
-		BT_ASSERT(stream_state);
-
-		BT_ASSERT(stream_state->state == AUTO_SEEK_STREAM_STATE_STREAM_BEGAN);
+		BT_ASSERT_DBG(stream_state);
+		BT_ASSERT_DBG(stream_state->state == AUTO_SEEK_STREAM_STATE_STREAM_BEGAN);
 		stream_state->state = AUTO_SEEK_STREAM_STATE_PACKET_BEGAN;
-		BT_ASSERT(!stream_state->packet);
+		BT_ASSERT_DBG(!stream_state->packet);
 		stream_state->packet = packet_msg->packet;
 
 		if (packet_msg->packet->stream->class->packets_have_beginning_default_clock_snapshot) {
@@ -1440,7 +1491,7 @@ skip_msg:
 
 		stream_state = g_hash_table_lookup(stream_states,
 			event_msg->event->packet->stream);
-		BT_ASSERT(stream_state);
+		BT_ASSERT_DBG(stream_state);
 
 		// HELPME: are we sure that event messages have clock snapshots at this point?
 		stream_state->seen_clock_snapshot = true;
@@ -1455,11 +1506,10 @@ skip_msg:
 
 		/* Update stream's state: packet ended. */
 		stream_state = g_hash_table_lookup(stream_states, packet_msg->packet->stream);
-		BT_ASSERT(stream_state);
-
-		BT_ASSERT(stream_state->state == AUTO_SEEK_STREAM_STATE_PACKET_BEGAN);
+		BT_ASSERT_DBG(stream_state);
+		BT_ASSERT_DBG(stream_state->state == AUTO_SEEK_STREAM_STATE_PACKET_BEGAN);
 		stream_state->state = AUTO_SEEK_STREAM_STATE_STREAM_BEGAN;
-		BT_ASSERT(stream_state->packet);
+		BT_ASSERT_DBG(stream_state->packet);
 		stream_state->packet = NULL;
 
 		if (packet_msg->packet->stream->class->packets_have_end_default_clock_snapshot) {
@@ -1474,9 +1524,9 @@ skip_msg:
 		struct auto_seek_stream_state *stream_state;
 
 		stream_state = g_hash_table_lookup(stream_states, stream_msg->stream);
-		BT_ASSERT(stream_state);
-		BT_ASSERT(stream_state->state == AUTO_SEEK_STREAM_STATE_STREAM_BEGAN);
-		BT_ASSERT(!stream_state->packet);
+		BT_ASSERT_DBG(stream_state);
+		BT_ASSERT_DBG(stream_state->state == AUTO_SEEK_STREAM_STATE_STREAM_BEGAN);
+		BT_ASSERT_DBG(!stream_state->packet);
 
 		/* Update stream's state: this stream doesn't exist anymore. */
 		g_hash_table_remove(stream_states, stream_msg->stream);
@@ -1490,7 +1540,7 @@ skip_msg:
 		struct auto_seek_stream_state *stream_state;
 
 		stream_state = g_hash_table_lookup(stream_states, discarded_msg->stream);
-		BT_ASSERT(stream_state);
+		BT_ASSERT_DBG(stream_state);
 
 		if ((msg->type == BT_MESSAGE_TYPE_DISCARDED_EVENTS && discarded_msg->stream->class->discarded_events_have_default_clock_snapshots) ||
 			(msg->type == BT_MESSAGE_TYPE_DISCARDED_PACKETS && discarded_msg->stream->class->discarded_packets_have_default_clock_snapshots)) {
@@ -1503,7 +1553,7 @@ skip_msg:
 		break;
 	}
 
-	bt_object_put_no_null_check(msg);
+	bt_object_put_ref_no_null_check(msg);
 	msg = NULL;
 	goto end;
 
@@ -1512,7 +1562,7 @@ push_msg:
 	msg = NULL;
 
 end:
-	BT_ASSERT(!msg || status != BT_FUNC_STATUS_OK);
+	BT_ASSERT_DBG(!msg || status != BT_FUNC_STATUS_OK);
 	return status;
 }
 
@@ -1521,7 +1571,7 @@ int find_message_ge_ns_from_origin(
 		struct bt_self_component_port_input_message_iterator *iterator,
 		int64_t ns_from_origin, GHashTable *stream_states)
 {
-	int status;
+	int status = BT_FUNC_STATUS_OK;
 	enum bt_self_component_port_input_message_iterator_state init_state =
 		iterator->state;
 	const struct bt_message *messages[MSG_BATCH_SIZE];
@@ -1529,7 +1579,7 @@ int find_message_ge_ns_from_origin(
 	uint64_t i;
 	bool got_first = false;
 
-	BT_ASSERT(iterator);
+	BT_ASSERT_DBG(iterator);
 	memset(&messages[0], 0, sizeof(messages[0]) * MSG_BATCH_SIZE);
 
 	/*
@@ -1539,7 +1589,7 @@ int find_message_ge_ns_from_origin(
 	set_self_comp_port_input_msg_iterator_state(iterator,
 		BT_SELF_COMPONENT_PORT_INPUT_MESSAGE_ITERATOR_STATE_ACTIVE);
 
-	BT_ASSERT(iterator->methods.next);
+	BT_ASSERT_DBG(iterator->methods.next);
 
 	while (!got_first) {
 		/*
@@ -1561,7 +1611,7 @@ int find_message_ge_ns_from_origin(
 		 * The user's "next" method must not do any action which
 		 * would change the iterator's state.
 		 */
-		BT_ASSERT(iterator->state ==
+		BT_ASSERT_DBG(iterator->state ==
 			BT_SELF_COMPONENT_PORT_INPUT_MESSAGE_ITERATOR_STATE_ACTIVE);
 
 		switch (status) {
@@ -1577,7 +1627,7 @@ int find_message_ge_ns_from_origin(
 		case BT_FUNC_STATUS_END:
 			goto end;
 		default:
-			abort();
+			bt_common_abort();
 		}
 
 		for (i = 0; i < user_count; i++) {
@@ -1603,7 +1653,7 @@ int find_message_ge_ns_from_origin(
 end:
 	for (i = 0; i < user_count; i++) {
 		if (messages[i]) {
-			bt_object_put_no_null_check(messages[i]);
+			bt_object_put_ref_no_null_check(messages[i]);
 		}
 	}
 
@@ -1619,7 +1669,7 @@ end:
  */
 
 static
-enum bt_component_class_message_iterator_next_method_status post_auto_seek_next(
+enum bt_message_iterator_class_next_method_status post_auto_seek_next(
 		struct bt_self_component_port_input_message_iterator *iterator,
 		bt_message_array_const msgs, uint64_t capacity,
 		uint64_t *count)
@@ -1686,7 +1736,9 @@ bt_self_component_port_input_message_iterator_seek_ns_from_origin(
 {
 	int status;
 	GHashTable *stream_states = NULL;
+	bt_bool can_seek_by_itself;
 
+	BT_ASSERT_PRE_NO_ERROR();
 	BT_ASSERT_PRE_NON_NULL(iterator, "Message iterator");
 	BT_ASSERT_PRE_ITER_HAS_STATE_TO_SEEK(iterator);
 	BT_ASSERT_PRE(
@@ -1694,6 +1746,7 @@ bt_self_component_port_input_message_iterator_seek_ns_from_origin(
 			BT_GRAPH_CONFIGURATION_STATE_CONFIGURING,
 		"Graph is not configured: %!+g",
 		bt_component_borrow_graph(iterator->upstream_component));
+	/* The iterator must be able to seek ns from origin one way or another. */
 	BT_ASSERT_PRE(
 		message_iterator_can_seek_ns_from_origin(iterator, ns_from_origin),
 		"Message iterator cannot seek nanoseconds from origin: %!+i, "
@@ -1707,8 +1760,25 @@ bt_self_component_port_input_message_iterator_seek_ns_from_origin(
 	 */
 	reset_iterator_expectations(iterator);
 
-	if (iterator->methods.seek_ns_from_origin) {
+	/* Check if the iterator can seek by itself.  If not we'll use autoseek. */
+	if (iterator->methods.can_seek_ns_from_origin) {
+		bt_message_iterator_class_can_seek_ns_from_origin_method_status
+			can_seek_status;
+
+		can_seek_status =
+			iterator->methods.can_seek_ns_from_origin(
+				iterator, ns_from_origin, &can_seek_by_itself);
+		if (can_seek_status != BT_FUNC_STATUS_OK) {
+			status = can_seek_status;
+			goto end;
+		}
+	} else {
+		can_seek_by_itself = false;
+	}
+
+	if (can_seek_by_itself) {
 		/* The iterator knows how to seek to a particular time, let it handle this. */
+		BT_ASSERT(iterator->methods.seek_ns_from_origin);
 		BT_LIB_LOGD("Calling user's \"seek nanoseconds from origin\" method: "
 			"%![iter-]+i, ns=%" PRId64, iterator, ns_from_origin);
 		status = iterator->methods.seek_ns_from_origin(iterator,
@@ -1721,6 +1791,7 @@ bt_self_component_port_input_message_iterator_seek_ns_from_origin(
 			status == BT_FUNC_STATUS_AGAIN,
 			"Unexpected status: %![iter-]+i, status=%s",
 			iterator, bt_common_func_status_string(status));
+		BT_ASSERT_POST_NO_ERROR_IF_NO_ERROR_STATUS(status);
 		if (status < 0) {
 			BT_LIB_LOGW_APPEND_CAUSE(
 				"Component input port message iterator's \"seek nanoseconds from origin\" method failed: "
@@ -1729,18 +1800,17 @@ bt_self_component_port_input_message_iterator_seek_ns_from_origin(
 		}
 	} else {
 		/*
-		 * The iterator doesn't know how to seek to a particular time.  We will
-		 * seek to the beginning and fast forward to the right place.
+		 * The iterator doesn't know how to seek by itself to a
+		 * particular time.  We will seek to the beginning and fast
+		 * forward to the right place.
 		 */
-		enum bt_component_class_message_iterator_can_seek_beginning_method_status
-			can_seek_status;
+		enum bt_message_iterator_class_can_seek_beginning_method_status can_seek_status;
 		bt_bool can_seek_beginning;
 
 		can_seek_status = iterator->methods.can_seek_beginning(iterator,
 			&can_seek_beginning);
 		BT_ASSERT(can_seek_status == BT_FUNC_STATUS_OK);
 		BT_ASSERT(can_seek_beginning);
-
 		BT_ASSERT(iterator->methods.seek_beginning);
 		BT_LIB_LOGD("Calling user's \"seek beginning\" method: %!+i",
 			iterator);
@@ -1768,7 +1838,7 @@ bt_self_component_port_input_message_iterator_seek_ns_from_origin(
 		case BT_FUNC_STATUS_AGAIN:
 			goto end;
 		default:
-			abort();
+			bt_common_abort();
 		}
 
 		/*
@@ -1779,7 +1849,7 @@ bt_self_component_port_input_message_iterator_seek_ns_from_origin(
 		 * message queue.
 		 */
 		while (!g_queue_is_empty(iterator->auto_seek.msgs)) {
-			bt_object_put_no_null_check(
+			bt_object_put_ref_no_null_check(
 				g_queue_pop_tail(iterator->auto_seek.msgs));
 		}
 
@@ -1912,7 +1982,7 @@ bt_self_component_port_input_message_iterator_seek_ns_from_origin(
 		case BT_FUNC_STATUS_AGAIN:
 			goto end;
 		default:
-			abort();
+			bt_common_abort();
 		}
 	}