OLD | NEW |
| (Empty) |
1 # Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. | |
2 # | |
3 # Use of this source code is governed by a BSD-style license | |
4 # that can be found in the LICENSE file in the root of the source | |
5 # tree. An additional intellectual property rights grant can be found | |
6 # in the file PATENTS. All contributing project authors may | |
7 # be found in the AUTHORS file in the root of the source tree. | |
8 | |
9 """Utility functions for calculating statistics. | |
10 """ | |
11 | |
12 from __future__ import division | |
13 import collections | |
14 import sys | |
15 | |
16 | |
17 def CountReordered(sequence_numbers): | |
18 """Returns number of reordered indices. | |
19 | |
20 A reordered index is an index `i` for which sequence_numbers[i] >= | |
21 sequence_numbers[i + 1] | |
22 """ | |
23 return sum(1 for (s1, s2) in zip(sequence_numbers, | |
24 sequence_numbers[1:]) if | |
25 s1 >= s2) | |
26 | |
27 | |
28 def SsrcNormalizedSizeTable(data_points): | |
29 """Counts proportion of data for every SSRC. | |
30 | |
31 Args: | |
32 data_points: list of pb_parse.DataPoint | |
33 | |
34 Returns: | |
35 A dictionary mapping from every SSRC in the data points. The | |
36 value of an SSRC `s` is the proportion of sizes of packets with | |
37 SSRC `s` to the total size of all packets. | |
38 | |
39 """ | |
40 mapping = collections.defaultdict(int) | |
41 for point in data_points: | |
42 mapping[point.ssrc] += point.size | |
43 return NormalizeCounter(mapping) | |
44 | |
45 | |
46 def NormalizeCounter(counter): | |
47 """Returns a normalized version of the dictionary `counter`. | |
48 | |
49 Does not modify `counter`. | |
50 | |
51 Returns: | |
52 A new dictionary, in which every value in `counter` | |
53 has been divided by the total to sum up to 1. | |
54 """ | |
55 total = sum(counter.values()) | |
56 return {key: counter[key] / total for key in counter} | |
57 | |
58 | |
59 def Unwrap(data, mod): | |
60 """Returns `data` unwrapped modulo `mod`. Does not modify data. | |
61 | |
62 Adds integer multiples of mod to all elements of data except the | |
63 first, such that all pairs of consecutive elements (a, b) satisfy | |
64 -mod / 2 <= b - a < mod / 2. | |
65 | |
66 E.g. Unwrap([0, 1, 2, 0, 1, 2, 7, 8], 3) -> [0, 1, 2, 3, | |
67 4, 5, 4, 5] | |
68 """ | |
69 lst = data[:] | |
70 for i in range(1, len(data)): | |
71 lst[i] = lst[i - 1] + (lst[i] - lst[i - 1] + | |
72 mod // 2) % mod - (mod // 2) | |
73 return lst | |
74 | |
75 | |
76 def SsrcDirections(data_points): | |
77 ssrc_is_incoming = {} | |
78 for point in data_points: | |
79 ssrc_is_incoming[point.ssrc] = point.incoming | |
80 return ssrc_is_incoming | |
81 | |
82 | |
83 # Python 2/3-compatible input function | |
84 if sys.version_info[0] <= 2: | |
85 get_input = raw_input # pylint: disable=invalid-name | |
86 else: | |
87 get_input = input # pylint: disable=invalid-name | |
OLD | NEW |