Implement WebPermissionClient for Document and Worker contexts

content/child/permissions/permission_manager_thread_proxy.cc

+// Copyright 2015 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/child/permissions/permission_manager_thread_proxy.h"
+
+#include "base/bind.h"
+#include "base/bind_helpers.h"
+#include "base/lazy_instance.h"
+#include "base/location.h"
+#include "base/single_thread_task_runner.h"
+#include "base/threading/thread_local.h"
+#include "content/child/permissions/permission_manager.h"
+#include "content/child/worker_task_runner.h"
+#include "third_party/WebKit/public/platform/WebURL.h"
+
+using base::LazyInstance;
+using base::ThreadLocalPointer;
+
+namespace content {
+
+namespace {
+
+LazyInstance<ThreadLocalPointer<PermissionManagerThreadProxy>>::Leaky

[Bernhard Bauer, 2015/03/23 18:27:42]

Why do we need a separate instance of this class for each thread?

+    g_permission_manager_tls = LAZY_INSTANCE_INITIALIZER;
+
+}  // anonymous namespace
+
+PermissionManagerThreadProxy*
+PermissionManagerThreadProxy::GetThreadInstance(
+    base::SingleThreadTaskRunner* main_thread_task_runner,
+    PermissionManager* permissions_manager) {
+  if (g_permission_manager_tls.Pointer()->Get())
+    return g_permission_manager_tls.Pointer()->Get();
+
+  PermissionManagerThreadProxy* instance =
+      new PermissionManagerThreadProxy(main_thread_task_runner,
+                                        permissions_manager);
+  DCHECK(WorkerTaskRunner::Instance()->CurrentWorkerId());
+  WorkerTaskRunner::Instance()->AddStopObserver(instance);
+  return instance;
+}
+
+PermissionManagerThreadProxy::PermissionManagerThreadProxy(
+    base::SingleThreadTaskRunner* main_thread_task_runner,
+    PermissionManager* permissions_manager)
+  : main_thread_task_runner_(main_thread_task_runner),
+    permissions_manager_(permissions_manager) {
+  g_permission_manager_tls.Pointer()->Set(this);
+}
+
+PermissionManagerThreadProxy::~PermissionManagerThreadProxy() {
+  g_permission_manager_tls.Pointer()->Set(nullptr);
+}
+
+void PermissionManagerThreadProxy::queryPermission(
+    blink::WebPermissionType type,
+    const blink::WebURL& origin,
+    blink::WebPermissionQueryCallback* callback) {
+  main_thread_task_runner_->PostTask(
+      FROM_HERE,
+      base::Bind(&PermissionManager::QueryPermissionForWorker,
+                 base::Unretained(permissions_manager_),
+                 type,
+                 origin.string().utf8(),
+                 base::Unretained(callback),
+                 WorkerTaskRunner::Instance()->CurrentWorkerId()));
+}
+
+void PermissionManagerThreadProxy::OnWorkerRunLoopStopped() {
+  delete this;
+}
+
+}  // namespace content