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 |