OLD | NEW |
1 // Copyright 2017 The Chromium Authors. All rights reserved. | 1 // Copyright 2017 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "media/audio/audio_debug_recording_helper.h" | 5 #include "media/audio/audio_debug_recording_helper.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/files/file_path.h" | 8 #include "base/files/file_path.h" |
9 #include "base/memory/ptr_util.h" | 9 #include "base/memory/ptr_util.h" |
10 #include "base/single_thread_task_runner.h" | 10 #include "base/single_thread_task_runner.h" |
11 #include "media/audio/audio_debug_file_writer.h" | 11 #include "media/audio/audio_debug_file_writer.h" |
12 | 12 |
13 namespace media { | 13 namespace media { |
14 | 14 |
15 AudioDebugRecordingHelper::AudioDebugRecordingHelper( | 15 AudioDebugRecordingHelper::AudioDebugRecordingHelper( |
16 const AudioParameters& params, | 16 const AudioParameters& params, |
17 scoped_refptr<base::SingleThreadTaskRunner> task_runner, | 17 scoped_refptr<base::SingleThreadTaskRunner> task_runner, |
18 scoped_refptr<base::SingleThreadTaskRunner> file_task_runner, | |
19 base::OnceClosure on_destruction_closure) | 18 base::OnceClosure on_destruction_closure) |
20 : params_(params), | 19 : params_(params), |
21 recording_enabled_(0), | 20 recording_enabled_(0), |
22 task_runner_(std::move(task_runner)), | 21 task_runner_(std::move(task_runner)), |
23 file_task_runner_(std::move(file_task_runner)), | |
24 on_destruction_closure_(std::move(on_destruction_closure)), | 22 on_destruction_closure_(std::move(on_destruction_closure)), |
25 weak_factory_(this) {} | 23 weak_factory_(this) {} |
26 | 24 |
27 AudioDebugRecordingHelper::~AudioDebugRecordingHelper() { | 25 AudioDebugRecordingHelper::~AudioDebugRecordingHelper() { |
28 if (on_destruction_closure_) | 26 if (on_destruction_closure_) |
29 std::move(on_destruction_closure_).Run(); | 27 std::move(on_destruction_closure_).Run(); |
30 } | 28 } |
31 | 29 |
32 void AudioDebugRecordingHelper::EnableDebugRecording( | 30 void AudioDebugRecordingHelper::EnableDebugRecording( |
33 const base::FilePath& file_name) { | 31 const base::FilePath& file_name) { |
34 DCHECK(task_runner_->BelongsToCurrentThread()); | 32 DCHECK(task_runner_->BelongsToCurrentThread()); |
35 DCHECK(!debug_writer_); | 33 DCHECK(!debug_writer_); |
36 DCHECK(!file_name.empty()); | 34 DCHECK(!file_name.empty()); |
37 | 35 |
38 debug_writer_ = CreateAudioDebugFileWriter(params_, file_task_runner_); | 36 debug_writer_ = CreateAudioDebugFileWriter(params_); |
39 debug_writer_->Start( | 37 debug_writer_->Start( |
40 file_name.AddExtension(debug_writer_->GetFileNameExtension())); | 38 file_name.AddExtension(debug_writer_->GetFileNameExtension())); |
41 | 39 |
42 base::subtle::NoBarrier_Store(&recording_enabled_, 1); | 40 base::subtle::NoBarrier_Store(&recording_enabled_, 1); |
43 } | 41 } |
44 | 42 |
45 void AudioDebugRecordingHelper::DisableDebugRecording() { | 43 void AudioDebugRecordingHelper::DisableDebugRecording() { |
46 DCHECK(task_runner_->BelongsToCurrentThread()); | 44 DCHECK(task_runner_->BelongsToCurrentThread()); |
47 | 45 |
48 base::subtle::NoBarrier_Store(&recording_enabled_, 0); | 46 base::subtle::NoBarrier_Store(&recording_enabled_, 0); |
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
86 | 84 |
87 void AudioDebugRecordingHelper::DoWrite(std::unique_ptr<media::AudioBus> data) { | 85 void AudioDebugRecordingHelper::DoWrite(std::unique_ptr<media::AudioBus> data) { |
88 DCHECK(task_runner_->BelongsToCurrentThread()); | 86 DCHECK(task_runner_->BelongsToCurrentThread()); |
89 | 87 |
90 if (debug_writer_) | 88 if (debug_writer_) |
91 debug_writer_->Write(std::move(data)); | 89 debug_writer_->Write(std::move(data)); |
92 } | 90 } |
93 | 91 |
94 std::unique_ptr<AudioDebugFileWriter> | 92 std::unique_ptr<AudioDebugFileWriter> |
95 AudioDebugRecordingHelper::CreateAudioDebugFileWriter( | 93 AudioDebugRecordingHelper::CreateAudioDebugFileWriter( |
96 const AudioParameters& params, | 94 const AudioParameters& params) { |
97 scoped_refptr<base::SingleThreadTaskRunner> file_task_runner) { | 95 return base::MakeUnique<AudioDebugFileWriter>(params); |
98 return base::MakeUnique<AudioDebugFileWriter>(params, file_task_runner); | |
99 } | 96 } |
100 | 97 |
101 } // namespace media | 98 } // namespace media |
OLD | NEW |