Plumb audio focus support for spitzer clients.

content/browser/media/android/media_web_contents_observer_android.cc

 // Copyright 2016 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 "content/browser/media/android/media_web_contents_observer_android.h"
 
+#include "base/callback.h"
 #include "content/browser/media/android/browser_media_player_manager.h"
 #include "content/browser/media/android/browser_media_session_manager.h"
 #include "content/browser/media/android/media_session.h"
 #include "content/browser/media/android/media_session_controller.h"
 #include "content/browser/media/android/media_session_observer.h"
 #include "content/browser/media/cdm/browser_cdm_manager.h"
 #include "content/browser/web_contents/web_contents_impl.h"
 #include "content/common/media/media_player_delegate_messages.h"
 #include "content/common/media/media_player_messages_android.h"
 #include "content/common/media/media_session_messages_android.h"
@@ skipping 63 matching lines @@
        it != media_player_managers_.end(); ++it) {
     it->second->OnFrameInfoUpdated();
   }
 }
 #endif  // defined(VIDEO_HOLE)
 
 void MediaWebContentsObserverAndroid::RenderFrameDeleted(
     RenderFrameHost* render_frame_host) {
   MediaWebContentsObserver::RenderFrameDeleted(render_frame_host);
 
+  const int routing_id = render_frame_host->GetRoutingID();
+  for (auto it = focus_waiters_.begin(); it != focus_waiters_.end();) {
+    if (it->first == routing_id)
+      it = focus_waiters_.erase(it);
+    else
+      ++it;
+  }
+
   for (auto it = media_session_map_.begin(); it != media_session_map_.end();) {
     if (it->first.first == render_frame_host)
       it = media_session_map_.erase(it);
     else
       ++it;
   }
 
   // Always destroy the media players before CDMs because we do not support
   // detaching CDMs from media players yet. See http://crbug.com/330324
   media_player_managers_.erase(render_frame_host);
@@ skipping 25 matching lines @@
 
   if (OnMediaPlayerSetCdmMessageReceived(msg, render_frame_host))
     return true;
 
   if (OnMediaSessionMessageReceived(msg, render_frame_host))
     return true;
 
   return false;
 }
 
+void MediaWebContentsObserverAndroid::WaitForAudioFocusAsyncInternal(
+    int render_frame_id,
+    const base::Closure& focus_cb) {
+  // See if audio focus has already been approved for the given render frame; we
+  // don't care which delegate it corresponds to, just that one has approval and
+  // is actively playing audio.
+  for (const auto& kv : media_session_map_) {
+    if (kv.first.first->GetRoutingID() == render_frame_id &&
+        kv.second->is_playing()) {

[mlamouri (slow - plz ping), 2016/02/03 15:20:51]

Couldn't a controller be playing even though it doesn't have the right kind of
audio focus?

+      focus_cb.Run();
+      return;
+    }
+  }
+
+  focus_waiters_.push_back(FocusWaiter(render_frame_id, focus_cb));
+}
+
 void MediaWebContentsObserverAndroid::OnMediaPlayerDelegateMessageReceived(
     const IPC::Message& msg,
     RenderFrameHost* render_frame_host) {
   IPC_BEGIN_MESSAGE_MAP_WITH_PARAM(MediaWebContentsObserverAndroid, msg,
                                    render_frame_host)
     IPC_MESSAGE_HANDLER(MediaPlayerDelegateHostMsg_OnMediaDestroyed,
                         OnMediaDestroyed)
     IPC_MESSAGE_HANDLER(MediaPlayerDelegateHostMsg_OnMediaPaused, OnMediaPaused)
     IPC_MESSAGE_HANDLER(MediaPlayerDelegateHostMsg_OnMediaPlaying,
                         OnMediaPlaying)
@@ skipping 145 matching lines @@
     bool is_remote,
     base::TimeDelta duration) {
   const MediaPlayerId id(render_frame_host, delegate_id);
 
   // Since we don't remove session instances on pause, there may be an existing
   // instance for this playback attempt.
   //
   // In this case, try to reinitialize it with the new settings.  If they are
   // the same, this is a no-op.  If the reinitialize fails, destroy the
   // controller. A later playback attempt will create a new controller.
-  auto it = media_session_map_.find(id);
-  if (it != media_session_map_.end()) {
-    if (!it->second->Initialize(has_audio, is_remote, duration))
-      media_session_map_.erase(it);
-    return;
+  auto session_it = media_session_map_.find(id);
+  if (session_it != media_session_map_.end()) {
+    if (!session_it->second->Initialize(has_audio, is_remote, duration)) {
+      media_session_map_.erase(session_it);
+      return;
+    }
+  } else {
+    scoped_ptr<MediaSessionController> controller(
+        new MediaSessionController(id, this));
+
+    if (!controller->Initialize(has_audio, is_remote, duration))
+      return;
+
+    media_session_map_[id] = std::move(controller);
   }
 
-  scoped_ptr<MediaSessionController> controller(
-      new MediaSessionController(id, this));
-
-  if (!controller->Initialize(has_audio, is_remote, duration))
-    return;
-
-  media_session_map_[id] = std::move(controller);
+  // Notify all focus waiters for the render frame that audio output is allowed,
+  // delegates will still pause audio as necessary in response to focus changes
+  // from the media session.
+  const int routing_id = render_frame_host->GetRoutingID();
+  for (auto it = focus_waiters_.begin(); it != focus_waiters_.end();) {
+    if (it->first == routing_id) {
+      it->second.Run();
+      it = focus_waiters_.erase(it);
+    } else {
+      ++it;
+    }
+  }
 }
 
 }  // namespace content