projects
/
babeltrace.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
python: standardize intra-bt2 imports
[babeltrace.git]
/
src
/
bindings
/
python
/
bt2
/
bt2
/
component.py
diff --git
a/src/bindings/python/bt2/bt2/component.py
b/src/bindings/python/bt2/bt2/component.py
index 1bb6763e1e79b916ac262fb0d21fb3e6cc22c0e3..7f907cc9beee92e1f7e9ce96a3ec5805d994eccd 100644
(file)
--- a/
src/bindings/python/bt2/bt2/component.py
+++ b/
src/bindings/python/bt2/bt2/component.py
@@
-2,7
+2,9
@@
#
# Copyright (c) 2017 Philippe Proulx <pproulx@efficios.com>
#
# Copyright (c) 2017 Philippe Proulx <pproulx@efficios.com>
-from bt2 import native_bt, object, utils
+from bt2 import native_bt
+from bt2 import object as bt2_object
+from bt2 import utils as bt2_utils
from bt2 import message_iterator as bt2_message_iterator
import collections.abc
from bt2 import value as bt2_value
from bt2 import message_iterator as bt2_message_iterator
import collections.abc
from bt2 import value as bt2_value
@@
-25,7
+27,7
@@
import bt2
# pointer to a 'bt_component_class *'.
# pointer to a 'bt_component_class *'.
-class _ComponentClassConst(object._SharedObject):
+class _ComponentClassConst(
bt2_
object._SharedObject):
@property
def name(self):
ptr = self._bt_as_component_class_ptr(self._ptr)
@property
def name(self):
ptr = self._bt_as_component_class_ptr(self._ptr)
@@
-141,7
+143,7
@@
class _ComponentPorts(collections.abc.Mapping):
self._port_pycls = port_pycls
def __getitem__(self, key):
self._port_pycls = port_pycls
def __getitem__(self, key):
- utils._check_str(key)
+
bt2_
utils._check_str(key)
port_ptr = self._borrow_port_ptr_by_name(self._component_ptr, key)
if port_ptr is None:
port_ptr = self._borrow_port_ptr_by_name(self._component_ptr, key)
if port_ptr is None:
@@
-235,7
+237,7
@@
class _SinkComponentConst(_ComponentConst):
# This is analogous to _SourceComponentClassConst, but for source
# component objects.
# This is analogous to _SourceComponentClassConst, but for source
# component objects.
-class _GenericSourceComponentConst(object._SharedObject, _SourceComponentConst):
+class _GenericSourceComponentConst(
bt2_
object._SharedObject, _SourceComponentConst):
@staticmethod
def _get_ref(ptr):
native_bt.component_source_get_ref(ptr)
@staticmethod
def _get_ref(ptr):
native_bt.component_source_get_ref(ptr)
@@
-257,7
+259,7
@@
class _GenericSourceComponentConst(object._SharedObject, _SourceComponentConst):
# This is analogous to _FilterComponentClassConst, but for filter
# component objects.
# This is analogous to _FilterComponentClassConst, but for filter
# component objects.
-class _GenericFilterComponentConst(object._SharedObject, _FilterComponentConst):
+class _GenericFilterComponentConst(
bt2_
object._SharedObject, _FilterComponentConst):
@staticmethod
def _get_ref(ptr):
native_bt.component_filter_get_ref(ptr)
@staticmethod
def _get_ref(ptr):
native_bt.component_filter_get_ref(ptr)
@@
-289,7
+291,7
@@
class _GenericFilterComponentConst(object._SharedObject, _FilterComponentConst):
# This is analogous to _SinkComponentClassConst, but for sink
# component objects.
# This is analogous to _SinkComponentClassConst, but for sink
# component objects.
-class _GenericSinkComponentConst(object._SharedObject, _SinkComponentConst):
+class _GenericSinkComponentConst(
bt2_
object._SharedObject, _SinkComponentConst):
@staticmethod
def _get_ref(ptr):
native_bt.component_sink_get_ref(ptr)
@staticmethod
def _get_ref(ptr):
native_bt.component_sink_get_ref(ptr)
@@
-480,12
+482,12
@@
class _UserComponentType(type):
return
comp_cls_name = kwargs.get("name", class_name)
return
comp_cls_name = kwargs.get("name", class_name)
- utils._check_str(comp_cls_name)
+
bt2_
utils._check_str(comp_cls_name)
comp_cls_descr = None
comp_cls_help = None
if hasattr(cls, "__doc__") and cls.__doc__ is not None:
comp_cls_descr = None
comp_cls_help = None
if hasattr(cls, "__doc__") and cls.__doc__ is not None:
- utils._check_str(cls.__doc__)
+
bt2_
utils._check_str(cls.__doc__)
docstring = _trim_docstring(cls.__doc__)
lines = docstring.splitlines()
docstring = _trim_docstring(cls.__doc__)
lines = docstring.splitlines()
@@
-864,7
+866,7
@@
class _UserSourceComponent(_UserComponent, _SourceComponentConst):
)
def _add_output_port(self, name, user_data=None):
)
def _add_output_port(self, name, user_data=None):
- utils._check_str(name)
+
bt2_
utils._check_str(name)
if name in self._output_ports:
raise ValueError(
if name in self._output_ports:
raise ValueError(
@@
-875,7
+877,7
@@
class _UserSourceComponent(_UserComponent, _SourceComponentConst):
fn = native_bt.self_component_source_add_output_port
comp_status, self_port_ptr = fn(self._bt_ptr, name, user_data)
fn = native_bt.self_component_source_add_output_port
comp_status, self_port_ptr = fn(self._bt_ptr, name, user_data)
- utils._handle_func_status(
+
bt2_
utils._handle_func_status(
comp_status, "cannot add output port to source component object"
)
assert self_port_ptr is not None
comp_status, "cannot add output port to source component object"
)
assert self_port_ptr is not None
@@
-922,7
+924,7
@@
class _UserFilterComponent(_UserComponent, _FilterComponentConst):
)
def _add_output_port(self, name, user_data=None):
)
def _add_output_port(self, name, user_data=None):
- utils._check_str(name)
+
bt2_
utils._check_str(name)
if name in self._output_ports:
raise ValueError(
if name in self._output_ports:
raise ValueError(
@@
-933,7
+935,7
@@
class _UserFilterComponent(_UserComponent, _FilterComponentConst):
fn = native_bt.self_component_filter_add_output_port
comp_status, self_port_ptr = fn(self._bt_ptr, name, user_data)
fn = native_bt.self_component_filter_add_output_port
comp_status, self_port_ptr = fn(self._bt_ptr, name, user_data)
- utils._handle_func_status(
+
bt2_
utils._handle_func_status(
comp_status, "cannot add output port to filter component object"
)
assert self_port_ptr
comp_status, "cannot add output port to filter component object"
)
assert self_port_ptr
@@
-942,7
+944,7
@@
class _UserFilterComponent(_UserComponent, _FilterComponentConst):
)
def _add_input_port(self, name, user_data=None):
)
def _add_input_port(self, name, user_data=None):
- utils._check_str(name)
+
bt2_
utils._check_str(name)
if name in self._input_ports:
raise ValueError(
if name in self._input_ports:
raise ValueError(
@@
-953,7
+955,7
@@
class _UserFilterComponent(_UserComponent, _FilterComponentConst):
fn = native_bt.self_component_filter_add_input_port
comp_status, self_port_ptr = fn(self._bt_ptr, name, user_data)
fn = native_bt.self_component_filter_add_input_port
comp_status, self_port_ptr = fn(self._bt_ptr, name, user_data)
- utils._handle_func_status(
+
bt2_
utils._handle_func_status(
comp_status, "cannot add input port to filter component object"
)
assert self_port_ptr
comp_status, "cannot add input port to filter component object"
)
assert self_port_ptr
@@
-992,7
+994,7
@@
class _UserSinkComponent(_UserComponent, _SinkComponentConst):
)
def _add_input_port(self, name, user_data=None):
)
def _add_input_port(self, name, user_data=None):
- utils._check_str(name)
+
bt2_
utils._check_str(name)
if name in self._input_ports:
raise ValueError(
if name in self._input_ports:
raise ValueError(
@@
-1003,7
+1005,7
@@
class _UserSinkComponent(_UserComponent, _SinkComponentConst):
fn = native_bt.self_component_sink_add_input_port
comp_status, self_port_ptr = fn(self._bt_ptr, name, user_data)
fn = native_bt.self_component_sink_add_input_port
comp_status, self_port_ptr = fn(self._bt_ptr, name, user_data)
- utils._handle_func_status(
+
bt2_
utils._handle_func_status(
comp_status, "cannot add input port to sink component object"
)
assert self_port_ptr
comp_status, "cannot add input port to sink component object"
)
assert self_port_ptr
@@
-1012,7
+1014,7
@@
class _UserSinkComponent(_UserComponent, _SinkComponentConst):
)
def _create_message_iterator(self, input_port):
)
def _create_message_iterator(self, input_port):
- utils._check_type(input_port, bt2_port._UserComponentInputPort)
+
bt2_
utils._check_type(input_port, bt2_port._UserComponentInputPort)
if not input_port.is_connected:
raise ValueError("input port is not connected")
if not input_port.is_connected:
raise ValueError("input port is not connected")
@@
-1023,7
+1025,7
@@
class _UserSinkComponent(_UserComponent, _SinkComponentConst):
) = native_bt.bt2_message_iterator_create_from_sink_component(
self._bt_ptr, input_port._ptr
)
) = native_bt.bt2_message_iterator_create_from_sink_component(
self._bt_ptr, input_port._ptr
)
- utils._handle_func_status(status, "cannot create message iterator object")
+
bt2_
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)
assert msg_iter_ptr is not None
return bt2_message_iterator._UserComponentInputPortMessageIterator(msg_iter_ptr)
This page took
0.026903 seconds
and
4
git commands to generate.