Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "chromeos/dbus/bluetooth_media_endpoint_service_provider.h" | 5 #include "chromeos/dbus/bluetooth_media_endpoint_service_provider.h" |
| 6 | 6 |
| 7 #include <string> | |
| 8 | |
| 9 #include "base/bind.h" | 7 #include "base/bind.h" |
| 10 #include "base/logging.h" | 8 #include "base/logging.h" |
| 11 #include "base/memory/ref_counted.h" | 9 #include "base/memory/ref_counted.h" |
| 12 #include "base/memory/scoped_ptr.h" | 10 #include "base/memory/scoped_ptr.h" |
| 13 #include "base/threading/platform_thread.h" | 11 #include "base/threading/platform_thread.h" |
| 12 #include "chromeos/dbus/bluetooth_media_transport_client.h" | |
| 14 #include "chromeos/dbus/dbus_thread_manager.h" | 13 #include "chromeos/dbus/dbus_thread_manager.h" |
| 15 #include "chromeos/dbus/fake_bluetooth_media_endpoint_service_provider.h" | 14 #include "chromeos/dbus/fake_bluetooth_media_endpoint_service_provider.h" |
| 16 #include "dbus/bus.h" | 15 #include "dbus/bus.h" |
| 17 #include "dbus/exported_object.h" | 16 #include "dbus/exported_object.h" |
| 18 #include "dbus/message.h" | 17 #include "dbus/message.h" |
| 19 | 18 |
| 20 namespace { | 19 namespace { |
| 21 | 20 |
| 22 // TODO(mcchou): Move these constants to dbus/service_constants.h. | 21 // TODO(mcchou): Move these constants to dbus/service_constants.h. |
| 23 // Bluetooth Media Endpoint service identifier. | 22 // Bluetooth Media Endpoint service identifier. |
| 24 const char kBluetoothMediaEndpointInterface[] = "org.bluez.MediaEndpoint1"; | 23 const char kBluetoothMediaEndpointInterface[] = "org.bluez.MediaEndpoint1"; |
| 25 | 24 |
| 26 // Bluetooth Media Endpoint methods. | 25 // Method names in Bluetooth Media Endpoint interface. |
| 27 const char kSetConfiguration[] = "SetConfiguration"; | 26 const char kSetConfiguration[] = "SetConfiguration"; |
| 28 const char kSelectConfiguration[] = "SelectConfiguration"; | 27 const char kSelectConfiguration[] = "SelectConfiguration"; |
| 29 const char kClearConfiguration[] = "ClearConfiguration"; | 28 const char kClearConfiguration[] = "ClearConfiguration"; |
| 30 const char kRelease[] = "Release"; | 29 const char kRelease[] = "Release"; |
| 31 | 30 |
| 32 } // namespace | 31 } // namespace |
| 33 | 32 |
| 34 namespace chromeos { | 33 namespace chromeos { |
| 35 | 34 |
| 36 // The BluetoothMediaEndopintServiceProvider implementation used in production. | 35 // The BluetoothMediaEndopintServiceProvider implementation used in production. |
| (...skipping 74 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 111 } | 110 } |
| 112 | 111 |
| 113 // Called by dbus:: when the remote device connects to the Media Endpoint. | 112 // Called by dbus:: when the remote device connects to the Media Endpoint. |
| 114 void SetConfiguration(dbus::MethodCall* method_call, | 113 void SetConfiguration(dbus::MethodCall* method_call, |
| 115 dbus::ExportedObject::ResponseSender response_sender) { | 114 dbus::ExportedObject::ResponseSender response_sender) { |
| 116 DCHECK(OnOriginThread()); | 115 DCHECK(OnOriginThread()); |
| 117 DCHECK(delegate_); | 116 DCHECK(delegate_); |
| 118 | 117 |
| 119 dbus::MessageReader reader(method_call); | 118 dbus::MessageReader reader(method_call); |
| 120 dbus::ObjectPath transport_path; | 119 dbus::ObjectPath transport_path; |
| 121 dbus::MessageReader properties(method_call); | 120 dbus::MessageReader property_reader(method_call); |
| 122 if (!reader.PopObjectPath(&transport_path) || | 121 if (!reader.PopObjectPath(&transport_path) || |
| 123 !reader.PopArray(&properties)) { | 122 !reader.PopArray(&property_reader)) { |
| 124 LOG(WARNING) << "SetConfiguration called with incorrect parameters: " | 123 LOG(WARNING) << "SetConfiguration called with incorrect parameters: " |
| 125 << method_call->ToString(); | 124 << method_call->ToString(); |
| 126 return; | 125 return; |
| 127 } | 126 } |
| 128 | 127 |
| 128 // Parses |properties| and passes the property set as a | |
| 129 // Delegate::TransportProperties structure to |delegate_|. | |
|
armansito
2015/02/10 00:17:01
Some of the properties below are mandatory and som
Miao
2015/02/10 22:15:21
Done.
| |
| 130 Delegate::TransportProperties properties; | |
| 131 while (property_reader.HasMoreData()) { | |
| 132 dbus::MessageReader dict_entry_reader(nullptr); | |
| 133 std::string key; | |
| 134 if (!property_reader.PopDictEntry(&dict_entry_reader) || | |
| 135 !dict_entry_reader.PopString(&key)) { | |
| 136 LOG(WARNING) << "SetConfiguration called with incorrect parameters: " | |
| 137 << method_call->ToString(); | |
| 138 } else { | |
|
armansito
2015/02/10 00:17:01
nit: you can just continue with "else-if" here ins
Miao
2015/02/10 22:15:21
Done.
| |
| 139 if (key == BluetoothMediaTransportClient::kDeviceProperty) { | |
| 140 dict_entry_reader.PopVariantOfObjectPath(&properties.device); | |
| 141 } else if (key == BluetoothMediaTransportClient::kUUIDProperty) { | |
| 142 dict_entry_reader.PopVariantOfString(&properties.uuid); | |
| 143 } else if (key == BluetoothMediaTransportClient::kCodecProperty) { | |
| 144 dict_entry_reader.PopVariantOfByte(&properties.codec); | |
| 145 } else if (key == | |
| 146 BluetoothMediaTransportClient::kConfigurationProperty) { | |
| 147 dbus::MessageReader variant_reader(nullptr); | |
| 148 const uint8_t* bytes = nullptr; | |
| 149 size_t length = 0; | |
| 150 dict_entry_reader.PopVariant(&variant_reader); | |
| 151 variant_reader.PopArrayOfBytes(&bytes, &length); | |
| 152 properties.configuration = | |
| 153 std::vector<uint8_t>(bytes, bytes + length); | |
| 154 } else if (key == BluetoothMediaTransportClient::kStateProperty) { | |
| 155 dict_entry_reader.PopVariantOfString(&properties.state); | |
| 156 } else if (key == BluetoothMediaTransportClient::kDelayProperty) { | |
| 157 dict_entry_reader.PopVariantOfUint16(properties.delay.get()); | |
|
armansito
2015/02/10 00:17:01
These two won't work! You're passing a NULL pointe
Miao
2015/02/10 22:15:21
Done.
| |
| 158 } else if (key == BluetoothMediaTransportClient::kVolumeProperty) { | |
| 159 dict_entry_reader.PopVariantOfUint16(properties.volume.get()); | |
| 160 } | |
| 161 } | |
| 162 } | |
| 163 | |
| 129 delegate_->SetConfiguration(transport_path, properties); | 164 delegate_->SetConfiguration(transport_path, properties); |
| 130 | 165 |
| 131 response_sender.Run(dbus::Response::FromMethodCall(method_call)); | 166 response_sender.Run(dbus::Response::FromMethodCall(method_call)); |
| 132 } | 167 } |
| 133 | 168 |
| 134 // Called by dbus:: when the remote device receives the configuration for | 169 // Called by dbus:: when the remote device receives the configuration for |
| 135 // media transport. | 170 // media transport. |
| 136 void SelectConfiguration( | 171 void SelectConfiguration( |
| 137 dbus::MethodCall* method_call, | 172 dbus::MethodCall* method_call, |
| 138 dbus::ExportedObject::ResponseSender response_sender) { | 173 dbus::ExportedObject::ResponseSender response_sender) { |
| (...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 181 response_sender.Run(dbus::Response::FromMethodCall(method_call)); | 216 response_sender.Run(dbus::Response::FromMethodCall(method_call)); |
| 182 } | 217 } |
| 183 | 218 |
| 184 // Called by Bluetooth daemon to do the clean up after unregistering the Media | 219 // Called by Bluetooth daemon to do the clean up after unregistering the Media |
| 185 // Endpoint. | 220 // Endpoint. |
| 186 void Release(dbus::MethodCall* method_call, | 221 void Release(dbus::MethodCall* method_call, |
| 187 dbus::ExportedObject::ResponseSender response_sender) { | 222 dbus::ExportedObject::ResponseSender response_sender) { |
| 188 DCHECK(OnOriginThread()); | 223 DCHECK(OnOriginThread()); |
| 189 DCHECK(delegate_); | 224 DCHECK(delegate_); |
| 190 | 225 |
| 191 delegate_->Release(); | 226 delegate_->Released(); |
| 192 | 227 |
| 193 response_sender.Run(dbus::Response::FromMethodCall(method_call)); | 228 response_sender.Run(dbus::Response::FromMethodCall(method_call)); |
| 194 } | 229 } |
| 195 | 230 |
| 196 // Called by Delegate to response to a method requiring transport | 231 // Called by Delegate to response to a method requiring transport |
| 197 // configuration. | 232 // configuration. |
| 198 void OnConfiguration(dbus::MethodCall* method_call, | 233 void OnConfiguration(dbus::MethodCall* method_call, |
| 199 dbus::ExportedObject::ResponseSender response_sender, | 234 dbus::ExportedObject::ResponseSender response_sender, |
| 200 const std::vector<uint8_t>& configuration) { | 235 const std::vector<uint8_t>& configuration) { |
| 201 DCHECK(OnOriginThread()); | 236 DCHECK(OnOriginThread()); |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 234 // Weak pointer factory for generating 'this' printers that might live longer | 269 // Weak pointer factory for generating 'this' printers that might live longer |
| 235 // than we do. | 270 // than we do. |
| 236 // Note This should remain the last member so it'll be destroyed and | 271 // Note This should remain the last member so it'll be destroyed and |
| 237 // invalidate it's weak pointers before any other members are destroyed. | 272 // invalidate it's weak pointers before any other members are destroyed. |
| 238 base::WeakPtrFactory<BluetoothMediaEndpointServiceProviderImpl> | 273 base::WeakPtrFactory<BluetoothMediaEndpointServiceProviderImpl> |
| 239 weak_ptr_factory_; | 274 weak_ptr_factory_; |
| 240 | 275 |
| 241 DISALLOW_COPY_AND_ASSIGN(BluetoothMediaEndpointServiceProviderImpl); | 276 DISALLOW_COPY_AND_ASSIGN(BluetoothMediaEndpointServiceProviderImpl); |
| 242 }; | 277 }; |
| 243 | 278 |
| 279 BluetoothMediaEndpointServiceProvider::Delegate::TransportProperties:: | |
| 280 TransportProperties() : delay(nullptr), volume(nullptr) { | |
|
armansito
2015/02/10 00:17:01
You should assign a default value for codec and st
Miao
2015/02/10 22:15:21
Done. These default value can be used to check whe
| |
| 281 } | |
| 282 | |
| 283 BluetoothMediaEndpointServiceProvider::Delegate::TransportProperties:: | |
| 284 ~TransportProperties() { | |
| 285 } | |
| 286 | |
| 244 BluetoothMediaEndpointServiceProvider::BluetoothMediaEndpointServiceProvider() { | 287 BluetoothMediaEndpointServiceProvider::BluetoothMediaEndpointServiceProvider() { |
| 245 } | 288 } |
| 246 | 289 |
| 247 BluetoothMediaEndpointServiceProvider::~BluetoothMediaEndpointServiceProvider() | 290 BluetoothMediaEndpointServiceProvider:: |
| 248 {} | 291 ~BluetoothMediaEndpointServiceProvider() { |
| 292 } | |
| 249 | 293 |
| 250 BluetoothMediaEndpointServiceProvider* | 294 BluetoothMediaEndpointServiceProvider* |
| 251 BluetoothMediaEndpointServiceProvider::Create( | 295 BluetoothMediaEndpointServiceProvider::Create( |
| 252 dbus::Bus* bus, | 296 dbus::Bus* bus, |
| 253 const dbus::ObjectPath& object_path, | 297 const dbus::ObjectPath& object_path, |
| 254 Delegate* delegate) { | 298 Delegate* delegate) { |
| 255 // Returns a real implementation. | 299 // Returns a real implementation. |
| 256 if (!DBusThreadManager::Get()->IsUsingStub(DBusClientBundle::BLUETOOTH)) { | 300 if (!DBusThreadManager::Get()->IsUsingStub(DBusClientBundle::BLUETOOTH)) { |
| 257 return new BluetoothMediaEndpointServiceProviderImpl( | 301 return new BluetoothMediaEndpointServiceProviderImpl( |
| 258 bus, object_path, delegate); | 302 bus, object_path, delegate); |
| 259 } | 303 } |
| 260 // Returns a fake implementation. | 304 // Returns a fake implementation. |
| 261 return new FakeBluetoothMediaEndpointServiceProvider(object_path, delegate); | 305 return new FakeBluetoothMediaEndpointServiceProvider(object_path, delegate); |
| 262 } | 306 } |
| 263 | 307 |
| 264 } // namespace chromeos | 308 } // namespace chromeos |
| OLD | NEW |