DevTools: do not retain android_usb_devices in their manager.

chrome/browser/devtools/adb/android_usb_socket.cc

 // Copyright (c) 2013 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 "chrome/browser/devtools/adb/android_usb_socket.h"
 
 #include "base/message_loop/message_loop.h"
 
 namespace {
 
@@ skipping 15 matching lines @@
 
 AndroidUsbSocket::AndroidUsbSocket(scoped_refptr<AndroidUsbDevice> device,
                                    uint32 socket_id,
                                    const std::string& command,
                                    base::Callback<void(uint32)> delete_callback)
     : device_(device),
       command_(command),
       delete_callback_(delete_callback),
       local_id_(socket_id),
       remote_id_(0),
-      is_connected_(false),
-      is_closed_(false) {
+      is_connected_(false) {
 }
 
 AndroidUsbSocket::~AndroidUsbSocket() {
   DCHECK(CalledOnValidThread());
   if (is_connected_)
     Disconnect();
-  delete_callback_.Run(local_id_);
+  if (!delete_callback_.is_null())
+    delete_callback_.Run(local_id_);
 }
 
 void AndroidUsbSocket::HandleIncoming(scoped_refptr<AdbMessage> message) {
+  if (!device_)
+    return;
+
   CHECK_EQ(message->arg1, local_id_);
   switch (message->command) {
     case AdbMessage::kCommandOKAY:
       if (!is_connected_) {
         remote_id_ = message->arg0;
         is_connected_ = true;
         net::CompletionCallback callback = connect_callback_;
         connect_callback_.Reset();
         callback.Run(net::OK);
         // "this" can be NULL.
@@ skipping 14 matching lines @@
         callback.Run(net::OK);
         // "this" can be NULL.
       } else {
         RespondToReaders(false);
         // "this" can be NULL.
       }
       break;
     case AdbMessage::kCommandCLSE:
       if (is_connected_)
         device_->Send(AdbMessage::kCommandCLSE, local_id_, 0, "");
-      is_connected_ = false;
-      is_closed_ = true;
-      RespondToReaders(true);
+      Terminated();
       // "this" can be NULL.
       break;
     default:
       break;
   }
 }
 
 void AndroidUsbSocket::Terminated() {
   is_connected_ = false;
-  is_closed_ = true;
+
+  // Break the socket -> device connection, release the device.
+  delete_callback_.Run(local_id_);
+  delete_callback_.Reset();
+  device_ = NULL;
+
+  // Respond to pending callbacks.
   if (!connect_callback_.is_null()) {
     net::CompletionCallback callback = connect_callback_;
     connect_callback_.Reset();
     callback.Run(net::ERR_FAILED);
     // "this" can be NULL.
     return;
   }
   RespondToReaders(true);
 }
 
 int AndroidUsbSocket::Read(net::IOBuffer* buffer,
                            int length,
                            const net::CompletionCallback& callback) {
   if (!is_connected_)
-    return is_closed_ ? 0 : net::ERR_SOCKET_NOT_CONNECTED;
+    return device_ ? net::ERR_SOCKET_NOT_CONNECTED : 0;
 
   if (read_buffer_.empty()) {
     read_requests_.push_back(IORequest(buffer, length, callback));
     return net::ERR_IO_PENDING;
   }
 
   size_t bytes_to_copy = static_cast<size_t>(length) > read_buffer_.length() ?
       read_buffer_.length() : static_cast<size_t>(length);
   memcpy(buffer->data(), read_buffer_.data(), bytes_to_copy);
   if (read_buffer_.length() > bytes_to_copy)
@@ skipping 22 matching lines @@
   return net::ERR_NOT_IMPLEMENTED;
 }
 
 int AndroidUsbSocket::SetSendBufferSize(int32 size) {
   NOTIMPLEMENTED();
   return net::ERR_NOT_IMPLEMENTED;
 }
 
 int AndroidUsbSocket::Connect(const net::CompletionCallback& callback) {
   DCHECK(CalledOnValidThread());
-  if (device_->terminated())
+  if (!device_)
     return net::ERR_FAILED;
   connect_callback_ = callback;
   device_->Send(AdbMessage::kCommandOPEN, local_id_, 0, command_);
   return net::ERR_IO_PENDING;
 }
 
 void AndroidUsbSocket::Disconnect() {
-  is_connected_ = false;
+  if (!device_)
+    return;
   device_->Send(AdbMessage::kCommandCLSE, local_id_, remote_id_, "");
-  RespondToReaders(true);
+  Terminated();
 }
 
 bool AndroidUsbSocket::IsConnected() const {
   DCHECK(CalledOnValidThread());
   return is_connected_;
 }
 
 bool AndroidUsbSocket::IsConnectedAndIdle() const {
   NOTIMPLEMENTED();
   return false;
@@ skipping 64 matching lines @@
   }
 }
 
 void AndroidUsbSocket::RespondToWriters() {
   if (!write_requests_.empty()) {
     IORequest write_request = write_requests_.front();
     write_requests_.pop_front();
     write_request.callback.Run(write_request.length);
   }
 }