X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=bindings%2Fpython%2Fbt2%2Fbt2%2Fconnection.py;fp=bindings%2Fpython%2Fbt2%2Fbt2%2Fconnection.py;h=a15c67927bc75e136ba76e1d64071b6577a5a719;hb=78288f581343ec033cc38898777fe43a02380719;hp=90c6399468277a8bb55448a9e5be5e3148b3768b;hpb=fca9fd7dfa103b71eb02ebc67ec92dd3f7d7b10d;p=babeltrace.git diff --git a/bindings/python/bt2/bt2/connection.py b/bindings/python/bt2/bt2/connection.py index 90c63994..a15c6792 100644 --- a/bindings/python/bt2/bt2/connection.py +++ b/bindings/python/bt2/bt2/connection.py @@ -44,7 +44,7 @@ def _create_private_from_ptr(ptr): return obj -class _Connection(object._Object): +class _Connection(object._SharedObject): @staticmethod def _downstream_port(ptr): port_ptr = native_bt.connection_get_downstream_port(ptr) @@ -78,25 +78,3 @@ class _Connection(object._Object): return False return self.addr == other.addr - - -class _PrivateConnection(object._PrivateObject, _Connection): - def create_message_iterator(self, message_types=None): - msg_types = bt2.message._msg_types_from_msg_classes(message_types) - status, msg_iter_ptr = native_bt.py3_create_priv_conn_msg_iter(int(self._ptr), - msg_types) - _handle_status(status, 'cannot create message iterator object') - assert(msg_iter_ptr) - return bt2.message_iterator._PrivateConnectionMessageIterator._create_from_ptr(msg_iter_ptr) - - @property - def is_ended(self): - return self._is_ended(self._pub_ptr) - - @property - def downstream_port(self): - return self._downstream_port(self._pub_ptr) - - @property - def upstream_port(self): - return self._upstream_port(self._pub_ptr)