from bt2 import trace_class as bt2_trace_class
from bt2 import clock_class as bt2_clock_class
from bt2 import query_executor as bt2_query_executor
-import traceback
from bt2 import port as bt2_port
import sys
import bt2
-import os
# This class wraps a component class pointer. This component class could
cls, comp_cls_name, comp_cls_descr, comp_cls_help
)
elif _UserSinkComponent in bases:
- if not hasattr(cls, '_consume'):
+ if not hasattr(cls, '_user_consume'):
raise bt2._IncompleteUserClass(
- "cannot create component class '{}': missing a _consume() method".format(
+ "cannot create component class '{}': missing a _user_consume() method".format(
class_name
)
)
cls._bt_cc_ptr = cc_ptr
- def _bt_init_from_native(cls, comp_ptr, params_ptr):
+ def _bt_init_from_native(cls, comp_ptr, params_ptr, obj):
# create instance, not user-initialized yet
self = cls.__new__(cls)
else:
params = None
- self.__init__(params)
+ self.__init__(params, obj)
return self
def __call__(cls, *args, **kwargs):
def addr(cls):
return int(cls._bt_cc_ptr)
- def _bt_query_from_native(cls, query_exec_ptr, obj, params_ptr, log_level):
- # this can raise, in which case the native call to
- # bt_component_class_query() returns NULL
+ 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)
else:
params = None
- query_exec = bt2_query_executor.QueryExecutor._create_from_ptr_and_get_ref(
- query_exec_ptr
- )
+ # this can raise, but the native side checks the exception
+ range_set = cls._user_get_supported_mip_versions(params, obj, log_level)
+
+ if type(range_set) is not bt2.UnsignedIntegerRangeSet:
+ # this can raise, but the native side checks the exception
+ range_set = bt2.UnsignedIntegerRangeSet(range_set)
+ # return new reference
+ range_set._get_ref(range_set._ptr)
+ return int(range_set._ptr)
+
+ def _user_get_supported_mip_versions(cls, params, obj, log_level):
+ return [0]
+
+ 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
- results = cls._query(query_exec, obj, params, log_level)
+ if params_ptr is not None:
+ params = bt2_value._create_from_ptr_and_get_ref(params_ptr)
+ else:
+ params = None
+
+ priv_query_exec = bt2_query_executor._PrivateQueryExecutor(priv_query_exec_ptr)
+
+ try:
+ # this can raise, but the native side checks the exception
+ results = cls._user_query(priv_query_exec, object, params, method_obj)
+ finally:
+ # the private query executor is a private view on the query
+ # executor; it's not a shared object (the library does not
+ # offer an API to get/put a reference, just like "self"
+ # objects) from this query's point of view, so invalidate
+ # the object in case the user kept a reference and uses it
+ # later
+ priv_query_exec._invalidate()
# this can raise, but the native side checks the exception
results = bt2.create_value(results)
if results is None:
results_ptr = native_bt.value_null
else:
- # return new reference
results_ptr = results._ptr
- # We return a new reference.
+ # return new reference
bt2_value._Value._get_ref(results_ptr)
-
return int(results_ptr)
- def _query(cls, query_executor, obj, params, log_level):
- raise NotImplementedError
+ def _user_query(cls, priv_query_executor, object, params, method_obj):
+ raise bt2.UnknownObject
def _bt_component_class_ptr(self):
return self._bt_as_component_class_ptr(self._bt_cc_ptr)
if hasattr(cls, '_bt_cc_ptr'):
cc_ptr = cls._bt_as_component_class_ptr(cls._bt_cc_ptr)
native_bt.component_class_put_ref(cc_ptr)
+ native_bt.bt2_unregister_cc_ptr_to_py_cls(cc_ptr)
# Subclasses must provide these methods or property:
def addr(self):
return int(self._bt_ptr)
- def __init__(self, params=None):
+ @property
+ def _graph_mip_version(self):
+ ptr = self._bt_as_self_component_ptr(self._bt_ptr)
+ return native_bt.self_component_get_graph_mip_version(ptr)
+
+ def __init__(self, params=None, obj=None):
pass
- def _finalize(self):
+ def _user_finalize(self):
pass
- def _port_connected(self, port, other_port):
+ def _user_port_connected(self, port, other_port):
pass
def _bt_port_connected_from_native(
other_port = bt2_port._create_from_ptr_and_get_ref(
other_port_ptr, other_port_type
)
- self._port_connected(port, other_port)
+ self._user_port_connected(port, other_port)
def _create_trace_class(self, assigns_automatic_stream_class_id=True):
ptr = self._bt_as_self_component_ptr(self._bt_ptr)
)
def _bt_graph_is_configured_from_native(self):
- self._graph_is_configured()
+ self._user_graph_is_configured()
- def _graph_is_configured(self):
+ def _user_graph_is_configured(self):
pass
@property
)
if msg_iter_ptr is None:
- raise bt2.CreationError('cannot create message iterator object')
+ raise bt2._MemoryError('cannot create message iterator object')
return bt2_message_iterator._UserComponentInputPortMessageIterator(msg_iter_ptr)
projects / babeltrace.git / blobdiff