# This is extended by the user to implement component classes in Python. It
# is created for a given output port when an input port message iterator is
-# created on the input port on the other side of the connection. It is also
-# created when an output port message iterator is created on this output port.
+# created on the input port on the other side of the connection.
#
# Its purpose is to feed the messages that should go out through this output
# port.
def _create_message_iterator(self, input_port):
utils._check_type(input_port, bt2_port._UserComponentInputPort)
+ if not input_port.is_connected:
+ raise ValueError('input port is not connected')
+
(
status,
msg_iter_ptr,
utils._check_uint64(beg_clock_snapshot)
utils._check_uint64(end_clock_snapshot)
- ptr = native_bt.message_discarded_events_create_with_default_clock_snapshots(
- self._bt_ptr, stream._ptr, beg_clock_snapshot, end_clock_snapshot
+
+ if beg_clock_snapshot > end_clock_snapshot:
+ raise ValueError(
+ 'beginning default clock snapshot value ({}) is greater than end default clock snapshot value ({})'.format(
+ beg_clock_snapshot, end_clock_snapshot
+ )
+ )
+
+ ptr = (
+ native_bt.message_discarded_events_create_with_default_clock_snapshots(
+ self._bt_ptr, stream._ptr, beg_clock_snapshot, end_clock_snapshot
+ )
)
else:
if beg_clock_snapshot is not None or end_clock_snapshot is not None:
utils._check_uint64(beg_clock_snapshot)
utils._check_uint64(end_clock_snapshot)
- ptr = native_bt.message_discarded_packets_create_with_default_clock_snapshots(
- self._bt_ptr, stream._ptr, beg_clock_snapshot, end_clock_snapshot
+
+ if beg_clock_snapshot > end_clock_snapshot:
+ raise ValueError(
+ 'beginning default clock snapshot value ({}) is greater than end default clock snapshot value ({})'.format(
+ beg_clock_snapshot, end_clock_snapshot
+ )
+ )
+
+ ptr = (
+ native_bt.message_discarded_packets_create_with_default_clock_snapshots(
+ self._bt_ptr, stream._ptr, beg_clock_snapshot, end_clock_snapshot
+ )
)
else:
if beg_clock_snapshot is not None or end_clock_snapshot is not None: