/*
- Copyright (C) 2006 Paul Davis
+ Copyright (C) 2006 Paul Davis
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
}
/** Files created this way are never writable or removable */
-SndFileSource::SndFileSource (Session& s, const ustring& path, bool embedded, int chn, Flag flags)
+SndFileSource::SndFileSource (Session& s, const ustring& path, int chn, Flag flags)
: Source(s, DataType::AUDIO, path, flags)
- , AudioFileSource (s, path, embedded,
- Flag (flags & ~(Writable|Removable|RemovableIfEmpty|RemoveAtDestroy)))
+ , AudioFileSource (s, path, Flag (flags & ~(Writable|Removable|RemovableIfEmpty|RemoveAtDestroy)))
{
_channel = chn;
}
/** This constructor is used to construct new files, not open existing ones. */
-SndFileSource::SndFileSource (Session& s, const ustring& path, bool embedded,
+SndFileSource::SndFileSource (Session& s, const ustring& path,
SampleFormat sfmt, HeaderFormat hf, nframes_t rate, Flag flags)
: Source(s, DataType::AUDIO, path, flags)
- , AudioFileSource (s, path, embedded, flags, sfmt, hf)
+ , AudioFileSource (s, path, flags, sfmt, hf)
{
int fmt = 0;
fmt |= SF_FORMAT_PCM_16;
break;
}
-
+
_info.channels = 1;
_info.samplerate = rate;
_info.format = fmt;
}
}
-void
+void
SndFileSource::init_sndfile ()
{
ustring file;
sf = 0;
_broadcast_info = 0;
- if (is_embedded()) {
- _name = _path;
- } else {
- _name = Glib::path_get_basename (_path);
- }
-
/* although libsndfile says we don't need to set this,
valgrind and source code shows us that we do.
*/
_capture_end = false;
file_pos = 0;
- if (destructive()) {
+ if (destructive()) {
xfade_buf = new Sample[xfade_frames];
_timeline_position = header_position_offset;
}
- AudioFileSource::HeaderPositionOffsetChanged.connect (
- mem_fun (*this, &SndFileSource::handle_header_position_change));
+ AudioFileSource::HeaderPositionOffsetChanged.connect_same_thread (header_position_connection, boost::bind (&SndFileSource::handle_header_position_change, this));
}
int
so we don't want to see this message.
*/
- error << string_compose(_("SndFileSource: cannot open file \"%1\" for %2 (%3)"),
+ error << string_compose(_("SndFileSource: cannot open file \"%1\" for %2 (%3)"),
_path, (writable() ? "read+write" : "reading"), errbuf) << endmsg;
#endif
return -1;
if (!_broadcast_info) {
_broadcast_info = new BroadcastInfo;
}
-
+
bool bwf_info_exists = _broadcast_info->load_from_file (sf);
set_timeline_position (bwf_info_exists ? _broadcast_info->get_time_reference() : header_position_offset);
SndFileSource::~SndFileSource ()
{
- GoingAway (); /* EMIT SIGNAL */
-
if (sf) {
sf_close (sf);
sf = 0;
}
float
-SndFileSource::sample_rate () const
+SndFileSource::sample_rate () const
{
return _info.samplerate;
}
if (start > _length) {
/* read starts beyond end of data, just memset to zero */
-
+
file_cnt = 0;
} else if (start + cnt > _length) {
-
+
/* read ends beyond end of data, read some, memset the rest */
-
+
file_cnt = _length - start;
} else {
-
+
/* read is entirely within data */
file_cnt = cnt;
}
-
+
if (file_cnt != cnt) {
nframes_t delta = cnt - file_cnt;
memset (dst+file_cnt, 0, sizeof (Sample) * delta);
error << string_compose(_("SndFileSource: could not seek to frame %1 within %2 (%3)"), start, _name.substr (1), errbuf) << endmsg;
return 0;
}
-
+
if (_info.channels == 1) {
nframes_t ret = sf_read_float (sf, dst, file_cnt);
_read_data_count = ret * sizeof(float);
real_cnt = cnt * _info.channels;
Sample* interleave_buf = get_interleave_buffer (real_cnt);
-
+
nread = sf_read_float (sf, interleave_buf, real_cnt);
ptr = interleave_buf + _channel;
nread /= _info.channels;
-
+
/* stride through the interleaved data */
-
+
for (int32_t n = 0; n < nread; ++n) {
dst[n] = *ptr;
ptr += _info.channels;
}
_read_data_count = cnt * sizeof(float);
-
+
return nread;
}
-nframes_t
+nframes_t
SndFileSource::write_unlocked (Sample *data, nframes_t cnt)
{
if (destructive()) {
}
}
-nframes_t
+nframes_t
SndFileSource::nondestructive_write_unlocked (Sample *data, nframes_t cnt)
{
if (!writable()) {
/*NOTREACHED*/
return 0;
}
-
+
nframes_t oldlen;
int32_t frame_pos = _length;
_capture_start = false;
_capture_end = false;
-
+
/* move to the correct location place */
file_pos = capture_start_frame - _timeline_position;
-
+
// split cnt in half
nframes_t subcnt = cnt / 2;
nframes_t ofilepos = file_pos;
-
+
// fade in
if (crossfade (data, subcnt, 1) != subcnt) {
return 0;
}
-
+
file_pos += subcnt;
Sample * tmpdata = data + subcnt;
-
+
// fade out
subcnt = cnt - subcnt;
if (crossfade (tmpdata, subcnt, 0) != subcnt) {
return 0;
}
-
+
file_pos = ofilepos; // adjusted below
} else if (_capture_start) {
_capture_start = false;
_capture_end = false;
-
+
/* move to the correct location place */
file_pos = capture_start_frame - _timeline_position;
if (crossfade (data, cnt, 1) != cnt) {
return 0;
}
-
+
} else if (_capture_end) {
/* end of capture both occur within the data we are writing,
_capture_start = false;
_capture_end = false;
-
+
if (crossfade (data, cnt, 0) != cnt) {
return 0;
}
}
file_pos += cnt;
-
+
return cnt;
}
int
SndFileSource::update_header (sframes_t when, struct tm& now, time_t tnow)
-{
+{
set_timeline_position (when);
if (_flags & Broadcast) {
if (setup_broadcast_info (when, now, tnow)) {
return -1;
}
- }
+ }
return flush_header ();
}
}
int
-SndFileSource::setup_broadcast_info (sframes_t when, struct tm& now, time_t tnow)
+SndFileSource::setup_broadcast_info (sframes_t /*when*/, struct tm& now, time_t /*tnow*/)
{
if (!writable()) {
warning << string_compose (_("attempt to store broadcast info in a non-writable audio file source (%1)"), _path) << endmsg;
_broadcast_info->set_originator_ref (_session);
_broadcast_info->set_origination_time (&now);
-
+
/* now update header position taking header offset into account */
-
+
set_header_timeline_position ();
if (!_broadcast_info->write_to_file (sf)) {
error << string_compose (_("%1: cannot seek to %2 (libsndfile error: %3"), _path, frame_pos, errbuf) << endmsg;
return 0;
}
-
+
if (sf_writef_float (sf, data, cnt) != (ssize_t) cnt) {
return 0;
}
-
+
return cnt;
}
{
_capture_start = false;
_capture_end = false;
-}
+}
void
SndFileSource::mark_capture_start (sframes_t pos)
}
if (fade_position > _length) {
-
+
/* read starts beyond end of data, just memset to zero */
-
+
file_cnt = 0;
} else if (fade_position + xfade > _length) {
-
+
/* read ends beyond end of data, read some, memset the rest */
-
+
file_cnt = _length - fade_position;
} else {
-
+
/* read is entirely within data */
file_cnt = xfade;
}
if (file_cnt) {
-
+
if ((retval = read_unlocked (xfade_buf, fade_position, file_cnt)) != (ssize_t) file_cnt) {
if (retval >= 0 && errno == EAGAIN) {
/* XXX - can we really trust that errno is meaningful here? yes POSIX, i'm talking to you.
return 0;
}
}
- }
+ }
if (file_cnt != xfade) {
nframes_t delta = xfade - file_cnt;
memset (xfade_buf+file_cnt, 0, sizeof (Sample) * delta);
}
-
+
if (nofade && !fade_in) {
if (write_float (data, file_pos, nofade) != nofade) {
error << string_compose(_("SndFileSource: \"%1\" bad write (%2)"), _path, strerror (errno)) << endmsg;
nframes_t n;
/* use the standard xfade curve */
-
+
if (fade_in) {
/* fade new material in */
-
+
for (n = 0; n < xfade; ++n) {
xfade_buf[n] = (xfade_buf[n] * out_coefficient[n]) + (fade_data[n] * in_coefficient[n]);
}
/* fade new material out */
-
+
for (n = 0; n < xfade; ++n) {
xfade_buf[n] = (xfade_buf[n] * in_coefficient[n]) + (fade_data[n] * out_coefficient[n]);
}
compute_equal_power_fades (xfade, in, out);
for (nframes_t n = 0; n < xfade; ++n) {
- xfade_buf[n] = (xfade_buf[n] * out[n]) + (fade_data[n] * in[n]);
+ xfade_buf[n] = (xfade_buf[n] * out[n]) + (fade_data[n] * in[n]);
}
} else if (xfade) {
return 0;
}
}
-
+
if (fade_in && nofade) {
if (write_float (data + xfade, file_pos + xfade, nofade) != nofade) {
error << string_compose(_("SndFileSource: \"%1\" bad write (%2)"), _path, strerror (errno)) << endmsg;
SndFileSource::set_timeline_position (int64_t pos)
{
// destructive track timeline postion does not change
- // except at instantion or when header_position_offset
+ // except at instantion or when header_position_offset
// (session start) changes
if (!destructive()) {
AudioFileSource::set_timeline_position (pos);
- }
+ }
}
int
sf_info.format = 0; // libsndfile says to clear this before sf_open().
- if ((sf = sf_open ((char*) path.c_str(), SFM_READ, &sf_info)) == 0) {
+ if ((sf = sf_open ((char*) path.c_str(), SFM_READ, &sf_info)) == 0) {
char errbuf[256];
error_msg = sf_error_str (0, errbuf, sizeof (errbuf) - 1);
return false;