Fix BluetoothAdapterProfileChromeOS lifecycle management

device/bluetooth/bluetooth_adapter_chromeos.cc

 // Copyright 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 "device/bluetooth/bluetooth_adapter_chromeos.h"
 
 #include <string>
 
 #include "base/bind.h"
 #include "base/location.h"
@@ skipping 67 matching lines @@
 void BluetoothAdapterChromeOS::Shutdown() {
   if (dbus_is_shutdown_)
     return;
   DCHECK(DBusThreadManager::IsInitialized())
       << "Call BluetoothAdapterFactory::Shutdown() before "
          "DBusThreadManager::Shutdown().";
 
   if (IsPresent())
     RemoveAdapter();  // Also deletes devices_.
   DCHECK(devices_.empty());
+  // profiles_ should be empty because all BluetoothSockets have been signaled
+  // that this adapter is disappearing.
+  DCHECK(profiles_.empty());
+
+  for (auto& it : profile_queues_)
+    delete it.second;
+  profile_queues_.clear();
 
   DBusThreadManager::Get()->GetBluetoothAdapterClient()->RemoveObserver(this);
   DBusThreadManager::Get()->GetBluetoothDeviceClient()->RemoveObserver(this);
   DBusThreadManager::Get()->GetBluetoothInputClient()->RemoveObserver(this);
 
   VLOG(1) << "Unregistering pairing agent";
   DBusThreadManager::Get()->GetBluetoothAgentManagerClient()->UnregisterAgent(
       dbus::ObjectPath(kAgentPath), base::Bind(&base::DoNothing),
       base::Bind(&OnUnregisterAgentError));
 
@@ skipping 852 matching lines @@
 
 void BluetoothAdapterChromeOS::UseProfile(
     const BluetoothUUID& uuid,
     const dbus::ObjectPath& device_path,
     const BluetoothProfileManagerClient::Options& options,
     BluetoothProfileServiceProvider::Delegate* delegate,
     const ProfileRegisteredCallback& success_callback,
     const ErrorCompletionCallback& error_callback) {
   DCHECK(delegate);
 
+  if (!IsPresent()) {
+    VLOG(2) << "Adapter not present, erroring out";
+    error_callback.Run("Adapter not present");
+    return;
+  }
+
   if (profiles_.find(uuid) != profiles_.end()) {
     // TODO(jamuraa) check that the options are the same and error when they are
     // not.
     SetProfileDelegate(uuid, device_path, delegate, success_callback,
                        error_callback);
     return;
   }
 
-  profiles_[uuid] = BluetoothAdapterProfileChromeOS::Register(
-      this, uuid, options,
-      base::Bind(&BluetoothAdapterChromeOS::OnRegisterProfile, this, uuid,
+  if (profile_queues_.find(uuid) == profile_queues_.end()) {
+    BluetoothAdapterProfileChromeOS::Register(
+        uuid, options,
+        base::Bind(&BluetoothAdapterChromeOS::OnRegisterProfile, this, uuid),
+        base::Bind(&BluetoothAdapterChromeOS::OnRegisterProfileError, this,
+                   uuid));
+
+    profile_queues_[uuid] = new std::vector<RegisterProfileCompletionPair>();
+  }
+
+  profile_queues_[uuid]->push_back(std::make_pair(
+      base::Bind(&BluetoothAdapterChromeOS::SetProfileDelegate, this, uuid,
                  device_path, delegate, success_callback, error_callback),
-      base::Bind(&BluetoothAdapterChromeOS::OnRegisterProfileError, this, uuid,
-                 error_callback));
+      error_callback));
 }
 
-void BluetoothAdapterChromeOS::ReleaseProfile(const BluetoothUUID& uuid) {
+void BluetoothAdapterChromeOS::ReleaseProfile(
+    const dbus::ObjectPath& device_path,
+    BluetoothAdapterProfileChromeOS* profile) {
+  VLOG(2) << "Releasing Profile: " << profile->uuid().canonical_value()
+          << " from " << device_path.value();
+  profile->RemoveDelegate(
+      device_path, base::Bind(&BluetoothAdapterChromeOS::RemoveProfile,
+                              weak_ptr_factory_.GetWeakPtr(), profile->uuid()));
+}
+
+void BluetoothAdapterChromeOS::RemoveProfile(const BluetoothUUID& uuid) {
+  VLOG(2) << "Remove Profile: " << uuid.canonical_value();
+
   if (profiles_.find(uuid) != profiles_.end()) {
     delete profiles_[uuid];
     profiles_.erase(uuid);
   }
 }
 
 void BluetoothAdapterChromeOS::OnRegisterProfile(
     const BluetoothUUID& uuid,
+    scoped_ptr<BluetoothAdapterProfileChromeOS> profile) {
+  profiles_[uuid] = profile.release();
+
+  if (profile_queues_.find(uuid) == profile_queues_.end())
+    return;
+
+  for (auto& it : *profile_queues_[uuid])
+    it.first.Run();
+  delete profile_queues_[uuid];
+  profile_queues_.erase(uuid);
+}
+
+void BluetoothAdapterChromeOS::SetProfileDelegate(
+    const BluetoothUUID& uuid,
     const dbus::ObjectPath& device_path,
     BluetoothProfileServiceProvider::Delegate* delegate,
     const ProfileRegisteredCallback& success_callback,
     const ErrorCompletionCallback& error_callback) {
-  SetProfileDelegate(uuid, device_path, delegate, success_callback,
-                     error_callback);
-}
+  if (profiles_.find(uuid) == profiles_.end()) {
+    error_callback.Run("Cannot find profile!");
+    return;
+  }
 
-bool BluetoothAdapterChromeOS::SetProfileDelegate(
-    const BluetoothUUID& uuid,
-    const dbus::ObjectPath& device_path,
-    BluetoothProfileServiceProvider::Delegate* delegate,
-    const ProfileRegisteredCallback& success_callback,
-    const ErrorCompletionCallback& error_callback) {
   if (profiles_[uuid]->SetDelegate(device_path, delegate)) {
     success_callback.Run(profiles_[uuid]);
-    return true;
+    return;
   }
   // Already set
   error_callback.Run(bluetooth_agent_manager::kErrorAlreadyExists);
-  return false;
 }
 
 void BluetoothAdapterChromeOS::OnRegisterProfileError(
     const BluetoothUUID& uuid,
-    const ErrorCompletionCallback& error_callback,
     const std::string& error_name,
     const std::string& error_message) {
-  LOG(WARNING) << object_path_.value()
-               << ": Failed to register profile: " << error_name << ": "
-               << error_message;
-  error_callback.Run(error_message);
-  ReleaseProfile(uuid);
+  VLOG(2) << object_path_.value() << ": Failed to register profile: "
+          << error_name << ": " << error_message;
+  if (profile_queues_.find(uuid) == profile_queues_.end())
+    return;
+
+  for (auto& it : *profile_queues_[uuid])
+    it.second.Run(error_message);
+
+  delete profile_queues_[uuid];
+  profile_queues_.erase(uuid);
 }
 
 void BluetoothAdapterChromeOS::OnSetDiscoverable(
     const base::Closure& callback,
     const ErrorCallback& error_callback,
     bool success) {
   if (!IsPresent()) {
     error_callback.Run();
     return;
   }
@@ skipping 196 matching lines @@
 
     // If the queued request resulted in a pending call, then let it
     // asynchonously process the remaining queued requests once the pending
     // call returns.
     if (discovery_request_pending_)
       return;
   }
 }
 
 }  // namespace chromeos