| Index: chrome/browser/extensions/api/serial/serial_connection.cc
|
| diff --git a/chrome/browser/extensions/api/serial/serial_connection.cc b/chrome/browser/extensions/api/serial/serial_connection.cc
|
| index aee95a2bd5c5e3bce09fe9c3371b7888d99df662..8ff045e0d8b051ce10605c635196d98e68db8b0d 100644
|
| --- a/chrome/browser/extensions/api/serial/serial_connection.cc
|
| +++ b/chrome/browser/extensions/api/serial/serial_connection.cc
|
| @@ -40,7 +40,7 @@ SerialConnection::SerialConnection(const std::string& port,
|
| send_timeout_(0),
|
| paused_(false),
|
| io_handler_(SerialIoHandler::Create()) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| }
|
|
|
| SerialConnection::~SerialConnection() {
|
| @@ -72,7 +72,7 @@ void SerialConnection::set_paused(bool paused) {
|
| }
|
|
|
| void SerialConnection::Open(const OpenCompleteCallback& callback) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| DCHECK(open_complete_.is_null());
|
| open_complete_ = callback;
|
| BrowserThread::PostTask(
|
| @@ -83,7 +83,7 @@ void SerialConnection::Open(const OpenCompleteCallback& callback) {
|
|
|
| void SerialConnection::Close() {
|
| DCHECK(open_complete_.is_null());
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (file_.IsValid()) {
|
| BrowserThread::PostTask(
|
| BrowserThread::FILE,
|
| @@ -93,7 +93,7 @@ void SerialConnection::Close() {
|
| }
|
|
|
| bool SerialConnection::Receive(const ReceiveCompleteCallback& callback) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (!receive_complete_.is_null())
|
| return false;
|
| receive_complete_ = callback;
|
| @@ -109,7 +109,7 @@ bool SerialConnection::Receive(const ReceiveCompleteCallback& callback) {
|
|
|
| bool SerialConnection::Send(const std::string& data,
|
| const SendCompleteCallback& callback) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (!send_complete_.is_null())
|
| return false;
|
| send_complete_ = callback;
|
| @@ -125,7 +125,7 @@ bool SerialConnection::Send(const std::string& data,
|
|
|
| bool SerialConnection::Configure(
|
| const api::serial::ConnectionOptions& options) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (options.persistent.get())
|
| set_persistent(*options.persistent);
|
| if (options.name.get())
|
| @@ -147,7 +147,7 @@ void SerialConnection::SetIoHandlerForTest(
|
| }
|
|
|
| bool SerialConnection::GetInfo(api::serial::ConnectionInfo* info) const {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| info->paused = paused_;
|
| info->persistent = persistent_;
|
| info->name = name_;
|
| @@ -159,7 +159,7 @@ bool SerialConnection::GetInfo(api::serial::ConnectionInfo* info) const {
|
|
|
| void SerialConnection::StartOpen() {
|
| DCHECK(!open_complete_.is_null());
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::FILE);
|
| DCHECK(!file_.IsValid());
|
| // It's the responsibility of the API wrapper around SerialConnection to
|
| // validate the supplied path against the set of valid port names, and
|
| @@ -180,7 +180,7 @@ void SerialConnection::StartOpen() {
|
| }
|
|
|
| void SerialConnection::FinishOpen(base::File file) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| DCHECK(!open_complete_.is_null());
|
| DCHECK(!file_.IsValid());
|
| OpenCompleteCallback callback = open_complete_;
|
| @@ -209,23 +209,23 @@ void SerialConnection::FinishOpen(base::File file) {
|
|
|
| // static
|
| void SerialConnection::DoClose(base::File port) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::FILE);
|
| // port closed by destructor.
|
| }
|
|
|
| void SerialConnection::OnReceiveTimeout() {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| io_handler_->CancelRead(api::serial::RECEIVE_ERROR_TIMEOUT);
|
| }
|
|
|
| void SerialConnection::OnSendTimeout() {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| io_handler_->CancelWrite(api::serial::SEND_ERROR_TIMEOUT);
|
| }
|
|
|
| void SerialConnection::OnAsyncReadComplete(const std::string& data,
|
| api::serial::ReceiveError error) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| DCHECK(!receive_complete_.is_null());
|
| ReceiveCompleteCallback callback = receive_complete_;
|
| receive_complete_.Reset();
|
| @@ -235,7 +235,7 @@ void SerialConnection::OnAsyncReadComplete(const std::string& data,
|
|
|
| void SerialConnection::OnAsyncWriteComplete(int bytes_sent,
|
| api::serial::SendError error) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| DCHECK(!send_complete_.is_null());
|
| SendCompleteCallback callback = send_complete_;
|
| send_complete_.Reset();
|
|
|