- } 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, channels[0].write_source->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), "0x%x", _flags);
- node->add_property ("flags", buf);
-
- 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 ("flags")) != 0) {
- _flags = strtol (prop->value().c_str(), 0, 0);
- }
-
- 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 (!destructive() && capture_pending_node) {
- /* destructive streams have one and only one source per channel,
- and so they never end up in pending capture in any useful
- sense.
- */
- 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 when we handle the input set
- up of the IO that owns this DS (::non_realtime_input_change())
- */
-
- 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 ();
-
- /* do not remove destructive files even if they are empty */
-
- chan.write_source->set_allow_remove_if_empty (!destructive());
-
- return 0;
-}
-
-void
-DiskStream::reset_write_sources (bool mark_write_complete, bool force)
-{
- ChannelList::iterator chan;
- uint32_t n;
-
- if (!recordable()) {
- return;
- }
-
- capturing_sources.clear ();
-
- for (chan = channels.begin(), n = 0; chan != channels.end(); ++chan, ++n) {
- if (!destructive()) {
-
- 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);
- }
-
- } else {
- if ((*chan).write_source == 0) {
- use_new_write_source (n);
- }
- }
- }
-
- if (destructive()) {
-
- /* we now have all our write sources set up, so create the
- playlist's single region.