cannam@89: /** @file paex_record.c
cannam@89: 	@ingroup examples_src
cannam@89: 	@brief Record input into an array; Save array to a file; Playback recorded data.
cannam@89: 	@author Phil Burk  http://www.softsynth.com
cannam@89: */
cannam@89: /*
cannam@89:  * $Id: paex_record.c 1752 2011-09-08 03:21:55Z philburk $
cannam@89:  *
cannam@89:  * This program uses the PortAudio Portable Audio Library.
cannam@89:  * For more information see: http://www.portaudio.com
cannam@89:  * Copyright (c) 1999-2000 Ross Bencina and Phil Burk
cannam@89:  *
cannam@89:  * Permission is hereby granted, free of charge, to any person obtaining
cannam@89:  * a copy of this software and associated documentation files
cannam@89:  * (the "Software"), to deal in the Software without restriction,
cannam@89:  * including without limitation the rights to use, copy, modify, merge,
cannam@89:  * publish, distribute, sublicense, and/or sell copies of the Software,
cannam@89:  * and to permit persons to whom the Software is furnished to do so,
cannam@89:  * subject to the following conditions:
cannam@89:  *
cannam@89:  * The above copyright notice and this permission notice shall be
cannam@89:  * included in all copies or substantial portions of the Software.
cannam@89:  *
cannam@89:  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
cannam@89:  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
cannam@89:  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
cannam@89:  * IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR
cannam@89:  * ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF
cannam@89:  * CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
cannam@89:  * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
cannam@89:  */
cannam@89: 
cannam@89: /*
cannam@89:  * The text above constitutes the entire PortAudio license; however, 
cannam@89:  * the PortAudio community also makes the following non-binding requests:
cannam@89:  *
cannam@89:  * Any person wishing to distribute modifications to the Software is
cannam@89:  * requested to send the modifications to the original developer so that
cannam@89:  * they can be incorporated into the canonical version. It is also 
cannam@89:  * requested that these non-binding requests be included along with the 
cannam@89:  * license above.
cannam@89:  */
cannam@89: 
cannam@89: #include <stdio.h>
cannam@89: #include <stdlib.h>
cannam@89: #include "portaudio.h"
cannam@89: 
cannam@89: /* #define SAMPLE_RATE  (17932) // Test failure to open with this value. */
cannam@89: #define SAMPLE_RATE  (44100)
cannam@89: #define FRAMES_PER_BUFFER (512)
cannam@89: #define NUM_SECONDS     (5)
cannam@89: #define NUM_CHANNELS    (2)
cannam@89: /* #define DITHER_FLAG     (paDitherOff) */
cannam@89: #define DITHER_FLAG     (0) /**/
cannam@89: /** Set to 1 if you want to capture the recording to a file. */
cannam@89: #define WRITE_TO_FILE   (0)
cannam@89: 
cannam@89: /* Select sample format. */
cannam@89: #if 1
cannam@89: #define PA_SAMPLE_TYPE  paFloat32
cannam@89: typedef float SAMPLE;
cannam@89: #define SAMPLE_SILENCE  (0.0f)
cannam@89: #define PRINTF_S_FORMAT "%.8f"
cannam@89: #elif 1
cannam@89: #define PA_SAMPLE_TYPE  paInt16
cannam@89: typedef short SAMPLE;
cannam@89: #define SAMPLE_SILENCE  (0)
cannam@89: #define PRINTF_S_FORMAT "%d"
cannam@89: #elif 0
cannam@89: #define PA_SAMPLE_TYPE  paInt8
cannam@89: typedef char SAMPLE;
cannam@89: #define SAMPLE_SILENCE  (0)
cannam@89: #define PRINTF_S_FORMAT "%d"
cannam@89: #else
cannam@89: #define PA_SAMPLE_TYPE  paUInt8
cannam@89: typedef unsigned char SAMPLE;
cannam@89: #define SAMPLE_SILENCE  (128)
cannam@89: #define PRINTF_S_FORMAT "%d"
cannam@89: #endif
cannam@89: 
cannam@89: typedef struct
cannam@89: {
cannam@89:     int          frameIndex;  /* Index into sample array. */
cannam@89:     int          maxFrameIndex;
cannam@89:     SAMPLE      *recordedSamples;
cannam@89: }
cannam@89: paTestData;
cannam@89: 
cannam@89: /* This routine will be called by the PortAudio engine when audio is needed.
cannam@89: ** It may be called at interrupt level on some machines so don't do anything
cannam@89: ** that could mess up the system like calling malloc() or free().
cannam@89: */
cannam@89: static int recordCallback( const void *inputBuffer, void *outputBuffer,
cannam@89:                            unsigned long framesPerBuffer,
cannam@89:                            const PaStreamCallbackTimeInfo* timeInfo,
cannam@89:                            PaStreamCallbackFlags statusFlags,
cannam@89:                            void *userData )
cannam@89: {
cannam@89:     paTestData *data = (paTestData*)userData;
cannam@89:     const SAMPLE *rptr = (const SAMPLE*)inputBuffer;
cannam@89:     SAMPLE *wptr = &data->recordedSamples[data->frameIndex * NUM_CHANNELS];
cannam@89:     long framesToCalc;
cannam@89:     long i;
cannam@89:     int finished;
cannam@89:     unsigned long framesLeft = data->maxFrameIndex - data->frameIndex;
cannam@89: 
cannam@89:     (void) outputBuffer; /* Prevent unused variable warnings. */
cannam@89:     (void) timeInfo;
cannam@89:     (void) statusFlags;
cannam@89:     (void) userData;
cannam@89: 
cannam@89:     if( framesLeft < framesPerBuffer )
cannam@89:     {
cannam@89:         framesToCalc = framesLeft;
cannam@89:         finished = paComplete;
cannam@89:     }
cannam@89:     else
cannam@89:     {
cannam@89:         framesToCalc = framesPerBuffer;
cannam@89:         finished = paContinue;
cannam@89:     }
cannam@89: 
cannam@89:     if( inputBuffer == NULL )
cannam@89:     {
cannam@89:         for( i=0; i<framesToCalc; i++ )
cannam@89:         {
cannam@89:             *wptr++ = SAMPLE_SILENCE;  /* left */
cannam@89:             if( NUM_CHANNELS == 2 ) *wptr++ = SAMPLE_SILENCE;  /* right */
cannam@89:         }
cannam@89:     }
cannam@89:     else
cannam@89:     {
cannam@89:         for( i=0; i<framesToCalc; i++ )
cannam@89:         {
cannam@89:             *wptr++ = *rptr++;  /* left */
cannam@89:             if( NUM_CHANNELS == 2 ) *wptr++ = *rptr++;  /* right */
cannam@89:         }
cannam@89:     }
cannam@89:     data->frameIndex += framesToCalc;
cannam@89:     return finished;
cannam@89: }
cannam@89: 
cannam@89: /* This routine will be called by the PortAudio engine when audio is needed.
cannam@89: ** It may be called at interrupt level on some machines so don't do anything
cannam@89: ** that could mess up the system like calling malloc() or free().
cannam@89: */
cannam@89: static int playCallback( const void *inputBuffer, void *outputBuffer,
cannam@89:                          unsigned long framesPerBuffer,
cannam@89:                          const PaStreamCallbackTimeInfo* timeInfo,
cannam@89:                          PaStreamCallbackFlags statusFlags,
cannam@89:                          void *userData )
cannam@89: {
cannam@89:     paTestData *data = (paTestData*)userData;
cannam@89:     SAMPLE *rptr = &data->recordedSamples[data->frameIndex * NUM_CHANNELS];
cannam@89:     SAMPLE *wptr = (SAMPLE*)outputBuffer;
cannam@89:     unsigned int i;
cannam@89:     int finished;
cannam@89:     unsigned int framesLeft = data->maxFrameIndex - data->frameIndex;
cannam@89: 
cannam@89:     (void) inputBuffer; /* Prevent unused variable warnings. */
cannam@89:     (void) timeInfo;
cannam@89:     (void) statusFlags;
cannam@89:     (void) userData;
cannam@89: 
cannam@89:     if( framesLeft < framesPerBuffer )
cannam@89:     {
cannam@89:         /* final buffer... */
cannam@89:         for( i=0; i<framesLeft; i++ )
cannam@89:         {
cannam@89:             *wptr++ = *rptr++;  /* left */
cannam@89:             if( NUM_CHANNELS == 2 ) *wptr++ = *rptr++;  /* right */
cannam@89:         }
cannam@89:         for( ; i<framesPerBuffer; i++ )
cannam@89:         {
cannam@89:             *wptr++ = 0;  /* left */
cannam@89:             if( NUM_CHANNELS == 2 ) *wptr++ = 0;  /* right */
cannam@89:         }
cannam@89:         data->frameIndex += framesLeft;
cannam@89:         finished = paComplete;
cannam@89:     }
cannam@89:     else
cannam@89:     {
cannam@89:         for( i=0; i<framesPerBuffer; i++ )
cannam@89:         {
cannam@89:             *wptr++ = *rptr++;  /* left */
cannam@89:             if( NUM_CHANNELS == 2 ) *wptr++ = *rptr++;  /* right */
cannam@89:         }
cannam@89:         data->frameIndex += framesPerBuffer;
cannam@89:         finished = paContinue;
cannam@89:     }
cannam@89:     return finished;
cannam@89: }
cannam@89: 
cannam@89: /*******************************************************************/
cannam@89: int main(void);
cannam@89: int main(void)
cannam@89: {
cannam@89:     PaStreamParameters  inputParameters,
cannam@89:                         outputParameters;
cannam@89:     PaStream*           stream;
cannam@89:     PaError             err = paNoError;
cannam@89:     paTestData          data;
cannam@89:     int                 i;
cannam@89:     int                 totalFrames;
cannam@89:     int                 numSamples;
cannam@89:     int                 numBytes;
cannam@89:     SAMPLE              max, val;
cannam@89:     double              average;
cannam@89: 
cannam@89:     printf("patest_record.c\n"); fflush(stdout);
cannam@89: 
cannam@89:     data.maxFrameIndex = totalFrames = NUM_SECONDS * SAMPLE_RATE; /* Record for a few seconds. */
cannam@89:     data.frameIndex = 0;
cannam@89:     numSamples = totalFrames * NUM_CHANNELS;
cannam@89:     numBytes = numSamples * sizeof(SAMPLE);
cannam@89:     data.recordedSamples = (SAMPLE *) malloc( numBytes ); /* From now on, recordedSamples is initialised. */
cannam@89:     if( data.recordedSamples == NULL )
cannam@89:     {
cannam@89:         printf("Could not allocate record array.\n");
cannam@89:         goto done;
cannam@89:     }
cannam@89:     for( i=0; i<numSamples; i++ ) data.recordedSamples[i] = 0;
cannam@89: 
cannam@89:     err = Pa_Initialize();
cannam@89:     if( err != paNoError ) goto done;
cannam@89: 
cannam@89:     inputParameters.device = Pa_GetDefaultInputDevice(); /* default input device */
cannam@89:     if (inputParameters.device == paNoDevice) {
cannam@89:         fprintf(stderr,"Error: No default input device.\n");
cannam@89:         goto done;
cannam@89:     }
cannam@89:     inputParameters.channelCount = 2;                    /* stereo input */
cannam@89:     inputParameters.sampleFormat = PA_SAMPLE_TYPE;
cannam@89:     inputParameters.suggestedLatency = Pa_GetDeviceInfo( inputParameters.device )->defaultLowInputLatency;
cannam@89:     inputParameters.hostApiSpecificStreamInfo = NULL;
cannam@89: 
cannam@89:     /* Record some audio. -------------------------------------------- */
cannam@89:     err = Pa_OpenStream(
cannam@89:               &stream,
cannam@89:               &inputParameters,
cannam@89:               NULL,                  /* &outputParameters, */
cannam@89:               SAMPLE_RATE,
cannam@89:               FRAMES_PER_BUFFER,
cannam@89:               paClipOff,      /* we won't output out of range samples so don't bother clipping them */
cannam@89:               recordCallback,
cannam@89:               &data );
cannam@89:     if( err != paNoError ) goto done;
cannam@89: 
cannam@89:     err = Pa_StartStream( stream );
cannam@89:     if( err != paNoError ) goto done;
cannam@89:     printf("\n=== Now recording!! Please speak into the microphone. ===\n"); fflush(stdout);
cannam@89: 
cannam@89:     while( ( err = Pa_IsStreamActive( stream ) ) == 1 )
cannam@89:     {
cannam@89:         Pa_Sleep(1000);
cannam@89:         printf("index = %d\n", data.frameIndex ); fflush(stdout);
cannam@89:     }
cannam@89:     if( err < 0 ) goto done;
cannam@89: 
cannam@89:     err = Pa_CloseStream( stream );
cannam@89:     if( err != paNoError ) goto done;
cannam@89: 
cannam@89:     /* Measure maximum peak amplitude. */
cannam@89:     max = 0;
cannam@89:     average = 0.0;
cannam@89:     for( i=0; i<numSamples; i++ )
cannam@89:     {
cannam@89:         val = data.recordedSamples[i];
cannam@89:         if( val < 0 ) val = -val; /* ABS */
cannam@89:         if( val > max )
cannam@89:         {
cannam@89:             max = val;
cannam@89:         }
cannam@89:         average += val;
cannam@89:     }
cannam@89: 
cannam@89:     average = average / (double)numSamples;
cannam@89: 
cannam@89:     printf("sample max amplitude = "PRINTF_S_FORMAT"\n", max );
cannam@89:     printf("sample average = %lf\n", average );
cannam@89: 
cannam@89:     /* Write recorded data to a file. */
cannam@89: #if WRITE_TO_FILE
cannam@89:     {
cannam@89:         FILE  *fid;
cannam@89:         fid = fopen("recorded.raw", "wb");
cannam@89:         if( fid == NULL )
cannam@89:         {
cannam@89:             printf("Could not open file.");
cannam@89:         }
cannam@89:         else
cannam@89:         {
cannam@89:             fwrite( data.recordedSamples, NUM_CHANNELS * sizeof(SAMPLE), totalFrames, fid );
cannam@89:             fclose( fid );
cannam@89:             printf("Wrote data to 'recorded.raw'\n");
cannam@89:         }
cannam@89:     }
cannam@89: #endif
cannam@89: 
cannam@89:     /* Playback recorded data.  -------------------------------------------- */
cannam@89:     data.frameIndex = 0;
cannam@89: 
cannam@89:     outputParameters.device = Pa_GetDefaultOutputDevice(); /* default output device */
cannam@89:     if (outputParameters.device == paNoDevice) {
cannam@89:         fprintf(stderr,"Error: No default output device.\n");
cannam@89:         goto done;
cannam@89:     }
cannam@89:     outputParameters.channelCount = 2;                     /* stereo output */
cannam@89:     outputParameters.sampleFormat =  PA_SAMPLE_TYPE;
cannam@89:     outputParameters.suggestedLatency = Pa_GetDeviceInfo( outputParameters.device )->defaultLowOutputLatency;
cannam@89:     outputParameters.hostApiSpecificStreamInfo = NULL;
cannam@89: 
cannam@89:     printf("\n=== Now playing back. ===\n"); fflush(stdout);
cannam@89:     err = Pa_OpenStream(
cannam@89:               &stream,
cannam@89:               NULL, /* no input */
cannam@89:               &outputParameters,
cannam@89:               SAMPLE_RATE,
cannam@89:               FRAMES_PER_BUFFER,
cannam@89:               paClipOff,      /* we won't output out of range samples so don't bother clipping them */
cannam@89:               playCallback,
cannam@89:               &data );
cannam@89:     if( err != paNoError ) goto done;
cannam@89: 
cannam@89:     if( stream )
cannam@89:     {
cannam@89:         err = Pa_StartStream( stream );
cannam@89:         if( err != paNoError ) goto done;
cannam@89:         
cannam@89:         printf("Waiting for playback to finish.\n"); fflush(stdout);
cannam@89: 
cannam@89:         while( ( err = Pa_IsStreamActive( stream ) ) == 1 ) Pa_Sleep(100);
cannam@89:         if( err < 0 ) goto done;
cannam@89:         
cannam@89:         err = Pa_CloseStream( stream );
cannam@89:         if( err != paNoError ) goto done;
cannam@89:         
cannam@89:         printf("Done.\n"); fflush(stdout);
cannam@89:     }
cannam@89: 
cannam@89: done:
cannam@89:     Pa_Terminate();
cannam@89:     if( data.recordedSamples )       /* Sure it is NULL or valid. */
cannam@89:         free( data.recordedSamples );
cannam@89:     if( err != paNoError )
cannam@89:     {
cannam@89:         fprintf( stderr, "An error occured while using the portaudio stream\n" );
cannam@89:         fprintf( stderr, "Error number: %d\n", err );
cannam@89:         fprintf( stderr, "Error message: %s\n", Pa_GetErrorText( err ) );
cannam@89:         err = 1;          /* Always return 0 or 1, but no other return codes. */
cannam@89:     }
cannam@89:     return err;
cannam@89: }
cannam@89: