deadbeef | 6979b02 | 2015-09-24 16:47:53 -0700 | [diff] [blame] | 1 | /* |
kjellander | b24317b | 2016-02-10 07:54:43 -0800 | [diff] [blame] | 2 | * Copyright 2015 The WebRTC project authors. All Rights Reserved. |
deadbeef | 6979b02 | 2015-09-24 16:47:53 -0700 | [diff] [blame] | 3 | * |
kjellander | b24317b | 2016-02-10 07:54:43 -0800 | [diff] [blame] | 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. |
deadbeef | 6979b02 | 2015-09-24 16:47:53 -0700 | [diff] [blame] | 9 | */ |
| 10 | |
Henrik Kjellander | 15583c1 | 2016-02-10 10:53:12 +0100 | [diff] [blame] | 11 | #include "webrtc/api/rtpreceiver.h" |
deadbeef | 6979b02 | 2015-09-24 16:47:53 -0700 | [diff] [blame] | 12 | |
perkj | f0dcfe2 | 2016-03-10 18:32:00 +0100 | [diff] [blame] | 13 | #include "webrtc/api/mediastreamtrackproxy.h" |
perkj | d61bf80 | 2016-03-24 03:16:19 -0700 | [diff] [blame] | 14 | #include "webrtc/api/audiotrack.h" |
nisse | 5b68ab5 | 2016-04-07 07:45:54 -0700 | [diff] [blame] | 15 | #include "webrtc/api/videosourceproxy.h" |
perkj | f0dcfe2 | 2016-03-10 18:32:00 +0100 | [diff] [blame] | 16 | #include "webrtc/api/videotrack.h" |
Taylor Brandstetter | db0cd9e | 2016-05-16 11:40:30 -0700 | [diff] [blame] | 17 | #include "webrtc/base/trace_event.h" |
deadbeef | 70ab1a1 | 2015-09-28 16:53:55 -0700 | [diff] [blame] | 18 | |
| 19 | namespace webrtc { |
| 20 | |
perkj | d61bf80 | 2016-03-24 03:16:19 -0700 | [diff] [blame] | 21 | AudioRtpReceiver::AudioRtpReceiver(MediaStreamInterface* stream, |
| 22 | const std::string& track_id, |
Peter Boström | 0c4e06b | 2015-10-07 12:23:21 +0200 | [diff] [blame] | 23 | uint32_t ssrc, |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 24 | cricket::VoiceChannel* channel) |
perkj | d61bf80 | 2016-03-24 03:16:19 -0700 | [diff] [blame] | 25 | : id_(track_id), |
deadbeef | 70ab1a1 | 2015-09-28 16:53:55 -0700 | [diff] [blame] | 26 | ssrc_(ssrc), |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 27 | channel_(channel), |
perkj | d61bf80 | 2016-03-24 03:16:19 -0700 | [diff] [blame] | 28 | track_(AudioTrackProxy::Create( |
| 29 | rtc::Thread::Current(), |
| 30 | AudioTrack::Create(track_id, |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 31 | RemoteAudioSource::Create(ssrc, channel)))), |
perkj | d61bf80 | 2016-03-24 03:16:19 -0700 | [diff] [blame] | 32 | cached_track_enabled_(track_->enabled()) { |
tommi | 6eca7e3 | 2015-12-15 04:27:11 -0800 | [diff] [blame] | 33 | RTC_DCHECK(track_->GetSource()->remote()); |
deadbeef | 70ab1a1 | 2015-09-28 16:53:55 -0700 | [diff] [blame] | 34 | track_->RegisterObserver(this); |
| 35 | track_->GetSource()->RegisterAudioObserver(this); |
| 36 | Reconfigure(); |
perkj | d61bf80 | 2016-03-24 03:16:19 -0700 | [diff] [blame] | 37 | stream->AddTrack(track_); |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 38 | if (channel_) { |
| 39 | channel_->SignalFirstPacketReceived.connect( |
| 40 | this, &AudioRtpReceiver::OnFirstPacketReceived); |
| 41 | } |
deadbeef | 70ab1a1 | 2015-09-28 16:53:55 -0700 | [diff] [blame] | 42 | } |
| 43 | |
| 44 | AudioRtpReceiver::~AudioRtpReceiver() { |
| 45 | track_->GetSource()->UnregisterAudioObserver(this); |
| 46 | track_->UnregisterObserver(this); |
| 47 | Stop(); |
| 48 | } |
| 49 | |
| 50 | void AudioRtpReceiver::OnChanged() { |
| 51 | if (cached_track_enabled_ != track_->enabled()) { |
| 52 | cached_track_enabled_ = track_->enabled(); |
| 53 | Reconfigure(); |
| 54 | } |
| 55 | } |
| 56 | |
| 57 | void AudioRtpReceiver::OnSetVolume(double volume) { |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 58 | RTC_DCHECK(volume >= 0 && volume <= 10); |
| 59 | cached_volume_ = volume; |
| 60 | if (!channel_) { |
| 61 | LOG(LS_ERROR) << "AudioRtpReceiver::OnSetVolume: No audio channel exists."; |
| 62 | return; |
| 63 | } |
deadbeef | 70ab1a1 | 2015-09-28 16:53:55 -0700 | [diff] [blame] | 64 | // When the track is disabled, the volume of the source, which is the |
| 65 | // corresponding WebRtc Voice Engine channel will be 0. So we do not allow |
| 66 | // setting the volume to the source when the track is disabled. |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 67 | if (!stopped_ && track_->enabled()) { |
| 68 | RTC_DCHECK(channel_->SetOutputVolume(ssrc_, cached_volume_)); |
| 69 | } |
deadbeef | 70ab1a1 | 2015-09-28 16:53:55 -0700 | [diff] [blame] | 70 | } |
| 71 | |
Taylor Brandstetter | db0cd9e | 2016-05-16 11:40:30 -0700 | [diff] [blame] | 72 | RtpParameters AudioRtpReceiver::GetParameters() const { |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 73 | if (!channel_ || stopped_) { |
| 74 | return RtpParameters(); |
| 75 | } |
| 76 | return channel_->GetRtpReceiveParameters(ssrc_); |
Taylor Brandstetter | db0cd9e | 2016-05-16 11:40:30 -0700 | [diff] [blame] | 77 | } |
| 78 | |
| 79 | bool AudioRtpReceiver::SetParameters(const RtpParameters& parameters) { |
| 80 | TRACE_EVENT0("webrtc", "AudioRtpReceiver::SetParameters"); |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 81 | if (!channel_ || stopped_) { |
| 82 | return false; |
| 83 | } |
| 84 | return channel_->SetRtpReceiveParameters(ssrc_, parameters); |
Taylor Brandstetter | db0cd9e | 2016-05-16 11:40:30 -0700 | [diff] [blame] | 85 | } |
| 86 | |
deadbeef | a601f5c | 2016-06-06 14:27:39 -0700 | [diff] [blame] | 87 | void AudioRtpReceiver::Stop() { |
| 88 | // TODO(deadbeef): Need to do more here to fully stop receiving packets. |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 89 | if (stopped_) { |
deadbeef | a601f5c | 2016-06-06 14:27:39 -0700 | [diff] [blame] | 90 | return; |
| 91 | } |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 92 | if (channel_) { |
| 93 | // Allow that SetOutputVolume fail. This is the normal case when the |
| 94 | // underlying media channel has already been deleted. |
| 95 | channel_->SetOutputVolume(ssrc_, 0); |
| 96 | } |
| 97 | stopped_ = true; |
deadbeef | a601f5c | 2016-06-06 14:27:39 -0700 | [diff] [blame] | 98 | } |
| 99 | |
deadbeef | 70ab1a1 | 2015-09-28 16:53:55 -0700 | [diff] [blame] | 100 | void AudioRtpReceiver::Reconfigure() { |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 101 | RTC_DCHECK(!stopped_); |
| 102 | if (!channel_) { |
| 103 | LOG(LS_ERROR) << "AudioRtpReceiver::Reconfigure: No audio channel exists."; |
deadbeef | 70ab1a1 | 2015-09-28 16:53:55 -0700 | [diff] [blame] | 104 | return; |
| 105 | } |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 106 | RTC_DCHECK( |
| 107 | channel_->SetOutputVolume(ssrc_, track_->enabled() ? cached_volume_ : 0)); |
deadbeef | 70ab1a1 | 2015-09-28 16:53:55 -0700 | [diff] [blame] | 108 | } |
| 109 | |
zhihuang | 184a3fd | 2016-06-14 11:47:14 -0700 | [diff] [blame] | 110 | void AudioRtpReceiver::SetObserver(RtpReceiverObserverInterface* observer) { |
| 111 | observer_ = observer; |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 112 | // Deliver any notifications the observer may have missed by being set late. |
zhihuang | 184a3fd | 2016-06-14 11:47:14 -0700 | [diff] [blame] | 113 | if (received_first_packet_) { |
| 114 | observer_->OnFirstPacketReceived(media_type()); |
| 115 | } |
| 116 | } |
| 117 | |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 118 | void AudioRtpReceiver::SetChannel(cricket::VoiceChannel* channel) { |
| 119 | if (channel_) { |
| 120 | channel_->SignalFirstPacketReceived.disconnect(this); |
| 121 | } |
| 122 | channel_ = channel; |
| 123 | if (channel_) { |
| 124 | channel_->SignalFirstPacketReceived.connect( |
| 125 | this, &AudioRtpReceiver::OnFirstPacketReceived); |
| 126 | } |
| 127 | } |
| 128 | |
| 129 | void AudioRtpReceiver::OnFirstPacketReceived(cricket::BaseChannel* channel) { |
zhihuang | 184a3fd | 2016-06-14 11:47:14 -0700 | [diff] [blame] | 130 | if (observer_) { |
| 131 | observer_->OnFirstPacketReceived(media_type()); |
| 132 | } |
| 133 | received_first_packet_ = true; |
| 134 | } |
| 135 | |
perkj | f0dcfe2 | 2016-03-10 18:32:00 +0100 | [diff] [blame] | 136 | VideoRtpReceiver::VideoRtpReceiver(MediaStreamInterface* stream, |
| 137 | const std::string& track_id, |
| 138 | rtc::Thread* worker_thread, |
Peter Boström | 0c4e06b | 2015-10-07 12:23:21 +0200 | [diff] [blame] | 139 | uint32_t ssrc, |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 140 | cricket::VideoChannel* channel) |
perkj | f0dcfe2 | 2016-03-10 18:32:00 +0100 | [diff] [blame] | 141 | : id_(track_id), |
| 142 | ssrc_(ssrc), |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 143 | channel_(channel), |
perkj | f0dcfe2 | 2016-03-10 18:32:00 +0100 | [diff] [blame] | 144 | source_(new RefCountedObject<VideoTrackSource>(&broadcaster_, |
perkj | f0dcfe2 | 2016-03-10 18:32:00 +0100 | [diff] [blame] | 145 | true /* remote */)), |
| 146 | track_(VideoTrackProxy::Create( |
| 147 | rtc::Thread::Current(), |
nisse | 5b68ab5 | 2016-04-07 07:45:54 -0700 | [diff] [blame] | 148 | worker_thread, |
| 149 | VideoTrack::Create( |
| 150 | track_id, |
| 151 | VideoTrackSourceProxy::Create(rtc::Thread::Current(), |
| 152 | worker_thread, |
| 153 | source_)))) { |
perkj | f0dcfe2 | 2016-03-10 18:32:00 +0100 | [diff] [blame] | 154 | source_->SetState(MediaSourceInterface::kLive); |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 155 | if (!channel_) { |
| 156 | LOG(LS_ERROR) |
| 157 | << "VideoRtpReceiver::VideoRtpReceiver: No video channel exists."; |
| 158 | } else { |
| 159 | RTC_DCHECK(channel_->SetSink(ssrc_, &broadcaster_)); |
| 160 | } |
perkj | f0dcfe2 | 2016-03-10 18:32:00 +0100 | [diff] [blame] | 161 | stream->AddTrack(track_); |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 162 | if (channel_) { |
| 163 | channel_->SignalFirstPacketReceived.connect( |
| 164 | this, &VideoRtpReceiver::OnFirstPacketReceived); |
| 165 | } |
deadbeef | 70ab1a1 | 2015-09-28 16:53:55 -0700 | [diff] [blame] | 166 | } |
| 167 | |
| 168 | VideoRtpReceiver::~VideoRtpReceiver() { |
| 169 | // Since cricket::VideoRenderer is not reference counted, |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 170 | // we need to remove it from the channel before we are deleted. |
deadbeef | 70ab1a1 | 2015-09-28 16:53:55 -0700 | [diff] [blame] | 171 | Stop(); |
| 172 | } |
| 173 | |
deadbeef | a601f5c | 2016-06-06 14:27:39 -0700 | [diff] [blame] | 174 | RtpParameters VideoRtpReceiver::GetParameters() const { |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 175 | if (!channel_ || stopped_) { |
| 176 | return RtpParameters(); |
| 177 | } |
| 178 | return channel_->GetRtpReceiveParameters(ssrc_); |
deadbeef | a601f5c | 2016-06-06 14:27:39 -0700 | [diff] [blame] | 179 | } |
| 180 | |
| 181 | bool VideoRtpReceiver::SetParameters(const RtpParameters& parameters) { |
| 182 | TRACE_EVENT0("webrtc", "VideoRtpReceiver::SetParameters"); |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 183 | if (!channel_ || stopped_) { |
| 184 | return false; |
| 185 | } |
| 186 | return channel_->SetRtpReceiveParameters(ssrc_, parameters); |
deadbeef | a601f5c | 2016-06-06 14:27:39 -0700 | [diff] [blame] | 187 | } |
| 188 | |
deadbeef | 70ab1a1 | 2015-09-28 16:53:55 -0700 | [diff] [blame] | 189 | void VideoRtpReceiver::Stop() { |
| 190 | // TODO(deadbeef): Need to do more here to fully stop receiving packets. |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 191 | if (stopped_) { |
deadbeef | 70ab1a1 | 2015-09-28 16:53:55 -0700 | [diff] [blame] | 192 | return; |
| 193 | } |
perkj | f0dcfe2 | 2016-03-10 18:32:00 +0100 | [diff] [blame] | 194 | source_->SetState(MediaSourceInterface::kEnded); |
| 195 | source_->OnSourceDestroyed(); |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 196 | if (!channel_) { |
| 197 | LOG(LS_WARNING) << "VideoRtpReceiver::Stop: No video channel exists."; |
| 198 | } else { |
| 199 | // Allow that SetSink fail. This is the normal case when the underlying |
| 200 | // media channel has already been deleted. |
| 201 | channel_->SetSink(ssrc_, nullptr); |
| 202 | } |
| 203 | stopped_ = true; |
deadbeef | 70ab1a1 | 2015-09-28 16:53:55 -0700 | [diff] [blame] | 204 | } |
| 205 | |
zhihuang | 184a3fd | 2016-06-14 11:47:14 -0700 | [diff] [blame] | 206 | void VideoRtpReceiver::SetObserver(RtpReceiverObserverInterface* observer) { |
| 207 | observer_ = observer; |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 208 | // Deliver any notifications the observer may have missed by being set late. |
zhihuang | 184a3fd | 2016-06-14 11:47:14 -0700 | [diff] [blame] | 209 | if (received_first_packet_) { |
| 210 | observer_->OnFirstPacketReceived(media_type()); |
| 211 | } |
| 212 | } |
| 213 | |
Taylor Brandstetter | 2d54917 | 2016-06-24 14:18:22 -0700 | [diff] [blame] | 214 | void VideoRtpReceiver::SetChannel(cricket::VideoChannel* channel) { |
| 215 | if (channel_) { |
| 216 | channel_->SignalFirstPacketReceived.disconnect(this); |
| 217 | } |
| 218 | channel_ = channel; |
| 219 | if (channel_) { |
| 220 | channel_->SignalFirstPacketReceived.connect( |
| 221 | this, &VideoRtpReceiver::OnFirstPacketReceived); |
| 222 | } |
| 223 | } |
| 224 | |
| 225 | void VideoRtpReceiver::OnFirstPacketReceived(cricket::BaseChannel* channel) { |
zhihuang | 184a3fd | 2016-06-14 11:47:14 -0700 | [diff] [blame] | 226 | if (observer_) { |
| 227 | observer_->OnFirstPacketReceived(media_type()); |
| 228 | } |
| 229 | received_first_packet_ = true; |
| 230 | } |
| 231 | |
deadbeef | 70ab1a1 | 2015-09-28 16:53:55 -0700 | [diff] [blame] | 232 | } // namespace webrtc |