Pepper UDP socket: buffer received packets in the plugin process to improve performance.

ppapi/proxy/plugin_message_filter.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 "ppapi/proxy/plugin_message_filter.h"
 
 #include "base/bind.h"
 #include "base/logging.h"
 #include "ipc/ipc_channel.h"
 #include "ppapi/proxy/ppapi_messages.h"
@@ skipping 65 matching lines @@
   // This instance ID is new so we can return that it's usable and mark it as
   // used for future reference.
   seen_instance_ids_->insert(instance);
   *usable = true;
 }
 
 void PluginMessageFilter::OnMsgResourceReply(
     const ResourceMessageReplyParams& reply_params,
     const IPC::Message& nested_msg) {
   scoped_refptr<base::MessageLoopProxy> target =
-      resource_reply_thread_registrar_->GetTargetThreadAndUnregister(
-          reply_params.pp_resource(), reply_params.sequence());
+      resource_reply_thread_registrar_->GetTargetThread(reply_params,
+                                                        nested_msg);
 
-  target->PostTask(
-      FROM_HERE,
-      base::Bind(&DispatchResourceReply, reply_params, nested_msg));
+  if (!target.get()) {
+    DispatchResourceReply(reply_params, nested_msg);
+  } else {
+    target->PostTask(
+        FROM_HERE,
+        base::Bind(&DispatchResourceReply, reply_params, nested_msg));
+  }
 }
 
 // static
 void PluginMessageFilter::DispatchResourceReply(
     const ResourceMessageReplyParams& reply_params,
     const IPC::Message& nested_msg) {
   ProxyAutoLock lock;
   Resource* resource = PpapiGlobals::Get()->GetResourceTracker()->GetResource(
       reply_params.pp_resource());
   if (!resource) {
     DVLOG_IF(1, reply_params.sequence() != 0)
         << "Pepper resource reply message received but the resource doesn't "
            "exist (probably has been destroyed).";
     return;
   }
   resource->OnReplyReceived(reply_params, nested_msg);
 }
 
 }  // namespace proxy
 }  // namespace ppapi