tts_message_filter.cc revision cedac228d2dd51db4b79ea1e72c7f249408ee061
1// Copyright (c) 2013 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 "chrome/browser/speech/tts_message_filter.h" 6 7#include "base/bind.h" 8#include "base/logging.h" 9#include "chrome/browser/profiles/profile.h" 10#include "chrome/browser/speech/tts_controller.h" 11#include "chrome/browser/speech/tts_message_filter.h" 12#include "content/public/browser/browser_context.h" 13#include "content/public/browser/render_process_host.h" 14 15using content::BrowserThread; 16 17TtsMessageFilter::TtsMessageFilter(int render_process_id, Profile* profile) 18 : BrowserMessageFilter(TtsMsgStart), 19 render_process_id_(render_process_id), 20 profile_(profile) { 21 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 22 TtsController::GetInstance()->AddVoicesChangedDelegate(this); 23} 24 25void TtsMessageFilter::OverrideThreadForMessage( 26 const IPC::Message& message, BrowserThread::ID* thread) { 27 switch (message.type()) { 28 case TtsHostMsg_InitializeVoiceList::ID: 29 case TtsHostMsg_Speak::ID: 30 case TtsHostMsg_Pause::ID: 31 case TtsHostMsg_Resume::ID: 32 case TtsHostMsg_Cancel::ID: 33 *thread = BrowserThread::UI; 34 break; 35 } 36} 37 38bool TtsMessageFilter::OnMessageReceived(const IPC::Message& message) { 39 bool handled = true; 40 IPC_BEGIN_MESSAGE_MAP(TtsMessageFilter, message) 41 IPC_MESSAGE_HANDLER(TtsHostMsg_InitializeVoiceList, OnInitializeVoiceList) 42 IPC_MESSAGE_HANDLER(TtsHostMsg_Speak, OnSpeak) 43 IPC_MESSAGE_HANDLER(TtsHostMsg_Pause, OnPause) 44 IPC_MESSAGE_HANDLER(TtsHostMsg_Resume, OnResume) 45 IPC_MESSAGE_HANDLER(TtsHostMsg_Cancel, OnCancel) 46 IPC_MESSAGE_UNHANDLED(handled = false) 47 IPC_END_MESSAGE_MAP() 48 return handled; 49} 50 51void TtsMessageFilter::OnChannelClosing() { 52 BrowserThread::PostTask( 53 BrowserThread::UI, FROM_HERE, 54 base::Bind(&TtsMessageFilter::OnChannelClosingInUIThread, this)); 55} 56 57void TtsMessageFilter::OnInitializeVoiceList() { 58 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 59 TtsController* tts_controller = TtsController::GetInstance(); 60 std::vector<VoiceData> voices; 61 tts_controller->GetVoices(profile_, &voices); 62 63 std::vector<TtsVoice> out_voices; 64 out_voices.resize(voices.size()); 65 for (size_t i = 0; i < voices.size(); ++i) { 66 TtsVoice& out_voice = out_voices[i]; 67 out_voice.voice_uri = voices[i].name; 68 out_voice.name = voices[i].name; 69 out_voice.lang = voices[i].lang; 70 out_voice.local_service = !voices[i].remote; 71 out_voice.is_default = (i == 0); 72 } 73 Send(new TtsMsg_SetVoiceList(out_voices)); 74} 75 76void TtsMessageFilter::OnSpeak(const TtsUtteranceRequest& request) { 77 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 78 scoped_ptr<Utterance> utterance(new Utterance(profile_)); 79 utterance->set_src_id(request.id); 80 utterance->set_text(request.text); 81 utterance->set_lang(request.lang); 82 utterance->set_voice_name(request.voice); 83 utterance->set_can_enqueue(true); 84 85 UtteranceContinuousParameters params; 86 params.rate = request.rate; 87 params.pitch = request.pitch; 88 params.volume = request.volume; 89 utterance->set_continuous_parameters(params); 90 91 utterance->set_event_delegate(this->AsWeakPtr()); 92 93 TtsController::GetInstance()->SpeakOrEnqueue(utterance.release()); 94} 95 96void TtsMessageFilter::OnPause() { 97 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 98 TtsController::GetInstance()->Pause(); 99} 100 101void TtsMessageFilter::OnResume() { 102 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 103 TtsController::GetInstance()->Resume(); 104} 105 106void TtsMessageFilter::OnCancel() { 107 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 108 TtsController::GetInstance()->Stop(); 109} 110 111void TtsMessageFilter::OnTtsEvent(Utterance* utterance, 112 TtsEventType event_type, 113 int char_index, 114 const std::string& error_message) { 115 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 116 switch (event_type) { 117 case TTS_EVENT_START: 118 Send(new TtsMsg_DidStartSpeaking(utterance->src_id())); 119 break; 120 case TTS_EVENT_END: 121 Send(new TtsMsg_DidFinishSpeaking(utterance->src_id())); 122 break; 123 case TTS_EVENT_WORD: 124 Send(new TtsMsg_WordBoundary(utterance->src_id(), char_index)); 125 break; 126 case TTS_EVENT_SENTENCE: 127 Send(new TtsMsg_SentenceBoundary(utterance->src_id(), char_index)); 128 break; 129 case TTS_EVENT_MARKER: 130 Send(new TtsMsg_MarkerEvent(utterance->src_id(), char_index)); 131 break; 132 case TTS_EVENT_INTERRUPTED: 133 Send(new TtsMsg_WasInterrupted(utterance->src_id())); 134 break; 135 case TTS_EVENT_CANCELLED: 136 Send(new TtsMsg_WasCancelled(utterance->src_id())); 137 break; 138 case TTS_EVENT_ERROR: 139 Send(new TtsMsg_SpeakingErrorOccurred( 140 utterance->src_id(), error_message)); 141 break; 142 case TTS_EVENT_PAUSE: 143 Send(new TtsMsg_DidPauseSpeaking(utterance->src_id())); 144 break; 145 case TTS_EVENT_RESUME: 146 Send(new TtsMsg_DidResumeSpeaking(utterance->src_id())); 147 break; 148 } 149} 150 151void TtsMessageFilter::OnVoicesChanged() { 152 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 153 OnInitializeVoiceList(); 154} 155 156void TtsMessageFilter::OnChannelClosingInUIThread() { 157 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 158 TtsController::GetInstance()->RemoveVoicesChangedDelegate(this); 159} 160 161TtsMessageFilter::~TtsMessageFilter() { 162} 163