| 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 <windows.h> | 5 #include <windows.h> |
| 6 | 6 |
| 7 #include "device/serial/serial_io_handler_win.h" | 7 #include "device/serial/serial_io_handler_win.h" |
| 8 | 8 |
| 9 namespace device { | 9 namespace device { |
| 10 | 10 |
| (...skipping 116 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 127 case ONESTOPBIT: | 127 case ONESTOPBIT: |
| 128 default: | 128 default: |
| 129 return serial::STOP_BITS_ONE; | 129 return serial::STOP_BITS_ONE; |
| 130 } | 130 } |
| 131 } | 131 } |
| 132 | 132 |
| 133 } // namespace | 133 } // namespace |
| 134 | 134 |
| 135 // static | 135 // static |
| 136 scoped_refptr<SerialIoHandler> SerialIoHandler::Create( | 136 scoped_refptr<SerialIoHandler> SerialIoHandler::Create( |
| 137 scoped_refptr<base::MessageLoopProxy> file_thread_message_loop) { | 137 scoped_refptr<base::MessageLoopProxy> file_thread_message_loop, |
| 138 return new SerialIoHandlerWin(file_thread_message_loop); | 138 scoped_refptr<base::MessageLoopProxy> ui_thread_message_loop) { |
| 139 return new SerialIoHandlerWin(file_thread_message_loop, |
| 140 ui_thread_message_loop); |
| 139 } | 141 } |
| 140 | 142 |
| 141 bool SerialIoHandlerWin::PostOpen() { | 143 bool SerialIoHandlerWin::PostOpen() { |
| 142 DCHECK(!comm_context_); | 144 DCHECK(!comm_context_); |
| 143 DCHECK(!read_context_); | 145 DCHECK(!read_context_); |
| 144 DCHECK(!write_context_); | 146 DCHECK(!write_context_); |
| 145 | 147 |
| 146 base::MessageLoopForIO::current()->RegisterIOHandler(file().GetPlatformFile(), | 148 base::MessageLoopForIO::current()->RegisterIOHandler(file().GetPlatformFile(), |
| 147 this); | 149 this); |
| 148 | 150 |
| (...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 232 ::CancelIo(file().GetPlatformFile()); | 234 ::CancelIo(file().GetPlatformFile()); |
| 233 } | 235 } |
| 234 | 236 |
| 235 void SerialIoHandlerWin::CancelWriteImpl() { | 237 void SerialIoHandlerWin::CancelWriteImpl() { |
| 236 DCHECK(CalledOnValidThread()); | 238 DCHECK(CalledOnValidThread()); |
| 237 DCHECK(file().IsValid()); | 239 DCHECK(file().IsValid()); |
| 238 ::CancelIo(file().GetPlatformFile()); | 240 ::CancelIo(file().GetPlatformFile()); |
| 239 } | 241 } |
| 240 | 242 |
| 241 SerialIoHandlerWin::SerialIoHandlerWin( | 243 SerialIoHandlerWin::SerialIoHandlerWin( |
| 242 scoped_refptr<base::MessageLoopProxy> file_thread_message_loop) | 244 scoped_refptr<base::MessageLoopProxy> file_thread_message_loop, |
| 243 : SerialIoHandler(file_thread_message_loop), | 245 scoped_refptr<base::MessageLoopProxy> ui_thread_message_loop) |
| 246 : SerialIoHandler(file_thread_message_loop, ui_thread_message_loop), |
| 244 event_mask_(0), | 247 event_mask_(0), |
| 245 is_comm_pending_(false) { | 248 is_comm_pending_(false) { |
| 246 } | 249 } |
| 247 | 250 |
| 248 SerialIoHandlerWin::~SerialIoHandlerWin() { | 251 SerialIoHandlerWin::~SerialIoHandlerWin() { |
| 249 } | 252 } |
| 250 | 253 |
| 251 void SerialIoHandlerWin::OnIOCompleted( | 254 void SerialIoHandlerWin::OnIOCompleted( |
| 252 base::MessageLoopForIO::IOContext* context, | 255 base::MessageLoopForIO::IOContext* context, |
| 253 DWORD bytes_transferred, | 256 DWORD bytes_transferred, |
| (...skipping 122 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 376 std::string SerialIoHandler::MaybeFixUpPortName(const std::string& port_name) { | 379 std::string SerialIoHandler::MaybeFixUpPortName(const std::string& port_name) { |
| 377 // For COM numbers less than 9, CreateFile is called with a string such as | 380 // For COM numbers less than 9, CreateFile is called with a string such as |
| 378 // "COM1". For numbers greater than 9, a prefix of "\\\\.\\" must be added. | 381 // "COM1". For numbers greater than 9, a prefix of "\\\\.\\" must be added. |
| 379 if (port_name.length() > std::string("COM9").length()) | 382 if (port_name.length() > std::string("COM9").length()) |
| 380 return std::string("\\\\.\\").append(port_name); | 383 return std::string("\\\\.\\").append(port_name); |
| 381 | 384 |
| 382 return port_name; | 385 return port_name; |
| 383 } | 386 } |
| 384 | 387 |
| 385 } // namespace device | 388 } // namespace device |
| OLD | NEW |