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..8062c438e67c564c743d8dc2d7f20ed378722604 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 |
@@ -44,8 +45,8 @@ def parse_protobuf(file_path): |
with open(file_path, "rb") as f: |
event_stream.ParseFromString(f.read()) |
- return [DataPoint(event.rtp_packet.header, |
- event.rtp_packet.packet_length, |
- event.timestamp_us) |
- for event in event_stream.stream |
- if event.HasField("rtp_packet")] |
+ return [DataPoint(event.rtp_packet.header, |
phoglund
2016/09/06 13:14:50
Nit: remove extra space
|
+ event.rtp_packet.packet_length, |
+ event.timestamp_us, event.rtp_packet.incoming) |
+ for event in event_stream.stream |
+ if event.HasField("rtp_packet")] |