jackaudio
/
jack2
mirror of https://github.com/jackaudio/jack2
1
0
Fork 0
Code Releases 45 Activity
jack2 codebase
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
1501 Commits
8 Branches
256MB
Tree: 522fd2b7f8
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from '522fd2b7f8'
${ noResults }
jack2/common/JackAudioAdapterInterface.cpp

298 lines
12KB
Raw Blame History 

  1. /*

  2. Copyright (C) 2008 Grame

  3. 

  4. This program is free software; you can redistribute it and/or modify

  5. it under the terms of the GNU General Public License as published by

  6. the Free Software Foundation; either version 2 of the License, or

  7. (at your option) any later version.

  8. 

  9. This program is distributed in the hope that it will be useful,

  10. but WITHOUT ANY WARRANTY; without even the implied warranty of

  11. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

  12. GNU General Public License for more details.

  13. 

  14. You should have received a copy of the GNU General Public License

  15. along with this program; if not, write to the Free Software

  16. Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.

  17. 

  18. */

  19. 

  20. #include "JackAudioAdapter.h"

  21. #ifdef __APPLE__

  22. #include <TargetConditionals.h>

  23. #endif

  24. #ifndef TARGET_OS_IPHONE

  25. #include "JackLibSampleRateResampler.h"

  26. #endif

  27. #include "JackTime.h"  

  28. #include <stdio.h>

  29. 

  30. namespace Jack

  31. {

  32. 

  33. #ifdef JACK_MONITOR

  34. 

  35.     void MeasureTable::Write(int time1, int time2, float r1, float r2, int pos1, int pos2)

  36.     {

  37.         int pos = (++fCount) % TABLE_MAX;

  38.         fTable[pos].time1 = time1;

  39.         fTable[pos].time2 = time2;

  40.         fTable[pos].r1 = r1;

  41.         fTable[pos].r2 = r2;

  42.         fTable[pos].pos1 = pos1;

  43.         fTable[pos].pos2 = pos2;

  44.     }

  45. 

  46.     void MeasureTable::Save(unsigned int fHostBufferSize, unsigned int fHostSampleRate, unsigned int fAdaptedSampleRate, unsigned int fAdaptedBufferSize)

  47.     {

  48.         char buffer[1024];

  49.         FILE* file = fopen("JackAudioAdapter.log", "w");

  50. 

  51.         int max = (fCount) % TABLE_MAX - 1;

  52.         for (int i = 1; i < max; i++)

  53.         {

  54.             fprintf(file, "%d \t %d \t %d  \t %f \t %f \t %d \t %d \n",

  55.                     fTable[i].delta, fTable[i].time1, fTable[i].time2,

  56.                     fTable[i].r1, fTable[i].r2, fTable[i].pos1, fTable[i].pos2);

  57.         }

  58.         fclose(file);

  59. 

  60.         // No used for now

  61.         // Adapter timing 1

  62.         file = fopen("AdapterTiming1.plot", "w");

  63.         fprintf(file, "set multiplot\n");

  64.         fprintf(file, "set grid\n");

  65.         fprintf(file, "set title \"Audio adapter timing: host [rate = %.1f kHz buffer = %d frames] adapter [rate = %.1f kHz buffer = %d frames] \"\n"

  66.             ,float(fHostSampleRate)/1000.f, fHostBufferSize, float(fAdaptedSampleRate)/1000.f, fAdaptedBufferSize);

  67.         fprintf(file, "set xlabel \"audio cycles\"\n");

  68.         fprintf(file, "set ylabel \"frames\"\n");

  69.         fprintf(file, "plot ");

  70.         sprintf(buffer, "\"JackAudioAdapter.log\" using 2 title \"Ringbuffer error\" with lines,");

  71.         fprintf(file, buffer);

  72.         sprintf(buffer, "\"JackAudioAdapter.log\" using 3 title \"Ringbuffer error with timing correction\" with lines");

  73.         fprintf(file, buffer);

  74.         

  75.         fprintf(file, "\n unset multiplot\n");  

  76.         fprintf(file, "set output 'AdapterTiming1.pdf\n");

  77.         fprintf(file, "set terminal pdf\n");

  78.         

  79.         fprintf(file, "set multiplot\n");

  80.         fprintf(file, "set grid\n");

  81.         fprintf(file, "set title \"Audio adapter timing: host [rate = %.1f kHz buffer = %d frames] adapter [rate = %.1f kHz buffer = %d frames] \"\n"

  82.             ,float(fHostSampleRate)/1000.f, fHostBufferSize, float(fAdaptedSampleRate)/1000.f, fAdaptedBufferSize);

  83.         fprintf(file, "set xlabel \"audio cycles\"\n");

  84.         fprintf(file, "set ylabel \"frames\"\n");

  85.         fprintf(file, "plot ");

  86.         sprintf(buffer, "\"JackAudioAdapter.log\" using 2 title \"Consumer interrupt period\" with lines,");

  87.         fprintf(file, buffer);

  88.         sprintf(buffer, "\"JackAudioAdapter.log\" using 3 title \"Producer interrupt period\" with lines");

  89.         fprintf(file, buffer);

  90.         

  91.         fclose(file);

  92.    

  93.         // Adapter timing 2

  94.         file = fopen("AdapterTiming2.plot", "w");

  95.         fprintf(file, "set multiplot\n");

  96.         fprintf(file, "set grid\n");

  97.         fprintf(file, "set title \"Audio adapter timing: host [rate = %.1f kHz buffer = %d frames] adapter [rate = %.1f kHz buffer = %d frames] \"\n"

  98.             ,float(fHostSampleRate)/1000.f, fHostBufferSize, float(fAdaptedSampleRate)/1000.f, fAdaptedBufferSize);

  99.         fprintf(file, "set xlabel \"audio cycles\"\n");

  100.         fprintf(file, "set ylabel \"resampling ratio\"\n");

  101.         fprintf(file, "plot ");

  102.         sprintf(buffer, "\"JackAudioAdapter.log\" using 4 title \"Ratio 1\" with lines,");

  103.         fprintf(file, buffer);

  104.         sprintf(buffer, "\"JackAudioAdapter.log\" using 5 title \"Ratio 2\" with lines");

  105.         fprintf(file, buffer);

  106.         

  107.         fprintf(file, "\n unset multiplot\n");  

  108.         fprintf(file, "set output 'AdapterTiming2.pdf\n");

  109.         fprintf(file, "set terminal pdf\n");

  110.         

  111.         fprintf(file, "set multiplot\n");

  112.         fprintf(file, "set grid\n");

  113.         fprintf(file, "set title \"Audio adapter timing: host [rate = %.1f kHz buffer = %d frames] adapter [rate = %.1f kHz buffer = %d frames] \"\n"

  114.             ,float(fHostSampleRate)/1000.f, fHostBufferSize, float(fAdaptedSampleRate)/1000.f, fAdaptedBufferSize);

  115.         fprintf(file, "set xlabel \"audio cycles\"\n");

  116.         fprintf(file, "set ylabel \"resampling ratio\"\n");

  117.         fprintf(file, "plot ");

  118.         sprintf(buffer, "\"JackAudioAdapter.log\" using 4 title \"Ratio 1\" with lines,");

  119.         fprintf(file, buffer);

  120.         sprintf(buffer, "\"JackAudioAdapter.log\" using 5 title \"Ratio 2\" with lines");

  121.         fprintf(file, buffer);

  122.         

  123.         fclose(file);

  124. 

  125.         // Adapter timing 3

  126.         file = fopen("AdapterTiming3.plot", "w");

  127.         fprintf(file, "set multiplot\n");

  128.         fprintf(file, "set grid\n");

  129.         fprintf(file, "set title \"Audio adapter timing: host [rate = %.1f kHz buffer = %d frames] adapter [rate = %.1f kHz buffer = %d frames] \"\n"

  130.             ,float(fHostSampleRate)/1000.f, fHostBufferSize, float(fAdaptedSampleRate)/1000.f, fAdaptedBufferSize);

  131.          fprintf(file, "set xlabel \"audio cycles\"\n");

  132.         fprintf(file, "set ylabel \"frames\"\n");

  133.         fprintf(file, "plot ");

  134.         sprintf(buffer, "\"JackAudioAdapter.log\" using 6 title \"Frames position in consumer ringbuffer\" with lines,");

  135.         fprintf(file, buffer);

  136.         sprintf(buffer, "\"JackAudioAdapter.log\" using 7 title \"Frames position in producer ringbuffer\" with lines");

  137.         fprintf(file, buffer);

  138.         

  139.         fprintf(file, "\n unset multiplot\n");  

  140.         fprintf(file, "set output 'AdapterTiming3.pdf\n");

  141.         fprintf(file, "set terminal pdf\n");

  142.         

  143.         fprintf(file, "set multiplot\n");

  144.         fprintf(file, "set grid\n");

  145.         fprintf(file, "set title \"Audio adapter timing: host [rate = %.1f kHz buffer = %d frames] adapter [rate = %.1f kHz buffer = %d frames] \"\n"

  146.             ,float(fHostSampleRate)/1000.f, fHostBufferSize, float(fAdaptedSampleRate)/1000.f, fAdaptedBufferSize);

  147.         fprintf(file, "set xlabel \"audio cycles\"\n");

  148.         fprintf(file, "set ylabel \"frames\"\n");

  149.         fprintf(file, "plot ");

  150.         sprintf(buffer, "\"JackAudioAdapter.log\" using 6 title \"Frames position in consumer ringbuffer\" with lines,");

  151.         fprintf(file, buffer);

  152.         sprintf(buffer, "\"JackAudioAdapter.log\" using 7 title \"Frames position in producer ringbuffer\" with lines");

  153.         fprintf(file, buffer);

  154.         

  155.         fclose(file);

  156.     }

  157. 

  158. #endif

  159. 

  160.     void JackAudioAdapterInterface::GrowRingBufferSize()

  161.     {

  162.         fRingbufferCurSize *= 2;

  163.     }

  164.     

  165.     void JackAudioAdapterInterface::AdaptRingBufferSize()

  166.     {

  167.         if (fHostBufferSize > fAdaptedBufferSize)

  168.             fRingbufferCurSize = 4 * fHostBufferSize;

  169.         else 

  170.             fRingbufferCurSize = 4 * fAdaptedBufferSize;

  171.     }

  172.         

  173.     void JackAudioAdapterInterface::ResetRingBuffers()

  174.     {

  175.         if (fRingbufferCurSize > DEFAULT_RB_SIZE) 

  176.             fRingbufferCurSize = DEFAULT_RB_SIZE;

  177.         

  178.         for (int i = 0; i < fCaptureChannels; i++)

  179.             fCaptureRingBuffer[i]->Reset(fRingbufferCurSize);

  180.         for (int i = 0; i < fPlaybackChannels; i++)

  181.             fPlaybackRingBuffer[i]->Reset(fRingbufferCurSize);

  182.     }

  183.     

  184.     void JackAudioAdapterInterface::Reset()

  185.     {

  186.         ResetRingBuffers();

  187.         fRunning = false;

  188.     }

  189.     

  190. #ifdef TARGET_OS_IPHONE

  191.     void JackAudioAdapterInterface::Create()

  192.     {}

  193. #else

  194.     void JackAudioAdapterInterface::Create()

  195.     {

  196.         //ringbuffers

  197.         fCaptureRingBuffer = new JackResampler*[fCaptureChannels];

  198.         fPlaybackRingBuffer = new JackResampler*[fPlaybackChannels];

  199.         

  200.         if (fAdaptative) {

  201.             AdaptRingBufferSize();

  202.             jack_info("Ringbuffer automatic adaptative mode size = %d frames", fRingbufferCurSize);

  203.         } else {

  204.             if (fRingbufferCurSize > DEFAULT_RB_SIZE) 

  205.                 fRingbufferCurSize = DEFAULT_RB_SIZE;

  206.             jack_info("Fixed ringbuffer size = %d frames", fRingbufferCurSize);

  207.         }

  208.         

  209.         for (int i = 0; i < fCaptureChannels; i++ ) {

  210.             fCaptureRingBuffer[i] = new JackLibSampleRateResampler(fQuality);

  211.             fCaptureRingBuffer[i]->Reset(fRingbufferCurSize);

  212.         }

  213.         for (int i = 0; i < fPlaybackChannels; i++ ) {

  214.             fPlaybackRingBuffer[i] = new JackLibSampleRateResampler(fQuality);

  215.             fPlaybackRingBuffer[i]->Reset(fRingbufferCurSize);

  216.         }

  217.      

  218.         if (fCaptureChannels > 0)

  219.             jack_log("ReadSpace = %ld", fCaptureRingBuffer[0]->ReadSpace());

  220.         if (fPlaybackChannels > 0)

  221.             jack_log("WriteSpace = %ld", fPlaybackRingBuffer[0]->WriteSpace());

  222.     }

  223. #endif

  224.     

  225.     void JackAudioAdapterInterface::Destroy()

  226.     {

  227.         for (int i = 0; i < fCaptureChannels; i++ )

  228.             delete ( fCaptureRingBuffer[i] );

  229.         for (int i = 0; i < fPlaybackChannels; i++ )

  230.             delete ( fPlaybackRingBuffer[i] );

  231. 

  232.         delete[] fCaptureRingBuffer;

  233.         delete[] fPlaybackRingBuffer;

  234.     }

  235.     

  236.     int JackAudioAdapterInterface::PushAndPull(float** inputBuffer, float** outputBuffer, unsigned int frames)

  237.     {

  238.         bool failure = false;

  239.         fRunning = true;

  240.    

  241.         // Finer estimation of the position in the ringbuffer

  242.         int delta_frames = (fPullAndPushTime > 0) ? (int)((float(long(GetMicroSeconds() - fPullAndPushTime)) * float(fAdaptedSampleRate)) / 1000000.f) : 0;

  243.         double ratio = fPIControler.GetRatio(fCaptureRingBuffer[0]->GetError() - delta_frames);

  244.         

  245.     #ifdef JACK_MONITOR

  246.         fTable.Write(fCaptureRingBuffer[0]->GetError(), fCaptureRingBuffer[0]->GetError() - delta_frames, ratio, 1/ratio, fCaptureRingBuffer[0]->ReadSpace(), fCaptureRingBuffer[0]->ReadSpace());

  247.     #endif

  248.     

  249.         // Push/pull from ringbuffer

  250.         for (int i = 0; i < fCaptureChannels; i++) {

  251.             fCaptureRingBuffer[i]->SetRatio(ratio);

  252.             if (fCaptureRingBuffer[i]->WriteResample(inputBuffer[i], frames) < frames)

  253.                 failure = true;

  254.         }

  255. 

  256.         for (int i = 0; i < fPlaybackChannels; i++) {

  257.             fPlaybackRingBuffer[i]->SetRatio(1/ratio);

  258.             if (fPlaybackRingBuffer[i]->ReadResample(outputBuffer[i], frames) < frames)

  259.                  failure = true;

  260.         }

  261.         // Reset all ringbuffers in case of failure

  262.         if (failure) {

  263.             jack_error("JackAudioAdapterInterface::PushAndPull ringbuffer failure... reset");

  264.             if (fAdaptative) {

  265.                 GrowRingBufferSize();

  266.                 jack_info("Ringbuffer size = %d frames", fRingbufferCurSize);

  267.             }

  268.             ResetRingBuffers();

  269.             return -1;

  270.         } else {

  271.             return 0;

  272.         }

  273.     }

  274. 

  275.     int JackAudioAdapterInterface::PullAndPush(float** inputBuffer, float** outputBuffer, unsigned int frames) 

  276.     {

  277.         fPullAndPushTime = GetMicroSeconds();

  278.         if (!fRunning)

  279.             return 0;

  280. 

  281.         int res = 0;

  282.     

  283.         // Push/pull from ringbuffer

  284.         for (int i = 0; i < fCaptureChannels; i++) {

  285.             if (fCaptureRingBuffer[i]->Read(inputBuffer[i], frames) < frames)

  286.                 res = -1;

  287.         }

  288. 

  289.         for (int i = 0; i < fPlaybackChannels; i++) {

  290.             if (fPlaybackRingBuffer[i]->Write(outputBuffer[i], frames) < frames)

  291.                 res = -1;

  292.         }

  293.         

  294.         return res;

  295.     }

  296.  

  297. } // namespace