X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=src%2Fbindings%2Fpython%2Fbt2%2Fbt2%2Fport.py;h=963a5b3c603097684b68422af5d86bf56de673ad;hb=57081273d1191fc79edc101af619fab96b72460d;hp=ecee18ce47b7eaa65dca8a218136572f9cd26c2a;hpb=4acc866e829881299a13d0aa8e28b93807549975;p=babeltrace.git diff --git a/src/bindings/python/bt2/bt2/port.py b/src/bindings/python/bt2/bt2/port.py index ecee18ce..963a5b3c 100644 --- a/src/bindings/python/bt2/bt2/port.py +++ b/src/bindings/python/bt2/bt2/port.py @@ -21,11 +21,7 @@ # THE SOFTWARE. from bt2 import native_bt, object -import bt2.component -import bt2.connection -import bt2.message_iterator -import bt2.message -import bt2 +from bt2 import connection as bt2_connection def _create_from_ptr_and_get_ref(ptr, port_type): @@ -72,7 +68,7 @@ class _Port(object._SharedObject): if conn_ptr is None: return - return bt2.connection._Connection._create_from_ptr_and_get_ref(conn_ptr) + return bt2_connection._Connection._create_from_ptr_and_get_ref(conn_ptr) @property def is_connected(self): @@ -101,7 +97,7 @@ class _UserComponentPort(_Port): if conn_ptr is None: return - return bt2.connection._Connection._create_from_ptr_and_get_ref(conn_ptr) + return bt2_connection._Connection._create_from_ptr_and_get_ref(conn_ptr) @property def user_data(self): @@ -114,15 +110,6 @@ class _UserComponentInputPort(_UserComponentPort, _InputPort): native_bt.self_component_port_input_as_self_component_port ) - def create_message_iterator(self): - msg_iter_ptr = native_bt.self_component_port_input_message_iterator_create( - self._ptr - ) - if msg_iter_ptr is None: - raise bt2.MemoryError('cannot create message iterator object') - - return bt2.message_iterator._UserComponentInputPortMessageIterator(msg_iter_ptr) - class _UserComponentOutputPort(_UserComponentPort, _OutputPort): _as_self_port_ptr = staticmethod(