Implement the host side of serial connection I/O on data pipe.

device/serial/test_serial_io_handler.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "device/serial/test_serial_io_handler.h"
 
+#include <algorithm>
+
 #include "base/bind.h"
 #include "device/serial/serial.mojom.h"
 
 namespace device {
 
 TestSerialIoHandler::TestSerialIoHandler()
     : SerialIoHandler(NULL),
       opened_(false),
       dtr_(false),
       rts_(false),
@@ skipping 20 matching lines @@
   if (options.parity_bit != serial::PARITY_BIT_NONE)
     info_.parity_bit = options.parity_bit;
   if (options.stop_bits != serial::STOP_BITS_NONE)
     info_.stop_bits = options.stop_bits;
   if (options.has_cts_flow_control)
     info_.cts_flow_control = options.cts_flow_control;
   return true;
 }
 
 void TestSerialIoHandler::ReadImpl() {
+  if (!pending_read_buffer())
+    return;
+  if (buffer_.empty())
+    return;
+
+  size_t num_bytes =
+      std::min(buffer_.size(), static_cast<size_t>(pending_read_buffer_len()));
+  memcpy(pending_read_buffer(), buffer_.c_str(), num_bytes);
+  buffer_ = buffer_.substr(num_bytes);
+  ReadCompleted(static_cast<uint32_t>(num_bytes), serial::RECEIVE_ERROR_NONE);
 }
 
 void TestSerialIoHandler::CancelReadImpl() {
-  QueueReadCompleted(0, read_cancel_reason());
+  ReadCompleted(0, read_cancel_reason());
 }
 
 void TestSerialIoHandler::WriteImpl() {
-  DCHECK(pending_read_buffer());
-  DCHECK_LE(pending_write_buffer_len(), pending_read_buffer_len());
-  memcpy(pending_read_buffer(),
-         pending_write_buffer(),
-         pending_write_buffer_len());
-  QueueReadCompleted(pending_write_buffer_len(), serial::RECEIVE_ERROR_NONE);
-  QueueWriteCompleted(pending_write_buffer_len(), serial::SEND_ERROR_NONE);
+  if (!send_callback_.is_null()) {
+    base::Closure callback = send_callback_;
+    send_callback_.Reset();
+    callback.Run();
+    return;
+  }
+  buffer_ += std::string(pending_write_buffer(), pending_write_buffer_len());
+  WriteCompleted(pending_write_buffer_len(), serial::SEND_ERROR_NONE);
+  if (pending_read_buffer())
+    ReadImpl();
 }
 
 void TestSerialIoHandler::CancelWriteImpl() {
-  QueueWriteCompleted(0, write_cancel_reason());
+  WriteCompleted(0, write_cancel_reason());
 }
 
 serial::DeviceControlSignalsPtr TestSerialIoHandler::GetControlSignals() const {
   serial::DeviceControlSignalsPtr signals(serial::DeviceControlSignals::New());
   *signals = device_control_signals_;
   return signals.Pass();
 }
 
 serial::ConnectionInfoPtr TestSerialIoHandler::GetPortInfo() const {
   serial::ConnectionInfoPtr info(serial::ConnectionInfo::New());
@@ skipping 12 matching lines @@
     dtr_ = signals.dtr;
   if (signals.has_rts)
     rts_ = signals.rts;
   return true;
 }
 
 TestSerialIoHandler::~TestSerialIoHandler() {
 }
 
 }  // namespace device