- int32_t ret = 0;
- jack_nframes_t to_read;
- RingBufferNPT<Sample>::rw_vector vector;
- bool free_mixdown;
- bool free_gain;
- bool free_workbuf;
- bool reversed = (_visible_speed * _session.transport_speed()) < 0.0f;
- jack_nframes_t total_space;
- jack_nframes_t zero_fill;
- uint32_t chan_n;
- ChannelList::iterator i;
- jack_nframes_t ts;
-
- channels.front().playback_buf->get_write_vector (&vector);
-
- if ((total_space = vector.len[0] + vector.len[1]) == 0) {
- return 0;
- }
-
- /* if there are 2+ chunks of disk i/o possible for
- this track, let the caller know so that it can arrange
- for us to be called again, ASAP.
- */
-
- if (total_space >= (_slaved?3:2) * disk_io_chunk_frames) {
- ret = 1;
- }
-
- /* if we're running close to normal speed and there isn't enough
- space to do disk_io_chunk_frames of I/O, then don't bother.
-
- at higher speeds, just do it because the sync between butler
- and audio thread may not be good enough.
- */
-
- if ((total_space < disk_io_chunk_frames) && fabs (_actual_speed) < 2.0f) {
- return 0;
- }
-
- /* when slaved, don't try to get too close to the read pointer. this
- leaves space for the buffer reversal to have something useful to
- work with.
- */
-
- if (_slaved && total_space < (channels.front().playback_buf->bufsize() / 2)) {
- return 0;
- }
-
- total_space = min (disk_io_chunk_frames, total_space);
-
- if (reversed) {
-
- if (file_frame == 0) {
-
- /* at start: nothing to do but fill with silence */
-
- for (chan_n = 0, i = channels.begin(); i != channels.end(); ++i, ++chan_n) {
-
- ChannelInfo& chan (*i);
- chan.playback_buf->get_write_vector (&vector);
- memset (vector.buf[0], 0, sizeof(Sample) * vector.len[0]);
- if (vector.len[1]) {
- memset (vector.buf[1], 0, sizeof(Sample) * vector.len[1]);
- }
- chan.playback_buf->increment_write_ptr (vector.len[0] + vector.len[1]);
- }
- return 0;
- }
-
- if (file_frame < total_space) {
-
- /* too close to the start: read what we can,
- and then zero fill the rest
- */
-
- zero_fill = total_space - file_frame;
- total_space = file_frame;
- file_frame = 0;
-
- } else {
-
- /* move read position backwards because we are going
- to reverse the data.
- */
-
- file_frame -= total_space;
- zero_fill = 0;
- }
-
- } else {
-
- if (file_frame == max_frames) {
-
- /* at end: nothing to do but fill with silence */
-
- for (chan_n = 0, i = channels.begin(); i != channels.end(); ++i, ++chan_n) {
-
- ChannelInfo& chan (*i);
- chan.playback_buf->get_write_vector (&vector);
- memset (vector.buf[0], 0, sizeof(Sample) * vector.len[0]);
- if (vector.len[1]) {
- memset (vector.buf[1], 0, sizeof(Sample) * vector.len[1]);
- }
- chan.playback_buf->increment_write_ptr (vector.len[0] + vector.len[1]);
- }
- return 0;
- }
-
- if (file_frame > max_frames - total_space) {
-
- /* to close to the end: read what we can, and zero fill the rest */
-
- zero_fill = total_space - (max_frames - file_frame);
- total_space = max_frames - file_frame;
-
- } else {
- zero_fill = 0;
- }
- }
-
- /* Please note: the code to allocate buffers isn't run
- during normal butler thread operation. Its there
- for other times when we need to call do_refill()
- from somewhere other than the butler thread.
- */
-
- if (mixdown_buffer == 0) {
- mixdown_buffer = new Sample[disk_io_chunk_frames];
- free_mixdown = true;
- } else {
- free_mixdown = false;
- }
-
- if (gain_buffer == 0) {
- gain_buffer = new float[disk_io_chunk_frames];
- free_gain = true;
- } else {
- free_gain = false;
- }
-
- if (workbuf == 0) {
- workbuf = new char[disk_io_chunk_frames * 4];
- free_workbuf = true;
- } else {
- free_workbuf = false;
- }
-
- jack_nframes_t file_frame_tmp = 0;
-
- for (chan_n = 0, i = channels.begin(); i != channels.end(); ++i, ++chan_n) {
-
- ChannelInfo& chan (*i);
- Sample* buf1;
- Sample* buf2;
- jack_nframes_t len1, len2;
-
- chan.playback_buf->get_write_vector (&vector);
-
- ts = total_space;
- file_frame_tmp = file_frame;
-
- if (reversed) {
- buf1 = vector.buf[1];
- len1 = vector.len[1];
- buf2 = vector.buf[0];
- len2 = vector.len[0];
- } else {
- buf1 = vector.buf[0];
- len1 = vector.len[0];
- buf2 = vector.buf[1];
- len2 = vector.len[1];
- }
-
-
- to_read = min (ts, len1);
- to_read = min (to_read, disk_io_chunk_frames);
-
- if (to_read) {
-
- if (read (buf1, mixdown_buffer, gain_buffer, workbuf, file_frame_tmp, to_read, chan, chan_n, reversed)) {
- ret = -1;
- goto out;
- }
-
- chan.playback_buf->increment_write_ptr (to_read);
- ts -= to_read;
- }
-
- to_read = min (ts, len2);
-
- if (to_read) {
-
-
- /* we read all of vector.len[0], but it wasn't an entire disk_io_chunk_frames of data,
- so read some or all of vector.len[1] as well.
- */
-
- if (read (buf2, mixdown_buffer, gain_buffer, workbuf, file_frame_tmp, to_read, chan, chan_n, reversed)) {
- ret = -1;
- goto out;
- }
-
- chan.playback_buf->increment_write_ptr (to_read);
- }
-
- if (zero_fill) {
- /* do something */
- }
-
- }
-
- file_frame = file_frame_tmp;
-
- out:
- if (free_mixdown) {
- delete [] mixdown_buffer;
- }
- if (free_gain) {
- delete [] gain_buffer;
- }
- if (free_workbuf) {
- delete [] workbuf;
- }
-
- return ret;
-}
-
-int
-DiskStream::do_flush (char * workbuf, bool force_flush)
-{
- uint32_t to_write;
- int32_t ret = 0;
- RingBufferNPT<Sample>::rw_vector vector;
- RingBufferNPT<CaptureTransition>::rw_vector transvec;
- jack_nframes_t total;
-
- /* important note: this function will write *AT MOST*
- disk_io_chunk_frames of data to disk. it will never
- write more than that. if its writes that much and there
- is more than that waiting to be written, it will return 1,
- otherwise 0 on success or -1 on failure.
-
- if there is less than disk_io_chunk_frames to be written,
- no data will be written at all unless `force_flush' is true.
- */
-
- _write_data_count = 0;
-
- for (ChannelList::iterator chan = channels.begin(); chan != channels.end(); ++chan) {
-
- (*chan).capture_buf->get_read_vector (&vector);
-
- total = vector.len[0] + vector.len[1];
-
-
- if (total == 0 || (total < disk_io_chunk_frames && !force_flush && was_recording)) {
- goto out;
- }
-
-
- /* if there are 2+ chunks of disk i/o possible for
- this track, let the caller know so that it can arrange
- for us to be called again, ASAP.
-
- if we are forcing a flush, then if there is* any* extra
- work, let the caller know.
-
- if we are no longer recording and there is any extra work,
- let the caller know too.
- */
-
- if (total >= 2 * disk_io_chunk_frames || ((force_flush || !was_recording) && total > disk_io_chunk_frames)) {
- ret = 1;
- }
-
- to_write = min (disk_io_chunk_frames, (jack_nframes_t) vector.len[0]);
-
-
- // check the transition buffer when recording destructive
- // important that we get this after the capture buf
-
- if (destructive()) {
- (*chan).capture_transition_buf->get_read_vector(&transvec);
- size_t transcount = transvec.len[0] + transvec.len[1];
- bool have_start = false;
- size_t ti;
-
- for (ti=0; ti < transcount; ++ti) {
- CaptureTransition & captrans = (ti < transvec.len[0]) ? transvec.buf[0][ti] : transvec.buf[1][ti-transvec.len[0]];
-
- if (captrans.type == CaptureStart) {
- // by definition, the first data we got above represents the given capture pos
-
- (*chan).write_source->mark_capture_start (captrans.capture_val);
- (*chan).curr_capture_cnt = 0;
-
- have_start = true;
- }
- else if (captrans.type == CaptureEnd) {
-
- // capture end, the capture_val represents total frames in capture
-
- if (captrans.capture_val <= (*chan).curr_capture_cnt + to_write) {
-
- // shorten to make the write a perfect fit
- uint32_t nto_write = (captrans.capture_val - (*chan).curr_capture_cnt);
-
- if (nto_write < to_write) {
- ret = 1; // should we?
- }
- to_write = nto_write;
-
- (*chan).write_source->mark_capture_end ();
-
- // increment past this transition, but go no further
- ++ti;
- break;
- }
- else {
- // actually ends just beyond this chunk, so force more work
- ret = 1;
- break;
- }
- }
- }
-
- if (ti > 0) {
- (*chan).capture_transition_buf->increment_read_ptr(ti);
- }
- }
-
-
-
- if ((!(*chan).write_source) || (*chan).write_source->write (vector.buf[0], to_write, workbuf) != to_write) {
- error << string_compose(_("DiskStream %1: cannot write to disk"), _id) << endmsg;
- return -1;
- }
-
- (*chan).capture_buf->increment_read_ptr (to_write);
- (*chan).curr_capture_cnt += to_write;
-
- if ((to_write == vector.len[0]) && (total > to_write) && (to_write < disk_io_chunk_frames) && !destructive()) {
-
- /* we wrote all of vector.len[0] but it wasn't an entire
- disk_io_chunk_frames of data, so arrange for some part
- of vector.len[1] to be flushed to disk as well.
- */
-
- to_write = min ((jack_nframes_t)(disk_io_chunk_frames - to_write), (jack_nframes_t) vector.len[1]);
-
- if ((*chan).write_source->write (vector.buf[1], to_write, workbuf) != to_write) {
- error << string_compose(_("DiskStream %1: cannot write to disk"), _id) << endmsg;
- return -1;
- }
-
- _write_data_count += (*chan).write_source->write_data_count();
-
- (*chan).capture_buf->increment_read_ptr (to_write);
- (*chan).curr_capture_cnt += to_write;
- }
- }
-
- out:
- return ret;
-}
-
-void
-DiskStream::playlist_changed (Change ignored)
-{
- playlist_modified ();
-}
-
-void
-DiskStream::playlist_modified ()
-{
- if (!i_am_the_modifier && !overwrite_queued) {
- _session.request_overwrite_buffer (this);
- overwrite_queued = true;
- }
-}
-
-void
-DiskStream::transport_stopped (struct tm& when, time_t twhen, bool abort_capture)
-{
- uint32_t buffer_position;
- bool more_work = true;
- int err = 0;
- AudioRegion* region = 0;
- jack_nframes_t total_capture;
- AudioRegion::SourceList srcs;
- AudioRegion::SourceList::iterator src;
- ChannelList::iterator chan;
- vector<CaptureInfo*>::iterator ci;
- uint32_t n = 0;
- list<Source*>* deletion_list;
- bool mark_write_completed = false;
-
- finish_capture (true);
-
- /* butler is already stopped, but there may be work to do
- to flush remaining data to disk.
- */
-
- while (more_work && !err) {
- switch (do_flush ( _session.conversion_buffer(Session::TransportContext), true)) {
- case 0:
- more_work = false;
- break;
- case 1:
- break;
- case -1:
- error << string_compose(_("DiskStream \"%1\": cannot flush captured data to disk!"), _name) << endmsg;
- err++;
- }
- }
-
- /* XXX is there anything we can do if err != 0 ? */
- LockMonitor lm (capture_info_lock, __LINE__, __FILE__);
-
- if (capture_info.empty()) {
- return;
- }
-
- if (abort_capture) {
-
- ChannelList::iterator chan;
-
- deletion_list = new list<Source*>;
-
- for ( chan = channels.begin(); chan != channels.end(); ++chan) {
-
- if ((*chan).write_source) {
-
- (*chan).write_source->mark_for_remove ();
- (*chan).write_source->release ();
-
- deletion_list->push_back ((*chan).write_source);
-
- (*chan).write_source = 0;
- }
-
- /* new source set up in "out" below */
- }
-
- if (!deletion_list->empty()) {
- DeleteSources (deletion_list);
- } else {
- delete deletion_list;
- }
-
- goto out;
- }
-
- for (total_capture = 0, ci = capture_info.begin(); ci != capture_info.end(); ++ci) {
- total_capture += (*ci)->frames;
- }
-
- /* figure out the name for this take */
-
- for (n = 0, chan = channels.begin(); chan != channels.end(); ++chan, ++n) {
-
- Source* s = (*chan).write_source;
-
- if (s) {
-
- FileSource* fsrc;
-
- srcs.push_back (s);
-
- if ((fsrc = dynamic_cast<FileSource *>(s)) != 0) {
- fsrc->update_header (capture_info.front()->start, when, twhen);
- }
-
- s->set_captured_for (_name);
-
- }
- }
-
- /* destructive tracks have a single, never changing region */
-
- if (destructive()) {
-
- /* send a signal that any UI can pick up to do the right thing. there is
- a small problem here in that a UI may need the peak data to be ready
- for the data that was recorded and this isn't interlocked with that
- process. this problem is deferred to the UI.
- */
-
- _playlist->Modified();
-
- } else {
-
- /* Register a new region with the Session that
- describes the entire source. Do this first
- so that any sub-regions will obviously be
- children of this one (later!)
- */
-
- try {
- region = new AudioRegion (srcs, channels[0].write_source->last_capture_start_frame(), total_capture,
- region_name_from_path (channels[0].write_source->name()),
- 0, AudioRegion::Flag (AudioRegion::DefaultFlags|AudioRegion::Automatic|AudioRegion::WholeFile));
-
- region->special_set_position (capture_info.front()->start);
- }
-
-
- catch (failed_constructor& err) {
- error << string_compose(_("%1: could not create region for complete audio file"), _name) << endmsg;
- /* XXX what now? */
- }
-
- _last_capture_regions.push_back (region);
-
- // cerr << _name << ": there are " << capture_info.size() << " capture_info records\n";
-
- _session.add_undo (_playlist->get_memento());
- _playlist->freeze ();
-
- for (buffer_position = channels[0].write_source->last_capture_start_frame(), ci = capture_info.begin(); ci != capture_info.end(); ++ci) {
-
- string region_name;
- _session.region_name (region_name, _name, false);
-
- // cerr << _name << ": based on ci of " << (*ci)->start << " for " << (*ci)->frames << " add a region\n";
-
- try {
- region = new AudioRegion (srcs, buffer_position, (*ci)->frames, region_name);
- }
-
- catch (failed_constructor& err) {
- error << _("DiskStream: could not create region for captured audio!") << endmsg;
- continue; /* XXX is this OK? */
- }
-
- _last_capture_regions.push_back (region);
-
- // cerr << "add new region, buffer position = " << buffer_position << " @ " << (*ci)->start << endl;
-
- i_am_the_modifier++;
- _playlist->add_region (*region, (*ci)->start);
- i_am_the_modifier--;
-
- buffer_position += (*ci)->frames;
- }
-
- _playlist->thaw ();
- _session.add_redo_no_execute (_playlist->get_memento());
- }
-
- mark_write_completed = true;
-
- reset_write_sources (mark_write_completed);
-
- out:
- for (ci = capture_info.begin(); ci != capture_info.end(); ++ci) {
- delete *ci;
- }
-
- capture_info.clear ();
- capture_start_frame = 0;
-}
-
-void
-DiskStream::finish_capture (bool rec_monitors_input)
-{
- was_recording = false;
-
- if (capture_captured == 0) {
- return;
- }
-
- if (recordable() && destructive()) {
- for (ChannelList::iterator chan = channels.begin(); chan != channels.end(); ++chan) {
-
- RingBufferNPT<CaptureTransition>::rw_vector transvec;
- (*chan).capture_transition_buf->get_write_vector(&transvec);
-
-
- if (transvec.len[0] > 0) {
- transvec.buf[0]->type = CaptureEnd;
- transvec.buf[0]->capture_val = capture_captured;
- (*chan).capture_transition_buf->increment_write_ptr(1);
- }
- else {
- // bad!
- fatal << string_compose (_("programmer error: %1"), X_("capture_transition_buf is full when stopping record! inconceivable!")) << endmsg;
- }
- }
- }
-
-
- CaptureInfo* ci = new CaptureInfo;
-
- ci->start = capture_start_frame;
- ci->frames = capture_captured;
-
- /* XXX theoretical race condition here. Need atomic exchange ?
- However, the circumstances when this is called right
- now (either on record-disable or transport_stopped)
- mean that no actual race exists. I think ...
- We now have a capture_info_lock, but it is only to be used
- to synchronize in the transport_stop and the capture info
- accessors, so that invalidation will not occur (both non-realtime).
- */
-
- // cerr << "Finish capture, add new CI, " << ci->start << '+' << ci->frames << endl;
-
- capture_info.push_back (ci);
- capture_captured = 0;
-}
-
-void
-DiskStream::set_record_enabled (bool yn, void* src)
-{
- bool rolling = _session.transport_speed() != 0.0f;
-
- if (!recordable() || !_session.record_enabling_legal()) {
- return;
- }
-
- /* if we're turning on rec-enable, there needs to be an
- input connection.
- */
-
- if (yn && channels[0].source == 0) {
-
- /* pick up connections not initiated *from* the IO object
- we're associated with.
- */
-
- get_input_sources ();
-
- if (channels[0].source == 0) {
-
- if (yn) {
- CannotRecordNoInput (this); /* emit signal */
- }
- return;
- }
- }
-
- /* yes, i know that this not proof against race conditions, but its
- good enough. i think.
- */
-
- if (record_enabled() != yn) {
- if (yn) {
- atomic_set (&_record_enabled, 1);
- capturing_sources.clear ();
- if (Config->get_use_hardware_monitoring()) {
- for (ChannelList::iterator chan = channels.begin(); chan != channels.end(); ++chan) {
- if ((*chan).source) {
- (*chan).source->request_monitor_input (!(_session.get_auto_input() && rolling));
- }
- capturing_sources.push_back ((*chan).write_source);
- }
- } else {
- for (ChannelList::iterator chan = channels.begin(); chan != channels.end(); ++chan) {
- capturing_sources.push_back ((*chan).write_source);
- }
- }
-
- } else {
- atomic_set (&_record_enabled, 0);
- if (Config->get_use_hardware_monitoring()) {
- for (ChannelList::iterator chan = channels.begin(); chan != channels.end(); ++chan) {
- if ((*chan).source) {
- (*chan).source->request_monitor_input (false);
- }
- }
- }
- capturing_sources.clear ();
- }
-
- record_enable_changed (src); /* EMIT SIGNAL */
- }
-}
-
-XMLNode&
-DiskStream::get_state ()
-{
- XMLNode* node = new XMLNode ("DiskStream");
- char buf[64];
- LocaleGuard lg (X_("POSIX"));
-
- snprintf (buf, sizeof(buf), "%zd", channels.size());
- node->add_property ("channels", buf);
-
- node->add_property ("playlist", _playlist->name());
-
- snprintf (buf, sizeof(buf), "%f", _visible_speed);
- node->add_property ("speed", buf);
-
- node->add_property("name", _name);
- snprintf (buf, sizeof(buf), "%" PRIu64, id());
- node->add_property("id", buf);
-
- if (!capturing_sources.empty() && _session.get_record_enabled()) {
-
- XMLNode* cs_child = new XMLNode (X_("CapturingSources"));
- XMLNode* cs_grandchild;
-
- for (vector<FileSource*>::iterator i = capturing_sources.begin(); i != capturing_sources.end(); ++i) {
- cs_grandchild = new XMLNode (X_("file"));
- cs_grandchild->add_property (X_("path"), (*i)->path());
- cs_child->add_child_nocopy (*cs_grandchild);
- }
-
- /* store the location where capture will start */
-
- Location* pi;
-
- if (_session.get_punch_in() && ((pi = _session.locations()->auto_punch_location()) != 0)) {
- snprintf (buf, sizeof (buf), "%" PRIu32, pi->start());
- } else {
- snprintf (buf, sizeof (buf), "%" PRIu32, _session.transport_frame());
- }
-
- cs_child->add_property (X_("at"), buf);
- node->add_child_nocopy (*cs_child);
- }
-
- if (_extra_xml) {
- node->add_child_copy (*_extra_xml);
- }
-
- return* node;
-}
-
-int
-DiskStream::set_state (const XMLNode& node)
-{
- const XMLProperty* prop;
- XMLNodeList nlist = node.children();
- XMLNodeIterator niter;
- uint32_t nchans = 1;
- XMLNode* capture_pending_node = 0;
- LocaleGuard lg (X_("POSIX"));
-
- in_set_state = true;
-
- for (niter = nlist.begin(); niter != nlist.end(); ++niter) {
- if ((*niter)->name() == IO::state_node_name) {
- deprecated_io_node = new XMLNode (**niter);
- }
-
- if ((*niter)->name() == X_("CapturingSources")) {
- capture_pending_node = *niter;
- }
- }
-
- /* prevent write sources from being created */
-
- in_set_state = true;
-
- if ((prop = node.property ("name")) != 0) {
- _name = prop->value();
- }
-
- if (deprecated_io_node) {
- if ((prop = deprecated_io_node->property ("id")) != 0) {
- sscanf (prop->value().c_str(), "%" PRIu64, &_id);
- }
- } else {
- if ((prop = node.property ("id")) != 0) {
- sscanf (prop->value().c_str(), "%" PRIu64, &_id);
- }
- }
-
- if ((prop = node.property ("channels")) != 0) {
- nchans = atoi (prop->value().c_str());
- }
-
- // create necessary extra channels
- // we are always constructed with one
- // and we always need one
-
- if (nchans > _n_channels) {
-
- // we need to add new channel infos
- //LockMonitor lm (state_lock, __LINE__, __FILE__);
-
- int diff = nchans - channels.size();
-
- for (int i=0; i < diff; ++i) {
- add_channel ();
- }
-
- } else if (nchans < _n_channels) {
-
- // we need to get rid of channels
- //LockMonitor lm (state_lock, __LINE__, __FILE__);
-
- int diff = channels.size() - nchans;
-
- for (int i = 0; i < diff; ++i) {
- remove_channel ();
- }
- }
-
- if ((prop = node.property ("playlist")) == 0) {
- return -1;
- }
-
- {
- bool had_playlist = (_playlist != 0);
-
- if (find_and_use_playlist (prop->value())) {
- return -1;
- }
-
- if (!had_playlist) {
- _playlist->set_orig_diskstream_id (_id);
- }
-
- if (capture_pending_node) {
- use_pending_capture_data (*capture_pending_node);
- }
-
- }
-
- if ((prop = node.property ("speed")) != 0) {
- double sp = atof (prop->value().c_str());
-
- if (realtime_set_speed (sp, false)) {
- non_realtime_set_speed ();
- }
- }
-
- _n_channels = channels.size();
-
- in_set_state = false;
-
- /* make sure this is clear before we do anything else */
-
- capturing_sources.clear ();
-
- /* write sources are handled elsewhere;
- for destructive tracks: in {setup,use}_destructive_playlist()
- for non-destructive: when we handle the input set up of the IO that owns this DS
- */
-
- in_set_state = false;
-
- return 0;
-}
-
-int
-DiskStream::use_new_write_source (uint32_t n)
-{
- if (!recordable()) {
- return 1;
- }
-
- if (n >= channels.size()) {
- error << string_compose (_("DiskStream: channel %1 out of range"), n) << endmsg;
- return -1;
- }
-
- ChannelInfo &chan = channels[n];
-
- if (chan.write_source) {
-
- if (FileSource::is_empty (chan.write_source->path())) {
- chan.write_source->mark_for_remove ();
- chan.write_source->release();
- delete chan.write_source;
- } else {
- chan.write_source->release();
- chan.write_source = 0;
- }
- }
-
- try {
- if ((chan.write_source = _session.create_file_source (*this, n, destructive())) == 0) {
- throw failed_constructor();
- }
- }
-
- catch (failed_constructor &err) {
- error << string_compose (_("%1:%2 new capture file not initialized correctly"), _name, n) << endmsg;
- chan.write_source = 0;
- return -1;
- }
-
- chan.write_source->use ();
-
- return 0;
-}
-
-void
-DiskStream::reset_write_sources (bool mark_write_complete, bool force)
-{
- ChannelList::iterator chan;
- uint32_t n;
-
- if (!recordable()) {
- return;
- }
-
- if (!force && destructive()) {
-
- /* make sure we always have enough sources for the current channel count */
-
- for (chan = channels.begin(), n = 0; chan != channels.end(); ++chan, ++n) {
- if ((*chan).write_source == 0) {
- break;
- }
- }
-
- if (chan == channels.end()) {
- return;
- }
-
- /* some channels do not have a write source */
- }
-
- capturing_sources.clear ();
-
- for (chan = channels.begin(), n = 0; chan != channels.end(); ++chan, ++n) {
- if ((*chan).write_source && mark_write_complete) {
- (*chan).write_source->mark_streaming_write_completed ();
- }
- use_new_write_source (n);
- if (record_enabled()) {
- capturing_sources.push_back ((*chan).write_source);
- }
- }
-}
-
-void
-DiskStream::set_block_size (jack_nframes_t nframes)
-{
- if (_session.get_block_size() > speed_buffer_size) {
- speed_buffer_size = _session.get_block_size();
-
- for (ChannelList::iterator chan = channels.begin(); chan != channels.end(); ++chan) {
- if ((*chan).speed_buffer) delete [] (*chan).speed_buffer;
- (*chan).speed_buffer = new Sample[speed_buffer_size];
- }
- }
- allocate_temporary_buffers ();
-}
-
-void
-DiskStream::allocate_temporary_buffers ()
-{
- /* make sure the wrap buffer is at least large enough to deal
- with the speeds up to 1.2, to allow for micro-variation
- when slaving to MTC, SMPTE etc.
- */
-
- double sp = max (fabsf (_actual_speed), 1.2f);
- jack_nframes_t required_wrap_size = (jack_nframes_t) floor (_session.get_block_size() * sp) + 1;
-
- if (required_wrap_size > wrap_buffer_size) {
-
- for (ChannelList::iterator chan = channels.begin(); chan != channels.end(); ++chan) {
- if ((*chan).playback_wrap_buffer) delete [] (*chan).playback_wrap_buffer;
- (*chan).playback_wrap_buffer = new Sample[required_wrap_size];
- if ((*chan).capture_wrap_buffer) delete [] (*chan).capture_wrap_buffer;
- (*chan).capture_wrap_buffer = new Sample[required_wrap_size];
- }
-
- wrap_buffer_size = required_wrap_size;
- }
-}
-
-void
-DiskStream::monitor_input (bool yn)
-{
- for (ChannelList::iterator chan = channels.begin(); chan != channels.end(); ++chan) {
-
- if ((*chan).source) {
- (*chan).source->request_monitor_input (yn);
- }
- }
-}
-
-void
-DiskStream::set_capture_offset ()
-{
- if (_io == 0) {
- /* can't capture, so forget it */
- return;
- }
-
- _capture_offset = _io->input_latency();
-}
-
-void
-DiskStream::set_persistent_align_style (AlignStyle a)
-{
- _persistent_alignment_style = a;
-}
-
-void
-DiskStream::set_align_style_from_io ()
-{
- bool have_physical = false;
-
- if (_io == 0) {
- return;
- }
-
- get_input_sources ();
-
- for (ChannelList::iterator chan = channels.begin(); chan != channels.end(); ++chan) {
- if ((*chan).source && (*chan).source->flags() & JackPortIsPhysical) {
- have_physical = true;
- break;
- }
- }
-
- if (have_physical) {
- set_align_style (ExistingMaterial);
- } else {
- set_align_style (CaptureTime);
- }
-}
-
-void
-DiskStream::set_align_style (AlignStyle a)
-{
- if (record_enabled() && _session.actively_recording()) {
- return;
- }
-
-
- if (a != _alignment_style) {
- _alignment_style = a;
- AlignmentStyleChanged ();
- }
-}
-
-int
-DiskStream::add_channel ()
-{
- /* XXX need to take lock??? */
-
- ChannelInfo chan;
-
- init_channel (chan);
-
- chan.speed_buffer = new Sample[speed_buffer_size];
- chan.playback_wrap_buffer = new Sample[wrap_buffer_size];
- chan.capture_wrap_buffer = new Sample[wrap_buffer_size];
-
- channels.push_back (chan);
-
- _n_channels = channels.size();
-
- return 0;
-}
-
-int
-DiskStream::remove_channel ()
-{
- if (channels.size() > 1) {
- /* XXX need to take lock??? */
- ChannelInfo & chan = channels.back();
- destroy_channel (chan);
- channels.pop_back();
-
- _n_channels = channels.size();
- return 0;
- }
-
- return -1;
-}
-
-float
-DiskStream::playback_buffer_load () const
-{
- return (float) ((double) channels.front().playback_buf->read_space()/
- (double) channels.front().playback_buf->bufsize());
-}
-
-float
-DiskStream::capture_buffer_load () const
-{
- return (float) ((double) channels.front().capture_buf->write_space()/
- (double) channels.front().capture_buf->bufsize());
-}
-
-int
-DiskStream::set_loop (Location *location)
-{
- if (location) {
- if (location->start() >= location->end()) {
- error << string_compose(_("Location \"%1\" not valid for track loop (start >= end)"), location->name()) << endl;
- return -1;
- }
- }
-
- loop_location = location;
-
- LoopSet (location); /* EMIT SIGNAL */
- return 0;
-}
-
-jack_nframes_t
-DiskStream::get_capture_start_frame (uint32_t n)
-{
- LockMonitor lm (capture_info_lock, __LINE__, __FILE__);
-
- if (capture_info.size() > n) {
- return capture_info[n]->start;
- }
- else {
- return capture_start_frame;
- }
-}
-
-jack_nframes_t
-DiskStream::get_captured_frames (uint32_t n)
-{
- LockMonitor lm (capture_info_lock, __LINE__, __FILE__);
-
- if (capture_info.size() > n) {
- return capture_info[n]->frames;
- }
- else {
- return capture_captured;
- }
-}
-
-void
-DiskStream::punch_in ()
-{
-}
-
-void
-DiskStream::punch_out ()
-{
-}
-
-int
-DiskStream::use_pending_capture_data (XMLNode& node)
-{
- const XMLProperty* prop;
- XMLNodeList nlist = node.children();
- XMLNodeIterator niter;
- FileSource* fs;
- FileSource* first_fs = 0;
- AudioRegion::SourceList pending_sources;
- jack_nframes_t position;
-
- if ((prop = node.property (X_("at"))) == 0) {
- return -1;
- }
-
- if (sscanf (prop->value().c_str(), "%" PRIu32, &position) != 1) {
- return -1;
- }
-
- for (niter = nlist.begin(); niter != nlist.end(); ++niter) {
- if ((*niter)->name() == X_("file")) {
-
- if ((prop = (*niter)->property (X_("path"))) == 0) {
- continue;
- }
-
- try {
- fs = new FileSource (prop->value(), _session.frame_rate(), true);
- }
-
- catch (failed_constructor& err) {
- error << string_compose (_("%1: cannot restore pending capture source file %2"),
- _name, prop->value())
- << endmsg;
- return -1;
- }
-
- pending_sources.push_back (fs);
-
- if (first_fs == 0) {
- first_fs = fs;
- }
-
- fs->set_captured_for (_name);
- }
- }
-
- if (pending_sources.size() == 0) {
- /* nothing can be done */
- return 1;
- }
-
- if (pending_sources.size() != _n_channels) {
- error << string_compose (_("%1: incorrect number of pending sources listed - ignoring them all"), _name)
- << endmsg;
- return -1;
- }
-
- AudioRegion* region;
-
- try {
- region = new AudioRegion (pending_sources, 0, first_fs->length(),
- region_name_from_path (first_fs->name()),
- 0, AudioRegion::Flag (AudioRegion::DefaultFlags|AudioRegion::Automatic|AudioRegion::WholeFile));
-
- region->special_set_position (0);
- }
-
- catch (failed_constructor& err) {
- error << string_compose (_("%1: cannot create whole-file region from pending capture sources"),
- _name)
- << endmsg;
-
- return -1;
- }
-
- try {
- region = new AudioRegion (pending_sources, 0, first_fs->length(), region_name_from_path (first_fs->name()));
- }
-
- catch (failed_constructor& err) {
- error << string_compose (_("%1: cannot create region from pending capture sources"),
- _name)
- << endmsg;
-
- return -1;
- }
-
- _playlist->add_region (*region, position);
-
- return 0;
-}
-
-void
-DiskStream::set_roll_delay (jack_nframes_t nframes)
-{
- _roll_delay = nframes;
-}
-
-void
-DiskStream::set_destructive (bool yn)
-{
- if (yn != destructive()) {
- reset_write_sources (true, true);
- if (yn) {
- _flags |= Destructive;
- } else {
- _flags &= ~Destructive;
- }
- }