Hook up the PPB_Flash_Print interface to new host system.

ppapi/host/ppapi_host.cc

 // Copyright (c) 2012 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 "ppapi/host/ppapi_host.h"
 
 #include "base/logging.h"
 #include "ppapi/c/pp_errors.h"
 #include "ppapi/host/host_factory.h"
 #include "ppapi/host/host_message_context.h"
+#include "ppapi/host/instance_message_filter.h"
 #include "ppapi/host/resource_host.h"
 #include "ppapi/proxy/ppapi_messages.h"
 #include "ppapi/proxy/resource_message_params.h"
 #include "ppapi/shared_impl/host_resource.h"
 
 namespace ppapi {
 namespace host {
 
 namespace {
 
 // Put a cap on the maximum number of resources so we don't explode if the
 // renderer starts spamming us.
 const size_t kMaxResourcesPerPlugin = 1 << 14;
 
 }  // namespace
 
 PpapiHost::PpapiHost(IPC::Sender* sender,
                      HostFactory* host_factory,
                      const PpapiPermissions& perms)
     : sender_(sender),
       host_factory_(host_factory),
       permissions_(perms) {
 }
 
 PpapiHost::~PpapiHost() {
+  FOR_EACH_OBSERVER(InstanceMessageFilter,
+                    instance_message_filters_,
+                    CallPpapiHostDestroyed());
 }
 
 bool PpapiHost::Send(IPC::Message* msg) {
   return sender_->Send(msg);
 }
 
 bool PpapiHost::OnMessageReceived(const IPC::Message& msg) {
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP(PpapiHost, msg)
     IPC_MESSAGE_HANDLER(PpapiHostMsg_ResourceCall,
                         OnHostMsgResourceCall)
     IPC_MESSAGE_HANDLER(PpapiHostMsg_ResourceCreated,
                         OnHostMsgResourceCreated)
     IPC_MESSAGE_HANDLER(PpapiHostMsg_ResourceDestroyed,
                         OnHostMsgResourceDestroyed)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
+
+  if (!handled) {
+    // Custom implementation of FOR_EACH_OBSERVER to allow for filter
+    // functionality.
+    if (instance_message_filters_.might_have_observers()) {
+      ObserverListBase<InstanceMessageFilter>::Iterator it(
+          instance_message_filters_);
+      InstanceMessageFilter* obs;
+      while ((obs = it.GetNext()) != NULL) {
+        if (obs->OnInstanceMessageReceived(msg)) {
+          handled = true;
+          break;
+        }
+      }
+    }
+  }
+
   return handled;
 }
 
 void PpapiHost::SendReply(const proxy::ResourceMessageReplyParams& params,
                           const IPC::Message& msg) {
   Send(new PpapiPluginMsg_ResourceReply(params, msg));
 }
 
+
+void PpapiHost::AddInstanceMessageFilter(InstanceMessageFilter* filter) {
+  instance_message_filters_.AddObserver(filter);
+}
+
+void PpapiHost::RemoveInstanceMessageFilter(InstanceMessageFilter* filter) {
+  instance_message_filters_.RemoveObserver(filter);
+}
+
 void PpapiHost::OnHostMsgResourceCall(
     const proxy::ResourceMessageCallParams& params,
     const IPC::Message& nested_msg) {
   HostMessageContext context(params);
   proxy::ResourceMessageReplyParams reply_params(params.pp_resource(),
                                                  params.sequence());
 
   ResourceHost* resource_host = GetResourceHost(params.pp_resource());
   if (resource_host) {
     reply_params.set_result(resource_host->OnResourceMessageReceived(
@@ skipping 22 matching lines @@
 }
 
 void PpapiHost::OnHostMsgResourceCreated(
     const proxy::ResourceMessageCallParams& params,
     PP_Instance instance,
     const IPC::Message& nested_msg) {
   if (resources_.size() >= kMaxResourcesPerPlugin)
     return;
 
   scoped_ptr<ResourceHost> resource_host(
-      host_factory_->CreateResourceHost(this, params, instance,
-                                        nested_msg));
+      host_factory_->CreateResourceHost(this, params, instance, nested_msg));
   if (!resource_host.get()) {
     NOTREACHED();
     return;
   }
 
   resources_[params.pp_resource()] =
       linked_ptr<ResourceHost>(resource_host.release());
 }
 
 void PpapiHost::OnHostMsgResourceDestroyed(PP_Resource resource) {
   ResourceMap::iterator found = resources_.find(resource);
   if (found == resources_.end()) {
     NOTREACHED();
     return;
   }
   resources_.erase(found);
 }
 
 ResourceHost* PpapiHost::GetResourceHost(PP_Resource resource) {
   ResourceMap::iterator found = resources_.find(resource);
   return found == resources_.end() ? NULL : found->second.get();
 }
 
 }  // namespace host
 }  // namespace ppapi