projects / babeltrace.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
bt2: remove unused imports
[babeltrace.git] / src / bindings / python / bt2 / bt2 / message.py
diff --git a/src/bindings/python/bt2/bt2/message.py b/src/bindings/python/bt2/bt2/message.py
index 56b545daa98faf1c0220f424b5e2dd8f6cec7aec..bf6cf84d8f4a1f275dbade2c2505081218e3b9a2 100644 (file)
--- a/src/bindings/python/bt2/bt2/message.py
+++ b/src/bindings/python/bt2/bt2/message.py
@@ -21,19 +21,14 @@
 # THE SOFTWARE.
 
 from bt2 import native_bt, object, utils
-import bt2.clock_snapshot
-import bt2.packet
-import bt2.stream
-import bt2.event
-import bt2
+from bt2 import clock_snapshot as bt2_clock_snapshot
+from bt2 import packet as bt2_packet
+from bt2 import stream as bt2_stream
+from bt2 import event as bt2_event
 
 
 def _create_from_ptr(ptr):
     msg_type = native_bt.message_get_type(ptr)
-
-    if msg_type not in _MESSAGE_TYPE_TO_CLS:
-        raise bt2.Error('unknown message type: {}'.format(msg_type))
-
     return _MESSAGE_TYPE_TO_CLS[msg_type]._create_from_ptr(ptr)
 
 
@@ -44,31 +39,37 @@ class _Message(object._SharedObject):
     @staticmethod
     def _check_has_default_clock_class(clock_class):
         if clock_class is None:
-            raise bt2.NonexistentClockSnapshot('cannot get default clock snapshot: stream class has no default clock class')
+            raise ValueError(
+                'cannot get default clock snapshot: stream class has no default clock class'
+            )
 
 
 class _MessageWithDefaultClockSnapshot:
     def _get_default_clock_snapshot(self, borrow_clock_snapshot_ptr):
         snapshot_ptr = borrow_clock_snapshot_ptr(self._ptr)
 
-        return bt2.clock_snapshot._ClockSnapshot._create_from_ptr_and_get_ref(
-            snapshot_ptr, self._ptr, self._get_ref, self._put_ref)
+        return bt2_clock_snapshot._ClockSnapshot._create_from_ptr_and_get_ref(
+            snapshot_ptr, self._ptr, self._get_ref, self._put_ref
+        )
 
 
 class _EventMessage(_Message, _MessageWithDefaultClockSnapshot):
-    _borrow_default_clock_snapshot_ptr = staticmethod(native_bt.message_event_borrow_default_clock_snapshot_const)
+    _borrow_default_clock_snapshot_ptr = staticmethod(
+        native_bt.message_event_borrow_default_clock_snapshot_const
+    )
 
     @property
     def default_clock_snapshot(self):
-        self._check_has_default_clock_class(self.event.packet.stream.cls.default_clock_class)
+        self._check_has_default_clock_class(self.event.stream.cls.default_clock_class)
         return self._get_default_clock_snapshot(self._borrow_default_clock_snapshot_ptr)
 
     @property
     def event(self):
         event_ptr = native_bt.message_event_borrow_event(self._ptr)
         assert event_ptr is not None
-        return bt2.event._Event._create_from_ptr_and_get_ref(
-            event_ptr, self._ptr, self._get_ref, self._put_ref)
+        return bt2_event._Event._create_from_ptr_and_get_ref(
+            event_ptr, self._ptr, self._get_ref, self._put_ref
+        )
 
 
 class _PacketMessage(_Message, _MessageWithDefaultClockSnapshot):
@@ -81,81 +82,74 @@ class _PacketMessage(_Message, _MessageWithDefaultClockSnapshot):
     def packet(self):
         packet_ptr = self._borrow_packet_ptr(self._ptr)
         assert packet_ptr is not None
-        return bt2.packet._Packet._create_from_ptr_and_get_ref(packet_ptr)
+        return bt2_packet._Packet._create_from_ptr_and_get_ref(packet_ptr)
 
 
 class _PacketBeginningMessage(_PacketMessage):
     _borrow_packet_ptr = staticmethod(native_bt.message_packet_beginning_borrow_packet)
-    _borrow_default_clock_snapshot_ptr = staticmethod(native_bt.message_packet_beginning_borrow_default_clock_snapshot_const)
+    _borrow_default_clock_snapshot_ptr = staticmethod(
+        native_bt.message_packet_beginning_borrow_default_clock_snapshot_const
+    )
 
 
 class _PacketEndMessage(_PacketMessage):
     _borrow_packet_ptr = staticmethod(native_bt.message_packet_end_borrow_packet)
-    _borrow_default_clock_snapshot_ptr = staticmethod(native_bt.message_packet_end_borrow_default_clock_snapshot_const)
+    _borrow_default_clock_snapshot_ptr = staticmethod(
+        native_bt.message_packet_end_borrow_default_clock_snapshot_const
+    )
 
 
-class _StreamMessage(_Message):
+class _StreamMessage(_Message, _MessageWithDefaultClockSnapshot):
     @property
     def stream(self):
         stream_ptr = self._borrow_stream_ptr(self._ptr)
         assert stream_ptr
-        return bt2.stream._Stream._create_from_ptr_and_get_ref(stream_ptr)
-
-
-class _StreamBeginningMessage(_StreamMessage):
-    _borrow_stream_ptr = staticmethod(native_bt.message_stream_beginning_borrow_stream)
-
-
-class _StreamEndMessage(_StreamMessage):
-    _borrow_stream_ptr = staticmethod(native_bt.message_stream_end_borrow_stream)
-
+        return bt2_stream._Stream._create_from_ptr_and_get_ref(stream_ptr)
 
-class _StreamActivityMessage(_Message):
     @property
     def default_clock_snapshot(self):
         self._check_has_default_clock_class(self.stream.cls.default_clock_class)
-        status, snapshot_ptr = self._borrow_default_clock_snapshot_ptr(self._ptr)
 
-        if status == native_bt.MESSAGE_STREAM_ACTIVITY_CLOCK_SNAPSHOT_STATE_KNOWN:
-            snapshot_type = bt2.clock_snapshot._ClockSnapshot
-        elif status == native_bt.MESSAGE_STREAM_ACTIVITY_CLOCK_SNAPSHOT_STATE_UNKNOWN:
-            snapshot_type = bt2.clock_snapshot._UnknownClockSnapshot
-        elif status == native_bt.MESSAGE_STREAM_ACTIVITY_CLOCK_SNAPSHOT_STATE_INFINITE:
-            snapshot_type = bt2.clock_snapshot._InfiniteClockSnapshot
-        else:
-            raise bt2.Error('cannot borrow default clock snapshot from message')
+        status, snapshot_ptr = self._borrow_default_clock_snapshot_ptr(self._ptr)
 
-        assert snapshot_ptr is not None
+        if status == native_bt.MESSAGE_STREAM_CLOCK_SNAPSHOT_STATE_UNKNOWN:
+            return bt2_clock_snapshot._UnknownClockSnapshot()
 
-        return snapshot_type._create_from_ptr_and_get_ref(
-            snapshot_ptr, self._ptr, self._get_ref, self._put_ref)
+        return bt2_clock_snapshot._ClockSnapshot._create_from_ptr_and_get_ref(
+            snapshot_ptr, self._ptr, self._get_ref, self._put_ref
+        )
 
-    def _default_clock_snapshot(self, value):
-        self._set_default_clock_snapshot_ptr(self._ptr, value)
+    def _default_clock_snapshot(self, raw_value):
+        utils._check_uint64(raw_value)
+        self._set_default_clock_snapshot(self._ptr, raw_value)
 
     _default_clock_snapshot = property(fset=_default_clock_snapshot)
 
-    @property
-    def stream(self):
-        stream_ptr = self._borrow_stream_ptr(self._ptr)
-        assert stream_ptr
-        return bt2.stream._Stream._create_from_ptr_and_get_ref(stream_ptr)
 
-
-class _StreamActivityBeginningMessage(_StreamActivityMessage):
-    _borrow_default_clock_snapshot_ptr = staticmethod(native_bt.message_stream_activity_beginning_borrow_default_clock_snapshot_const)
-    _set_default_clock_snapshot_ptr = staticmethod(native_bt.message_stream_activity_beginning_set_default_clock_snapshot)
-    _borrow_stream_ptr = staticmethod(native_bt.message_stream_activity_beginning_borrow_stream)
+class _StreamBeginningMessage(_StreamMessage):
+    _borrow_stream_ptr = staticmethod(native_bt.message_stream_beginning_borrow_stream)
+    _borrow_default_clock_snapshot_ptr = staticmethod(
+        native_bt.message_stream_beginning_borrow_default_clock_snapshot_const
+    )
+    _set_default_clock_snapshot = staticmethod(
+        native_bt.message_stream_beginning_set_default_clock_snapshot
+    )
 
 
-class _StreamActivityEndMessage(_StreamActivityMessage):
-    _borrow_default_clock_snapshot_ptr = staticmethod(native_bt.message_stream_activity_end_borrow_default_clock_snapshot_const)
-    _set_default_clock_snapshot_ptr = staticmethod(native_bt.message_stream_activity_end_set_default_clock_snapshot)
-    _borrow_stream_ptr = staticmethod(native_bt.message_stream_activity_end_borrow_stream)
+class _StreamEndMessage(_StreamMessage):
+    _borrow_stream_ptr = staticmethod(native_bt.message_stream_end_borrow_stream)
+    _borrow_default_clock_snapshot_ptr = staticmethod(
+        native_bt.message_stream_end_borrow_default_clock_snapshot_const
+    )
+    _set_default_clock_snapshot = staticmethod(
+        native_bt.message_stream_end_set_default_clock_snapshot
+    )
 
 
 class _MessageIteratorInactivityMessage(_Message, _MessageWithDefaultClockSnapshot):
-    _borrow_default_clock_snapshot_ptr = staticmethod(native_bt.message_message_iterator_inactivity_borrow_default_clock_snapshot_const)
+    _borrow_default_clock_snapshot_ptr = staticmethod(
+        native_bt.message_message_iterator_inactivity_borrow_default_clock_snapshot_const
+    )
 
     @property
     def default_clock_snapshot(self):
@@ -169,7 +163,7 @@ class _DiscardedMessage(_Message, _MessageWithDefaultClockSnapshot):
     def stream(self):
         stream_ptr = self._borrow_stream_ptr(self._ptr)
         assert stream_ptr
-        return bt2.stream._Stream._create_from_ptr_and_get_ref(stream_ptr)
+        return bt2_stream._Stream._create_from_ptr_and_get_ref(stream_ptr)
 
     @property
     def count(self):
@@ -185,12 +179,16 @@ class _DiscardedMessage(_Message, _MessageWithDefaultClockSnapshot):
 
     def _check_has_default_clock_snapshots(self):
         if not self._has_default_clock_snapshots:
-            raise bt2.NonexistentClockSnapshot('cannot get default clock snapshot: such a message has no clock snapshots for this stream class')
+            raise ValueError(
+                'cannot get default clock snapshot: such a message has no clock snapshots for this stream class'
+            )
 
     @property
     def beginning_default_clock_snapshot(self):
         self._check_has_default_clock_snapshots()
-        return self._get_default_clock_snapshot(self._borrow_beginning_clock_snapshot_ptr)
+        return self._get_default_clock_snapshot(
+            self._borrow_beginning_clock_snapshot_ptr
+        )
 
     @property
     def end_default_clock_snapshot(self):
@@ -199,11 +197,17 @@ class _DiscardedMessage(_Message, _MessageWithDefaultClockSnapshot):
 
 
 class _DiscardedEventsMessage(_DiscardedMessage):
-    _borrow_stream_ptr = staticmethod(native_bt.message_discarded_events_borrow_stream_const)
+    _borrow_stream_ptr = staticmethod(
+        native_bt.message_discarded_events_borrow_stream_const
+    )
     _get_count = staticmethod(native_bt.message_discarded_events_get_count)
     _set_count = staticmethod(native_bt.message_discarded_events_set_count)
-    _borrow_beginning_clock_snapshot_ptr = staticmethod(native_bt.message_discarded_events_borrow_beginning_default_clock_snapshot_const)
-    _borrow_end_clock_snapshot_ptr = staticmethod(native_bt.message_discarded_events_borrow_end_default_clock_snapshot_const)
+    _borrow_beginning_clock_snapshot_ptr = staticmethod(
+        native_bt.message_discarded_events_borrow_beginning_default_clock_snapshot_const
+    )
+    _borrow_end_clock_snapshot_ptr = staticmethod(
+        native_bt.message_discarded_events_borrow_end_default_clock_snapshot_const
+    )
 
     @property
     def _has_default_clock_snapshots(self):
@@ -211,11 +215,17 @@ class _DiscardedEventsMessage(_DiscardedMessage):
 
 
 class _DiscardedPacketsMessage(_DiscardedMessage):
-    _borrow_stream_ptr = staticmethod(native_bt.message_discarded_packets_borrow_stream_const)
+    _borrow_stream_ptr = staticmethod(
+        native_bt.message_discarded_packets_borrow_stream_const
+    )
     _get_count = staticmethod(native_bt.message_discarded_packets_get_count)
     _set_count = staticmethod(native_bt.message_discarded_packets_set_count)
-    _borrow_beginning_clock_snapshot_ptr = staticmethod(native_bt.message_discarded_packets_borrow_beginning_default_clock_snapshot_const)
-    _borrow_end_clock_snapshot_ptr = staticmethod(native_bt.message_discarded_packets_borrow_end_default_clock_snapshot_const)
+    _borrow_beginning_clock_snapshot_ptr = staticmethod(
+        native_bt.message_discarded_packets_borrow_beginning_default_clock_snapshot_const
+    )
+    _borrow_end_clock_snapshot_ptr = staticmethod(
+        native_bt.message_discarded_packets_borrow_end_default_clock_snapshot_const
+    )
 
     @property
     def _has_default_clock_snapshots(self):
@@ -229,8 +239,6 @@ _MESSAGE_TYPE_TO_CLS = {
     native_bt.MESSAGE_TYPE_STREAM_END: _StreamEndMessage,
     native_bt.MESSAGE_TYPE_PACKET_BEGINNING: _PacketBeginningMessage,
     native_bt.MESSAGE_TYPE_PACKET_END: _PacketEndMessage,
-    native_bt.MESSAGE_TYPE_STREAM_ACTIVITY_BEGINNING: _StreamActivityBeginningMessage,
-    native_bt.MESSAGE_TYPE_STREAM_ACTIVITY_END: _StreamActivityEndMessage,
     native_bt.MESSAGE_TYPE_DISCARDED_EVENTS: _DiscardedEventsMessage,
     native_bt.MESSAGE_TYPE_DISCARDED_PACKETS: _DiscardedPacketsMessage,
 }
BabelTrace - Trace Format Babel Tower
This page took 0.026945 seconds and 4 git commands to generate.