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 <memory> |
9 #include <utility> | 9 #include <utility> |
10 | 10 |
11 #include "base/bind.h" | 11 #include "base/bind.h" |
12 #include "base/message_loop/message_loop.h" | 12 #include "base/location.h" |
| 13 #include "base/single_thread_task_runner.h" |
| 14 #include "base/threading/thread_task_runner_handle.h" |
13 | 15 |
14 namespace device { | 16 namespace device { |
15 | 17 |
16 // Represents a receive that is not yet fulfilled. | 18 // Represents a receive that is not yet fulfilled. |
17 class DataReceiver::PendingReceive { | 19 class DataReceiver::PendingReceive { |
18 public: | 20 public: |
19 PendingReceive(DataReceiver* receiver, | 21 PendingReceive(DataReceiver* receiver, |
20 const ReceiveDataCallback& callback, | 22 const ReceiveDataCallback& callback, |
21 const ReceiveErrorCallback& error_callback, | 23 const ReceiveErrorCallback& error_callback, |
22 int32_t fatal_error_value); | 24 int32_t fatal_error_value); |
(...skipping 195 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
218 buffer_in_use_(false) { | 220 buffer_in_use_(false) { |
219 } | 221 } |
220 | 222 |
221 bool DataReceiver::PendingReceive::DispatchDataFrame( | 223 bool DataReceiver::PendingReceive::DispatchDataFrame( |
222 DataReceiver::DataFrame* data) { | 224 DataReceiver::DataFrame* data) { |
223 DCHECK(!buffer_in_use_); | 225 DCHECK(!buffer_in_use_); |
224 DCHECK(!data->dispatched); | 226 DCHECK(!data->dispatched); |
225 | 227 |
226 if (data->is_error) { | 228 if (data->is_error) { |
227 data->dispatched = true; | 229 data->dispatched = true; |
228 base::MessageLoop::current()->PostTask( | 230 base::ThreadTaskRunnerHandle::Get()->PostTask( |
229 FROM_HERE, base::Bind(receive_error_callback_, data->error)); | 231 FROM_HERE, base::Bind(receive_error_callback_, data->error)); |
230 return true; | 232 return true; |
231 } | 233 } |
232 buffer_in_use_ = true; | 234 buffer_in_use_ = true; |
233 base::MessageLoop::current()->PostTask( | 235 base::ThreadTaskRunnerHandle::Get()->PostTask( |
234 FROM_HERE, | 236 FROM_HERE, |
235 base::Bind( | 237 base::Bind( |
236 receive_callback_, | 238 receive_callback_, |
237 base::Passed(std::unique_ptr<ReadOnlyBuffer>(new Buffer( | 239 base::Passed(std::unique_ptr<ReadOnlyBuffer>(new Buffer( |
238 receiver_, this, | 240 receiver_, this, |
239 reinterpret_cast<char*>(&data->data[0]) + data->offset, | 241 reinterpret_cast<char*>(&data->data[0]) + data->offset, |
240 static_cast<uint32_t>(data->data.size() - data->offset)))))); | 242 static_cast<uint32_t>(data->data.size() - data->offset)))))); |
241 return false; | 243 return false; |
242 } | 244 } |
243 | 245 |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
283 buffer_size_ = 0; | 285 buffer_size_ = 0; |
284 } | 286 } |
285 | 287 |
286 void DataReceiver::PendingReceive::Buffer::DoneWithError( | 288 void DataReceiver::PendingReceive::Buffer::DoneWithError( |
287 uint32_t bytes_consumed, | 289 uint32_t bytes_consumed, |
288 int32_t error) { | 290 int32_t error) { |
289 Done(bytes_consumed); | 291 Done(bytes_consumed); |
290 } | 292 } |
291 | 293 |
292 } // namespace device | 294 } // namespace device |
OLD | NEW |