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 "device/serial/data_receiver.h" | 5 #include "device/serial/data_receiver.h" |
6 | 6 |
7 #include <limits> | 7 #include <limits> |
| 8 #include <memory> |
8 #include <utility> | 9 #include <utility> |
9 | 10 |
10 #include "base/bind.h" | 11 #include "base/bind.h" |
11 #include "base/message_loop/message_loop.h" | 12 #include "base/message_loop/message_loop.h" |
12 | 13 |
13 namespace device { | 14 namespace device { |
14 | 15 |
15 // Represents a receive that is not yet fulfilled. | 16 // Represents a receive that is not yet fulfilled. |
16 class DataReceiver::PendingReceive { | 17 class DataReceiver::PendingReceive { |
17 public: | 18 public: |
(...skipping 208 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
226 data->dispatched = true; | 227 data->dispatched = true; |
227 base::MessageLoop::current()->PostTask( | 228 base::MessageLoop::current()->PostTask( |
228 FROM_HERE, base::Bind(receive_error_callback_, data->error)); | 229 FROM_HERE, base::Bind(receive_error_callback_, data->error)); |
229 return true; | 230 return true; |
230 } | 231 } |
231 buffer_in_use_ = true; | 232 buffer_in_use_ = true; |
232 base::MessageLoop::current()->PostTask( | 233 base::MessageLoop::current()->PostTask( |
233 FROM_HERE, | 234 FROM_HERE, |
234 base::Bind( | 235 base::Bind( |
235 receive_callback_, | 236 receive_callback_, |
236 base::Passed(scoped_ptr<ReadOnlyBuffer>(new Buffer( | 237 base::Passed(std::unique_ptr<ReadOnlyBuffer>(new Buffer( |
237 receiver_, | 238 receiver_, this, |
238 this, | |
239 reinterpret_cast<char*>(&data->data[0]) + data->offset, | 239 reinterpret_cast<char*>(&data->data[0]) + data->offset, |
240 static_cast<uint32_t>(data->data.size() - data->offset)))))); | 240 static_cast<uint32_t>(data->data.size() - data->offset)))))); |
241 return false; | 241 return false; |
242 } | 242 } |
243 | 243 |
244 void DataReceiver::PendingReceive::DispatchFatalError() { | 244 void DataReceiver::PendingReceive::DispatchFatalError() { |
245 receive_error_callback_.Run(fatal_error_value_); | 245 receive_error_callback_.Run(fatal_error_value_); |
246 } | 246 } |
247 | 247 |
248 void DataReceiver::PendingReceive::Done(uint32_t bytes_consumed) { | 248 void DataReceiver::PendingReceive::Done(uint32_t bytes_consumed) { |
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
283 buffer_size_ = 0; | 283 buffer_size_ = 0; |
284 } | 284 } |
285 | 285 |
286 void DataReceiver::PendingReceive::Buffer::DoneWithError( | 286 void DataReceiver::PendingReceive::Buffer::DoneWithError( |
287 uint32_t bytes_consumed, | 287 uint32_t bytes_consumed, |
288 int32_t error) { | 288 int32_t error) { |
289 Done(bytes_consumed); | 289 Done(bytes_consumed); |
290 } | 290 } |
291 | 291 |
292 } // namespace device | 292 } // namespace device |
OLD | NEW |