Блог

Я пытаюсь создать программу для полнодуплексного аудио, которая обнаруживает аудиовход с микрофона и направляет его на динамик в режиме реального времени, используя библиотеку portaudio и функцию обратного вызова, но я продолжаю получать ошибки. Я попытался открыть полный поток ввода-вывода, затем начать чтение с микрофона и отправить захваченные данные в функцию обратного вызова, которая запустит потоковую передачу звука на динамик, Может кто-нибудь помочь мне с этим?? Вот ошибки:

 ALSA lib pcm.c:2495:(snd_pcm_open_noupdate) Unknown PCM cards.pcm.rear
ALSA lib pcm.c:2495:(snd_pcm_open_noupdate) Unknown PCM cards.pcm.center_lfe
ALSA lib pcm.c:2495:(snd_pcm_open_noupdate) Unknown PCM cards.pcm.side
ALSA lib pcm_route.c:867:(find_matching_chmap) Found no matching channel map
ALSA lib pcm_route.c:867:(find_matching_chmap) Found no matching channel map
ALSA lib pcm_route.c:867:(find_matching_chmap) Found no matching channel map
ALSA lib pcm_route.c:867:(find_matching_chmap) Found no matching channel map
Output device # 14.
Output LL: 0.00870748 s
Output HL: 0.0348299 s
Now recording!!
An error occured while using the portaudio stream
Error number: -9988
Error message: Invalid stream pointer
An error occured while using the portaudio stream
Error number: -9988
Error message: Invalid stream pointer
An error occured while using the portaudio stream
Error number: -9977
Error message: Can't read from a callback stream
  

и это мой код:

 
#include "diffusion.c"
#include "confusion.c"
#include "portaudio.h"
#include "wave_file.c"

/* #define SAMPLE_RATE  (17932) // Test failure to open with this value. */
#define SAMPLE_RATE  (44100)
#define FRAMES_PER_BUFFER (0)
#define NUM_SECONDS     (2)
#define NUM_CHANNELS    (2)
/* #define DITHER_FLAG     (paDitherOff)  */
#define DITHER_FLAG     (0) /**/

#define WRITE_TO_WAVE_FILE  (1)

/* define sample format. */

#define PA_SAMPLE_TYPE  paInt16
typedef short SAMPLE;
#define SAMPLE_SILENCE  (0)
#define PRINTF_S_FORMAT "%d"


PaStreamParameters inputParameters, outputParameters;
    PaStream *stream;
    PaError err;
    SAMPLE *recordedSamples, *recordedSamples2;
    int i;
    int totalFrames;
    int numSamples;
    int numBytes;

static int playCallback (const void *input,
                                      void *output,
                                      unsigned long frameCount,
                                      const PaStreamCallbackTimeInfo* timeInfo,
                                      PaStreamCallbackFlags statusFlags,
                                      void *userData
 ) 
{


    err = Pa_StartStream( stream );
    if( err != paNoError ) goto error;
    printf("Now recording!!n"); fflush(stdout);

    err = Pa_WriteStream( stream, userData, totalFrames );
    if( err != paNoError ) goto error;
    
    err = Pa_CloseStream( stream );
    if( err != paNoError ) goto error;
    free( userData );
    return paContinue;

error:
    fprintf( stderr, "An error occured while using the portaudio streamn" );
    fprintf( stderr, "Error number: %dn", err );
    fprintf( stderr, "Error message: %sn", Pa_GetErrorText( err ) );
    return paContinue;
}





int main(void);
int main(void)
{
    PaStreamParameters inputParameters, outputParameters;
    PaStream *stream;
    PaError err;
    SAMPLE *recordedSamples, *recordedSamples2;
    int i;
    int totalFrames;
    int numSamples;
    int numBytes;
    
    printf("patest_read_record.cn"); fflush(stdout);
    totalFrames = NUM_SECONDS * SAMPLE_RATE; /* Record for a few seconds. */
    numSamples = totalFrames * NUM_CHANNELS;

    numBytes = numSamples * sizeof(SAMPLE);
    recordedSamples = (SAMPLE *) malloc( numBytes );
    if( recordedSamples == NULL )
    {
        printf("Could not allocate record array.n");
        exit(1);
    }
    for( i=0; i<numSamples; i   ) recordedSamples[i] = 0;

    err = Pa_Initialize();
    if( err != paNoError ) goto error;

    inputParameters.device = Pa_GetDefaultInputDevice(); /* default input device */
    if (inputParameters.device == paNoDevice) {
      fprintf(stderr,"Error: No default input device.n");
      goto error;
    }
    inputParameters.channelCount = NUM_CHANNELS;
    inputParameters.sampleFormat = PA_SAMPLE_TYPE;
    inputParameters.suggestedLatency = Pa_GetDeviceInfo( inputParameters.device )->defaultLowInputLatency;
    inputParameters.hostApiSpecificStreamInfo = NULL;

    outputParameters.device = Pa_GetDefaultOutputDevice(); /* default output device */
    printf( "Output device # %d.n", outputParameters.device );
    printf( "Output LL: %g sn", Pa_GetDeviceInfo( outputParameters.device )->defaultLowOutputLatency );
    printf( "Output HL: %g sn", Pa_GetDeviceInfo( outputParameters.device )->defaultHighOutputLatency );
    outputParameters.channelCount = NUM_CHANNELS;
    outputParameters.sampleFormat = PA_SAMPLE_TYPE;
    outputParameters.suggestedLatency = Pa_GetDeviceInfo( outputParameters.device )->defaultHighOutputLatency;
    outputParameters.hostApiSpecificStreamInfo = NULL;

    /* Record some audio. -------------------------------------------- */
    err = Pa_OpenStream(
              amp;stream,
              amp;inputParameters,
              amp;outputParameters,                  /* amp;outputParameters, */
              SAMPLE_RATE,
              paFramesPerBufferUnspecified,
              paClipOff,      /* we won't output out of range samples so don't bother clipping them */
              playCallback, /* no callback, use blocking API */
              recordedSamples ); /* no callback, so no callback userData */
    if( err != paNoError ) goto error;

    err = Pa_StartStream( stream );
    if( err != paNoError ) goto error;
    printf("Now recording!!n"); fflush(stdout);

    err = Pa_ReadStream( stream, recordedSamples, totalFrames );
    if( err != paNoError ) goto error;
    
    err = Pa_CloseStream( stream );
    if( err != paNoError ) goto error;
     /* save the recorded data in a wave file " recording.wav ".  -------------------------- */
    saveInWaveFile(recordedSamples, totalFrames, "recording.wav");
    for (int i =0; i< numSamples ; i  ){
        recordedSamples2[i] = recordedSamples[i];
    }

    free( recordedSamples );
    Pa_Terminate();
    return 0;

error:
    Pa_Terminate();
    fprintf( stderr, "An error occured while using the portaudio streamn" );
    fprintf( stderr, "Error number: %dn", err );
    fprintf( stderr, "Error message: %sn", Pa_GetErrorText( err ) );
    return -1;
}

  

Сначала убедитесь, что устройства ввода и вывода по умолчанию установлены правильно. Вы можете сделать это, сначала запустив пример pa_devs.c в папке examples, чтобы распечатать список разрешенных аудиоустройств, подключенных к компьютеру. Как только вы определили правильные устройства, замените строки номером устройства, например

 inputParameters.device = Pa_GetDefaultInputDevice();
  

для

 inputParameters.device = <device number (e.g. 11)>;
  

и

 outputParameters.device = Pa_GetDefaultOutputDevice();
  

для

 outputParameters.device = <device number (e.g. 11)>;
  

Другой способ, который вы можете попробовать, — это пример с именем paex_read_write_wire.c. Это должно обеспечить ту же функциональность, о которой вы говорите, однако использует блокирующий подход, а не функцию обратного вызова, которую вы использовали в своем коде.

Я не могу протестировать это сейчас, но он должен воспроизводить (контролировать) входной буфер (микрофон):

 static int patestCallback( const void *inputBuffer, void *outputBuffer,
                       unsigned long framesPerBuffer,
                       const PaStreamCallbackTimeInfo* timeInfo,
                       PaStreamCallbackFlags statusFlags,
                       void *userData )
{
    paTestData *data = (paTestData*)userData; 
    float *out = (float*)outputBuffer;
    unsigned int i;
    float *in = (float*)inputBuffer;

    for( i=0; i<framesPerBuffer; i   )
    {
         out   = in  ;  /* left */
         out   = in  ;  /* right*/
    }
    return 0;
}