1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 2 // Use of this source code is governed by a BSD-style license that can be 3 // found in the LICENSE file. 4 5 #include "remoting/host/audio_capturer_linux.h" 6 7 #include "base/files/file_path.h" 8 #include "base/lazy_instance.h" 9 #include "base/logging.h" 10 #include "remoting/proto/audio.pb.h" 11 12 namespace remoting { 13 14 namespace { 15 16 base::LazyInstance<scoped_refptr<AudioPipeReader> >::Leaky 17 g_pulseaudio_pipe_sink_reader = LAZY_INSTANCE_INITIALIZER; 18 19 } // namespace 20 21 // TODO(wez): Remove this and have the DesktopEnvironmentFactory own the 22 // AudioPipeReader rather than having it process-global. 23 // See crbug.com/161373 and crbug.com/104544. InitializePipeReader(scoped_refptr<base::SingleThreadTaskRunner> task_runner,const base::FilePath & pipe_name)24void AudioCapturerLinux::InitializePipeReader( 25 scoped_refptr<base::SingleThreadTaskRunner> task_runner, 26 const base::FilePath& pipe_name) { 27 scoped_refptr<AudioPipeReader> pipe_reader; 28 if (!pipe_name.empty()) 29 pipe_reader = AudioPipeReader::Create(task_runner, pipe_name); 30 g_pulseaudio_pipe_sink_reader.Get() = pipe_reader; 31 } 32 AudioCapturerLinux(scoped_refptr<AudioPipeReader> pipe_reader)33AudioCapturerLinux::AudioCapturerLinux( 34 scoped_refptr<AudioPipeReader> pipe_reader) 35 : pipe_reader_(pipe_reader), 36 silence_detector_(0) { 37 } 38 ~AudioCapturerLinux()39AudioCapturerLinux::~AudioCapturerLinux() { 40 } 41 Start(const PacketCapturedCallback & callback)42bool AudioCapturerLinux::Start(const PacketCapturedCallback& callback) { 43 callback_ = callback; 44 silence_detector_.Reset(AudioPipeReader::kSamplingRate, 45 AudioPipeReader::kChannels); 46 pipe_reader_->AddObserver(this); 47 return true; 48 } 49 Stop()50void AudioCapturerLinux::Stop() { 51 pipe_reader_->RemoveObserver(this); 52 callback_.Reset(); 53 } 54 IsStarted()55bool AudioCapturerLinux::IsStarted() { 56 return !callback_.is_null(); 57 } 58 OnDataRead(scoped_refptr<base::RefCountedString> data)59void AudioCapturerLinux::OnDataRead( 60 scoped_refptr<base::RefCountedString> data) { 61 DCHECK(!callback_.is_null()); 62 63 if (silence_detector_.IsSilence( 64 reinterpret_cast<const int16*>(data->data().data()), 65 data->data().size() / sizeof(int16))) { 66 return; 67 } 68 69 scoped_ptr<AudioPacket> packet(new AudioPacket()); 70 packet->add_data(data->data()); 71 packet->set_encoding(AudioPacket::ENCODING_RAW); 72 packet->set_sampling_rate(AudioPipeReader::kSamplingRate); 73 packet->set_bytes_per_sample(AudioPipeReader::kBytesPerSample); 74 packet->set_channels(AudioPipeReader::kChannels); 75 callback_.Run(packet.Pass()); 76 } 77 IsSupported()78bool AudioCapturer::IsSupported() { 79 return g_pulseaudio_pipe_sink_reader.Get().get() != NULL; 80 } 81 Create()82scoped_ptr<AudioCapturer> AudioCapturer::Create() { 83 scoped_refptr<AudioPipeReader> reader = 84 g_pulseaudio_pipe_sink_reader.Get(); 85 if (!reader.get()) 86 return scoped_ptr<AudioCapturer>(); 87 return scoped_ptr<AudioCapturer>(new AudioCapturerLinux(reader)); 88 } 89 90 } // namespace remoting 91