more MTC debugging
[ardour.git] / libs / ardour / sndfilesource.cc
index 8d89f2aa924fe4ce55fb856e30a16cd8c35556ce..d9d428a4cb8ae098e6827d67e635904b037f6e73 100644 (file)
@@ -1,5 +1,5 @@
 /*
-    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
 
 */
 
+#ifdef WAF_BUILD
+#include "libardour-config.h"
+#endif
+
 #include <cstring>
 #include <cerrno>
 #include <climits>
 
 #include <glibmm/miscutils.h>
 
-#include <ardour/sndfilesource.h>
-#include <ardour/sndfile_helpers.h>
-#include <ardour/utils.h>
-#include <ardour/version.h>
+#include "ardour/sndfilesource.h"
+#include "ardour/sndfile_helpers.h"
+#include "ardour/utils.h"
+#include "ardour/version.h"
+#include "ardour/rc_configuration.h"
+#include "ardour/session.h"
 
 #include "i18n.h"
 
@@ -50,38 +56,39 @@ const Source::Flag SndFileSource::default_writable_flags = Source::Flag (
                Source::CanRename );
 
 SndFileSource::SndFileSource (Session& s, const XMLNode& node)
-       : AudioFileSource (s, node)
+       : Source(s, node)
+       , AudioFileSource (s, node)
 {
-       init ();
+       init_sndfile ();
 
        if (open()) {
                throw failed_constructor ();
        }
 }
 
-SndFileSource::SndFileSource (Session& s, ustring path, int chn, Flag flags)
-          /* files created this way are never writable or removable */
-       : AudioFileSource (s, path, Flag (flags & ~(Writable|Removable|RemovableIfEmpty|RemoveAtDestroy)))
+/** Files created this way are never writable or removable */
+SndFileSource::SndFileSource (Session& s, const ustring& path, int chn, Flag flags)
+       : Source(s, DataType::AUDIO, path, flags)
+       , AudioFileSource (s, path, Flag (flags & ~(Writable|Removable|RemovableIfEmpty|RemoveAtDestroy)))
 {
        _channel = chn;
 
-       init ();
+       init_sndfile ();
 
        if (open()) {
                throw failed_constructor ();
        }
 }
 
-SndFileSource::SndFileSource (Session& s, ustring path, SampleFormat sfmt, HeaderFormat hf, nframes_t rate, Flag flags)
-       : AudioFileSource (s, path, flags, sfmt, hf)
+/** This constructor is used to construct new files, not open existing ones. */
+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, flags, sfmt, hf)
 {
        int fmt = 0;
 
-       init ();
-
-       /* this constructor is used to construct new files, not open
-          existing ones.
-       */
+       init_sndfile ();
 
        _file_is_new = true;
 
@@ -131,7 +138,7 @@ SndFileSource::SndFileSource (Session& s, ustring path, SampleFormat sfmt, Heade
                fmt |= SF_FORMAT_PCM_16;
                break;
        }
-       
+
        _info.channels = 1;
        _info.samplerate = rate;
        _info.format = fmt;
@@ -160,8 +167,8 @@ SndFileSource::SndFileSource (Session& s, ustring path, SampleFormat sfmt, Heade
        }
 }
 
-void 
-SndFileSource::init ()
+void
+SndFileSource::init_sndfile ()
 {
        ustring file;
 
@@ -170,12 +177,6 @@ SndFileSource::init ()
        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.
        */
@@ -186,12 +187,12 @@ SndFileSource::init ()
        _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
@@ -205,7 +206,7 @@ SndFileSource::open ()
                   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;
@@ -225,7 +226,7 @@ SndFileSource::open ()
        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);
@@ -245,8 +246,6 @@ SndFileSource::open ()
 
 SndFileSource::~SndFileSource ()
 {
-       GoingAway (); /* EMIT SIGNAL */
-
        if (sf) {
                sf_close (sf);
                sf = 0;
@@ -265,13 +264,13 @@ SndFileSource::~SndFileSource ()
 }
 
 float
-SndFileSource::sample_rate () const 
+SndFileSource::sample_rate () const
 {
        return _info.samplerate;
 }
 
 nframes_t
-SndFileSource::read_unlocked (Sample *dst, nframes_t start, nframes_t cnt) const
+SndFileSource::read_unlocked (Sample *dst, sframes_t start, nframes_t cnt) const
 {
        int32_t nread;
        float *ptr;
@@ -281,22 +280,22 @@ SndFileSource::read_unlocked (Sample *dst, nframes_t start, nframes_t cnt) const
        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);
@@ -310,7 +309,7 @@ SndFileSource::read_unlocked (Sample *dst, nframes_t start, nframes_t cnt) const
                        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);
@@ -326,24 +325,24 @@ SndFileSource::read_unlocked (Sample *dst, nframes_t start, nframes_t cnt) const
        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()) {
@@ -353,7 +352,7 @@ SndFileSource::write_unlocked (Sample *data, nframes_t cnt)
        }
 }
 
-nframes_t 
+nframes_t
 SndFileSource::nondestructive_write_unlocked (Sample *data, nframes_t cnt)
 {
        if (!writable()) {
@@ -366,7 +365,7 @@ SndFileSource::nondestructive_write_unlocked (Sample *data, nframes_t cnt)
                /*NOTREACHED*/
                return 0;
        }
-       
+
        nframes_t oldlen;
        int32_t frame_pos = _length;
 
@@ -404,28 +403,28 @@ SndFileSource::destructive_write_unlocked (Sample* data, nframes_t cnt)
 
                _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) {
@@ -436,14 +435,14 @@ SndFileSource::destructive_write_unlocked (Sample* data, nframes_t cnt)
 
                _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,
@@ -452,7 +451,7 @@ SndFileSource::destructive_write_unlocked (Sample* data, nframes_t cnt)
 
                _capture_start = false;
                _capture_end = false;
-               
+
                if (crossfade (data, cnt, 0) != cnt) {
                        return 0;
                }
@@ -474,20 +473,20 @@ SndFileSource::destructive_write_unlocked (Sample* data, nframes_t cnt)
        }
 
        file_pos += cnt;
-       
+
        return cnt;
 }
 
 int
-SndFileSource::update_header (nframes_t when, struct tm& now, time_t tnow)
-{      
+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 ();
 }
@@ -503,7 +502,7 @@ SndFileSource::flush_header ()
 }
 
 int
-SndFileSource::setup_broadcast_info (nframes_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;
@@ -514,11 +513,11 @@ SndFileSource::setup_broadcast_info (nframes_t when, struct tm& now, time_t tnow
                return 0;
        }
 
-       _broadcast_info->set_originator_ref ();
+       _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)) {
@@ -553,7 +552,7 @@ SndFileSource::set_header_timeline_position ()
 }
 
 nframes_t
-SndFileSource::write_float (Sample* data, nframes_t frame_pos, nframes_t cnt)
+SndFileSource::write_float (Sample* data, sframes_t frame_pos, nframes_t cnt)
 {
        if (sf_seek (sf, frame_pos, SEEK_SET|SFM_WRITE) < 0) {
                char errbuf[256];
@@ -561,15 +560,15 @@ SndFileSource::write_float (Sample* data, nframes_t frame_pos, nframes_t cnt)
                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;
 }
 
-nframes_t
+sframes_t
 SndFileSource::natural_position() const
 {
        return _timeline_position;
@@ -599,10 +598,10 @@ SndFileSource::clear_capture_marks ()
 {
        _capture_start = false;
        _capture_end = false;
-}      
+}
 
 void
-SndFileSource::mark_capture_start (nframes_t pos)
+SndFileSource::mark_capture_start (sframes_t pos)
 {
        if (destructive()) {
                if (pos < _timeline_position) {
@@ -641,26 +640,26 @@ SndFileSource::crossfade (Sample* data, nframes_t cnt, int fade_in)
        }
 
        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.
@@ -671,13 +670,13 @@ SndFileSource::crossfade (Sample* data, nframes_t cnt, int fade_in)
                                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;
@@ -690,11 +689,11 @@ SndFileSource::crossfade (Sample* data, nframes_t cnt, int fade_in)
                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]);
                        }
@@ -703,7 +702,7 @@ SndFileSource::crossfade (Sample* data, nframes_t cnt, int fade_in)
 
 
                        /* 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]);
                        }
@@ -719,7 +718,7 @@ SndFileSource::crossfade (Sample* data, nframes_t cnt, int fade_in)
                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) {
@@ -734,7 +733,7 @@ SndFileSource::crossfade (Sample* data, nframes_t cnt, int fade_in)
                        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;
@@ -745,7 +744,7 @@ SndFileSource::crossfade (Sample* data, nframes_t cnt, int fade_in)
        return cnt;
 }
 
-nframes_t
+sframes_t
 SndFileSource::last_capture_start_frame () const
 {
        if (destructive()) {
@@ -770,13 +769,13 @@ SndFileSource::handle_header_position_change ()
 }
 
 void
-SndFileSource::setup_standard_crossfades (nframes_t rate)
+SndFileSource::setup_standard_crossfades (Session const & s, nframes_t rate)
 {
        /* This static method is assumed to have been called by the Session
           before any DFS's are created.
        */
 
-       xfade_frames = (nframes_t) floor ((Config->get_destructive_xfade_msecs () / 1000.0) * rate);
+       xfade_frames = (nframes_t) floor ((s.config.get_destructive_xfade_msecs () / 1000.0) * rate);
 
        delete [] out_coefficient;
        delete [] in_coefficient;
@@ -791,12 +790,12 @@ void
 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
@@ -808,7 +807,7 @@ SndFileSource::get_soundfile_info (const ustring& path, SoundFileInfo& info, str
 
        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;