Support HTTP test-server based net unit tests on Android.

tools/android/forwarder2/host_controller.cc

 // Copyright (c) 2012 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 "tools/android/forwarder2/host_controller.h"
 
 #include <string>
 
 #include "base/logging.h"
 #include "base/memory/scoped_ptr.h"
@@ skipping 17 matching lines @@
   adb_control_socket_.set_exit_notifier_fd(exit_notifier_fd);
 }
 
 HostController::~HostController() {
 }
 
 void HostController::StartForwarder(
     scoped_ptr<Socket> host_server_data_socket) {
   scoped_ptr<Socket> adb_data_socket(new Socket);
   if (!adb_data_socket->ConnectTcp("", adb_port_)) {
-    LOG(ERROR) << "Could not Connect AdbDataSocket on port: "
+    LOG(ERROR) << "Could not connect AdbDataSocket on port: "
                << adb_port_;
     return;
   }
   // Open the Adb data connection, and send a command with the
   // |device_forward_port| as a way for the device to identify the connection.
   SendCommand(command::DATA_CONNECTION,
               device_port_,
               adb_data_socket.get());
 
   // Check that the device received the new Adb Data Connection.  Observe that
   // this check is done through the |adb_control_socket_| that is handled in the
   // DeviceListener thread just after the call to WaitForAdbDataSocket().
   if (!ReceivedCommand(command::ADB_DATA_SOCKET_SUCCESS,
                        &adb_control_socket_)) {
     LOG(ERROR) << "Device could not handle the new Adb Data Connection.";
     host_server_data_socket->Close();
     adb_data_socket->Close();
     return;
   }
   Forwarder* forwarder = new Forwarder(host_server_data_socket.Pass(),
                                        adb_data_socket.Pass());
   // Forwarder object will self delete after returning.
   forwarder->Start();
 }
 
 bool HostController::Connect() {
   if (!adb_control_socket_.ConnectTcp("", adb_port_)) {
-    LOG(ERROR) << "Could not Connect HostController socket on port: "
+    LOG(ERROR) << "Could not connect HostController socket on port: "
                << adb_port_;
     return false;
   }
   // Send the command to the device start listening to the "device_forward_port"
   bool send_command_success = SendCommand(
       command::LISTEN, device_port_, &adb_control_socket_);
   CHECK(send_command_success);
   int device_port_allocated;
   command::Type command;
   if (!ReadCommand(&adb_control_socket_, &device_port_allocated, &command) ||
       command != command::BIND_SUCCESS) {
     LOG(ERROR) << "Device binding error using port " << device_port_;
     adb_control_socket_.Close();
     return false;
   }
   // When doing dynamically allocation of port, we get the port from the
   // BIND_SUCCESS command we received above.
   device_port_ = device_port_allocated;
   ready_ = true;
   return true;
 }
 
 void HostController::Run() {
   CHECK(ready_) << "HostController not ready. Must call Connect() first.";
   while (true) {
     if (!ReceivedCommand(command::ACCEPT_SUCCESS,
                          &adb_control_socket_)) {
+      // TODO(pliard): This can also happen if device_forwarder was
+      // intentionally killed before host_forwarder. In that case,
+      // device_forwarder should send a notification to the host.  Currently the
+      // error message below is always emitted to the log file although this is
+      // not necessarily an error.
       LOG(ERROR) << "Device socket error on accepting using port "
                  << device_port_;
       break;
     }
     // Try to connect to host server.
     scoped_ptr<Socket> host_server_data_socket(new Socket);
     host_server_data_socket->set_exit_notifier_fd(exit_notifier_fd_);
     if (!host_server_data_socket->ConnectTcp(
             forward_to_host_, forward_to_host_port_)) {
       LOG(ERROR) << "Could not Connect HostServerData socket on port: "
@@ skipping 12 matching lines @@
     }
     SendCommand(command::HOST_SERVER_SUCCESS,
                 device_port_,
                 &adb_control_socket_);
     StartForwarder(host_server_data_socket.Pass());
   }
   adb_control_socket_.Close();
 }
 
 }  // namespace forwarder2