- /* 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<AudioBuffers> resampled (new AudioBuffers (_channels, max_resampled_frames));
-
- int const resampled_frames = swr_convert (
- _swr_context, (uint8_t **) resampled->data(), max_resampled_frames, (uint8_t const **) in->data(), in->frames()
- );
-
- if (resampled_frames < 0) {
- char buf[256];
- av_strerror (resampled_frames, buf, sizeof(buf));
- throw EncodeError (String::compose (_("could not run sample-rate converter for %1 samples (%2) (%3)"), in->frames(), resampled_frames, buf));
+ DCPOMATIC_ASSERT(in->channels() == _channels);
+
+ int in_frames = in->frames ();
+ int in_offset = 0;
+ int out_offset = 0;
+ auto resampled = make_shared<AudioBuffers>(_channels, 0);
+
+ while (in_frames > 0) {
+
+ /* Compute the resampled frames count and add 32 for luck */
+ int const max_resampled_frames = ceil (static_cast<double>(in_frames) * _out_rate / _in_rate) + 32;
+
+ SRC_DATA data;
+ std::vector<float> in_buffer(in_frames * _channels);
+ std::vector<float> out_buffer(max_resampled_frames * _channels);
+
+ {
+ auto p = in->data ();
+ auto q = in_buffer.data();
+ for (int i = 0; i < in_frames; ++i) {
+ for (int j = 0; j < _channels; ++j) {
+ *q++ = p[j][in_offset + i];
+ }
+ }
+ }
+
+ data.data_in = in_buffer.data();
+ data.input_frames = in_frames;
+
+ data.data_out = out_buffer.data();
+ data.output_frames = max_resampled_frames;
+
+ data.end_of_input = 0;
+ data.src_ratio = double (_out_rate) / _in_rate;
+
+ int const r = src_process (_src, &data);
+ if (r) {
+ throw EncodeError (
+ String::compose (
+ N_("could not run sample-rate converter (%1) [processing %2 to %3, %4 channels]"),
+ src_strerror (r),
+ in_frames,
+ max_resampled_frames,
+ _channels
+ )
+ );
+ }
+
+ if (data.output_frames_gen == 0) {
+ break;
+ }
+
+ resampled->set_frames (out_offset + data.output_frames_gen);
+
+ {
+ auto p = data.data_out;
+ auto q = resampled->data ();
+ for (int i = 0; i < data.output_frames_gen; ++i) {
+ for (int j = 0; j < _channels; ++j) {
+ q[j][out_offset + i] = *p++;
+ }
+ }
+ }
+
+ in_frames -= data.input_frames_used;
+ in_offset += data.input_frames_used;
+ out_offset += data.output_frames_gen;