| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include <queue> | 5 #include <queue> |
| 6 | 6 |
| 7 #include "device/serial/data_sink_receiver.h" | 7 #include "device/serial/data_sink_receiver.h" |
| 8 #include "device/serial/data_stream.mojom.h" | 8 #include "device/serial/data_stream.mojom.h" |
| 9 #include "extensions/renderer/api_test_base.h" | 9 #include "extensions/renderer/api_test_base.h" |
| 10 #include "grit/extensions_renderer_resources.h" | 10 #include "grit/extensions_renderer_resources.h" |
| (...skipping 20 matching lines...) Expand all Loading... |
| 31 buffer_.reset(); | 31 buffer_.reset(); |
| 32 ApiTestBase::TearDown(); | 32 ApiTestBase::TearDown(); |
| 33 } | 33 } |
| 34 | 34 |
| 35 std::queue<int32_t> error_to_report_; | 35 std::queue<int32_t> error_to_report_; |
| 36 std::queue<std::string> expected_data_; | 36 std::queue<std::string> expected_data_; |
| 37 | 37 |
| 38 private: | 38 private: |
| 39 void CreateDataSink( | 39 void CreateDataSink( |
| 40 mojo::InterfaceRequest<device::serial::DataSink> request) { | 40 mojo::InterfaceRequest<device::serial::DataSink> request) { |
| 41 receiver_ = mojo::WeakBindToRequest( | 41 receiver_ = new device::DataSinkReceiver( |
| 42 new device::DataSinkReceiver( | 42 request.Pass(), |
| 43 base::Bind(&DataSenderTest::ReadyToReceive, base::Unretained(this)), | 43 base::Bind(&DataSenderTest::ReadyToReceive, base::Unretained(this)), |
| 44 base::Bind(&DataSenderTest::OnCancel, base::Unretained(this)), | 44 base::Bind(&DataSenderTest::OnCancel, base::Unretained(this)), |
| 45 base::Bind(base::DoNothing)), | 45 base::Bind(base::DoNothing)); |
| 46 &request); | |
| 47 } | 46 } |
| 48 | 47 |
| 49 void ReadyToReceive(scoped_ptr<device::ReadOnlyBuffer> buffer) { | 48 void ReadyToReceive(scoped_ptr<device::ReadOnlyBuffer> buffer) { |
| 50 std::string data(buffer->GetData(), buffer->GetSize()); | 49 std::string data(buffer->GetData(), buffer->GetSize()); |
| 51 if (expected_data_.empty()) { | 50 if (expected_data_.empty()) { |
| 52 buffer_ = buffer.Pass(); | 51 buffer_ = buffer.Pass(); |
| 53 return; | 52 return; |
| 54 } | 53 } |
| 55 | 54 |
| 56 std::string& expected = expected_data_.front(); | 55 std::string& expected = expected_data_.front(); |
| (...skipping 120 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 177 | 176 |
| 178 TEST_F(DataSenderTest, SerializeWaitsForCancel) { | 177 TEST_F(DataSenderTest, SerializeWaitsForCancel) { |
| 179 RunTest("data_sender_unittest.js", "testSerializeWaitsForCancel"); | 178 RunTest("data_sender_unittest.js", "testSerializeWaitsForCancel"); |
| 180 } | 179 } |
| 181 | 180 |
| 182 TEST_F(DataSenderTest, SerializeAfterClose) { | 181 TEST_F(DataSenderTest, SerializeAfterClose) { |
| 183 RunTest("data_sender_unittest.js", "testSerializeAfterClose"); | 182 RunTest("data_sender_unittest.js", "testSerializeAfterClose"); |
| 184 } | 183 } |
| 185 | 184 |
| 186 } // namespace extensions | 185 } // namespace extensions |
| OLD | NEW |