///////////////////////////////////////////////////////////////////////////////////
//
//
///////////////////////////////////////////////////////////////////////////////////
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sched.h>
#include <errno.h>
#include <getopt.h>
#include <alsa/asoundlib.h>
#include <sys/time.h>
#include <math.h>
#include <fftw3.h>
static char *device = "plughw:0,0"; /* playback device */
static snd_pcm_format_t format = SND_PCM_FORMAT_S16; /* sample format */
static unsigned int rate = 24000; /* stream rate */
//static unsigned int buffer_size = 200000; /* ring buffer length in us */
//static unsigned int period_size = 10000; /* period time in us */
static int verbose = 0; /* verbose flag */
static int resample = 1; /* enable alsa-lib resampling */
static int period_event = 0; /* produce poll event after each period */
static snd_pcm_sframes_t buffer_size=7008; // size of buffer at sound card
static snd_pcm_sframes_t period_size=3504; //samples per frame
static snd_output_t *output = NULL;
FILE *out;
double df; //frequency resolution
unsigned int frequency_bins; // number of output frequency bins
double *inl, *inr;
fftw_complex *outl, *outr;
fftw_plan fft_plan_left, fft_plan_right;
double *spect_avg_left, *spect_avg_right;
unsigned int period;
static int set_hwparams(snd_pcm_t *handle, snd_pcm_hw_params_t *params, unsigned int channels)
{
unsigned int rrate;
snd_pcm_uframes_t size;
int err, dir;
/* choose all parameters */
err = snd_pcm_hw_params_any(handle, params);
if (err < 0) {
printf("Broken configuration for capture: no configurations available: %s\n", snd_strerror(err));
return err;
}
/* set hardware resampling */
err = snd_pcm_hw_params_set_rate_resample(handle, params, resample);
if (err < 0) {
printf("Resampling setup failed for capture: %s\n", snd_strerror(err));
return err;
}
/* set the interleaved read/write format */
err = snd_pcm_hw_params_set_access(handle, params, SND_PCM_ACCESS_RW_INTERLEAVED);
if (err < 0) {
printf("Access type not available for capture: %s\n", snd_strerror(err));
return err;
}
/* set the sample format */
err = snd_pcm_hw_params_set_format(handle, params, format);
if (err < 0) {
printf("Sample format not available for playback: %s\n", snd_strerror(err));
return err;
}
/* set the count of channels */
err = snd_pcm_hw_params_set_channels(handle, params, channels);
if (err < 0) {
printf("Channels count (%i) not available for playbacks: %s\n", channels, snd_strerror(err));
return err;
}
/* set the stream rate */
rrate = rate;
err = snd_pcm_hw_params_set_rate_near(handle, params, &rrate, 0);
if (err < 0) {
printf("Rate %iHz not available for playback: %s\n", rate, snd_strerror(err));
return err;
}
if (rrate != rate) {
printf("Rate doesn't match (requested %iHz, get %iHz)\n", rate, err);
return -EINVAL;
}
else printf("Sampling rate set to %i Hz\n", rate, err);
/* set the buffer size */
size = buffer_size;
err = snd_pcm_hw_params_set_buffer_size_near(handle, params, &size);
if (err < 0) {
printf("Unable to set buffer size %i for capture: %s\n", (int) buffer_size, snd_strerror(err));
return err;
}
if (size != buffer_size) {
printf("Buffer size doesn't match (requested %i , get %i )\n", (int) buffer_size, (int) size);
return -EINVAL;
}
else printf("Buffer size set to %i \n", (int) size);
/* set the period size */
size = period_size;
err = snd_pcm_hw_params_set_period_size_near(handle, params, &size, &dir);
if (err < 0) {
printf("Unable to set period size %i for capture: %s\n", (int) period_size, snd_strerror(err));
return err;
}
if (size != period_size) {
printf("Period size doesn't match (requested %i, get %i)\n", (int) period_size, (int) size);
return -EINVAL;
}
else printf("Period size set to %i \n", (int) size);
/* write the parameters to device */
err = snd_pcm_hw_params(handle, params);
if (err < 0) {
printf("Unable to set hw params for playback: %s\n", snd_strerror(err));
return err;
}
return 0;
}
static int set_swparams(snd_pcm_t *handle, snd_pcm_sw_params_t *swparams)
{
int err;
/* get the current swparams */
err = snd_pcm_sw_params_current(handle, swparams);
if (err < 0) {
printf("Unable to determine current swparams for playback: %s\n", snd_strerror(err));
return err;
}
/* start the transfer when the buffer is almost full: */
/* (buffer_size / avail_min) * avail_min */
err = snd_pcm_sw_params_set_start_threshold(handle, swparams, (buffer_size / period_size) * period_size);
if (err < 0) {
printf("Unable to set start threshold mode for playback: %s\n", snd_strerror(err));
return err;
}
/* allow the transfer when at least period_size samples can be processed */
/* or disable this mechanism when period event is enabled (aka interrupt like style processing) */
err = snd_pcm_sw_params_set_avail_min(handle, swparams, period_event ? buffer_size : period_size);
if (err < 0) {
printf("Unable to set avail min for playback: %s\n", snd_strerror(err));
return err;
}
/* enable period events when requested */
if (period_event) {
err = snd_pcm_sw_params_set_period_event(handle, swparams, 1);
if (err < 0) {
printf("Unable to set period event: %s\n", snd_strerror(err));
return err;
}
}
/* write the parameters to the playback device */
err = snd_pcm_sw_params(handle, swparams);
if (err < 0) {
printf("Unable to set sw params for playback: %s\n", snd_strerror(err));
return err;
}
return 0;
}
struct async_private_data {
signed short *samples;
snd_pcm_channel_area_t *areas;
unsigned int period;
};
/////////// CALL BACK STUFF ///////////////////
static void async_capture_callback(snd_async_handler_t *ahandler)
{
snd_pcm_t *handle = snd_async_handler_get_pcm(ahandler);
int err;
unsigned int i, n;
short signal[300000];
/*signal = calloc( (unsigned int) period_size, sizeof(short) );
if (signal = NULL) printf("memory allocation failed");*/
while (snd_pcm_avail_update(handle) >= period_size) { // read until data is ready in buffer
err = snd_pcm_readi(handle, signal, period_size);
if (err < 0) {
printf("Read error: %s\n", snd_strerror(err));
exit(EXIT_FAILURE);
}
if (err != period_size) {
printf("Read error: red %i expected %li\n", err, period_size);
exit(EXIT_FAILURE);
}
n=0;
i=0;
do {
inl[n]= signal[i];
inr[n]= signal[i+1];
n++;
i+=2;
} while (n < period_size);
fftw_execute(fft_plan_left);
fftw_execute(fft_plan_right);
for(i=0; i < frequency_bins; i++) spect_avg_left[i] += sqrt( (outl[i][0] * outl[i][0]) + (outl[i][1] * outl[i][1]) ); //acumulate average spectrum
for(i=0; i < frequency_bins; i++) spect_avg_right[i] += sqrt( (outr[i][0] * outr[i][0]) + (outr[i][1] * outr[i][1]) ); //acumulate average spectrum
period++;
}
if (period > 100)
{
for(i=0; i < frequency_bins; i++) spect_avg_left[i] = spect_avg_left[i]/100;
for(i=0; i < frequency_bins; i++) spect_avg_right[i] = spect_avg_right[i]/100;
out=fopen("/tmp/sidspect","w");
for(i=0; i < frequency_bins; i++)
{
fprintf(out,"%6f %6f %6f\n",(i+0.5)*df, spect_avg_left[i], spect_avg_right[i]);
spect_avg_left[i]=0;
spect_avg_right[i]=0;
}
fclose(out);
period=0;
}
// free(signal);
}
int main(int argc, char *argv[])
{
snd_pcm_t *playback_handle, *capture_handle;
int err;
snd_pcm_hw_params_t *hwparams;
snd_pcm_sw_params_t *swparams;
signed short *frame; // pointer to array of samples
unsigned int chn;
snd_pcm_channel_area_t *areas;
struct async_private_data data;
snd_async_handler_t *chandler;
snd_pcm_hw_params_alloca(&hwparams);
snd_pcm_sw_params_alloca(&swparams);
printf("SID monitor 2.0 starting work.. \n");
//open and set capture device
if ((err = snd_pcm_open(&capture_handle, device, SND_PCM_STREAM_CAPTURE, 0)) < 0) {
printf("Playback open error: %s\n", snd_strerror(err));
return 0;
}
if ((err = set_hwparams(capture_handle, hwparams, 2)) < 0) {
printf("Setting of hwparams failed: %s\n", snd_strerror(err));
exit(EXIT_FAILURE);
}
if ((err = set_swparams(capture_handle, swparams)) < 0) {
printf("Setting of swparams failed: %s\n", snd_strerror(err));
exit(EXIT_FAILURE);
}
frequency_bins = period_size/2 + 1;
spect_avg_left = calloc(frequency_bins, sizeof (double)); //allocate space for frrequency spectrum
spect_avg_right = calloc(frequency_bins, sizeof (double));
// register capture callback
err = snd_async_add_pcm_handler(&chandler, capture_handle, async_capture_callback, &data); // fill by dummy &data
if (err < 0) {
printf("Unable to register async handler\n");
exit(EXIT_FAILURE);
}
// setup fft
df = (double) rate/ (double) frequency_bins * 2.0;
inl = fftw_malloc(sizeof(double) * period_size); // period_size);
outl = fftw_malloc(sizeof(fftw_complex) * frequency_bins);
inr = fftw_malloc(sizeof(double) * period_size); // period_size);
outr = fftw_malloc(sizeof(fftw_complex) * frequency_bins);
fft_plan_left = fftw_plan_dft_r2c_1d(period_size, inl, outl, FFTW_ESTIMATE);
fft_plan_right = fftw_plan_dft_r2c_1d(period_size, inr, outr, FFTW_ESTIMATE);
period=0;
//start capture
if ((err = snd_pcm_prepare (capture_handle)) < 0) {
fprintf (stderr, "cannot prepare audio interface for use (%s)\n",
snd_strerror (err));
exit (1);
}
err = snd_pcm_start(capture_handle);
if (err < 0) {
printf("Start error: %s\n", snd_strerror(err));
exit(EXIT_FAILURE);
}
// wait for interrupt
printf("processing audio input.. \n");
while(1) usleep(1000);
snd_pcm_close(capture_handle);
return 0;
}
