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 |