Add a private PPB_Talk_Private interface.

chrome/renderer/chrome_ppb_talk_private_impl.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 "chrome/renderer/chrome_ppb_talk_private_impl.h"
+
+#include "content/public/render_view.h"
+#include "content/public/render_view_observer.h"
+#include "ppapi/c/private/ppb_talk_private.h"
+#include "ppapi/proxy/ppapi_param_traits.h"
+
+using ppapi::thunk::PPB_Talk_Private_API;
+
+namespace chrome {
+
+namespace {
+
+PP_Resource Create(PP_Instance instance) {
+  return (new PPB_Talk_Private_Impl(instance))->GetReference();
+}
+
+int32_t GetPermission(PP_Resource talk_resource,
+                      PP_CompletionCallback callback) {
+  ppapi::EnterResource<PPB_Talk_API> enter(resource, callback, true);
+  if (enter.failed())
+    return enter.retval();
+  return enter.SetResult(enter.object()->GetPermission(callback));
+}
+
+const PPB_Talk_Private_1_0 talk_interface = {
+  &Create,
+  &GetPermission
+};
+
+}  // namespace
+
+// This observer adds itself to the render view to listen for reply messages.
+class PPB_Talk_Private_Impl::Observer : public content::RenderViewObserver {
+ public:
+  Observer(PPB_Talk_Private_Impl* talk)
+      : RenderViewObserver(talk->GetRenderView()),
+        talk_(talk) {
+  }
+
+  // RenderViewObserver message filter. We return true only when the message
+  // is the reply message for this particular resource (since there could be
+  // multiple replies pending for different resources).
+  virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE {
+    // TODO add this message type in the same place
+    // ChromeViewHostMsg_PDFHasUnsupportedFeature is declared. First param
+    // should be host resource, second int32.
+    if (message->type() == ChromeViewHostMsg_GetTalkPermissionACK) {
+      // Manually extract the first parameter from the message to see if it's
+      // our resource.
+      void** iter = NULL;
+      ppapi::HostResource resource;
+      int32 result;
+      if (IPC::ParamTraits<HostResource>::Read(&message, iter, &resource) &&
+          IPC::ParamTraits<int32>::Read(&message, iter, &result) &&
+          resource == talk_->host_resource()) {
+        talk_->ReplyReceived(result);
+        return true;
+      }
+    }
+    return false;
+  }
+
+ private:
+  PPB_Talk_Private_Impl* talk_;
+
+  DISALLOW_COPY_AND_ASSIGN(Observer);
+};
+
+PPB_Talk_Private_Impl::PPB_Talk_Private_Impl(PP_Instance instance)
+    : Resource(ppapi::OBJECT_IS_IMPL) {
+  observer_.reset(new Observer(this));
+}
+
+PPB_Talk_Private_Impl::~PPB_Talk_Private_Impl() {
+}
+
+// static
+const PPB_Talk_Private_1_0* PPB_Talk_Private_Impl::GetInterface() {
+  return &talk_interface;
+}
+
+PPB_Talk_Private_API* PPB_Talk_Private_Impl::AsPPB_Talk_Private_API() {
+  return this;
+}
+
+int32_t PPB_Talk_Private_Impl::GetPermission(
+    const PP_CompletionCallback& callback) {
+  RenderView* render_view = GetRenderView();
+  if (!render_view)
+    return PP_ERROR_FAILED;
+
+  callback_ = new TrackedCallback(this, callback);
+
+  render_view->Send(new ChromeViewHostMsg_GetTalkPermission(
+      render_view->GetRoutingID(), host_resource()));
+}
+
+content::RenderView* PPB_Talk_Private_Impl::GetRenderView() {
+  WebView* view = instance->container()->element().document().frame()->view();
+  return content::RenderView::FromWebView(view);
+}
+
+void PPB_Talk_Private_Impl::ReplyReceived(int32_t result) {
+  if (ppapi::TrackedCallback::IsPending(&callback_))
+    ppapi::TrackedCallback::ClearAndRun(&callback_, result);
+}
+
+}  // namespace chrome