X-Git-Url: https://git.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fresampler.cc;h=7bc933fd01b2536da1b8d7f0e70c6a9264d6a6f0;hb=78e5a331074a456097a162d47501daf1df1ab1a3;hp=1235b9038408b668dd1778f47ba62ffb83b64fee;hpb=d0d584a7dde6de383302615634fdee17e9724fe8;p=dcpomatic.git diff --git a/src/lib/resampler.cc b/src/lib/resampler.cc index 1235b9038..7bc933fd0 100644 --- a/src/lib/resampler.cc +++ b/src/lib/resampler.cc @@ -1,3 +1,22 @@ +/* + Copyright (C) 2013 Carl Hetherington + + 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 + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + +*/ + extern "C" { #include "libavutil/channel_layout.h" } @@ -7,6 +26,9 @@ extern "C" { #include "i18n.h" +using std::cout; +using std::pair; +using std::make_pair; using boost::shared_ptr; Resampler::Resampler (int in, int out, int channels) @@ -41,9 +63,11 @@ Resampler::~Resampler () swr_free (&_swr_context); } -shared_ptr -Resampler::run (shared_ptr in) +pair, AudioContent::Frame> +Resampler::run (shared_ptr in, AudioContent::Frame frame) { + AudioContent::Frame const resamp_time = swr_next_pts (_swr_context, frame * _out_rate) / _in_rate; + /* Compute the resampled frames count and add 32 for luck */ int const max_resampled_frames = ceil ((double) in->frames() * _out_rate / _in_rate) + 32; shared_ptr resampled (new AudioBuffers (_channels, max_resampled_frames)); @@ -57,5 +81,33 @@ Resampler::run (shared_ptr in) } resampled->set_frames (resampled_frames); - return resampled; + return make_pair (resampled, resamp_time); } + +shared_ptr +Resampler::flush () +{ + shared_ptr out (new AudioBuffers (_channels, 0)); + int out_offset = 0; + int64_t const pass_size = 256; + shared_ptr pass (new AudioBuffers (_channels, 256)); + + while (1) { + int const frames = swr_convert (_swr_context, (uint8_t **) pass->data(), pass_size, 0, 0); + + if (frames < 0) { + throw EncodeError (_("could not run sample-rate converter")); + } + + if (frames == 0) { + break; + } + + out->ensure_size (out_offset + frames); + out->copy_from (pass.get(), frames, 0, out_offset); + out_offset += frames; + out->set_frames (out_offset); + } + + return out; +}