Chromium Code Reviews| Index: talk/app/webrtc/rtpreceiver.cc |
| diff --git a/talk/app/webrtc/rtpreceiver.cc b/talk/app/webrtc/rtpreceiver.cc |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..1d124d5dbbf4d68ed15863f643bd877fe7086004 |
| --- /dev/null |
| +++ b/talk/app/webrtc/rtpreceiver.cc |
| @@ -0,0 +1,116 @@ |
| +/* |
| + * libjingle |
| + * Copyright 2015 Google Inc. |
| + * |
| + * Redistribution and use in source and binary forms, with or without |
| + * modification, are permitted provided that the following conditions are met: |
| + * |
| + * 1. Redistributions of source code must retain the above copyright notice, |
| + * this list of conditions and the following disclaimer. |
| + * 2. Redistributions in binary form must reproduce the above copyright notice, |
| + * this list of conditions and the following disclaimer in the documentation |
| + * and/or other materials provided with the distribution. |
| + * 3. The name of the author may not be used to endorse or promote products |
| + * derived from this software without specific prior written permission. |
| + * |
| + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED |
| + * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF |
| + * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO |
| + * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
| + * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, |
| + * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; |
| + * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, |
| + * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR |
| + * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF |
| + * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| + */ |
| + |
| +#include "talk/app/webrtc/rtpreceiver.h" |
| + |
| +#include "talk/app/webrtc/videosourceinterface.h" |
| + |
| +namespace webrtc { |
| + |
| +AudioRtpReceiver::AudioRtpReceiver(AudioTrackInterface* track, |
| + uint32 ssrc, |
| + const std::string& mid, |
| + AudioProviderInterface* provider) |
| + : track_(track), |
| + ssrc_(ssrc), |
| + mid_(mid), |
| + provider_(provider), |
| + enabled_(track->enabled()) { |
| + track_->RegisterObserver(this); |
| + track_->GetSource()->RegisterAudioObserver(this); |
| + UpdateEnabled(); |
| +} |
| + |
| +AudioRtpReceiver::~AudioRtpReceiver() { |
| + track_->GetSource()->UnregisterAudioObserver(this); |
| + track_->UnregisterObserver(this); |
| + if (provider_) { |
| + Stop(); |
| + } |
| +} |
| + |
| +void AudioRtpReceiver::OnChanged() { |
| + if (enabled_ != track_->enabled()) { |
| + enabled_ = track_->enabled(); |
| + UpdateEnabled(); |
| + } |
| +} |
| + |
| +void AudioRtpReceiver::OnSetVolume(double volume) { |
| + // When the track is disabled, the volume of the source, which is the |
| + // corresponding WebRtc Voice Engine channel will be 0. So we do not allow |
| + // setting the volume to the source when the track is disabled. |
| + if (track_->enabled()) |
| + provider_->SetAudioPlayoutVolume(ssrc_, volume); |
| +} |
| + |
| +void AudioRtpReceiver::Stop() { |
| + provider_->SetAudioPlayout(ssrc_, false, NULL); |
| + provider_ = nullptr; |
| +} |
| + |
| +void AudioRtpReceiver::UpdateEnabled() { |
| + if (!provider_) { |
| + return; |
| + } |
| + provider_->SetAudioPlayout(ssrc_, track_->enabled(), track_->GetRenderer()); |
| +} |
| + |
| +VideoRtpReceiver::VideoRtpReceiver(VideoTrackInterface* track, |
| + uint32 ssrc, |
| + const std::string& mid, |
| + VideoProviderInterface* provider) |
| + : track_(track), ssrc_(ssrc), mid_(mid), provider_(provider) { |
| + provider_->SetVideoPlayout(ssrc_, true, track_->GetSource()->FrameInput()); |
|
pthatcher1
2015/09/17 04:25:46
Can you put a TODO for unifying SetVideoPlayout an
Taylor Brandstetter
2015/09/23 00:10:45
Calling SetVideoSend here was a copy/paste mistake
|
| +} |
| + |
| +VideoRtpReceiver::~VideoRtpReceiver() { |
| + if (provider_) { |
| + Stop(); |
| + } |
| +} |
| + |
| +void VideoRtpReceiver::Stop() { |
| + // Since cricket::VideoRenderer is not reference counted |
| + // we need to remove the renderer before we are deleted. |
| + provider_->SetVideoPlayout(ssrc_, false, nullptr); |
| + provider_ = nullptr; |
| +} |
| + |
| +void VideoRtpReceiver::UpdateEnabled() { |
| + if (!provider_) { |
| + return; |
| + } |
| + const cricket::VideoOptions* options = nullptr; |
| + VideoSourceInterface* source = track_->GetSource(); |
| + if (track_->enabled() && source) { |
|
pthatcher1
2015/09/17 04:25:46
Wait... why do we track the previous track_->enabl
Taylor Brandstetter
2015/09/23 00:10:45
See above comment.
|
| + options = source->options(); |
| + } |
| + provider_->SetVideoSend(ssrc_, track_->enabled(), options); |
| +} |
| + |
| +} // namespace webrtc |