2 Copyright (C) 2014 Paul Davis
3 Written by: Robin Gareus <robin@gareus.org>
5 This program is free software; you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published by
7 the Free Software Foundation; either version 2 of the License, or
8 (at your option) any later version.
10 This program is distributed in the hope that it will be useful,
11 but WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 GNU General Public License for more details.
15 You should have received a copy of the GNU General Public License
16 along with this program; if not, write to the Free Software
17 Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
21 #include "pbd/error.h"
22 #include "pbd/failed_constructor.h"
24 #include "ardour/audiofilesource.h"
25 #include "ardour/debug.h"
26 #include "ardour/srcfilesource.h"
30 using namespace ARDOUR;
33 const uint32_t SrcFileSource::max_blocksize = 2097152U; /* see AudioDiskstream::_do_refill_with_alloc, max */
35 SrcFileSource::SrcFileSource (Session& s, boost::shared_ptr<AudioFileSource> src, SrcQuality srcq)
36 : Source(s, DataType::AUDIO, src->name(), Flag (src->flags() & ~(Writable|Removable|RemovableIfEmpty|RemoveAtDestroy)))
37 , AudioFileSource (s, src->path(), Flag (src->flags() & ~(Writable|Removable|RemovableIfEmpty|RemoveAtDestroy)))
44 assert(_source->n_channels() == 1);
46 int src_type = SRC_SINC_BEST_QUALITY;
50 src_type = SRC_SINC_BEST_QUALITY;
53 src_type = SRC_SINC_MEDIUM_QUALITY;
56 src_type = SRC_SINC_FASTEST;
59 src_type = SRC_ZERO_ORDER_HOLD;
62 src_type = SRC_LINEAR;
67 _ratio = s.nominal_frame_rate() / _source->sample_rate();
68 _src_data.src_ratio = _ratio;
70 src_buffer_size = ceil((double)max_blocksize / _ratio) + 2;
71 _src_buffer = new float[src_buffer_size];
74 if ((_src_state = src_new (src_type, 1, &err)) == 0) {
75 error << string_compose(_("Import: src_new() failed : %1"), src_strerror (err)) << endmsg ;
76 throw failed_constructor ();
80 SrcFileSource::~SrcFileSource ()
82 DEBUG_TRACE (DEBUG::AudioPlayback, "SrcFileSource::~SrcFileSource\n");
83 _src_state = src_delete (_src_state) ;
84 delete [] _src_buffer;
88 SrcFileSource::close ()
90 boost::shared_ptr<FileSource> fs = boost::dynamic_pointer_cast<FileSource> (_source);
97 SrcFileSource::read_unlocked (Sample *dst, framepos_t start, framecnt_t cnt) const
100 const double srccnt = cnt / _ratio;
102 if (_target_position != start) {
103 DEBUG_TRACE (DEBUG::AudioPlayback, string_compose ("SRC: reset %1 -> %2\n", _target_position, start));
104 src_reset(_src_state);
106 _source_position = start / _ratio;
107 _target_position = start;
110 const framecnt_t scnt = ceilf(srccnt - _fract_position);
111 _fract_position += (scnt - srccnt);
114 if (scnt >= src_buffer_size) {
115 DEBUG_TRACE (DEBUG::AudioPlayback, string_compose ("SRC: CRASH AHEAD :) %1 >= %2 (fract=%3, cnt=%4)\n",
116 scnt, src_buffer_size, _fract_position, cnt));
119 assert(scnt < src_buffer_size);
121 _src_data.input_frames = _source->read (_src_buffer, _source_position, scnt);
123 if ((framecnt_t) _src_data.input_frames * _ratio <= cnt
124 && _source_position + scnt >= _source->length(0)) {
125 _src_data.end_of_input = true;
126 DEBUG_TRACE (DEBUG::AudioPlayback, "SRC: END OF INPUT\n");
128 _src_data.end_of_input = false;
131 if ((framecnt_t) _src_data.input_frames < scnt) {
132 _target_position += _src_data.input_frames * _ratio;
134 _target_position += cnt;
137 _src_data.output_frames = cnt;
138 _src_data.data_in = _src_buffer;
139 _src_data.data_out = dst;
141 if ((err = src_process (_src_state, &_src_data))) {
142 error << string_compose(_("SrcFileSource: %1"), src_strerror (err)) << endmsg ;
146 if (_src_data.end_of_input && _src_data.output_frames_gen <= 0) {
150 _source_position += _src_data.input_frames_used;
152 framepos_t saved_target = _target_position;
153 framecnt_t generated = _src_data.output_frames_gen;
155 while (generated < cnt) {
156 DEBUG_TRACE (DEBUG::AudioPlayback, string_compose ("SRC: recurse for %1 samples\n", cnt - generated));
157 framecnt_t g = read_unlocked(dst + generated, _target_position, cnt - generated);
161 _target_position = saved_target;
163 DEBUG_TRACE (DEBUG::AudioPlayback, string_compose ("SRC: in: %1-> want: %2 || got: %3 total: %4\n",
164 _src_data.input_frames, _src_data.output_frames, _src_data.output_frames_gen, generated));