projects / ardour.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
reconstruct and use global state commands (mute/solo/rec-enable/meter point)
[ardour.git] / libs / ardour / session_process.cc
diff --git a/libs/ardour/session_process.cc b/libs/ardour/session_process.cc
index 88b111a1fbedb24fd8d1ea25b47065c2e60237b4..06ba4e304ec5ba67cc3c8b5e39ecad4a6c5438d3 100644 (file)
--- a/libs/ardour/session_process.cc
+++ b/libs/ardour/session_process.cc
@@ -44,7 +44,7 @@ using namespace PBD;
 using namespace std;
 
 void
-Session::process (jack_nframes_t nframes)
+Session::process (nframes_t nframes)
 {
        if (synced_to_jack() && waiting_to_start) {
                if ( _engine.transport_state() == AudioEngine::TransportRolling) {
@@ -53,7 +53,7 @@ Session::process (jack_nframes_t nframes)
        }
 
        if (non_realtime_work_pending()) {
-               if (g_atomic_int_get (&butler_should_do_transport_work) == 0) {
+               if (!transport_work_requested ()) {
                        post_transport ();
                } 
        } 
@@ -66,15 +66,16 @@ Session::process (jack_nframes_t nframes)
 void
 Session::prepare_diskstreams ()
 {
-       for (DiskstreamList::iterator i = diskstreams.begin(); i != diskstreams.end(); ++i) {
+       boost::shared_ptr<DiskstreamList> dsl = diskstreams.reader();
+       for (DiskstreamList::iterator i = dsl->begin(); i != dsl->end(); ++i) {
                (*i)->prepare ();
        }
 }
 
 int
-Session::no_roll (jack_nframes_t nframes, jack_nframes_t offset)
+Session::no_roll (nframes_t nframes, nframes_t offset)
 {
-       jack_nframes_t end_frame = _transport_frame + nframes;
+       nframes_t end_frame = _transport_frame + nframes;
        int ret = 0;
        bool declick = get_transport_declick_required();
        boost::shared_ptr<RouteList> r = routes.reader ();
@@ -110,7 +111,7 @@ Session::no_roll (jack_nframes_t nframes, jack_nframes_t offset)
 }
 
 int
-Session::process_routes (jack_nframes_t nframes, jack_nframes_t offset)
+Session::process_routes (nframes_t nframes, nframes_t offset)
 {
        bool record_active;
        int  declick = get_transport_declick_required();
@@ -141,7 +142,8 @@ Session::process_routes (jack_nframes_t nframes, jack_nframes_t offset)
                           call path, so make sure we release any outstanding locks here before we return failure.
                        */
 
-                       for (DiskstreamList::iterator ids = diskstreams.begin(); ids != diskstreams.end(); ++ids) {
+                       boost::shared_ptr<DiskstreamList> dsl = diskstreams.reader();
+                       for (DiskstreamList::iterator ids = dsl->begin(); ids != dsl->end(); ++ids) {
                                (*ids)->recover ();
                        }
 
@@ -154,7 +156,7 @@ Session::process_routes (jack_nframes_t nframes, jack_nframes_t offset)
 }
 
 int
-Session::silent_process_routes (jack_nframes_t nframes, jack_nframes_t offset)
+Session::silent_process_routes (nframes_t nframes, nframes_t offset)
 {
        bool record_active = actively_recording();
        int  declick = get_transport_declick_required();
@@ -181,7 +183,8 @@ Session::silent_process_routes (jack_nframes_t nframes, jack_nframes_t offset)
                           call path, so make sure we release any outstanding locks here before we return failure.
                        */
 
-                       for (DiskstreamList::iterator ids = diskstreams.begin(); ids != diskstreams.end(); ++ids) {
+                       boost::shared_ptr<DiskstreamList> dsl = diskstreams.reader();
+                       for (DiskstreamList::iterator ids = dsl->begin(); ids != dsl->end(); ++ids) {
                                (*ids)->recover ();
                        }
 
@@ -194,13 +197,14 @@ Session::silent_process_routes (jack_nframes_t nframes, jack_nframes_t offset)
 }
 
 void
-Session::commit_diskstreams (jack_nframes_t nframes, bool &needs_butler)
+Session::commit_diskstreams (nframes_t nframes, bool &needs_butler)
 {
        int dret;
        float pworst = 1.0f;
        float cworst = 1.0f;
 
-       for (DiskstreamList::iterator i = diskstreams.begin(); i != diskstreams.end(); ++i) {
+       boost::shared_ptr<DiskstreamList> dsl = diskstreams.reader();
+       for (DiskstreamList::iterator i = dsl->begin(); i != dsl->end(); ++i) {
 
                if ((*i)->hidden()) {
                        continue;
@@ -238,14 +242,14 @@ Session::commit_diskstreams (jack_nframes_t nframes, bool &needs_butler)
 }
 
 void
-Session::process_with_events (jack_nframes_t nframes)
+Session::process_with_events (nframes_t nframes)
 {
        Event* ev;
-       jack_nframes_t this_nframes;
-       jack_nframes_t end_frame;
-       jack_nframes_t offset;
+       nframes_t this_nframes;
+       nframes_t end_frame;
+       nframes_t offset;
        bool session_needs_butler = false;
-       jack_nframes_t stop_limit;
+       nframes_t stop_limit;
        long           frames_moved;
 
        /* make sure the auditioner is silent */
@@ -284,12 +288,10 @@ Session::process_with_events (jack_nframes_t nframes)
        end_frame = _transport_frame + nframes;
 
        {
-               Glib::RWLock::ReaderLock dsm (diskstream_lock, Glib::TRY_LOCK);
-       
                Event* this_event;
                Events::iterator the_next_one;
                
-               if (!dsm.locked() || (post_transport_work & (PostTransportLocate|PostTransportStop))) {
+               if (post_transport_work & (PostTransportLocate|PostTransportStop)) {
                        no_roll (nframes, 0);
                        return;
                }
@@ -361,7 +363,7 @@ Session::process_with_events (jack_nframes_t nframes)
                                nframes -= this_nframes;
                                offset += this_nframes;
                                
-                               frames_moved = (jack_nframes_t) floor (_transport_speed * this_nframes);
+                               frames_moved = (nframes_t) floor (_transport_speed * this_nframes);
                        
                                if (frames_moved < 0) {
                                        decrement_transport_position (-frames_moved);
@@ -408,7 +410,7 @@ Session::process_with_events (jack_nframes_t nframes)
                summon_butler ();
        } 
        
-       if (!_engine.freewheeling() && send_mtc) {
+       if (!_engine.freewheeling() && session_send_mtc) {
                send_midi_time_code_in_another_thread ();
        }
 
@@ -429,7 +431,7 @@ Session::transport_locked () const
 {
        Slave* sl = _slave;
 
-       if (!locate_pending() && ((_slave_type == None) || (sl && sl->ok() && sl->locked()))) {
+       if (!locate_pending() && ((Config->get_slave_source() == None) || (sl && sl->ok() && sl->locked()))) {
                return true;
        }
 
@@ -437,17 +439,17 @@ Session::transport_locked () const
 }
 
 bool
-Session::follow_slave (jack_nframes_t nframes, jack_nframes_t offset)
+Session::follow_slave (nframes_t nframes, nframes_t offset)
 {
        float slave_speed;
-       jack_nframes_t slave_transport_frame;
-       jack_nframes_t this_delta;
+       nframes_t slave_transport_frame;
+       nframes_t this_delta;
        int dir;
        bool starting;
 
        if (!_slave->ok()) {
                stop_transport ();
-               set_slave_source (None, 0);
+               Config->set_slave_source (None);
                goto noroll;
        }
        
@@ -538,9 +540,9 @@ Session::follow_slave (jack_nframes_t nframes, jack_nframes_t offset)
 
                                Location* al = _locations.auto_loop_location();
 
-                               if (al && auto_loop && (slave_transport_frame < al->start() || slave_transport_frame > al->end())) {
+                               if (al && play_loop && (slave_transport_frame < al->start() || slave_transport_frame > al->end())) {
                                        // cancel looping
-                                       request_auto_loop(false);
+                                       request_play_loop(false);
                                }
 
                                if (slave_transport_frame != _transport_frame) {
@@ -560,17 +562,18 @@ Session::follow_slave (jack_nframes_t nframes, jack_nframes_t offset)
                if (slave_state == Waiting) {
 
                        // cerr << "waiting at " << slave_transport_frame << endl;
-                       Glib::RWLock::ReaderLock dsm (diskstream_lock, Glib::TRY_LOCK);
-                               
-                       if (dsm.locked() && slave_transport_frame >= slave_wait_end) {
+                       
+                       if (slave_transport_frame >= slave_wait_end) {
                                // cerr << "\tstart at " << _transport_frame << endl;
 
                                slave_state = Running;
 
                                bool ok = true;
-                               jack_nframes_t frame_delta = slave_transport_frame - _transport_frame;
+                               nframes_t frame_delta = slave_transport_frame - _transport_frame;
+
+                               boost::shared_ptr<DiskstreamList> dsl = diskstreams.reader();
                                
-                               for (DiskstreamList::iterator i = diskstreams.begin(); i != diskstreams.end(); ++i) {
+                               for (DiskstreamList::iterator i = dsl->begin(); i != dsl->end(); ++i) {
                                        if (!(*i)->can_internal_playback_seek (frame_delta)) {
                                                ok = false;
                                                break;
@@ -578,7 +581,7 @@ Session::follow_slave (jack_nframes_t nframes, jack_nframes_t offset)
                                }
 
                                if (ok) {
-                                       for (DiskstreamList::iterator i = diskstreams.begin(); i != diskstreams.end(); ++i) {
+                                       for (DiskstreamList::iterator i = dsl->begin(); i != dsl->end(); ++i) {
                                                (*i)->internal_playback_seek (frame_delta);
                                        }
                                        _transport_frame += frame_delta;
@@ -588,7 +591,7 @@ Session::follow_slave (jack_nframes_t nframes, jack_nframes_t offset)
                                        /* XXX what? */
                                }
 
-                               memset (delta_accumulator, 0, sizeof (jack_nframes_t) * delta_accumulator_size);
+                               memset (delta_accumulator, 0, sizeof (nframes_t) * delta_accumulator_size);
                                average_slave_delta = 0;
                                this_delta = 0;
                        }
@@ -611,7 +614,7 @@ Session::follow_slave (jack_nframes_t nframes, jack_nframes_t offset)
                        // << " tf = " << _transport_frame
                        // << endl;
                        
-                       if (_slave_type == JACK) {
+                       if (Config->get_slave_source() == JACK) {
                                last_stop_frame = _transport_frame;
                        }
 
@@ -659,7 +662,7 @@ Session::follow_slave (jack_nframes_t nframes, jack_nframes_t offset)
                        request_transport_speed (adjusted_speed);
                        
 #if 1
-                       if ((jack_nframes_t) average_slave_delta > _slave->resolution()) {
+                       if ((nframes_t) average_slave_delta > _slave->resolution()) {
                                // cerr << "not locked\n";
                                goto silent_motion;
                        }
@@ -682,12 +685,6 @@ Session::follow_slave (jack_nframes_t nframes, jack_nframes_t offset)
 
                bool need_butler;
                
-               Glib::RWLock::ReaderLock dsm (diskstream_lock, Glib::TRY_LOCK);
-               if (!dsm.locked()) {
-                       goto noroll;
-               }
-
-               
                prepare_diskstreams ();
                silent_process_routes (nframes, offset);
                commit_diskstreams (nframes, need_butler);
@@ -704,7 +701,7 @@ Session::follow_slave (jack_nframes_t nframes, jack_nframes_t offset)
                        increment_transport_position (frames_moved);
                }
                
-               jack_nframes_t stop_limit;
+               nframes_t stop_limit;
                
                if (actively_recording()) {
                        stop_limit = max_frames;
@@ -726,16 +723,15 @@ Session::follow_slave (jack_nframes_t nframes, jack_nframes_t offset)
 }
 
 void
-Session::process_without_events (jack_nframes_t nframes)
+Session::process_without_events (nframes_t nframes)
 {
        bool session_needs_butler = false;
-       jack_nframes_t stop_limit;
+       nframes_t stop_limit;
        long frames_moved;
-       
-       {
-               Glib::RWLock::ReaderLock dsm (diskstream_lock, Glib::TRY_LOCK);
+       nframes_t offset = 0;
 
-               if (!dsm.locked() || (post_transport_work & (PostTransportLocate|PostTransportStop))) {
+       {
+               if (post_transport_work & (PostTransportLocate|PostTransportStop)) {
                        no_roll (nframes, 0);
                        return;
                }
@@ -766,16 +762,20 @@ Session::process_without_events (jack_nframes_t nframes)
                        return;
                } 
 
-               click (_transport_frame, nframes, 0);
+               if (maybe_sync_start (nframes, offset)) {
+                       return;
+               }
+
+               click (_transport_frame, nframes, offset);
 
                prepare_diskstreams ();
        
                frames_moved = (long) floor (_transport_speed * nframes);
 
-               if (process_routes (nframes, 0)) {
-                       no_roll (nframes, 0);
-                       return;
-               }
+               if (process_routes (nframes, offset)) {
+                       no_roll (nframes, offset);
+                       return;
+               }
 
                commit_diskstreams (nframes, session_needs_butler);
 
@@ -784,7 +784,7 @@ Session::process_without_events (jack_nframes_t nframes)
                } else {
                        increment_transport_position (frames_moved);
                }
-               
+
                maybe_stop (stop_limit);
                check_declick_out ();
 
@@ -794,7 +794,7 @@ Session::process_without_events (jack_nframes_t nframes)
                summon_butler ();
        } 
        
-       if (!_engine.freewheeling() && send_mtc) {
+       if (!_engine.freewheeling() && session_send_mtc) {
                send_midi_time_code_in_another_thread ();
        }
 
@@ -802,7 +802,7 @@ Session::process_without_events (jack_nframes_t nframes)
 }              
 
 void
-Session::process_audition (jack_nframes_t nframes)
+Session::process_audition (nframes_t nframes)
 {
        Event* ev;
        boost::shared_ptr<RouteList> r = routes.reader ();
@@ -841,3 +841,31 @@ Session::process_audition (jack_nframes_t nframes)
        }
 }
 
+bool
+Session::maybe_sync_start (nframes_t& nframes, nframes_t& offset)
+{
+       nframes_t sync_offset;
+       
+       if (!waiting_for_sync_offset) {
+               return false;
+       }
+
+       if (_engine.get_sync_offset (sync_offset) && sync_offset < nframes) {
+
+               no_roll (sync_offset, 0);
+               nframes -= sync_offset;
+               offset += sync_offset;
+               waiting_for_sync_offset = false;
+               
+               if (nframes == 0) {
+                       return true; // done
+               }
+               
+       } else {
+               no_roll (nframes, 0);
+               return true; // done
+       }
+
+       return false;
+}
+
Unnamed repository; edit this file 'description' to name the repository.