DevTools: Partially redesigned DevToolsAndroidBridge and AndroidDeviceManager

chrome/browser/devtools/device/adb/mock_adb_server.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 "base/strings/string_number_conversions.h"
 #include "base/strings/string_util.h"
 #include "base/strings/stringprintf.h"
 #include "base/threading/non_thread_safe.h"
 #include "content/public/browser/browser_thread.h"
 #include "content/public/test/browser_test.h"
@@ skipping 453 matching lines @@
   void ProcessCommand(const std::string& command) {
     CHECK(CalledOnValidThread());
     if (command == "host:devices") {
       SendResponse(base::StringPrintf("%s\tdevice\n%s\toffline",
                                       kSerialOnline,
                                       kSerialOffline));
     } else if (command.find(kHostTransportPrefix) == 0) {
       selected_device_ = command.substr(strlen(kHostTransportPrefix));
       SendResponse("");
     } else if (selected_device_ != kSerialOnline) {
-      NOTREACHED() << "Unknown device - " << selected_device_;
+      Send("FAIL", "device offline (x)");
     } else if (command == kDeviceModelCommand) {
       SendResponse(kDeviceModel);
     } else if (command == kOpenedUnixSocketsCommand) {
       SendResponse(kSampleOpenedUnixSockets);
     } else if (command == kDumpsysCommand) {
       SendResponse(kSampleDumpsys);
     } else if (command == kListProcessesCommand) {
       SendResponse(kSampleListProcesses);
     } else if (command == kInstalledChromePackagesCommand) {
       SendResponse(kSampleListPackages);
     } else if (command.find(kLocalAbstractPrefix) == 0) {
       selected_socket_ = command.substr(strlen(kLocalAbstractPrefix));
       SendResponse("");
     } else {
       NOTREACHED() << "Unknown command - " << command;
     }
   }
 
-  void SendResponse(const std::string& response) {
+  void SendResponse(const std::string& response) { Send("OKAY", response); }
+
+  void Send(const std::string& status, const std::string& response) {
     CHECK(CalledOnValidThread());
+    CHECK_EQ(4U, status.size());
+
     std::stringstream response_stream;
-    response_stream << "OKAY";
+    response_stream << status;
 
     int size = response.size();
     if (size > 0) {
       static const char kHexChars[] = "0123456789ABCDEF";
       for (int i = 3; i >= 0; i--)
         response_stream << kHexChars[ (size >> 4*i) & 0x0f ];
       response_stream << response;
     }
 
     server_->Send(response_stream.str());
@@ skipping 41 matching lines @@
 
 void StopMockAdbServer() {
   BrowserThread::PostTaskAndReply(
       BrowserThread::IO,
       FROM_HERE,
       base::Bind(&StopMockAdbServerOnIOThread),
       base::MessageLoop::QuitClosure());
   content::RunMessageLoop();
 }