OLD | NEW |
(Empty) | |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. |
| 4 |
| 5 #include "device/bluetooth/dbus/bluetooth_gatt_application_service_provider_impl
.h" |
| 6 |
| 7 #include "base/bind.h" |
| 8 #include "base/logging.h" |
| 9 #include "third_party/cros_system_api/dbus/service_constants.h" |
| 10 |
| 11 namespace bluez { |
| 12 |
| 13 BluetoothGattApplicationServiceProviderImpl:: |
| 14 BluetoothGattApplicationServiceProviderImpl( |
| 15 dbus::Bus* bus, |
| 16 const dbus::ObjectPath& object_path, |
| 17 const std::map<dbus::ObjectPath, BluetoothLocalGattServiceBlueZ*>& |
| 18 services) |
| 19 : origin_thread_id_(base::PlatformThread::CurrentId()), |
| 20 bus_(bus), |
| 21 object_path_(object_path), |
| 22 weak_ptr_factory_(this) { |
| 23 VLOG(1) << "Creating Bluetooth GATT application: " << object_path_.value(); |
| 24 DCHECK(object_path_.IsValid()); |
| 25 DCHECK(bus_); |
| 26 |
| 27 exported_object_ = bus_->GetExportedObject(object_path_); |
| 28 |
| 29 exported_object_->ExportMethod( |
| 30 dbus::kDBusObjectManagerInterface, |
| 31 dbus::kDBusObjectManagerGetManagedObjects, |
| 32 base::Bind( |
| 33 &BluetoothGattApplicationServiceProviderImpl::GetManagedObjects, |
| 34 weak_ptr_factory_.GetWeakPtr()), |
| 35 base::Bind(&BluetoothGattApplicationServiceProviderImpl::OnExported, |
| 36 weak_ptr_factory_.GetWeakPtr())); |
| 37 |
| 38 BluetoothGattApplicationServiceProvider::CreateAttributeServiceProviders( |
| 39 bus, services, &service_providers_, &characteristic_providers_, |
| 40 &descriptor_providers_); |
| 41 } |
| 42 |
| 43 BluetoothGattApplicationServiceProviderImpl:: |
| 44 ~BluetoothGattApplicationServiceProviderImpl() { |
| 45 VLOG(1) << "Cleaning up Bluetooth GATT service: " << object_path_.value(); |
| 46 bus_->UnregisterExportedObject(object_path_); |
| 47 } |
| 48 |
| 49 bool BluetoothGattApplicationServiceProviderImpl::OnOriginThread() { |
| 50 return base::PlatformThread::CurrentId() == origin_thread_id_; |
| 51 } |
| 52 |
| 53 template <typename AttributeProvider> |
| 54 void BluetoothGattApplicationServiceProviderImpl::WriteObjectStruct( |
| 55 dbus::MessageWriter* writer, |
| 56 const std::string& attribute_interface, |
| 57 AttributeProvider* attribute_provider) { |
| 58 // Open a struct entry for { object_path : interface_list }. |
| 59 dbus::MessageWriter object_struct_writer(NULL); |
| 60 // [ (oa(sa{sv}) ] |
| 61 writer->OpenStruct(&object_struct_writer); |
| 62 |
| 63 // Key: Object path. [ (o ] |
| 64 object_struct_writer.AppendVariantOfObjectPath( |
| 65 attribute_provider->object_path()); |
| 66 |
| 67 // Value: Open array for single entry interface_list. [ a(sa{sv}) ] |
| 68 dbus::MessageWriter interface_array_writer(NULL); |
| 69 object_struct_writer.OpenArray("(sa{sv})", &interface_array_writer); |
| 70 WriteInterfaceStruct(&interface_array_writer, attribute_interface, |
| 71 attribute_provider); |
| 72 object_struct_writer.CloseContainer(&interface_array_writer); |
| 73 |
| 74 writer->CloseContainer(&object_struct_writer); |
| 75 } |
| 76 |
| 77 template <typename AttributeProvider> |
| 78 void BluetoothGattApplicationServiceProviderImpl::WriteInterfaceStruct( |
| 79 dbus::MessageWriter* writer, |
| 80 const std::string& attribute_interface, |
| 81 AttributeProvider* attribute_provider) { |
| 82 // Open a struct entry for { interface_name : properties_list }. |
| 83 dbus::MessageWriter interface_struct_writer(NULL); |
| 84 // [ (sa{sv}) ] |
| 85 writer->OpenStruct(&interface_struct_writer); |
| 86 |
| 87 // Key: Interface name. [ (s ] |
| 88 interface_struct_writer.AppendVariantOfString(attribute_interface); |
| 89 // Value: Open a array for properties_list. [ a{sv}) ] |
| 90 WriteAttributeProperties(&interface_struct_writer, attribute_provider); |
| 91 writer->CloseContainer(&interface_struct_writer); |
| 92 } |
| 93 |
| 94 void BluetoothGattApplicationServiceProviderImpl::WriteAttributeProperties( |
| 95 dbus::MessageWriter* writer, |
| 96 BluetoothGattServiceServiceProvider* service_provider) { |
| 97 service_provider->WriteProperties(writer); |
| 98 } |
| 99 |
| 100 void BluetoothGattApplicationServiceProviderImpl::WriteAttributeProperties( |
| 101 dbus::MessageWriter* writer, |
| 102 BluetoothGattCharacteristicServiceProvider* characteristic_provider) { |
| 103 characteristic_provider->WriteProperties(writer, nullptr); |
| 104 } |
| 105 |
| 106 void BluetoothGattApplicationServiceProviderImpl::WriteAttributeProperties( |
| 107 dbus::MessageWriter* writer, |
| 108 BluetoothGattDescriptorServiceProvider* descriptor_provider) { |
| 109 descriptor_provider->WriteProperties(writer, nullptr); |
| 110 } |
| 111 |
| 112 void BluetoothGattApplicationServiceProviderImpl::GetManagedObjects( |
| 113 dbus::MethodCall* method_call, |
| 114 dbus::ExportedObject::ResponseSender response_sender) { |
| 115 VLOG(2) << "BluetoothGattApplicationServiceProvider::GetManagedObjects: " |
| 116 << object_path_.value(); |
| 117 DCHECK(OnOriginThread()); |
| 118 |
| 119 dbus::MessageReader reader(method_call); |
| 120 |
| 121 std::unique_ptr<dbus::Response> response = |
| 122 dbus::Response::FromMethodCall(method_call); |
| 123 |
| 124 // The expected format by GetAll is [ a(oa(sa{sv})) ] |
| 125 dbus::MessageWriter writer(response.get()); |
| 126 dbus::MessageWriter array_writer(nullptr); |
| 127 |
| 128 writer.OpenArray("(oa(sa{sv}))", &array_writer); |
| 129 |
| 130 for (const auto& service_provider : service_providers_) { |
| 131 WriteObjectStruct(&array_writer, |
| 132 bluetooth_gatt_service::kBluetoothGattServiceInterface, |
| 133 service_provider.get()); |
| 134 } |
| 135 for (const auto& characteristic_provider : characteristic_providers_) { |
| 136 WriteObjectStruct( |
| 137 &array_writer, |
| 138 bluetooth_gatt_characteristic::kBluetoothGattCharacteristicInterface, |
| 139 characteristic_provider.get()); |
| 140 } |
| 141 for (const auto& descriptor_provider : descriptor_providers_) { |
| 142 WriteObjectStruct( |
| 143 &array_writer, |
| 144 bluetooth_gatt_descriptor::kBluetoothGattDescriptorInterface, |
| 145 descriptor_provider.get()); |
| 146 } |
| 147 |
| 148 writer.CloseContainer(&array_writer); |
| 149 |
| 150 response_sender.Run(std::move(response)); |
| 151 } |
| 152 |
| 153 // Called by dbus:: when a method is exported. |
| 154 void BluetoothGattApplicationServiceProviderImpl::OnExported( |
| 155 const std::string& interface_name, |
| 156 const std::string& method_name, |
| 157 bool success) { |
| 158 LOG_IF(WARNING, !success) << "Failed to export " << interface_name << "." |
| 159 << method_name; |
| 160 } |
| 161 |
| 162 } // namespace bluez |
OLD | NEW |