Add ability to create pending resource hosts.

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"
@@ skipping 10 matching lines @@
 
 // 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,
                      const PpapiPermissions& perms)
     : sender_(sender),
-      permissions_(perms) {
+      permissions_(perms),
+      next_pending_resource_host_id_(1) {
 }
 
 PpapiHost::~PpapiHost() {
   // Delete these explicitly before destruction since then the host is still
   // technically alive in case one of the filters accesses us from the
   // destructor.
   instance_message_filters_.clear();
 }
 
 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_DELAY_REPLY(PpapiHostMsg_ResourceSyncCall,
                                     OnHostMsgResourceSyncCall)
     IPC_MESSAGE_HANDLER(PpapiHostMsg_ResourceCreated,
                         OnHostMsgResourceCreated)
+    IPC_MESSAGE_HANDLER(PpapiHostMsg_AttachToPendingHost,
+                        OnHostMsgAttachToPendingHost)
     IPC_MESSAGE_HANDLER(PpapiHostMsg_ResourceDestroyed,
                         OnHostMsgResourceDestroyed)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
 
   if (!handled) {
     for (size_t i = 0; i < instance_message_filters_.size(); i++) {
       if (instance_message_filters_[i]->OnInstanceMessageReceived(msg)) {
         handled = true;
         break;
@@ skipping 10 matching lines @@
     PpapiHostMsg_ResourceSyncCall::WriteReplyParams(context.sync_reply_msg,
                                                     context.params, msg);
     Send(context.sync_reply_msg);
   } else {
     Send(new PpapiPluginMsg_ResourceReply(context.params, msg));
   }
 }
 
 void PpapiHost::SendUnsolicitedReply(PP_Resource resource,
                                      const IPC::Message& msg) {
+  DCHECK(resource);  // If this fails, host is probably pending.
   proxy::ResourceMessageReplyParams params(resource, 0);
   Send(new PpapiPluginMsg_ResourceReply(params, msg));
 }
 
+int PpapiHost::AddPendingResourceHost(scoped_ptr<ResourceHost> resource_host) {
+  // The resource ID should not be assigned.
+  DCHECK(resource_host->pp_resource() == 0);
+
+  int pending_id = next_pending_resource_host_id_++;
+  pending_resource_hosts_[pending_id] =
+      linked_ptr<ResourceHost>(resource_host.release());
+  return pending_id;
+}
+
 void PpapiHost::AddHostFactoryFilter(scoped_ptr<HostFactory> filter) {
   host_factory_filters_.push_back(filter.release());
 }
 
 void PpapiHost::AddInstanceMessageFilter(
     scoped_ptr<InstanceMessageFilter> filter) {
   instance_message_filters_.push_back(filter.release());
 }
 
 void PpapiHost::OnHostMsgResourceCall(
@@ skipping 46 matching lines @@
     resource_host = host_factory_filters_[i]->CreateResourceHost(
         this, params, instance, nested_msg).Pass();
     if (resource_host.get())
       break;
   }
   if (!resource_host.get()) {
     NOTREACHED();
     return;
   }
 
+  // Resource should have been assigned a nonzero PP_Resource.
+  DCHECK(resource_host->pp_resource());
+
   resources_[params.pp_resource()] =
       linked_ptr<ResourceHost>(resource_host.release());
 }
 
+void PpapiHost::OnHostMsgAttachToPendingHost(PP_Resource pp_resource,
+                                             int pending_host_id) {
+  PendingHostResourceMap::iterator found =
+      pending_resource_hosts_.find(pending_host_id);
+  if (found == pending_resource_hosts_.end()) {
+    // Plugin sent a bad ID.
+    NOTREACHED();
+    return;
+  }
+  found->second->SetPPResourceForPendingHost(pp_resource);
+  resources_[pp_resource] = found->second;
+  pending_resource_hosts_.erase(found);
+}
+
 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) const {
   ResourceMap::const_iterator found = resources_.find(resource);
   return found == resources_.end() ? NULL : found->second.get();
 }
 
 }  // namespace host
 }  // namespace ppapi