c@375: /* -*- c-basic-offset: 4 indent-tabs-mode: nil -*-  vi:set ts=8 sts=4 sw=4: */
c@375: 
c@375: #include "dsp/rateconversion/Resampler.h"
c@375: 
c@375: #include "base/Window.h"
c@375: #include "dsp/transforms/FFT.h"
c@375: 
c@375: #include <iostream>
c@375: 
c@375: #include <cmath>
c@375: 
c@375: #define BOOST_TEST_DYN_LINK
c@375: #define BOOST_TEST_MAIN
c@375: 
c@375: #include <boost/test/unit_test.hpp>
c@375: 
c@375: BOOST_AUTO_TEST_SUITE(TestResampler)
c@375: 
c@375: using std::cout;
c@375: using std::endl;
c@375: using std::vector;
c@375: 
c@375: void
c@375: testResamplerOneShot(int sourceRate,
c@375: 		     int targetRate,
c@375: 		     int n,
c@375: 		     double *in,
c@375: 		     int m,
c@375: 		     double *expected,
c@375: 		     int skip)
c@375: {
c@375:     vector<double> resampled = Resampler::resample(sourceRate, targetRate,
c@375: 						   in, n);
c@375:     if (skip == 0) {
c@375: 	BOOST_CHECK_EQUAL(resampled.size(), m);
c@375:     }
c@375:     for (int i = 0; i < m; ++i) {
c@375: 	BOOST_CHECK_SMALL(resampled[i + skip] - expected[i], 1e-6);
c@375:     }
c@375: }
c@375: 
c@375: void
c@375: testResampler(int sourceRate,
c@375: 	      int targetRate,
c@375: 	      int n,
c@375: 	      double *in,
c@375: 	      int m,
c@375: 	      double *expected)
c@375: {
c@375:     // Here we provide the input in chunks (of varying size)
c@375: 
c@375:     Resampler r(sourceRate, targetRate);
c@375:     int latency = r.getLatency();
c@375: 
c@375:     int m1 = m + latency;
c@375:     int n1 = int((m1 * sourceRate) / targetRate);
c@375: 
c@375:     double *inPadded = new double[n1];
c@375:     double *outPadded = new double[m1];
c@375: 
c@375:     for (int i = 0; i < n1; ++i) {
c@375: 	if (i < n) inPadded[i] = in[i];
c@375: 	else inPadded[i] = 0.0;
c@375:     }
c@375:     
c@375:     for (int i = 0; i < m1; ++i) {
c@375: 	outPadded[i] = -999.0;
c@375:     }
c@375: 
c@375:     int chunkSize = 1;
c@375:     int got = 0;
c@375:     int i = 0;
c@375: 
c@375:     while (true) {
c@375: 	got += r.process(inPadded + i, outPadded + got, chunkSize);
c@375: 	i = i + chunkSize;
c@375: 	chunkSize = chunkSize + 1;
c@375: 	if (i >= n1) {
c@375: 	    break;
c@375: 	} else if (i + chunkSize >= n1) {
c@375: 	    chunkSize = n1 - i;
c@375: 	} else if (chunkSize > 15) {
c@375: 	    chunkSize = 1;
c@375: 	}
c@375:     }
c@375: 
c@375:     BOOST_CHECK_EQUAL(got, m1);
c@375: 
c@375:     for (int i = latency; i < m1; ++i) {
c@375: 	BOOST_CHECK_SMALL(outPadded[i] - expected[i-latency], 1e-8);
c@375:     }
c@375: 
c@375:     delete[] outPadded;
c@375:     delete[] inPadded;
c@375: }
c@375: 
c@375: BOOST_AUTO_TEST_CASE(sameRateOneShot)
c@375: {
c@375:     double d[] = { 0, 0.1, -0.3, -0.4, -0.3, 0, 0.5, 0.2, 0.8, -0.1 };
c@375:     testResamplerOneShot(4, 4, 10, d, 10, d, 0);
c@375: }
c@375: 
c@375: BOOST_AUTO_TEST_CASE(sameRate)
c@375: {
c@375:     double d[] = { 0, 0.1, -0.3, -0.4, -0.3, 0, 0.5, 0.2, 0.8, -0.1 };
c@375:     testResampler(4, 4, 10, d, 10, d);
c@375: }
c@375: 
c@375: BOOST_AUTO_TEST_CASE(interpolatedMisc)
c@375: {
c@375:     // Interpolating any signal by N should give a signal in which
c@375:     // every Nth sample is the original signal
c@375:     double in[] = { 0, 0.1, -0.3, -0.4, -0.3, 0, 0.5, 0.2, 0.8, -0.1 };
c@375:     int n = sizeof(in)/sizeof(in[0]);
c@375:     for (int factor = 2; factor < 10; ++factor) {
c@375: 	vector<double> out = Resampler::resample(6, 6 * factor, in, n);
c@375: 	for (int i = 0; i < n; ++i) {
c@375: 	    BOOST_CHECK_SMALL(out[i * factor] - in[i], 1e-5);
c@375: 	}
c@375:     }
c@375: }
c@375: 
c@375: BOOST_AUTO_TEST_CASE(interpolatedSine)
c@375: {
c@375:     // Interpolating a sinusoid should give us a sinusoid, once we've
c@375:     // dropped the first few samples
c@375:     double in[1000];
c@375:     double out[2000];
c@375:     for (int i = 0; i < 1000; ++i) {
c@375: 	in[i] = sin(i * M_PI / 2.0);
c@375:     }
c@375:     for (int i = 0; i < 2000; ++i) {
c@375: 	out[i] = sin(i * M_PI / 4.0);
c@375:     }
c@375:     testResamplerOneShot(8, 16, 1000, in, 200, out, 512);
c@375: }
c@375: 
c@375: BOOST_AUTO_TEST_CASE(decimatedSine)
c@375: {
c@375:     // Decimating a sinusoid should give us a sinusoid, once we've
c@375:     // dropped the first few samples
c@375:     double in[2000];
c@375:     double out[1000];
c@375:     for (int i = 0; i < 2000; ++i) {
c@375: 	in[i] = sin(i * M_PI / 8.0);
c@375:     }
c@375:     for (int i = 0; i < 1000; ++i) {
c@375: 	out[i] = sin(i * M_PI / 4.0);
c@375:     }
c@375:     testResamplerOneShot(16, 8, 2000, in, 200, out, 256);
c@375: }
c@375: 
c@397: double
c@397: measureSinFreq(const vector<double> &v, int rate, int countCycles)
c@397: {
c@397:     int n = v.size();
c@398:     int firstPeak = -1;
c@398:     int lastPeak = -1;
c@398:     int nPeaks = 0;
c@398:     // count +ve peaks
c@398:     for (int i = v.size()/4; i + 1 < n; ++i) {
c@398:         // allow some fuzz
c@398:         int x0 = int(10000 * v[i-1]);
c@398:         int x1 = int(10000 * v[i]);
c@398:         int x2 = int(10000 * v[i+1]);
c@398:         if (x1 > 0 && x1 > x0 && x1 >= x2) {
c@398:             if (firstPeak < 0) firstPeak = i;
c@398:             lastPeak = i;
c@398:             ++nPeaks;
c@398:             if (nPeaks == countCycles) break;
c@397:         }
c@397:     }
c@398:     int nCycles = nPeaks - 1;
c@397:     if (nCycles <= 0) return 0.0;
c@398:     double cycle = double(lastPeak - firstPeak) / nCycles;
c@398: //    cout << "lastPeak = " << lastPeak << ", firstPeak = " << firstPeak << ", dist = " << lastPeak - firstPeak << ", nCycles = " << nCycles << ", cycle = " << cycle << endl;
c@397:     return rate / cycle;
c@397: }
c@397: 
c@397: void
c@397: testSinFrequency(int freq,
c@397:                  int sourceRate,
c@397:                  int targetRate)
c@397: {
c@397:     // Resampling a sinusoid and then resampling back should give us a
c@399:     // sinusoid of the same frequency as we started with
c@397: 
c@398:     int nCycles = 500;
c@397: 
c@397:     int duration = int(nCycles * float(sourceRate) / float(freq));
c@398: //    cout << "freq = " << freq << ", sourceRate = " << sourceRate << ", targetRate = " << targetRate << ", duration = " << duration << endl;
c@397: 
c@397:     vector<double> in(duration, 0);
c@397:     for (int i = 0; i < duration; ++i) {
c@397:         in[i] = sin(i * M_PI * 2.0 * freq / sourceRate);
c@397:     }
c@397: 
c@397:     vector<double> out = Resampler::resample(sourceRate, targetRate,
c@397:                                              in.data(), in.size());
c@397: 
c@397:     vector<double> back = Resampler::resample(targetRate, sourceRate,
c@397:                                               out.data(), out.size());
c@397: 
c@397:     BOOST_CHECK_EQUAL(in.size(), back.size());
c@397: 
c@398:     double inFreq = measureSinFreq(in, sourceRate, nCycles / 2);
c@398:     double backFreq = measureSinFreq(back, sourceRate, nCycles / 2);
c@397:     
c@398:     BOOST_CHECK_SMALL(inFreq - backFreq, 1e-8);
c@398: }
c@397: 
c@398: // In each of the following we use a frequency that has an exact cycle
c@398: // length in samples at the lowest sample rate, so that we can easily
c@398: // rule out errors in measuring the cycle length after resampling. If
c@398: // the resampler gets its input or output rate wrong, that will show
c@398: // up no matter what the test signal's initial frequency is.
c@397: 
c@397: BOOST_AUTO_TEST_CASE(downUp2)
c@397: {
c@398:     testSinFrequency(441, 44100, 22050);
c@398: }
c@398: 
c@398: BOOST_AUTO_TEST_CASE(downUp5)
c@398: {
c@398:     testSinFrequency(300, 15000, 3000);
c@397: }
c@397: 
c@397: BOOST_AUTO_TEST_CASE(downUp16)
c@397: {
c@398:     testSinFrequency(300, 48000, 3000);
c@397: }
c@397: 
c@397: BOOST_AUTO_TEST_CASE(upDown2)
c@397: {
c@398:     testSinFrequency(441, 44100, 88200);
c@398: }
c@398: 
c@398: BOOST_AUTO_TEST_CASE(upDown5)
c@398: {
c@398:     testSinFrequency(300, 3000, 15000);
c@397: }
c@397: 
c@397: BOOST_AUTO_TEST_CASE(upDown16)
c@397: {
c@398:     testSinFrequency(300, 3000, 48000);
c@397: }
c@397: 
c@375: vector<double>
c@375: squareWave(int rate, double freq, int n)
c@375: {
c@375:     //!!! todo: hoist, test
c@375:     vector<double> v(n, 0.0);
c@375:     for (int h = 0; h < (rate/4)/freq; ++h) {
c@375: 	double m = h * 2 + 1;
c@375: 	double scale = 1.0 / m;
c@375: 	for (int i = 0; i < n; ++i) {
c@375: 	    double s = scale * sin((i * 2.0 * M_PI * m * freq) / rate);
c@375: 	    v[i] += s;
c@375: 	}
c@375:     }
c@375:     return v;
c@375: }
c@375: 
c@375: void
c@375: testSpectrum(int inrate, int outrate)
c@375: {
c@375:     // One second of a square wave
c@375:     int freq = 500;
c@375: 
c@375:     vector<double> square =
c@375: 	squareWave(inrate, freq, inrate);
c@375: 
c@375:     vector<double> maybeSquare = 
c@375: 	Resampler::resample(inrate, outrate, square.data(), square.size());
c@375: 
c@375:     BOOST_CHECK_EQUAL(maybeSquare.size(), outrate);
c@375: 
c@375:     Window<double>(HanningWindow, inrate).cut(square.data());
c@375:     Window<double>(HanningWindow, outrate).cut(maybeSquare.data());
c@375: 
c@375:     // forward magnitude with size inrate, outrate
c@375: 
c@375:     vector<double> inSpectrum(inrate, 0.0);
c@375:     FFTReal(inrate).forwardMagnitude(square.data(), inSpectrum.data());
c@375:     for (int i = 0; i < (int)inSpectrum.size(); ++i) {
c@375: 	inSpectrum[i] /= inrate;
c@375:     }
c@375: 
c@375:     vector<double> outSpectrum(outrate, 0.0);
c@375:     FFTReal(outrate).forwardMagnitude(maybeSquare.data(), outSpectrum.data());
c@375:     for (int i = 0; i < (int)outSpectrum.size(); ++i) {
c@375: 	outSpectrum[i] /= outrate;
c@375:     }
c@375: 
c@381:     // Don't compare bins any higher than 96% of Nyquist freq of lower sr
c@375:     int lengthOfInterest = (inrate < outrate ? inrate : outrate) / 2;
c@381:     lengthOfInterest = lengthOfInterest - (lengthOfInterest / 25);
c@375: 
c@375:     for (int i = 0; i < lengthOfInterest; ++i) {
c@375: 	BOOST_CHECK_SMALL(inSpectrum[i] - outSpectrum[i], 1e-7);
c@375:     }
c@375: }
c@398: /*
c@375: BOOST_AUTO_TEST_CASE(spectrum)
c@375: {
c@375:     int rates[] = { 8000, 22050, 44100, 48000 };
c@375:     for (int i = 0; i < (int)(sizeof(rates)/sizeof(rates[0])); ++i) {
c@375: 	    for (int j = 0; j < (int)(sizeof(rates)/sizeof(rates[0])); ++j) {
c@375: 	    testSpectrum(rates[i], rates[j]);
c@375: 	}
c@375:     }
c@375: }
c@398: */
c@375: BOOST_AUTO_TEST_SUITE_END()
c@375: