Revert https://src.chromium.org/viewvc/chrome?view=rev&revision=231330

ppapi/host/resource_message_filter_unittest.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 "base/message_loop/message_loop.h"
 #include "base/message_loop/message_loop_proxy.h"
 #include "base/synchronization/waitable_event.h"
 #include "base/threading/thread.h"
 #include "ipc/ipc_message.h"
 #include "ppapi/c/pp_errors.h"
@@ skipping 46 matching lines @@
 
   void AddMessageFilter(scoped_refptr<ResourceMessageFilter> filter) {
     AddFilter(filter);
   }
 
   virtual int32_t OnResourceMessageReceived(
       const IPC::Message& msg,
       HostMessageContext* context) OVERRIDE {
     last_handled_msg_ = msg;
     if (msg.type() == msg_type_) {
-      context->reply_msg = IPC::Message(0, reply_msg_type_);
+      context->reply_msg = IPC::Message(0, reply_msg_type_,
+                                        IPC::Message::PRIORITY_NORMAL);
       return PP_OK;
     }
     return PP_ERROR_FAILED;
   }
 
   virtual void SendReply(const ReplyMessageContext& context,
                          const IPC::Message& msg) OVERRIDE {
     last_reply_msg_ = msg;
     last_reply_message_loop_ = base::MessageLoop::current();
     g_handler_completion.Signal();
@@ skipping 37 matching lines @@
       return message_loop_proxy_;
     return NULL;
   }
 
   virtual int32_t OnResourceMessageReceived(
       const IPC::Message& msg,
       HostMessageContext* context) OVERRIDE {
     last_handled_msg_ = msg;
     last_message_loop_ = base::MessageLoop::current();
     if (msg.type() == msg_type_) {
-      context->reply_msg = IPC::Message(0, reply_msg_type_);
+      context->reply_msg = IPC::Message(0, reply_msg_type_,
+                                        IPC::Message::PRIORITY_NORMAL);
       return PP_OK;
     }
     return PP_ERROR_FAILED;
   }
 
  private:
   scoped_refptr<base::MessageLoopProxy> message_loop_proxy_;
   uint32 msg_type_;
   uint32 reply_msg_type_;
 
@@ skipping 21 matching lines @@
 
   PP_Instance instance = 12345;
   PP_Resource resource = 67890;
   MyResourceHost host(NULL, instance, resource, MSG3_TYPE, REPLY_MSG3_TYPE);
   host.AddMessageFilter(filter1);
   host.AddMessageFilter(filter2);
 
   proxy::ResourceMessageCallParams params(resource, 1);
   params.set_has_callback();
   HostMessageContext context(params);
-  IPC::Message message1(0, MSG1_TYPE);
-  IPC::Message message2(0, MSG2_TYPE);
-  IPC::Message message3(0, MSG3_TYPE);
+  IPC::Message message1(0, MSG1_TYPE, IPC::Message::PRIORITY_NORMAL);
+  IPC::Message message2(0, MSG2_TYPE, IPC::Message::PRIORITY_NORMAL);
+  IPC::Message message3(0, MSG3_TYPE, IPC::Message::PRIORITY_NORMAL);
 
   // Message 1 handled by the first filter.
   host.HandleMessage(message1, &context);
   g_handler_completion.Wait();
   EXPECT_EQ(filter1->last_handled_msg().type(), message1.type());
   EXPECT_EQ(filter1->last_message_loop(), bg_thread1.message_loop());
   EXPECT_EQ(host.last_reply_msg().type(), static_cast<uint32>(REPLY_MSG1_TYPE));
   EXPECT_EQ(host.last_reply_message_loop(), io_thread.message_loop());
   g_handler_completion.Reset();
 
@@ skipping 11 matching lines @@
   EXPECT_EQ(host.last_handled_msg().type(), message3.type());
   EXPECT_EQ(host.last_reply_msg().type(), static_cast<uint32>(REPLY_MSG3_TYPE));
 
   io_thread.Stop();
   bg_thread1.Stop();
   bg_thread2.Stop();
 }
 
 }  // namespace proxy
 }  // namespace ppapi