assert() to help find some possible causes of #2991. Fix some confusion with GTK...
[ardour.git] / libs / ardour / session_state.cc
index 79c937daebf3d740eae9be3ad1df8c3ce2413f48..e222de2221624a1df43ea398569179f483840b9a 100644 (file)
@@ -30,7 +30,6 @@
 #include <string>
 #include <cerrno>
 
-#include <sigc++/bind.h>
 
 #include <cstdio> /* snprintf(3) ... grrr */
 #include <cmath>
@@ -58,6 +57,7 @@
 #include "midi++/port.h"
 
 #include "pbd/boost_debug.h"
+#include "pbd/controllable_descriptor.h"
 #include "pbd/enumwriter.h"
 #include "pbd/error.h"
 #include "pbd/pathscanner.h"
@@ -65,6 +65,7 @@
 #include "pbd/search_path.h"
 #include "pbd/stacktrace.h"
 
+#include "ardour/amp.h"
 #include "ardour/audio_diskstream.h"
 #include "ardour/audio_track.h"
 #include "ardour/audioengine.h"
@@ -145,10 +146,8 @@ Session::first_stage_init (string fullpath, string snapshot_name)
        }
 
        if (Glib::file_test (_path, Glib::FILE_TEST_EXISTS) && ::access (_path.c_str(), W_OK)) {
-               cerr << "Session non-writable based on " << _path << endl;
                _writable = false;
        } else {
-               cerr << "Session writable based on " << _path << endl;
                _writable = true;
        }
 
@@ -165,7 +164,7 @@ Session::first_stage_init (string fullpath, string snapshot_name)
        _base_frame_rate = _current_frame_rate;
 
        _tempo_map = new TempoMap (_current_frame_rate);
-       _tempo_map->StateChanged.connect (mem_fun (*this, &Session::tempo_map_changed));
+       _tempo_map->StateChanged.connect_same_thread (*this, boost::bind (&Session::tempo_map_changed, this, _1));
 
 
        _non_soloed_outs_muted = false;
@@ -210,7 +209,6 @@ Session::first_stage_init (string fullpath, string snapshot_name)
        g_atomic_int_set (&_capture_load_min, 100);
        _play_range = false;
        _exporting = false;
-       _exporting_realtime = false;
        _gain_automation_buffer = 0;
        _pan_automation_buffer = 0;
        _npan_buffers = 0;
@@ -219,7 +217,7 @@ Session::first_stage_init (string fullpath, string snapshot_name)
        first_file_data_format_reset = true;
        first_file_header_format_reset = true;
        post_export_sync = false;
-       //midi_thread = (pthread_t) 0;
+       midi_control_ui = 0;
 
        AudioDiskstream::allocate_working_buffers();
 
@@ -267,20 +265,17 @@ Session::first_stage_init (string fullpath, string snapshot_name)
        delta_accumulator_cnt = 0;
        _slave_state = Stopped;
 
-       _engine.GraphReordered.connect (mem_fun (*this, &Session::graph_reordered));
+       _engine.GraphReordered.connect_same_thread (*this, boost::bind (&Session::graph_reordered, this));
 
        /* These are all static "per-class" signals */
 
-       RegionFactory::CheckNewRegion.connect (mem_fun (*this, &Session::add_region));
-       SourceFactory::SourceCreated.connect (mem_fun (*this, &Session::add_source));
-       PlaylistFactory::PlaylistCreated.connect (mem_fun (*this, &Session::add_playlist));
-       Processor::ProcessorCreated.connect (mem_fun (*this, &Session::add_processor));
-       NamedSelection::NamedSelectionCreated.connect (mem_fun (*this, &Session::add_named_selection));
-       AutomationList::AutomationListCreated.connect (mem_fun (*this, &Session::add_automation_list));
-
-       Controllable::Destroyed.connect (mem_fun (*this, &Session::remove_controllable));
-
-       IO::PortCountChanged.connect (mem_fun (*this, &Session::ensure_buffers));
+       RegionFactory::CheckNewRegion.connect_same_thread (*this, boost::bind (&Session::add_region, this, _1));
+       SourceFactory::SourceCreated.connect_same_thread (*this, boost::bind (&Session::add_source, this, _1));
+       PlaylistFactory::PlaylistCreated.connect_same_thread (*this, boost::bind (&Session::add_playlist, this, _1, _2));
+       Processor::ProcessorCreated.connect_same_thread (*this, boost::bind (&Session::add_processor, this, _1));
+       AutomationList::AutomationListCreated.connect_same_thread (*this, boost::bind (&Session::add_automation_list, this, _1));
+       Controllable::Destroyed.connect_same_thread (*this, boost::bind (&Session::remove_controllable, this, _1));
+       IO::PortCountChanged.connect_same_thread (*this, boost::bind (&Session::ensure_buffers, this, _1));
 
        /* stop IO objects from doing stuff until we're ready for them */
 
@@ -332,15 +327,15 @@ Session::second_stage_init (bool new_session)
        _state_of_the_state = StateOfTheState (_state_of_the_state|CannotSave|Loading);
 
 
-       _locations.changed.connect (mem_fun (this, &Session::locations_changed));
-       _locations.added.connect (mem_fun (this, &Session::locations_added));
+       _locations.changed.connect_same_thread (*this, boost::bind (&Session::locations_changed, this));
+       _locations.added.connect_same_thread (*this, boost::bind (&Session::locations_added, this, _1));
        setup_click_sounds (0);
        setup_midi_control ();
 
        /* Pay attention ... */
 
-       _engine.Halted.connect (mem_fun (*this, &Session::engine_halted));
-       _engine.Xrun.connect (mem_fun (*this, &Session::xrun_recovery));
+       _engine.Halted.connect_same_thread (*this, boost::bind (&Session::engine_halted, this));
+       _engine.Xrun.connect_same_thread (*this, boost::bind (&Session::xrun_recovery, this));
 
        try {
                when_engine_running();
@@ -364,14 +359,14 @@ Session::second_stage_init (bool new_session)
        deliver_mmc (MIDI::MachineControl::cmdMmcReset, 0);
        deliver_mmc (MIDI::MachineControl::cmdLocate, 0);
 
-       MidiClockTicker::instance().set_session(*this);
-       MIDI::Name::MidiPatchManager::instance().set_session(*this);
+       MidiClockTicker::instance().set_session (this);
+       MIDI::Name::MidiPatchManager::instance().set_session (this);
 
        /* initial program change will be delivered later; see ::config_changed() */
 
        BootMessage (_("Reset Control Protocols"));
 
-       ControlProtocolManager::instance().set_session (*this);
+       ControlProtocolManager::instance().set_session (this);
 
        config.set_end_marker_is_free (new_session);
 
@@ -792,7 +787,7 @@ Session::load_state (string snapshot_name)
 
                /* there is pending state from a crashed capture attempt */
 
-               if (AskAboutPendingState()) {
+               if (*AskAboutPendingState()) {
                        state_was_pending = true;
                }
        }
@@ -1062,7 +1057,7 @@ Session::state(bool full_state)
                }
        }
 
-       playlists.add_state (node, full_state);
+       playlists->add_state (node, full_state);
 
        child = node->add_child ("RouteGroups");
        for (list<RouteGroup *>::iterator i = _route_groups.begin(); i != _route_groups.end(); ++i) {
@@ -1129,7 +1124,7 @@ Session::set_state (const XMLNode& node, int version)
                _nominal_frame_rate = atoi (prop->value());
 
                if (_nominal_frame_rate != _current_frame_rate) {
-                       if (AskAboutSampleRateMismatch (_nominal_frame_rate, _current_frame_rate)) {
+                       if (*AskAboutSampleRateMismatch (_nominal_frame_rate, _current_frame_rate)) {
                                return -1;
                        }
                }
@@ -1246,13 +1241,13 @@ Session::set_state (const XMLNode& node, int version)
        if ((child = find_named_node (node, "Playlists")) == 0) {
                error << _("Session: XML state has no playlists section") << endmsg;
                goto out;
-       } else if (playlists.load (*this, *child)) {
+       } else if (playlists->load (*this, *child)) {
                goto out;
        }
 
        if ((child = find_named_node (node, "UnusedPlaylists")) == 0) {
                // this is OK
-       } else if (playlists.load_unused (*this, *child)) {
+       } else if (playlists->load_unused (*this, *child)) {
                goto out;
        }
        
@@ -1281,6 +1276,20 @@ Session::set_state (const XMLNode& node, int version)
                }
        }
        
+       if ((child = find_named_node (node, "TempoMap")) == 0) {
+               error << _("Session: XML state has no Tempo Map section") << endmsg;
+               goto out;
+       } else if (_tempo_map->set_state (*child, version)) {
+               goto out;
+       }
+
+       if ((child = find_named_node (node, "Routes")) == 0) {
+               error << _("Session: XML state has no routes section") << endmsg;
+               goto out;
+       } else if (load_routes (*child, version)) {
+               goto out;
+       }
+
        if (version >= 3000) {
                
                if ((child = find_named_node (node, "RouteGroups")) == 0) {
@@ -1307,20 +1316,6 @@ Session::set_state (const XMLNode& node, int version)
                }
        }
 
-       if ((child = find_named_node (node, "TempoMap")) == 0) {
-               error << _("Session: XML state has no Tempo Map section") << endmsg;
-               goto out;
-       } else if (_tempo_map->set_state (*child, version)) {
-               goto out;
-       }
-
-       if ((child = find_named_node (node, "Routes")) == 0) {
-               error << _("Session: XML state has no routes section") << endmsg;
-               goto out;
-       } else if (load_routes (*child, version)) {
-               goto out;
-       }
-
        if ((child = find_named_node (node, "Click")) == 0) {
                warning << _("Session: XML state has no click section") << endmsg;
        } else if (_click_io) {
@@ -1382,6 +1377,7 @@ Session::XMLRouteFactory (const XMLNode& node, int version)
 
        DataType type = DataType::AUDIO;
        const XMLProperty* prop = node.property("default-type");
+       boost::shared_ptr<Route> ret;
 
        if (prop) {
                type = DataType(prop->value());
@@ -1392,17 +1388,19 @@ Session::XMLRouteFactory (const XMLNode& node, int version)
        if (has_diskstream) {
                if (type == DataType::AUDIO) {
                        AudioTrack* at = new AudioTrack (*this, node, version);
-                       // boost_debug_shared_ptr_mark_interesting (at, typeid (at).name());
-                       boost::shared_ptr<Route> ret (at);
-                       return ret;
+                       boost_debug_shared_ptr_mark_interesting (at, "Track");
+                       ret.reset (at);
+                       
                } else {
-                       boost::shared_ptr<Route> ret (new MidiTrack (*this, node, version));
-                       return ret;
+                       ret.reset (new MidiTrack (*this, node, version));
                }
        } else {
-               boost::shared_ptr<Route> ret (new Route (*this, node));
-               return ret;
+               Route* rt = new Route (*this, node);
+               boost_debug_shared_ptr_mark_interesting (rt, "Route");
+               ret.reset (rt);
        }
+
+       return ret;
 }
 
 int
@@ -2103,15 +2101,14 @@ Session::remove_route_group (RouteGroup& rg)
        list<RouteGroup*>::iterator i;
 
        if ((i = find (_route_groups.begin(), _route_groups.end(), &rg)) != _route_groups.end()) {
-               (*i)->apply (&Route::drop_route_group, this);
                _route_groups.erase (i);
+               delete &rg;
+
                route_group_removed (); /* EMIT SIGNAL */
        }
 
-       delete &rg;
 }
 
-
 RouteGroup *
 Session::route_group_by_name (string name)
 {
@@ -2125,6 +2122,23 @@ Session::route_group_by_name (string name)
        return 0;
 }
 
+UndoTransaction*
+Session::start_reversible_command (const string& name)
+{
+       UndoTransaction* trans = new UndoTransaction();
+       trans->set_name(name);
+       return trans;
+}
+
+void
+Session::finish_reversible_command (UndoTransaction& ut)
+{
+       struct timeval now;
+       gettimeofday(&now, 0);
+       ut.set_timestamp(now);
+       _history.add (&ut);
+}
+
 void
 Session::begin_reversible_command(const string& name)
 {
@@ -2160,92 +2174,6 @@ Session::commit_reversible_command(Command *cmd)
        _current_trans.pop();
 }
 
-Session::GlobalRouteBooleanState
-Session::get_global_route_boolean (bool (Route::*method)(void) const)
-{
-       GlobalRouteBooleanState s;
-       boost::shared_ptr<RouteList> r = routes.reader ();
-
-       for (RouteList::iterator i = r->begin(); i != r->end(); ++i) {
-               if (!(*i)->is_hidden()) {
-                       RouteBooleanState v;
-
-                       v.first =* i;
-                       Route* r = (*i).get();
-                       v.second = (r->*method)();
-
-                       s.push_back (v);
-               }
-       }
-
-       return s;
-}
-
-Session::GlobalRouteMeterState
-Session::get_global_route_metering ()
-{
-       GlobalRouteMeterState s;
-       boost::shared_ptr<RouteList> r = routes.reader ();
-
-       for (RouteList::iterator i = r->begin(); i != r->end(); ++i) {
-               if (!(*i)->is_hidden()) {
-                       RouteMeterState v;
-
-                       v.first =* i;
-                       v.second = (*i)->meter_point();
-
-                       s.push_back (v);
-               }
-       }
-
-       return s;
-}
-
-void
-Session::set_global_route_metering (GlobalRouteMeterState s, void* arg)
-{
-       for (GlobalRouteMeterState::iterator i = s.begin(); i != s.end(); ++i) {
-
-               boost::shared_ptr<Route> r = (i->first.lock());
-
-               if (r) {
-                       r->set_meter_point (i->second, arg);
-               }
-       }
-}
-
-void
-Session::set_global_route_boolean (GlobalRouteBooleanState s, void (Route::*method)(bool, void*), void* arg)
-{
-       for (GlobalRouteBooleanState::iterator i = s.begin(); i != s.end(); ++i) {
-
-               boost::shared_ptr<Route> r = (i->first.lock());
-
-               if (r) {
-                       Route* rp = r.get();
-                       (rp->*method) (i->second, arg);
-               }
-       }
-}
-
-void
-Session::set_global_mute (GlobalRouteBooleanState s, void* src)
-{
-       set_global_route_boolean (s, &Route::set_mute, src);
-}
-
-void
-Session::set_global_solo (GlobalRouteBooleanState s, void* src)
-{
-       set_global_route_boolean (s, &Route::set_solo, src);
-}
-
-void
-Session::set_global_record_enable (GlobalRouteBooleanState s, void* src)
-{
-       set_global_route_boolean (s, &Route::set_record_enable, src);
-}
-
 static bool
 accept_all_non_peak_files (const string& path, void */*arg*/)
 {
@@ -2360,6 +2288,12 @@ struct RegionCounter {
     RegionCounter() : count (0) {}
 };
 
+int
+Session::ask_about_playlist_deletion (boost::shared_ptr<Playlist> p)
+{
+       return *AskAboutPlaylistDeletion (p);
+}
+
 int
 Session::cleanup_sources (CleanupReport& rep)
 {
@@ -2381,7 +2315,7 @@ Session::cleanup_sources (CleanupReport& rep)
 
        /* step 1: consider deleting all unused playlists */
        
-       if (playlists.maybe_delete_unused (AskAboutPlaylistDeletion)) {
+       if (playlists->maybe_delete_unused (boost::bind (Session::ask_about_playlist_deletion, _1))) {
                ret = 0;
                goto out;
        }
@@ -2402,9 +2336,9 @@ Session::cleanup_sources (CleanupReport& rep)
                   capture files.
                */
 
-               if (!playlists.source_use_count(i->second) && i->second->length(i->second->timeline_position()) > 0) {
+               if (!playlists->source_use_count(i->second) && i->second->length(i->second->timeline_position()) > 0) {
                        dead_sources.push_back (i->second);
-                       i->second->GoingAway();
+                       i->second->drop_references ();
                }
 
                i = tmp;
@@ -2723,8 +2657,7 @@ Session::remove_controllable (Controllable* c)
 
        Glib::Mutex::Lock lm (controllables_lock);
 
-       Controllables::iterator x = controllables.find(
-                boost::shared_ptr<Controllable>(c, null_deleter()));
+       Controllables::iterator x = controllables.find (boost::shared_ptr<Controllable>(c, null_deleter()));
 
        if (x != controllables.end()) {
                controllables.erase (x);
@@ -2745,6 +2678,121 @@ Session::controllable_by_id (const PBD::ID& id)
        return boost::shared_ptr<Controllable>();
 }
 
+boost::shared_ptr<Controllable>
+Session::controllable_by_descriptor (const ControllableDescriptor& desc)
+{
+       boost::shared_ptr<Controllable> c;
+       boost::shared_ptr<Route> r;
+
+       switch (desc.top_level_type()) {
+       case ControllableDescriptor::NamedRoute:
+       {
+               std::string str = desc.top_level_name();
+               if (str == "master") {
+                       r = _master_out;
+               } else if (str == "control" || str == "listen") {
+                       r = _control_out;
+               } else {
+                       r = route_by_name (desc.top_level_name());
+               }
+               break;
+       }
+
+       case ControllableDescriptor::RemoteControlID:
+               r = route_by_remote_id (desc.rid());
+               break;
+       }
+       
+       if (!r) {
+               return c;
+       }
+
+       switch (desc.subtype()) {
+       case ControllableDescriptor::Gain:
+               c = r->gain_control ();
+               break;
+
+       case ControllableDescriptor::Solo:
+               c = r->solo_control();
+               break;
+
+       case ControllableDescriptor::Mute:
+               c = r->mute_control();
+               break;
+
+       case ControllableDescriptor::Recenable:
+       {
+               boost::shared_ptr<Track> t = boost::dynamic_pointer_cast<Track>(r);
+               
+               if (t) {
+                       c = t->rec_enable_control ();
+               }
+               break;
+       }
+
+       case ControllableDescriptor::Pan:
+               /* XXX pan control */
+               break;
+
+       case ControllableDescriptor::Balance:
+               /* XXX simple pan control */
+               break;
+
+       case ControllableDescriptor::PluginParameter:
+       {
+               uint32_t plugin = desc.target (0);
+               uint32_t parameter_index = desc.target (1);
+
+               /* revert to zero based counting */
+               
+               if (plugin > 0) {
+                       --plugin;
+               }
+               
+               if (parameter_index > 0) {
+                       --parameter_index;
+               }
+
+               boost::shared_ptr<Processor> p = r->nth_plugin (plugin);
+               
+               if (p) {
+                       c = boost::dynamic_pointer_cast<ARDOUR::AutomationControl>(
+                               p->data().control(Evoral::Parameter(PluginAutomation, 0, parameter_index)));
+               }
+               break;
+       }
+
+       case ControllableDescriptor::SendGain: 
+       {
+               uint32_t send = desc.target (0);
+
+               /* revert to zero-based counting */
+               
+               if (send > 0) {
+                       --send;
+               }
+               
+               boost::shared_ptr<Processor> p = r->nth_send (send);
+               
+               if (p) {
+                       boost::shared_ptr<Send> s = boost::dynamic_pointer_cast<Send>(p);
+                       boost::shared_ptr<Amp> a = s->amp();
+
+                       if (a) {
+                               c = s->amp()->gain_control();
+                       }
+               }
+               break;
+       }
+
+       default:
+               /* relax and return a null pointer */
+               break;
+       }
+
+       return c;
+}
+
 void
 Session::add_instant_xml (XMLNode& node, bool write_to_config)
 {
@@ -2876,12 +2924,6 @@ Session::restore_history (string snapshot_name)
                                        ut->add_command(c);
                                }
 
-                       } else if (n->name() == X_("GlobalRouteStateCommand")) {
-
-                               if ((c = global_state_command_factory (*n))) {
-                                       ut->add_command (c);
-                               }
-
                        } else if (n->name() == "DeltaCommand") {
                                PBD::ID  id(n->property("midi-source")->value());
                                boost::shared_ptr<MidiSource> midi_source =
@@ -2968,9 +3010,9 @@ Session::config_changed (std::string p, bool ours)
 
        } else if (p == "edit-mode") {
 
-               Glib::Mutex::Lock lm (playlists.lock);
+               Glib::Mutex::Lock lm (playlists->lock);
 
-               for (SessionPlaylists::List::iterator i = playlists.playlists.begin(); i != playlists.playlists.end(); ++i) {
+               for (SessionPlaylists::List::iterator i = playlists->playlists.begin(); i != playlists->playlists.end(); ++i) {
                        (*i)->set_edit_mode (Config->get_edit_mode ());
                }