Index: webrtc/media/engine/webrtcvoiceengine.cc |
diff --git a/webrtc/media/engine/webrtcvoiceengine.cc b/webrtc/media/engine/webrtcvoiceengine.cc |
index aa2f6640c078fc2eb7b209783fa06cfd4ac0ddf4..0db5fefd3935bc910d447479e57ab928a9f91f0b 100644 |
--- a/webrtc/media/engine/webrtcvoiceengine.cc |
+++ b/webrtc/media/engine/webrtcvoiceengine.cc |
@@ -574,7 +574,10 @@ WebRtcVoiceEngine::WebRtcVoiceEngine( |
const rtc::scoped_refptr<webrtc::AudioDecoderFactory>& decoder_factory, |
rtc::scoped_refptr<webrtc::AudioMixer> audio_mixer, |
VoEWrapper* voe_wrapper) |
- : adm_(adm), decoder_factory_(decoder_factory), voe_wrapper_(voe_wrapper) { |
+ : worker_queue_("file_writer_task_queue_"), |
+ adm_(adm), |
+ decoder_factory_(decoder_factory), |
+ voe_wrapper_(voe_wrapper) { |
RTC_DCHECK(worker_thread_checker_.CalledOnValidThread()); |
LOG(LS_INFO) << "WebRtcVoiceEngine::WebRtcVoiceEngine"; |
RTC_DCHECK(voe_wrapper); |
@@ -1008,7 +1011,8 @@ bool WebRtcVoiceEngine::StartAecDump(rtc::PlatformFile file, |
return false; |
} |
StopAecDump(); |
- if (apm()->StartDebugRecording(aec_dump_file_stream, max_size_bytes) != |
+ if (apm()->StartDebugRecording(aec_dump_file_stream, max_size_bytes, |
+ &worker_queue_) != |
webrtc::AudioProcessing::kNoError) { |
LOG_RTCERR0(StartDebugRecording); |
fclose(aec_dump_file_stream); |
@@ -1022,7 +1026,7 @@ void WebRtcVoiceEngine::StartAecDump(const std::string& filename) { |
RTC_DCHECK(worker_thread_checker_.CalledOnValidThread()); |
if (!is_dumping_aec_) { |
// Start dumping AEC when we are not dumping. |
- if (apm()->StartDebugRecording(filename.c_str(), -1) != |
+ if (apm()->StartDebugRecording(filename.c_str(), -1, &worker_queue_) != |
webrtc::AudioProcessing::kNoError) { |
LOG_RTCERR1(StartDebugRecording, filename.c_str()); |
} else { |