2 Copyright (C) 2002 Paul Davis
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.
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.
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.
22 #include "ardour/bundle.h"
23 #include "ardour/audioengine.h"
24 #include "ardour/port.h"
29 using namespace ARDOUR;
32 /** Construct an audio bundle.
33 * @param i true if ports are inputs, otherwise false.
35 Bundle::Bundle (bool i)
36 : _ports_are_inputs (i),
37 _signals_suspended (false),
38 _pending_change (Change (0))
44 /** Construct an audio bundle.
46 * @param i true if ports are inputs, otherwise false.
48 Bundle::Bundle (std::string const & n, bool i)
50 _ports_are_inputs (i),
51 _signals_suspended (false),
52 _pending_change (Change (0))
57 Bundle::Bundle (boost::shared_ptr<Bundle> other)
58 : _channel (other->_channel),
60 _ports_are_inputs (other->_ports_are_inputs),
61 _signals_suspended (other->_signals_suspended),
62 _pending_change (other->_pending_change)
68 Bundle::nchannels () const
70 Glib::Mutex::Lock lm (_channel_mutex);
73 for (vector<Channel>::const_iterator i = _channel.begin(); i != _channel.end(); ++i) {
74 c.set (i->type, c.get (i->type) + 1);
80 Bundle::PortList const &
81 Bundle::channel_ports (uint32_t c) const
83 assert (c < nchannels().n_total());
85 Glib::Mutex::Lock lm (_channel_mutex);
86 return _channel[c].ports;
89 /** Add an association between one of our channels and a port.
90 * @param ch Channel index.
91 * @param portname full port name to associate with (including prefix).
94 Bundle::add_port_to_channel (uint32_t ch, string portname)
96 assert (ch < nchannels().n_total());
97 assert (portname.find_first_of (':') != string::npos);
100 Glib::Mutex::Lock lm (_channel_mutex);
101 _channel[ch].ports.push_back (portname);
104 emit_changed (PortsChanged);
107 /** Disassociate a port from one of our channels.
108 * @param ch Channel index.
109 * @param portname port name to disassociate from.
112 Bundle::remove_port_from_channel (uint32_t ch, string portname)
114 assert (ch < nchannels().n_total());
116 bool changed = false;
119 Glib::Mutex::Lock lm (_channel_mutex);
120 PortList& pl = _channel[ch].ports;
121 PortList::iterator i = find (pl.begin(), pl.end(), portname);
130 emit_changed (PortsChanged);
134 /** Set a single port to be associated with a channel, removing any others.
136 * @param portname Full port name, including prefix.
139 Bundle::set_port (uint32_t ch, string portname)
141 assert (ch < nchannels().n_total());
142 assert (portname.find_first_of (':') != string::npos);
145 Glib::Mutex::Lock lm (_channel_mutex);
146 _channel[ch].ports.clear ();
147 _channel[ch].ports.push_back (portname);
150 emit_changed (PortsChanged);
153 /** @param n Channel name */
155 Bundle::add_channel (std::string const & n, DataType t)
158 Glib::Mutex::Lock lm (_channel_mutex);
159 _channel.push_back (Channel (n, t));
162 emit_changed (ConfigurationChanged);
165 /** @param n Channel name */
167 Bundle::add_channel (std::string const & n, DataType t, PortList p)
170 Glib::Mutex::Lock lm (_channel_mutex);
171 _channel.push_back (Channel (n, t, p));
174 emit_changed (ConfigurationChanged);
177 /** @param n Channel name */
179 Bundle::add_channel (std::string const & n, DataType t, std::string const & p)
182 Glib::Mutex::Lock lm (_channel_mutex);
183 _channel.push_back (Channel (n, t, p));
186 emit_changed (ConfigurationChanged);
190 Bundle::port_attached_to_channel (uint32_t ch, std::string portname)
192 assert (ch < nchannels().n_total());
194 Glib::Mutex::Lock lm (_channel_mutex);
195 return (std::find (_channel[ch].ports.begin (), _channel[ch].ports.end (), portname) != _channel[ch].ports.end ());
198 /** Remove a channel.
202 Bundle::remove_channel (uint32_t ch)
204 assert (ch < nchannels().n_total());
206 Glib::Mutex::Lock lm (_channel_mutex);
207 _channel.erase (_channel.begin () + ch);
210 /** Remove all channels */
212 Bundle::remove_channels ()
214 Glib::Mutex::Lock lm (_channel_mutex);
219 /** @param p Port name.
220 * @return true if any channel is associated with p.
223 Bundle::offers_port (std::string p) const
225 Glib::Mutex::Lock lm (_channel_mutex);
227 for (std::vector<Channel>::const_iterator i = _channel.begin(); i != _channel.end(); ++i) {
228 for (PortList::const_iterator j = i->ports.begin(); j != i->ports.end(); ++j) {
238 /** @param p Port name.
239 * @return true if this bundle offers this port on its own on a channel.
242 Bundle::offers_port_alone (std::string p) const
244 Glib::Mutex::Lock lm (_channel_mutex);
246 for (std::vector<Channel>::const_iterator i = _channel.begin(); i != _channel.end(); ++i) {
247 if (i->ports.size() == 1 && i->ports[0] == p) {
256 /** @param ch Channel.
257 * @return Channel name.
260 Bundle::channel_name (uint32_t ch) const
262 assert (ch < nchannels().n_total());
264 Glib::Mutex::Lock lm (_channel_mutex);
265 return _channel[ch].name;
268 /** Set the name of a channel.
273 Bundle::set_channel_name (uint32_t ch, std::string const & n)
275 assert (ch < nchannels().n_total());
278 Glib::Mutex::Lock lm (_channel_mutex);
279 _channel[ch].name = n;
282 emit_changed (NameChanged);
285 /** Take the channels from another bundle and add them to this bundle,
286 * so that channels from other are added to this (with their ports)
287 * and are named "<other_bundle_name> <other_channel_name>".
290 Bundle::add_channels_from_bundle (boost::shared_ptr<Bundle> other)
292 uint32_t const ch = nchannels().n_total();
294 for (uint32_t i = 0; i < other->nchannels().n_total(); ++i) {
297 s << other->name() << " " << other->channel_name(i);
299 add_channel (s.str(), other->channel_type(i));
301 PortList const& pl = other->channel_ports (i);
302 for (uint32_t j = 0; j < pl.size(); ++j) {
303 add_port_to_channel (ch + i, pl[j]);
308 /** Connect the ports associated with our channels to the ports associated
309 * with another bundle's channels.
310 * @param other Other bundle.
311 * @param engine AudioEngine to use to make the connections.
314 Bundle::connect (boost::shared_ptr<Bundle> other, AudioEngine & engine)
316 uint32_t const N = nchannels().n_total();
317 assert (N == other->nchannels().n_total());
319 for (uint32_t i = 0; i < N; ++i) {
320 Bundle::PortList const & our_ports = channel_ports (i);
321 Bundle::PortList const & other_ports = other->channel_ports (i);
323 for (Bundle::PortList::const_iterator j = our_ports.begin(); j != our_ports.end(); ++j) {
324 for (Bundle::PortList::const_iterator k = other_ports.begin(); k != other_ports.end(); ++k) {
325 engine.connect (*j, *k);
332 Bundle::disconnect (boost::shared_ptr<Bundle> other, AudioEngine & engine)
334 uint32_t const N = nchannels().n_total();
335 assert (N == other->nchannels().n_total());
337 for (uint32_t i = 0; i < N; ++i) {
338 Bundle::PortList const & our_ports = channel_ports (i);
339 Bundle::PortList const & other_ports = other->channel_ports (i);
341 for (Bundle::PortList::const_iterator j = our_ports.begin(); j != our_ports.end(); ++j) {
342 for (Bundle::PortList::const_iterator k = other_ports.begin(); k != other_ports.end(); ++k) {
343 engine.disconnect (*j, *k);
349 /** Remove all ports from all channels */
351 Bundle::remove_ports_from_channels ()
354 Glib::Mutex::Lock lm (_channel_mutex);
355 for (uint32_t c = 0; c < _channel.size(); ++c) {
356 _channel[c].ports.clear ();
361 emit_changed (PortsChanged);
364 /** Remove all ports from a given channel.
368 Bundle::remove_ports_from_channel (uint32_t ch)
370 assert (ch < nchannels().n_total());
373 Glib::Mutex::Lock lm (_channel_mutex);
374 _channel[ch].ports.clear ();
377 emit_changed (PortsChanged);
381 Bundle::suspend_signals ()
383 _signals_suspended = true;
387 Bundle::resume_signals ()
389 if (_pending_change) {
390 Changed (_pending_change);
391 _pending_change = Change (0);
394 _signals_suspended = false;
398 Bundle::emit_changed (Change c)
400 if (_signals_suspended) {
401 _pending_change = Change (int (_pending_change) | int (c));
408 Bundle::connected_to (boost::shared_ptr<Bundle> other, AudioEngine & engine)
410 if (_ports_are_inputs == other->_ports_are_inputs || nchannels() != other->nchannels()) {
414 for (uint32_t i = 0; i < nchannels().n_total(); ++i) {
415 Bundle::PortList const & A = channel_ports (i);
416 Bundle::PortList const & B = other->channel_ports (i);
418 for (uint32_t j = 0; j < A.size(); ++j) {
419 for (uint32_t k = 0; k < B.size(); ++k) {
421 boost::shared_ptr<Port> p = engine.get_port_by_name (A[j]);
422 boost::shared_ptr<Port> q = engine.get_port_by_name (B[k]);
428 if (p && !p->connected_to (B[k])) {
430 } else if (q && !q->connected_to (A[j])) {
440 /** This must not be called in code executed as a response to a JACK event,
441 * as it uses jack_port_get_all_connections().
442 * @return true if any of this bundle's channels are connected to anything.
445 Bundle::connected_to_anything (AudioEngine& engine)
447 for (uint32_t i = 0; i < nchannels().n_total(); ++i) {
448 Bundle::PortList const & ports = channel_ports (i);
450 for (uint32_t j = 0; j < ports.size(); ++j) {
451 /* ports[j] may not be an Ardour port, so use JACK directly
452 rather than doing it with Port.
454 jack_port_t* jp = jack_port_by_name (engine.jack(), ports[j].c_str());
456 const char ** c = jack_port_get_all_connections (engine.jack(), jp);
469 Bundle::set_ports_are_inputs ()
471 _ports_are_inputs = true;
472 emit_changed (DirectionChanged);
476 Bundle::set_ports_are_outputs ()
478 _ports_are_inputs = false;
479 emit_changed (DirectionChanged);
486 Bundle::set_name (string const & n)
489 emit_changed (NameChanged);
492 /** @param b Other bundle.
493 * @return true if b has the same number of channels as this bundle, and those channels have corresponding ports.
496 Bundle::has_same_ports (boost::shared_ptr<Bundle> b) const
498 uint32_t const N = nchannels().n_total();
500 if (b->nchannels().n_total() != N) {
504 /* XXX: probably should sort channel port lists before comparing them */
506 for (uint32_t i = 0; i < N; ++i) {
507 if (channel_ports (i) != b->channel_ports (i)) {
516 Bundle::channel_type (uint32_t c) const
518 assert (c < nchannels().n_total());
520 Glib::Mutex::Lock lm (_channel_mutex);
521 return _channel[c].type;
525 operator<< (ostream& os, Bundle const & b)
527 os << "BUNDLE " << b.nchannels() << " channels: ";
528 for (uint32_t i = 0; i < b.nchannels().n_total(); ++i) {
530 Bundle::PortList const & pl = b.channel_ports (i);
531 for (Bundle::PortList::const_iterator j = pl.begin(); j != pl.end(); ++j) {
541 Bundle::operator== (Bundle const & other)
543 return _channel == other._channel;
546 /** Given an index of a channel as the nth channel of a particular type,
547 * return an index of that channel when considering channels of all types.
549 * e.g. given a bundle with channels:
554 * If t == MIDI and c == 0, then we would return 2, as 2 is the index of the
557 * If t == NIL, we just return c.
561 Bundle::type_channel_to_overall (DataType t, uint32_t c) const
563 if (t == DataType::NIL) {
567 Glib::Mutex::Lock lm (_channel_mutex);
569 vector<Channel>::const_iterator i = _channel.begin ();
575 assert (i != _channel.end ());
593 /** Perform the reverse of type_channel_to_overall */
595 Bundle::overall_channel_to_type (DataType t, uint32_t c) const
597 if (t == DataType::NIL) {
601 Glib::Mutex::Lock lm (_channel_mutex);
605 vector<Channel>::const_iterator i = _channel.begin ();
606 for (uint32_t j = 0; j < c; ++j) {