Add serialization support to the JS DataSender and DataReceiver.

extensions/renderer/api/serial/data_sender_unittest.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 <queue>
 
 #include "device/serial/data_sink_receiver.h"
 #include "device/serial/data_stream.mojom.h"
 #include "extensions/renderer/api_test_base.h"
 #include "grit/extensions_renderer_resources.h"
 
 namespace extensions {
 
 // Runs tests defined in extensions/test/data/data_sender_unittest.js
 class DataSenderTest : public ApiTestBase {
  public:
   DataSenderTest() {}
 
   virtual void SetUp() OVERRIDE {
     ApiTestBase::SetUp();
     env()->RegisterModule("async_waiter", IDR_ASYNC_WAITER_JS);
     env()->RegisterModule("data_sender", IDR_DATA_SENDER_JS);
     env()->RegisterModule("device/serial/data_stream.mojom",
                           IDR_DATA_STREAM_MOJOM_JS);
+    env()->RegisterModule("device/serial/data_stream_serialization.mojom",
+                          IDR_DATA_STREAM_SERIALIZATION_MOJOM_JS);
     service_provider()->AddService(
         base::Bind(&DataSenderTest::CreateDataSink, base::Unretained(this)));
   }
 
   virtual void TearDown() OVERRIDE {
     if (receiver_.get()) {
       receiver_->ShutDown();
       receiver_ = NULL;
     }
     EXPECT_FALSE(buffer_);
@@ skipping 117 matching lines @@
 }
 
 TEST_F(DataSenderTest, Cancel) {
   RunTest("data_sender_unittest.js", "testCancel");
 }
 
 TEST_F(DataSenderTest, Close) {
   RunTest("data_sender_unittest.js", "testClose");
 }
 
+TEST_F(DataSenderTest, SendWithSerialization) {
+  expected_data_.push("aaa");
+  RunTest("data_sender_unittest.js", "testSendWithSerialization");
+}
+
+TEST_F(DataSenderTest, SendErrorWithSerialization) {
+  expected_data_.push("");
+  expected_data_.push("a");
+  error_to_report_.push(1);
+  expected_data_.push("");
+  expected_data_.push("c");
+  error_to_report_.push(0);
+  error_to_report_.push(3);
+  RunTest("data_sender_unittest.js", "testSendErrorWithSerialization");
+}
+
+TEST_F(DataSenderTest, SendErrorPartialSuccessWithSerialization) {
+  expected_data_.push(std::string(5, 'b'));
+  expected_data_.push("a");
+  error_to_report_.push(1);
+  expected_data_.push(std::string(5, 'c'));
+  expected_data_.push("d");
+  error_to_report_.push(0);
+  error_to_report_.push(3);
+  RunTest("data_sender_unittest.js",
+          "testSendErrorPartialSuccessWithSerialization");
+}
+
+TEST_F(DataSenderTest, SendErrorBetweenPacketsWithSerialization) {
+  expected_data_.push(std::string(2, 'b'));
+  expected_data_.push("a");
+  error_to_report_.push(1);
+  error_to_report_.push(0);
+
+  expected_data_.push(std::string(2, 'c'));
+  expected_data_.push("d");
+  error_to_report_.push(3);
+  RunTest("data_sender_unittest.js",
+          "testSendErrorBetweenPacketsWithSerialization");
+}
+
+TEST_F(DataSenderTest, SendErrorInSecondPacketWithSerialization) {
+  expected_data_.push(std::string(3, 'b'));
+  expected_data_.push("a");
+  error_to_report_.push(1);
+  error_to_report_.push(0);
+  expected_data_.push(std::string(3, 'c'));
+  expected_data_.push("d");
+  error_to_report_.push(3);
+  RunTest("data_sender_unittest.js",
+          "testSendErrorInSecondPacketWithSerialization");
+}
+
+TEST_F(DataSenderTest, CancelWithSerialization) {
+  RunTest("data_sender_unittest.js", "testCancelWithSerialization");
+}
+
+TEST_F(DataSenderTest, SerializeWithSendsInProgress) {
+  RunTest("data_sender_unittest.js", "testSerializeWithSendsInProgress");
+}
+
+TEST_F(DataSenderTest, SerializeWithSendAndCancelInProgress) {
+  RunTest("data_sender_unittest.js",
+          "testSerializeWithSendAndCancelInProgress");
+}
+
+TEST_F(DataSenderTest, SerializeAfterClose) {
+  RunTest("data_sender_unittest.js", "testSerializeAfterClose");
+}
+
 }  // namespace extensions