fix up confusion between silence() decls for Processor & PluginInsert; fix typo that...
[ardour.git] / libs / ardour / plugin_insert.cc
1 /*
2     Copyright (C) 2000 Paul Davis 
3
4     This program is free software; you can redistribute it and/or modify
5     it under the terms of the GNU General Public License as published by
6     the Free Software Foundation; either version 2 of the License, or
7     (at your option) any later version.
8
9     This program is distributed in the hope that it will be useful,
10     but WITHOUT ANY WARRANTY; without even the implied warranty of
11     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12     GNU General Public License for more details.
13
14     You should have received a copy of the GNU General Public License
15     along with this program; if not, write to the Free Software
16     Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
17
18 */
19
20 #include <string>
21
22 #include <sigc++/bind.h>
23
24 #include "pbd/failed_constructor.h"
25 #include "pbd/xml++.h"
26
27 #include "ardour/audio_buffer.h"
28 #include "ardour/automation_list.h"
29 #include "ardour/buffer_set.h"
30 #include "ardour/event_type_map.h"
31 #include "ardour/ladspa_plugin.h"
32 #include "ardour/plugin.h"
33 #include "ardour/plugin_insert.h"
34 #include "ardour/port.h"
35 #include "ardour/route.h"
36
37 #ifdef HAVE_SLV2
38 #include "ardour/lv2_plugin.h"
39 #endif
40
41 #ifdef VST_SUPPORT
42 #include "ardour/vst_plugin.h"
43 #endif
44
45 #ifdef HAVE_AUDIOUNITS
46 #include "ardour/audio_unit.h"
47 #endif
48
49 #include "ardour/audioengine.h"
50 #include "ardour/session.h"
51 #include "ardour/types.h"
52
53 #include "i18n.h"
54
55 using namespace std;
56 using namespace ARDOUR;
57 using namespace PBD;
58
59 const string PluginInsert::port_automation_node_name = "PortAutomation";
60
61 PluginInsert::PluginInsert (Session& s, boost::shared_ptr<Plugin> plug, Placement placement)
62         : Processor (s, plug->name(), placement),
63           _signal_analysis_collected_nframes(0),
64           _signal_analysis_collect_nframes_max(0)
65 {
66         /* the first is the master */
67
68         _plugins.push_back (plug);
69
70         init ();
71
72         {
73                 Glib::Mutex::Lock em (_session.engine().process_lock());
74                 IO::PortCountChanged (max(input_streams(), output_streams()));
75         }
76
77         ProcessorCreated (this); /* EMIT SIGNAL */
78 }
79
80 PluginInsert::PluginInsert (Session& s, const XMLNode& node)
81         : Processor (s, "unnamed plugin insert", PreFader),
82           _signal_analysis_collected_nframes(0),
83           _signal_analysis_collect_nframes_max(0)
84 {
85         if (set_state (node)) {
86                 throw failed_constructor();
87         }
88
89         // XXX: This would dump all automation, which has already been loaded by
90         //      Processor. But this could also have been related to the Parameter change..
91         //      will look into this later.
92         //set_automatable ();
93
94         {
95                 Glib::Mutex::Lock em (_session.engine().process_lock());
96                 IO::PortCountChanged (max(input_streams(), output_streams()));
97         }
98 }
99
100 bool
101 PluginInsert::set_count (uint32_t num)
102 {
103         bool require_state = !_plugins.empty();
104
105         /* this is a bad idea.... we shouldn't do this while active.
106            only a route holding their redirect_lock should be calling this 
107         */
108
109         if (num == 0) { 
110                 return false;
111         } else if (num > _plugins.size()) {
112                 uint32_t diff = num - _plugins.size();
113
114                 for (uint32_t n = 0; n < diff; ++n) {
115                         _plugins.push_back (plugin_factory (_plugins[0]));
116
117                         if (require_state) {
118                                 /* XXX do something */
119                         }
120                 }
121
122         } else if (num < _plugins.size()) {
123                 uint32_t diff = _plugins.size() - num;
124                 for (uint32_t n= 0; n < diff; ++n) {
125                         _plugins.pop_back();
126                 }
127         }
128
129         return true;
130 }
131
132 void
133 PluginInsert::init ()
134 {
135         set_automatable ();
136 }
137
138 PluginInsert::~PluginInsert ()
139 {
140         GoingAway (); /* EMIT SIGNAL */
141 }
142
143 void
144 PluginInsert::auto_state_changed (Evoral::Parameter which)
145 {
146         if (which.type() != PluginAutomation)
147                 return;
148
149         boost::shared_ptr<AutomationControl> c
150                         = boost::dynamic_pointer_cast<AutomationControl>(data().control (which));
151
152         if (c && ((AutomationList*)c->list().get())->automation_state() != Off) {
153                 _plugins[0]->set_parameter (which.id(), c->list()->eval (_session.transport_frame()));
154         }
155 }
156
157 ChanCount
158 PluginInsert::output_streams() const
159 {
160         ChanCount out = _plugins.front()->get_info()->n_outputs;
161
162         if (out == ChanCount::INFINITE) {
163
164                 return _plugins.front()->output_streams ();
165
166         } else {
167
168                 out.set_audio (out.n_audio() * _plugins.size());
169                 out.set_midi (out.n_midi() * _plugins.size());
170
171                 return out;
172         }
173 }
174
175 ChanCount
176 PluginInsert::input_streams() const
177 {
178         ChanCount in = _plugins[0]->get_info()->n_inputs;
179         
180         if (in == ChanCount::INFINITE) {
181                 return _plugins[0]->input_streams ();
182         } else {
183                 in.set_audio (in.n_audio() * _plugins.size());
184                 in.set_midi (in.n_midi() * _plugins.size());
185
186                 return in;
187         }
188 }
189
190 ChanCount
191 PluginInsert::natural_output_streams() const
192 {
193         return _plugins[0]->get_info()->n_outputs;
194 }
195
196 ChanCount
197 PluginInsert::natural_input_streams() const
198 {
199         return _plugins[0]->get_info()->n_inputs;
200 }
201
202 bool
203 PluginInsert::is_generator() const
204 {
205         /* XXX more finesse is possible here. VST plugins have a
206            a specific "instrument" flag, for example.
207          */
208
209         return _plugins[0]->get_info()->n_inputs.n_audio() == 0;
210 }
211
212 void
213 PluginInsert::set_automatable ()
214 {
215         set<Evoral::Parameter> a = _plugins.front()->automatable ();
216
217         Plugin::ParameterDescriptor desc;
218
219         for (set<Evoral::Parameter>::iterator i = a.begin(); i != a.end(); ++i) {
220                 if (i->type() == PluginAutomation) {
221                         can_automate (*i);
222                         _plugins.front()->get_parameter_descriptor(i->id(), desc);
223                         Evoral::Parameter param(*i);
224                         param.set_range(desc.lower, desc.upper, _plugins.front()->default_value(i->id()));
225                         boost::shared_ptr<AutomationList> list(new AutomationList(param));
226                         add_control(boost::shared_ptr<AutomationControl>(new PluginControl(this, *i, list)));
227                 }
228         }
229 }
230
231 void
232 PluginInsert::parameter_changed (Evoral::Parameter which, float val)
233 {
234         if (which.type() != PluginAutomation)
235                 return;
236
237         vector<boost::shared_ptr<Plugin> >::iterator i = _plugins.begin();
238
239         /* don't set the first plugin, just all the slaves */
240
241         if (i != _plugins.end()) {
242                 ++i;
243                 for (; i != _plugins.end(); ++i) {
244                         (*i)->set_parameter (which, val);
245                 }
246         }
247 }
248
249 void
250 PluginInsert::set_block_size (nframes_t nframes)
251 {
252         for (vector<boost::shared_ptr<Plugin> >::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
253                 (*i)->set_block_size (nframes);
254         }
255 }
256
257 void
258 PluginInsert::activate ()
259 {
260         for (vector<boost::shared_ptr<Plugin> >::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
261                 (*i)->activate ();
262         }
263 }
264
265 void
266 PluginInsert::deactivate ()
267 {
268         for (vector<boost::shared_ptr<Plugin> >::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
269                 (*i)->deactivate ();
270         }
271 }
272
273 void
274 PluginInsert::connect_and_run (BufferSet& bufs, nframes_t nframes, nframes_t offset, bool with_auto, nframes_t now)
275 {
276         // Calculate if, and how many frames we need to collect for analysis
277         nframes_t collect_signal_nframes = (_signal_analysis_collect_nframes_max -
278                                             _signal_analysis_collected_nframes);
279         if (nframes < collect_signal_nframes) { // we might not get all frames now
280                 collect_signal_nframes = nframes;
281         }
282
283         uint32_t in_index = 0;
284         uint32_t out_index = 0;
285
286         /* Note that we've already required that plugins
287            be able to handle in-place processing.
288         */
289
290         if (with_auto) {
291
292                 uint32_t n = 0;
293                 
294                 for (Controls::iterator li = data().controls().begin(); li != data().controls().end(); ++li, ++n) {
295                         
296                         boost::shared_ptr<AutomationControl> c
297                                 = boost::dynamic_pointer_cast<AutomationControl>(li->second);
298
299                         if (c->parameter().type() == PluginAutomation && c->automation_playback()) {
300                                 bool valid;
301
302                                 const float val = c->list()->rt_safe_eval (now, valid);                         
303
304                                 if (valid) {
305                                         c->set_value(val);
306                                 }
307
308                         } 
309                 }
310         }
311
312         if (collect_signal_nframes > 0) {
313                 // collect input
314                 //std::cerr << "collect input, bufs " << bufs.count().n_audio() << " count,  " << bufs.available().n_audio() << " available" << std::endl;
315                 //std::cerr << "               streams " << input_streams().n_audio() << std::endl;
316                 //std::cerr << "filling buffer with " << collect_signal_nframes << " frames at " << _signal_analysis_collected_nframes << std::endl;
317                 for (uint32_t i = 0; i < input_streams().n_audio(); ++i) {
318                         _signal_analysis_input_bufferset.get_audio(i).read_from(
319                                 bufs.get_audio(i),
320                                 collect_signal_nframes,
321                                 _signal_analysis_collected_nframes); // offset is for target buffer
322                 }
323         }
324
325         for (vector<boost::shared_ptr<Plugin> >::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
326                 (*i)->connect_and_run (bufs, in_index, out_index, nframes, offset);
327         }
328
329         if (collect_signal_nframes > 0) {
330                 // collect output
331                 //std::cerr << "       output, bufs " << bufs.count().n_audio() << " count,  " << bufs.available().n_audio() << " available" << std::endl;
332                 //std::cerr << "               streams " << output_streams().n_audio() << std::endl;
333                 for (uint32_t i = 0; i < output_streams().n_audio(); ++i) {
334                         _signal_analysis_output_bufferset.get_audio(i).read_from(
335                                 bufs.get_audio(i), 
336                                 collect_signal_nframes, 
337                                 _signal_analysis_collected_nframes); // offset is for target buffer
338                 }
339
340                 _signal_analysis_collected_nframes += collect_signal_nframes;
341                 assert(_signal_analysis_collected_nframes <= _signal_analysis_collect_nframes_max);
342
343                 if (_signal_analysis_collected_nframes == _signal_analysis_collect_nframes_max) {
344                         _signal_analysis_collect_nframes_max = 0;
345                         _signal_analysis_collected_nframes   = 0;
346
347                         AnalysisDataGathered(&_signal_analysis_input_bufferset, 
348                                              &_signal_analysis_output_bufferset);
349                 }
350         }
351         /* leave remaining channel buffers alone */
352 }
353
354 void
355 PluginInsert::silence (nframes_t nframes)
356 {
357         uint32_t in_index = 0;
358         uint32_t out_index = 0;
359
360         if (active()) {
361                 for (vector<boost::shared_ptr<Plugin> >::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
362                         (*i)->connect_and_run (_session.get_silent_buffers ((*i)->get_info()->n_inputs), in_index, out_index, nframes, 0);
363                 }
364         }
365 }
366         
367 void
368 PluginInsert::run_in_place (BufferSet& bufs, nframes_t start_frame, nframes_t end_frame, nframes_t nframes)
369 {
370         if (active()) {
371
372                 if (_session.transport_rolling()) {
373                         automation_run (bufs, nframes);
374                 } else {
375                         connect_and_run (bufs, nframes, 0, false);
376                 }
377         } else {
378
379                 /* FIXME: type, audio only */
380
381                 uint32_t in = _plugins[0]->get_info()->n_inputs.n_audio();
382                 uint32_t out = _plugins[0]->get_info()->n_outputs.n_audio();
383
384                 if (out > in) {
385
386                         /* not active, but something has make up for any channel count increase */
387                         
388                         for (uint32_t n = out - in; n < out; ++n) {
389                                 memcpy (bufs.get_audio(n).data(), bufs.get_audio(in - 1).data(), sizeof (Sample) * nframes);
390                         }
391                 }
392
393                 bufs.count().set_audio(out);
394         }
395 }
396
397 void
398 PluginInsert::set_parameter (Evoral::Parameter param, float val)
399 {
400         if (param.type() != PluginAutomation)
401                 return;
402
403         /* the others will be set from the event triggered by this */
404
405         _plugins[0]->set_parameter (param.id(), val);
406         
407         boost::shared_ptr<AutomationControl> ac
408                         = boost::dynamic_pointer_cast<AutomationControl>(data().control(param));
409         
410         if (ac) {
411                 ac->set_value(val);
412         } else {
413                 warning << "set_parameter called for nonexistant parameter "
414                         << EventTypeMap::instance().to_symbol(param) << endmsg;
415         }
416
417         _session.set_dirty();
418 }
419
420 float
421 PluginInsert::get_parameter (Evoral::Parameter param)
422 {
423         if (param.type() != PluginAutomation)
424                 return 0.0;
425         else
426                 return
427                 _plugins[0]->get_parameter (param.id());
428 }
429
430 void
431 PluginInsert::automation_run (BufferSet& bufs, nframes_t nframes)
432 {
433         Evoral::ControlEvent next_event (0, 0.0f);
434         nframes_t now = _session.transport_frame ();
435         nframes_t end = now + nframes;
436         nframes_t offset = 0;
437
438         Glib::Mutex::Lock lm (data().control_lock(), Glib::TRY_LOCK);
439
440         if (!lm.locked()) {
441                 connect_and_run (bufs, nframes, offset, false);
442                 return;
443         }
444         
445         if (!data().find_next_event (now, end, next_event)) {
446                 
447                 /* no events have a time within the relevant range */
448                 
449                 connect_and_run (bufs, nframes, offset, true, now);
450                 return;
451         }
452         
453         while (nframes) {
454
455                 nframes_t cnt = min (((nframes_t) ceil (next_event.when) - now), nframes);
456   
457                 connect_and_run (bufs, cnt, offset, true, now);
458                 
459                 nframes -= cnt;
460                 offset += cnt;
461                 now += cnt;
462
463                 if (!data().find_next_event (now, end, next_event)) {
464                         break;
465                 }
466         }
467   
468         /* cleanup anything that is left to do */
469   
470         if (nframes) {
471                 connect_and_run (bufs, nframes, offset, true, now);
472         }
473 }       
474
475 float
476 PluginInsert::default_parameter_value (const Evoral::Parameter& param)
477 {
478         if (param.type() != PluginAutomation)
479                 return 1.0;
480
481         if (_plugins.empty()) {
482                 fatal << _("programming error: ") << X_("PluginInsert::default_parameter_value() called with no plugin")
483                       << endmsg;
484                 /*NOTREACHED*/
485         }
486
487         return _plugins[0]->default_value (param.id());
488 }
489
490 boost::shared_ptr<Plugin>
491 PluginInsert::plugin_factory (boost::shared_ptr<Plugin> other)
492 {
493         boost::shared_ptr<LadspaPlugin> lp;
494 #ifdef HAVE_SLV2
495         boost::shared_ptr<LV2Plugin> lv2p;
496 #endif
497 #ifdef VST_SUPPORT
498         boost::shared_ptr<VSTPlugin> vp;
499 #endif
500 #ifdef HAVE_AUDIOUNITS
501         boost::shared_ptr<AUPlugin> ap;
502 #endif
503
504         if ((lp = boost::dynamic_pointer_cast<LadspaPlugin> (other)) != 0) {
505                 return boost::shared_ptr<Plugin> (new LadspaPlugin (*lp));
506 #ifdef HAVE_SLV2
507         } else if ((lv2p = boost::dynamic_pointer_cast<LV2Plugin> (other)) != 0) {
508                 return boost::shared_ptr<Plugin> (new LV2Plugin (*lv2p));
509 #endif
510 #ifdef VST_SUPPORT
511         } else if ((vp = boost::dynamic_pointer_cast<VSTPlugin> (other)) != 0) {
512                 return boost::shared_ptr<Plugin> (new VSTPlugin (*vp));
513 #endif
514 #ifdef HAVE_AUDIOUNITS
515         } else if ((ap = boost::dynamic_pointer_cast<AUPlugin> (other)) != 0) {
516                 return boost::shared_ptr<Plugin> (new AUPlugin (*ap));
517 #endif
518         }
519
520         fatal << string_compose (_("programming error: %1"),
521                           X_("unknown plugin type in PluginInsert::plugin_factory"))
522               << endmsg;
523         /*NOTREACHED*/
524         return boost::shared_ptr<Plugin> ((Plugin*) 0);
525 }
526
527 bool
528 PluginInsert::configure_io (ChanCount in, ChanCount out)
529 {
530         if (set_count (count_for_configuration (in, out)) < 0) {
531                 return false;
532         }
533
534         /* if we're running replicated plugins, each plugin has
535            the same i/o configuration and we may need to announce how many
536            output streams there are.
537
538            if we running a single plugin, we need to configure it.
539         */
540
541         if (_plugins.front()->configure_io (in, out) < 0) {
542                 return false;
543         }
544
545         // we don't know the analysis window size, so we must work with the
546         // current buffer size here. each request for data fills in these
547         // buffers and the analyser makes sure it gets enough data for the 
548         // analysis window
549         _signal_analysis_input_bufferset.ensure_buffers (in,  session().engine().frames_per_cycle());
550         _signal_analysis_input_bufferset.set_count(in);
551
552         _signal_analysis_output_bufferset.ensure_buffers(out, session().engine().frames_per_cycle());
553         _signal_analysis_output_bufferset.set_count(out);
554
555
556         return Processor::configure_io (in, out);
557 }
558
559 bool
560 PluginInsert::can_support_io_configuration (const ChanCount& in, ChanCount& out) const
561 {
562         if (_plugins.front()->reconfigurable_io()) {
563                 /* plugin has flexible I/O, so delegate to it */
564                 return _plugins.front()->can_support_io_configuration (in, out);
565         }
566
567         ChanCount outputs = _plugins[0]->get_info()->n_outputs;
568         ChanCount inputs = _plugins[0]->get_info()->n_inputs;
569
570         if ((inputs.n_total() == 0)
571                         || (inputs.n_total() == 1 && outputs == inputs)
572                         || (inputs.n_total() == 1 && outputs == inputs
573                                 && ((inputs.n_audio() == 0 && in.n_audio() == 0)
574                                         || (inputs.n_midi() == 0 && in.n_midi() == 0)))
575                         || (inputs == in)) {
576                 out = outputs;
577                 return true;
578         }
579
580         bool can_replicate = true;
581
582         /* if number of inputs is a factor of the requested input
583            configuration for every type, we can replicate.
584         */
585         for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
586                 if (inputs.get(*t) >= in.get(*t) || (inputs.get(*t) % in.get(*t) != 0)) {
587                         can_replicate = false;
588                         break;
589                 }
590         }
591
592         if (!can_replicate || (in.n_total() % inputs.n_total() != 0)) {
593                 return false;
594         }
595
596         if (inputs.n_total() == 0) {
597                 /* instrument plugin, always legal, but throws away any existing streams */
598                 out = outputs;
599         } else if (inputs.n_total() == 1 && outputs == inputs
600                         && ((inputs.n_audio() == 0 && in.n_audio() == 0)
601                             || (inputs.n_midi() == 0 && in.n_midi() == 0))) {
602                 /* mono, single-typed plugin, replicate as needed to match in */
603                 out = in;
604         } else if (inputs == in) {
605                 /* exact match */
606                 out = outputs;
607         } else {
608                 /* replicate - note that we've already verified that
609                    the replication count is constant across all data types.
610                 */
611                 for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
612                         out.set (*t, outputs.get(*t) * (in.get(*t) / inputs.get(*t)));
613                 }
614         }
615                 
616         return true;
617 }
618
619 /* Number of plugin instances required to support a given channel configuration.
620  * (private helper)
621  */
622 int32_t
623 PluginInsert::count_for_configuration (ChanCount in, ChanCount out) const
624 {
625         if (_plugins.front()->reconfigurable_io()) {
626                 /* plugin has flexible I/O, so the answer is always 1 */
627                 /* this could change if we ever decide to replicate AU's */
628                 return 1;
629         }
630
631         // FIXME: take 'out' into consideration
632         
633         ChanCount outputs = _plugins[0]->get_info()->n_outputs;
634         ChanCount inputs = _plugins[0]->get_info()->n_inputs;
635
636         if (inputs.n_total() == 0) {
637                 /* instrument plugin, always legal, but throws away any existing streams */
638                 return 1;
639         }
640
641         if (inputs.n_total() == 1 && outputs == inputs
642                         && ((inputs.n_audio() == 0 && in.n_audio() == 0)
643                                 || (inputs.n_midi() == 0 && in.n_midi() == 0))) {
644                 /* mono plugin, replicate as needed to match in */
645                 return in.n_total();
646         }
647
648         if (inputs == in) {
649                 /* exact match */
650                 return 1;
651         }
652
653         // assumes in is valid, so we must be replicating
654         if (inputs.n_total() < in.n_total()
655                         && (in.n_total() % inputs.n_total() == 0)) {
656
657                 return in.n_total() / inputs.n_total();
658         }
659
660         /* err... */
661         return 0;
662 }
663
664 XMLNode&
665 PluginInsert::get_state(void)
666 {
667         return state (true);
668 }
669
670 XMLNode&
671 PluginInsert::state (bool full)
672 {
673         XMLNode& node = Processor::state (full);
674
675         node.add_property("type", _plugins[0]->state_node_name());
676         node.add_property("unique-id", _plugins[0]->unique_id());
677         node.add_property("count", string_compose("%1", _plugins.size()));
678         node.add_child_nocopy (_plugins[0]->get_state());
679
680         /* add port automation state */
681         //XMLNode *autonode = new XMLNode(port_automation_node_name);
682         set<Evoral::Parameter> automatable = _plugins[0]->automatable();
683         
684         for (set<Evoral::Parameter>::iterator x = automatable.begin(); x != automatable.end(); ++x) {
685                 
686                 /*XMLNode* child = new XMLNode("port");
687                 snprintf(buf, sizeof(buf), "%" PRIu32, *x);
688                 child->add_property("number", string(buf));
689                 
690                 child->add_child_nocopy (automation_list (*x).state (full));
691                 autonode->add_child_nocopy (*child);
692                 */
693                 //autonode->add_child_nocopy (((AutomationList*)data().control(*x)->list().get())->state (full));
694         }
695
696         //node.add_child_nocopy (*autonode);
697         
698         return node;
699 }
700
701 int
702 PluginInsert::set_state(const XMLNode& node)
703 {
704         XMLNodeList nlist = node.children();
705         XMLNodeIterator niter;
706         XMLPropertyList plist;
707         const XMLProperty *prop;
708         ARDOUR::PluginType type;
709
710         if ((prop = node.property ("type")) == 0) {
711                 error << _("XML node describing insert is missing the `type' field") << endmsg;
712                 return -1;
713         }
714
715         if (prop->value() == X_("ladspa") || prop->value() == X_("Ladspa")) { /* handle old school sessions */
716                 type = ARDOUR::LADSPA;
717         } else if (prop->value() == X_("lv2")) {
718                 type = ARDOUR::LV2;
719         } else if (prop->value() == X_("vst")) {
720                 type = ARDOUR::VST;
721         } else {
722                 error << string_compose (_("unknown plugin type %1 in plugin insert state"),
723                                   prop->value())
724                       << endmsg;
725                 return -1;
726         }
727         
728         prop = node.property ("unique-id");
729         if (prop == 0) {
730                 error << _("Plugin has no unique ID field") << endmsg;
731                 return -1;
732         }
733
734         boost::shared_ptr<Plugin> plugin;
735         
736         plugin = find_plugin (_session, prop->value(), type);   
737
738         if (plugin == 0) {
739                 error << string_compose(_("Found a reference to a plugin (\"%1\") that is unknown.\n"
740                                    "Perhaps it was removed or moved since it was last used."), prop->value()) 
741                       << endmsg;
742                 return -1;
743         }
744
745         uint32_t count = 1;
746
747         if ((prop = node.property ("count")) != 0) {
748                 sscanf (prop->value().c_str(), "%u", &count);
749         }
750
751         if (_plugins.size() != count) {
752                 
753                 _plugins.push_back (plugin);
754                 
755                 for (uint32_t n=1; n < count; ++n) {
756                         _plugins.push_back (plugin_factory (plugin));
757                 }
758         }
759         
760         for (niter = nlist.begin(); niter != nlist.end(); ++niter) {
761                 if ((*niter)->name() == plugin->state_node_name()) {
762                         for (vector<boost::shared_ptr<Plugin> >::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
763                                 (*i)->set_state (**niter);
764                         }
765                         break;
766                 }
767         } 
768
769         const XMLNode* insert_node = &node;
770
771         // legacy sessions: search for child IOProcessor node
772         for (niter = nlist.begin(); niter != nlist.end(); ++niter) {
773                 if ((*niter)->name() == "IOProcessor") {
774                         insert_node = *niter;
775                         break;
776                 }
777         }
778         
779         Processor::set_state (*insert_node);
780
781         /* look for port automation node */
782         
783         for (niter = nlist.begin(); niter != nlist.end(); ++niter) {
784
785                 if ((*niter)->name() != port_automation_node_name) {
786                         continue;
787                 }
788
789                 XMLNodeList cnodes;
790                 XMLProperty *cprop;
791                 XMLNodeConstIterator iter;
792                 XMLNode *child;
793                 const char *port;
794                 uint32_t port_id;
795                 
796                 cnodes = (*niter)->children ("Port");
797                 
798                 for(iter = cnodes.begin(); iter != cnodes.end(); ++iter){
799                         
800                         child = *iter;
801                         
802                         if ((cprop = child->property("number")) != 0) {
803                                 port = cprop->value().c_str();
804                         } else {
805                                 warning << _("PluginInsert: Auto: no plugin port number") << endmsg;
806                                 continue;
807                         }
808                         
809                         sscanf (port, "%" PRIu32, &port_id);
810                         
811                         if (port_id >= _plugins[0]->parameter_count()) {
812                                 warning << _("PluginInsert: Auto: port id out of range") << endmsg;
813                                 continue;
814                         }
815
816                         boost::shared_ptr<AutomationControl> c = boost::dynamic_pointer_cast<AutomationControl>(
817                                         data().control(Evoral::Parameter(PluginAutomation, 0, port_id), true));
818
819                         if (!child->children().empty()) {
820                                 c->alist()->set_state (*child->children().front());
821                         } else {
822                                 if ((cprop = child->property("auto")) != 0) {
823                                         
824                                         /* old school */
825
826                                         int x;
827                                         sscanf (cprop->value().c_str(), "0x%x", &x);
828                                         c->alist()->set_automation_state (AutoState (x));
829
830                                 } else {
831                                         
832                                         /* missing */
833                                         
834                                         c->alist()->set_automation_state (Off);
835                                 }
836                         }
837
838                 }
839
840                 /* done */
841
842                 break;
843         } 
844
845         if (niter == nlist.end()) {
846                 warning << string_compose(_("XML node describing a port automation is missing the `%1' information"), port_automation_node_name) << endmsg;
847         }
848         
849         // The name of the PluginInsert comes from the plugin, nothing else
850         _name = plugin->get_info()->name;
851         
852         return 0;
853 }
854
855 string
856 PluginInsert::describe_parameter (Evoral::Parameter param)
857 {
858         if (param.type() != PluginAutomation)
859                 return Automatable::describe_parameter(param);
860
861         return _plugins[0]->describe_parameter (param);
862 }
863
864 ARDOUR::nframes_t 
865 PluginInsert::signal_latency() const
866 {
867         if (_user_latency) {
868                 return _user_latency;
869         }
870
871         return _plugins[0]->signal_latency ();
872 }
873
874 ARDOUR::PluginType
875 PluginInsert::type ()
876 {
877         boost::shared_ptr<LadspaPlugin> lp;
878 #ifdef VST_SUPPORT
879         boost::shared_ptr<VSTPlugin> vp;
880 #endif
881 #ifdef HAVE_AUDIOUNITS
882         boost::shared_ptr<AUPlugin> ap;
883 #endif
884         
885         PluginPtr other = plugin ();
886
887         if ((lp = boost::dynamic_pointer_cast<LadspaPlugin> (other)) != 0) {
888                 return ARDOUR::LADSPA;
889 #ifdef VST_SUPPORT
890         } else if ((vp = boost::dynamic_pointer_cast<VSTPlugin> (other)) != 0) {
891                 return ARDOUR::VST;
892 #endif
893 #ifdef HAVE_AUDIOUNITS
894         } else if ((ap = boost::dynamic_pointer_cast<AUPlugin> (other)) != 0) {
895                 return ARDOUR::AudioUnit;
896 #endif
897         } else {
898                 /* NOT REACHED */
899                 return (ARDOUR::PluginType) 0;
900         }
901 }
902
903 PluginInsert::PluginControl::PluginControl (PluginInsert* p, const Evoral::Parameter &param, boost::shared_ptr<AutomationList> list)
904         : AutomationControl (p->session(), param, list, p->describe_parameter(param))
905         , _plugin (p)
906 {
907         Plugin::ParameterDescriptor desc;
908         p->plugin(0)->get_parameter_descriptor (param.id(), desc);
909         _logarithmic = desc.logarithmic;
910         _toggled = desc.toggled;
911 }
912          
913 void
914 PluginInsert::PluginControl::set_value (float val)
915 {
916         /* FIXME: probably should be taking out some lock here.. */
917         
918         if (_toggled) {
919                 if (val > 0.5) {
920                         val = 1.0;
921                 } else {
922                         val = 0.0;
923                 }
924         } else {
925                         
926                 /*const float range = _list->get_max_y() - _list->get_min_y();
927                 const float lower = _list->get_min_y();
928
929                 if (!_logarithmic) {
930                         val = lower + (range * val);
931                 } else {
932                         float log_lower = 0.0f;
933                         if (lower > 0.0f) {
934                                 log_lower = log(lower);
935                         }
936
937                         val = exp(log_lower + log(range) * val);
938                 }*/
939
940         }
941
942         for (vector<boost::shared_ptr<Plugin> >::iterator i = _plugin->_plugins.begin();
943                         i != _plugin->_plugins.end(); ++i) {
944                 (*i)->set_parameter (_list->parameter().id(), val);
945         }
946
947         boost::shared_ptr<Plugin> iasp = _plugin->_impulseAnalysisPlugin.lock();
948         if (iasp) {
949                 iasp->set_parameter (_list->parameter().id(), val);
950         }
951
952         AutomationControl::set_value(val);
953 }
954
955 float
956 PluginInsert::PluginControl::get_value (void) const
957 {
958         /* FIXME: probably should be taking out some lock here.. */
959         
960         float val = _plugin->get_parameter (_list->parameter());
961
962         return val;
963
964         /*if (_toggled) {
965                 
966                 return val;
967                 
968         } else {
969                 
970                 if (_logarithmic) {
971                         val = log(val);
972                 }
973                 
974                 return ((val - lower) / range);
975         }*/
976 }
977
978 boost::shared_ptr<Plugin>
979 PluginInsert::get_impulse_analysis_plugin()
980 {
981         boost::shared_ptr<Plugin> ret;
982         if (_impulseAnalysisPlugin.expired()) {
983                 ret = plugin_factory(_plugins[0]);
984                 _impulseAnalysisPlugin = ret;
985         } else {
986                 ret = _impulseAnalysisPlugin.lock();
987         }
988
989         return ret;
990 }
991