projects
/
babeltrace.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
black: run `black` version 19.10b0 on entire project
[babeltrace.git]
/
tests
/
data
/
plugins
/
src.ctf.lttng-live
/
lttng_live_server.py
diff --git
a/tests/data/plugins/src.ctf.lttng-live/lttng_live_server.py
b/tests/data/plugins/src.ctf.lttng-live/lttng_live_server.py
index a30dbc4657c79d65bead37cc264b49da8f9cf370..91e1cc8a6f446b4df30e78520a7cfebffb26c45c 100644
(file)
--- a/
tests/data/plugins/src.ctf.lttng-live/lttng_live_server.py
+++ b/
tests/data/plugins/src.ctf.lttng-live/lttng_live_server.py
@@
-457,7
+457,7
@@
class _LttngLiveViewerProtocolCodec:
version, tracing_session_id, offset, seek_type
)
elif cmd_type == 4:
version, tracing_session_id, offset, seek_type
)
elif cmd_type == 4:
-
stream_id,
= self._unpack_payload('Q', data)
+
(stream_id,)
= self._unpack_payload('Q', data)
return _LttngLiveViewerGetNextDataStreamIndexEntryCommand(
version, stream_id
)
return _LttngLiveViewerGetNextDataStreamIndexEntryCommand(
version, stream_id
)
@@
-467,15
+467,15
@@
class _LttngLiveViewerProtocolCodec:
version, stream_id, offset, req_length
)
elif cmd_type == 6:
version, stream_id, offset, req_length
)
elif cmd_type == 6:
-
stream_id,
= self._unpack_payload('Q', data)
+
(stream_id,)
= self._unpack_payload('Q', data)
return _LttngLiveViewerGetMetadataStreamDataCommand(version, stream_id)
elif cmd_type == 7:
return _LttngLiveViewerGetMetadataStreamDataCommand(version, stream_id)
elif cmd_type == 7:
-
tracing_session_id,
= self._unpack_payload('Q', data)
+
(tracing_session_id,)
= self._unpack_payload('Q', data)
return _LttngLiveViewerGetNewStreamInfosCommand(version, tracing_session_id)
elif cmd_type == 8:
return _LttngLiveViewerCreateViewerSessionCommand(version)
elif cmd_type == 9:
return _LttngLiveViewerGetNewStreamInfosCommand(version, tracing_session_id)
elif cmd_type == 8:
return _LttngLiveViewerCreateViewerSessionCommand(version)
elif cmd_type == 9:
-
tracing_session_id,
= self._unpack_payload('Q', data)
+
(tracing_session_id,)
= self._unpack_payload('Q', data)
return _LttngLiveViewerDetachFromTracingSessionCommand(
version, tracing_session_id
)
return _LttngLiveViewerDetachFromTracingSessionCommand(
version, tracing_session_id
)
@@
-674,9
+674,15
@@
class _LttngDataStreamIndex(collections.abc.Sequence):
break
assert len(data) == size
break
assert len(data) == size
- offset_bytes, total_size_bits, content_size_bits, timestamp_begin, timestamp_end, events_discarded, stream_class_id = struct.unpack(
- fmt, data
- )
+ (
+ offset_bytes,
+ total_size_bits,
+ content_size_bits,
+ timestamp_begin,
+ timestamp_end,
+ events_discarded,
+ stream_class_id,
+ ) = struct.unpack(fmt, data)
self._entries.append(
_LttngDataStreamIndexEntry(
self._entries.append(
_LttngDataStreamIndexEntry(
This page took
0.044862 seconds
and
4
git commands to generate.