Merge branch 'master' into windows+cc
[ardour.git] / libs / ardour / session.cc
index 4be42c769ada52882c164d87ace9d8dd120e5001..4b30543cb018021dfd904314d89819926b4a194f 100644 (file)
@@ -258,17 +258,41 @@ Session::Session (AudioEngine &eng,
        , _suspend_timecode_transmission (0)
        ,  _speakers (new Speakers)
        , ignore_route_processor_changes (false)
+       , _midi_ports (0)
+       , _mmc (0)
 {
        uint32_t sr = 0;
 
        pre_engine_init (fullpath);
        
        if (_is_new) {
+               if (ensure_engine (sr)) {
+                       destroy ();
+                       throw failed_constructor ();
+               }
+
                if (create (mix_template, bus_profile)) {
                        destroy ();
                        throw failed_constructor ();
                }
+
+               /* if a mix template was provided, then ::create() will
+                * have copied it into the session and we need to load it
+                * so that we have the state ready for ::set_state()
+                * after the engine is started.
+                *
+                * Note that we do NOT try to get the sample rate from
+                * the template at this time, though doing so would
+                * be easy if we decided this was an appropriate part
+                * of a template.
+                */
+
+               if (!mix_template.empty() && load_state (_current_snapshot_name)) {
+                       throw failed_constructor ();
+               }
+
        } else {
+
                if (load_state (_current_snapshot_name)) {
                        throw failed_constructor ();
                }
@@ -284,11 +308,11 @@ Session::Session (AudioEngine &eng,
                                sr = atoi (prop->value());
                        }
                }
-       }
 
-       if (ensure_engine (sr)) {
-               destroy ();
-               throw failed_constructor ();
+               if (ensure_engine (sr)) {
+                       destroy ();
+                       throw failed_constructor ();
+               }
        }
 
        if (post_engine_init ()) {
@@ -361,6 +385,50 @@ Session::ensure_engine (uint32_t desired_sample_rate)
                return -1;
        }
 
+       return immediately_post_engine ();
+
+}
+
+int
+Session::immediately_post_engine ()
+{
+       /* Do various initializations that should take place directly after we
+        * know that the engine is running, but before we either create a
+        * session or set state for an existing one.
+        */
+        
+       if (how_many_dsp_threads () > 1) {
+               /* For now, only create the graph if we are using >1 DSP threads, as
+                  it is a bit slower than the old code with 1 thread.
+               */
+               _process_graph.reset (new Graph (*this));
+       }
+
+       /* every time we reconnect, recompute worst case output latencies */
+
+       _engine.Running.connect_same_thread (*this, boost::bind (&Session::initialize_latencies, this));
+
+       if (synced_to_engine()) {
+               _engine.transport_stop ();
+       }
+
+       if (config.get_jack_time_master()) {
+               _engine.transport_locate (_transport_frame);
+       }
+
+       try {
+               BootMessage (_("Set up LTC"));
+               setup_ltc ();
+               BootMessage (_("Set up Click"));
+               setup_click ();
+               BootMessage (_("Set up standard connections"));
+               setup_bundles ();
+       }
+
+       catch (failed_constructor& err) {
+               return -1;
+       }
+
        return 0;
 }
 
@@ -474,9 +542,9 @@ Session::destroy ()
        /* not strictly necessary, but doing it here allows the shared_ptr debugging to work */
        playlists.reset ();
 
-       delete _mmc;
-       delete _midi_ports;
-       delete _locations;
+       delete _mmc; _mmc = 0;
+       delete _midi_ports; _midi_ports = 0;
+       delete _locations; _locations = 0;
 
        DEBUG_TRACE (DEBUG::Destruction, "Session::destroy() done\n");
 
@@ -524,14 +592,21 @@ Session::setup_ltc ()
 void
 Session::setup_click ()
 {
-       XMLNode* child = 0;
-
        _clicking = false;
        _click_io.reset (new ClickIO (*this, "click"));
        _click_gain.reset (new Amp (*this));
        _click_gain->activate ();
-       
-       if (state_tree && (child = find_named_node (*state_tree->root(), "Click")) != 0) {
+       if (state_tree) {
+               setup_click_state (*state_tree->root());
+       }
+}
+
+void
+Session::setup_click_state (const XMLNode& node)
+{      
+       const XMLNode* child = 0;
+
+       if ((child = find_named_node (node, "Click")) != 0) {
                
                /* existing state for Click */
                int c = 0;
@@ -683,81 +758,6 @@ Session::setup_bundles ()
 
 }
 
-int
-Session::when_engine_running ()
-{
-       /* every time we reconnect, recompute worst case output latencies */
-
-       _engine.Running.connect_same_thread (*this, boost::bind (&Session::initialize_latencies, this));
-
-       if (synced_to_jack()) {
-               _engine.transport_stop ();
-       }
-
-       if (config.get_jack_time_master()) {
-               _engine.transport_locate (_transport_frame);
-       }
-
-
-       try {
-               BootMessage (_("Set up LTC"));
-               setup_ltc ();
-               BootMessage (_("Set up Click"));
-               setup_click ();
-               BootMessage (_("Set up standard connections"));
-               setup_bundles ();
-       }
-
-       catch (failed_constructor& err) {
-               return -1;
-       }
-
-       BootMessage (_("Setup signal flow and plugins"));
-
-       /* Reset all panners */
-
-       Delivery::reset_panners ();
-
-       /* this will cause the CPM to instantiate any protocols that are in use
-        * (or mandatory), which will pass it this Session, and then call
-        * set_state() on each instantiated protocol to match stored state.
-        */
-
-       ControlProtocolManager::instance().set_session (this);
-
-       /* This must be done after the ControlProtocolManager set_session above,
-          as it will set states for ports which the ControlProtocolManager creates.
-       */
-
-       // XXX set state of MIDI::Port's
-       // MidiPortManager::instance()->set_port_states (Config->midi_port_states ());
-
-       /* And this must be done after the MIDI::Manager::set_port_states as
-        * it will try to make connections whose details are loaded by set_port_states.
-        */
-
-       hookup_io ();
-
-       /* Let control protocols know that we are now all connected, so they
-        * could start talking to surfaces if they want to.
-        */
-
-       ControlProtocolManager::instance().midi_connectivity_established ();
-
-       if (_is_new && !no_auto_connect()) {
-               Glib::Threads::Mutex::Lock lm (AudioEngine::instance()->process_lock());
-               auto_connect_master_bus ();
-       }
-
-       _state_of_the_state = StateOfTheState (_state_of_the_state & ~(CannotSave|Dirty));
-
-        /* update latencies */
-
-        initialize_latencies ();
-
-       return 0;
-}
-
 void
 Session::auto_connect_master_bus ()
 {
@@ -917,14 +917,14 @@ Session::add_monitor_section ()
                        
                        /* Monitor bus is audio only */
 
-                       uint32_t mod = n_physical_outputs.get (DataType::AUDIO);
-                       uint32_t limit = _monitor_out->n_outputs().get (DataType::AUDIO);
                        vector<string> outputs[DataType::num_types];
 
                        for (uint32_t i = 0; i < DataType::num_types; ++i) {
                                _engine.get_physical_outputs (DataType (DataType::Symbol (i)), outputs[i]);
                        }
-                       
+
+                       uint32_t mod = outputs[DataType::AUDIO].size();
+                       uint32_t limit = _monitor_out->n_outputs().get (DataType::AUDIO);
                        
                        if (mod != 0) {
                                
@@ -1428,7 +1428,7 @@ Session::audible_frame () const
                offset = current_block_size;
        }
 
-       if (synced_to_jack()) {
+       if (synced_to_engine()) {
                tf = _engine.transport_frame();
        } else {
                tf = _transport_frame;