native_bt.component_source_borrow_output_port_by_name_const,
native_bt.component_source_borrow_output_port_by_index_const,
native_bt.component_source_get_output_port_count,
- bt2_port._OutputPort,
+ bt2_port._OutputPortConst,
)
native_bt.component_filter_borrow_output_port_by_name_const,
native_bt.component_filter_borrow_output_port_by_index_const,
native_bt.component_filter_get_output_port_count,
- bt2_port._OutputPort,
+ bt2_port._OutputPortConst,
)
@property
native_bt.component_filter_borrow_input_port_by_name_const,
native_bt.component_filter_borrow_input_port_by_index_const,
native_bt.component_filter_get_input_port_count,
- bt2_port._InputPort,
+ bt2_port._InputPortConst,
)
native_bt.component_sink_borrow_input_port_by_name_const,
native_bt.component_sink_borrow_input_port_by_index_const,
native_bt.component_sink_get_input_port_count,
- bt2_port._InputPort,
+ bt2_port._InputPortConst,
)
# call user's __init__() method
if params_ptr is not None:
- params = bt2_value._create_from_ptr_and_get_ref(params_ptr)
+ params = bt2_value._create_from_const_ptr_and_get_ref(params_ptr)
else:
params = None
def _bt_get_supported_mip_versions_from_native(cls, params_ptr, obj, log_level):
# this can raise, but the native side checks the exception
if params_ptr is not None:
- params = bt2_value._create_from_ptr_and_get_ref(params_ptr)
+ params = bt2_value._create_from_const_ptr_and_get_ref(params_ptr)
else:
params = None
def _bt_query_from_native(cls, priv_query_exec_ptr, object, params_ptr, method_obj):
# this can raise, but the native side checks the exception
if params_ptr is not None:
- params = bt2_value._create_from_ptr_and_get_ref(params_ptr)
+ params = bt2_value._create_from_const_ptr_and_get_ref(params_ptr)
else:
params = None
else:
other_port_type = native_bt.PORT_TYPE_OUTPUT
- other_port = bt2_port._create_from_ptr_and_get_ref(
+ other_port = bt2_port._create_from_const_ptr_and_get_ref(
other_port_ptr, other_port_type
)
self._user_port_connected(port, other_port)
def _create_input_port_message_iterator(self, input_port):
utils._check_type(input_port, bt2_port._UserComponentInputPort)
- msg_iter_ptr = native_bt.self_component_port_input_message_iterator_create_from_sink_component(
+ status, msg_iter_ptr = native_bt.bt2_self_component_port_input_message_iterator_create_from_sink_component(
self._bt_ptr, input_port._ptr
)
-
- if msg_iter_ptr is None:
- raise bt2._MemoryError('cannot create message iterator object')
+ utils._handle_func_status(status, 'cannot create message iterator object')
+ assert msg_iter_ptr is not None
return bt2_message_iterator._UserComponentInputPortMessageIterator(msg_iter_ptr)