#include "ardour/butler.h"
#include "ardour/cycle_timer.h"
#include "ardour/debug.h"
+#include "ardour/disk_reader.h"
#include "ardour/graph.h"
#include "ardour/port.h"
#include "ardour/process_thread.h"
(*i)->automation_run (start_frame, nframes);
}
+ _global_locate_pending = locate_pending ();
+
if (_process_graph) {
DEBUG_TRACE(DEBUG::ProcessThreads,"calling graph/process-routes\n");
if (_process_graph->process_routes (nframes, start_frame, end_frame, declick, need_butler) < 0) {
return 0;
}
-/** @param need_butler to be set to true by this method if it needs the butler,
- * otherwise it must be left alone.
- */
-int
-Session::silent_process_routes (pframes_t nframes, bool& need_butler)
-{
- boost::shared_ptr<RouteList> r = routes.reader ();
-
- const framepos_t start_frame = _transport_frame;
- const framepos_t end_frame = _transport_frame + lrintf(nframes * _transport_speed);
-
- VCAList v = _vca_manager->vcas ();
- for (VCAList::const_iterator i = v.begin(); i != v.end(); ++i) {
- (*i)->automation_run (start_frame, nframes);
- }
-
- if (_process_graph) {
- _process_graph->silent_process_routes (nframes, start_frame, end_frame, need_butler);
- } else {
- for (RouteList::iterator i = r->begin(); i != r->end(); ++i) {
-
- int ret;
-
- if ((*i)->is_auditioner()) {
- continue;
- }
-
- bool b = false;
-
- if ((ret = (*i)->silent_roll (nframes, start_frame, end_frame, b)) < 0) {
- stop_transport ();
- return -1;
- }
-
- if (b) {
- need_butler = true;
- }
- }
- }
-
- return 0;
-}
-
void
Session::get_track_statistics ()
{
boost::shared_ptr<Track> tr = boost::dynamic_pointer_cast<Track> (*i);
- if (!tr || tr->hidden()) {
+ if (!tr || tr->is_private_route()) {
continue;
}
}
}
- if (_transport_speed == 1.0) {
- frames_moved = (framecnt_t) nframes;
+ if (locate_pending()) {
+ frames_moved = 0;
} else {
- interpolation.set_target_speed (_target_transport_speed);
- interpolation.set_speed (_transport_speed);
- frames_moved = (framecnt_t) interpolation.interpolate (0, nframes, 0, 0);
+ if (_transport_speed == 1.0) {
+ frames_moved = (framecnt_t) nframes;
+ } else {
+ interpolation.set_target_speed (_target_transport_speed);
+ interpolation.set_speed (_transport_speed);
+ frames_moved = (framecnt_t) interpolation.interpolate (0, nframes, 0, 0);
+ }
}
end_frame = _transport_frame + frames_moved;
while (nframes) {
this_nframes = nframes; /* real (jack) time relative */
- frames_moved = (framecnt_t) floor (_transport_speed * nframes); /* transport relative */
+ if (locate_pending()) {
+ frames_moved = 0;
+ } else {
+ frames_moved = (framecnt_t) floor (_transport_speed * nframes); /* transport relative */
+ }
/* running an event, position transport precisely to its time */
if (this_event && this_event->action_frame <= end_frame && this_event->action_frame >= _transport_frame) {
if (frames_moved < 0) {
decrement_transport_position (-frames_moved);
- } else {
+ } else if (frames_moved) {
increment_transport_position (frames_moved);
}
*/
if (_slave_state == Running) {
- calculate_moving_average_of_slave_delta(dir, this_delta);
+ calculate_moving_average_of_slave_delta(dir, abs(this_delta));
}
}
_slave_state, slave_transport_frame, slave_speed, this_delta, average_slave_delta));
- if (_slave_state == Running && !_slave->is_always_synced() &&
- !(Config->get_timecode_source_is_synced() && (dynamic_cast<TimecodeSlave*>(_slave)) != 0)
- ) {
+ if (_slave_state == Running && !_slave->is_always_synced() && !(Config->get_timecode_source_is_synced() && (dynamic_cast<TimecodeSlave*>(_slave)) != 0)) {
+
+ /* may need to varispeed to sync with slave */
if (_transport_speed != 0.0f) {
slave_speed));
}
-#if 1
- if (!actively_recording() && (framecnt_t) abs(average_slave_delta) > _slave->resolution()) {
- cerr << "average slave delta greater than slave resolution (" << _slave->resolution() << "), going to silent motion\n";
- goto silent_motion;
+ if (!actively_recording() && (framecnt_t) average_slave_delta > _slave->resolution()) {
+ DEBUG_TRACE (DEBUG::Slave, string_compose ("average slave delta %1 greater than slave resolution %2 => silent motion\n", average_slave_delta, _slave->resolution()));
+ /* run routes as normal, but no disk output */
+ DiskReader::set_no_disk_output (true);
+ return true;
+ }
+
+ if (!have_first_delta_accumulator) {
+ DEBUG_TRACE (DEBUG::Slave, "waiting for first slave delta accumulator to be ready\n");
+ /* run routes as normal, but no disk output */
+ DiskReader::set_no_disk_output (true);
+ return true;
}
-#endif
}
}
- if (_slave_state == Running && 0 == (post_transport_work () & ~PostTransportSpeed)) {
+ if (!have_first_delta_accumulator) {
+ DiskReader::set_no_disk_output (true);
+ } else {
+ DiskReader::set_no_disk_output (false);
+ }
+
+ if ((_slave_state == Running) && (0 == (post_transport_work () & ~PostTransportSpeed))) {
/* speed is set, we're locked, and good to go */
return true;
}
- silent_motion:
- DEBUG_TRACE (DEBUG::Slave, "silent motion\n")
- follow_slave_silently (nframes, slave_speed);
-
noroll:
/* don't move at all */
DEBUG_TRACE (DEBUG::Slave, "no roll\n")
average_slave_delta /= (int32_t) delta_accumulator_size;
if (average_slave_delta < 0L) {
average_dir = -1;
- average_slave_delta = abs(average_slave_delta);
+ average_slave_delta = average_slave_delta;
} else {
average_dir = 1;
}
}
}
-void
-Session::follow_slave_silently (pframes_t nframes, float slave_speed)
-{
- if (slave_speed && _transport_speed) {
-
- /* something isn't right, but we should move with the master
- for now.
- */
-
- bool need_butler = false;
-
- silent_process_routes (nframes, need_butler);
-
- get_track_statistics ();
-
- if (need_butler) {
- DEBUG_TRACE (DEBUG::Butler, "f-slave-silently: session needs butler, call it\n");
- _butler->summon ();
- }
-
- int32_t frames_moved = (int32_t) floor (_transport_speed * nframes);
-
- if (frames_moved < 0) {
- decrement_transport_position (-frames_moved);
- } else {
- increment_transport_position (frames_moved);
- }
-
- framepos_t const stop_limit = compute_stop_limit ();
- maybe_stop (stop_limit);
- }
-}
-
void
Session::process_without_events (pframes_t nframes)
{
}
if (_transport_speed == 0) {
- fail_roll (nframes);
+ no_roll (nframes);
return;
}
- if (_transport_speed == 1.0) {
- frames_moved = (framecnt_t) nframes;
+ if (locate_pending()) {
+ frames_moved = 0;
} else {
- interpolation.set_target_speed (_target_transport_speed);
- interpolation.set_speed (_transport_speed);
- frames_moved = (framecnt_t) interpolation.interpolate (0, nframes, 0, 0);
+ if (_transport_speed == 1.0) {
+ frames_moved = (framecnt_t) nframes;
+ } else {
+ interpolation.set_target_speed (_target_transport_speed);
+ interpolation.set_speed (_transport_speed);
+ frames_moved = (framecnt_t) interpolation.interpolate (0, nframes, 0, 0);
+ }
}
if (!_exporting && !timecode_transmission_suspended()) {
framepos_t const stop_limit = compute_stop_limit ();
if (maybe_stop (stop_limit)) {
- fail_roll (nframes);
+ no_roll (nframes);
return;
}
if (frames_moved < 0) {
decrement_transport_position (-frames_moved);
- } else {
+ } else if (frames_moved) {
increment_transport_position (frames_moved);
}
ev->region.reset ();
break;
- case SessionEvent::InputConfigurationChange:
- add_post_transport_work (PostTransportInputChange);
- _butler->schedule_transport_work ();
- break;
-
case SessionEvent::SetPlayAudioRange:
set_play_range (ev->audio_range, (ev->speed == 1.0f));
break;
projects / ardour.git / blobdiff