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 90 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
101 packet->header.timestamp == (*it)->header.timestamp) { | 101 packet->header.timestamp == (*it)->header.timestamp) { |
102 delete [] (*it)->payload; | 102 delete [] (*it)->payload; |
103 delete *it; | 103 delete *it; |
104 it = buffer_.erase(it); | 104 it = buffer_.erase(it); |
105 } | 105 } |
106 buffer_.insert(it, packet); // Insert the packet at that position. | 106 buffer_.insert(it, packet); // Insert the packet at that position. |
107 | 107 |
108 return return_val; | 108 return return_val; |
109 } | 109 } |
110 | 110 |
111 int PacketBuffer::InsertPacketList(PacketList* packet_list, | 111 int PacketBuffer::InsertPacketList( |
112 const DecoderDatabase& decoder_database, | 112 PacketList* packet_list, |
113 uint8_t* current_rtp_payload_type, | 113 const DecoderDatabase& decoder_database, |
114 uint8_t* current_cng_rtp_payload_type) { | 114 rtc::Optional<uint8_t>* current_rtp_payload_type, |
| 115 rtc::Optional<uint8_t>* current_cng_rtp_payload_type) { |
115 bool flushed = false; | 116 bool flushed = false; |
116 while (!packet_list->empty()) { | 117 while (!packet_list->empty()) { |
117 Packet* packet = packet_list->front(); | 118 Packet* packet = packet_list->front(); |
118 if (decoder_database.IsComfortNoise(packet->header.payloadType)) { | 119 if (decoder_database.IsComfortNoise(packet->header.payloadType)) { |
119 if (*current_cng_rtp_payload_type != 0xFF && | 120 if (*current_cng_rtp_payload_type && |
120 *current_cng_rtp_payload_type != packet->header.payloadType) { | 121 **current_cng_rtp_payload_type != packet->header.payloadType) { |
121 // New CNG payload type implies new codec type. | 122 // New CNG payload type implies new codec type. |
122 *current_rtp_payload_type = 0xFF; | 123 *current_rtp_payload_type = rtc::Optional<uint8_t>(); |
123 Flush(); | 124 Flush(); |
124 flushed = true; | 125 flushed = true; |
125 } | 126 } |
126 *current_cng_rtp_payload_type = packet->header.payloadType; | 127 *current_cng_rtp_payload_type = |
| 128 rtc::Optional<uint8_t>(packet->header.payloadType); |
127 } else if (!decoder_database.IsDtmf(packet->header.payloadType)) { | 129 } else if (!decoder_database.IsDtmf(packet->header.payloadType)) { |
128 // This must be speech. | 130 // This must be speech. |
129 if (*current_rtp_payload_type != 0xFF && | 131 if (*current_rtp_payload_type && |
130 *current_rtp_payload_type != packet->header.payloadType) { | 132 **current_rtp_payload_type != packet->header.payloadType) { |
131 *current_cng_rtp_payload_type = 0xFF; | 133 *current_cng_rtp_payload_type = rtc::Optional<uint8_t>(); |
132 Flush(); | 134 Flush(); |
133 flushed = true; | 135 flushed = true; |
134 } | 136 } |
135 *current_rtp_payload_type = packet->header.payloadType; | 137 *current_rtp_payload_type = |
| 138 rtc::Optional<uint8_t>(packet->header.payloadType); |
136 } | 139 } |
137 int return_val = InsertPacket(packet); | 140 int return_val = InsertPacket(packet); |
138 packet_list->pop_front(); | 141 packet_list->pop_front(); |
139 if (return_val == kFlushed) { | 142 if (return_val == kFlushed) { |
140 // The buffer flushed, but this is not an error. We can still continue. | 143 // The buffer flushed, but this is not an error. We can still continue. |
141 flushed = true; | 144 flushed = true; |
142 } else if (return_val != kOK) { | 145 } else if (return_val != kOK) { |
143 // An error occurred. Delete remaining packets in list and return. | 146 // An error occurred. Delete remaining packets in list and return. |
144 DeleteAllPackets(packet_list); | 147 DeleteAllPackets(packet_list); |
145 return return_val; | 148 return return_val; |
(...skipping 142 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
288 // Continue while the list is not empty. | 291 // Continue while the list is not empty. |
289 } | 292 } |
290 } | 293 } |
291 | 294 |
292 void PacketBuffer::BufferStat(int* num_packets, int* max_num_packets) const { | 295 void PacketBuffer::BufferStat(int* num_packets, int* max_num_packets) const { |
293 *num_packets = static_cast<int>(buffer_.size()); | 296 *num_packets = static_cast<int>(buffer_.size()); |
294 *max_num_packets = static_cast<int>(max_number_of_packets_); | 297 *max_num_packets = static_cast<int>(max_number_of_packets_); |
295 } | 298 } |
296 | 299 |
297 } // namespace webrtc | 300 } // namespace webrtc |
OLD | NEW |