X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=libs%2Fardour%2Fbundle.cc;h=d8666c5bbba8d9d5424085185b9e4dc1bec09780;hb=ae94dfda5f42a6a0cbd042bce7a8007d90628d51;hp=98d056a8f175be1e97664fa89a9556c70f412f79;hpb=e0aaed6d65f160c328cb8b56d7c6552ee15d65e2;p=ardour.git

diff --git a/libs/ardour/bundle.cc b/libs/ardour/bundle.cc
index 98d056a8f1..d8666c5bbb 100644
--- a/libs/ardour/bundle.cc
+++ b/libs/ardour/bundle.cc
@@ -1,5 +1,5 @@
 /*
-    Copyright (C) 2002 Paul Davis 
+    Copyright (C) 2002 Paul Davis
 
     This program is free software; you can redistribute it and/or modify
     it under the terms of the GNU General Public License as published by
@@ -28,6 +28,7 @@
 
 #include "i18n.h"
 
+using namespace std;
 using namespace ARDOUR;
 using namespace PBD;
 
@@ -35,8 +36,7 @@ using namespace PBD;
  *  @param i true if ports are inputs, otherwise false.
  */
 Bundle::Bundle (bool i)
-	: _type (DataType::AUDIO),
-	  _ports_are_inputs (i),
+	: _ports_are_inputs (i),
 	  _signals_suspended (false),
 	  _pending_change (Change (0))
 {
@@ -50,7 +50,6 @@ Bundle::Bundle (bool i)
  */
 Bundle::Bundle (std::string const & n, bool i)
 	: _name (n),
-	  _type (DataType::AUDIO),
 	  _ports_are_inputs (i),
 	  _signals_suspended (false),
 	  _pending_change (Change (0))
@@ -58,45 +57,33 @@ Bundle::Bundle (std::string const & n, bool i)
 
 }
 
-
-/** Construct a bundle.
- *  @param n Name.
- *  @param t Type.
- *  @param i true if ports are inputs, otherwise false.
- */
-Bundle::Bundle (std::string const & n, DataType t, bool i)
-	: _name (n),
-	  _type (t),
-	  _ports_are_inputs (i),
-	  _signals_suspended (false),
-	  _pending_change (Change (0))
-{
-
-}
-
-
 Bundle::Bundle (boost::shared_ptr<Bundle> other)
 	: _channel (other->_channel),
 	  _name (other->_name),
-	  _type (other->_type),
 	  _ports_are_inputs (other->_ports_are_inputs),
 	  _signals_suspended (other->_signals_suspended),
 	  _pending_change (other->_pending_change)
 {
-	
+
 }
 
-uint32_t
+ChanCount
 Bundle::nchannels () const
 {
 	Glib::Mutex::Lock lm (_channel_mutex);
-	return _channel.size ();
+
+	ChanCount c;
+	for (vector<Channel>::const_iterator i = _channel.begin(); i != _channel.end(); ++i) {
+		c.set (i->type, c.get (i->type) + 1);
+	}
+
+	return c;
 }
 
 Bundle::PortList const &
 Bundle::channel_ports (uint32_t c) const
 {
-	assert (c < nchannels());
+	assert (c < nchannels().n_total());
 
 	Glib::Mutex::Lock lm (_channel_mutex);
 	return _channel[c].ports;
@@ -109,7 +96,7 @@ Bundle::channel_ports (uint32_t c) const
 void
 Bundle::add_port_to_channel (uint32_t ch, string portname)
 {
-	assert (ch < nchannels());
+	assert (ch < nchannels().n_total());
 	assert (portname.find_first_of (':') != string::npos);
 
 	{
@@ -127,7 +114,7 @@ Bundle::add_port_to_channel (uint32_t ch, string portname)
 void
 Bundle::remove_port_from_channel (uint32_t ch, string portname)
 {
-	assert (ch < nchannels());
+	assert (ch < nchannels().n_total());
 
 	bool changed = false;
 
@@ -135,7 +122,7 @@ Bundle::remove_port_from_channel (uint32_t ch, string portname)
 		Glib::Mutex::Lock lm (_channel_mutex);
 		PortList& pl = _channel[ch].ports;
 		PortList::iterator i = find (pl.begin(), pl.end(), portname);
-		
+
 		if (i != pl.end()) {
 			pl.erase (i);
 			changed = true;
@@ -154,7 +141,7 @@ Bundle::remove_port_from_channel (uint32_t ch, string portname)
 void
 Bundle::set_port (uint32_t ch, string portname)
 {
-	assert (ch < nchannels());
+	assert (ch < nchannels().n_total());
 	assert (portname.find_first_of (':') != string::npos);
 
 	{
@@ -168,11 +155,35 @@ Bundle::set_port (uint32_t ch, string portname)
 
 /** @param n Channel name */
 void
-Bundle::add_channel (std::string const & n)
+Bundle::add_channel (std::string const & n, DataType t)
 {
 	{
 		Glib::Mutex::Lock lm (_channel_mutex);
-		_channel.push_back (Channel (n));
+		_channel.push_back (Channel (n, t));
+	}
+
+	emit_changed (ConfigurationChanged);
+}
+
+/** @param n Channel name */
+void
+Bundle::add_channel (std::string const & n, DataType t, PortList p)
+{
+	{
+		Glib::Mutex::Lock lm (_channel_mutex);
+		_channel.push_back (Channel (n, t, p));
+	}
+
+	emit_changed (ConfigurationChanged);
+}
+
+/** @param n Channel name */
+void
+Bundle::add_channel (std::string const & n, DataType t, std::string const & p)
+{
+	{
+		Glib::Mutex::Lock lm (_channel_mutex);
+		_channel.push_back (Channel (n, t, p));
 	}
 
 	emit_changed (ConfigurationChanged);
@@ -181,8 +192,8 @@ Bundle::add_channel (std::string const & n)
 bool
 Bundle::port_attached_to_channel (uint32_t ch, std::string portname)
 {
-	assert (ch < nchannels());
-	
+	assert (ch < nchannels().n_total());
+
 	Glib::Mutex::Lock lm (_channel_mutex);
 	return (std::find (_channel[ch].ports.begin (), _channel[ch].ports.end (), portname) != _channel[ch].ports.end ());
 }
@@ -193,7 +204,7 @@ Bundle::port_attached_to_channel (uint32_t ch, std::string portname)
 void
 Bundle::remove_channel (uint32_t ch)
 {
-	assert (ch < nchannels ());
+	assert (ch < nchannels().n_total());
 
 	Glib::Mutex::Lock lm (_channel_mutex);
 	_channel.erase (_channel.begin () + ch);
@@ -212,7 +223,7 @@ Bundle::remove_channels ()
  *  @return true if any channel is associated with p.
  */
 bool
-Bundle::uses_port (std::string p) const
+Bundle::offers_port (std::string p) const
 {
 	Glib::Mutex::Lock lm (_channel_mutex);
 
@@ -251,7 +262,7 @@ Bundle::offers_port_alone (std::string p) const
 std::string
 Bundle::channel_name (uint32_t ch) const
 {
-	assert (ch < nchannels());
+	assert (ch < nchannels().n_total());
 
 	Glib::Mutex::Lock lm (_channel_mutex);
 	return _channel[ch].name;
@@ -264,7 +275,7 @@ Bundle::channel_name (uint32_t ch) const
 void
 Bundle::set_channel_name (uint32_t ch, std::string const & n)
 {
-	assert (ch < nchannels());
+	assert (ch < nchannels().n_total());
 
 	{
 		Glib::Mutex::Lock lm (_channel_mutex);
@@ -281,14 +292,14 @@ Bundle::set_channel_name (uint32_t ch, std::string const & n)
 void
 Bundle::add_channels_from_bundle (boost::shared_ptr<Bundle> other)
 {
-	uint32_t const ch = nchannels ();
-	
-	for (uint32_t i = 0; i < other->nchannels(); ++i) {
+	uint32_t const ch = nchannels().n_total();
+
+	for (uint32_t i = 0; i < other->nchannels().n_total(); ++i) {
 
 		std::stringstream s;
 		s << other->name() << " " << other->channel_name(i);
 
-		add_channel (s.str());
+		add_channel (s.str(), other->channel_type(i));
 
 		PortList const& pl = other->channel_ports (i);
 		for (uint32_t j = 0; j < pl.size(); ++j) {
@@ -305,8 +316,8 @@ Bundle::add_channels_from_bundle (boost::shared_ptr<Bundle> other)
 void
 Bundle::connect (boost::shared_ptr<Bundle> other, AudioEngine & engine)
 {
-	uint32_t const N = nchannels ();
-	assert (N == other->nchannels ());
+	uint32_t const N = nchannels().n_total();
+	assert (N == other->nchannels().n_total());
 
 	for (uint32_t i = 0; i < N; ++i) {
 		Bundle::PortList const & our_ports = channel_ports (i);
@@ -323,8 +334,8 @@ Bundle::connect (boost::shared_ptr<Bundle> other, AudioEngine & engine)
 void
 Bundle::disconnect (boost::shared_ptr<Bundle> other, AudioEngine & engine)
 {
-	uint32_t const N = nchannels ();
-	assert (N == other->nchannels ());
+	uint32_t const N = nchannels().n_total();
+	assert (N == other->nchannels().n_total());
 
 	for (uint32_t i = 0; i < N; ++i) {
 		Bundle::PortList const & our_ports = channel_ports (i);
@@ -359,8 +370,8 @@ Bundle::remove_ports_from_channels ()
 void
 Bundle::remove_ports_from_channel (uint32_t ch)
 {
-	assert (ch < nchannels ());
-	
+	assert (ch < nchannels().n_total());
+
 	{
 		Glib::Mutex::Lock lm (_channel_mutex);
 		_channel[ch].ports.clear ();
@@ -395,26 +406,23 @@ Bundle::emit_changed (Change c)
 		Changed (c);
 	}
 }
-		
+
 bool
 Bundle::connected_to (boost::shared_ptr<Bundle> other, AudioEngine & engine)
 {
-	if (_ports_are_inputs == other->_ports_are_inputs ||
-	    _type != other->_type ||
-	    nchannels() != other->nchannels ()) {
-
+	if (_ports_are_inputs == other->_ports_are_inputs || nchannels() != other->nchannels()) {
 		return false;
 	}
 
-	for (uint32_t i = 0; i < nchannels(); ++i) {
+	for (uint32_t i = 0; i < nchannels().n_total(); ++i) {
 		Bundle::PortList const & A = channel_ports (i);
 		Bundle::PortList const & B = other->channel_ports (i);
-		
+
 		for (uint32_t j = 0; j < A.size(); ++j) {
 			for (uint32_t k = 0; k < B.size(); ++k) {
 
-				Port* p = engine.get_port_by_name (A[j]);
-				Port* q = engine.get_port_by_name (B[k]);
+				boost::shared_ptr<Port> p = engine.get_port_by_name (A[j]);
+				boost::shared_ptr<Port> q = engine.get_port_by_name (B[k]);
 
 				if (!p && !q) {
 					return false;
@@ -431,3 +439,81 @@ Bundle::connected_to (boost::shared_ptr<Bundle> other, AudioEngine & engine)
 
 	return true;
 }
+
+void
+Bundle::set_ports_are_inputs ()
+{
+	_ports_are_inputs = true;
+	emit_changed (DirectionChanged);
+}
+
+void
+Bundle::set_ports_are_outputs ()
+{
+	_ports_are_inputs = false;
+	emit_changed (DirectionChanged);
+}
+
+/** Set the name.
+ *  @param n New name.
+ */
+void
+Bundle::set_name (string const & n)
+{
+	_name = n;
+	emit_changed (NameChanged);
+}
+
+/** @param b Other bundle.
+ *  @return true if b has the same number of channels as this bundle, and those channels have corresponding ports.
+ */
+bool
+Bundle::has_same_ports (boost::shared_ptr<Bundle> b) const
+{
+	uint32_t const N = nchannels().n_total();
+
+	if (b->nchannels().n_total() != N) {
+		return false;
+	}
+
+	/* XXX: probably should sort channel port lists before comparing them */
+
+	for (uint32_t i = 0; i < N; ++i) {
+		if (channel_ports (i) != b->channel_ports (i)) {
+			return false;
+		}
+	}
+
+	return true;
+}
+
+DataType
+Bundle::channel_type (uint32_t c) const
+{
+	assert (c < nchannels().n_total());
+
+	Glib::Mutex::Lock lm (_channel_mutex);
+	return _channel[c].type;
+}
+
+ostream &
+operator<< (ostream& os, Bundle const & b)
+{
+	os << "BUNDLE " << b.nchannels() << " channels: ";
+	for (uint32_t i = 0; i < b.nchannels().n_total(); ++i) {
+		os << "( ";
+		Bundle::PortList const & pl = b.channel_ports (i);
+		for (Bundle::PortList::const_iterator j = pl.begin(); j != pl.end(); ++j) {
+			os << *j << " ";
+		}
+		os << ") ";
+	}
+
+	return os;
+}
+
+bool
+Bundle::operator== (Bundle const & other)
+{
+	return _channel == other._channel;
+}