OLD | NEW |
| (Empty) |
1 /* | |
2 * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. | |
3 * | |
4 * Use of this source code is governed by a BSD-style license | |
5 * that can be found in the LICENSE file in the root of the source | |
6 * tree. An additional intellectual property rights grant can be found | |
7 * in the file PATENTS. All contributing project authors may | |
8 * be found in the AUTHORS file in the root of the source tree. | |
9 */ | |
10 | |
11 #ifndef WEBRTC_TOOLS_EVENT_LOG_VISUALIZER_ANALYZER_H_ | |
12 #define WEBRTC_TOOLS_EVENT_LOG_VISUALIZER_ANALYZER_H_ | |
13 | |
14 #include <map> | |
15 #include <memory> | |
16 #include <set> | |
17 #include <string> | |
18 #include <utility> | |
19 #include <vector> | |
20 | |
21 #include "webrtc/base/function_view.h" | |
22 #include "webrtc/logging/rtc_event_log/rtc_event_log_parser.h" | |
23 #include "webrtc/modules/audio_coding/audio_network_adaptor/include/audio_networ
k_adaptor.h" | |
24 #include "webrtc/modules/rtp_rtcp/include/rtp_rtcp_defines.h" | |
25 #include "webrtc/modules/rtp_rtcp/source/rtcp_packet.h" | |
26 #include "webrtc/tools/event_log_visualizer/plot_base.h" | |
27 | |
28 namespace webrtc { | |
29 namespace plotting { | |
30 | |
31 struct LoggedRtpPacket { | |
32 LoggedRtpPacket(uint64_t timestamp, RTPHeader header, size_t total_length) | |
33 : timestamp(timestamp), header(header), total_length(total_length) {} | |
34 uint64_t timestamp; | |
35 // TODO(terelius): This allocates space for 15 CSRCs even if none are used. | |
36 RTPHeader header; | |
37 size_t total_length; | |
38 }; | |
39 | |
40 struct LoggedRtcpPacket { | |
41 LoggedRtcpPacket(uint64_t timestamp, | |
42 RTCPPacketType rtcp_type, | |
43 std::unique_ptr<rtcp::RtcpPacket> rtcp_packet) | |
44 : timestamp(timestamp), type(rtcp_type), packet(std::move(rtcp_packet)) {} | |
45 uint64_t timestamp; | |
46 RTCPPacketType type; | |
47 std::unique_ptr<rtcp::RtcpPacket> packet; | |
48 }; | |
49 | |
50 struct LossBasedBweUpdate { | |
51 uint64_t timestamp; | |
52 int32_t new_bitrate; | |
53 uint8_t fraction_loss; | |
54 int32_t expected_packets; | |
55 }; | |
56 | |
57 struct AudioNetworkAdaptationEvent { | |
58 uint64_t timestamp; | |
59 AudioEncoderRuntimeConfig config; | |
60 }; | |
61 | |
62 class EventLogAnalyzer { | |
63 public: | |
64 // The EventLogAnalyzer keeps a reference to the ParsedRtcEventLog for the | |
65 // duration of its lifetime. The ParsedRtcEventLog must not be destroyed or | |
66 // modified while the EventLogAnalyzer is being used. | |
67 explicit EventLogAnalyzer(const ParsedRtcEventLog& log); | |
68 | |
69 void CreatePacketGraph(PacketDirection desired_direction, Plot* plot); | |
70 | |
71 void CreateAccumulatedPacketsGraph(PacketDirection desired_direction, | |
72 Plot* plot); | |
73 | |
74 void CreatePlayoutGraph(Plot* plot); | |
75 | |
76 void CreateAudioLevelGraph(Plot* plot); | |
77 | |
78 void CreateSequenceNumberGraph(Plot* plot); | |
79 | |
80 void CreateIncomingPacketLossGraph(Plot* plot); | |
81 | |
82 void CreateDelayChangeGraph(Plot* plot); | |
83 | |
84 void CreateAccumulatedDelayChangeGraph(Plot* plot); | |
85 | |
86 void CreateFractionLossGraph(Plot* plot); | |
87 | |
88 void CreateTotalBitrateGraph(PacketDirection desired_direction, Plot* plot); | |
89 | |
90 void CreateStreamBitrateGraph(PacketDirection desired_direction, Plot* plot); | |
91 | |
92 void CreateBweSimulationGraph(Plot* plot); | |
93 | |
94 void CreateNetworkDelayFeedbackGraph(Plot* plot); | |
95 void CreateTimestampGraph(Plot* plot); | |
96 | |
97 void CreateAudioEncoderTargetBitrateGraph(Plot* plot); | |
98 void CreateAudioEncoderFrameLengthGraph(Plot* plot); | |
99 void CreateAudioEncoderUplinkPacketLossFractionGraph(Plot* plot); | |
100 void CreateAudioEncoderEnableFecGraph(Plot* plot); | |
101 void CreateAudioEncoderEnableDtxGraph(Plot* plot); | |
102 void CreateAudioEncoderNumChannelsGraph(Plot* plot); | |
103 void CreateAudioJitterBufferGraph(const std::string& replacement_file_name, | |
104 int file_sample_rate_hz, | |
105 Plot* plot); | |
106 | |
107 // Returns a vector of capture and arrival timestamps for the video frames | |
108 // of the stream with the most number of frames. | |
109 std::vector<std::pair<int64_t, int64_t>> GetFrameTimestamps() const; | |
110 | |
111 private: | |
112 class StreamId { | |
113 public: | |
114 StreamId(uint32_t ssrc, webrtc::PacketDirection direction) | |
115 : ssrc_(ssrc), direction_(direction) {} | |
116 bool operator<(const StreamId& other) const { | |
117 return std::tie(ssrc_, direction_) < | |
118 std::tie(other.ssrc_, other.direction_); | |
119 } | |
120 bool operator==(const StreamId& other) const { | |
121 return std::tie(ssrc_, direction_) == | |
122 std::tie(other.ssrc_, other.direction_); | |
123 } | |
124 uint32_t GetSsrc() const { return ssrc_; } | |
125 webrtc::PacketDirection GetDirection() const { return direction_; } | |
126 | |
127 private: | |
128 uint32_t ssrc_; | |
129 webrtc::PacketDirection direction_; | |
130 }; | |
131 | |
132 template <typename T> | |
133 void CreateAccumulatedPacketsTimeSeries( | |
134 PacketDirection desired_direction, | |
135 Plot* plot, | |
136 const std::map<StreamId, std::vector<T>>& packets, | |
137 const std::string& label_prefix); | |
138 | |
139 bool IsRtxSsrc(StreamId stream_id) const; | |
140 | |
141 bool IsVideoSsrc(StreamId stream_id) const; | |
142 | |
143 bool IsAudioSsrc(StreamId stream_id) const; | |
144 | |
145 std::string GetStreamName(StreamId) const; | |
146 | |
147 const ParsedRtcEventLog& parsed_log_; | |
148 | |
149 // A list of SSRCs we are interested in analysing. | |
150 // If left empty, all SSRCs will be considered relevant. | |
151 std::vector<uint32_t> desired_ssrc_; | |
152 | |
153 // Tracks what each stream is configured for. Note that a single SSRC can be | |
154 // in several sets. For example, the SSRC used for sending video over RTX | |
155 // will appear in both video_ssrcs_ and rtx_ssrcs_. In the unlikely case that | |
156 // an SSRC is reconfigured to a different media type mid-call, it will also | |
157 // appear in multiple sets. | |
158 std::set<StreamId> rtx_ssrcs_; | |
159 std::set<StreamId> video_ssrcs_; | |
160 std::set<StreamId> audio_ssrcs_; | |
161 | |
162 // Maps a stream identifier consisting of ssrc and direction to the parsed | |
163 // RTP headers in that stream. Header extensions are parsed if the stream | |
164 // has been configured. | |
165 std::map<StreamId, std::vector<LoggedRtpPacket>> rtp_packets_; | |
166 | |
167 std::map<StreamId, std::vector<LoggedRtcpPacket>> rtcp_packets_; | |
168 | |
169 // Maps an SSRC to the timestamps of parsed audio playout events. | |
170 std::map<uint32_t, std::vector<uint64_t>> audio_playout_events_; | |
171 | |
172 // Stores the timestamps for all log segments, in the form of associated start | |
173 // and end events. | |
174 std::vector<std::pair<uint64_t, uint64_t>> log_segments_; | |
175 | |
176 // A list of all updates from the send-side loss-based bandwidth estimator. | |
177 std::vector<LossBasedBweUpdate> bwe_loss_updates_; | |
178 | |
179 std::vector<AudioNetworkAdaptationEvent> audio_network_adaptation_events_; | |
180 | |
181 std::vector<ParsedRtcEventLog::BweProbeClusterCreatedEvent> | |
182 bwe_probe_cluster_created_events_; | |
183 | |
184 std::vector<ParsedRtcEventLog::BweProbeResultEvent> bwe_probe_result_events_; | |
185 | |
186 std::vector<ParsedRtcEventLog::BweDelayBasedUpdate> bwe_delay_updates_; | |
187 | |
188 // Window and step size used for calculating moving averages, e.g. bitrate. | |
189 // The generated data points will be |step_| microseconds apart. | |
190 // Only events occuring at most |window_duration_| microseconds before the | |
191 // current data point will be part of the average. | |
192 uint64_t window_duration_; | |
193 uint64_t step_; | |
194 | |
195 // First and last events of the log. | |
196 uint64_t begin_time_; | |
197 uint64_t end_time_; | |
198 | |
199 // Duration (in seconds) of log file. | |
200 float call_duration_s_; | |
201 }; | |
202 | |
203 } // namespace plotting | |
204 } // namespace webrtc | |
205 | |
206 #endif // WEBRTC_TOOLS_EVENT_LOG_VISUALIZER_ANALYZER_H_ | |
OLD | NEW |