Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 /* | 1 /* |
| 2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. |
| 3 * | 3 * |
| 4 * Use of this source code is governed by a BSD-style license | 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 | 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 | 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ | 9 */ |
| 10 | 10 |
| (...skipping 773 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 784 padding_bytes(0), | 784 padding_bytes(0), |
| 785 packets(0) {} | 785 packets(0) {} |
| 786 | 786 |
| 787 void Add(const RtpPacketCounter& other) { | 787 void Add(const RtpPacketCounter& other) { |
| 788 header_bytes += other.header_bytes; | 788 header_bytes += other.header_bytes; |
| 789 payload_bytes += other.payload_bytes; | 789 payload_bytes += other.payload_bytes; |
| 790 padding_bytes += other.padding_bytes; | 790 padding_bytes += other.padding_bytes; |
| 791 packets += other.packets; | 791 packets += other.packets; |
| 792 } | 792 } |
| 793 | 793 |
| 794 void Subtract(const RtpPacketCounter& other) { | |
| 795 header_bytes -= other.header_bytes; | |
|
mflodman
2016/02/29 09:41:17
There's no >= 0 check, do we count on the user to
sprang_webrtc
2016/02/29 13:00:33
Yes. But I'll add a DCHECK to be sure.
| |
| 796 payload_bytes -= other.payload_bytes; | |
| 797 padding_bytes -= other.padding_bytes; | |
| 798 packets -= other.packets; | |
| 799 } | |
| 800 | |
| 794 void AddPacket(size_t packet_length, const RTPHeader& header) { | 801 void AddPacket(size_t packet_length, const RTPHeader& header) { |
| 795 ++packets; | 802 ++packets; |
| 796 header_bytes += header.headerLength; | 803 header_bytes += header.headerLength; |
| 797 padding_bytes += header.paddingLength; | 804 padding_bytes += header.paddingLength; |
| 798 payload_bytes += | 805 payload_bytes += |
| 799 packet_length - (header.headerLength + header.paddingLength); | 806 packet_length - (header.headerLength + header.paddingLength); |
| 800 } | 807 } |
| 801 | 808 |
| 802 size_t TotalBytes() const { | 809 size_t TotalBytes() const { |
| 803 return header_bytes + payload_bytes + padding_bytes; | 810 return header_bytes + payload_bytes + padding_bytes; |
| (...skipping 14 matching lines...) Expand all Loading... | |
| 818 retransmitted.Add(other.retransmitted); | 825 retransmitted.Add(other.retransmitted); |
| 819 fec.Add(other.fec); | 826 fec.Add(other.fec); |
| 820 if (other.first_packet_time_ms != -1 && | 827 if (other.first_packet_time_ms != -1 && |
| 821 (other.first_packet_time_ms < first_packet_time_ms || | 828 (other.first_packet_time_ms < first_packet_time_ms || |
| 822 first_packet_time_ms == -1)) { | 829 first_packet_time_ms == -1)) { |
| 823 // Use oldest time. | 830 // Use oldest time. |
| 824 first_packet_time_ms = other.first_packet_time_ms; | 831 first_packet_time_ms = other.first_packet_time_ms; |
| 825 } | 832 } |
| 826 } | 833 } |
| 827 | 834 |
| 835 void Subtract(const StreamDataCounters& other) { | |
| 836 transmitted.Subtract(other.transmitted); | |
| 837 retransmitted.Subtract(other.retransmitted); | |
| 838 fec.Subtract(other.fec); | |
| 839 if (other.first_packet_time_ms != -1 && | |
| 840 (other.first_packet_time_ms > first_packet_time_ms || | |
| 841 first_packet_time_ms == -1)) { | |
| 842 // Use youngest time. | |
| 843 first_packet_time_ms = other.first_packet_time_ms; | |
| 844 } | |
| 845 } | |
| 846 | |
| 828 int64_t TimeSinceFirstPacketInMs(int64_t now_ms) const { | 847 int64_t TimeSinceFirstPacketInMs(int64_t now_ms) const { |
| 829 return (first_packet_time_ms == -1) ? -1 : (now_ms - first_packet_time_ms); | 848 return (first_packet_time_ms == -1) ? -1 : (now_ms - first_packet_time_ms); |
| 830 } | 849 } |
| 831 | 850 |
| 832 // Returns the number of bytes corresponding to the actual media payload (i.e. | 851 // Returns the number of bytes corresponding to the actual media payload (i.e. |
| 833 // RTP headers, padding, retransmissions and fec packets are excluded). | 852 // RTP headers, padding, retransmissions and fec packets are excluded). |
| 834 // Note this function does not have meaning for an RTX stream. | 853 // Note this function does not have meaning for an RTX stream. |
| 835 size_t MediaPayloadBytes() const { | 854 size_t MediaPayloadBytes() const { |
| 836 return transmitted.payload_bytes - retransmitted.payload_bytes - | 855 return transmitted.payload_bytes - retransmitted.payload_bytes - |
| 837 fec.payload_bytes; | 856 fec.payload_bytes; |
| (...skipping 14 matching lines...) Expand all Loading... | |
| 852 uint32_t ssrc) = 0; | 871 uint32_t ssrc) = 0; |
| 853 }; | 872 }; |
| 854 | 873 |
| 855 // RTCP mode to use. Compound mode is described by RFC 4585 and reduced-size | 874 // RTCP mode to use. Compound mode is described by RFC 4585 and reduced-size |
| 856 // RTCP mode is described by RFC 5506. | 875 // RTCP mode is described by RFC 5506. |
| 857 enum class RtcpMode { kOff, kCompound, kReducedSize }; | 876 enum class RtcpMode { kOff, kCompound, kReducedSize }; |
| 858 | 877 |
| 859 } // namespace webrtc | 878 } // namespace webrtc |
| 860 | 879 |
| 861 #endif // WEBRTC_COMMON_TYPES_H_ | 880 #endif // WEBRTC_COMMON_TYPES_H_ |
| OLD | NEW |