1/*
2 * libjingle
3 * Copyright 2014 Google Inc.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are met:
7 *
8 *  1. Redistributions of source code must retain the above copyright notice,
9 *     this list of conditions and the following disclaimer.
10 *  2. Redistributions in binary form must reproduce the above copyright notice,
11 *     this list of conditions and the following disclaimer in the documentation
12 *     and/or other materials provided with the distribution.
13 *  3. The name of the author may not be used to endorse or promote products
14 *     derived from this software without specific prior written permission.
15 *
16 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED
17 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
18 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO
19 * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
20 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
21 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
22 * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
23 * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
24 * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
25 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26 */
27
28#include "talk/app/webrtc/remoteaudiosource.h"
29
30#include <algorithm>
31#include <functional>
32#include <utility>
33
34#include "talk/app/webrtc/mediastreamprovider.h"
35#include "webrtc/base/checks.h"
36#include "webrtc/base/logging.h"
37#include "webrtc/base/thread.h"
38
39namespace webrtc {
40
41class RemoteAudioSource::MessageHandler : public rtc::MessageHandler {
42 public:
43  explicit MessageHandler(RemoteAudioSource* source) : source_(source) {}
44
45 private:
46  ~MessageHandler() override {}
47
48  void OnMessage(rtc::Message* msg) override {
49    source_->OnMessage(msg);
50    delete this;
51  }
52
53  const rtc::scoped_refptr<RemoteAudioSource> source_;
54  RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(MessageHandler);
55};
56
57class RemoteAudioSource::Sink : public AudioSinkInterface {
58 public:
59  explicit Sink(RemoteAudioSource* source) : source_(source) {}
60  ~Sink() override { source_->OnAudioProviderGone(); }
61
62 private:
63  void OnData(const AudioSinkInterface::Data& audio) override {
64    if (source_)
65      source_->OnData(audio);
66  }
67
68  const rtc::scoped_refptr<RemoteAudioSource> source_;
69  RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(Sink);
70};
71
72rtc::scoped_refptr<RemoteAudioSource> RemoteAudioSource::Create(
73    uint32_t ssrc,
74    AudioProviderInterface* provider) {
75  rtc::scoped_refptr<RemoteAudioSource> ret(
76      new rtc::RefCountedObject<RemoteAudioSource>());
77  ret->Initialize(ssrc, provider);
78  return ret;
79}
80
81RemoteAudioSource::RemoteAudioSource()
82    : main_thread_(rtc::Thread::Current()),
83      state_(MediaSourceInterface::kLive) {
84  RTC_DCHECK(main_thread_);
85}
86
87RemoteAudioSource::~RemoteAudioSource() {
88  RTC_DCHECK(main_thread_->IsCurrent());
89  RTC_DCHECK(audio_observers_.empty());
90  RTC_DCHECK(sinks_.empty());
91}
92
93void RemoteAudioSource::Initialize(uint32_t ssrc,
94                                   AudioProviderInterface* provider) {
95  RTC_DCHECK(main_thread_->IsCurrent());
96  // To make sure we always get notified when the provider goes out of scope,
97  // we register for callbacks here and not on demand in AddSink.
98  if (provider) {  // May be null in tests.
99    provider->SetRawAudioSink(
100        ssrc, rtc::scoped_ptr<AudioSinkInterface>(new Sink(this)));
101  }
102}
103
104MediaSourceInterface::SourceState RemoteAudioSource::state() const {
105  RTC_DCHECK(main_thread_->IsCurrent());
106  return state_;
107}
108
109bool RemoteAudioSource::remote() const {
110  RTC_DCHECK(main_thread_->IsCurrent());
111  return true;
112}
113
114void RemoteAudioSource::SetVolume(double volume) {
115  RTC_DCHECK(volume >= 0 && volume <= 10);
116  for (auto* observer : audio_observers_)
117    observer->OnSetVolume(volume);
118}
119
120void RemoteAudioSource::RegisterAudioObserver(AudioObserver* observer) {
121  RTC_DCHECK(observer != NULL);
122  RTC_DCHECK(std::find(audio_observers_.begin(), audio_observers_.end(),
123                       observer) == audio_observers_.end());
124  audio_observers_.push_back(observer);
125}
126
127void RemoteAudioSource::UnregisterAudioObserver(AudioObserver* observer) {
128  RTC_DCHECK(observer != NULL);
129  audio_observers_.remove(observer);
130}
131
132void RemoteAudioSource::AddSink(AudioTrackSinkInterface* sink) {
133  RTC_DCHECK(main_thread_->IsCurrent());
134  RTC_DCHECK(sink);
135
136  if (state_ != MediaSourceInterface::kLive) {
137    LOG(LS_ERROR) << "Can't register sink as the source isn't live.";
138    return;
139  }
140
141  rtc::CritScope lock(&sink_lock_);
142  RTC_DCHECK(std::find(sinks_.begin(), sinks_.end(), sink) == sinks_.end());
143  sinks_.push_back(sink);
144}
145
146void RemoteAudioSource::RemoveSink(AudioTrackSinkInterface* sink) {
147  RTC_DCHECK(main_thread_->IsCurrent());
148  RTC_DCHECK(sink);
149
150  rtc::CritScope lock(&sink_lock_);
151  sinks_.remove(sink);
152}
153
154void RemoteAudioSource::OnData(const AudioSinkInterface::Data& audio) {
155  // Called on the externally-owned audio callback thread, via/from webrtc.
156  rtc::CritScope lock(&sink_lock_);
157  for (auto* sink : sinks_) {
158    sink->OnData(audio.data, 16, audio.sample_rate, audio.channels,
159                 audio.samples_per_channel);
160  }
161}
162
163void RemoteAudioSource::OnAudioProviderGone() {
164  // Called when the data provider is deleted.  It may be the worker thread
165  // in libjingle or may be a different worker thread.
166  main_thread_->Post(new MessageHandler(this));
167}
168
169void RemoteAudioSource::OnMessage(rtc::Message* msg) {
170  RTC_DCHECK(main_thread_->IsCurrent());
171  sinks_.clear();
172  state_ = MediaSourceInterface::kEnded;
173  FireOnChanged();
174}
175
176}  // namespace webrtc
177