more solo model work, including a GUI fix for mute button state when the route is...
[ardour.git] / libs / ardour / route.cc
index c57594da3723b44cf3923b806ec0c876b8b85ae4..33af0f8abfc199d0046f3d506ad8ae1c3c4eb735 100644 (file)
@@ -80,7 +80,8 @@ Route::Route (Session& sess, string name, Flag flg, DataType default_type)
         , _meter_point (MeterPostFader)
         , _phase_invert (0)
         , _self_solo (false)
-        , _soloed_by_others (0)
+        , _soloed_by_others_upstream (0)
+        , _soloed_by_others_downstream (0)
         , _solo_isolated (0)
         , _denormal_protection (false)
         , _recordable (true)
@@ -90,7 +91,10 @@ Route::Route (Session& sess, string name, Flag flg, DataType default_type)
        , _mute_control (new MuteControllable (X_("mute"), *this))
        , _mute_master (new MuteMaster (sess, name))
         , _mute_points (MuteMaster::AllPoints)
+        , _path_muted_by_others (false)
         , _have_internal_generator (false)
+        , _physically_connected (false)
+        , _graph_level (-1)
         , _solo_safe (false)
        , _default_type (default_type)
         , _remote_control_id (0)
@@ -161,7 +165,9 @@ Route::init ()
                 _main_outs->panner()->set_bypassed (true);
        }
 
-        markup_solo_ignore ();
+        if (is_master() || is_monitor() || is_hidden()) {
+                _mute_master->set_solo_ignore (true);
+        }
 
        /* now that we have _meter, its safe to connect to this */
 
@@ -449,6 +455,10 @@ Route::process_output_buffers (BufferSet& bufs,
        Glib::RWLock::ReaderLock rm (_processor_lock, Glib::TRY_LOCK);
 
        if (rm.locked()) {
+                //cerr << name() << " upstream solo " << _soloed_by_others_upstream
+                // << " downstream solo " << _soloed_by_others_downstream
+                // << " self " << _self_solo
+                //<< endl;
                for (ProcessorList::iterator i = _processors.begin(); i != _processors.end(); ++i) {
 
                        if (bufs.count() != (*i)->input_streams()) {
@@ -529,10 +539,8 @@ Route::set_listen (bool yn, void* src)
        if (_monitor_send) {
                if (yn != _monitor_send->active()) {
                        if (yn) {
-                                _monitor_send->set_solo_level (1);
                                _monitor_send->activate ();
                        } else {
-                                _monitor_send->set_solo_level (0);
                                _monitor_send->deactivate ();
                        }
 
@@ -580,8 +588,8 @@ Route::set_solo (bool yn, void *src)
 
        if (self_soloed() != yn) {
                set_self_solo (yn);
-               set_delivery_solo ();
-               solo_changed (src); /* EMIT SIGNAL */
+                set_mute_master_solo ();
+               solo_changed (true, src); /* EMIT SIGNAL */
                _solo_control->Changed (); /* EMIT SIGNAL */
        }
 }
@@ -593,43 +601,63 @@ Route::set_self_solo (bool yn)
 }
 
 void
-Route::mod_solo_by_others (int32_t delta)
+Route::mod_solo_by_others_upstream (int32_t delta)
 {
         if (_solo_safe) {
                 return;
         }
 
        if (delta < 0) {
-               if (_soloed_by_others >= (uint32_t) abs (delta)) {
-                       _soloed_by_others += delta;
+               if (_soloed_by_others_upstream >= (uint32_t) abs (delta)) {
+                       _soloed_by_others_upstream += delta;
                } else {
-                       _soloed_by_others = 0;
+                       _soloed_by_others_upstream = 0;
                }
        } else {
-               _soloed_by_others += delta;
+               _soloed_by_others_upstream += delta;
        }
 
-       set_delivery_solo ();
-        solo_changed (this);
+        set_mute_master_solo ();
+        solo_changed (false, this);
 }
 
 void
-Route::set_delivery_solo ()
+Route::mod_solo_by_others_downstream (int32_t delta)
 {
-       /* tell all delivery processors what the solo situation is, so that they keep
-          delivering even though Session::soloing() is true and they were not
-          explicitly soloed.
-       */
+        if (_solo_safe) {
+                return;
+        }
 
-       Glib::RWLock::ReaderLock rm (_processor_lock);
-       for (ProcessorList::iterator i = _processors.begin(); i != _processors.end(); ++i) {
-               boost::shared_ptr<Delivery> d;
-               
-               if ((d = boost::dynamic_pointer_cast<Delivery> (*i)) != 0) {
-                       d->set_solo_level (soloed ());
-                       d->set_solo_isolated (solo_isolated());
+       if (delta < 0) {
+               if (_soloed_by_others_downstream >= (uint32_t) abs (delta)) {
+                       _soloed_by_others_downstream += delta;
+               } else {
+                       _soloed_by_others_downstream = 0;
                }
+       } else {
+               _soloed_by_others_downstream += delta;
        }
+
+        set_mute_master_solo ();
+        solo_changed (false, this);
+}
+
+void
+Route::set_mute_master_solo ()
+{
+        SoloLevel level;
+
+        if (self_soloed()) {
+                level = SelfSoloed;
+        } else if (soloed_by_others_upstream()) {
+                level = UpstreamSoloed;
+        } else if (soloed_by_others_downstream()) {
+                level = DownstreamSoloed;
+        } else {
+                level = NotSoloed;
+        }
+
+        _mute_master->set_solo_level (level);
 }
 
 void
@@ -648,34 +676,32 @@ Route::set_solo_isolated (bool yn, void *src)
 
        boost::shared_ptr<RouteList> routes = _session.get_routes ();
        for (RouteList::iterator i = routes->begin(); i != routes->end(); ++i) {
+
+               if ((*i).get() == this || (*i)->is_master() || (*i)->is_monitor() || (*i)->is_hidden()) {
+                        continue;
+                }
+
                bool sends_only;
-               bool does_feed = feeds (*i, &sends_only);
+               bool does_feed = direct_feeds (*i, &sends_only); // we will recurse anyway, so don't use ::feeds()
                
                if (does_feed && !sends_only) {
                        (*i)->set_solo_isolated (yn, (*i)->route_group());
                }
        }
 
-        /* XXX should we back-propagate as well? */
-
-       bool changed = false;
+        /* XXX should we back-propagate as well? (April 2010: myself and chris goddard think not) */
 
        if (yn) {
-               if (_solo_isolated == 0) {
-                       changed = true;
-               }
                _solo_isolated++;
+                _mute_master->clear_muted_by_others ();
+                solo_isolated_changed (src);
        } else {
-               changed = (_solo_isolated == 1);
                if (_solo_isolated > 0) {
                        _solo_isolated--;
+                        solo_isolated_changed (src);
                }
        }
 
-       if (changed) {
-               set_delivery_solo ();
-               solo_isolated_changed (src);
-       }
 }
 
 bool
@@ -687,13 +713,13 @@ Route::solo_isolated () const
 void
 Route::set_mute_points (MuteMaster::MutePoint mp)
 {
-       _mute_points = mp;
-       mute_points_changed (); /* EMIT SIGNAL */
-
-       if (_mute_master->muted()) {
-               _mute_master->mute_at (_mute_points);
-               mute_changed (this); /* EMIT SIGNAL */
-       }
+        _mute_points = mp;
+        _mute_master->set_mute_points (MuteMaster::AllPoints);
+        mute_points_changed (); /* EMIT SIGNAL */
+        
+        if (_mute_master->muted()) {
+                mute_changed (this); /* EMIT SIGNAL */
+        }
 }
 
 void
@@ -704,21 +730,56 @@ Route::set_mute (bool yn, void *src)
                return;
        }
 
-       if (muted() != yn) {
-               if (yn) {
-                       _mute_master->mute_at (_mute_points);
-               } else {
-                       _mute_master->clear_mute ();
-               }
-
+       if (self_muted() != yn) {
+                _mute_master->set_self_muted (yn);
                mute_changed (src); /* EMIT SIGNAL */
        }
 }
 
 bool
-Route::muted() const
+Route::muted () const
+{
+        return self_muted() || muted_by_others();
+}
+
+bool
+Route::self_muted() const
+{
+       return _mute_master->self_muted ();
+}
+
+bool
+Route::muted_by_others() const
+{
+       return _mute_master->muted_by_others ();
+}
+
+void
+Route::mod_muted_by_others (int delta)
+{
+        if (_solo_isolated) {
+                return;
+        }
+
+        bool old = muted ();
+        _mute_master->mod_muted_by_others (delta);
+        if (old != muted()) {
+                mute_changed (this);
+        }
+}
+
+void
+Route::mod_path_muted_by_others (int32_t delta)
 {
-       return _mute_master->muted ();
+       if (delta < 0) {
+               if (_path_muted_by_others >= (uint32_t) abs (delta)) {
+                       _path_muted_by_others += delta;
+               } else {
+                       _path_muted_by_others = 0;
+               }
+       } else {
+               _path_muted_by_others += delta;
+       }
 }
 
 #if 0
@@ -825,12 +886,6 @@ Route::add_processor (boost::shared_ptr<Processor> processor, ProcessorList::ite
 
                 if (isend && _session.monitor_out() && (isend->target_id() == _session.monitor_out()->id())) {
                         _monitor_send = isend;
-                        
-                        if (_monitor_send->active()) {
-                                _monitor_send->set_solo_level (1);
-                        } else {
-                                _monitor_send->set_solo_level (0);
-                        }
                 }
 
                if (activation_allowed && (processor != _monitor_send)) {
@@ -1675,8 +1730,10 @@ Route::state(bool full_state)
        }
        node->add_property ("order-keys", order_string);
        node->add_property ("self-solo", (_self_solo ? "yes" : "no"));
-       snprintf (buf, sizeof (buf), "%d", _soloed_by_others);
-       node->add_property ("soloed-by-others", buf);
+       snprintf (buf, sizeof (buf), "%d", _soloed_by_others_upstream);
+       node->add_property ("soloed-by-upstream", buf);
+       snprintf (buf, sizeof (buf), "%d", _soloed_by_others_downstream);
+       node->add_property ("soloed-by-downstream", buf);
 
        node->add_child_nocopy (_input->state (full_state));
        node->add_child_nocopy (_output->state (full_state));
@@ -1742,6 +1799,10 @@ Route::_set_state (const XMLNode& node, int version, bool /*call_base*/)
                _flags = Flag (0);
        }
 
+        if (is_master() || is_monitor() || is_hidden()) {
+                _mute_master->set_solo_ignore (true);
+        }
+
        /* add all processors (except amp, which is always present) */
 
        nlist = node.children();
@@ -1774,9 +1835,14 @@ Route::_set_state (const XMLNode& node, int version, bool /*call_base*/)
                set_self_solo (string_is_affirmative (prop->value()));
        }
 
-       if ((prop = node.property ("soloed-by-others")) != 0) {
-               _soloed_by_others = 0; // needed for mod_solo_by_others () to work
-               mod_solo_by_others (atoi (prop->value()));
+       if ((prop = node.property ("soloed-by-upstream")) != 0) {
+               _soloed_by_others_upstream = 0; // needed for mod_.... () to work
+               mod_solo_by_others_upstream (atoi (prop->value()));
+       }
+
+       if ((prop = node.property ("soloed-by-downstream")) != 0) {
+               _soloed_by_others_downstream = 0; // needed for mod_.... () to work
+               mod_solo_by_others_downstream (atoi (prop->value()));
        }
 
        if ((prop = node.property ("solo-isolated")) != 0) {
@@ -1919,7 +1985,7 @@ Route::_set_state_2X (const XMLNode& node, int version)
                bool first = true;
                bool muted = string_is_affirmative (prop->value());
                
-               if(muted){
+               if (muted){
                  
                        string mute_point;
                        
@@ -1969,7 +2035,7 @@ Route::_set_state_2X (const XMLNode& node, int version)
                                }
                        }
                        
-                       _mute_master->set_state (mute_point);
+                       _mute_master->set_mute_points (mute_point);
                }
        }
 
@@ -2249,30 +2315,9 @@ Route::set_processor_state (const XMLNode& node)
                 }
         }
 
-        markup_solo_ignore ();
-
         processors_changed (RouteProcessorChange ());
 }
 
-void
-Route::markup_solo_ignore ()
-{
-        Glib::RWLock::ReaderLock lm (_processor_lock);
-        
-        for (ProcessorList::iterator p = _processors.begin(); p !=  _processors.end(); ++p) {
-
-                /* all delivery processors on master, monitor and auditioner never ever pay attention to solo
-                 */
-
-                boost::shared_ptr<Delivery> d = boost::dynamic_pointer_cast<Delivery>(*p);
-                
-                if (d && (is_master() || is_monitor() || is_hidden())) {
-                        cerr << _name << " Found a delivery unit, mark solo ignored\n";
-                        d->set_solo_ignored (true);
-                }
-        }
-}
-
 void
 Route::curve_reallocate ()
 {
@@ -2372,11 +2417,6 @@ Route::listen_via (boost::shared_ptr<Route> route, Placement placement, bool /*a
 
                                if (route == _session.monitor_out()) {
                                        _monitor_send = boost::dynamic_pointer_cast<Delivery>(d);
-                                        if (_monitor_send->active()) {
-                                                _monitor_send->set_solo_level (1);
-                                        } else {
-                                                _monitor_send->set_solo_level (0);
-                                        }
                                }
 
                                /* already listening via the specified IO: do nothing */
@@ -2465,7 +2505,53 @@ Route::set_comment (string cmt, void *src)
 }
 
 bool
-Route::feeds (boost::shared_ptr<Route> other, bool* only_send)
+Route::add_fed_by (boost::shared_ptr<Route> other, bool via_sends_only)
+{
+        FeedRecord fr (other, via_sends_only);
+
+        pair<FedBy::iterator,bool> result =  _fed_by.insert (fr);
+
+        if (!result.second) {
+
+                /* already a record for "other" - make sure sends-only information is correct */
+                if (!via_sends_only && result.first->sends_only) {
+                        FeedRecord* frp = const_cast<FeedRecord*>(&(*result.first));
+                        frp->sends_only = false;
+                }
+        }
+        
+        return result.second;
+}
+
+void
+Route::clear_fed_by ()
+{
+        _fed_by.clear ();
+}
+
+bool
+Route::feeds (boost::shared_ptr<Route> other, bool* via_sends_only)
+{
+        const FedBy& fed_by (other->fed_by());
+
+        for (FedBy::iterator f = fed_by.begin(); f != fed_by.end(); ++f) {
+                boost::shared_ptr<Route> sr = f->r.lock();
+
+                if (sr && (sr.get() == this)) {
+
+                        if (via_sends_only) {
+                                *via_sends_only = f->sends_only;
+                        }
+
+                        return true;
+                }
+        }
+
+        return false;
+}
+
+bool
+Route::direct_feeds (boost::shared_ptr<Route> other, bool* only_send)
 {
        DEBUG_TRACE (DEBUG::Graph, string_compose ("Feeds? %1\n", _name));
 
@@ -2503,6 +2589,12 @@ Route::feeds (boost::shared_ptr<Route> other, bool* only_send)
        return false;
 }
 
+void
+Route::check_physical_connections ()
+{
+        _physically_connected = _output->physically_connected ();
+}
+
 void
 Route::handle_transport_stopped (bool /*abort_ignored*/, bool did_locate, bool can_flush_processors)
 {
@@ -2962,7 +3054,7 @@ Route::MuteControllable::set_value (float val)
 float
 Route::MuteControllable::get_value (void) const
 {
-       return route.muted() ? 1.0f : 0.0f;
+       return route.self_muted() ? 1.0f : 0.0f;
 }
 
 void
@@ -3273,3 +3365,9 @@ Route::has_io_processor_named (const string& name)
         
         return false;
 }
+
+void
+Route::set_graph_level (int32_t l)
+{
+        _graph_level = l;
+}