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_sink_receiver.h" | 5 #include "device/serial/data_sink_receiver.h" |
6 | 6 |
7 #include <limits> | 7 #include <limits> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/message_loop/message_loop.h" | 10 #include "base/message_loop/message_loop.h" |
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
72 const CancelCallback& cancel_callback, | 72 const CancelCallback& cancel_callback, |
73 const ErrorCallback& error_callback) | 73 const ErrorCallback& error_callback) |
74 : binding_(this, request.Pass()), | 74 : binding_(this, request.Pass()), |
75 ready_callback_(ready_callback), | 75 ready_callback_(ready_callback), |
76 cancel_callback_(cancel_callback), | 76 cancel_callback_(cancel_callback), |
77 error_callback_(error_callback), | 77 error_callback_(error_callback), |
78 current_error_(0), | 78 current_error_(0), |
79 buffer_in_use_(NULL), | 79 buffer_in_use_(NULL), |
80 shut_down_(false), | 80 shut_down_(false), |
81 weak_factory_(this) { | 81 weak_factory_(this) { |
82 binding_.set_error_handler(this); | 82 binding_.set_connection_error_handler( |
| 83 base::Bind(&DataSinkReceiver::OnConnectionError, base::Unretained(this))); |
83 } | 84 } |
84 | 85 |
85 void DataSinkReceiver::ShutDown() { | 86 void DataSinkReceiver::ShutDown() { |
86 shut_down_ = true; | 87 shut_down_ = true; |
87 } | 88 } |
88 | 89 |
89 DataSinkReceiver::~DataSinkReceiver() { | 90 DataSinkReceiver::~DataSinkReceiver() { |
90 } | 91 } |
91 | 92 |
92 void DataSinkReceiver::Cancel(int32_t error) { | 93 void DataSinkReceiver::Cancel(int32_t error) { |
(...skipping 182 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
275 callback_.Run(offset_, 0); | 276 callback_.Run(offset_, 0); |
276 } | 277 } |
277 void DataSinkReceiver::DataFrame::ReportError(uint32_t bytes_read, | 278 void DataSinkReceiver::DataFrame::ReportError(uint32_t bytes_read, |
278 int32_t error) { | 279 int32_t error) { |
279 offset_ += bytes_read; | 280 offset_ += bytes_read; |
280 DCHECK_LE(offset_, data_.size()); | 281 DCHECK_LE(offset_, data_.size()); |
281 callback_.Run(offset_, error); | 282 callback_.Run(offset_, error); |
282 } | 283 } |
283 | 284 |
284 } // namespace device | 285 } // namespace device |
OLD | NEW |