110 lines
2.9 KiB
C
110 lines
2.9 KiB
C
#include <portaudio.h>
|
|
#include <semaphore.h>
|
|
#include <stdio.h>
|
|
#include <unistd.h>
|
|
|
|
static int paCallback(const void *inputBuffer, void *outputBuffer,
|
|
unsigned long framesPerBuffer,
|
|
const PaStreamCallbackTimeInfo* timeInfo,
|
|
PaStreamCallbackFlags statusFlags,
|
|
void *userData);
|
|
|
|
static PaStream *AudioStream;
|
|
static int JuliaPipeReadFD = 0;
|
|
static int JuliaPipeWriteFD = 0;
|
|
static sem_t CSemaphore;
|
|
static void *OutData = NULL;
|
|
static unsigned long OutFrames = 0;
|
|
|
|
|
|
int make_pipe(void)
|
|
{
|
|
int pipefd[2];
|
|
pipe(pipefd);
|
|
JuliaPipeReadFD = pipefd[0];
|
|
JuliaPipeWriteFD = pipefd[1];
|
|
sem_init(&CSemaphore, 0, 0);
|
|
return JuliaPipeReadFD;
|
|
}
|
|
|
|
|
|
void wake_callback_thread(void *outData, unsigned int outFrames)
|
|
{
|
|
OutData = outData;
|
|
OutFrames = outFrames;
|
|
sem_post(&CSemaphore);
|
|
}
|
|
|
|
PaError open_stream(unsigned int sampleRate, unsigned int bufSize)
|
|
{
|
|
PaError err;
|
|
|
|
|
|
err = Pa_OpenDefaultStream(&AudioStream,
|
|
0, /* no input channels */
|
|
1, /* mono output */
|
|
paFloat32, /* 32 bit floating point output */
|
|
sampleRate,
|
|
bufSize, /* frames per buffer, i.e. the number of sample frames
|
|
that PortAudio will request from the callback. Many
|
|
apps may want to use paFramesPerBufferUnspecified,
|
|
which tells PortAudio to pick the best, possibly
|
|
changing, buffer size.*/
|
|
paCallback, /* this is your callback function */
|
|
NULL); /*This is a pointer that will be passed to your callback*/
|
|
if(err != paNoError)
|
|
{
|
|
return err;
|
|
}
|
|
|
|
err = Pa_StartStream(AudioStream);
|
|
if(err != paNoError)
|
|
{
|
|
return err;
|
|
}
|
|
|
|
return paNoError;
|
|
}
|
|
|
|
|
|
//PaError stop_sin(void)
|
|
//{
|
|
// PaError err;
|
|
// err = Pa_StopStream(sin_stream);
|
|
// if(err != paNoError)
|
|
// {
|
|
// return err;
|
|
// }
|
|
//
|
|
// err = Pa_CloseStream(sin_stream);
|
|
// if( err != paNoError )
|
|
// {
|
|
// return err;
|
|
// }
|
|
// return paNoError;
|
|
//}
|
|
|
|
|
|
/*
|
|
* This routine will be called by the PortAudio engine when audio is needed.
|
|
* It may called at interrupt level on some machines so don't do anything that
|
|
* could mess up the system like calling malloc() or free().
|
|
*/
|
|
static int paCallback(const void *inputBuffer, void *outputBuffer,
|
|
unsigned long framesPerBuffer,
|
|
const PaStreamCallbackTimeInfo* timeInfo,
|
|
PaStreamCallbackFlags statusFlags,
|
|
void *userData)
|
|
{
|
|
unsigned int i;
|
|
unsigned char fd_data = 0;
|
|
|
|
sem_wait(&CSemaphore);
|
|
for(i=0; i<framesPerBuffer; i++)
|
|
{
|
|
((float *)outputBuffer)[i] = ((float *)OutData)[i];
|
|
}
|
|
// TODO: copy the input data somewhere
|
|
write(JuliaPipeWriteFD, &fd_data, 1);
|
|
return 0;
|
|
}
|