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 <stddef.h> | 5 #include <stddef.h> |
6 #include <stdint.h> | 6 #include <stdint.h> |
| 7 #include <utility> |
7 | 8 |
8 #include "base/bind.h" | 9 #include "base/bind.h" |
9 #include "base/macros.h" | 10 #include "base/macros.h" |
10 #include "base/message_loop/message_loop.h" | 11 #include "base/message_loop/message_loop.h" |
11 #include "base/run_loop.h" | 12 #include "base/run_loop.h" |
12 #include "base/strings/string_piece.h" | 13 #include "base/strings/string_piece.h" |
13 #include "device/serial/data_sender.h" | 14 #include "device/serial/data_sender.h" |
14 #include "device/serial/data_sink_receiver.h" | 15 #include "device/serial/data_sink_receiver.h" |
15 #include "device/serial/data_stream.mojom.h" | 16 #include "device/serial/data_stream.mojom.h" |
16 #include "mojo/public/cpp/bindings/interface_ptr.h" | 17 #include "mojo/public/cpp/bindings/interface_ptr.h" |
(...skipping 23 matching lines...) Expand all Loading... |
40 expected_event_(EVENT_NONE) {} | 41 expected_event_(EVENT_NONE) {} |
41 | 42 |
42 void SetUp() override { | 43 void SetUp() override { |
43 message_loop_.reset(new base::MessageLoop); | 44 message_loop_.reset(new base::MessageLoop); |
44 mojo::InterfacePtr<serial::DataSink> sink_handle; | 45 mojo::InterfacePtr<serial::DataSink> sink_handle; |
45 sink_receiver_ = new DataSinkReceiver( | 46 sink_receiver_ = new DataSinkReceiver( |
46 mojo::GetProxy(&sink_handle), | 47 mojo::GetProxy(&sink_handle), |
47 base::Bind(&DataSinkTest::OnDataToRead, base::Unretained(this)), | 48 base::Bind(&DataSinkTest::OnDataToRead, base::Unretained(this)), |
48 base::Bind(&DataSinkTest::OnCancel, base::Unretained(this)), | 49 base::Bind(&DataSinkTest::OnCancel, base::Unretained(this)), |
49 base::Bind(&DataSinkTest::OnError, base::Unretained(this))); | 50 base::Bind(&DataSinkTest::OnError, base::Unretained(this))); |
50 sender_.reset(new DataSender(sink_handle.Pass(), kBufferSize, kFatalError)); | 51 sender_.reset( |
| 52 new DataSender(std::move(sink_handle), kBufferSize, kFatalError)); |
51 } | 53 } |
52 | 54 |
53 void TearDown() override { | 55 void TearDown() override { |
54 read_buffer_.reset(); | 56 read_buffer_.reset(); |
55 message_loop_.reset(); | 57 message_loop_.reset(); |
56 if (sink_receiver_.get()) | 58 if (sink_receiver_.get()) |
57 EXPECT_TRUE(sink_receiver_->HasOneRef()); | 59 EXPECT_TRUE(sink_receiver_->HasOneRef()); |
58 } | 60 } |
59 | 61 |
60 void WaitForEvent(Event event) { | 62 void WaitForEvent(Event event) { |
(...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
151 } | 153 } |
152 | 154 |
153 void OnSendError(uint32_t bytes_sent, int32_t error) { | 155 void OnSendError(uint32_t bytes_sent, int32_t error) { |
154 bytes_sent_ = bytes_sent; | 156 bytes_sent_ = bytes_sent; |
155 send_error_ = error; | 157 send_error_ = error; |
156 has_send_error_ = true; | 158 has_send_error_ = true; |
157 EventReceived(EVENT_SEND_ERROR); | 159 EventReceived(EVENT_SEND_ERROR); |
158 } | 160 } |
159 | 161 |
160 void OnDataToRead(scoped_ptr<ReadOnlyBuffer> buffer) { | 162 void OnDataToRead(scoped_ptr<ReadOnlyBuffer> buffer) { |
161 read_buffer_ = buffer.Pass(); | 163 read_buffer_ = std::move(buffer); |
162 read_buffer_contents_ = | 164 read_buffer_contents_ = |
163 std::string(read_buffer_->GetData(), read_buffer_->GetSize()); | 165 std::string(read_buffer_->GetData(), read_buffer_->GetSize()); |
164 EventReceived(EVENT_READ_BUFFER_READY); | 166 EventReceived(EVENT_READ_BUFFER_READY); |
165 } | 167 } |
166 | 168 |
167 bool Cancel(int32_t error) { | 169 bool Cancel(int32_t error) { |
168 return sender_->Cancel( | 170 return sender_->Cancel( |
169 error, base::Bind(&DataSinkTest::CancelAck, base::Unretained(this))); | 171 error, base::Bind(&DataSinkTest::CancelAck, base::Unretained(this))); |
170 } | 172 } |
171 | 173 |
(...skipping 235 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
407 sender_.reset(); | 409 sender_.reset(); |
408 ExpectSendError(0, kFatalError); | 410 ExpectSendError(0, kFatalError); |
409 ExpectSendError(0, kFatalError); | 411 ExpectSendError(0, kFatalError); |
410 ExpectCancelResult(); | 412 ExpectCancelResult(); |
411 if (!seen_connection_error_) | 413 if (!seen_connection_error_) |
412 WaitForEvent(EVENT_ERROR); | 414 WaitForEvent(EVENT_ERROR); |
413 EXPECT_TRUE(seen_connection_error_); | 415 EXPECT_TRUE(seen_connection_error_); |
414 } | 416 } |
415 | 417 |
416 } // namespace device | 418 } // namespace device |
OLD | NEW |