Index: webrtc/tools/py_event_log_analyzer/pb_parse.py |
diff --git a/webrtc/tools/py_event_log_analyzer/pb_parse.py b/webrtc/tools/py_event_log_analyzer/pb_parse.py |
index b0ca2b3354463a76e5f932758e21c580eedb6f43..bd2f2b4314a5411a2be7762b6757d5fe205f9a77 100644 |
--- a/webrtc/tools/py_event_log_analyzer/pb_parse.py |
+++ b/webrtc/tools/py_event_log_analyzer/pb_parse.py |
@@ -17,13 +17,14 @@ class DataPoint(object): |
"""Simple container class for RTP events.""" |
def __init__(self, rtp_header_str, packet_size, |
- arrival_timestamp_us): |
+ arrival_timestamp_us, incoming): |
"""Builds a data point by parsing an RTP header, size and arrival time. |
RTP header structure is defined in RFC 3550 section 5.1. |
""" |
self.size = packet_size |
self.arrival_timestamp_ms = arrival_timestamp_us / 1000 |
+ self.incoming = incoming |
header = struct.unpack_from("!HHII", rtp_header_str, 0) |
(first2header_bytes, self.sequence_number, self.timestamp, |
self.ssrc) = header |
@@ -46,6 +47,6 @@ def parse_protobuf(file_path): |
return [DataPoint(event.rtp_packet.header, |
event.rtp_packet.packet_length, |
- event.timestamp_us) |
+ event.timestamp_us, event.rtp_packet.incoming) |
for event in event_stream.stream |
if event.HasField("rtp_packet")] |