1 /*
2  * Copyright (C) 2013 The Android Open Source Project
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *      http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 
17 #define LOG_TAG "AudioResamplerDyn"
18 //#define LOG_NDEBUG 0
19 
20 #include <malloc.h>
21 #include <string.h>
22 #include <stdlib.h>
23 #include <dlfcn.h>
24 #include <math.h>
25 
26 #include <cutils/compiler.h>
27 #include <cutils/properties.h>
28 #include <utils/Debug.h>
29 #include <utils/Log.h>
30 #include <audio_utils/primitives.h>
31 
32 #include "AudioResamplerFirOps.h" // USE_NEON and USE_INLINE_ASSEMBLY defined here
33 #include "AudioResamplerFirProcess.h"
34 #include "AudioResamplerFirProcessNeon.h"
35 #include "AudioResamplerFirGen.h" // requires math.h
36 #include "AudioResamplerDyn.h"
37 
38 //#define DEBUG_RESAMPLER
39 
40 namespace android {
41 
42 /*
43  * InBuffer is a type agnostic input buffer.
44  *
45  * Layout of the state buffer for halfNumCoefs=8.
46  *
47  * [rrrrrrppppppppnnnnnnnnrrrrrrrrrrrrrrrrrrr.... rrrrrrr]
48  *  S            I                                R
49  *
50  * S = mState
51  * I = mImpulse
52  * R = mRingFull
53  * p = past samples, convoluted with the (p)ositive side of sinc()
54  * n = future samples, convoluted with the (n)egative side of sinc()
55  * r = extra space for implementing the ring buffer
56  */
57 
58 template<typename TC, typename TI, typename TO>
InBuffer()59 AudioResamplerDyn<TC, TI, TO>::InBuffer::InBuffer()
60     : mState(NULL), mImpulse(NULL), mRingFull(NULL), mStateCount(0)
61 {
62 }
63 
64 template<typename TC, typename TI, typename TO>
~InBuffer()65 AudioResamplerDyn<TC, TI, TO>::InBuffer::~InBuffer()
66 {
67     init();
68 }
69 
70 template<typename TC, typename TI, typename TO>
init()71 void AudioResamplerDyn<TC, TI, TO>::InBuffer::init()
72 {
73     free(mState);
74     mState = NULL;
75     mImpulse = NULL;
76     mRingFull = NULL;
77     mStateCount = 0;
78 }
79 
80 // resizes the state buffer to accommodate the appropriate filter length
81 template<typename TC, typename TI, typename TO>
resize(int CHANNELS,int halfNumCoefs)82 void AudioResamplerDyn<TC, TI, TO>::InBuffer::resize(int CHANNELS, int halfNumCoefs)
83 {
84     // calculate desired state size
85     size_t stateCount = halfNumCoefs * CHANNELS * 2 * kStateSizeMultipleOfFilterLength;
86 
87     // check if buffer needs resizing
88     if (mState
89             && stateCount == mStateCount
90             && mRingFull-mState == (ssize_t) (mStateCount-halfNumCoefs*CHANNELS)) {
91         return;
92     }
93 
94     // create new buffer
95     TI* state = NULL;
96     (void)posix_memalign(reinterpret_cast<void**>(&state), 32, stateCount*sizeof(*state));
97     memset(state, 0, stateCount*sizeof(*state));
98 
99     // attempt to preserve state
100     if (mState) {
101         TI* srcLo = mImpulse - halfNumCoefs*CHANNELS;
102         TI* srcHi = mImpulse + halfNumCoefs*CHANNELS;
103         TI* dst = state;
104 
105         if (srcLo < mState) {
106             dst += mState-srcLo;
107             srcLo = mState;
108         }
109         if (srcHi > mState + mStateCount) {
110             srcHi = mState + mStateCount;
111         }
112         memcpy(dst, srcLo, (srcHi - srcLo) * sizeof(*srcLo));
113         free(mState);
114     }
115 
116     // set class member vars
117     mState = state;
118     mStateCount = stateCount;
119     mImpulse = state + halfNumCoefs*CHANNELS; // actually one sample greater than needed
120     mRingFull = state + mStateCount - halfNumCoefs*CHANNELS;
121 }
122 
123 // copy in the input data into the head (impulse+halfNumCoefs) of the buffer.
124 template<typename TC, typename TI, typename TO>
125 template<int CHANNELS>
readAgain(TI * & impulse,const int halfNumCoefs,const TI * const in,const size_t inputIndex)126 void AudioResamplerDyn<TC, TI, TO>::InBuffer::readAgain(TI*& impulse, const int halfNumCoefs,
127         const TI* const in, const size_t inputIndex)
128 {
129     TI* head = impulse + halfNumCoefs*CHANNELS;
130     for (size_t i=0 ; i<CHANNELS ; i++) {
131         head[i] = in[inputIndex*CHANNELS + i];
132     }
133 }
134 
135 // advance the impulse pointer, and load in data into the head (impulse+halfNumCoefs)
136 template<typename TC, typename TI, typename TO>
137 template<int CHANNELS>
readAdvance(TI * & impulse,const int halfNumCoefs,const TI * const in,const size_t inputIndex)138 void AudioResamplerDyn<TC, TI, TO>::InBuffer::readAdvance(TI*& impulse, const int halfNumCoefs,
139         const TI* const in, const size_t inputIndex)
140 {
141     impulse += CHANNELS;
142 
143     if (CC_UNLIKELY(impulse >= mRingFull)) {
144         const size_t shiftDown = mRingFull - mState - halfNumCoefs*CHANNELS;
145         memcpy(mState, mState+shiftDown, halfNumCoefs*CHANNELS*2*sizeof(TI));
146         impulse -= shiftDown;
147     }
148     readAgain<CHANNELS>(impulse, halfNumCoefs, in, inputIndex);
149 }
150 
151 template<typename TC, typename TI, typename TO>
set(int L,int halfNumCoefs,int inSampleRate,int outSampleRate)152 void AudioResamplerDyn<TC, TI, TO>::Constants::set(
153         int L, int halfNumCoefs, int inSampleRate, int outSampleRate)
154 {
155     int bits = 0;
156     int lscale = inSampleRate/outSampleRate < 2 ? L - 1 :
157             static_cast<int>(static_cast<uint64_t>(L)*inSampleRate/outSampleRate);
158     for (int i=lscale; i; ++bits, i>>=1)
159         ;
160     mL = L;
161     mShift = kNumPhaseBits - bits;
162     mHalfNumCoefs = halfNumCoefs;
163 }
164 
165 template<typename TC, typename TI, typename TO>
AudioResamplerDyn(int inChannelCount,int32_t sampleRate,src_quality quality)166 AudioResamplerDyn<TC, TI, TO>::AudioResamplerDyn(
167         int inChannelCount, int32_t sampleRate, src_quality quality)
168     : AudioResampler(inChannelCount, sampleRate, quality),
169       mResampleFunc(0), mFilterSampleRate(0), mFilterQuality(DEFAULT_QUALITY),
170     mCoefBuffer(NULL)
171 {
172     mVolumeSimd[0] = mVolumeSimd[1] = 0;
173     // The AudioResampler base class assumes we are always ready for 1:1 resampling.
174     // We reset mInSampleRate to 0, so setSampleRate() will calculate filters for
175     // setSampleRate() for 1:1. (May be removed if precalculated filters are used.)
176     mInSampleRate = 0;
177     mConstants.set(128, 8, mSampleRate, mSampleRate); // TODO: set better
178 }
179 
180 template<typename TC, typename TI, typename TO>
~AudioResamplerDyn()181 AudioResamplerDyn<TC, TI, TO>::~AudioResamplerDyn()
182 {
183     free(mCoefBuffer);
184 }
185 
186 template<typename TC, typename TI, typename TO>
init()187 void AudioResamplerDyn<TC, TI, TO>::init()
188 {
189     mFilterSampleRate = 0; // always trigger new filter generation
190     mInBuffer.init();
191 }
192 
193 template<typename TC, typename TI, typename TO>
setVolume(float left,float right)194 void AudioResamplerDyn<TC, TI, TO>::setVolume(float left, float right)
195 {
196     AudioResampler::setVolume(left, right);
197     if (is_same<TO, float>::value || is_same<TO, double>::value) {
198         mVolumeSimd[0] = static_cast<TO>(left);
199         mVolumeSimd[1] = static_cast<TO>(right);
200     } else {  // integer requires scaling to U4_28 (rounding down)
201         // integer volumes are clamped to 0 to UNITY_GAIN so there
202         // are no issues with signed overflow.
203         mVolumeSimd[0] = u4_28_from_float(clampFloatVol(left));
204         mVolumeSimd[1] = u4_28_from_float(clampFloatVol(right));
205     }
206 }
207 
max(T a,T b)208 template<typename T> T max(T a, T b) {return a > b ? a : b;}
209 
absdiff(T a,T b)210 template<typename T> T absdiff(T a, T b) {return a > b ? a - b : b - a;}
211 
212 template<typename TC, typename TI, typename TO>
createKaiserFir(Constants & c,double stopBandAtten,int inSampleRate,int outSampleRate,double tbwCheat)213 void AudioResamplerDyn<TC, TI, TO>::createKaiserFir(Constants &c,
214         double stopBandAtten, int inSampleRate, int outSampleRate, double tbwCheat)
215 {
216     TC* buf = NULL;
217     static const double atten = 0.9998;   // to avoid ripple overflow
218     double fcr;
219     double tbw = firKaiserTbw(c.mHalfNumCoefs, stopBandAtten);
220 
221     (void)posix_memalign(reinterpret_cast<void**>(&buf), 32, (c.mL+1)*c.mHalfNumCoefs*sizeof(TC));
222     if (inSampleRate < outSampleRate) { // upsample
223         fcr = max(0.5*tbwCheat - tbw/2, tbw/2);
224     } else { // downsample
225         fcr = max(0.5*tbwCheat*outSampleRate/inSampleRate - tbw/2, tbw/2);
226     }
227     // create and set filter
228     firKaiserGen(buf, c.mL, c.mHalfNumCoefs, stopBandAtten, fcr, atten);
229     c.mFirCoefs = buf;
230     if (mCoefBuffer) {
231         free(mCoefBuffer);
232     }
233     mCoefBuffer = buf;
234 #ifdef DEBUG_RESAMPLER
235     // print basic filter stats
236     printf("L:%d  hnc:%d  stopBandAtten:%lf  fcr:%lf  atten:%lf  tbw:%lf\n",
237             c.mL, c.mHalfNumCoefs, stopBandAtten, fcr, atten, tbw);
238     // test the filter and report results
239     double fp = (fcr - tbw/2)/c.mL;
240     double fs = (fcr + tbw/2)/c.mL;
241     double passMin, passMax, passRipple;
242     double stopMax, stopRipple;
243     testFir(buf, c.mL, c.mHalfNumCoefs, fp, fs, /*passSteps*/ 1000, /*stopSteps*/ 100000,
244             passMin, passMax, passRipple, stopMax, stopRipple);
245     printf("passband(%lf, %lf): %.8lf %.8lf %.8lf\n", 0., fp, passMin, passMax, passRipple);
246     printf("stopband(%lf, %lf): %.8lf %.3lf\n", fs, 0.5, stopMax, stopRipple);
247 #endif
248 }
249 
250 // recursive gcd. Using objdump, it appears the tail recursion is converted to a while loop.
gcd(int n,int m)251 static int gcd(int n, int m)
252 {
253     if (m == 0) {
254         return n;
255     }
256     return gcd(m, n % m);
257 }
258 
isClose(int32_t newSampleRate,int32_t prevSampleRate,int32_t filterSampleRate,int32_t outSampleRate)259 static bool isClose(int32_t newSampleRate, int32_t prevSampleRate,
260         int32_t filterSampleRate, int32_t outSampleRate)
261 {
262 
263     // different upsampling ratios do not need a filter change.
264     if (filterSampleRate != 0
265             && filterSampleRate < outSampleRate
266             && newSampleRate < outSampleRate)
267         return true;
268 
269     // check design criteria again if downsampling is detected.
270     int pdiff = absdiff(newSampleRate, prevSampleRate);
271     int adiff = absdiff(newSampleRate, filterSampleRate);
272 
273     // allow up to 6% relative change increments.
274     // allow up to 12% absolute change increments (from filter design)
275     return pdiff < prevSampleRate>>4 && adiff < filterSampleRate>>3;
276 }
277 
278 template<typename TC, typename TI, typename TO>
setSampleRate(int32_t inSampleRate)279 void AudioResamplerDyn<TC, TI, TO>::setSampleRate(int32_t inSampleRate)
280 {
281     if (mInSampleRate == inSampleRate) {
282         return;
283     }
284     int32_t oldSampleRate = mInSampleRate;
285     uint32_t oldPhaseWrapLimit = mConstants.mL << mConstants.mShift;
286     bool useS32 = false;
287 
288     mInSampleRate = inSampleRate;
289 
290     // TODO: Add precalculated Equiripple filters
291 
292     if (mFilterQuality != getQuality() ||
293             !isClose(inSampleRate, oldSampleRate, mFilterSampleRate, mSampleRate)) {
294         mFilterSampleRate = inSampleRate;
295         mFilterQuality = getQuality();
296 
297         // Begin Kaiser Filter computation
298         //
299         // The quantization floor for S16 is about 96db - 10*log_10(#length) + 3dB.
300         // Keep the stop band attenuation no greater than 84-85dB for 32 length S16 filters
301         //
302         // For s32 we keep the stop band attenuation at the same as 16b resolution, about
303         // 96-98dB
304         //
305 
306         double stopBandAtten;
307         double tbwCheat = 1.; // how much we "cheat" into aliasing
308         int halfLength;
309         if (mFilterQuality == DYN_HIGH_QUALITY) {
310             // 32b coefficients, 64 length
311             useS32 = true;
312             stopBandAtten = 98.;
313             if (inSampleRate >= mSampleRate * 4) {
314                 halfLength = 48;
315             } else if (inSampleRate >= mSampleRate * 2) {
316                 halfLength = 40;
317             } else {
318                 halfLength = 32;
319             }
320         } else if (mFilterQuality == DYN_LOW_QUALITY) {
321             // 16b coefficients, 16-32 length
322             useS32 = false;
323             stopBandAtten = 80.;
324             if (inSampleRate >= mSampleRate * 4) {
325                 halfLength = 24;
326             } else if (inSampleRate >= mSampleRate * 2) {
327                 halfLength = 16;
328             } else {
329                 halfLength = 8;
330             }
331             if (inSampleRate <= mSampleRate) {
332                 tbwCheat = 1.05;
333             } else {
334                 tbwCheat = 1.03;
335             }
336         } else { // DYN_MED_QUALITY
337             // 16b coefficients, 32-64 length
338             // note: > 64 length filters with 16b coefs can have quantization noise problems
339             useS32 = false;
340             stopBandAtten = 84.;
341             if (inSampleRate >= mSampleRate * 4) {
342                 halfLength = 32;
343             } else if (inSampleRate >= mSampleRate * 2) {
344                 halfLength = 24;
345             } else {
346                 halfLength = 16;
347             }
348             if (inSampleRate <= mSampleRate) {
349                 tbwCheat = 1.03;
350             } else {
351                 tbwCheat = 1.01;
352             }
353         }
354 
355         // determine the number of polyphases in the filterbank.
356         // for 16b, it is desirable to have 2^(16/2) = 256 phases.
357         // https://ccrma.stanford.edu/~jos/resample/Relation_Interpolation_Error_Quantization.html
358         //
359         // We are a bit more lax on this.
360 
361         int phases = mSampleRate / gcd(mSampleRate, inSampleRate);
362 
363         // TODO: Once dynamic sample rate change is an option, the code below
364         // should be modified to execute only when dynamic sample rate change is enabled.
365         //
366         // as above, #phases less than 63 is too few phases for accurate linear interpolation.
367         // we increase the phases to compensate, but more phases means more memory per
368         // filter and more time to compute the filter.
369         //
370         // if we know that the filter will be used for dynamic sample rate changes,
371         // that would allow us skip this part for fixed sample rate resamplers.
372         //
373         while (phases<63) {
374             phases *= 2; // this code only needed to support dynamic rate changes
375         }
376 
377         if (phases>=256) {  // too many phases, always interpolate
378             phases = 127;
379         }
380 
381         // create the filter
382         mConstants.set(phases, halfLength, inSampleRate, mSampleRate);
383         createKaiserFir(mConstants, stopBandAtten,
384                 inSampleRate, mSampleRate, tbwCheat);
385     } // End Kaiser filter
386 
387     // update phase and state based on the new filter.
388     const Constants& c(mConstants);
389     mInBuffer.resize(mChannelCount, c.mHalfNumCoefs);
390     const uint32_t phaseWrapLimit = c.mL << c.mShift;
391     // try to preserve as much of the phase fraction as possible for on-the-fly changes
392     mPhaseFraction = static_cast<unsigned long long>(mPhaseFraction)
393             * phaseWrapLimit / oldPhaseWrapLimit;
394     mPhaseFraction %= phaseWrapLimit; // should not do anything, but just in case.
395     mPhaseIncrement = static_cast<uint32_t>(static_cast<uint64_t>(phaseWrapLimit)
396             * inSampleRate / mSampleRate);
397 
398     // determine which resampler to use
399     // check if locked phase (works only if mPhaseIncrement has no "fractional phase bits")
400     int locked = (mPhaseIncrement << (sizeof(mPhaseIncrement)*8 - c.mShift)) == 0;
401     if (locked) {
402         mPhaseFraction = mPhaseFraction >> c.mShift << c.mShift; // remove fractional phase
403     }
404 
405     // stride is the minimum number of filter coefficients processed per loop iteration.
406     // We currently only allow a stride of 16 to match with SIMD processing.
407     // This means that the filter length must be a multiple of 16,
408     // or half the filter length (mHalfNumCoefs) must be a multiple of 8.
409     //
410     // Note: A stride of 2 is achieved with non-SIMD processing.
411     int stride = ((c.mHalfNumCoefs & 7) == 0) ? 16 : 2;
412     LOG_ALWAYS_FATAL_IF(stride < 16, "Resampler stride must be 16 or more");
413     LOG_ALWAYS_FATAL_IF(mChannelCount < 1 || mChannelCount > 8,
414             "Resampler channels(%d) must be between 1 to 8", mChannelCount);
415     // stride 16 (falls back to stride 2 for machines that do not support NEON)
416     if (locked) {
417         switch (mChannelCount) {
418         case 1:
419             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<1, true, 16>;
420             break;
421         case 2:
422             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<2, true, 16>;
423             break;
424         case 3:
425             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<3, true, 16>;
426             break;
427         case 4:
428             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<4, true, 16>;
429             break;
430         case 5:
431             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<5, true, 16>;
432             break;
433         case 6:
434             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<6, true, 16>;
435             break;
436         case 7:
437             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<7, true, 16>;
438             break;
439         case 8:
440             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<8, true, 16>;
441             break;
442         }
443     } else {
444         switch (mChannelCount) {
445         case 1:
446             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<1, false, 16>;
447             break;
448         case 2:
449             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<2, false, 16>;
450             break;
451         case 3:
452             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<3, false, 16>;
453             break;
454         case 4:
455             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<4, false, 16>;
456             break;
457         case 5:
458             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<5, false, 16>;
459             break;
460         case 6:
461             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<6, false, 16>;
462             break;
463         case 7:
464             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<7, false, 16>;
465             break;
466         case 8:
467             mResampleFunc = &AudioResamplerDyn<TC, TI, TO>::resample<8, false, 16>;
468             break;
469         }
470     }
471 #ifdef DEBUG_RESAMPLER
472     printf("channels:%d  %s  stride:%d  %s  coef:%d  shift:%d\n",
473             mChannelCount, locked ? "locked" : "interpolated",
474             stride, useS32 ? "S32" : "S16", 2*c.mHalfNumCoefs, c.mShift);
475 #endif
476 }
477 
478 template<typename TC, typename TI, typename TO>
resample(int32_t * out,size_t outFrameCount,AudioBufferProvider * provider)479 size_t AudioResamplerDyn<TC, TI, TO>::resample(int32_t* out, size_t outFrameCount,
480             AudioBufferProvider* provider)
481 {
482     return (this->*mResampleFunc)(reinterpret_cast<TO*>(out), outFrameCount, provider);
483 }
484 
485 template<typename TC, typename TI, typename TO>
486 template<int CHANNELS, bool LOCKED, int STRIDE>
resample(TO * out,size_t outFrameCount,AudioBufferProvider * provider)487 size_t AudioResamplerDyn<TC, TI, TO>::resample(TO* out, size_t outFrameCount,
488         AudioBufferProvider* provider)
489 {
490     // TODO Mono -> Mono is not supported. OUTPUT_CHANNELS reflects minimum of stereo out.
491     const int OUTPUT_CHANNELS = (CHANNELS < 2) ? 2 : CHANNELS;
492     const Constants& c(mConstants);
493     const TC* const coefs = mConstants.mFirCoefs;
494     TI* impulse = mInBuffer.getImpulse();
495     size_t inputIndex = 0;
496     uint32_t phaseFraction = mPhaseFraction;
497     const uint32_t phaseIncrement = mPhaseIncrement;
498     size_t outputIndex = 0;
499     size_t outputSampleCount = outFrameCount * OUTPUT_CHANNELS;
500     const uint32_t phaseWrapLimit = c.mL << c.mShift;
501     size_t inFrameCount = (phaseIncrement * (uint64_t)outFrameCount + phaseFraction)
502             / phaseWrapLimit;
503     // sanity check that inFrameCount is in signed 32 bit integer range.
504     ALOG_ASSERT(0 <= inFrameCount && inFrameCount < (1U << 31));
505 
506     //ALOGV("inFrameCount:%d  outFrameCount:%d"
507     //        "  phaseIncrement:%u  phaseFraction:%u  phaseWrapLimit:%u",
508     //        inFrameCount, outFrameCount, phaseIncrement, phaseFraction, phaseWrapLimit);
509 
510     // NOTE: be very careful when modifying the code here. register
511     // pressure is very high and a small change might cause the compiler
512     // to generate far less efficient code.
513     // Always sanity check the result with objdump or test-resample.
514 
515     // the following logic is a bit convoluted to keep the main processing loop
516     // as tight as possible with register allocation.
517     while (outputIndex < outputSampleCount) {
518         //ALOGV("LOOP: inFrameCount:%d  outputIndex:%d  outFrameCount:%d"
519         //        "  phaseFraction:%u  phaseWrapLimit:%u",
520         //        inFrameCount, outputIndex, outFrameCount, phaseFraction, phaseWrapLimit);
521 
522         // check inputIndex overflow
523         ALOG_ASSERT(inputIndex <= mBuffer.frameCount, "inputIndex%d > frameCount%d",
524                 inputIndex, mBuffer.frameCount);
525         // Buffer is empty, fetch a new one if necessary (inFrameCount > 0).
526         // We may not fetch a new buffer if the existing data is sufficient.
527         while (mBuffer.frameCount == 0 && inFrameCount > 0) {
528             mBuffer.frameCount = inFrameCount;
529             provider->getNextBuffer(&mBuffer);
530             if (mBuffer.raw == NULL) {
531                 goto resample_exit;
532             }
533             inFrameCount -= mBuffer.frameCount;
534             if (phaseFraction >= phaseWrapLimit) { // read in data
535                 mInBuffer.template readAdvance<CHANNELS>(
536                         impulse, c.mHalfNumCoefs,
537                         reinterpret_cast<TI*>(mBuffer.raw), inputIndex);
538                 inputIndex++;
539                 phaseFraction -= phaseWrapLimit;
540                 while (phaseFraction >= phaseWrapLimit) {
541                     if (inputIndex >= mBuffer.frameCount) {
542                         inputIndex = 0;
543                         provider->releaseBuffer(&mBuffer);
544                         break;
545                     }
546                     mInBuffer.template readAdvance<CHANNELS>(
547                             impulse, c.mHalfNumCoefs,
548                             reinterpret_cast<TI*>(mBuffer.raw), inputIndex);
549                     inputIndex++;
550                     phaseFraction -= phaseWrapLimit;
551                 }
552             }
553         }
554         const TI* const in = reinterpret_cast<const TI*>(mBuffer.raw);
555         const size_t frameCount = mBuffer.frameCount;
556         const int coefShift = c.mShift;
557         const int halfNumCoefs = c.mHalfNumCoefs;
558         const TO* const volumeSimd = mVolumeSimd;
559 
560         // main processing loop
561         while (CC_LIKELY(outputIndex < outputSampleCount)) {
562             // caution: fir() is inlined and may be large.
563             // output will be loaded with the appropriate values
564             //
565             // from the input samples in impulse[-halfNumCoefs+1]... impulse[halfNumCoefs]
566             // from the polyphase filter of (phaseFraction / phaseWrapLimit) in coefs.
567             //
568             //ALOGV("LOOP2: inFrameCount:%d  outputIndex:%d  outFrameCount:%d"
569             //        "  phaseFraction:%u  phaseWrapLimit:%u",
570             //        inFrameCount, outputIndex, outFrameCount, phaseFraction, phaseWrapLimit);
571             ALOG_ASSERT(phaseFraction < phaseWrapLimit);
572             fir<CHANNELS, LOCKED, STRIDE>(
573                     &out[outputIndex],
574                     phaseFraction, phaseWrapLimit,
575                     coefShift, halfNumCoefs, coefs,
576                     impulse, volumeSimd);
577 
578             outputIndex += OUTPUT_CHANNELS;
579 
580             phaseFraction += phaseIncrement;
581             while (phaseFraction >= phaseWrapLimit) {
582                 if (inputIndex >= frameCount) {
583                     goto done;  // need a new buffer
584                 }
585                 mInBuffer.template readAdvance<CHANNELS>(impulse, halfNumCoefs, in, inputIndex);
586                 inputIndex++;
587                 phaseFraction -= phaseWrapLimit;
588             }
589         }
590 done:
591         // We arrive here when we're finished or when the input buffer runs out.
592         // Regardless we need to release the input buffer if we've acquired it.
593         if (inputIndex > 0) {  // we've acquired a buffer (alternatively could check frameCount)
594             ALOG_ASSERT(inputIndex == frameCount, "inputIndex(%d) != frameCount(%d)",
595                     inputIndex, frameCount);  // must have been fully read.
596             inputIndex = 0;
597             provider->releaseBuffer(&mBuffer);
598             ALOG_ASSERT(mBuffer.frameCount == 0);
599         }
600     }
601 
602 resample_exit:
603     // inputIndex must be zero in all three cases:
604     // (1) the buffer never was been acquired; (2) the buffer was
605     // released at "done:"; or (3) getNextBuffer() failed.
606     ALOG_ASSERT(inputIndex == 0, "Releasing: inputindex:%d frameCount:%d  phaseFraction:%u",
607             inputIndex, mBuffer.frameCount, phaseFraction);
608     ALOG_ASSERT(mBuffer.frameCount == 0); // there must be no frames in the buffer
609     mInBuffer.setImpulse(impulse);
610     mPhaseFraction = phaseFraction;
611     return outputIndex / OUTPUT_CHANNELS;
612 }
613 
614 /* instantiate templates used by AudioResampler::create */
615 template class AudioResamplerDyn<float, float, float>;
616 template class AudioResamplerDyn<int16_t, int16_t, int32_t>;
617 template class AudioResamplerDyn<int32_t, int16_t, int32_t>;
618 
619 // ----------------------------------------------------------------------------
620 } // namespace android
621