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 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
49 class RateLimiter; | 49 class RateLimiter; |
50 class ReceiveStatistics; | 50 class ReceiveStatistics; |
51 class RemoteNtpTimeEstimator; | 51 class RemoteNtpTimeEstimator; |
52 class RtcEventLog; | 52 class RtcEventLog; |
53 class RTPPayloadRegistry; | 53 class RTPPayloadRegistry; |
54 class RTPReceiverAudio; | 54 class RTPReceiverAudio; |
55 class RtpPacketReceived; | 55 class RtpPacketReceived; |
56 class RtpRtcp; | 56 class RtpRtcp; |
57 class RtpTransportControllerSendInterface; | 57 class RtpTransportControllerSendInterface; |
58 class TelephoneEventHandler; | 58 class TelephoneEventHandler; |
59 class VoERTPObserver; | |
60 class VoiceEngineObserver; | 59 class VoiceEngineObserver; |
61 | 60 |
62 struct CallStatistics; | |
63 struct ReportBlock; | |
64 struct SenderInfo; | 61 struct SenderInfo; |
65 | 62 |
| 63 struct CallStatistics { |
| 64 unsigned short fractionLost; |
| 65 unsigned int cumulativeLost; |
| 66 unsigned int extendedMax; |
| 67 unsigned int jitterSamples; |
| 68 int64_t rttMs; |
| 69 size_t bytesSent; |
| 70 int packetsSent; |
| 71 size_t bytesReceived; |
| 72 int packetsReceived; |
| 73 // The capture ntp time (in local timebase) of the first played out audio |
| 74 // frame. |
| 75 int64_t capture_start_ntp_time_ms_; |
| 76 }; |
| 77 |
| 78 // See section 6.4.2 in http://www.ietf.org/rfc/rfc3550.txt for details. |
| 79 struct ReportBlock { |
| 80 uint32_t sender_SSRC; // SSRC of sender |
| 81 uint32_t source_SSRC; |
| 82 uint8_t fraction_lost; |
| 83 uint32_t cumulative_num_packets_lost; |
| 84 uint32_t extended_highest_sequence_number; |
| 85 uint32_t interarrival_jitter; |
| 86 uint32_t last_SR_timestamp; |
| 87 uint32_t delay_since_last_SR; |
| 88 }; |
| 89 |
66 namespace voe { | 90 namespace voe { |
67 | 91 |
68 class OutputMixer; | 92 class OutputMixer; |
69 class RtcEventLogProxy; | 93 class RtcEventLogProxy; |
70 class RtcpRttStatsProxy; | 94 class RtcpRttStatsProxy; |
71 class RtpPacketSenderProxy; | 95 class RtpPacketSenderProxy; |
72 class Statistics; | 96 class Statistics; |
73 class TransportFeedbackProxy; | 97 class TransportFeedbackProxy; |
74 class TransportSequenceNumberProxy; | 98 class TransportSequenceNumberProxy; |
75 class VoERtcpObserver; | 99 class VoERtcpObserver; |
(...skipping 132 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
208 // Audio+Video Sync. | 232 // Audio+Video Sync. |
209 uint32_t GetDelayEstimate() const; | 233 uint32_t GetDelayEstimate() const; |
210 int SetMinimumPlayoutDelay(int delayMs); | 234 int SetMinimumPlayoutDelay(int delayMs); |
211 int GetPlayoutTimestamp(unsigned int& timestamp); | 235 int GetPlayoutTimestamp(unsigned int& timestamp); |
212 int GetRtpRtcp(RtpRtcp** rtpRtcpModule, RtpReceiver** rtp_receiver) const; | 236 int GetRtpRtcp(RtpRtcp** rtpRtcpModule, RtpReceiver** rtp_receiver) const; |
213 | 237 |
214 // DTMF. | 238 // DTMF. |
215 int SendTelephoneEventOutband(int event, int duration_ms); | 239 int SendTelephoneEventOutband(int event, int duration_ms); |
216 int SetSendTelephoneEventPayloadType(int payload_type, int payload_frequency); | 240 int SetSendTelephoneEventPayloadType(int payload_type, int payload_frequency); |
217 | 241 |
218 // VoERTP_RTCP | 242 // RTP+RTCP |
219 int SetLocalSSRC(unsigned int ssrc); | 243 int SetLocalSSRC(unsigned int ssrc); |
220 int GetLocalSSRC(unsigned int& ssrc); | |
221 int GetRemoteSSRC(unsigned int& ssrc); | |
222 int SetSendAudioLevelIndicationStatus(bool enable, unsigned char id); | 244 int SetSendAudioLevelIndicationStatus(bool enable, unsigned char id); |
223 int SetReceiveAudioLevelIndicationStatus(bool enable, unsigned char id); | 245 int SetReceiveAudioLevelIndicationStatus(bool enable, unsigned char id); |
224 void EnableSendTransportSequenceNumber(int id); | 246 void EnableSendTransportSequenceNumber(int id); |
225 void EnableReceiveTransportSequenceNumber(int id); | 247 void EnableReceiveTransportSequenceNumber(int id); |
226 | 248 |
227 void RegisterSenderCongestionControlObjects( | 249 void RegisterSenderCongestionControlObjects( |
228 RtpTransportControllerSendInterface* transport, | 250 RtpTransportControllerSendInterface* transport, |
229 RtcpBandwidthObserver* bandwidth_observer); | 251 RtcpBandwidthObserver* bandwidth_observer); |
230 void RegisterReceiverCongestionControlObjects(PacketRouter* packet_router); | 252 void RegisterReceiverCongestionControlObjects(PacketRouter* packet_router); |
231 void ResetSenderCongestionControlObjects(); | 253 void ResetSenderCongestionControlObjects(); |
232 void ResetReceiverCongestionControlObjects(); | 254 void ResetReceiverCongestionControlObjects(); |
233 void SetRTCPStatus(bool enable); | 255 void SetRTCPStatus(bool enable); |
234 int GetRTCPStatus(bool& enabled); | |
235 int SetRTCP_CNAME(const char cName[256]); | 256 int SetRTCP_CNAME(const char cName[256]); |
236 int GetRemoteRTCP_CNAME(char cName[256]); | |
237 int SendApplicationDefinedRTCPPacket(unsigned char subType, | |
238 unsigned int name, | |
239 const char* data, | |
240 unsigned short dataLengthInBytes); | |
241 int GetRemoteRTCPReportBlocks(std::vector<ReportBlock>* report_blocks); | 257 int GetRemoteRTCPReportBlocks(std::vector<ReportBlock>* report_blocks); |
242 int GetRTPStatistics(CallStatistics& stats); | 258 int GetRTPStatistics(CallStatistics& stats); |
243 void SetNACKStatus(bool enable, int maxNumberOfPackets); | 259 void SetNACKStatus(bool enable, int maxNumberOfPackets); |
244 | 260 |
245 // From AudioPacketizationCallback in the ACM | 261 // From AudioPacketizationCallback in the ACM |
246 int32_t SendData(FrameType frameType, | 262 int32_t SendData(FrameType frameType, |
247 uint8_t payloadType, | 263 uint8_t payloadType, |
248 uint32_t timeStamp, | 264 uint32_t timeStamp, |
249 const uint8_t* payloadData, | 265 const uint8_t* payloadData, |
250 size_t payloadSize, | 266 size_t payloadSize, |
(...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
336 | 352 |
337 void OnRecoverableUplinkPacketLossRate(float recoverable_packet_loss_rate); | 353 void OnRecoverableUplinkPacketLossRate(float recoverable_packet_loss_rate); |
338 | 354 |
339 std::vector<RtpSource> GetSources() const { | 355 std::vector<RtpSource> GetSources() const { |
340 return rtp_receiver_->GetSources(); | 356 return rtp_receiver_->GetSources(); |
341 } | 357 } |
342 | 358 |
343 private: | 359 private: |
344 class ProcessAndEncodeAudioTask; | 360 class ProcessAndEncodeAudioTask; |
345 | 361 |
| 362 int GetRemoteSSRC(unsigned int& ssrc); |
346 void OnUplinkPacketLossRate(float packet_loss_rate); | 363 void OnUplinkPacketLossRate(float packet_loss_rate); |
347 bool InputMute() const; | 364 bool InputMute() const; |
348 bool OnRtpPacketWithHeader(const uint8_t* received_packet, | 365 bool OnRtpPacketWithHeader(const uint8_t* received_packet, |
349 size_t length, | 366 size_t length, |
350 RTPHeader *header); | 367 RTPHeader *header); |
351 bool OnRecoveredPacket(const uint8_t* packet, size_t packet_length); | 368 bool OnRecoveredPacket(const uint8_t* packet, size_t packet_length); |
352 | 369 |
353 bool ReceivePacket(const uint8_t* packet, | 370 bool ReceivePacket(const uint8_t* packet, |
354 size_t packet_length, | 371 size_t packet_length, |
355 const RTPHeader& header, | 372 const RTPHeader& header, |
(...skipping 112 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
468 | 485 |
469 bool encoder_queue_is_active_ RTC_GUARDED_BY(encoder_queue_lock_) = false; | 486 bool encoder_queue_is_active_ RTC_GUARDED_BY(encoder_queue_lock_) = false; |
470 | 487 |
471 rtc::TaskQueue* encoder_queue_ = nullptr; | 488 rtc::TaskQueue* encoder_queue_ = nullptr; |
472 }; | 489 }; |
473 | 490 |
474 } // namespace voe | 491 } // namespace voe |
475 } // namespace webrtc | 492 } // namespace webrtc |
476 | 493 |
477 #endif // VOICE_ENGINE_CHANNEL_H_ | 494 #endif // VOICE_ENGINE_CHANNEL_H_ |
OLD | NEW |