Don't start speech synthesis until after the audio mixer is initialized.

chrome/browser/extensions/extension_tts_api_chromeos.cc

 // Copyright (c) 2011 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
+#include <queue>
+
 #include "base/bind.h"
 #include "base/memory/singleton.h"
 #include "base/memory/weak_ptr.h"
 #include "base/message_loop.h"
 #include "base/string_number_conversions.h"
 #include "chrome/browser/chromeos/dbus/dbus_thread_manager.h"
 #include "chrome/browser/chromeos/dbus/speech_synthesizer_client.h"
+#include "chrome/browser/extensions/extension_tts_api_chromeos.h"

[oshima, 2011/11/09 23:47:32]

move this to top.

[dmazzoni, 2011/11/10 07:19:57]

Done.

 #include "chrome/browser/extensions/extension_tts_api_controller.h"
 #include "chrome/browser/extensions/extension_tts_api_platform.h"
 
 using base::DoubleToString;
 
 namespace {
 const int kSpeechCheckDelayIntervalMs = 100;
 };
 
-class ExtensionTtsPlatformImplChromeOs : public ExtensionTtsPlatformImpl {
+// Very simple queue of utterances that can't be spoken because audio
+// isn't initialized yet.
+struct QueuedUtterance {
+  int utterance_id;
+  std::string utterance;
+  std::string lang;
+  UtteranceContinuousParameters params;
+};
+
+class ExtensionTtsPlatformImplChromeOs
+    : public ExtensionTtsPlatformImpl {
  public:
   virtual bool PlatformImplAvailable() {
     return true;
   }
 
   virtual bool Speak(
       int utterance_id,
       const std::string& utterance,
       const std::string& lang,
       const UtteranceContinuousParameters& params);
 
   virtual bool StopSpeaking();
 
   virtual bool SendsEvent(TtsEventType event_type);
 
   // Get the single instance of this class.
   static ExtensionTtsPlatformImplChromeOs* GetInstance();
 
+  // TTS won't begin until this is called.
+  void Enable();
+
  private:
-  ExtensionTtsPlatformImplChromeOs()
-      : ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_(this)) {}
+  ExtensionTtsPlatformImplChromeOs();
   virtual ~ExtensionTtsPlatformImplChromeOs() {}
 
   void PollUntilSpeechFinishes(int utterance_id);
   void ContinuePollingIfSpeechIsNotFinished(int utterance_id, bool result);
 
   void AppendSpeakOption(std::string key,
                          std::string value,
                          std::string* options);
 
   int utterance_id_;
   int utterance_length_;
+  std::queue<QueuedUtterance*> queued_utterances_;
+  bool enabled_;
   base::WeakPtrFactory<ExtensionTtsPlatformImplChromeOs> weak_ptr_factory_;
 
   friend struct DefaultSingletonTraits<ExtensionTtsPlatformImplChromeOs>;
 
   DISALLOW_COPY_AND_ASSIGN(ExtensionTtsPlatformImplChromeOs);
 };
 
 // static
 ExtensionTtsPlatformImpl* ExtensionTtsPlatformImpl::GetInstance() {
   return ExtensionTtsPlatformImplChromeOs::GetInstance();
 }
 
+ExtensionTtsPlatformImplChromeOs::ExtensionTtsPlatformImplChromeOs()
+    : enabled_(false),
+      ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_(this)) {
+}
+
 bool ExtensionTtsPlatformImplChromeOs::Speak(
     int utterance_id,
     const std::string& utterance,
     const std::string& lang,
     const UtteranceContinuousParameters& params) {
+  if (!enabled_) {
+    QueuedUtterance *queued = new QueuedUtterance();
+    queued->utterance_id = utterance_id;
+    queued->utterance = utterance;
+    queued->lang = lang;
+    queued->params = params;
+    queued_utterances_.push(queued);
+    return true;
+  }
+
   utterance_id_ = utterance_id;
   utterance_length_ = utterance.size();
 
   std::string options;
 
   if (!lang.empty()) {
     AppendSpeakOption(
         chromeos::SpeechSynthesizerClient::kSpeechPropertyLocale,
         lang,
         &options);
@@ skipping 23 matching lines @@
         &options);
   }
 
   chromeos::SpeechSynthesizerClient* speech_synthesizer_client =
       chromeos::DBusThreadManager::Get()->GetSpeechSynthesizerClient();
 
   if (!options.empty())
     speech_synthesizer_client->SetSpeakProperties(options);
 
   speech_synthesizer_client->Speak(utterance);
-  ExtensionTtsController* controller = ExtensionTtsController::GetInstance();
-  controller->OnTtsEvent(utterance_id_, TTS_EVENT_START, 0, std::string());
-  PollUntilSpeechFinishes(utterance_id_);
+  if (utterance_id_ >= 0) {
+    ExtensionTtsController* controller = ExtensionTtsController::GetInstance();
+    controller->OnTtsEvent(utterance_id_, TTS_EVENT_START, 0, std::string());
+    PollUntilSpeechFinishes(utterance_id_);
+  }
 
   return true;
 }
 
 bool ExtensionTtsPlatformImplChromeOs::StopSpeaking() {
+  // If we haven't been enabled yet, clear the internal queue.
+  if (!enabled_) {
+    while (!queued_utterances_.empty()) {

[oshima, 2011/11/09 23:47:32]

STLDeleteContainerPointers?

[dmazzoni, 2011/11/10 07:19:57]

Good idea, I used STLDeleteElements.

+      delete queued_utterances_.front();
+      queued_utterances_.pop();
+    }
+    return true;
+  }
+
   chromeos::DBusThreadManager::Get()->GetSpeechSynthesizerClient()->
       StopSpeaking();
   return true;
 }
 
 bool ExtensionTtsPlatformImplChromeOs::SendsEvent(TtsEventType event_type) {
   return (event_type == TTS_EVENT_START ||
           event_type == TTS_EVENT_END ||
           event_type == TTS_EVENT_ERROR);
 }
 
+void ExtensionTtsPlatformImplChromeOs::Enable() {
+  enabled_ = true;
+  while (!queued_utterances_.empty()) {
+    QueuedUtterance* queued = queued_utterances_.front();
+    Speak(queued->utterance_id,
+          queued->utterance,
+          queued->lang,
+          queued->params);
+    delete queued;
+    queued_utterances_.pop();
+  }
+}
+
 void ExtensionTtsPlatformImplChromeOs::PollUntilSpeechFinishes(
     int utterance_id) {
   if (utterance_id != utterance_id_) {
     // This utterance must have been interrupted or cancelled.
     return;
   }
   chromeos::SpeechSynthesizerClient* speech_synthesizer_client =
       chromeos::DBusThreadManager::Get()->GetSpeechSynthesizerClient();
   speech_synthesizer_client->IsSpeaking(base::Bind(
       &ExtensionTtsPlatformImplChromeOs::ContinuePollingIfSpeechIsNotFinished,
@@ skipping 30 matching lines @@
       chromeos::SpeechSynthesizerClient::kSpeechPropertyEquals +
       value +
       chromeos::SpeechSynthesizerClient::kSpeechPropertyDelimiter;
 }
 
 // static
 ExtensionTtsPlatformImplChromeOs*
 ExtensionTtsPlatformImplChromeOs::GetInstance() {
   return Singleton<ExtensionTtsPlatformImplChromeOs>::get();
 }
+
+// global
+void EnableChromeOsTts() {
+  ExtensionTtsPlatformImplChromeOs::GetInstance()->Enable();
+}