| OLD | NEW |
| (Empty) |
| 1 // Copyright 2013 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 "media/audio/mac/aggregate_device_manager.h" | |
| 6 | |
| 7 #include <CoreAudio/AudioHardware.h> | |
| 8 #include <string> | |
| 9 | |
| 10 #include "base/mac/mac_logging.h" | |
| 11 #include "base/mac/scoped_cftyperef.h" | |
| 12 #include "media/audio/audio_parameters.h" | |
| 13 #include "media/audio/mac/audio_manager_mac.h" | |
| 14 | |
| 15 using base::ScopedCFTypeRef; | |
| 16 | |
| 17 namespace media { | |
| 18 | |
| 19 AggregateDeviceManager::AggregateDeviceManager() | |
| 20 : plugin_id_(kAudioObjectUnknown), | |
| 21 input_device_(kAudioDeviceUnknown), | |
| 22 output_device_(kAudioDeviceUnknown), | |
| 23 aggregate_device_(kAudioObjectUnknown) { | |
| 24 } | |
| 25 | |
| 26 AggregateDeviceManager::~AggregateDeviceManager() { | |
| 27 DestroyAggregateDevice(); | |
| 28 } | |
| 29 | |
| 30 AudioDeviceID AggregateDeviceManager::GetDefaultAggregateDevice() { | |
| 31 AudioDeviceID current_input_device; | |
| 32 AudioDeviceID current_output_device; | |
| 33 AudioManagerMac::GetDefaultInputDevice(¤t_input_device); | |
| 34 AudioManagerMac::GetDefaultOutputDevice(¤t_output_device); | |
| 35 | |
| 36 if (AudioManagerMac::HardwareSampleRateForDevice(current_input_device) != | |
| 37 AudioManagerMac::HardwareSampleRateForDevice(current_output_device)) { | |
| 38 // TODO(crogers): with some extra work we can make aggregate devices work | |
| 39 // if the clock domain is the same but the sample-rate differ. | |
| 40 // For now we fallback to the synchronized path. | |
| 41 return kAudioDeviceUnknown; | |
| 42 } | |
| 43 | |
| 44 // Use a lazily created aggregate device if it's already available | |
| 45 // and still appropriate. | |
| 46 if (aggregate_device_ != kAudioObjectUnknown) { | |
| 47 // TODO(crogers): handle default device changes for synchronized I/O. | |
| 48 // For now, we check to make sure the default devices haven't changed | |
| 49 // since we lazily created the aggregate device. | |
| 50 if (current_input_device == input_device_ && | |
| 51 current_output_device == output_device_) | |
| 52 return aggregate_device_; | |
| 53 | |
| 54 // For now, once lazily created don't attempt to create another | |
| 55 // aggregate device. | |
| 56 return kAudioDeviceUnknown; | |
| 57 } | |
| 58 | |
| 59 input_device_ = current_input_device; | |
| 60 output_device_ = current_output_device; | |
| 61 | |
| 62 // Only create an aggregrate device if the clock domains match. | |
| 63 UInt32 input_clockdomain = GetClockDomain(input_device_); | |
| 64 UInt32 output_clockdomain = GetClockDomain(output_device_); | |
| 65 DVLOG(1) << "input_clockdomain: " << input_clockdomain; | |
| 66 DVLOG(1) << "output_clockdomain: " << output_clockdomain; | |
| 67 | |
| 68 if (input_clockdomain == 0 || input_clockdomain != output_clockdomain) | |
| 69 return kAudioDeviceUnknown; | |
| 70 | |
| 71 OSStatus result = CreateAggregateDevice( | |
| 72 input_device_, | |
| 73 output_device_, | |
| 74 &aggregate_device_); | |
| 75 if (result != noErr) | |
| 76 DestroyAggregateDevice(); | |
| 77 | |
| 78 return aggregate_device_; | |
| 79 } | |
| 80 | |
| 81 CFStringRef AggregateDeviceManager::GetDeviceUID(AudioDeviceID id) { | |
| 82 static const AudioObjectPropertyAddress kDeviceUIDAddress = { | |
| 83 kAudioDevicePropertyDeviceUID, | |
| 84 kAudioObjectPropertyScopeGlobal, | |
| 85 kAudioObjectPropertyElementMaster | |
| 86 }; | |
| 87 | |
| 88 // As stated in the CoreAudio header (AudioHardwareBase.h), | |
| 89 // the caller is responsible for releasing the device_UID. | |
| 90 CFStringRef device_UID; | |
| 91 UInt32 size = sizeof(device_UID); | |
| 92 OSStatus result = AudioObjectGetPropertyData( | |
| 93 id, | |
| 94 &kDeviceUIDAddress, | |
| 95 0, | |
| 96 0, | |
| 97 &size, | |
| 98 &device_UID); | |
| 99 | |
| 100 return (result == noErr) ? device_UID : NULL; | |
| 101 } | |
| 102 | |
| 103 void AggregateDeviceManager::GetDeviceName( | |
| 104 AudioDeviceID id, char* name, UInt32 size) { | |
| 105 static const AudioObjectPropertyAddress kDeviceNameAddress = { | |
| 106 kAudioDevicePropertyDeviceName, | |
| 107 kAudioObjectPropertyScopeGlobal, | |
| 108 kAudioObjectPropertyElementMaster | |
| 109 }; | |
| 110 | |
| 111 OSStatus result = AudioObjectGetPropertyData( | |
| 112 id, | |
| 113 &kDeviceNameAddress, | |
| 114 0, | |
| 115 0, | |
| 116 &size, | |
| 117 name); | |
| 118 | |
| 119 if (result != noErr && size > 0) | |
| 120 name[0] = 0; | |
| 121 } | |
| 122 | |
| 123 UInt32 AggregateDeviceManager::GetClockDomain(AudioDeviceID device_id) { | |
| 124 static const AudioObjectPropertyAddress kClockDomainAddress = { | |
| 125 kAudioDevicePropertyClockDomain, | |
| 126 kAudioObjectPropertyScopeGlobal, | |
| 127 kAudioObjectPropertyElementMaster | |
| 128 }; | |
| 129 | |
| 130 UInt32 clockdomain = 0; | |
| 131 UInt32 size = sizeof(UInt32); | |
| 132 OSStatus result = AudioObjectGetPropertyData( | |
| 133 device_id, | |
| 134 &kClockDomainAddress, | |
| 135 0, | |
| 136 0, | |
| 137 &size, | |
| 138 &clockdomain); | |
| 139 | |
| 140 return (result == noErr) ? clockdomain : 0; | |
| 141 } | |
| 142 | |
| 143 OSStatus AggregateDeviceManager::GetPluginID(AudioObjectID* id) { | |
| 144 DCHECK(id); | |
| 145 | |
| 146 // Get the audio hardware plugin. | |
| 147 CFStringRef bundle_name = CFSTR("com.apple.audio.CoreAudio"); | |
| 148 | |
| 149 AudioValueTranslation plugin_translation; | |
| 150 plugin_translation.mInputData = &bundle_name; | |
| 151 plugin_translation.mInputDataSize = sizeof(bundle_name); | |
| 152 plugin_translation.mOutputData = id; | |
| 153 plugin_translation.mOutputDataSize = sizeof(*id); | |
| 154 | |
| 155 static const AudioObjectPropertyAddress kPlugInAddress = { | |
| 156 kAudioHardwarePropertyPlugInForBundleID, | |
| 157 kAudioObjectPropertyScopeGlobal, | |
| 158 kAudioObjectPropertyElementMaster | |
| 159 }; | |
| 160 | |
| 161 UInt32 size = sizeof(plugin_translation); | |
| 162 OSStatus result = AudioObjectGetPropertyData( | |
| 163 kAudioObjectSystemObject, | |
| 164 &kPlugInAddress, | |
| 165 0, | |
| 166 0, | |
| 167 &size, | |
| 168 &plugin_translation); | |
| 169 | |
| 170 DVLOG(1) << "CoreAudio plugin ID: " << *id; | |
| 171 | |
| 172 return result; | |
| 173 } | |
| 174 | |
| 175 CFMutableDictionaryRef | |
| 176 AggregateDeviceManager::CreateAggregateDeviceDictionary( | |
| 177 AudioDeviceID input_id, | |
| 178 AudioDeviceID output_id) { | |
| 179 CFMutableDictionaryRef aggregate_device_dict = CFDictionaryCreateMutable( | |
| 180 NULL, | |
| 181 0, | |
| 182 &kCFTypeDictionaryKeyCallBacks, | |
| 183 &kCFTypeDictionaryValueCallBacks); | |
| 184 if (!aggregate_device_dict) | |
| 185 return NULL; | |
| 186 | |
| 187 const CFStringRef kAggregateDeviceName = | |
| 188 CFSTR("ChromeAggregateAudioDevice"); | |
| 189 const CFStringRef kAggregateDeviceUID = | |
| 190 CFSTR("com.google.chrome.AggregateAudioDevice"); | |
| 191 | |
| 192 // Add name and UID of the device to the dictionary. | |
| 193 CFDictionaryAddValue( | |
| 194 aggregate_device_dict, | |
| 195 CFSTR(kAudioAggregateDeviceNameKey), | |
| 196 kAggregateDeviceName); | |
| 197 CFDictionaryAddValue( | |
| 198 aggregate_device_dict, | |
| 199 CFSTR(kAudioAggregateDeviceUIDKey), | |
| 200 kAggregateDeviceUID); | |
| 201 | |
| 202 // Add a "private aggregate key" to the dictionary. | |
| 203 // The 1 value means that the created aggregate device will | |
| 204 // only be accessible from the process that created it, and | |
| 205 // won't be visible to outside processes. | |
| 206 int value = 1; | |
| 207 ScopedCFTypeRef<CFNumberRef> aggregate_device_number(CFNumberCreate( | |
| 208 NULL, | |
| 209 kCFNumberIntType, | |
| 210 &value)); | |
| 211 CFDictionaryAddValue( | |
| 212 aggregate_device_dict, | |
| 213 CFSTR(kAudioAggregateDeviceIsPrivateKey), | |
| 214 aggregate_device_number); | |
| 215 | |
| 216 return aggregate_device_dict; | |
| 217 } | |
| 218 | |
| 219 CFMutableArrayRef | |
| 220 AggregateDeviceManager::CreateSubDeviceArray( | |
| 221 CFStringRef input_device_UID, CFStringRef output_device_UID) { | |
| 222 CFMutableArrayRef sub_devices_array = CFArrayCreateMutable( | |
| 223 NULL, | |
| 224 0, | |
| 225 &kCFTypeArrayCallBacks); | |
| 226 | |
| 227 CFArrayAppendValue(sub_devices_array, input_device_UID); | |
| 228 CFArrayAppendValue(sub_devices_array, output_device_UID); | |
| 229 | |
| 230 return sub_devices_array; | |
| 231 } | |
| 232 | |
| 233 OSStatus AggregateDeviceManager::CreateAggregateDevice( | |
| 234 AudioDeviceID input_id, | |
| 235 AudioDeviceID output_id, | |
| 236 AudioDeviceID* aggregate_device) { | |
| 237 DCHECK(aggregate_device); | |
| 238 | |
| 239 const size_t kMaxDeviceNameLength = 256; | |
| 240 | |
| 241 scoped_ptr<char[]> input_device_name(new char[kMaxDeviceNameLength]); | |
| 242 GetDeviceName( | |
| 243 input_id, | |
| 244 input_device_name.get(), | |
| 245 sizeof(input_device_name)); | |
| 246 DVLOG(1) << "Input device: \n" << input_device_name; | |
| 247 | |
| 248 scoped_ptr<char[]> output_device_name(new char[kMaxDeviceNameLength]); | |
| 249 GetDeviceName( | |
| 250 output_id, | |
| 251 output_device_name.get(), | |
| 252 sizeof(output_device_name)); | |
| 253 DVLOG(1) << "Output device: \n" << output_device_name; | |
| 254 | |
| 255 OSStatus result = GetPluginID(&plugin_id_); | |
| 256 if (result != noErr) | |
| 257 return result; | |
| 258 | |
| 259 // Create a dictionary for the aggregate device. | |
| 260 ScopedCFTypeRef<CFMutableDictionaryRef> aggregate_device_dict( | |
| 261 CreateAggregateDeviceDictionary(input_id, output_id)); | |
| 262 if (!aggregate_device_dict) | |
| 263 return -1; | |
| 264 | |
| 265 // Create the aggregate device. | |
| 266 static const AudioObjectPropertyAddress kCreateAggregateDeviceAddress = { | |
| 267 kAudioPlugInCreateAggregateDevice, | |
| 268 kAudioObjectPropertyScopeGlobal, | |
| 269 kAudioObjectPropertyElementMaster | |
| 270 }; | |
| 271 | |
| 272 UInt32 size = sizeof(*aggregate_device); | |
| 273 result = AudioObjectGetPropertyData( | |
| 274 plugin_id_, | |
| 275 &kCreateAggregateDeviceAddress, | |
| 276 sizeof(aggregate_device_dict), | |
| 277 &aggregate_device_dict, | |
| 278 &size, | |
| 279 aggregate_device); | |
| 280 if (result != noErr) { | |
| 281 DLOG(ERROR) << "Error creating aggregate audio device!"; | |
| 282 return result; | |
| 283 } | |
| 284 | |
| 285 // Set the sub-devices for the aggregate device. | |
| 286 // In this case we use two: the input and output devices. | |
| 287 | |
| 288 ScopedCFTypeRef<CFStringRef> input_device_UID(GetDeviceUID(input_id)); | |
| 289 ScopedCFTypeRef<CFStringRef> output_device_UID(GetDeviceUID(output_id)); | |
| 290 if (!input_device_UID || !output_device_UID) { | |
| 291 DLOG(ERROR) << "Error getting audio device UID strings."; | |
| 292 return -1; | |
| 293 } | |
| 294 | |
| 295 ScopedCFTypeRef<CFMutableArrayRef> sub_devices_array( | |
| 296 CreateSubDeviceArray(input_device_UID, output_device_UID)); | |
| 297 if (sub_devices_array == NULL) { | |
| 298 DLOG(ERROR) << "Error creating sub-devices array."; | |
| 299 return -1; | |
| 300 } | |
| 301 | |
| 302 static const AudioObjectPropertyAddress kSetSubDevicesAddress = { | |
| 303 kAudioAggregateDevicePropertyFullSubDeviceList, | |
| 304 kAudioObjectPropertyScopeGlobal, | |
| 305 kAudioObjectPropertyElementMaster | |
| 306 }; | |
| 307 | |
| 308 size = sizeof(CFMutableArrayRef); | |
| 309 result = AudioObjectSetPropertyData( | |
| 310 *aggregate_device, | |
| 311 &kSetSubDevicesAddress, | |
| 312 0, | |
| 313 NULL, | |
| 314 size, | |
| 315 &sub_devices_array); | |
| 316 if (result != noErr) { | |
| 317 DLOG(ERROR) << "Error setting aggregate audio device sub-devices!"; | |
| 318 return result; | |
| 319 } | |
| 320 | |
| 321 // Use the input device as the master device. | |
| 322 static const AudioObjectPropertyAddress kSetMasterDeviceAddress = { | |
| 323 kAudioAggregateDevicePropertyMasterSubDevice, | |
| 324 kAudioObjectPropertyScopeGlobal, | |
| 325 kAudioObjectPropertyElementMaster | |
| 326 }; | |
| 327 | |
| 328 size = sizeof(CFStringRef); | |
| 329 result = AudioObjectSetPropertyData( | |
| 330 *aggregate_device, | |
| 331 &kSetMasterDeviceAddress, | |
| 332 0, | |
| 333 NULL, | |
| 334 size, | |
| 335 &input_device_UID); | |
| 336 if (result != noErr) { | |
| 337 DLOG(ERROR) << "Error setting aggregate audio device master device!"; | |
| 338 return result; | |
| 339 } | |
| 340 | |
| 341 DVLOG(1) << "New aggregate device: " << *aggregate_device; | |
| 342 return noErr; | |
| 343 } | |
| 344 | |
| 345 void AggregateDeviceManager::DestroyAggregateDevice() { | |
| 346 if (aggregate_device_ == kAudioObjectUnknown) | |
| 347 return; | |
| 348 | |
| 349 static const AudioObjectPropertyAddress kDestroyAddress = { | |
| 350 kAudioPlugInDestroyAggregateDevice, | |
| 351 kAudioObjectPropertyScopeGlobal, | |
| 352 kAudioObjectPropertyElementMaster | |
| 353 }; | |
| 354 | |
| 355 UInt32 size = sizeof(aggregate_device_); | |
| 356 OSStatus result = AudioObjectGetPropertyData( | |
| 357 plugin_id_, | |
| 358 &kDestroyAddress, | |
| 359 0, | |
| 360 NULL, | |
| 361 &size, | |
| 362 &aggregate_device_); | |
| 363 if (result != noErr) { | |
| 364 DLOG(ERROR) << "Error destroying aggregate audio device!"; | |
| 365 return; | |
| 366 } | |
| 367 | |
| 368 aggregate_device_ = kAudioObjectUnknown; | |
| 369 } | |
| 370 | |
| 371 } // namespace media | |
| OLD | NEW |