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/serial_io_handler_posix.h" | 5 #include "device/serial/serial_io_handler_posix.h" |
6 | 6 |
7 #include <sys/ioctl.h> | 7 #include <sys/ioctl.h> |
8 #include <termios.h> | 8 #include <termios.h> |
9 | 9 |
10 #include "base/files/file_util.h" | 10 #include "base/files/file_util.h" |
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
106 #undef SPEED_TO_BITRATE_CASE | 106 #undef SPEED_TO_BITRATE_CASE |
107 } | 107 } |
108 #endif | 108 #endif |
109 | 109 |
110 } // namespace | 110 } // namespace |
111 | 111 |
112 namespace device { | 112 namespace device { |
113 | 113 |
114 // static | 114 // static |
115 scoped_refptr<SerialIoHandler> SerialIoHandler::Create( | 115 scoped_refptr<SerialIoHandler> SerialIoHandler::Create( |
116 scoped_refptr<base::SingleThreadTaskRunner> file_thread_task_runner, | |
117 scoped_refptr<base::SingleThreadTaskRunner> ui_thread_task_runner) { | 116 scoped_refptr<base::SingleThreadTaskRunner> ui_thread_task_runner) { |
118 return new SerialIoHandlerPosix(file_thread_task_runner, | 117 return new SerialIoHandlerPosix(ui_thread_task_runner); |
119 ui_thread_task_runner); | |
120 } | 118 } |
121 | 119 |
122 void SerialIoHandlerPosix::ReadImpl() { | 120 void SerialIoHandlerPosix::ReadImpl() { |
123 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); | 121 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
124 DCHECK(pending_read_buffer()); | 122 DCHECK(pending_read_buffer()); |
125 DCHECK(file().IsValid()); | 123 DCHECK(file().IsValid()); |
126 | 124 |
127 // Try to read immediately. This is needed because on some platforms | 125 // Try to read immediately. This is needed because on some platforms |
128 // (e.g., OSX) there may not be a notification from the message loop | 126 // (e.g., OSX) there may not be a notification from the message loop |
129 // when the fd is ready to read immediately after it is opened. There | 127 // when the fd is ready to read immediately after it is opened. There |
(...skipping 155 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
285 bool SerialIoHandlerPosix::PostOpen() { | 283 bool SerialIoHandlerPosix::PostOpen() { |
286 #if defined(OS_CHROMEOS) | 284 #if defined(OS_CHROMEOS) |
287 // The Chrome OS permission broker does not open devices in async mode. | 285 // The Chrome OS permission broker does not open devices in async mode. |
288 return base::SetNonBlocking(file().GetPlatformFile()); | 286 return base::SetNonBlocking(file().GetPlatformFile()); |
289 #else | 287 #else |
290 return true; | 288 return true; |
291 #endif | 289 #endif |
292 } | 290 } |
293 | 291 |
294 SerialIoHandlerPosix::SerialIoHandlerPosix( | 292 SerialIoHandlerPosix::SerialIoHandlerPosix( |
295 scoped_refptr<base::SingleThreadTaskRunner> file_thread_task_runner, | |
296 scoped_refptr<base::SingleThreadTaskRunner> ui_thread_task_runner) | 293 scoped_refptr<base::SingleThreadTaskRunner> ui_thread_task_runner) |
297 : SerialIoHandler(file_thread_task_runner, ui_thread_task_runner) {} | 294 : SerialIoHandler(ui_thread_task_runner) {} |
298 | 295 |
299 SerialIoHandlerPosix::~SerialIoHandlerPosix() { | 296 SerialIoHandlerPosix::~SerialIoHandlerPosix() { |
300 } | 297 } |
301 | 298 |
302 void SerialIoHandlerPosix::AttemptRead(bool within_read) { | 299 void SerialIoHandlerPosix::AttemptRead(bool within_read) { |
303 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); | 300 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
304 | 301 |
305 if (pending_read_buffer()) { | 302 if (pending_read_buffer()) { |
306 int bytes_read = HANDLE_EINTR(read(file().GetPlatformFile(), | 303 int bytes_read = HANDLE_EINTR(read(file().GetPlatformFile(), |
307 pending_read_buffer(), | 304 pending_read_buffer(), |
(...skipping 323 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
631 memcpy(buffer, chars_stashed_, std::min(new_bytes_read, 2)); | 628 memcpy(buffer, chars_stashed_, std::min(new_bytes_read, 2)); |
632 memcpy(chars_stashed_, tmp, num_chars_stashed_); | 629 memcpy(chars_stashed_, tmp, num_chars_stashed_); |
633 return new_bytes_read; | 630 return new_bytes_read; |
634 } | 631 } |
635 | 632 |
636 std::string SerialIoHandler::MaybeFixUpPortName(const std::string& port_name) { | 633 std::string SerialIoHandler::MaybeFixUpPortName(const std::string& port_name) { |
637 return port_name; | 634 return port_name; |
638 } | 635 } |
639 | 636 |
640 } // namespace device | 637 } // namespace device |
OLD | NEW |