Fix most absurd function name I've seen in a while.
[ardour.git] / libs / ardour / io.cc
index 2b8f12680fcf69df9a37a7a6466638bcf1a93d9f..43a61061d9765b595c3e1eaf77d02134ca5dcb10 100644 (file)
@@ -102,13 +102,12 @@ static double direct_gain_to_control (gain_t gain) {
  */
 IO::IO (Session& s, const string& name,
        int input_min, int input_max, int output_min, int output_max,
-       DataType default_type, bool public_ports)
+       DataType default_type)
        : SessionObject(s, name),
          AutomatableControls (s),
          _output_buffers (new BufferSet()),
          _active(true),
          _default_type (default_type),
-         _public_ports (public_ports),
          _input_minimum (ChanCount::ZERO),
          _input_maximum (ChanCount::INFINITE),
          _output_minimum (ChanCount::ZERO),
@@ -153,12 +152,9 @@ IO::IO (Session& s, const string& name,
                m_meter_connection = Meter.connect (mem_fun (*this, &IO::meter));
        }
        
-       // Connect to our own PortCountChanged signal to connect output buffers
-       IO::PortCountChanged.connect (mem_fun (*this, &IO::attach_buffers));
-
        _session.add_controllable (_gain_control);
 
-       create_bundles_for_inputs_and_outputs ();
+       setup_bundles_for_inputs_and_outputs ();
 }
 
 IO::IO (Session& s, const XMLNode& node, DataType dt)
@@ -169,7 +165,6 @@ IO::IO (Session& s, const XMLNode& node, DataType dt)
          _default_type (dt)
 {
        _meter = new PeakMeter (_session);
-       _public_ports = true; // XXX get this from node
        _panner = 0;
        deferred_state = 0;
        no_panner_reset = false;
@@ -195,12 +190,9 @@ IO::IO (Session& s, const XMLNode& node, DataType dt)
                m_meter_connection = Meter.connect (mem_fun (*this, &IO::meter));
        }
        
-       // Connect to our own PortCountChanged signal to connect output buffers
-       IO::PortCountChanged.connect (mem_fun (*this, &IO::attach_buffers));
-
        _session.add_controllable (_gain_control);
 
-       create_bundles_for_inputs_and_outputs ();
+       setup_bundles_for_inputs_and_outputs ();
 }
 
 IO::~IO ()
@@ -222,7 +214,6 @@ IO::~IO ()
 
        delete _meter;
        delete _panner;
-       delete _output_buffers;
 }
 
 void
@@ -261,51 +252,66 @@ IO::deliver_output (BufferSet& bufs, nframes_t start_frame, nframes_t end_frame,
 
                }
 
-               if (dg != _gain || dg != 1.0)
+               if (dg != _gain || dg != 1.0) {
                        Amp::run_in_place(bufs, nframes, _gain, dg, _phase_invert);
+                       _gain = dg;
+               }
        }
+       
+       /* do this so that any processing that comes after deliver_outputs()
+          can use the output buffers.
+       */
+
+       output_buffers().attach_buffers (_outputs, nframes, offset);
 
        // Use the panner to distribute audio to output port buffers
-       if( _panner && _panner->npanners() && !_panner->bypassed()) {
+
+       if (0 && _panner && _panner->npanners() && !_panner->bypassed()) {
+
+               /* blech .. we shouldn't be creating and tearing this down every process()
+                  cycle. XXX fix me to not waste cycles and do memory allocation etc.
+               */
+               
                _panner->run_out_of_place(bufs, output_buffers(), start_frame, end_frame, nframes, offset);
+
        } else {
-               const DataType type = DataType::AUDIO;
-               
-               // Copy any audio 1:1 to outputs
-               
-               BufferSet::iterator o = output_buffers().begin(type);
-               BufferSet::iterator i = bufs.begin(type);
-               BufferSet::iterator prev = i;
-               
-               while (i != bufs.end(type) && o != output_buffers().end (type)) {
-                       o->read_from(*i, nframes, offset);
-                       prev = i;
-                       ++i;
-                       ++o;
-               }
 
-               /* extra outputs get a copy of the last buffer */
+               /* do a 1:1 copy of data to output ports */
 
-               while (o != output_buffers().end(type)) {
-                       o->read_from(*prev, nframes, offset);
-                       ++o;
+               if (bufs.count().n_audio() > 0 && _outputs.count().n_audio () > 0) {
+                       copy_to_outputs (bufs, DataType::AUDIO, nframes, offset);
+               }
+               if (bufs.count().n_midi() > 0 && _outputs.count().n_midi () > 0) {
+                       copy_to_outputs (bufs, DataType::MIDI, nframes, offset);
                }
        }
+}
 
-       /* ********** MIDI ********** */
+void
+IO::copy_to_outputs (BufferSet& bufs, DataType type, nframes_t nframes, nframes_t offset)
+{
+       // Copy any buffers 1:1 to outputs
+       
+       PortSet::iterator o = _outputs.begin(type);
+       BufferSet::iterator i = bufs.begin(type);
+       BufferSet::iterator prev = i;
+       
+       while (i != bufs.end(type) && o != _outputs.end (type)) {
+               
+               Buffer& port_buffer (o->get_buffer (nframes, offset));
+               port_buffer.read_from (*i, nframes, offset);
 
-       // No MIDI, we're done here
-       if (bufs.count().n_midi() == 0) {
-               return;
+               prev = i;
+               ++i;
+               ++o;
        }
-
-       const DataType type = DataType::MIDI;
-
-       // Copy any MIDI 1:1 to outputs
-       assert(bufs.count().n_midi() == output_buffers().count().n_midi());
-       BufferSet::iterator o = output_buffers().begin(type);
-       for (BufferSet::iterator i = bufs.begin(type); i != bufs.end(type); ++i, ++o) {
-               o->read_from(*i, nframes, offset);
+       
+       /* extra outputs get a copy of the last buffer */
+       
+       while (o != _outputs.end(type)) {
+               Buffer& port_buffer (o->get_buffer (nframes, offset));
+               port_buffer.read_from(*prev, nframes, offset);
+               ++o;
        }
 }
 
@@ -322,8 +328,10 @@ IO::collect_input (BufferSet& outs, nframes_t nframes, nframes_t offset)
        for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
                
                BufferSet::iterator o = outs.begin(*t);
-               for (PortSet::iterator i = _inputs.begin(*t); i != _inputs.end(*t); ++i, ++o) {
-                       o->read_from(i->get_buffer(nframes,offset), nframes, offset);
+               PortSet::iterator e = _inputs.end (*t);
+               for (PortSet::iterator i = _inputs.begin(*t); i != e; ++i, ++o) {
+                       Buffer& b (i->get_buffer (nframes,offset));
+                       o->read_from (b, nframes, offset);
                }
 
        }
@@ -386,8 +394,7 @@ IO::check_bundles (std::vector<UserBundleInfo>& list, const PortSet& ports)
                if (ok) {
                        new_list.push_back (*i);
                } else {
-                       i->configuration_changed.disconnect ();
-                       i->ports_changed.disconnect ();
+                       i->changed.disconnect ();
                }
        }
 
@@ -416,7 +423,7 @@ IO::disconnect_input (Port* our_port, string other_port, void* src)
                        
                        /* disconnect it from the source */
                        
-                       if (_session.engine().disconnect (other_port, our_port->name())) {
+                       if (our_port->disconnect (other_port)) {
                                error << string_compose(_("IO: cannot disconnect input port %1 from %2"), our_port->name(), other_port) << endmsg;
                                return -1;
                        }
@@ -452,7 +459,7 @@ IO::connect_input (Port* our_port, string other_port, void* src)
                        
                        /* connect it to the source */
 
-                       if (_session.engine().connect (other_port, our_port->name())) {
+                       if (our_port->connect (other_port)) {
                                return -1;
                        }
                }
@@ -484,7 +491,7 @@ IO::disconnect_output (Port* our_port, string other_port, void* src)
                        
                        /* disconnect it from the destination */
                        
-                       if (_session.engine().disconnect (our_port->name(), other_port)) {
+                       if (our_port->disconnect (other_port)) {
                                error << string_compose(_("IO: cannot disconnect output port %1 from %2"), our_port->name(), other_port) << endmsg;
                                return -1;
                        }
@@ -520,7 +527,7 @@ IO::connect_output (Port* our_port, string other_port, void* src)
                        
                        /* connect it to the destination */
                        
-                       if (_session.engine().connect (our_port->name(), other_port)) {
+                       if (our_port->connect (other_port)) {
                                return -1;
                        }
                }
@@ -594,7 +601,7 @@ IO::remove_output_port (Port* port, void* src)
        }
 
        if (change == ConfigurationChanged) {
-               setup_bundles_for_inputs_and_outputs ();
+               setup_bundle_for_outputs ();
        }
 
        if (change != NoChange) {
@@ -635,7 +642,7 @@ IO::add_output_port (string destination, void* src, DataType type)
                        
                        string portname = build_legal_port_name (type, false);
                        
-                       if ((our_port = _session.engine().register_output_port (type, portname, _public_ports)) == 0) {
+                       if ((our_port = _session.engine().register_output_port (type, portname)) == 0) {
                                error << string_compose(_("IO: cannot register output port %1"), portname) << endmsg;
                                return -1;
                        }
@@ -649,14 +656,14 @@ IO::add_output_port (string destination, void* src, DataType type)
        }
 
        if (destination.length()) {
-               if (_session.engine().connect (our_port->name(), destination)) {
+               if (our_port->connect (destination)) {
                        return -1;
                }
        }
        
        // pan_changed (src); /* EMIT SIGNAL */
        output_changed (ConfigurationChanged, src); /* EMIT SIGNAL */
-       setup_bundles_for_inputs_and_outputs ();
+       setup_bundle_for_outputs ();
        _session.set_dirty ();
 
        return 0;
@@ -698,7 +705,7 @@ IO::remove_input_port (Port* port, void* src)
        }
 
        if (change == ConfigurationChanged) {
-               setup_bundles_for_inputs_and_outputs ();
+               setup_bundle_for_inputs ();
        }
 
        if (change != NoChange) {
@@ -739,7 +746,7 @@ IO::add_input_port (string source, void* src, DataType type)
                        
                        string portname = build_legal_port_name (type, true);
 
-                       if ((our_port = _session.engine().register_input_port (type, portname, _public_ports)) == 0) {
+                       if ((our_port = _session.engine().register_input_port (type, portname)) == 0) {
                                error << string_compose(_("IO: cannot register input port %1"), portname) << endmsg;
                                return -1;
                        }
@@ -754,14 +761,14 @@ IO::add_input_port (string source, void* src, DataType type)
 
        if (source.length()) {
 
-               if (_session.engine().connect (source, our_port->name())) {
+               if (our_port->connect (source)) {
                        return -1;
                }
        } 
 
        // pan_changed (src); /* EMIT SIGNAL */
        input_changed (ConfigurationChanged, src); /* EMIT SIGNAL */
-       setup_bundles_for_inputs_and_outputs ();
+       setup_bundle_for_inputs ();
        _session.set_dirty ();
        
        return 0;
@@ -777,7 +784,7 @@ IO::disconnect_inputs (void* src)
                        Glib::Mutex::Lock lm (io_lock);
                        
                        for (PortSet::iterator i = _inputs.begin(); i != _inputs.end(); ++i) {
-                               _session.engine().disconnect (*i);
+                               i->disconnect_all ();
                        }
 
                        check_bundles_connected_to_inputs ();
@@ -799,7 +806,7 @@ IO::disconnect_outputs (void* src)
                        Glib::Mutex::Lock lm (io_lock);
                        
                        for (PortSet::iterator i = _outputs.begin(); i != _outputs.end(); ++i) {
-                               _session.engine().disconnect (*i);
+                               i->disconnect_all ();
                        }
 
                        check_bundles_connected_to_outputs ();
@@ -841,7 +848,7 @@ IO::ensure_inputs_locked (ChanCount count, bool clear, void* src)
 
                        try {
 
-                               if ((input_port = _session.engine().register_input_port (*t, portname, _public_ports)) == 0) {
+                               if ((input_port = _session.engine().register_input_port (*t, portname)) == 0) {
                                        error << string_compose(_("IO: cannot register input port %1"), portname) << endmsg;
                                        return -1;
                                }
@@ -870,23 +877,13 @@ IO::ensure_inputs_locked (ChanCount count, bool clear, void* src)
        if (clear) {
                /* disconnect all existing ports so that we get a fresh start */
                for (PortSet::iterator i = _inputs.begin(); i != _inputs.end(); ++i) {
-                       _session.engine().disconnect (*i);
+                       i->disconnect_all ();
                }
        }
 
        return changed;
 }
 
-/** Attach output_buffers to port buffers.
- * 
- * Connected to IO's own PortCountChanged signal.
- */
-void
-IO::attach_buffers(ChanCount ignored)
-{
-       _output_buffers->attach_buffers(_outputs);
-}
-
 int
 IO::ensure_io (ChanCount in, ChanCount out, bool clear, void* src)
 {
@@ -949,7 +946,7 @@ IO::ensure_io (ChanCount in, ChanCount out, bool clear, void* src)
                                string portname = build_legal_port_name (*t, true);
 
                                try {
-                                       if ((port = _session.engine().register_input_port (*t, portname, _public_ports)) == 0) {
+                                       if ((port = _session.engine().register_input_port (*t, portname)) == 0) {
                                                error << string_compose(_("IO: cannot register input port %1"), portname) << endmsg;
                                                return -1;
                                        }
@@ -973,7 +970,7 @@ IO::ensure_io (ChanCount in, ChanCount out, bool clear, void* src)
                                string portname = build_legal_port_name (*t, false);
                                
                                try { 
-                                       if ((port = _session.engine().register_output_port (*t, portname, _public_ports)) == 0) {
+                                       if ((port = _session.engine().register_output_port (*t, portname)) == 0) {
                                                error << string_compose(_("IO: cannot register output port %1"), portname) << endmsg;
                                                return -1;
                                        }
@@ -996,11 +993,11 @@ IO::ensure_io (ChanCount in, ChanCount out, bool clear, void* src)
                        /* disconnect all existing ports so that we get a fresh start */
                        
                        for (PortSet::iterator i = _inputs.begin(); i != _inputs.end(); ++i) {
-                               _session.engine().disconnect (*i);
+                               i->disconnect_all ();
                        }
                        
                        for (PortSet::iterator i = _outputs.begin(); i != _outputs.end(); ++i) {
-                               _session.engine().disconnect (*i);
+                               i->disconnect_all ();
                        }
                }
                
@@ -1013,16 +1010,17 @@ IO::ensure_io (ChanCount in, ChanCount out, bool clear, void* src)
        if (out_changed) {
                check_bundles_connected_to_outputs ();
                output_changed (ConfigurationChanged, src); /* EMIT SIGNAL */
+               setup_bundle_for_outputs ();
        }
        
        if (in_changed) {
                check_bundles_connected_to_inputs ();
                input_changed (ConfigurationChanged, src); /* EMIT SIGNAL */
+               setup_bundle_for_inputs ();
        }
 
        if (in_changed || out_changed) {
                PortCountChanged (max (n_outputs(), n_inputs())); /* EMIT SIGNAL */
-               setup_bundles_for_inputs_and_outputs ();
                _session.set_dirty ();
        }
 
@@ -1050,7 +1048,7 @@ IO::ensure_inputs (ChanCount count, bool clear, bool lockit, void* src)
 
        if (changed) {
                input_changed (ConfigurationChanged, src); /* EMIT SIGNAL */
-               setup_bundles_for_inputs_and_outputs ();
+               setup_bundle_for_inputs ();
                _session.set_dirty ();
        }
        return 0;
@@ -1087,7 +1085,7 @@ IO::ensure_outputs_locked (ChanCount count, bool clear, void* src)
 
                        string portname = build_legal_port_name (*t, false);
 
-                       if ((output_port = _session.engine().register_output_port (*t, portname, _public_ports)) == 0) {
+                       if ((output_port = _session.engine().register_output_port (*t, portname)) == 0) {
                                error << string_compose(_("IO: cannot register output port %1"), portname) << endmsg;
                                return -1;
                        }
@@ -1111,7 +1109,7 @@ IO::ensure_outputs_locked (ChanCount count, bool clear, void* src)
        if (clear) {
                /* disconnect all existing ports so that we get a fresh start */
                for (PortSet::iterator i = _outputs.begin(); i != _outputs.end(); ++i) {
-                       _session.engine().disconnect (*i);
+                       i->disconnect_all ();
                }
        }
 
@@ -1142,7 +1140,7 @@ IO::ensure_outputs (ChanCount count, bool clear, bool lockit, void* src)
 
        if (changed) {
                 output_changed (ConfigurationChanged, src); /* EMIT SIGNAL */
-                setup_bundles_for_inputs_and_outputs ();
+                setup_bundle_for_outputs ();
        }
 
        return 0;
@@ -1342,7 +1340,7 @@ IO::set_state (const XMLNode& node)
        if ((prop = node.property ("name")) != 0) {
                _name = prop->value();
                /* used to set panner name with this, but no more */
-       } 
+       }
 
        if ((prop = node.property ("id")) != 0) {
                _id = prop->value ();
@@ -1965,13 +1963,13 @@ IO::set_name (const string& requested_name)
        }
 
        for (PortSet::iterator i = _inputs.begin(); i != _inputs.end(); ++i) {
-               string current_name = i->short_name();
+               string current_name = i->name();
                current_name.replace (current_name.find (_name), _name.length(), name);
                i->set_name (current_name);
        }
 
        for (PortSet::iterator i = _outputs.begin(); i != _outputs.end(); ++i) {
-               string current_name = i->short_name();
+               string current_name = i->name();
                current_name.replace (current_name.find (_name), _name.length(), name);
                i->set_name (current_name);
        }
@@ -2028,7 +2026,7 @@ IO::output_latency () const
        /* io lock not taken - must be protected by other means */
 
        for (PortSet::const_iterator i = _outputs.begin(); i != _outputs.end(); ++i) {
-               if ((latency = _session.engine().get_port_total_latency (*i)) > max_latency) {
+               if ((latency = i->total_latency ()) > max_latency) {
                        max_latency = latency;
                }
        }
@@ -2047,7 +2045,7 @@ IO::input_latency () const
        /* io lock not taken - must be protected by other means */
 
        for (PortSet::const_iterator i = _inputs.begin(); i != _inputs.end(); ++i) {
-               if ((latency = _session.engine().get_port_total_latency (*i)) > max_latency) {
+               if ((latency = i->total_latency ()) > max_latency) {
                        max_latency = latency;
                } 
        }
@@ -2062,25 +2060,7 @@ IO::connect_input_ports_to_bundle (boost::shared_ptr<Bundle> c, void* src)
                BLOCK_PROCESS_CALLBACK ();
                Glib::Mutex::Lock lm2 (io_lock);
 
-               /* Connect to the bundle, not worrying about any connections
-                  that are already made. */
-
-               uint32_t cnt = c->nchannels ();
-
-               for (uint32_t n = 0; n < cnt; ++n) {
-                       const Bundle::PortList& pl = c->channel_ports (n);
-
-                       for (Bundle::PortList::const_iterator i = pl.begin(); i != pl.end(); ++i) {
-
-                         if (!_inputs.port(n)->connected_to (*i)) {
-                                       
-                                       if (_session.engine().connect (*i, _inputs.port(n)->name())) {
-                                               return -1;
-                                       }
-                               }
-                               
-                       }
-               }
+               c->connect (_bundle_for_inputs, _session.engine());
 
                /* If this is a UserBundle, make a note of what we've done */
 
@@ -2105,31 +2085,42 @@ IO::connect_input_ports_to_bundle (boost::shared_ptr<Bundle> c, void* src)
 }
 
 int
-IO::connect_output_ports_to_bundle (boost::shared_ptr<Bundle> c, void* src)
+IO::disconnect_input_ports_from_bundle (boost::shared_ptr<Bundle> c, void* src)
 {
        {
                BLOCK_PROCESS_CALLBACK ();
                Glib::Mutex::Lock lm2 (io_lock);
 
-               /* Connect to the bundle, not worrying about any connections
-                  that are already made. */
-
-               uint32_t cnt = c->nchannels ();
-
-               for (uint32_t n = 0; n < cnt; ++n) {
+               c->disconnect (_bundle_for_inputs, _session.engine());
+                       
+               /* If this is a UserBundle, make a note of what we've done */
 
-                       const Bundle::PortList& pl = c->channel_ports (n);
+               boost::shared_ptr<UserBundle> ub = boost::dynamic_pointer_cast<UserBundle> (c);
+               if (ub) {
 
-                       for (Bundle::PortList::const_iterator i = pl.begin(); i != pl.end(); ++i) {
+                       std::vector<UserBundleInfo>::iterator i = _bundles_connected_to_inputs.begin();
+                       while (i != _bundles_connected_to_inputs.end() && i->bundle != ub) {
+                               ++i;
+                       }
 
-                               if (!_outputs.port(n)->connected_to (*i)) {
-                                               
-                                       if (_session.engine().connect (_outputs.port(n)->name(), *i)) {
-                                               return -1;
-                                       }
-                               }
+                       if (i != _bundles_connected_to_inputs.end()) {
+                               _bundles_connected_to_inputs.erase (i);
                        }
                }
+       }
+
+       input_changed (IOChange (ConfigurationChanged|ConnectionsChanged), src); /* EMIT SIGNAL */
+       return 0;
+}
+
+int
+IO::connect_output_ports_to_bundle (boost::shared_ptr<Bundle> c, void* src)
+{
+       {
+               BLOCK_PROCESS_CALLBACK ();
+               Glib::Mutex::Lock lm2 (io_lock);
+
+               c->connect (_bundle_for_outputs, _session.engine());
 
                /* If this is a UserBundle, make a note of what we've done */
 
@@ -2154,6 +2145,36 @@ IO::connect_output_ports_to_bundle (boost::shared_ptr<Bundle> c, void* src)
        return 0;
 }
 
+int
+IO::disconnect_output_ports_from_bundle (boost::shared_ptr<Bundle> c, void* src)
+{
+       {
+               BLOCK_PROCESS_CALLBACK ();
+               Glib::Mutex::Lock lm2 (io_lock);
+
+               c->disconnect (_bundle_for_outputs, _session.engine());
+                       
+               /* If this is a UserBundle, make a note of what we've done */
+
+               boost::shared_ptr<UserBundle> ub = boost::dynamic_pointer_cast<UserBundle> (c);
+               if (ub) {
+
+                       std::vector<UserBundleInfo>::iterator i = _bundles_connected_to_outputs.begin();
+                       while (i != _bundles_connected_to_outputs.end() && i->bundle != ub) {
+                               ++i;
+                       }
+
+                       if (i != _bundles_connected_to_outputs.end()) {
+                               _bundles_connected_to_outputs.erase (i);
+                       }
+               }
+       }
+
+       output_changed (IOChange (ConfigurationChanged|ConnectionsChanged), src); /* EMIT SIGNAL */
+       return 0;
+}
+
+
 int
 IO::disable_connecting ()
 {
@@ -2197,19 +2218,12 @@ IO::reset_panners ()
 }
 
 void
-IO::bundle_configuration_changed ()
+IO::bundle_changed (Bundle::Change c)
 {
        //XXX
 //     connect_input_ports_to_bundle (_input_bundle, this);
 }
 
-void
-IO::bundle_ports_changed (int ignored)
-{
-       //XXX
-//     connect_output_ports_to_bundle (_output_bundle, this);
-}
-
 void
 IO::GainControl::set_value (float val)
 {
@@ -2319,6 +2333,8 @@ IO::set_gain (gain_t val, void *src)
                val = 1.99526231f;
        }
 
+       cerr << "set desired gain to " << val << " when curgain = " << _gain_control->get_value () << endl;
+
        if (src != _gain_control.get()) {
                _gain_control->set_value(val);
                // bit twisty, this will come back and call us again
@@ -2473,7 +2489,7 @@ IO::find_input_port_hole (const char* base)
                snprintf (buf, jack_port_name_size(), _("%s %u"), base, n);
 
                for ( ; i != _inputs.end(); ++i) {
-                       if (i->short_name() == buf) {
+                       if (i->name() == buf) {
                                break;
                        }
                }
@@ -2506,7 +2522,7 @@ IO::find_output_port_hole (const char* base)
                snprintf (buf, jack_port_name_size(), _("%s %u"), base, n);
 
                for ( ; i != _outputs.end(); ++i) {
-                       if (i->short_name() == buf) {
+                       if (i->name() == buf) {
                                break;
                        }
                }
@@ -2584,147 +2600,128 @@ IO::update_port_total_latencies ()
 
 
 /**
- *  Setup bundles that describe our inputs and outputs.
+ *  Setup bundles that describe our inputs and outputs. Also creates bundles if necessary.
  */
 
 void
 IO::setup_bundles_for_inputs_and_outputs ()
+{
+       setup_bundle_for_inputs ();
+       setup_bundle_for_outputs ();
+}
+
+
+void
+IO::setup_bundle_for_inputs ()
 {
         char buf[32];
 
+       if (!_bundle_for_inputs) {
+               _bundle_for_inputs.reset (new Bundle (true));
+       }
+
+       _bundle_for_inputs->suspend_signals ();
+
+       _bundle_for_inputs->set_type (default_type ());
+
        _bundle_for_inputs->remove_channels ();
-       _bundle_for_outputs->remove_channels ();
-               
+
         snprintf(buf, sizeof (buf), _("%s in"), _name.c_str());
         _bundle_for_inputs->set_name (buf);
        uint32_t const ni = inputs().num_ports();
        for (uint32_t i = 0; i < ni; ++i) {
-               snprintf (buf, sizeof(buf), _("in %d"), (i + 1));
-               _bundle_for_inputs->add_channel (buf);
-               _bundle_for_inputs->set_port (i, inputs().port(i)->name());
+               _bundle_for_inputs->add_channel (bundle_channel_name (i, ni));
+               _bundle_for_inputs->set_port (i, _session.engine().make_port_name_non_relative (inputs().port(i)->name()));
        }
 
-        snprintf(buf, sizeof (buf), _("%s out"), _name.c_str());
-        _bundle_for_outputs->set_name (buf);
-       uint32_t const no = outputs().num_ports();
-       for (uint32_t i = 0; i < no; ++i) {
-               snprintf (buf, sizeof(buf), _("out %d"), (i + 1));
-               _bundle_for_outputs->add_channel (buf);
-               _bundle_for_outputs->set_port (i, outputs().port(i)->name());
-       }
+       _bundle_for_inputs->resume_signals ();
 }
 
 
-/**
- *  Create and setup bundles that describe our inputs and outputs.
- */
-
 void
-IO::create_bundles_for_inputs_and_outputs ()
+IO::setup_bundle_for_outputs ()
 {
-       _bundle_for_inputs = boost::shared_ptr<Bundle> (new Bundle (true));
-        _bundle_for_outputs = boost::shared_ptr<Bundle> (new Bundle (false));
-        setup_bundles_for_inputs_and_outputs ();
-}
+        char buf[32];
 
-/** Add a bundle to a list if is connected to our inputs.
- *  @param b Bundle to check.
- *  @param bundles List to add to.
- */
-void
-IO::maybe_add_input_bundle_to_list (boost::shared_ptr<Bundle> b, std::vector<boost::shared_ptr<Bundle> >* bundles)
-{
-       if (b->ports_are_outputs() == false) {
-               return;
-       }
-       
-       if (b->nchannels() != n_inputs().n_total ()) {
-               return;
+       if (!_bundle_for_outputs) {
+               _bundle_for_outputs.reset (new Bundle (false));
        }
 
-       for (uint32_t i = 0; i < n_inputs().n_total (); ++i) {
+       _bundle_for_outputs->suspend_signals ();
 
-               Bundle::PortList const & pl = b->channel_ports (i);
+       _bundle_for_outputs->set_type (default_type ());
 
-               if (pl.empty()) {
-                       return;
-               }
+       _bundle_for_outputs->remove_channels ();
 
-               if (!input(i)->connected_to (pl[0])) {
-                       return;
-               }
+        snprintf(buf, sizeof (buf), _("%s out"), _name.c_str());
+        _bundle_for_outputs->set_name (buf);
+       uint32_t const no = outputs().num_ports();
+       for (uint32_t i = 0; i < no; ++i) {
+               _bundle_for_outputs->add_channel (bundle_channel_name (i, no));
+               _bundle_for_outputs->set_port (i, _session.engine().make_port_name_non_relative (outputs().port(i)->name()));
        }
 
-       bundles->push_back (b);
+       _bundle_for_outputs->resume_signals ();
 }
 
+
 /** @return Bundles connected to our inputs */
-std::vector<boost::shared_ptr<Bundle> >
+BundleList
 IO::bundles_connected_to_inputs ()
 {
-       std::vector<boost::shared_ptr<Bundle> > bundles;
+       BundleList bundles;
        
        /* User bundles */
        for (std::vector<UserBundleInfo>::iterator i = _bundles_connected_to_inputs.begin(); i != _bundles_connected_to_inputs.end(); ++i) {
                bundles.push_back (i->bundle);
        }
 
-       /* Normal bundles */
-       _session.foreach_bundle (
-               sigc::bind (sigc::mem_fun (*this, &IO::maybe_add_input_bundle_to_list), &bundles)
-               );
-
-       return bundles;
-}
-
-
-/** Add a bundle to a list if is connected to our outputs.
- *  @param b Bundle to check.
- *  @param bundles List to add to.
- */
-void
-IO::maybe_add_output_bundle_to_list (boost::shared_ptr<Bundle> b, std::vector<boost::shared_ptr<Bundle> >* bundles)
-{
-       if (b->ports_are_inputs() == false) {
-               return;
-       }
-
-       if (b->nchannels () != n_outputs().n_total ()) {
-               return;
-       }
-
-       for (uint32_t i = 0; i < n_outputs().n_total (); ++i) {
-
-               Bundle::PortList const & pl = b->channel_ports (i);
-
-               if (pl.empty()) {
-                       return;
+       /* Session bundles */
+       boost::shared_ptr<ARDOUR::BundleList> b = _session.bundles ();
+       for (ARDOUR::BundleList::iterator i = b->begin(); i != b->end(); ++i) {
+               if ((*i)->connected_to (_bundle_for_inputs, _session.engine())) {
+                       bundles.push_back (*i);
                }
+       }
 
-               if (!output(i)->connected_to (pl[0])) {
-                       return;
+       /* Route bundles */
+       boost::shared_ptr<ARDOUR::RouteList> r = _session.get_routes ();
+       for (ARDOUR::RouteList::iterator i = r->begin(); i != r->end(); ++i) {
+               if ((*i)->bundle_for_outputs()->connected_to (_bundle_for_inputs, _session.engine())) {
+                       bundles.push_back ((*i)->bundle_for_outputs());
                }
        }
-
-       bundles->push_back (b);
+         
+       return bundles;
 }
 
 
 /* @return Bundles connected to our outputs */
-std::vector<boost::shared_ptr<Bundle> >
+BundleList
 IO::bundles_connected_to_outputs ()
 {
-       std::vector<boost::shared_ptr<Bundle> > bundles;
+       BundleList bundles;
 
        /* User bundles */
        for (std::vector<UserBundleInfo>::iterator i = _bundles_connected_to_outputs.begin(); i != _bundles_connected_to_outputs.end(); ++i) {
                bundles.push_back (i->bundle);
        }
 
-       /* Auto bundles */
-       _session.foreach_bundle (
-               sigc::bind (sigc::mem_fun (*this, &IO::maybe_add_output_bundle_to_list), &bundles)
-               );
+       /* Session bundles */
+       boost::shared_ptr<ARDOUR::BundleList> b = _session.bundles ();
+       for (ARDOUR::BundleList::iterator i = b->begin(); i != b->end(); ++i) {
+               if ((*i)->connected_to (_bundle_for_outputs, _session.engine())) {
+                       bundles.push_back (*i);
+               }
+       }
+
+       /* Route bundles */
+       boost::shared_ptr<ARDOUR::RouteList> r = _session.get_routes ();
+       for (ARDOUR::RouteList::iterator i = r->begin(); i != r->end(); ++i) {
+               if ((*i)->bundle_for_inputs()->connected_to (_bundle_for_outputs, _session.engine())) {
+                       bundles.push_back ((*i)->bundle_for_inputs());
+               }
+       }
 
        return bundles; 
 }
@@ -2733,11 +2730,8 @@ IO::bundles_connected_to_outputs ()
 IO::UserBundleInfo::UserBundleInfo (IO* io, boost::shared_ptr<UserBundle> b)
 {
        bundle = b;
-       configuration_changed = b->ConfigurationChanged.connect (
-               sigc::mem_fun (*io, &IO::bundle_configuration_changed)
-               );
-       ports_changed = b->PortsChanged.connect (
-               sigc::mem_fun (*io, &IO::bundle_ports_changed)
+       changed = b->Changed.connect (
+               sigc::mem_fun (*io, &IO::bundle_changed)
                );
 }
 
@@ -2762,3 +2756,23 @@ IO::flush_outputs (nframes_t nframes, nframes_t offset)
        }
                
 }
+
+std::string
+IO::bundle_channel_name (uint32_t c, uint32_t n) const
+{
+       char buf[32];
+       
+       switch (n) {
+       case 1:
+               return _("mono");
+       case 2:
+               return c == 0 ? _("L") : _("R");
+       default:
+               snprintf (buf, sizeof(buf), _("%d"), (c + 1));
+               return buf;
+       }
+
+       return "";
+}
+
+