X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=src%2Fbindings%2Fpython%2Fbt2%2Fbt2%2Fstream.py;h=dae698d6abc70a531bb34d6ac8a1087ec64af50b;hb=e5914347c8eea0f26c07348d0ac64dbe020de44a;hp=5fea4107cb837780e99bb146a28f2a1cadfeb320;hpb=0235b0db7de5bcacdb3650c92461f2ce5eb2143d;p=babeltrace.git diff --git a/src/bindings/python/bt2/bt2/stream.py b/src/bindings/python/bt2/bt2/stream.py index 5fea4107..dae698d6 100644 --- a/src/bindings/python/bt2/bt2/stream.py +++ b/src/bindings/python/bt2/bt2/stream.py @@ -2,7 +2,8 @@ # # Copyright (c) 2016-2017 Philippe Proulx -from bt2 import native_bt, utils +from bt2 import native_bt +from bt2 import utils as bt2_utils from bt2 import object as bt2_object from bt2 import packet as bt2_packet from bt2 import stream_class as bt2_stream_class @@ -17,8 +18,14 @@ def _bt2_trace(): class _StreamConst(bt2_object._SharedObject): - _get_ref = staticmethod(native_bt.stream_get_ref) - _put_ref = staticmethod(native_bt.stream_put_ref) + @staticmethod + def _get_ref(ptr): + native_bt.stream_get_ref(ptr) + + @staticmethod + def _put_ref(ptr): + native_bt.stream_put_ref(ptr) + _borrow_class_ptr = staticmethod(native_bt.stream_borrow_class_const) _borrow_user_attributes_ptr = staticmethod( native_bt.stream_borrow_user_attributes_const @@ -71,19 +78,19 @@ class _Stream(_StreamConst): def create_packet(self): if not self.cls.supports_packets: raise ValueError( - 'cannot create packet: stream class does not support packets' + "cannot create packet: stream class does not support packets" ) packet_ptr = native_bt.packet_create(self._ptr) if packet_ptr is None: - raise bt2._MemoryError('cannot create packet object') + raise bt2._MemoryError("cannot create packet object") return bt2_packet._Packet._create_from_ptr(packet_ptr) def _user_attributes(self, user_attributes): value = bt2_value.create_value(user_attributes) - utils._check_type(value, bt2_value.MapValue) + bt2_utils._check_type(value, bt2_value.MapValue) native_bt.stream_set_user_attributes(self._ptr, value._ptr) _user_attributes = property( @@ -91,7 +98,7 @@ class _Stream(_StreamConst): ) def _name(self, name): - utils._check_str(name) + bt2_utils._check_str(name) native_bt.stream_set_name(self._ptr, name) _name = property(fget=_StreamConst.name.fget, fset=_name)