Add support for HandleBlockingMessage to NaClMessageScanner

ppapi/tests/test_message_handler.cc

 // Copyright 2014 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/tests/test_message_handler.h"
 
 #include <string.h>
 #include <algorithm>
 #include <map>
 #include <sstream>
@@ skipping 201 matching lines @@
   ppb_messaging_if_ = static_cast<const PPB_Messaging_1_2*>(
       pp::Module::Get()->GetBrowserInterface(PPB_MESSAGING_INTERFACE_1_2));
   return ppb_messaging_if_ &&
          CheckTestingInterface() &&
          handler_thread_.Start();
 }
 
 void TestMessageHandler::RunTests(const std::string& filter) {
   RUN_TEST(RegisterErrorConditions, filter);
   RUN_TEST(PostMessageAndAwaitResponse, filter);
+  RUN_TEST(ArrayBuffer, filter);
   RUN_TEST(Exceptions, filter);
 }
 
 void TestMessageHandler::HandleMessage(const pp::Var& message_data) {
   if (instance()->current_test_name() == "Exceptions") {
     // For TestPostMessageAndAwaitResponse(), all messages should go to the
     // background thread message handler.
     assert(false);
   } else {
     // Any subtest causing a message to arrive here must wait for it before
@@ skipping 63 matching lines @@
   }
   instance_->EvalScript(js_code);
   instance_->EvalScript("plugin.postMessage('FINISHED_TEST');\n");
   handler.WaitForTestFinishedMessage();
   handler.Unregister();
   ASSERT_SUBTEST_SUCCESS(handler.WaitForDestroy());
 
   PASS();
 }
 
+std::string TestMessageHandler::TestArrayBuffer() {
+  // Set the array buffer shared memory threshold so that some of the
+  // ArrayBuffer values will be sent as shared memory.
+  ScopedArrayBufferSizeSetter setter(testing_interface_,
+                                     instance_->pp_instance(),
+                                     200);
+  const char* const sizes[] = { "0", "128", "1024", "4096", NULL };
+  MyMessageHandler handler(instance(),
+                           handler_thread_.message_loop());
+  handler.Register();
+  std::string js_code("var plugin = document.getElementById('plugin');\n");
+  js_code += "var result = undefined;\n";
+  js_code += "var param = undefined;\n";
+  for (size_t i = 0; sizes[i]; ++i) {
+    js_code += "param = new ArrayBuffer(";
+    js_code += sizes[i];
+    js_code += ");";
+    // TODO(dmichael): It would be better to set specific values in param.
+    js_code += "result = plugin.postMessageAndAwaitResponse(param);";
+    js_code += "if (!deepCompare(result, param))\n";
+    js_code += "  InternalError(\" Failed postMessageAndAwaitResponse for ";
+    js_code += "ArrayBuffer of size: ";
+    js_code +=     sizes[i];
+    js_code += " result: \" + result);\n";
+  }
+  instance_->EvalScript(js_code);
+  instance_->EvalScript("plugin.postMessage('FINISHED_TEST');\n");
+  handler.WaitForTestFinishedMessage();
+  handler.Unregister();
+  ASSERT_SUBTEST_SUCCESS(handler.WaitForDestroy());
+
+  PASS();
+}
+
 std::string TestMessageHandler::TestExceptions() {
   MyMessageHandler handler(instance(),
                            handler_thread_.message_loop());
   {
     // First, try sending a blocking message when there is no handler
     // registered. It should throw an exception.
     std::string js_code(
         "var plugin = document.getElementById('plugin');\n"
         "var caught_exception = false;\n"
         "try {\n"
@@ skipping 46 matching lines @@
 }
 
 pp::Var TestMessageHandler::WaitForMessage() {
   message_received_.Wait();
   pp::Var var_to_return = last_message_;
   last_message_ = pp::Var();
   message_received_.Reset();
   return var_to_return;
 }