X-Git-Url: https://git.carlh.net/gitweb/?a=blobdiff_plain;f=gtk2_ardour%2Fio_selector.cc;h=99050cc34ba0a5a75c728d2cf1da11cdd6004b1c;hb=7e2c002ef67ac7396f2534c0fed7f9f447081a5a;hp=954ddb6b9a712af392a5cd31eef34766d9a35459;hpb=18d6284438bb69655670a7b1e931cd73f35d00d8;p=ardour.git diff --git a/gtk2_ardour/io_selector.cc b/gtk2_ardour/io_selector.cc index 954ddb6b9a..99050cc34b 100644 --- a/gtk2_ardour/io_selector.cc +++ b/gtk2_ardour/io_selector.cc @@ -1,5 +1,5 @@ /* - Copyright (C) 2002-2007 Paul Davis + Copyright (C) 2002-2007 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 @@ -17,457 +17,257 @@ */ -#include +#include + #include #include -#include -#include "ardour/session.h" -#include "ardour/io.h" #include "ardour/audioengine.h" -#include "ardour/track.h" -#include "ardour/audio_track.h" -#include "ardour/midi_track.h" +#include "ardour/bundle.h" #include "ardour/data_type.h" +#include "ardour/io.h" +#include "ardour/port.h" +#include "ardour/session.h" #include "io_selector.h" #include "utils.h" #include "gui_thread.h" -#include "i18n.h" +#include "pbd/i18n.h" using namespace ARDOUR; +using namespace ARDOUR_UI_UTILS; using namespace Gtk; -IOSelector::IOSelector (ARDOUR::Session& session, boost::shared_ptr io, bool offer_inputs) - : PortMatrix (session, io->default_type(), offer_inputs, - PortGroupList::Mask (PortGroupList::BUSS | - PortGroupList::SYSTEM | - PortGroupList::OTHER)) +IOSelector::IOSelector (Gtk::Window* p, ARDOUR::Session* session, boost::shared_ptr io) + : PortMatrix (p, session, DataType::NIL) , _io (io) { - list our_ports; + setup_type (); - /* Listen for ports changing on the IO */ - if (_offer_inputs) { - _io->output_changed.connect (mem_fun(*this, &IOSelector::ports_changed)); + /* signal flow from 0 to 1 */ - const PortSet& ps (_io->outputs()); - - for (PortSet::const_iterator i = ps.begin(); i != ps.end(); ++i) { - our_ports.push_back ((*i).name()); - } + _find_inputs_for_io_outputs = (_io->direction() == IO::Output); + if (_find_inputs_for_io_outputs) { + _other = 1; + _ours = 0; } else { - _io->input_changed.connect (mem_fun(*this, &IOSelector::ports_changed)); - - const PortSet& ps (_io->inputs()); - - for (PortSet::const_iterator i = ps.begin(); i != ps.end(); ++i) { - our_ports.push_back ((*i).name()); - } - + _other = 0; + _ours = 1; } - - set_ports (our_ports); -} -void -IOSelector::ports_changed (ARDOUR::IOChange change, void *src) -{ - ENSURE_GUI_THREAD (bind (mem_fun (*this, &IOSelector::ports_changed), change, src)); + _port_group.reset (new PortGroup (io->name())); + _ports[_ours].add_group (_port_group); - redisplay (); -} + io->changed.connect (_io_connection, invalidator (*this), boost::bind (&IOSelector::io_changed_proxy, this), gui_context ()); -void -IOSelector::set_state (int r, std::string const & p, bool s, uint32_t keymod) -{ - if (s) { - if (!_offer_inputs) { - _io->connect_input (_io->input(r), p, 0); - } else { - _io->connect_output (_io->output(r), p, 0); - } - } else { - if (!_offer_inputs) { - _io->disconnect_input (_io->input(r), p, 0); - } else { - _io->disconnect_output (_io->output(r), p, 0); - } - } + setup_all_ports (); + init (); } -bool -IOSelector::get_state (int r, std::string const & p) const +void +IOSelector::setup_type () { - vector connections; - - if (_offer_inputs) { - _io->output(r)->get_connections (connections); - } else { - _io->input(r)->get_connections (connections); - } - - int k = 0; - for (vector::iterator i = connections.begin(); i != connections.end(); ++i) { - - if ((*i)== p) { - return true; + /* set type according to what's in the IO */ + + int N = 0; + DataType type_with_ports = DataType::NIL; + for (DataType::iterator i = DataType::begin(); i != DataType::end(); ++i) { + if (_io->ports().num_ports (*i)) { + type_with_ports = *i; + ++N; } - - ++k; } - return false; -} - -uint32_t -IOSelector::n_rows () const -{ - if (!_offer_inputs) { - return _io->inputs().num_ports (_io->default_type()); + if (N <= 1) { + set_type (type_with_ports); } else { - return _io->outputs().num_ports (_io->default_type()); + set_type (DataType::NIL); } } -uint32_t -IOSelector::maximum_rows () const +void +IOSelector::io_changed_proxy () { - if (!_offer_inputs) { - return _io->input_maximum ().get (_io->default_type()); - } else { - return _io->output_maximum ().get (_io->default_type()); - } -} + /* The IO's changed signal is emitted from code that holds its route's processor lock, + so we can't call setup_all_ports (which results in a call to Route::foreach_processor) + without a deadlock unless we break things up with this idle handler. + */ - -uint32_t -IOSelector::minimum_rows () const -{ - if (!_offer_inputs) { - return _io->input_minimum ().get (_io->default_type()); - } else { - return _io->output_minimum ().get (_io->default_type()); - } + Glib::signal_idle().connect_once (sigc::mem_fun (*this, &IOSelector::io_changed)); } -std::string -IOSelector::row_name (int r) const +void +IOSelector::io_changed () { - string n; - string::size_type pos; - - if (!_offer_inputs) { - n = _io->input(r)->short_name(); - } else { - n = _io->output(r)->short_name(); - } - - if ((pos = n.find ('/')) != string::npos) { - return n.substr (pos+1); - } else { - return n; - } + setup_type (); + setup_all_ports (); } void -IOSelector::add_row () +IOSelector::setup_ports (int dim) { - // The IO selector only works for single typed IOs - const ARDOUR::DataType t = _io->default_type (); + if (!_session) { + return; + } - if (!_offer_inputs) { + _ports[dim].suspend_signals (); - try { - _io->add_input_port ("", this); - } + if (dim == _other) { - catch (AudioEngine::PortRegistrationFailure& err) { - MessageDialog msg (_("There are no more JACK ports available.")); - msg.run (); - } + _ports[_other].gather (_session, type(), _find_inputs_for_io_outputs, false, show_only_bundles ()); } else { - try { - _io->add_output_port ("", this); - } - - catch (AudioEngine::PortRegistrationFailure& err) { - MessageDialog msg (_("There are no more JACK ports available.")); - msg.run (); - } + _port_group->clear (); + _port_group->add_bundle (_io->bundle (), _io); } + + _ports[dim].resume_signals (); } void -IOSelector::remove_row (int r) +IOSelector::set_state (ARDOUR::BundleChannel c[2], bool s) { - // The IO selector only works for single typed IOs - const ARDOUR::DataType t = _io->default_type (); - - if (!_offer_inputs) { - _io->remove_input_port (_io->input (r), this); - } else { - _io->remove_output_port (_io->output (r), this); + ARDOUR::Bundle::PortList const & our_ports = c[_ours].bundle->channel_ports (c[_ours].channel); + ARDOUR::Bundle::PortList const & other_ports = c[_other].bundle->channel_ports (c[_other].channel); + + for (ARDOUR::Bundle::PortList::const_iterator i = our_ports.begin(); i != our_ports.end(); ++i) { + for (ARDOUR::Bundle::PortList::const_iterator j = other_ports.begin(); j != other_ports.end(); ++j) { + + boost::shared_ptr f = _session->engine().get_port_by_name (*i); + if (!f) { + return; + } + + if (s) { + if (!f->connected_to (*j)) { + _io->connect (f, *j, 0); + } + } else { + if (f->connected_to (*j)) { + _io->disconnect (f, *j, 0); + } + } + } } } -std::string -IOSelector::row_descriptor () const -{ - return _("port"); -} - -IOSelectorWindow::IOSelectorWindow (ARDOUR::Session& session, boost::shared_ptr io, bool for_input, bool can_cancel) - : ArdourDialog ("I/O selector") - , _selector (session, io, !for_input) - , add_button (_("Add Port")) - , disconnect_button (_("Disconnect All")) - , ok_button (can_cancel ? _("OK"): _("Close")) - , cancel_button (_("Cancel")) - , rescan_button (_("Rescan")) - +PortMatrixNode::State +IOSelector::get_state (ARDOUR::BundleChannel c[2]) const { - add_events (Gdk::KEY_PRESS_MASK | Gdk::KEY_RELEASE_MASK); - set_name ("IOSelectorWindow2"); - - disconnect_button.set_name ("IOSelectorButton"); - disconnect_button.set_image (*Gtk::manage (new Gtk::Image (Gtk::Stock::DISCONNECT, Gtk::ICON_SIZE_BUTTON))); - get_action_area()->pack_start (disconnect_button, false, false); - - if (_selector.maximum_rows() > _selector.n_rows()) { - add_button.set_name ("IOSelectorButton"); - add_button.set_image (*Gtk::manage (new Gtk::Image (Gtk::Stock::ADD, Gtk::ICON_SIZE_BUTTON))); - get_action_area()->pack_start (add_button, false, false); - add_button.signal_clicked().connect (sigc::mem_fun (_selector, &IOSelector::add_row)); - } - - if (!for_input) { - io->output_changed.connect (mem_fun(*this, &IOSelectorWindow::ports_changed)); - } else { - io->input_changed.connect (mem_fun(*this, &IOSelectorWindow::ports_changed)); + if (c[0].bundle->nchannels() == ChanCount::ZERO || c[1].bundle->nchannels() == ChanCount::ZERO) { + return PortMatrixNode::NOT_ASSOCIATED; } - rescan_button.set_name ("IOSelectorButton"); - rescan_button.set_image (*Gtk::manage (new Gtk::Image (Gtk::Stock::REFRESH, Gtk::ICON_SIZE_BUTTON))); - get_action_area()->pack_start (rescan_button, false, false); + ARDOUR::Bundle::PortList const & our_ports = c[_ours].bundle->channel_ports (c[_ours].channel); + ARDOUR::Bundle::PortList const & other_ports = c[_other].bundle->channel_ports (c[_other].channel); - if (can_cancel) { - cancel_button.set_name ("IOSelectorButton"); - cancel_button.set_image (*Gtk::manage (new Gtk::Image (Gtk::Stock::CANCEL, Gtk::ICON_SIZE_BUTTON))); - get_action_area()->pack_start (cancel_button, false, false); - } else { - cancel_button.hide(); - } - - ok_button.set_name ("IOSelectorButton"); - if (!can_cancel) { - ok_button.set_image (*Gtk::manage (new Gtk::Image (Gtk::Stock::CLOSE, Gtk::ICON_SIZE_BUTTON))); + if (!_session || our_ports.empty() || other_ports.empty()) { + /* we're looking at a bundle with no parts associated with this channel, + so nothing to connect */ + return PortMatrixNode::NOT_ASSOCIATED; } - get_action_area()->pack_start (ok_button, false, false); - get_vbox()->set_spacing (8); - get_vbox()->pack_start (_selector); + for (ARDOUR::Bundle::PortList::const_iterator i = our_ports.begin(); i != our_ports.end(); ++i) { + for (ARDOUR::Bundle::PortList::const_iterator j = other_ports.begin(); j != other_ports.end(); ++j) { - suggestion.set_alignment (0.5, 0.5); - suggestion_box.pack_start (suggestion, true, true); - get_vbox()->pack_start (suggestion_box); - - ok_button.signal_clicked().connect (mem_fun(*this, &IOSelectorWindow::accept)); - cancel_button.signal_clicked().connect (mem_fun(*this, &IOSelectorWindow::cancel)); - rescan_button.signal_clicked().connect (mem_fun(*this, &IOSelectorWindow::rescan)); - - set_position (Gtk::WIN_POS_MOUSE); - - io_name_changed (this); - ports_changed (IOChange (0), this); - leave_scroller ((GdkEventCrossing*) 0); + boost::shared_ptr f = _session->engine().get_port_by_name (*i); - show_all (); + /* since we are talking about an IO, our ports should all have an associated Port *, + so the above call should never fail */ + assert (f); - signal_delete_event().connect (bind (sigc::ptr_fun (just_hide_it), this)); + if (!f->connected_to (*j)) { + /* if any one thing is not connected, all bets are off */ + return PortMatrixNode::NOT_ASSOCIATED; + } + } + } - _selector.scrolled_window().add_events (Gdk::ENTER_NOTIFY_MASK|Gdk::LEAVE_NOTIFY_MASK); - _selector.scrolled_window().signal_enter_notify_event().connect (mem_fun (*this, &IOSelectorWindow::enter_scroller), false); - _selector.scrolled_window().signal_leave_notify_event().connect (mem_fun (*this, &IOSelectorWindow::leave_scroller), false); + return PortMatrixNode::ASSOCIATED; } -IOSelectorWindow::~IOSelectorWindow() +uint32_t +IOSelector::n_io_ports () const { - + if (!_find_inputs_for_io_outputs) { + return _io->n_ports().get (_io->default_type()); + } else { + return _io->n_ports().get (_io->default_type()); + } } bool -IOSelectorWindow::enter_scroller (GdkEventCrossing* ignored) +IOSelector::list_is_global (int dim) const { - cerr << "IN\n"; - suggestion.set_text (_("Click to connect. Ctrl-click to disconnect. Shift-click for cross-connect")); - return false; + return (dim == _other); } -bool -IOSelectorWindow::leave_scroller (GdkEventCrossing* ignored) +std::string +IOSelector::disassociation_verb () const { - cerr << "OUT, ev = " << ignored << "\n"; - suggestion.set_text (_("Right-click on individual port names for per-port operations")); - return false; + return _("Disconnect"); } -void -IOSelectorWindow::ports_changed (ARDOUR::IOChange change, void *src) +std::string +IOSelector::channel_noun () const { - if (_selector.maximum_rows() > _selector.n_rows()) { - add_button.set_sensitive (true); - } else { - add_button.set_sensitive (false); - } + return _("port"); } -void -IOSelectorWindow::rescan () +IOSelectorWindow::IOSelectorWindow (ARDOUR::Session* session, boost::shared_ptr io, bool /*can_cancel*/) + : ArdourWindow (_("I/O selector")) + , _selector (this, session, io) { - _selector.redisplay (); -} + set_name ("IOSelectorWindow2"); -void -IOSelectorWindow::cancel () -{ - _selector.Finished (IOSelector::Cancelled); - hide (); + add (_selector); + + io_name_changed (this); + + show_all (); + + signal_delete_event().connect (sigc::mem_fun (*this, &IOSelectorWindow::wm_delete)); } -void -IOSelectorWindow::accept () +bool +IOSelectorWindow::wm_delete (GdkEventAny* /*event*/) { _selector.Finished (IOSelector::Accepted); - hide (); + return false; } + void IOSelectorWindow::on_map () { - _selector.redisplay (); + _selector.setup_all_ports (); Window::on_map (); } void -IOSelectorWindow::io_name_changed (void* src) -{ - ENSURE_GUI_THREAD(bind (mem_fun(*this, &IOSelectorWindow::io_name_changed), src)); - - string title; - - if (!_selector.offering_input()) { - title = string_compose(_("%1 input"), _selector.io()->name()); - } else { - title = string_compose(_("%1 output"), _selector.io()->name()); - } - - set_title (title); -} - -PortInsertUI::PortInsertUI (ARDOUR::Session& sess, boost::shared_ptr pi) - : input_selector (sess, pi->io(), true), - output_selector (sess, pi->io(), false) -{ - hbox.pack_start (output_selector, true, true); - hbox.pack_start (input_selector, true, true); - - pack_start (hbox); -} - -void -PortInsertUI::redisplay () +IOSelectorWindow::on_show () { - input_selector.redisplay(); - output_selector.redisplay(); + Gtk::Window::on_show (); + std::pair const pm_max = _selector.max_size (); + resize_window_to_proportion_of_monitor (this, pm_max.first, pm_max.second); } void -PortInsertUI::finished (IOSelector::Result r) +IOSelectorWindow::io_name_changed (void*) { - input_selector.Finished (r); - output_selector.Finished (r); -} + ENSURE_GUI_THREAD (*this, &IOSelectorWindow::io_name_changed, src) + std::string title; -PortInsertWindow::PortInsertWindow (ARDOUR::Session& sess, boost::shared_ptr pi, bool can_cancel) - : ArdourDialog ("port insert dialog"), - _portinsertui (sess, pi), - ok_button (can_cancel ? _("OK"): _("Close")), - cancel_button (_("Cancel")), - rescan_button (_("Rescan")) -{ - - set_name ("IOSelectorWindow"); - string title = _("ardour: "); - title += pi->name(); - set_title (title); - - ok_button.set_name ("IOSelectorButton"); - if (!can_cancel) { - ok_button.set_image (*Gtk::manage (new Gtk::Image (Gtk::Stock::CLOSE, Gtk::ICON_SIZE_BUTTON))); - } - cancel_button.set_name ("IOSelectorButton"); - rescan_button.set_name ("IOSelectorButton"); - rescan_button.set_image (*Gtk::manage (new Gtk::Image (Gtk::Stock::REFRESH, Gtk::ICON_SIZE_BUTTON))); - - get_action_area()->pack_start (rescan_button, false, false); - if (can_cancel) { - cancel_button.set_image (*Gtk::manage (new Gtk::Image (Gtk::Stock::CANCEL, Gtk::ICON_SIZE_BUTTON))); - get_action_area()->pack_start (cancel_button, false, false); + if (!_selector.find_inputs_for_io_outputs()) { + title = string_compose(_("%1 input"), _selector.io()->name()); } else { - cancel_button.hide(); + title = string_compose(_("%1 output"), _selector.io()->name()); } - get_action_area()->pack_start (ok_button, false, false); - - get_vbox()->pack_start (_portinsertui); - - ok_button.signal_clicked().connect (mem_fun (*this, &PortInsertWindow::accept)); - cancel_button.signal_clicked().connect (mem_fun (*this, &PortInsertWindow::cancel)); - rescan_button.signal_clicked().connect (mem_fun (*this, &PortInsertWindow::rescan)); - - signal_delete_event().connect (bind (sigc::ptr_fun (just_hide_it), reinterpret_cast (this))); - - going_away_connection = pi->GoingAway.connect (mem_fun (*this, &PortInsertWindow::plugin_going_away)); -} - -void -PortInsertWindow::plugin_going_away () -{ - ENSURE_GUI_THREAD (mem_fun (*this, &PortInsertWindow::plugin_going_away)); - - going_away_connection.disconnect (); - delete_when_idle (this); -} - -void -PortInsertWindow::on_map () -{ - _portinsertui.redisplay (); - Window::on_map (); -} - -void -PortInsertWindow::rescan () -{ - _portinsertui.redisplay (); -} - -void -PortInsertWindow::cancel () -{ - _portinsertui.finished (IOSelector::Cancelled); - hide (); + set_title (title); } -void -PortInsertWindow::accept () -{ - _portinsertui.finished (IOSelector::Accepted); - hide (); -}