74b61b1290b6e5812d95e8ed6978af3185458dae
[ardour.git] / libs / ardour / audio_unit.cc
1 /*
2     Copyright (C) 2006-2009 Paul Davis
3     Some portions Copyright (C) Sophia Poirier.
4
5     This program is free software; you can redistribute it and/or modify
6     it under the terms of the GNU General Public License as published by
7     the Free Software Foundation; either version 2 of the License, or
8     (at your option) any later version.
9
10     This program is distributed in the hope that it will be useful,
11     but WITHOUT ANY WARRANTY; without even the implied warranty of
12     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13     GNU General Public License for more details.
14
15     You should have received a copy of the GNU General Public License
16     along with this program; if not, write to the Free Software
17     Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
18
19 */
20
21 #include <sstream>
22 #include <fstream>
23 #include <errno.h>
24 #include <string.h>
25 #include <math.h>
26 #include <ctype.h>
27
28 #include "pbd/gstdio_compat.h"
29 #include "pbd/transmitter.h"
30 #include "pbd/xml++.h"
31 #include "pbd/convert.h"
32 #include "pbd/whitespace.h"
33 #include "pbd/file_utils.h"
34 #include "pbd/locale_guard.h"
35
36 #include <glibmm/threads.h>
37 #include <glibmm/fileutils.h>
38 #include <glibmm/miscutils.h>
39
40 #include "ardour/ardour.h"
41 #include "ardour/audioengine.h"
42 #include "ardour/audio_buffer.h"
43 #include "ardour/debug.h"
44 #include "ardour/midi_buffer.h"
45 #include "ardour/filesystem_paths.h"
46 #include "ardour/io.h"
47 #include "ardour/audio_unit.h"
48 #include "ardour/route.h"
49 #include "ardour/session.h"
50 #include "ardour/tempo.h"
51 #include "ardour/utils.h"
52
53 #include "CAAudioUnit.h"
54 #include "CAAUParameter.h"
55
56 #include <CoreFoundation/CoreFoundation.h>
57 #include <CoreServices/CoreServices.h>
58 #include <AudioUnit/AudioUnit.h>
59 #include <AudioToolbox/AudioUnitUtilities.h>
60 #ifdef WITH_CARBON
61 #include <Carbon/Carbon.h>
62 #endif
63
64 #ifdef COREAUDIO105
65 #define ArdourComponent Component
66 #define ArdourDescription ComponentDescription
67 #define ArdourFindNext FindNextComponent
68 #else
69 #define ArdourComponent AudioComponent
70 #define ArdourDescription AudioComponentDescription
71 #define ArdourFindNext AudioComponentFindNext
72 #endif
73
74 #include "i18n.h"
75
76 using namespace std;
77 using namespace PBD;
78 using namespace ARDOUR;
79
80 AUPluginInfo::CachedInfoMap AUPluginInfo::cached_info;
81
82 static string preset_search_path = "/Library/Audio/Presets:/Network/Library/Audio/Presets";
83 static string preset_suffix = ".aupreset";
84 static bool preset_search_path_initialized = false;
85 FILE * AUPluginInfo::_crashlog_fd = NULL;
86 bool AUPluginInfo::_scan_only = true;
87
88
89 static void au_blacklist (std::string id)
90 {
91         string fn = Glib::build_filename (ARDOUR::user_cache_directory(), "au_blacklist.txt");
92         FILE * blacklist_fd = NULL;
93         if (! (blacklist_fd = fopen(fn.c_str(), "a"))) {
94                 PBD::error << "Cannot append to AU blacklist for '"<< id <<"'\n";
95                 return;
96         }
97         assert(id.find("\n") == string::npos);
98         fprintf(blacklist_fd, "%s\n", id.c_str());
99         ::fclose(blacklist_fd);
100 }
101
102 static void au_unblacklist (std::string id)
103 {
104         string fn = Glib::build_filename (ARDOUR::user_cache_directory(), "au_blacklist.txt");
105         if (!Glib::file_test (fn, Glib::FILE_TEST_EXISTS)) {
106                 PBD::warning << "Expected Blacklist file does not exist.\n";
107                 return;
108         }
109
110         std::string bl;
111         {
112                 std::ifstream ifs(fn.c_str());
113                 bl.assign ((std::istreambuf_iterator<char>(ifs)), (std::istreambuf_iterator<char>()));
114         }
115
116         ::g_unlink (fn.c_str());
117
118         assert (!Glib::file_test (fn, Glib::FILE_TEST_EXISTS));
119         assert(id.find("\n") == string::npos);
120
121         id += "\n"; // add separator
122         const size_t rpl = bl.find(id);
123         if (rpl != string::npos) {
124                 bl.replace(rpl, id.size(), "");
125         }
126         if (bl.empty()) {
127                 return;
128         }
129
130         FILE * blacklist_fd = NULL;
131         if (! (blacklist_fd = fopen(fn.c_str(), "w"))) {
132                 PBD::error << "Cannot open AU blacklist.\n";
133                 return;
134         }
135         fprintf(blacklist_fd, "%s", bl.c_str());
136         ::fclose(blacklist_fd);
137 }
138
139 static bool is_blacklisted (std::string id)
140 {
141         string fn = Glib::build_filename (ARDOUR::user_cache_directory(), "au_blacklist.txt");
142         if (!Glib::file_test (fn, Glib::FILE_TEST_EXISTS)) {
143                 return false;
144         }
145         std::string bl;
146         std::ifstream ifs(fn.c_str());
147         bl.assign ((std::istreambuf_iterator<char>(ifs)), (std::istreambuf_iterator<char>()));
148
149         assert(id.find("\n") == string::npos);
150
151         id += "\n"; // add separator
152         const size_t rpl = bl.find(id);
153         if (rpl != string::npos) {
154                 return true;
155         }
156         return false;
157 }
158
159
160
161 static OSStatus
162 _render_callback(void *userData,
163                  AudioUnitRenderActionFlags *ioActionFlags,
164                  const AudioTimeStamp    *inTimeStamp,
165                  UInt32       inBusNumber,
166                  UInt32       inNumberFrames,
167                  AudioBufferList*       ioData)
168 {
169         if (userData) {
170                 return ((AUPlugin*)userData)->render_callback (ioActionFlags, inTimeStamp, inBusNumber, inNumberFrames, ioData);
171         }
172         return paramErr;
173 }
174
175 static OSStatus
176 _get_beat_and_tempo_callback (void*    userData,
177                               Float64* outCurrentBeat,
178                               Float64* outCurrentTempo)
179 {
180         if (userData) {
181                 return ((AUPlugin*)userData)->get_beat_and_tempo_callback (outCurrentBeat, outCurrentTempo);
182         }
183
184         return paramErr;
185 }
186
187 static OSStatus
188 _get_musical_time_location_callback (void *     userData,
189                                      UInt32 *   outDeltaSampleOffsetToNextBeat,
190                                      Float32 *  outTimeSig_Numerator,
191                                      UInt32 *   outTimeSig_Denominator,
192                                      Float64 *  outCurrentMeasureDownBeat)
193 {
194         if (userData) {
195                 return ((AUPlugin*)userData)->get_musical_time_location_callback (outDeltaSampleOffsetToNextBeat,
196                                                                                   outTimeSig_Numerator,
197                                                                                   outTimeSig_Denominator,
198                                                                                   outCurrentMeasureDownBeat);
199         }
200         return paramErr;
201 }
202
203 static OSStatus
204 _get_transport_state_callback (void*     userData,
205                                Boolean*  outIsPlaying,
206                                Boolean*  outTransportStateChanged,
207                                Float64*  outCurrentSampleInTimeLine,
208                                Boolean*  outIsCycling,
209                                Float64*  outCycleStartBeat,
210                                Float64*  outCycleEndBeat)
211 {
212         if (userData) {
213                 return ((AUPlugin*)userData)->get_transport_state_callback (
214                         outIsPlaying, outTransportStateChanged,
215                         outCurrentSampleInTimeLine, outIsCycling,
216                         outCycleStartBeat, outCycleEndBeat);
217         }
218         return paramErr;
219 }
220
221
222 static int
223 save_property_list (CFPropertyListRef propertyList, Glib::ustring path)
224
225 {
226         CFDataRef xmlData;
227         int fd;
228
229         // Convert the property list into XML data.
230
231         xmlData = CFPropertyListCreateXMLData( kCFAllocatorDefault, propertyList);
232
233         if (!xmlData) {
234                 error << _("Could not create XML version of property list") << endmsg;
235                 return -1;
236         }
237
238         // Write the XML data to the file.
239
240         fd = open (path.c_str(), O_WRONLY|O_CREAT|O_EXCL, 0664);
241         while (fd < 0) {
242                 if (errno == EEXIST) {
243                         error << string_compose (_("Preset file %1 exists; not overwriting"),
244                                                  path) << endmsg;
245                 } else {
246                         error << string_compose (_("Cannot open preset file %1 (%2)"),
247                                                  path, strerror (errno)) << endmsg;
248                 }
249                 CFRelease (xmlData);
250                 return -1;
251         }
252
253         size_t cnt = CFDataGetLength (xmlData);
254
255         if (write (fd, CFDataGetBytePtr (xmlData), cnt) != (ssize_t) cnt) {
256                 CFRelease (xmlData);
257                 close (fd);
258                 return -1;
259         }
260
261         close (fd);
262         return 0;
263 }
264
265
266 static CFPropertyListRef
267 load_property_list (Glib::ustring path)
268 {
269         int fd;
270         CFPropertyListRef propertyList = 0;
271         CFDataRef         xmlData;
272         CFStringRef       errorString;
273
274         // Read the XML file.
275
276         if ((fd = open (path.c_str(), O_RDONLY)) < 0) {
277                 return propertyList;
278
279         }
280
281         off_t len = lseek (fd, 0, SEEK_END);
282         char* buf = new char[len];
283         lseek (fd, 0, SEEK_SET);
284
285         if (read (fd, buf, len) != len) {
286                 delete [] buf;
287                 close (fd);
288                 return propertyList;
289         }
290
291         close (fd);
292
293         xmlData = CFDataCreateWithBytesNoCopy (kCFAllocatorDefault, (UInt8*) buf, len, kCFAllocatorNull);
294
295         // Reconstitute the dictionary using the XML data.
296
297         propertyList = CFPropertyListCreateFromXMLData( kCFAllocatorDefault,
298                                                         xmlData,
299                                                         kCFPropertyListImmutable,
300                                                         &errorString);
301
302         CFRelease (xmlData);
303         delete [] buf;
304
305         return propertyList;
306 }
307
308 //-----------------------------------------------------------------------------
309 static void
310 set_preset_name_in_plist (CFPropertyListRef plist, string preset_name)
311 {
312         if (!plist) {
313                 return;
314         }
315         CFStringRef pn = CFStringCreateWithCString (kCFAllocatorDefault, preset_name.c_str(), kCFStringEncodingUTF8);
316
317         if (CFGetTypeID (plist) == CFDictionaryGetTypeID()) {
318                 CFDictionarySetValue ((CFMutableDictionaryRef)plist, CFSTR(kAUPresetNameKey), pn);
319         }
320
321         CFRelease (pn);
322 }
323
324 //-----------------------------------------------------------------------------
325 static std::string
326 get_preset_name_in_plist (CFPropertyListRef plist)
327 {
328         std::string ret;
329
330         if (!plist) {
331                 return ret;
332         }
333
334         if (CFGetTypeID (plist) == CFDictionaryGetTypeID()) {
335                 const void *p = CFDictionaryGetValue ((CFMutableDictionaryRef)plist, CFSTR(kAUPresetNameKey));
336                 if (p) {
337                         CFStringRef str = (CFStringRef) p;
338                         int len = CFStringGetLength(str);
339                         len =  (len * 2) + 1;
340                         char local_buffer[len];
341                         if (CFStringGetCString (str, local_buffer, len, kCFStringEncodingUTF8)) {
342                                 ret = local_buffer;
343                         }
344                 }
345         }
346         return ret;
347 }
348
349 //--------------------------------------------------------------------------
350 // general implementation for ComponentDescriptionsMatch() and ComponentDescriptionsMatch_Loosely()
351 // if inIgnoreType is true, then the type code is ignored in the ComponentDescriptions
352 Boolean ComponentDescriptionsMatch_General(const ArdourDescription * inComponentDescription1, const ArdourDescription * inComponentDescription2, Boolean inIgnoreType);
353 Boolean ComponentDescriptionsMatch_General(const ArdourDescription * inComponentDescription1, const ArdourDescription * inComponentDescription2, Boolean inIgnoreType)
354 {
355         if ( (inComponentDescription1 == NULL) || (inComponentDescription2 == NULL) )
356                 return FALSE;
357
358         if ( (inComponentDescription1->componentSubType == inComponentDescription2->componentSubType)
359                         && (inComponentDescription1->componentManufacturer == inComponentDescription2->componentManufacturer) )
360         {
361                 // only sub-type and manufacturer IDs need to be equal
362                 if (inIgnoreType)
363                         return TRUE;
364                 // type, sub-type, and manufacturer IDs all need to be equal in order to call this a match
365                 else if (inComponentDescription1->componentType == inComponentDescription2->componentType)
366                         return TRUE;
367         }
368
369         return FALSE;
370 }
371
372 //--------------------------------------------------------------------------
373 // general implementation for ComponentAndDescriptionMatch() and ComponentAndDescriptionMatch_Loosely()
374 // if inIgnoreType is true, then the type code is ignored in the ComponentDescriptions
375 Boolean ComponentAndDescriptionMatch_General(ArdourComponent inComponent, const ArdourDescription * inComponentDescription, Boolean inIgnoreType);
376 Boolean ComponentAndDescriptionMatch_General(ArdourComponent inComponent, const ArdourDescription * inComponentDescription, Boolean inIgnoreType)
377 {
378         OSErr status;
379         ArdourDescription desc;
380
381         if ( (inComponent == NULL) || (inComponentDescription == NULL) )
382                 return FALSE;
383
384         // get the ComponentDescription of the input Component
385 #ifdef COREAUDIO105
386         status = GetComponentInfo(inComponent, &desc, NULL, NULL, NULL);
387 #else
388         status = AudioComponentGetDescription (inComponent, &desc);
389 #endif
390         if (status != noErr)
391                 return FALSE;
392
393         // check if the Component's ComponentDescription matches the input ComponentDescription
394         return ComponentDescriptionsMatch_General(&desc, inComponentDescription, inIgnoreType);
395 }
396
397 //--------------------------------------------------------------------------
398 // determine if 2 ComponentDescriptions are basically equal
399 // (by that, I mean that the important identifying values are compared,
400 // but not the ComponentDescription flags)
401 Boolean ComponentDescriptionsMatch(const ArdourDescription * inComponentDescription1, const ArdourDescription * inComponentDescription2)
402 {
403         return ComponentDescriptionsMatch_General(inComponentDescription1, inComponentDescription2, FALSE);
404 }
405
406 //--------------------------------------------------------------------------
407 // determine if 2 ComponentDescriptions have matching sub-type and manufacturer codes
408 Boolean ComponentDescriptionsMatch_Loose(const ArdourDescription * inComponentDescription1, const ArdourDescription * inComponentDescription2)
409 {
410         return ComponentDescriptionsMatch_General(inComponentDescription1, inComponentDescription2, TRUE);
411 }
412
413 //--------------------------------------------------------------------------
414 // determine if a ComponentDescription basically matches that of a particular Component
415 Boolean ComponentAndDescriptionMatch(ArdourComponent inComponent, const ArdourDescription * inComponentDescription)
416 {
417         return ComponentAndDescriptionMatch_General(inComponent, inComponentDescription, FALSE);
418 }
419
420 //--------------------------------------------------------------------------
421 // determine if a ComponentDescription matches only the sub-type and manufacturer codes of a particular Component
422 Boolean ComponentAndDescriptionMatch_Loosely(ArdourComponent inComponent, const ArdourDescription * inComponentDescription)
423 {
424         return ComponentAndDescriptionMatch_General(inComponent, inComponentDescription, TRUE);
425 }
426
427
428 AUPlugin::AUPlugin (AudioEngine& engine, Session& session, boost::shared_ptr<CAComponent> _comp)
429         : Plugin (engine, session)
430         , comp (_comp)
431         , unit (new CAAudioUnit)
432         , initialized (false)
433         , _current_block_size (0)
434         , _requires_fixed_size_buffers (false)
435         , buffers (0)
436         , input_maxbuf (0)
437         , input_offset (0)
438         , input_buffers (0)
439         , input_map (0)
440         , frames_processed (0)
441         , audio_input_cnt (0)
442         , _parameter_listener (0)
443         , _parameter_listener_arg (0)
444         , last_transport_rolling (false)
445         , last_transport_speed (0.0)
446 {
447         if (!preset_search_path_initialized) {
448                 Glib::ustring p = Glib::get_home_dir();
449                 p += "/Library/Audio/Presets:";
450                 p += preset_search_path;
451                 preset_search_path = p;
452                 preset_search_path_initialized = true;
453                 DEBUG_TRACE (DEBUG::AudioUnits, string_compose("AU Preset Path: %1\n", preset_search_path));
454         }
455
456         init ();
457 }
458
459
460 AUPlugin::AUPlugin (const AUPlugin& other)
461         : Plugin (other)
462         , comp (other.get_comp())
463         , unit (new CAAudioUnit)
464         , initialized (false)
465         , _current_block_size (0)
466         , _last_nframes (0)
467         , _requires_fixed_size_buffers (false)
468         , buffers (0)
469         , input_maxbuf (0)
470         , input_offset (0)
471         , input_buffers (0)
472         , input_map (0)
473         , frames_processed (0)
474         , _parameter_listener (0)
475         , _parameter_listener_arg (0)
476
477 {
478         init ();
479         for (size_t i = 0; i < descriptors.size(); ++i) {
480                 set_parameter (i, other.get_parameter (i));
481         }
482 }
483
484 AUPlugin::~AUPlugin ()
485 {
486         if (_parameter_listener) {
487                 AUListenerDispose (_parameter_listener);
488                 _parameter_listener = 0;
489         }
490
491         if (unit) {
492                 DEBUG_TRACE (DEBUG::AudioUnits, "about to call uninitialize in plugin destructor\n");
493                 unit->Uninitialize ();
494         }
495
496         if (buffers) {
497                 free (buffers);
498         }
499 }
500
501 void
502 AUPlugin::discover_factory_presets ()
503 {
504         CFArrayRef presets;
505         UInt32 dataSize;
506         Boolean isWritable;
507         OSStatus err;
508
509         if ((err = unit->GetPropertyInfo (kAudioUnitProperty_FactoryPresets, kAudioUnitScope_Global, 0, &dataSize, &isWritable)) != 0) {
510                 DEBUG_TRACE (DEBUG::AudioUnits, "no factory presets for AU\n");
511                 return;
512         }
513
514         assert (dataSize == sizeof (presets));
515
516         if ((err = unit->GetProperty (kAudioUnitProperty_FactoryPresets, kAudioUnitScope_Global, 0, (void*) &presets, &dataSize)) != 0) {
517                 error << string_compose (_("cannot get factory preset info: errcode %1"), err) << endmsg;
518                 return;
519         }
520
521         if (!presets) {
522                 return;
523         }
524
525         CFIndex cnt = CFArrayGetCount (presets);
526
527         for (CFIndex i = 0; i < cnt; ++i) {
528                 AUPreset* preset = (AUPreset*) CFArrayGetValueAtIndex (presets, i);
529
530                 string name = CFStringRefToStdString (preset->presetName);
531                 factory_preset_map[name] = preset->presetNumber;
532                 DEBUG_TRACE (DEBUG::AudioUnits, string_compose("AU Factory Preset: %1 > %2\n", name, preset->presetNumber));
533         }
534
535         CFRelease (presets);
536 }
537
538 void
539 AUPlugin::init ()
540 {
541         OSErr err;
542         CFStringRef itemName;
543
544         /* these keep track of *configured* channel set up,
545            not potential set ups.
546         */
547
548         input_channels = -1;
549         output_channels = -1;
550         {
551                 CAComponentDescription temp;
552 #ifdef COREAUDIO105
553                 GetComponentInfo (comp.get()->Comp(), &temp, NULL, NULL, NULL);
554 #else
555                 AudioComponentGetDescription (comp.get()->Comp(), &temp);
556 #endif
557                 CFStringRef compTypeString = UTCreateStringForOSType(temp.componentType);
558                 CFStringRef compSubTypeString = UTCreateStringForOSType(temp.componentSubType);
559                 CFStringRef compManufacturerString = UTCreateStringForOSType(temp.componentManufacturer);
560                 itemName = CFStringCreateWithFormat(kCFAllocatorDefault, NULL, CFSTR("%@ - %@ - %@"),
561                                 compTypeString, compManufacturerString, compSubTypeString);
562                 if (compTypeString != NULL) CFRelease(compTypeString);
563                 if (compSubTypeString != NULL) CFRelease(compSubTypeString);
564                 if (compManufacturerString != NULL) CFRelease(compManufacturerString);
565         }
566
567         au_blacklist(CFStringRefToStdString(itemName));
568
569         try {
570                 DEBUG_TRACE (DEBUG::AudioUnits, "opening AudioUnit\n");
571                 err = CAAudioUnit::Open (*(comp.get()), *unit);
572         } catch (...) {
573                 error << _("Exception thrown during AudioUnit plugin loading - plugin ignored") << endmsg;
574                 throw failed_constructor();
575         }
576
577         if (err != noErr) {
578                 error << _("AudioUnit: Could not convert CAComponent to CAAudioUnit") << endmsg;
579                 throw failed_constructor ();
580         }
581
582         DEBUG_TRACE (DEBUG::AudioUnits, "count global elements\n");
583         unit->GetElementCount (kAudioUnitScope_Global, global_elements);
584         DEBUG_TRACE (DEBUG::AudioUnits, "count input elements\n");
585         unit->GetElementCount (kAudioUnitScope_Input, input_elements);
586         DEBUG_TRACE (DEBUG::AudioUnits, "count output elements\n");
587         unit->GetElementCount (kAudioUnitScope_Output, output_elements);
588
589         if (input_elements > 0) {
590                 /* setup render callback: the plugin calls this to get input data
591                  */
592
593                 AURenderCallbackStruct renderCallbackInfo;
594
595                 renderCallbackInfo.inputProc = _render_callback;
596                 renderCallbackInfo.inputProcRefCon = this;
597
598                 DEBUG_TRACE (DEBUG::AudioUnits, "set render callback in input scope\n");
599                 if ((err = unit->SetProperty (kAudioUnitProperty_SetRenderCallback, kAudioUnitScope_Input,
600                                               0, (void*) &renderCallbackInfo, sizeof(renderCallbackInfo))) != 0) {
601                         error << string_compose (_("cannot install render callback (err = %1)"), err) << endmsg;
602                         throw failed_constructor();
603                 }
604         }
605
606         /* tell the plugin about tempo/meter/transport callbacks in case it wants them */
607
608         HostCallbackInfo info;
609         memset (&info, 0, sizeof (HostCallbackInfo));
610         info.hostUserData = this;
611         info.beatAndTempoProc = _get_beat_and_tempo_callback;
612         info.musicalTimeLocationProc = _get_musical_time_location_callback;
613         info.transportStateProc = _get_transport_state_callback;
614
615         //ignore result of this - don't care if the property isn't supported
616         DEBUG_TRACE (DEBUG::AudioUnits, "set host callbacks in global scope\n");
617         unit->SetProperty (kAudioUnitProperty_HostCallbacks,
618                            kAudioUnitScope_Global,
619                            0, //elementID
620                            &info,
621                            sizeof (HostCallbackInfo));
622
623         if (set_block_size (_session.get_block_size())) {
624                 error << _("AUPlugin: cannot set processing block size") << endmsg;
625                 throw failed_constructor();
626         }
627
628         create_parameter_listener (AUPlugin::_parameter_change_listener, this, 0.05);
629         discover_parameters ();
630         discover_factory_presets ();
631
632         // Plugin::setup_controls ();
633
634         au_unblacklist(CFStringRefToStdString(itemName));
635         if (itemName != NULL) CFRelease(itemName);
636 }
637
638 void
639 AUPlugin::discover_parameters ()
640 {
641         /* discover writable parameters */
642
643         AudioUnitScope scopes[] = {
644                 kAudioUnitScope_Global,
645                 kAudioUnitScope_Output,
646                 kAudioUnitScope_Input
647         };
648
649         descriptors.clear ();
650
651         for (uint32_t i = 0; i < sizeof (scopes) / sizeof (scopes[0]); ++i) {
652
653                 AUParamInfo param_info (unit->AU(), false, /* include read only */ true, scopes[i]);
654
655                 for (uint32_t i = 0; i < param_info.NumParams(); ++i) {
656
657                         AUParameterDescriptor d;
658
659                         d.id = param_info.ParamID (i);
660
661                         const CAAUParameter* param = param_info.GetParamInfo (d.id);
662                         const AudioUnitParameterInfo& info (param->ParamInfo());
663
664                         const int len = CFStringGetLength (param->GetName());
665                         char local_buffer[len*2];
666                         Boolean good = CFStringGetCString (param->GetName(), local_buffer ,len*2 , kCFStringEncodingUTF8);
667                         if (!good) {
668                                 d.label = "???";
669                         } else {
670                                 d.label = local_buffer;
671                         }
672
673                         d.scope = param_info.GetScope ();
674                         d.element = param_info.GetElement ();
675
676                         /* info.units to consider */
677                         /*
678                           kAudioUnitParameterUnit_Generic             = 0
679                           kAudioUnitParameterUnit_Indexed             = 1
680                           kAudioUnitParameterUnit_Boolean             = 2
681                           kAudioUnitParameterUnit_Percent             = 3
682                           kAudioUnitParameterUnit_Seconds             = 4
683                           kAudioUnitParameterUnit_SampleFrames        = 5
684                           kAudioUnitParameterUnit_Phase               = 6
685                           kAudioUnitParameterUnit_Rate                = 7
686                           kAudioUnitParameterUnit_Hertz               = 8
687                           kAudioUnitParameterUnit_Cents               = 9
688                           kAudioUnitParameterUnit_RelativeSemiTones   = 10
689                           kAudioUnitParameterUnit_MIDINoteNumber      = 11
690                           kAudioUnitParameterUnit_MIDIController      = 12
691                           kAudioUnitParameterUnit_Decibels            = 13
692                           kAudioUnitParameterUnit_LinearGain          = 14
693                           kAudioUnitParameterUnit_Degrees             = 15
694                           kAudioUnitParameterUnit_EqualPowerCrossfade = 16
695                           kAudioUnitParameterUnit_MixerFaderCurve1    = 17
696                           kAudioUnitParameterUnit_Pan                 = 18
697                           kAudioUnitParameterUnit_Meters              = 19
698                           kAudioUnitParameterUnit_AbsoluteCents       = 20
699                           kAudioUnitParameterUnit_Octaves             = 21
700                           kAudioUnitParameterUnit_BPM                 = 22
701                           kAudioUnitParameterUnit_Beats               = 23
702                           kAudioUnitParameterUnit_Milliseconds        = 24
703                           kAudioUnitParameterUnit_Ratio               = 25
704                         */
705
706                         /* info.flags to consider */
707
708                         /*
709
710                           kAudioUnitParameterFlag_CFNameRelease       = (1L << 4)
711                           kAudioUnitParameterFlag_HasClump            = (1L << 20)
712                           kAudioUnitParameterFlag_HasName             = (1L << 21)
713                           kAudioUnitParameterFlag_DisplayLogarithmic  = (1L << 22)
714                           kAudioUnitParameterFlag_IsHighResolution    = (1L << 23)
715                           kAudioUnitParameterFlag_NonRealTime         = (1L << 24)
716                           kAudioUnitParameterFlag_CanRamp             = (1L << 25)
717                           kAudioUnitParameterFlag_ExpertMode          = (1L << 26)
718                           kAudioUnitParameterFlag_HasCFNameString     = (1L << 27)
719                           kAudioUnitParameterFlag_IsGlobalMeta        = (1L << 28)
720                           kAudioUnitParameterFlag_IsElementMeta       = (1L << 29)
721                           kAudioUnitParameterFlag_IsReadable          = (1L << 30)
722                           kAudioUnitParameterFlag_IsWritable          = (1L << 31)
723                         */
724
725                         d.lower = info.minValue;
726                         d.upper = info.maxValue;
727                         d.normal = info.defaultValue;
728
729                         d.integer_step = (info.unit == kAudioUnitParameterUnit_Indexed);
730                         d.toggled = (info.unit == kAudioUnitParameterUnit_Boolean) ||
731                                 (d.integer_step && ((d.upper - d.lower) == 1.0));
732                         d.sr_dependent = (info.unit == kAudioUnitParameterUnit_SampleFrames);
733                         d.automatable = /* !d.toggled && -- ardour can automate toggles, can AU ? */
734                                 !(info.flags & kAudioUnitParameterFlag_NonRealTime) &&
735                                 (info.flags & kAudioUnitParameterFlag_IsWritable);
736
737                         d.logarithmic = (info.flags & kAudioUnitParameterFlag_DisplayLogarithmic);
738                         d.au_unit = info.unit;
739                         switch (info.unit) {
740                         case kAudioUnitParameterUnit_Decibels:
741                                 d.unit = ParameterDescriptor::DB;
742                                 break;
743                         case kAudioUnitParameterUnit_MIDINoteNumber:
744                                 d.unit = ParameterDescriptor::MIDI_NOTE;
745                                 break;
746                         case kAudioUnitParameterUnit_Hertz:
747                                 d.unit = ParameterDescriptor::HZ;
748                                 break;
749                         }
750
751                         d.min_unbound = 0; // lower is bound
752                         d.max_unbound = 0; // upper is bound
753                         d.update_steps();
754
755                         descriptors.push_back (d);
756
757                         uint32_t last_param = descriptors.size() - 1;
758                         parameter_map.insert (pair<uint32_t,uint32_t> (d.id, last_param));
759                         listen_to_parameter (last_param);
760                 }
761         }
762 }
763
764
765 static unsigned int
766 four_ints_to_four_byte_literal (unsigned char n[4])
767 {
768         /* this is actually implementation dependent. sigh. this is what gcc
769            and quite a few others do.
770          */
771         return ((n[0] << 24) + (n[1] << 16) + (n[2] << 8) + n[3]);
772 }
773
774 std::string
775 AUPlugin::maybe_fix_broken_au_id (const std::string& id)
776 {
777         if (isdigit (id[0])) {
778                 return id;
779         }
780
781         /* ID format is xxxx-xxxx-xxxx
782            where x maybe \xNN or a printable character.
783
784            Split at the '-' and and process each part into an integer.
785            Then put it back together.
786         */
787
788
789         unsigned char nascent[4];
790         const char* cstr = id.c_str();
791         const char* estr = cstr + id.size();
792         uint32_t n[3];
793         int in;
794         int next_int;
795         char short_buf[3];
796         stringstream s;
797
798         in = 0;
799         next_int = 0;
800         short_buf[2] = '\0';
801
802         while (*cstr && next_int < 4) {
803
804                 if (*cstr == '\\') {
805
806                         if (estr - cstr < 3) {
807
808                                 /* too close to the end for \xNN parsing: treat as literal characters */
809
810                                 nascent[in] = *cstr;
811                                 ++cstr;
812                                 ++in;
813
814                         } else {
815
816                                 if (cstr[1] == 'x' && isxdigit (cstr[2]) && isxdigit (cstr[3])) {
817
818                                         /* parse \xNN */
819
820                                         memcpy (short_buf, &cstr[2], 2);
821                                         nascent[in] = strtol (short_buf, NULL, 16);
822                                         cstr += 4;
823                                         ++in;
824
825                                 } else {
826
827                                         /* treat as literal characters */
828                                         nascent[in] = *cstr;
829                                         ++cstr;
830                                         ++in;
831                                 }
832                         }
833
834                 } else {
835
836                         nascent[in] = *cstr;
837                         ++cstr;
838                         ++in;
839                 }
840
841                 if (in && (in % 4 == 0)) {
842                         /* nascent is ready */
843                         n[next_int] = four_ints_to_four_byte_literal (nascent);
844                         in = 0;
845                         next_int++;
846
847                         /* swallow space-hyphen-space */
848
849                         if (next_int < 3) {
850                                 ++cstr;
851                                 ++cstr;
852                                 ++cstr;
853                         }
854                 }
855         }
856
857         if (next_int != 3) {
858                 goto err;
859         }
860
861         s << n[0] << '-' << n[1] << '-' << n[2];
862
863         return s.str();
864
865 err:
866         return string();
867 }
868
869 string
870 AUPlugin::unique_id () const
871 {
872         return AUPluginInfo::stringify_descriptor (comp->Desc());
873 }
874
875 const char *
876 AUPlugin::label () const
877 {
878         return _info->name.c_str();
879 }
880
881 uint32_t
882 AUPlugin::parameter_count () const
883 {
884         return descriptors.size();
885 }
886
887 float
888 AUPlugin::default_value (uint32_t port)
889 {
890         if (port < descriptors.size()) {
891                 return descriptors[port].normal;
892         }
893
894         return 0;
895 }
896
897 framecnt_t
898 AUPlugin::signal_latency () const
899 {
900         return unit->Latency() * _session.frame_rate();
901 }
902
903 void
904 AUPlugin::set_parameter (uint32_t which, float val)
905 {
906         if (which >= descriptors.size()) {
907                 return;
908         }
909
910         if (get_parameter(which) == val) {
911                 return;
912         }
913
914         const AUParameterDescriptor& d (descriptors[which]);
915         DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("set parameter %1 in scope %2 element %3 to %4\n", d.id, d.scope, d.element, val));
916         unit->SetParameter (d.id, d.scope, d.element, val);
917
918         /* tell the world what we did */
919
920         AudioUnitEvent theEvent;
921
922         theEvent.mEventType = kAudioUnitEvent_ParameterValueChange;
923         theEvent.mArgument.mParameter.mAudioUnit = unit->AU();
924         theEvent.mArgument.mParameter.mParameterID = d.id;
925         theEvent.mArgument.mParameter.mScope = d.scope;
926         theEvent.mArgument.mParameter.mElement = d.element;
927
928         DEBUG_TRACE (DEBUG::AudioUnits, "notify about parameter change\n");
929         /* Note the 1st argument, which means "Don't notify us about a change we made ourselves" */
930         AUEventListenerNotify (_parameter_listener, NULL, &theEvent);
931
932         Plugin::set_parameter (which, val);
933 }
934
935 float
936 AUPlugin::get_parameter (uint32_t which) const
937 {
938         float val = 0.0;
939         if (which < descriptors.size()) {
940                 const AUParameterDescriptor& d (descriptors[which]);
941                 // DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("get value of parameter %1 in scope %2 element %3\n", d.id, d.scope, d.element));
942                 unit->GetParameter(d.id, d.scope, d.element, val);
943         }
944         return val;
945 }
946
947 int
948 AUPlugin::get_parameter_descriptor (uint32_t which, ParameterDescriptor& pd) const
949 {
950         if (which < descriptors.size()) {
951                 pd = descriptors[which];
952                 return 0;
953         }
954         return -1;
955 }
956
957 uint32_t
958 AUPlugin::nth_parameter (uint32_t which, bool& ok) const
959 {
960         if (which < descriptors.size()) {
961                 ok = true;
962                 return which;
963         }
964         ok = false;
965         return 0;
966 }
967
968 void
969 AUPlugin::activate ()
970 {
971         if (!initialized) {
972                 OSErr err;
973                 DEBUG_TRACE (DEBUG::AudioUnits, "call Initialize in activate()\n");
974                 if ((err = unit->Initialize()) != noErr) {
975                         error << string_compose (_("AUPlugin: %1 cannot initialize plugin (err = %2)"), name(), err) << endmsg;
976                 } else {
977                         frames_processed = 0;
978                         initialized = true;
979                 }
980         }
981 }
982
983 void
984 AUPlugin::deactivate ()
985 {
986         DEBUG_TRACE (DEBUG::AudioUnits, "call Uninitialize in deactivate()\n");
987         unit->Uninitialize ();
988         initialized = false;
989 }
990
991 void
992 AUPlugin::flush ()
993 {
994         DEBUG_TRACE (DEBUG::AudioUnits, "call Reset in flush()\n");
995         unit->GlobalReset ();
996 }
997
998 bool
999 AUPlugin::requires_fixed_size_buffers() const
1000 {
1001         return _requires_fixed_size_buffers;
1002 }
1003
1004
1005 int
1006 AUPlugin::set_block_size (pframes_t nframes)
1007 {
1008         bool was_initialized = initialized;
1009         UInt32 numFrames = nframes;
1010         OSErr err;
1011
1012         if (initialized) {
1013                 deactivate ();
1014         }
1015
1016         DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("set MaximumFramesPerSlice in global scope to %1\n", numFrames));
1017         if ((err = unit->SetProperty (kAudioUnitProperty_MaximumFramesPerSlice, kAudioUnitScope_Global,
1018                                       0, &numFrames, sizeof (numFrames))) != noErr) {
1019                 error << string_compose (_("AU: cannot set max frames (err = %1)"), err) << endmsg;
1020                 return -1;
1021         }
1022
1023         if (was_initialized) {
1024                 activate ();
1025         }
1026
1027         _current_block_size = nframes;
1028
1029         return 0;
1030 }
1031
1032 bool
1033 AUPlugin::configure_io (ChanCount in, ChanCount out)
1034 {
1035         AudioStreamBasicDescription streamFormat;
1036         bool was_initialized = initialized;
1037         int32_t audio_out = out.n_audio();
1038         if (audio_input_cnt > 0) {
1039                 in.set (DataType::AUDIO, audio_input_cnt);
1040         }
1041         int32_t audio_in = in.n_audio();
1042
1043         DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("configure %1 for %2 in %3 out\n", name(), in, out));
1044
1045         if (initialized) {
1046                 //if we are already running with the requested i/o config, bail out here
1047                 if ( (audio_in==input_channels) && (audio_out==output_channels) ) {
1048                         return true;
1049                 } else {
1050                         deactivate ();
1051                 }
1052         }
1053
1054         streamFormat.mSampleRate = _session.frame_rate();
1055         streamFormat.mFormatID = kAudioFormatLinearPCM;
1056         streamFormat.mFormatFlags = kAudioFormatFlagIsFloat|kAudioFormatFlagIsPacked|kAudioFormatFlagIsNonInterleaved;
1057
1058 #ifdef __LITTLE_ENDIAN__
1059         /* relax */
1060 #else
1061         streamFormat.mFormatFlags |= kAudioFormatFlagIsBigEndian;
1062 #endif
1063
1064         streamFormat.mBitsPerChannel = 32;
1065         streamFormat.mFramesPerPacket = 1;
1066
1067         /* apple says that for non-interleaved data, these
1068            values always refer to a single channel.
1069         */
1070         streamFormat.mBytesPerPacket = 4;
1071         streamFormat.mBytesPerFrame = 4;
1072
1073         streamFormat.mChannelsPerFrame = audio_in;
1074
1075         if (set_input_format (streamFormat) != 0) {
1076                 return false;
1077         }
1078
1079         streamFormat.mChannelsPerFrame = audio_out;
1080
1081         if (set_output_format (streamFormat) != 0) {
1082                 return false;
1083         }
1084
1085         /* reset plugin info to show currently configured state */
1086
1087         _info->n_inputs = in;
1088         _info->n_outputs = out;
1089
1090         if (was_initialized) {
1091                 activate ();
1092         }
1093
1094         return true;
1095 }
1096
1097 ChanCount
1098 AUPlugin::input_streams() const
1099 {
1100         ChanCount c;
1101
1102
1103         if (input_channels < 0) {
1104                 // force PluginIoReConfigure -- see also commit msg e38eb06
1105                 c.set (DataType::AUDIO, 0);
1106                 c.set (DataType::MIDI, 0);
1107         } else {
1108                 c.set (DataType::AUDIO, input_channels);
1109                 c.set (DataType::MIDI, _has_midi_input ? 1 : 0);
1110         }
1111
1112         return c;
1113 }
1114
1115
1116 ChanCount
1117 AUPlugin::output_streams() const
1118 {
1119         ChanCount c;
1120
1121         if (output_channels < 0) {
1122                 // force PluginIoReConfigure - see also commit msg e38eb06
1123                 c.set (DataType::AUDIO, 0);
1124                 c.set (DataType::MIDI, 0);
1125         } else {
1126                 c.set (DataType::AUDIO, output_channels);
1127                 c.set (DataType::MIDI, _has_midi_output ? 1 : 0);
1128         }
1129
1130         return c;
1131 }
1132
1133 bool
1134 AUPlugin::can_support_io_configuration (const ChanCount& in, ChanCount& out, ChanCount* imprecise)
1135 {
1136         _output_configs.clear ();
1137         const int32_t audio_in = in.n_audio();
1138         AUPluginInfoPtr pinfo = boost::dynamic_pointer_cast<AUPluginInfo>(get_info());
1139
1140         /* lets check MIDI first */
1141
1142         if (in.n_midi() > 0 && !_has_midi_input && !imprecise) {
1143                 return false;
1144         }
1145
1146         vector<pair<int,int> >& io_configs = pinfo->cache.io_configs;
1147
1148         DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("%1 has %2 IO configurations, looking for %3 in, %4 out\n",
1149                                                         name(), io_configs.size(), in, out));
1150
1151         // preferred setting (provided by plugin_insert)
1152         const int preferred_out = out.n_audio ();
1153         bool found = false;
1154         bool exact_match = false;
1155
1156         /* kAudioUnitProperty_SupportedNumChannels
1157          * https://developer.apple.com/library/mac/documentation/MusicAudio/Conceptual/AudioUnitProgrammingGuide/TheAudioUnit/TheAudioUnit.html#//apple_ref/doc/uid/TP40003278-CH12-SW20
1158          *
1159          * - both fields are -1
1160          *   e.g. inChannels = -1 outChannels = -1
1161          *    This is the default case. Any number of input and output channels, as long as the numbers match
1162          *
1163          * - one field is -1, the other field is positive
1164          *   e.g. inChannels = -1 outChannels = 2
1165          *    Any number of input channels, exactly two output channels
1166          *
1167          * - one field is -1, the other field is -2
1168          *   e.g. inChannels = -1 outChannels = -2
1169          *    Any number of input channels, any number of output channels
1170          *
1171          * - both fields have non-negative values
1172          *   e.g. inChannels = 2 outChannels = 6
1173          *    Exactly two input channels, exactly six output channels
1174          *   e.g. inChannels = 0 outChannels = 2
1175          *    No input channels, exactly two output channels (such as for an instrument unit with stereo output)
1176          *
1177          * - both fields have negative values, neither of which is â€“1 or â€“2
1178          *   e.g. inChannels = -4 outChannels = -8
1179          *    Up to four input channels and up to eight output channels
1180          */
1181
1182         for (vector<pair<int,int> >::iterator i = io_configs.begin(); i != io_configs.end(); ++i) {
1183
1184                 int32_t possible_in = i->first;
1185                 int32_t possible_out = i->second;
1186
1187                 if ((possible_in == audio_in) && (possible_out == preferred_out)) {
1188                         DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("\tCHOSEN: %1 in %2 out to match in %3 out %4\n",
1189                                                 possible_in, possible_out,
1190                                                 in, out));
1191
1192                         // exact match
1193                         _output_configs.insert (preferred_out);
1194                         exact_match = true;
1195                         found = true;
1196                         break;
1197                 }
1198         }
1199
1200         /* now allow potentially "imprecise" matches */
1201         int32_t audio_out = -1;
1202         float penalty = 9999;
1203         int used_possible_in = 0;
1204
1205 #define FOUNDCFG(nch) {                            \
1206   float p = fabsf ((float)(nch) - preferred_out);  \
1207   _output_configs.insert (nch);                    \
1208   if ((nch) > preferred_out) { p *= 1.1; }         \
1209   if (p < penalty) {                               \
1210     used_possible_in = possible_in;                \
1211     audio_out = (nch);                             \
1212     penalty = p;                                   \
1213     found = true;                                  \
1214   }                                                \
1215 }
1216
1217 #define ANYTHINGGOES                               \
1218   _output_configs.insert (0);
1219
1220 #define UPTO(nch) {                                \
1221   for (int n = 1; n < nch; ++n) {                  \
1222     _output_configs.insert (n);                    \
1223   }                                                \
1224 }
1225
1226         for (vector<pair<int,int> >::iterator i = io_configs.begin(); i != io_configs.end(); ++i) {
1227
1228                 int32_t possible_in = i->first;
1229                 int32_t possible_out = i->second;
1230
1231                 DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("\tpossible in %1 possible out %2\n", possible_in, possible_out));
1232
1233                 if (possible_out == 0) {
1234                         warning << string_compose (_("AU %1 has zero outputs - configuration ignored"), name()) << endmsg;
1235                         /* XXX surely this is just a send? (e.g. AUNetSend) */
1236                         continue;
1237                 }
1238
1239                 if (possible_in == 0) {
1240                         /* no inputs, generators & instruments */
1241                         if (possible_out == -1) {
1242                                 /* any configuration possible, provide stereo output */
1243                                 FOUNDCFG (preferred_out);
1244                                 ANYTHINGGOES;
1245                         } else if (possible_out == -2) {
1246                                 /* invalid, should be (0, -1) */
1247                                 FOUNDCFG (preferred_out);
1248                                 ANYTHINGGOES;
1249                         } else if (possible_out < -2) {
1250                                 /* variable number of outputs up to -N, */
1251                                 FOUNDCFG (min (-possible_out, preferred_out));
1252                                 UPTO (-possible_out);
1253                         } else {
1254                                 /* exact number of outputs */
1255                                 FOUNDCFG (possible_out);
1256                         }
1257                 }
1258
1259                 if (possible_in == -1) {
1260                         /* wildcard for input */
1261                         if (possible_out == -1) {
1262                                 /* out must match in */
1263                                 FOUNDCFG (audio_in);
1264                         } else if (possible_out == -2) {
1265                                 /* any configuration possible, pick matching */
1266                                 FOUNDCFG (preferred_out);
1267                                 ANYTHINGGOES;
1268                         } else if (possible_out < -2) {
1269                                 /* explicitly variable number of outputs, pick maximum */
1270                                 FOUNDCFG (max (-possible_out, preferred_out));
1271                                 /* and try min, too, in case the penalty is lower */
1272                                 FOUNDCFG (min (-possible_out, preferred_out));
1273                                 UPTO (-possible_out)
1274                         } else {
1275                                 /* exact number of outputs */
1276                                 FOUNDCFG (possible_out);
1277                         }
1278                 }
1279
1280                 if (possible_in == -2) {
1281                         if (possible_out == -1) {
1282                                 /* any configuration possible, pick matching */
1283                                 FOUNDCFG (preferred_out);
1284                                 ANYTHINGGOES;
1285                         } else if (possible_out == -2) {
1286                                 /* invalid. interpret as (-1, -1) */
1287                                 FOUNDCFG (preferred_out);
1288                                 ANYTHINGGOES;
1289                         } else if (possible_out < -2) {
1290                                 /* invalid,  interpret as (<-2, <-2)
1291                                  * variable number of outputs up to -N, */
1292                                 FOUNDCFG (min (-possible_out, preferred_out));
1293                                 UPTO (-possible_out)
1294                         } else {
1295                                 /* exact number of outputs */
1296                                 FOUNDCFG (possible_out);
1297                         }
1298                 }
1299
1300                 if (possible_in < -2) {
1301                         /* explicit variable number of inputs */
1302                         if (audio_in > -possible_in && imprecise != NULL) {
1303                                 // hide inputs ports
1304                                 imprecise->set (DataType::AUDIO, -possible_in);
1305                         }
1306
1307                         if (audio_in > -possible_in && imprecise == NULL) {
1308                                 /* request is too large */
1309                         } else if (possible_out == -1) {
1310                                 /* any output configuration possible */
1311                                 FOUNDCFG (preferred_out);
1312                                 ANYTHINGGOES;
1313                         } else if (possible_out == -2) {
1314                                 /* invalid. interpret as (<-2, -1) */
1315                                 FOUNDCFG (preferred_out);
1316                                 ANYTHINGGOES;
1317                         } else if (possible_out < -2) {
1318                                 /* variable number of outputs up to -N, */
1319                                 FOUNDCFG (min (-possible_out, preferred_out));
1320                                 UPTO (-possible_out)
1321                         } else {
1322                                 /* exact number of outputs */
1323                                 FOUNDCFG (possible_out);
1324                         }
1325                 }
1326
1327                 if (possible_in && (possible_in == audio_in)) {
1328                         /* exact number of inputs ... must match obviously */
1329                         if (possible_out == -1) {
1330                                 /* any output configuration possible */
1331                                 FOUNDCFG (preferred_out);
1332                                 ANYTHINGGOES;
1333                         } else if (possible_out == -2) {
1334                                 /* plugins shouldn't really use (>0,-2), interpret as (>0,-1) */
1335                                 FOUNDCFG (preferred_out);
1336                                 ANYTHINGGOES;
1337                         } else if (possible_out < -2) {
1338                                 /* > 0, < -2 is not specified
1339                                  * interpret as up to -N */
1340                                 FOUNDCFG (min (-possible_out, preferred_out));
1341                                 UPTO (-possible_out)
1342                         } else {
1343                                 /* exact number of outputs */
1344                                 FOUNDCFG (possible_out);
1345                         }
1346                 }
1347         }
1348
1349         if (!found && imprecise) {
1350                 /* try harder */
1351                 for (vector<pair<int,int> >::iterator i = io_configs.begin(); i != io_configs.end(); ++i) {
1352                         int32_t possible_in = i->first;
1353                         int32_t possible_out = i->second;
1354
1355                         assert (possible_in > 0); // all other cases will have been matched above
1356                         assert (possible_out !=0 || possible_in !=0); // already handled above
1357
1358                         imprecise->set (DataType::AUDIO, possible_in);
1359                         if (possible_out == -1 || possible_out == -2) {
1360                                 FOUNDCFG (2);
1361                         } else if (possible_out < -2) {
1362                                 /* explicitly variable number of outputs, pick maximum */
1363                                 FOUNDCFG (min (-possible_out, preferred_out));
1364                         } else {
1365                                 /* exact number of outputs */
1366                                 FOUNDCFG (possible_out);
1367                         }
1368                         // ideally we'll also find the closest, best matching
1369                         // input configuration with minimal output penalty...
1370                 }
1371         }
1372
1373         if (!found) {
1374                 DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("\tFAIL: no io configs match %1\n", in));
1375                 return false;
1376         }
1377
1378         if (exact_match) {
1379                 out.set (DataType::MIDI, 0); // currently always zero
1380                 out.set (DataType::AUDIO, preferred_out);
1381         } else {
1382                 if (used_possible_in < -2 && audio_in == 0) {
1383                         // input-port count cannot be zero, use as many ports
1384                         // as outputs, but at most abs(possible_in)
1385                         audio_input_cnt = max (1, min (audio_out, -used_possible_in));
1386                 }
1387                 out.set (DataType::MIDI, 0); /// XXX
1388                 out.set (DataType::AUDIO, audio_out);
1389         }
1390         DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("\tCHOSEN: in %1 out %2\n", in, out));
1391
1392         return true;
1393 }
1394
1395 int
1396 AUPlugin::set_input_format (AudioStreamBasicDescription& fmt)
1397 {
1398         return set_stream_format (kAudioUnitScope_Input, input_elements, fmt);
1399 }
1400
1401 int
1402 AUPlugin::set_output_format (AudioStreamBasicDescription& fmt)
1403 {
1404         if (set_stream_format (kAudioUnitScope_Output, output_elements, fmt) != 0) {
1405                 return -1;
1406         }
1407
1408         if (buffers) {
1409                 free (buffers);
1410                 buffers = 0;
1411         }
1412
1413         buffers = (AudioBufferList *) malloc (offsetof(AudioBufferList, mBuffers) +
1414                                               fmt.mChannelsPerFrame * sizeof(::AudioBuffer));
1415
1416         return 0;
1417 }
1418
1419 int
1420 AUPlugin::set_stream_format (int scope, uint32_t cnt, AudioStreamBasicDescription& fmt)
1421 {
1422         OSErr result;
1423
1424         for (uint32_t i = 0; i < cnt; ++i) {
1425                 DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("set stream format for %1, scope = %2 element %3\n",
1426                                                                 (scope == kAudioUnitScope_Input ? "input" : "output"),
1427                                                                 scope, cnt));
1428                 if ((result = unit->SetFormat (scope, i, fmt)) != 0) {
1429                         error << string_compose (_("AUPlugin: could not set stream format for %1/%2 (err = %3)"),
1430                                                  (scope == kAudioUnitScope_Input ? "input" : "output"), i, result) << endmsg;
1431                         return -1;
1432                 }
1433         }
1434
1435         if (scope == kAudioUnitScope_Input) {
1436                 input_channels = fmt.mChannelsPerFrame;
1437         } else {
1438                 output_channels = fmt.mChannelsPerFrame;
1439         }
1440
1441         return 0;
1442 }
1443
1444 OSStatus
1445 AUPlugin::render_callback(AudioUnitRenderActionFlags*,
1446                           const AudioTimeStamp*,
1447                           UInt32,
1448                           UInt32       inNumberFrames,
1449                           AudioBufferList*       ioData)
1450 {
1451         /* not much to do with audio - the data is already in the buffers given to us in connect_and_run() */
1452
1453         // DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("%1: render callback, frames %2 bufs %3\n",
1454         // name(), inNumberFrames, ioData->mNumberBuffers));
1455
1456         if (input_maxbuf == 0) {
1457                 DEBUG_TRACE (DEBUG::AudioUnits, "AUPlugin: render callback called illegally!");
1458                 error << _("AUPlugin: render callback called illegally!") << endmsg;
1459                 return kAudioUnitErr_CannotDoInCurrentContext;
1460         }
1461         uint32_t limit = min ((uint32_t) ioData->mNumberBuffers, input_maxbuf);
1462
1463         ChanCount bufs_count (DataType::AUDIO, 1);
1464         BufferSet& silent_bufs = _session.get_silent_buffers(bufs_count);
1465
1466         for (uint32_t i = 0; i < limit; ++i) {
1467                 ioData->mBuffers[i].mNumberChannels = 1;
1468                 ioData->mBuffers[i].mDataByteSize = sizeof (Sample) * inNumberFrames;
1469
1470                 bool valid = false;
1471                 uint32_t idx = input_map->get (DataType::AUDIO, i, &valid);
1472                 if (valid) {
1473                         ioData->mBuffers[i].mData = input_buffers->get_audio (idx).data (cb_offset + input_offset);
1474                 } else {
1475                         ioData->mBuffers[i].mData = silent_bufs.get_audio(0).data (cb_offset + input_offset);
1476                 }
1477         }
1478
1479         cb_offset += inNumberFrames;
1480
1481         return noErr;
1482 }
1483
1484 int
1485 AUPlugin::connect_and_run (BufferSet& bufs, ChanMapping in_map, ChanMapping out_map, pframes_t nframes, framecnt_t offset)
1486 {
1487         Plugin::connect_and_run (bufs, in_map, out_map, nframes, offset);
1488
1489         AudioUnitRenderActionFlags flags = 0;
1490         AudioTimeStamp ts;
1491         OSErr err;
1492
1493         if (requires_fixed_size_buffers() && (nframes != _last_nframes)) {
1494                 unit->GlobalReset();
1495                 _last_nframes = nframes;
1496         }
1497
1498         /* test if we can run in-place; only compare audio buffers */
1499         bool inplace = true;
1500         ChanMapping::Mappings inmap (in_map.mappings ());
1501         ChanMapping::Mappings outmap (out_map.mappings ());
1502         assert (outmap[DataType::AUDIO].size () > 0);
1503         if (inmap[DataType::AUDIO].size() > 0 && inmap != outmap) {
1504                 inplace = false;
1505         }
1506
1507         DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("%1 in %2 out %3 MIDI %4 bufs %5 (available %6) Inplace: %7\n",
1508                                 name(), input_channels, output_channels, _has_midi_input,
1509                                 bufs.count(), bufs.available(), inplace));
1510
1511         /* the apparent number of buffers matches our input configuration, but we know that the bufferset
1512          * has the capacity to handle our outputs.
1513          */
1514
1515         assert (bufs.available() >= ChanCount (DataType::AUDIO, output_channels));
1516
1517         input_buffers = &bufs;
1518         input_map = &in_map;
1519         input_maxbuf = bufs.count().n_audio(); // number of input audio buffers
1520         input_offset = offset;
1521         cb_offset = 0;
1522
1523         buffers->mNumberBuffers = output_channels;
1524
1525         ChanCount bufs_count (DataType::AUDIO, 1);
1526         BufferSet& scratch_bufs = _session.get_scratch_buffers(bufs_count);
1527
1528         for (int32_t i = 0; i < output_channels; ++i) {
1529                 buffers->mBuffers[i].mNumberChannels = 1;
1530                 buffers->mBuffers[i].mDataByteSize = nframes * sizeof (Sample);
1531                 /* setting this to 0 indicates to the AU that it can provide buffers here
1532                  * if necessary. if it can process in-place, it will use the buffers provided
1533                  * as input by ::render_callback() above.
1534                  *
1535                  * a non-null values tells the plugin to render into the buffer pointed
1536                  * at by the value.
1537                  */
1538                 if (inplace) {
1539                         buffers->mBuffers[i].mData = 0;
1540                 } else {
1541                         bool valid = false;
1542                         uint32_t idx = out_map.get (DataType::AUDIO, i, &valid);
1543                         if (valid) {
1544                                 buffers->mBuffers[i].mData = bufs.get_audio (idx).data (offset);
1545                         } else {
1546                                 buffers->mBuffers[i].mData = scratch_bufs.get_audio(0).data(offset);
1547                         }
1548                 }
1549         }
1550
1551         if (_has_midi_input) {
1552
1553                 uint32_t nmidi = bufs.count().n_midi();
1554
1555                 for (uint32_t i = 0; i < nmidi; ++i) {
1556
1557                         /* one MIDI port/buffer only */
1558
1559                         MidiBuffer& m = bufs.get_midi (i);
1560
1561                         for (MidiBuffer::iterator i = m.begin(); i != m.end(); ++i) {
1562                                 Evoral::MIDIEvent<framepos_t> ev (*i);
1563
1564                                 if (ev.is_channel_event()) {
1565                                         const uint8_t* b = ev.buffer();
1566                                         DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("%1: MIDI event %2\n", name(), ev));
1567                                         unit->MIDIEvent (b[0], b[1], b[2], ev.time());
1568                                 }
1569
1570                                 /* XXX need to handle sysex and other message types */
1571                         }
1572                 }
1573         }
1574
1575         /* does this really mean anything ?  */
1576
1577         ts.mSampleTime = frames_processed;
1578         ts.mFlags = kAudioTimeStampSampleTimeValid;
1579
1580         DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("%1 render flags=%2 time=%3 nframes=%4 buffers=%5\n",
1581                                 name(), flags, frames_processed, nframes, buffers->mNumberBuffers));
1582
1583         if ((err = unit->Render (&flags, &ts, 0, nframes, buffers)) == noErr) {
1584
1585                 input_maxbuf = 0;
1586                 frames_processed += nframes;
1587
1588                 DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("%1 rendered %2 buffers of %3\n",
1589                                         name(), buffers->mNumberBuffers, output_channels));
1590
1591                 int32_t limit = min ((int32_t) buffers->mNumberBuffers, output_channels);
1592                 int32_t i;
1593
1594                 for (i = 0; i < limit; ++i) {
1595                         bool valid = false;
1596                         uint32_t idx = out_map.get (DataType::AUDIO, i, &valid);
1597                         if (!valid) continue;
1598                         Sample* expected_buffer_address = bufs.get_audio (idx).data (offset);
1599                         if (expected_buffer_address != buffers->mBuffers[i].mData) {
1600                                 /* plugin provided its own buffer for output so copy it back to where we want it
1601                                 */
1602                                 memcpy (expected_buffer_address, buffers->mBuffers[i].mData, nframes * sizeof (Sample));
1603                         }
1604                 }
1605
1606                 /* now silence any buffers that were passed in but the that the plugin
1607                  * did not fill/touch/use.
1608                  */
1609
1610                 for (;i < output_channels; ++i) {
1611                         bool valid = false;
1612                         uint32_t idx = out_map.get (DataType::AUDIO, i, &valid);
1613                         if (!valid) continue;
1614                         memset (bufs.get_audio (idx).data (offset), 0, nframes * sizeof (Sample));
1615                 }
1616
1617                 return 0;
1618         }
1619
1620         error << string_compose (_("AU: render error for %1, status = %2"), name(), err) << endmsg;
1621         return -1;
1622 }
1623
1624 OSStatus
1625 AUPlugin::get_beat_and_tempo_callback (Float64* outCurrentBeat,
1626                                        Float64* outCurrentTempo)
1627 {
1628         TempoMap& tmap (_session.tempo_map());
1629
1630         DEBUG_TRACE (DEBUG::AudioUnits, "AU calls ardour beat&tempo callback\n");
1631
1632         /* more than 1 meter or more than 1 tempo means that a simplistic computation
1633            (and interpretation) of a beat position will be incorrect. So refuse to
1634            offer the value.
1635         */
1636
1637         if (tmap.n_tempos() > 1 || tmap.n_meters() > 1) {
1638                 return kAudioUnitErr_CannotDoInCurrentContext;
1639         }
1640
1641         Timecode::BBT_Time bbt;
1642         TempoMetric metric = tmap.metric_at (_session.transport_frame() + input_offset);
1643         tmap.bbt_time (_session.transport_frame() + input_offset, bbt);
1644
1645         if (outCurrentBeat) {
1646                 float beat;
1647                 beat = metric.meter().divisions_per_bar() * bbt.bars;
1648                 beat += bbt.beats;
1649                 beat += bbt.ticks / Timecode::BBT_Time::ticks_per_beat;
1650                 *outCurrentBeat = beat;
1651         }
1652
1653         if (outCurrentTempo) {
1654                 *outCurrentTempo = floor (metric.tempo().beats_per_minute());
1655         }
1656
1657         return noErr;
1658
1659 }
1660
1661 OSStatus
1662 AUPlugin::get_musical_time_location_callback (UInt32*   outDeltaSampleOffsetToNextBeat,
1663                                               Float32*  outTimeSig_Numerator,
1664                                               UInt32*   outTimeSig_Denominator,
1665                                               Float64*  outCurrentMeasureDownBeat)
1666 {
1667         TempoMap& tmap (_session.tempo_map());
1668
1669         DEBUG_TRACE (DEBUG::AudioUnits, "AU calls ardour music time location callback\n");
1670
1671         /* more than 1 meter or more than 1 tempo means that a simplistic computation
1672            (and interpretation) of a beat position will be incorrect. So refuse to
1673            offer the value.
1674         */
1675
1676         if (tmap.n_tempos() > 1 || tmap.n_meters() > 1) {
1677                 return kAudioUnitErr_CannotDoInCurrentContext;
1678         }
1679
1680         Timecode::BBT_Time bbt;
1681         TempoMetric metric = tmap.metric_at (_session.transport_frame() + input_offset);
1682         tmap.bbt_time (_session.transport_frame() + input_offset, bbt);
1683
1684         if (outDeltaSampleOffsetToNextBeat) {
1685                 if (bbt.ticks == 0) {
1686                         /* on the beat */
1687                         *outDeltaSampleOffsetToNextBeat = 0;
1688                 } else {
1689                         *outDeltaSampleOffsetToNextBeat = (UInt32)
1690                                 floor (((Timecode::BBT_Time::ticks_per_beat - bbt.ticks)/Timecode::BBT_Time::ticks_per_beat) * // fraction of a beat to next beat
1691                                        metric.tempo().frames_per_beat (_session.frame_rate())); // frames per beat
1692                 }
1693         }
1694
1695         if (outTimeSig_Numerator) {
1696                 *outTimeSig_Numerator = (UInt32) lrintf (metric.meter().divisions_per_bar());
1697         }
1698         if (outTimeSig_Denominator) {
1699                 *outTimeSig_Denominator = (UInt32) lrintf (metric.meter().note_divisor());
1700         }
1701
1702         if (outCurrentMeasureDownBeat) {
1703
1704                 /* beat for the start of the bar.
1705                    1|1|0 -> 1
1706                    2|1|0 -> 1 + divisions_per_bar
1707                    3|1|0 -> 1 + (2 * divisions_per_bar)
1708                    etc.
1709                 */
1710
1711                 *outCurrentMeasureDownBeat = 1 + metric.meter().divisions_per_bar() * (bbt.bars - 1);
1712         }
1713
1714         return noErr;
1715 }
1716
1717 OSStatus
1718 AUPlugin::get_transport_state_callback (Boolean*  outIsPlaying,
1719                                         Boolean*  outTransportStateChanged,
1720                                         Float64*  outCurrentSampleInTimeLine,
1721                                         Boolean*  outIsCycling,
1722                                         Float64*  outCycleStartBeat,
1723                                         Float64*  outCycleEndBeat)
1724 {
1725         bool rolling;
1726         float speed;
1727
1728         DEBUG_TRACE (DEBUG::AudioUnits, "AU calls ardour transport state callback\n");
1729
1730         rolling = _session.transport_rolling();
1731         speed = _session.transport_speed ();
1732
1733         if (outIsPlaying) {
1734                 *outIsPlaying = _session.transport_rolling();
1735         }
1736
1737         if (outTransportStateChanged) {
1738                 if (rolling != last_transport_rolling) {
1739                         *outTransportStateChanged = true;
1740                 } else if (speed != last_transport_speed) {
1741                         *outTransportStateChanged = true;
1742                 } else {
1743                         *outTransportStateChanged = false;
1744                 }
1745         }
1746
1747         if (outCurrentSampleInTimeLine) {
1748                 /* this assumes that the AU can only call this host callback from render context,
1749                    where input_offset is valid.
1750                 */
1751                 *outCurrentSampleInTimeLine = _session.transport_frame() + input_offset;
1752         }
1753
1754         if (outIsCycling) {
1755                 Location* loc = _session.locations()->auto_loop_location();
1756
1757                 *outIsCycling = (loc && _session.transport_rolling() && _session.get_play_loop());
1758
1759                 if (*outIsCycling) {
1760
1761                         if (outCycleStartBeat || outCycleEndBeat) {
1762
1763                                 TempoMap& tmap (_session.tempo_map());
1764
1765                                 /* more than 1 meter means that a simplistic computation (and interpretation) of
1766                                    a beat position will be incorrect. so refuse to offer the value.
1767                                 */
1768
1769                                 if (tmap.n_meters() > 1) {
1770                                         return kAudioUnitErr_CannotDoInCurrentContext;
1771                                 }
1772
1773                                 Timecode::BBT_Time bbt;
1774
1775                                 if (outCycleStartBeat) {
1776                                         TempoMetric metric = tmap.metric_at (loc->start() + input_offset);
1777                                         _session.tempo_map().bbt_time (loc->start(), bbt);
1778
1779                                         float beat;
1780                                         beat = metric.meter().divisions_per_bar() * bbt.bars;
1781                                         beat += bbt.beats;
1782                                         beat += bbt.ticks / Timecode::BBT_Time::ticks_per_beat;
1783
1784                                         *outCycleStartBeat = beat;
1785                                 }
1786
1787                                 if (outCycleEndBeat) {
1788                                         TempoMetric metric = tmap.metric_at (loc->end() + input_offset);
1789                                         _session.tempo_map().bbt_time (loc->end(), bbt);
1790
1791                                         float beat;
1792                                         beat = metric.meter().divisions_per_bar() * bbt.bars;
1793                                         beat += bbt.beats;
1794                                         beat += bbt.ticks / Timecode::BBT_Time::ticks_per_beat;
1795
1796                                         *outCycleEndBeat = beat;
1797                                 }
1798                         }
1799                 }
1800         }
1801
1802         last_transport_rolling = rolling;
1803         last_transport_speed = speed;
1804
1805         return noErr;
1806 }
1807
1808 set<Evoral::Parameter>
1809 AUPlugin::automatable() const
1810 {
1811         set<Evoral::Parameter> automates;
1812
1813         for (uint32_t i = 0; i < descriptors.size(); ++i) {
1814                 if (descriptors[i].automatable) {
1815                         automates.insert (automates.end(), Evoral::Parameter (PluginAutomation, 0, i));
1816                 }
1817         }
1818
1819         return automates;
1820 }
1821
1822 string
1823 AUPlugin::describe_parameter (Evoral::Parameter param)
1824 {
1825         if (param.type() == PluginAutomation && param.id() < parameter_count()) {
1826                 return descriptors[param.id()].label;
1827         } else {
1828                 return "??";
1829         }
1830 }
1831
1832 void
1833 AUPlugin::print_parameter (uint32_t /*param*/, char* /*buf*/, uint32_t /*len*/) const
1834 {
1835         // NameValue stuff here
1836 }
1837
1838 bool
1839 AUPlugin::parameter_is_audio (uint32_t) const
1840 {
1841         return false;
1842 }
1843
1844 bool
1845 AUPlugin::parameter_is_control (uint32_t param) const
1846 {
1847         assert(param < descriptors.size());
1848         if (descriptors[param].automatable) {
1849                 /* corrently ardour expects all controls to be automatable
1850                  * IOW ardour GUI elements mandate an Evoral::Parameter
1851                  * for all input+control ports.
1852                  */
1853                 return true;
1854         }
1855         return false;
1856 }
1857
1858 bool
1859 AUPlugin::parameter_is_input (uint32_t param) const
1860 {
1861         /* AU params that are both readable and writeable,
1862          * are listed in kAudioUnitScope_Global
1863          */
1864         return (descriptors[param].scope == kAudioUnitScope_Input || descriptors[param].scope == kAudioUnitScope_Global);
1865 }
1866
1867 bool
1868 AUPlugin::parameter_is_output (uint32_t param) const
1869 {
1870         assert(param < descriptors.size());
1871         // TODO check if ardour properly handles ports
1872         // that report is_input + is_output == true
1873         // -> add || descriptors[param].scope == kAudioUnitScope_Global
1874         return (descriptors[param].scope == kAudioUnitScope_Output);
1875 }
1876
1877 void
1878 AUPlugin::add_state (XMLNode* root) const
1879 {
1880         LocaleGuard lg (X_("C"));
1881         CFDataRef xmlData;
1882         CFPropertyListRef propertyList;
1883
1884         DEBUG_TRACE (DEBUG::AudioUnits, "get preset state\n");
1885         if (unit->GetAUPreset (propertyList) != noErr) {
1886                 return;
1887         }
1888
1889         // Convert the property list into XML data.
1890
1891         xmlData = CFPropertyListCreateXMLData( kCFAllocatorDefault, propertyList);
1892
1893         if (!xmlData) {
1894                 error << _("Could not create XML version of property list") << endmsg;
1895                 return;
1896         }
1897
1898         /* re-parse XML bytes to create a libxml++ XMLTree that we can merge into
1899            our state node. GACK!
1900         */
1901
1902         XMLTree t;
1903
1904         if (t.read_buffer (string ((const char*) CFDataGetBytePtr (xmlData), CFDataGetLength (xmlData)))) {
1905                 if (t.root()) {
1906                         root->add_child_copy (*t.root());
1907                 }
1908         }
1909
1910         CFRelease (xmlData);
1911         CFRelease (propertyList);
1912 }
1913
1914 int
1915 AUPlugin::set_state(const XMLNode& node, int version)
1916 {
1917         int ret = -1;
1918         CFPropertyListRef propertyList;
1919         LocaleGuard lg (X_("C"));
1920
1921         if (node.name() != state_node_name()) {
1922                 error << _("Bad node sent to AUPlugin::set_state") << endmsg;
1923                 return -1;
1924         }
1925
1926 #ifndef NO_PLUGIN_STATE
1927         if (node.children().empty()) {
1928                 return -1;
1929         }
1930
1931         XMLNode* top = node.children().front();
1932         XMLNode* copy = new XMLNode (*top);
1933
1934         XMLTree t;
1935         t.set_root (copy);
1936
1937         const string& xml = t.write_buffer ();
1938         CFDataRef xmlData = CFDataCreateWithBytesNoCopy (kCFAllocatorDefault, (UInt8*) xml.data(), xml.length(), kCFAllocatorNull);
1939         CFStringRef errorString;
1940
1941         propertyList = CFPropertyListCreateFromXMLData( kCFAllocatorDefault,
1942                                                         xmlData,
1943                                                         kCFPropertyListImmutable,
1944                                                         &errorString);
1945
1946         CFRelease (xmlData);
1947
1948         if (propertyList) {
1949                 DEBUG_TRACE (DEBUG::AudioUnits, "set preset\n");
1950                 if (unit->SetAUPreset (propertyList) == noErr) {
1951                         ret = 0;
1952
1953                         /* tell the world */
1954
1955                         AudioUnitParameter changedUnit;
1956                         changedUnit.mAudioUnit = unit->AU();
1957                         changedUnit.mParameterID = kAUParameterListener_AnyParameter;
1958                         AUParameterListenerNotify (NULL, NULL, &changedUnit);
1959                 }
1960                 CFRelease (propertyList);
1961         }
1962 #endif
1963
1964         Plugin::set_state (node, version);
1965         return ret;
1966 }
1967
1968 bool
1969 AUPlugin::load_preset (PresetRecord r)
1970 {
1971         Plugin::load_preset (r);
1972
1973         bool ret = false;
1974         CFPropertyListRef propertyList;
1975         Glib::ustring path;
1976         UserPresetMap::iterator ux;
1977         FactoryPresetMap::iterator fx;
1978
1979         /* look first in "user" presets */
1980
1981         if ((ux = user_preset_map.find (r.label)) != user_preset_map.end()) {
1982
1983                 if ((propertyList = load_property_list (ux->second)) != 0) {
1984                         DEBUG_TRACE (DEBUG::AudioUnits, "set preset from user presets\n");
1985                         if (unit->SetAUPreset (propertyList) == noErr) {
1986                                 ret = true;
1987
1988                                 /* tell the world */
1989
1990                                 AudioUnitParameter changedUnit;
1991                                 changedUnit.mAudioUnit = unit->AU();
1992                                 changedUnit.mParameterID = kAUParameterListener_AnyParameter;
1993                                 AUParameterListenerNotify (NULL, NULL, &changedUnit);
1994                         }
1995                         CFRelease(propertyList);
1996                 }
1997
1998         } else if ((fx = factory_preset_map.find (r.label)) != factory_preset_map.end()) {
1999
2000                 AUPreset preset;
2001
2002                 preset.presetNumber = fx->second;
2003                 preset.presetName = CFStringCreateWithCString (kCFAllocatorDefault, fx->first.c_str(), kCFStringEncodingUTF8);
2004
2005                 DEBUG_TRACE (DEBUG::AudioUnits, "set preset from factory presets\n");
2006
2007                 if (unit->SetPresentPreset (preset) == 0) {
2008                         ret = true;
2009
2010                         /* tell the world */
2011
2012                         AudioUnitParameter changedUnit;
2013                         changedUnit.mAudioUnit = unit->AU();
2014                         changedUnit.mParameterID = kAUParameterListener_AnyParameter;
2015                         AUParameterListenerNotify (NULL, NULL, &changedUnit);
2016                 }
2017         }
2018
2019         return ret;
2020 }
2021
2022 void
2023 AUPlugin::do_remove_preset (std::string)
2024 {
2025 }
2026
2027 string
2028 AUPlugin::do_save_preset (string preset_name)
2029 {
2030         CFPropertyListRef propertyList;
2031         vector<Glib::ustring> v;
2032         Glib::ustring user_preset_path;
2033
2034         std::string m = maker();
2035         std::string n = name();
2036
2037         strip_whitespace_edges (m);
2038         strip_whitespace_edges (n);
2039
2040         v.push_back (Glib::get_home_dir());
2041         v.push_back ("Library");
2042         v.push_back ("Audio");
2043         v.push_back ("Presets");
2044         v.push_back (m);
2045         v.push_back (n);
2046
2047         user_preset_path = Glib::build_filename (v);
2048
2049         if (g_mkdir_with_parents (user_preset_path.c_str(), 0775) < 0) {
2050                 error << string_compose (_("Cannot create user plugin presets folder (%1)"), user_preset_path) << endmsg;
2051                 return string();
2052         }
2053
2054         DEBUG_TRACE (DEBUG::AudioUnits, "get current preset\n");
2055         if (unit->GetAUPreset (propertyList) != noErr) {
2056                 return string();
2057         }
2058
2059         // add the actual preset name */
2060
2061         v.push_back (preset_name + preset_suffix);
2062
2063         // rebuild
2064
2065         user_preset_path = Glib::build_filename (v);
2066
2067         set_preset_name_in_plist (propertyList, preset_name);
2068
2069         if (save_property_list (propertyList, user_preset_path)) {
2070                 error << string_compose (_("Saving plugin state to %1 failed"), user_preset_path) << endmsg;
2071                 return string();
2072         }
2073
2074         CFRelease(propertyList);
2075
2076         user_preset_map[preset_name] = user_preset_path;;
2077
2078         DEBUG_TRACE (DEBUG::AudioUnits, string_compose("AU Saving Preset to %1\n", user_preset_path));
2079
2080         return string ("file:///") + user_preset_path;
2081 }
2082
2083 //-----------------------------------------------------------------------------
2084 // this is just a little helper function used by GetAUComponentDescriptionFromPresetFile()
2085 static SInt32
2086 GetDictionarySInt32Value(CFDictionaryRef inAUStateDictionary, CFStringRef inDictionaryKey, Boolean * outSuccess)
2087 {
2088         CFNumberRef cfNumber;
2089         SInt32 numberValue = 0;
2090         Boolean dummySuccess;
2091
2092         if (outSuccess == NULL)
2093                 outSuccess = &dummySuccess;
2094         if ( (inAUStateDictionary == NULL) || (inDictionaryKey == NULL) )
2095         {
2096                 *outSuccess = FALSE;
2097                 return 0;
2098         }
2099
2100         cfNumber = (CFNumberRef) CFDictionaryGetValue(inAUStateDictionary, inDictionaryKey);
2101         if (cfNumber == NULL)
2102         {
2103                 *outSuccess = FALSE;
2104                 return 0;
2105         }
2106         *outSuccess = CFNumberGetValue(cfNumber, kCFNumberSInt32Type, &numberValue);
2107         if (*outSuccess)
2108                 return numberValue;
2109         else
2110                 return 0;
2111 }
2112
2113 static OSStatus
2114 GetAUComponentDescriptionFromStateData(CFPropertyListRef inAUStateData, ArdourDescription * outComponentDescription)
2115 {
2116         CFDictionaryRef auStateDictionary;
2117         ArdourDescription tempDesc = {0,0,0,0,0};
2118         SInt32 versionValue;
2119         Boolean gotValue;
2120
2121         if ( (inAUStateData == NULL) || (outComponentDescription == NULL) )
2122                 return paramErr;
2123
2124         // the property list for AU state data must be of the dictionary type
2125         if (CFGetTypeID(inAUStateData) != CFDictionaryGetTypeID()) {
2126                 return kAudioUnitErr_InvalidPropertyValue;
2127         }
2128
2129         auStateDictionary = (CFDictionaryRef)inAUStateData;
2130
2131         // first check to make sure that the version of the AU state data is one that we know understand
2132         // XXX should I really do this?  later versions would probably still hold these ID keys, right?
2133         versionValue = GetDictionarySInt32Value(auStateDictionary, CFSTR(kAUPresetVersionKey), &gotValue);
2134
2135         if (!gotValue) {
2136                 return kAudioUnitErr_InvalidPropertyValue;
2137         }
2138 #define kCurrentSavedStateVersion 0
2139         if (versionValue != kCurrentSavedStateVersion) {
2140                 return kAudioUnitErr_InvalidPropertyValue;
2141         }
2142
2143         // grab the ComponentDescription values from the AU state data
2144         tempDesc.componentType = (OSType) GetDictionarySInt32Value(auStateDictionary, CFSTR(kAUPresetTypeKey), NULL);
2145         tempDesc.componentSubType = (OSType) GetDictionarySInt32Value(auStateDictionary, CFSTR(kAUPresetSubtypeKey), NULL);
2146         tempDesc.componentManufacturer = (OSType) GetDictionarySInt32Value(auStateDictionary, CFSTR(kAUPresetManufacturerKey), NULL);
2147         // zero values are illegit for specific ComponentDescriptions, so zero for any value means that there was an error
2148         if ( (tempDesc.componentType == 0) || (tempDesc.componentSubType == 0) || (tempDesc.componentManufacturer == 0) )
2149                 return kAudioUnitErr_InvalidPropertyValue;
2150
2151         *outComponentDescription = tempDesc;
2152         return noErr;
2153 }
2154
2155
2156 static bool au_preset_filter (const string& str, void* arg)
2157 {
2158         /* Not a dotfile, has a prefix before a period, suffix is aupreset */
2159
2160         bool ret;
2161
2162         ret = (str[0] != '.' && str.length() > 9 && str.find (preset_suffix) == (str.length() - preset_suffix.length()));
2163
2164         if (ret && arg) {
2165
2166                 /* check the preset file path name against this plugin
2167                    ID. The idea is that all preset files for this plugin
2168                    include "<manufacturer>/<plugin-name>" in their path.
2169                 */
2170
2171                 AUPluginInfo* p = (AUPluginInfo *) arg;
2172                 string match = p->creator;
2173                 match += '/';
2174                 match += p->name;
2175
2176                 ret = str.find (match) != string::npos;
2177
2178                 if (ret == false) {
2179                         string m = p->creator;
2180                         string n = p->name;
2181                         strip_whitespace_edges (m);
2182                         strip_whitespace_edges (n);
2183                         match = m;
2184                         match += '/';
2185                         match += n;
2186
2187                         ret = str.find (match) != string::npos;
2188                 }
2189         }
2190
2191         return ret;
2192 }
2193
2194 static bool
2195 check_and_get_preset_name (ArdourComponent component, const string& pathstr, string& preset_name)
2196 {
2197         OSStatus status;
2198         CFPropertyListRef plist;
2199         ArdourDescription presetDesc;
2200         bool ret = false;
2201
2202         plist = load_property_list (pathstr);
2203
2204         if (!plist) {
2205                 return ret;
2206         }
2207
2208         // get the ComponentDescription from the AU preset file
2209
2210         status = GetAUComponentDescriptionFromStateData(plist, &presetDesc);
2211
2212         if (status == noErr) {
2213                 if (ComponentAndDescriptionMatch_Loosely(component, &presetDesc)) {
2214
2215                         /* try to get the preset name from the property list */
2216
2217                         if (CFGetTypeID(plist) == CFDictionaryGetTypeID()) {
2218
2219                                 const void* psk = CFDictionaryGetValue ((CFMutableDictionaryRef)plist, CFSTR(kAUPresetNameKey));
2220
2221                                 if (psk) {
2222
2223                                         const char* p = CFStringGetCStringPtr ((CFStringRef) psk, kCFStringEncodingUTF8);
2224
2225                                         if (!p) {
2226                                                 char buf[PATH_MAX+1];
2227
2228                                                 if (CFStringGetCString ((CFStringRef)psk, buf, sizeof (buf), kCFStringEncodingUTF8)) {
2229                                                         preset_name = buf;
2230                                                 }
2231                                         }
2232                                 }
2233                         }
2234                 }
2235         }
2236
2237         CFRelease (plist);
2238
2239         return true;
2240 }
2241
2242
2243 static void
2244 #ifdef COREAUDIO105
2245 get_names (CAComponentDescription& comp_desc, std::string& name, std::string& maker)
2246 #else
2247 get_names (ArdourComponent& comp, std::string& name, std::string& maker)
2248 #endif
2249 {
2250         CFStringRef itemName = NULL;
2251         // Marc Poirier-style item name
2252 #ifdef COREAUDIO105
2253         CAComponent auComponent (comp_desc);
2254         if (auComponent.IsValid()) {
2255                 CAComponentDescription dummydesc;
2256                 Handle nameHandle = NewHandle(sizeof(void*));
2257                 if (nameHandle != NULL) {
2258                         OSErr err = GetComponentInfo(auComponent.Comp(), &dummydesc, nameHandle, NULL, NULL);
2259                         if (err == noErr) {
2260                                 ConstStr255Param nameString = (ConstStr255Param) (*nameHandle);
2261                                 if (nameString != NULL) {
2262                                         itemName = CFStringCreateWithPascalString(kCFAllocatorDefault, nameString, CFStringGetSystemEncoding());
2263                                 }
2264                         }
2265                         DisposeHandle(nameHandle);
2266                 }
2267         }
2268 #else
2269         assert (comp);
2270         AudioComponentCopyName (comp, &itemName);
2271 #endif
2272
2273         // if Marc-style fails, do the original way
2274         if (itemName == NULL) {
2275 #ifndef COREAUDIO105
2276                 CAComponentDescription comp_desc;
2277                 AudioComponentGetDescription (comp, &comp_desc);
2278 #endif
2279                 CFStringRef compTypeString = UTCreateStringForOSType(comp_desc.componentType);
2280                 CFStringRef compSubTypeString = UTCreateStringForOSType(comp_desc.componentSubType);
2281                 CFStringRef compManufacturerString = UTCreateStringForOSType(comp_desc.componentManufacturer);
2282
2283                 itemName = CFStringCreateWithFormat(kCFAllocatorDefault, NULL, CFSTR("%@ - %@ - %@"),
2284                                 compTypeString, compManufacturerString, compSubTypeString);
2285
2286                 if (compTypeString != NULL)
2287                         CFRelease(compTypeString);
2288                 if (compSubTypeString != NULL)
2289                         CFRelease(compSubTypeString);
2290                 if (compManufacturerString != NULL)
2291                         CFRelease(compManufacturerString);
2292         }
2293
2294         string str = CFStringRefToStdString(itemName);
2295         string::size_type colon = str.find (':');
2296
2297         if (colon) {
2298                 name = str.substr (colon+1);
2299                 maker = str.substr (0, colon);
2300                 strip_whitespace_edges (maker);
2301                 strip_whitespace_edges (name);
2302         } else {
2303                 name = str;
2304                 maker = "unknown";
2305                 strip_whitespace_edges (name);
2306         }
2307 }
2308
2309 std::string
2310 AUPlugin::current_preset() const
2311 {
2312         string preset_name;
2313
2314         CFPropertyListRef propertyList;
2315
2316         DEBUG_TRACE (DEBUG::AudioUnits, "get current preset for current_preset()\n");
2317         if (unit->GetAUPreset (propertyList) == noErr) {
2318                 preset_name = get_preset_name_in_plist (propertyList);
2319                 CFRelease(propertyList);
2320         }
2321
2322         return preset_name;
2323 }
2324
2325 void
2326 AUPlugin::find_presets ()
2327 {
2328         vector<string> preset_files;
2329
2330         user_preset_map.clear ();
2331
2332         PluginInfoPtr nfo = get_info();
2333         find_files_matching_filter (preset_files, preset_search_path, au_preset_filter,
2334                         boost::dynamic_pointer_cast<AUPluginInfo> (nfo).get(),
2335                         true, true, true);
2336
2337         if (preset_files.empty()) {
2338                 DEBUG_TRACE (DEBUG::AudioUnits, "AU No Preset Files found for given plugin.\n");
2339         }
2340
2341         for (vector<string>::iterator x = preset_files.begin(); x != preset_files.end(); ++x) {
2342
2343                 string path = *x;
2344                 string preset_name;
2345
2346                 /* make an initial guess at the preset name using the path */
2347
2348                 preset_name = Glib::path_get_basename (path);
2349                 preset_name = preset_name.substr (0, preset_name.find_last_of ('.'));
2350
2351                 /* check that this preset file really matches this plugin
2352                    and potentially get the "real" preset name from
2353                    within the file.
2354                 */
2355
2356                 if (check_and_get_preset_name (get_comp()->Comp(), path, preset_name)) {
2357                         user_preset_map[preset_name] = path;
2358                         DEBUG_TRACE (DEBUG::AudioUnits, string_compose("AU Preset File: %1 > %2\n", preset_name, path));
2359                 } else {
2360                         DEBUG_TRACE (DEBUG::AudioUnits, string_compose("AU INVALID Preset: %1 > %2\n", preset_name, path));
2361                 }
2362
2363         }
2364
2365         /* now fill the vector<string> with the names we have */
2366
2367         for (UserPresetMap::iterator i = user_preset_map.begin(); i != user_preset_map.end(); ++i) {
2368                 _presets.insert (make_pair (i->second, Plugin::PresetRecord (i->second, i->first)));
2369                 DEBUG_TRACE (DEBUG::AudioUnits, string_compose("AU Adding User Preset: %1 > %2\n", i->first, i->second));
2370         }
2371
2372         /* add factory presets */
2373
2374         for (FactoryPresetMap::iterator i = factory_preset_map.begin(); i != factory_preset_map.end(); ++i) {
2375                 /* XXX: dubious */
2376                 string const uri = string_compose ("%1", _presets.size ());
2377                 _presets.insert (make_pair (uri, Plugin::PresetRecord (uri, i->first, false)));
2378                 DEBUG_TRACE (DEBUG::AudioUnits, string_compose("AU Adding Factory Preset: %1 > %2\n", i->first, i->second));
2379         }
2380 }
2381
2382 bool
2383 AUPlugin::has_editor () const
2384 {
2385         // even if the plugin doesn't have its own editor, the AU API can be used
2386         // to create one that looks native.
2387         return true;
2388 }
2389
2390 AUPluginInfo::AUPluginInfo (boost::shared_ptr<CAComponentDescription> d)
2391         : descriptor (d)
2392         , version (0)
2393 {
2394         type = ARDOUR::AudioUnit;
2395 }
2396
2397 AUPluginInfo::~AUPluginInfo ()
2398 {
2399         type = ARDOUR::AudioUnit;
2400 }
2401
2402 PluginPtr
2403 AUPluginInfo::load (Session& session)
2404 {
2405         try {
2406                 PluginPtr plugin;
2407
2408                 DEBUG_TRACE (DEBUG::AudioUnits, "load AU as a component\n");
2409                 boost::shared_ptr<CAComponent> comp (new CAComponent(*descriptor));
2410
2411                 if (!comp->IsValid()) {
2412                         error << ("AudioUnit: not a valid Component") << endmsg;
2413                 } else {
2414                         plugin.reset (new AUPlugin (session.engine(), session, comp));
2415                 }
2416
2417                 AUPluginInfo *aup = new AUPluginInfo (*this);
2418                 DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("plugin info for %1 = %2\n", this, aup));
2419                 plugin->set_info (PluginInfoPtr (aup));
2420                 boost::dynamic_pointer_cast<AUPlugin> (plugin)->set_fixed_size_buffers (aup->creator == "Universal Audio");
2421                 return plugin;
2422         }
2423
2424         catch (failed_constructor &err) {
2425                 DEBUG_TRACE (DEBUG::AudioUnits, "failed to load component/plugin\n");
2426                 return PluginPtr ();
2427         }
2428 }
2429
2430 std::vector<Plugin::PresetRecord>
2431 AUPluginInfo::get_presets (bool user_only) const
2432 {
2433         std::vector<Plugin::PresetRecord> p;
2434         boost::shared_ptr<CAComponent> comp;
2435 #ifndef NO_PLUGIN_STATE
2436         try {
2437                 comp = boost::shared_ptr<CAComponent>(new CAComponent(*descriptor));
2438                 if (!comp->IsValid()) {
2439                         throw failed_constructor();
2440                 }
2441         } catch (failed_constructor& err) {
2442                 return p;
2443         }
2444
2445         // user presets
2446
2447         if (!preset_search_path_initialized) {
2448                 Glib::ustring p = Glib::get_home_dir();
2449                 p += "/Library/Audio/Presets:";
2450                 p += preset_search_path;
2451                 preset_search_path = p;
2452                 preset_search_path_initialized = true;
2453                 DEBUG_TRACE (DEBUG::AudioUnits, string_compose("AU Preset Path: %1\n", preset_search_path));
2454         }
2455
2456         vector<string> preset_files;
2457         find_files_matching_filter (preset_files, preset_search_path, au_preset_filter, const_cast<AUPluginInfo*>(this), true, true, true);
2458
2459         for (vector<string>::iterator x = preset_files.begin(); x != preset_files.end(); ++x) {
2460                 string path = *x;
2461                 string preset_name;
2462                 preset_name = Glib::path_get_basename (path);
2463                 preset_name = preset_name.substr (0, preset_name.find_last_of ('.'));
2464                 if (check_and_get_preset_name (comp.get()->Comp(), path, preset_name)) {
2465                         p.push_back (Plugin::PresetRecord (path, preset_name));
2466                 }
2467         }
2468
2469         if (user_only) {
2470                 return p;
2471         }
2472
2473         // factory presets
2474
2475         CFArrayRef presets;
2476         UInt32 dataSize;
2477         Boolean isWritable;
2478
2479         boost::shared_ptr<CAAudioUnit> unit (new CAAudioUnit);
2480         if (noErr != CAAudioUnit::Open (*(comp.get()), *unit)) {
2481                 return p;
2482         }
2483         if (noErr != unit->GetPropertyInfo (kAudioUnitProperty_FactoryPresets, kAudioUnitScope_Global, 0, &dataSize, &isWritable)) {
2484                 unit->Uninitialize ();
2485                 return p;
2486         }
2487         if (noErr != unit->GetProperty (kAudioUnitProperty_FactoryPresets, kAudioUnitScope_Global, 0, (void*) &presets, &dataSize)) {
2488                 unit->Uninitialize ();
2489                 return p;
2490         }
2491         if (!presets) {
2492                 unit->Uninitialize ();
2493                 return p;
2494         }
2495
2496         CFIndex cnt = CFArrayGetCount (presets);
2497         for (CFIndex i = 0; i < cnt; ++i) {
2498                 AUPreset* preset = (AUPreset*) CFArrayGetValueAtIndex (presets, i);
2499                 string const uri = string_compose ("%1", i);
2500                 string name = CFStringRefToStdString (preset->presetName);
2501                 p.push_back (Plugin::PresetRecord (uri, name, false));
2502         }
2503         CFRelease (presets);
2504         unit->Uninitialize ();
2505
2506 #endif // NO_PLUGIN_STATE
2507         return p;
2508 }
2509
2510 Glib::ustring
2511 AUPluginInfo::au_cache_path ()
2512 {
2513         return Glib::build_filename (ARDOUR::user_cache_directory(), "au_cache");
2514 }
2515
2516 PluginInfoList*
2517 AUPluginInfo::discover (bool scan_only)
2518 {
2519         XMLTree tree;
2520
2521         /* AU require a CAComponentDescription pointer provided by the OS.
2522          * Ardour only caches port and i/o config. It can't just 'scan' without
2523          * 'discovering' (like we do for VST).
2524          *
2525          * "Scan Only" means
2526          * "Iterate over all plugins. skip the ones where there's no io-cache".
2527          */
2528         _scan_only = scan_only;
2529
2530         if (!Glib::file_test (au_cache_path(), Glib::FILE_TEST_EXISTS)) {
2531                 ARDOUR::BootMessage (_("Discovering AudioUnit plugins (could take some time ...)"));
2532         }
2533         // create crash log file
2534         au_start_crashlog ();
2535
2536         PluginInfoList* plugs = new PluginInfoList;
2537
2538         discover_fx (*plugs);
2539         discover_music (*plugs);
2540         discover_generators (*plugs);
2541         discover_instruments (*plugs);
2542
2543         // all fine if we get here
2544         au_remove_crashlog ();
2545
2546         DEBUG_TRACE (DEBUG::PluginManager, string_compose ("AU: discovered %1 plugins\n", plugs->size()));
2547
2548         return plugs;
2549 }
2550
2551 void
2552 AUPluginInfo::discover_music (PluginInfoList& plugs)
2553 {
2554         CAComponentDescription desc;
2555         desc.componentFlags = 0;
2556         desc.componentFlagsMask = 0;
2557         desc.componentSubType = 0;
2558         desc.componentManufacturer = 0;
2559         desc.componentType = kAudioUnitType_MusicEffect;
2560
2561         discover_by_description (plugs, desc);
2562 }
2563
2564 void
2565 AUPluginInfo::discover_fx (PluginInfoList& plugs)
2566 {
2567         CAComponentDescription desc;
2568         desc.componentFlags = 0;
2569         desc.componentFlagsMask = 0;
2570         desc.componentSubType = 0;
2571         desc.componentManufacturer = 0;
2572         desc.componentType = kAudioUnitType_Effect;
2573
2574         discover_by_description (plugs, desc);
2575 }
2576
2577 void
2578 AUPluginInfo::discover_generators (PluginInfoList& plugs)
2579 {
2580         CAComponentDescription desc;
2581         desc.componentFlags = 0;
2582         desc.componentFlagsMask = 0;
2583         desc.componentSubType = 0;
2584         desc.componentManufacturer = 0;
2585         desc.componentType = kAudioUnitType_Generator;
2586
2587         discover_by_description (plugs, desc);
2588 }
2589
2590 void
2591 AUPluginInfo::discover_instruments (PluginInfoList& plugs)
2592 {
2593         CAComponentDescription desc;
2594         desc.componentFlags = 0;
2595         desc.componentFlagsMask = 0;
2596         desc.componentSubType = 0;
2597         desc.componentManufacturer = 0;
2598         desc.componentType = kAudioUnitType_MusicDevice;
2599
2600         discover_by_description (plugs, desc);
2601 }
2602
2603
2604 bool
2605 AUPluginInfo::au_get_crashlog (std::string &msg)
2606 {
2607         string fn = Glib::build_filename (ARDOUR::user_cache_directory(), "au_crashlog.txt");
2608         if (!Glib::file_test (fn, Glib::FILE_TEST_EXISTS)) {
2609                 return false;
2610         }
2611         std::ifstream ifs(fn.c_str());
2612         msg.assign ((std::istreambuf_iterator<char>(ifs)), (std::istreambuf_iterator<char>()));
2613         au_remove_crashlog ();
2614         return true;
2615 }
2616
2617 void
2618 AUPluginInfo::au_start_crashlog ()
2619 {
2620         string fn = Glib::build_filename (ARDOUR::user_cache_directory(), "au_crashlog.txt");
2621         assert(!_crashlog_fd);
2622         DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("Creating AU Log: %1\n", fn));
2623         if (!(_crashlog_fd = fopen(fn.c_str(), "w"))) {
2624                 PBD::error << "Cannot create AU error-log" << fn << "\n";
2625                 cerr << "Cannot create AU error-log" << fn << "\n";
2626         }
2627 }
2628
2629 void
2630 AUPluginInfo::au_remove_crashlog ()
2631 {
2632         if (_crashlog_fd) {
2633                 ::fclose(_crashlog_fd);
2634                 _crashlog_fd = NULL;
2635         }
2636         string fn = Glib::build_filename (ARDOUR::user_cache_directory(), "au_crashlog.txt");
2637         ::g_unlink(fn.c_str());
2638         DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("Remove AU Log: %1\n", fn));
2639 }
2640
2641
2642 void
2643 AUPluginInfo::au_crashlog (std::string msg)
2644 {
2645         if (!_crashlog_fd) {
2646                 fprintf(stderr, "AU: %s\n", msg.c_str());
2647         } else {
2648                 fprintf(_crashlog_fd, "AU: %s\n", msg.c_str());
2649                 ::fflush(_crashlog_fd);
2650         }
2651 }
2652
2653 void
2654 AUPluginInfo::discover_by_description (PluginInfoList& plugs, CAComponentDescription& desc)
2655 {
2656         ArdourComponent comp = 0;
2657         au_crashlog(string_compose("Start AU discovery for Type: %1", (int)desc.componentType));
2658
2659         comp = ArdourFindNext (NULL, &desc);
2660
2661         while (comp != NULL) {
2662                 CAComponentDescription temp;
2663 #ifdef COREAUDIO105
2664                 GetComponentInfo (comp, &temp, NULL, NULL, NULL);
2665 #else
2666                 AudioComponentGetDescription (comp, &temp);
2667 #endif
2668                 CFStringRef itemName = NULL;
2669
2670                 {
2671                         if (itemName != NULL) CFRelease(itemName);
2672                         CFStringRef compTypeString = UTCreateStringForOSType(temp.componentType);
2673                         CFStringRef compSubTypeString = UTCreateStringForOSType(temp.componentSubType);
2674                         CFStringRef compManufacturerString = UTCreateStringForOSType(temp.componentManufacturer);
2675                         itemName = CFStringCreateWithFormat(kCFAllocatorDefault, NULL, CFSTR("%@ - %@ - %@"),
2676                                         compTypeString, compManufacturerString, compSubTypeString);
2677                         au_crashlog(string_compose("Scanning ID: %1", CFStringRefToStdString(itemName)));
2678                         if (compTypeString != NULL)
2679                                 CFRelease(compTypeString);
2680                         if (compSubTypeString != NULL)
2681                                 CFRelease(compSubTypeString);
2682                         if (compManufacturerString != NULL)
2683                                 CFRelease(compManufacturerString);
2684                 }
2685
2686                 if (is_blacklisted(CFStringRefToStdString(itemName))) {
2687                         info << string_compose (_("Skipped blacklisted AU plugin %1 "), CFStringRefToStdString(itemName)) << endmsg;
2688                         comp = ArdourFindNext (comp, &desc);
2689                         continue;
2690                 }
2691
2692                 bool has_midi_in = false;
2693
2694                 AUPluginInfoPtr info (new AUPluginInfo
2695                                       (boost::shared_ptr<CAComponentDescription> (new CAComponentDescription(temp))));
2696
2697                 /* although apple designed the subtype field to be a "category" indicator,
2698                    its really turned into a plugin ID field for a given manufacturer. Hence
2699                    there are no categories for AudioUnits. However, to keep the plugins
2700                    showing up under "categories", we'll use the "type" as a high level
2701                    selector.
2702
2703                    NOTE: no panners, format converters or i/o AU's for our purposes
2704                  */
2705
2706                 switch (info->descriptor->Type()) {
2707                 case kAudioUnitType_Panner:
2708                 case kAudioUnitType_OfflineEffect:
2709                 case kAudioUnitType_FormatConverter:
2710                         comp = ArdourFindNext (comp, &desc);
2711                         continue;
2712
2713                 case kAudioUnitType_Output:
2714                         info->category = _("AudioUnit Outputs");
2715                         break;
2716                 case kAudioUnitType_MusicDevice:
2717                         info->category = _("AudioUnit Instruments");
2718                         has_midi_in = true;
2719                         break;
2720                 case kAudioUnitType_MusicEffect:
2721                         info->category = _("AudioUnit MusicEffects");
2722                         has_midi_in = true;
2723                         break;
2724                 case kAudioUnitType_Effect:
2725                         info->category = _("AudioUnit Effects");
2726                         break;
2727                 case kAudioUnitType_Mixer:
2728                         info->category = _("AudioUnit Mixers");
2729                         break;
2730                 case kAudioUnitType_Generator:
2731                         info->category = _("AudioUnit Generators");
2732                         break;
2733                 default:
2734                         info->category = _("AudioUnit (Unknown)");
2735                         break;
2736                 }
2737
2738                 au_blacklist(CFStringRefToStdString(itemName));
2739 #ifdef COREAUDIO105
2740                 get_names (temp, info->name, info->creator);
2741 #else
2742                 get_names (comp, info->name, info->creator);
2743 #endif
2744                 ARDOUR::PluginScanMessage(_("AU"), info->name, false);
2745                 au_crashlog(string_compose("Plugin: %1", info->name));
2746
2747                 info->type = ARDOUR::AudioUnit;
2748                 info->unique_id = stringify_descriptor (*info->descriptor);
2749
2750                 /* XXX not sure of the best way to handle plugin versioning yet
2751                  */
2752
2753                 CAComponent cacomp (*info->descriptor);
2754
2755 #ifdef COREAUDIO105
2756                 if (cacomp.GetResourceVersion (info->version) != noErr)
2757 #else
2758                 if (cacomp.GetVersion (info->version) != noErr)
2759 #endif
2760                 {
2761                         info->version = 0;
2762                 }
2763
2764                 const int rv = cached_io_configuration (info->unique_id, info->version, cacomp, info->cache, info->name);
2765
2766                 if (rv == 0) {
2767                         /* here we have to map apple's wildcard system to a simple pair
2768                            of values. in ::can_do() we use the whole system, but here
2769                            we need a single pair of values. XXX probably means we should
2770                            remove any use of these values.
2771
2772                            for now, if the plugin provides a wildcard, treat it as 1. we really
2773                            don't care much, because whether we can handle an i/o configuration
2774                            depends upon ::can_support_io_configuration(), not these counts.
2775
2776                            they exist because other parts of ardour try to present i/o configuration
2777                            info to the user, which should perhaps be revisited.
2778                         */
2779
2780                         int32_t possible_in = info->cache.io_configs.front().first;
2781                         int32_t possible_out = info->cache.io_configs.front().second;
2782
2783                         if (possible_in > 0) {
2784                                 info->n_inputs.set (DataType::AUDIO, possible_in);
2785                         } else {
2786                                 info->n_inputs.set (DataType::AUDIO, 1);
2787                         }
2788
2789                         info->n_inputs.set (DataType::MIDI, has_midi_in ? 1 : 0);
2790
2791                         if (possible_out > 0) {
2792                                 info->n_outputs.set (DataType::AUDIO, possible_out);
2793                         } else {
2794                                 info->n_outputs.set (DataType::AUDIO, 1);
2795                         }
2796
2797                         DEBUG_TRACE (DEBUG::AudioUnits, string_compose ("detected AU %1 with %2 i/o configurations - %3\n",
2798                                                                         info->name.c_str(), info->cache.io_configs.size(), info->unique_id));
2799
2800                         plugs.push_back (info);
2801
2802                 }
2803                 else if (rv == -1) {
2804                         error << string_compose (_("Cannot get I/O configuration info for AU %1"), info->name) << endmsg;
2805                 }
2806
2807                 au_unblacklist(CFStringRefToStdString(itemName));
2808                 au_crashlog("Success.");
2809                 comp = ArdourFindNext (comp, &desc);
2810                 if (itemName != NULL) CFRelease(itemName); itemName = NULL;
2811         }
2812         au_crashlog(string_compose("End AU discovery for Type: %1", (int)desc.componentType));
2813 }
2814
2815 int
2816 AUPluginInfo::cached_io_configuration (const std::string& unique_id,
2817                                        UInt32 version,
2818                                        CAComponent& comp,
2819                                        AUPluginCachedInfo& cinfo,
2820                                        const std::string& name)
2821 {
2822         std::string id;
2823         char buf[32];
2824
2825         /* concatenate unique ID with version to provide a key for cached info lookup.
2826            this ensures we don't get stale information, or should if plugin developers
2827            follow Apple "guidelines".
2828          */
2829
2830         snprintf (buf, sizeof (buf), "%u", (uint32_t) version);
2831         id = unique_id;
2832         id += '/';
2833         id += buf;
2834
2835         CachedInfoMap::iterator cim = cached_info.find (id);
2836
2837         if (cim != cached_info.end()) {
2838                 cinfo = cim->second;
2839                 return 0;
2840         }
2841
2842         if (_scan_only) {
2843                 PBD::info << string_compose (_("Skipping AU %1 (not indexed. Discover new plugins to add)"), name) << endmsg;
2844                 return 1;
2845         }
2846
2847         CAAudioUnit unit;
2848         AUChannelInfo* channel_info;
2849         UInt32 cnt;
2850         int ret;
2851
2852         ARDOUR::BootMessage (string_compose (_("Checking AudioUnit: %1"), name));
2853
2854         try {
2855
2856                 if (CAAudioUnit::Open (comp, unit) != noErr) {
2857                         return -1;
2858                 }
2859
2860         } catch (...) {
2861
2862                 warning << string_compose (_("Could not load AU plugin %1 - ignored"), name) << endmsg;
2863                 return -1;
2864
2865         }
2866
2867         DEBUG_TRACE (DEBUG::AudioUnits, "get AU channel info\n");
2868         if ((ret = unit.GetChannelInfo (&channel_info, cnt)) < 0) {
2869                 return -1;
2870         }
2871
2872         if (ret > 0) {
2873
2874                 /* no explicit info available, so default to 1in/1out */
2875
2876                 /* XXX this is wrong. we should be indicating wildcard values */
2877
2878                 cinfo.io_configs.push_back (pair<int,int> (-1, -1));
2879
2880         } else {
2881
2882                 /* store each configuration */
2883
2884                 for (uint32_t n = 0; n < cnt; ++n) {
2885                         cinfo.io_configs.push_back (pair<int,int> (channel_info[n].inChannels,
2886                                                                    channel_info[n].outChannels));
2887                 }
2888
2889                 free (channel_info);
2890         }
2891
2892         add_cached_info (id, cinfo);
2893         save_cached_info ();
2894
2895         return 0;
2896 }
2897
2898 void
2899 AUPluginInfo::add_cached_info (const std::string& id, AUPluginCachedInfo& cinfo)
2900 {
2901         cached_info[id] = cinfo;
2902 }
2903
2904 #define AU_CACHE_VERSION "2.0"
2905
2906 void
2907 AUPluginInfo::save_cached_info ()
2908 {
2909         XMLNode* node;
2910
2911         node = new XMLNode (X_("AudioUnitPluginCache"));
2912         node->add_property( "version", AU_CACHE_VERSION );
2913
2914         for (map<string,AUPluginCachedInfo>::iterator i = cached_info.begin(); i != cached_info.end(); ++i) {
2915                 XMLNode* parent = new XMLNode (X_("plugin"));
2916                 parent->add_property ("id", i->first);
2917                 node->add_child_nocopy (*parent);
2918
2919                 for (vector<pair<int, int> >::iterator j = i->second.io_configs.begin(); j != i->second.io_configs.end(); ++j) {
2920
2921                         XMLNode* child = new XMLNode (X_("io"));
2922                         char buf[32];
2923
2924                         snprintf (buf, sizeof (buf), "%d", j->first);
2925                         child->add_property (X_("in"), buf);
2926                         snprintf (buf, sizeof (buf), "%d", j->second);
2927                         child->add_property (X_("out"), buf);
2928                         parent->add_child_nocopy (*child);
2929                 }
2930
2931         }
2932
2933         Glib::ustring path = au_cache_path ();
2934         XMLTree tree;
2935
2936         tree.set_root (node);
2937
2938         if (!tree.write (path)) {
2939                 error << string_compose (_("could not save AU cache to %1"), path) << endmsg;
2940                 g_unlink (path.c_str());
2941         }
2942 }
2943
2944 int
2945 AUPluginInfo::load_cached_info ()
2946 {
2947         Glib::ustring path = au_cache_path ();
2948         XMLTree tree;
2949
2950         if (!Glib::file_test (path, Glib::FILE_TEST_EXISTS)) {
2951                 return 0;
2952         }
2953
2954         if ( !tree.read (path) ) {
2955                 error << "au_cache is not a valid XML file.  AU plugins will be re-scanned" << endmsg;
2956                 return -1;
2957         }
2958
2959         const XMLNode* root (tree.root());
2960
2961         if (root->name() != X_("AudioUnitPluginCache")) {
2962                 return -1;
2963         }
2964
2965         //initial version has incorrectly stored i/o info, and/or garbage chars.
2966         const XMLProperty* version = root->property(X_("version"));
2967         if (! ((version != NULL) && (version->value() == X_(AU_CACHE_VERSION)))) {
2968                 error << "au_cache is not correct version.  AU plugins will be re-scanned" << endmsg;
2969                 return -1;
2970         }
2971
2972         cached_info.clear ();
2973
2974         const XMLNodeList children = root->children();
2975
2976         for (XMLNodeConstIterator iter = children.begin(); iter != children.end(); ++iter) {
2977
2978                 const XMLNode* child = *iter;
2979
2980                 if (child->name() == X_("plugin")) {
2981
2982                         const XMLNode* gchild;
2983                         const XMLNodeList gchildren = child->children();
2984                         const XMLProperty* prop = child->property (X_("id"));
2985
2986                         if (!prop) {
2987                                 continue;
2988                         }
2989
2990                         string id = prop->value();
2991                         string fixed;
2992                         string version;
2993
2994                         string::size_type slash = id.find_last_of ('/');
2995
2996                         if (slash == string::npos) {
2997                                 continue;
2998                         }
2999
3000                         version = id.substr (slash);
3001                         id = id.substr (0, slash);
3002                         fixed = AUPlugin::maybe_fix_broken_au_id (id);
3003
3004                         if (fixed.empty()) {
3005                                 error << string_compose (_("Your AudioUnit configuration cache contains an AU plugin whose ID cannot be understood - ignored (%1)"), id) << endmsg;
3006                                 continue;
3007                         }
3008
3009                         id = fixed;
3010                         id += version;
3011
3012                         AUPluginCachedInfo cinfo;
3013
3014                         for (XMLNodeConstIterator giter = gchildren.begin(); giter != gchildren.end(); giter++) {
3015
3016                                 gchild = *giter;
3017
3018                                 if (gchild->name() == X_("io")) {
3019
3020                                         int in;
3021                                         int out;
3022                                         const XMLProperty* iprop;
3023                                         const XMLProperty* oprop;
3024
3025                                         if (((iprop = gchild->property (X_("in"))) != 0) &&
3026                                             ((oprop = gchild->property (X_("out"))) != 0)) {
3027                                                 in = atoi (iprop->value());
3028                                                 out = atoi (oprop->value());
3029
3030                                                 cinfo.io_configs.push_back (pair<int,int> (in, out));
3031                                         }
3032                                 }
3033                         }
3034
3035                         if (cinfo.io_configs.size()) {
3036                                 add_cached_info (id, cinfo);
3037                         }
3038                 }
3039         }
3040
3041         return 0;
3042 }
3043
3044
3045 std::string
3046 AUPluginInfo::stringify_descriptor (const CAComponentDescription& desc)
3047 {
3048         stringstream s;
3049
3050         /* note: OSType is a compiler-implemenation-defined value,
3051            historically a 32 bit integer created with a multi-character
3052            constant such as 'abcd'. It is, fundamentally, an abomination.
3053         */
3054
3055         s << desc.Type();
3056         s << '-';
3057         s << desc.SubType();
3058         s << '-';
3059         s << desc.Manu();
3060
3061         return s.str();
3062 }
3063
3064 bool
3065 AUPluginInfo::needs_midi_input () const
3066 {
3067         return is_effect_with_midi_input () || is_instrument ();
3068 }
3069
3070 bool
3071 AUPluginInfo::is_effect () const
3072 {
3073         return is_effect_without_midi_input() || is_effect_with_midi_input();
3074 }
3075
3076 bool
3077 AUPluginInfo::is_effect_without_midi_input () const
3078 {
3079         return descriptor->IsAUFX();
3080 }
3081
3082 bool
3083 AUPluginInfo::is_effect_with_midi_input () const
3084 {
3085         return descriptor->IsAUFM();
3086 }
3087
3088 bool
3089 AUPluginInfo::is_instrument () const
3090 {
3091         return descriptor->IsMusicDevice();
3092 }
3093
3094 void
3095 AUPlugin::set_info (PluginInfoPtr info)
3096 {
3097         Plugin::set_info (info);
3098
3099         AUPluginInfoPtr pinfo = boost::dynamic_pointer_cast<AUPluginInfo>(get_info());
3100         _has_midi_input = pinfo->needs_midi_input ();
3101         _has_midi_output = false;
3102 }
3103
3104 int
3105 AUPlugin::create_parameter_listener (AUEventListenerProc cb, void* arg, float interval_secs)
3106 {
3107 #ifdef WITH_CARBON
3108         CFRunLoopRef run_loop = (CFRunLoopRef) GetCFRunLoopFromEventLoop(GetCurrentEventLoop());
3109 #else
3110         CFRunLoopRef run_loop = CFRunLoopGetCurrent();
3111 #endif
3112         CFStringRef  loop_mode = kCFRunLoopDefaultMode;
3113
3114         if (AUEventListenerCreate (cb, arg, run_loop, loop_mode, interval_secs, interval_secs, &_parameter_listener) != noErr) {
3115                 return -1;
3116         }
3117
3118         _parameter_listener_arg = arg;
3119
3120         return 0;
3121 }
3122
3123 int
3124 AUPlugin::listen_to_parameter (uint32_t param_id)
3125 {
3126         AudioUnitEvent      event;
3127
3128         if (!_parameter_listener || param_id >= descriptors.size()) {
3129                 return -2;
3130         }
3131
3132         event.mEventType = kAudioUnitEvent_ParameterValueChange;
3133         event.mArgument.mParameter.mAudioUnit = unit->AU();
3134         event.mArgument.mParameter.mParameterID = descriptors[param_id].id;
3135         event.mArgument.mParameter.mScope = descriptors[param_id].scope;
3136         event.mArgument.mParameter.mElement = descriptors[param_id].element;
3137
3138         if (AUEventListenerAddEventType (_parameter_listener, _parameter_listener_arg, &event) != noErr) {
3139                 return -1;
3140         }
3141
3142         event.mEventType = kAudioUnitEvent_BeginParameterChangeGesture;
3143         event.mArgument.mParameter.mAudioUnit = unit->AU();
3144         event.mArgument.mParameter.mParameterID = descriptors[param_id].id;
3145         event.mArgument.mParameter.mScope = descriptors[param_id].scope;
3146         event.mArgument.mParameter.mElement = descriptors[param_id].element;
3147
3148         if (AUEventListenerAddEventType (_parameter_listener, _parameter_listener_arg, &event) != noErr) {
3149                 return -1;
3150         }
3151
3152         event.mEventType = kAudioUnitEvent_EndParameterChangeGesture;
3153         event.mArgument.mParameter.mAudioUnit = unit->AU();
3154         event.mArgument.mParameter.mParameterID = descriptors[param_id].id;
3155         event.mArgument.mParameter.mScope = descriptors[param_id].scope;
3156         event.mArgument.mParameter.mElement = descriptors[param_id].element;
3157
3158         if (AUEventListenerAddEventType (_parameter_listener, _parameter_listener_arg, &event) != noErr) {
3159                 return -1;
3160         }
3161
3162         return 0;
3163 }
3164
3165 int
3166 AUPlugin::end_listen_to_parameter (uint32_t param_id)
3167 {
3168         AudioUnitEvent      event;
3169
3170         if (!_parameter_listener || param_id >= descriptors.size()) {
3171                 return -2;
3172         }
3173
3174         event.mEventType = kAudioUnitEvent_ParameterValueChange;
3175         event.mArgument.mParameter.mAudioUnit = unit->AU();
3176         event.mArgument.mParameter.mParameterID = descriptors[param_id].id;
3177         event.mArgument.mParameter.mScope = descriptors[param_id].scope;
3178         event.mArgument.mParameter.mElement = descriptors[param_id].element;
3179
3180         if (AUEventListenerRemoveEventType (_parameter_listener, _parameter_listener_arg, &event) != noErr) {
3181                 return -1;
3182         }
3183
3184         event.mEventType = kAudioUnitEvent_BeginParameterChangeGesture;
3185         event.mArgument.mParameter.mAudioUnit = unit->AU();
3186         event.mArgument.mParameter.mParameterID = descriptors[param_id].id;
3187         event.mArgument.mParameter.mScope = descriptors[param_id].scope;
3188         event.mArgument.mParameter.mElement = descriptors[param_id].element;
3189
3190         if (AUEventListenerRemoveEventType (_parameter_listener, _parameter_listener_arg, &event) != noErr) {
3191                 return -1;
3192         }
3193
3194         event.mEventType = kAudioUnitEvent_EndParameterChangeGesture;
3195         event.mArgument.mParameter.mAudioUnit = unit->AU();
3196         event.mArgument.mParameter.mParameterID = descriptors[param_id].id;
3197         event.mArgument.mParameter.mScope = descriptors[param_id].scope;
3198         event.mArgument.mParameter.mElement = descriptors[param_id].element;
3199
3200         if (AUEventListenerRemoveEventType (_parameter_listener, _parameter_listener_arg, &event) != noErr) {
3201                 return -1;
3202         }
3203
3204         return 0;
3205 }
3206
3207 void
3208 AUPlugin::_parameter_change_listener (void* arg, void* src, const AudioUnitEvent* event, UInt64 host_time, Float32 new_value)
3209 {
3210         ((AUPlugin*) arg)->parameter_change_listener (arg, src, event, host_time, new_value);
3211 }
3212
3213 void
3214 AUPlugin::parameter_change_listener (void* /*arg*/, void* src, const AudioUnitEvent* event, UInt64 /*host_time*/, Float32 new_value)
3215 {
3216         ParameterMap::iterator i;
3217
3218         if ((i = parameter_map.find (event->mArgument.mParameter.mParameterID)) == parameter_map.end()) {
3219                 return;
3220         }
3221
3222         switch (event->mEventType) {
3223         case kAudioUnitEvent_BeginParameterChangeGesture:
3224                 StartTouch (i->second);
3225                 break;
3226         case kAudioUnitEvent_EndParameterChangeGesture:
3227                 EndTouch (i->second);
3228                 break;
3229         case kAudioUnitEvent_ParameterValueChange:
3230                 /* whenever we change a parameter, we request that we are NOT notified of the change, so anytime we arrive here, it
3231                    means that something else (i.e. the plugin GUI) made the change.
3232                 */
3233                 ParameterChangedExternally (i->second, new_value);
3234                 break;
3235         default:
3236                 break;
3237         }
3238 }