A set of tools for configuring the Logitech G19 keyboard.
Based in:
https://github.com/Gnome15/gnome15
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.
285 lines
9.6 KiB
285 lines
9.6 KiB
/*
|
|
*
|
|
*+ Copyright (c) 2009 Ian Halpern
|
|
*@ http://impulse.ian-halpern.com
|
|
*
|
|
* This file is part of Impulse.
|
|
*
|
|
* Impulse is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* Impulse is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with Impulse. If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#include <pulse/pulseaudio.h>
|
|
#include <assert.h>
|
|
#include <string.h>
|
|
#include <fftw3.h>
|
|
#include <math.h>
|
|
|
|
#define CHUNK 1024
|
|
|
|
static const long fft_max[] = { 12317168L, 7693595L, 5863615L, 4082974L, 5836037L, 4550263L, 3377914L, 3085778L, 3636534L, 3751823L, 2660548L, 3313252L, 2698853L, 2186441L, 1697466L, 1960070L, 1286950L, 1252382L, 1313726L, 1140443L, 1345589L, 1269153L, 897605L, 900408L, 892528L, 587972L, 662925L, 668177L, 686784L, 656330L, 1580286L, 785491L, 761213L, 730185L, 851753L, 927848L, 891221L, 634291L, 833909L, 646617L, 804409L, 1015627L, 671714L, 813811L, 689614L, 727079L, 853936L, 819333L, 679111L, 730295L, 836287L, 1602396L, 990827L, 773609L, 733606L, 638993L, 604530L, 573002L, 634570L, 1015040L, 679452L, 672091L, 880370L, 1140558L, 1593324L, 686787L, 781368L, 605261L, 1190262L, 525205L, 393080L, 409546L, 436431L, 723744L, 765299L, 393927L, 322105L, 478074L, 458596L, 512763L, 381303L, 671156L, 1177206L, 476813L, 366285L, 436008L, 361763L, 252316L, 204433L, 291331L, 296950L, 329226L, 319209L, 258334L, 388701L, 543025L, 396709L, 296099L, 190213L, 167976L, 138928L, 116720L, 163538L, 331761L, 133932L, 187456L, 530630L, 131474L, 84888L, 82081L, 122379L, 82914L, 75510L, 62669L, 73492L, 68775L, 57121L, 94098L, 68262L, 68307L, 48801L, 46864L, 61480L, 46607L, 45974L, 45819L, 45306L, 45110L, 45175L, 44969L, 44615L, 44440L, 44066L, 43600L, 57117L, 43332L, 59980L, 55319L, 54385L, 81768L, 51165L, 54785L, 73248L, 52494L, 57252L, 61869L, 65900L, 75893L, 65152L, 108009L, 421578L, 152611L, 135307L, 254745L, 132834L, 169101L, 137571L, 141159L, 142151L, 211389L, 267869L, 367730L, 256726L, 185238L, 251197L, 204304L, 284443L, 258223L, 158730L, 228565L, 375950L, 294535L, 288708L, 351054L, 694353L, 477275L, 270576L, 426544L, 362456L, 441219L, 313264L, 300050L, 421051L, 414769L, 244296L, 292822L, 262203L, 418025L, 579471L, 418584L, 419449L, 405345L, 739170L, 488163L, 376361L, 339649L, 313814L, 430849L, 275287L, 382918L, 297214L, 286238L, 367684L, 303578L, 516246L, 654782L, 353370L, 417745L, 392892L, 418934L, 475608L, 284765L, 260639L, 288961L, 301438L, 301305L, 329190L, 252484L, 272364L, 261562L, 208419L, 203045L, 229716L, 191240L, 328251L, 267655L, 322116L, 509542L, 498288L, 341654L, 346341L, 451042L, 452194L, 467716L, 447635L, 644331L, 1231811L, 1181923L, 1043922L, 681166L, 1078456L, 1088757L, 1221378L, 1358397L, 1817252L, 1255182L, 1410357L, 2264454L, 1880361L, 1630934L, 1147988L, 1919954L, 1624734L, 1373554L, 1865118L, 2431931L };
|
|
|
|
static uint32_t source_index = 0;
|
|
static int context_ready = 0;
|
|
static int16_t buffer[ CHUNK / 2 ], snapshot[ CHUNK / 2 ];
|
|
static size_t buffer_index = 0;
|
|
|
|
static pa_context *context = NULL;
|
|
static pa_stream *stream = NULL;
|
|
static pa_threaded_mainloop* mainloop = NULL;
|
|
static pa_io_event* stdio_event = NULL;
|
|
static pa_mainloop_api *mainloop_api = NULL;
|
|
static char *stream_name = NULL, *client_name = NULL, *device = NULL;
|
|
|
|
static pa_sample_spec sample_spec = {
|
|
.format = PA_SAMPLE_S16LE,
|
|
.rate = 44100,
|
|
.channels = 2
|
|
};
|
|
|
|
static pa_stream_flags_t flags = 0;
|
|
|
|
static pa_channel_map channel_map;
|
|
static int channel_map_set = 0;
|
|
|
|
/* A shortcut for terminating the application */
|
|
static void quit( int ret ) {
|
|
assert( mainloop_api );
|
|
mainloop_api->quit( mainloop_api, ret );
|
|
}
|
|
|
|
static void unmute_source_success_cb( pa_context *c, int success, void *userdata ) {
|
|
printf("unmute: %d\n", success);
|
|
}
|
|
|
|
static void get_source_info_callback( pa_context *c, const pa_source_info *i, int is_last, void *userdata ) {
|
|
|
|
if ( !i )
|
|
return;
|
|
|
|
printf("source index: %u\n", i->index );
|
|
|
|
// snprintf(t, sizeof(t), "%u", i->monitor_of_sink);
|
|
|
|
// if ( i->monitor_of_sink != PA_INVALID_INDEX ) {
|
|
puts( i->name );
|
|
// if ( device && strcmp( device, i->name ) == 0 ) return;
|
|
|
|
device = pa_xstrdup( i->name );
|
|
|
|
if ( ( pa_stream_connect_record( stream, device, NULL, flags ) ) < 0 ) {
|
|
fprintf(stderr, "pa_stream_connect_record() failed: %s\n", pa_strerror(pa_context_errno(c)));
|
|
quit(1);
|
|
}
|
|
// }
|
|
}
|
|
|
|
/* This is called whenever new data is available */
|
|
static void stream_read_callback(pa_stream *s, size_t length, void *userdata) {
|
|
const void *data;
|
|
assert(s);
|
|
assert(length > 0);
|
|
// printf("stream index: %d\n", pa_stream_get_index( s ) );
|
|
if (stdio_event)
|
|
mainloop_api->io_enable(stdio_event, PA_IO_EVENT_OUTPUT);
|
|
|
|
if (pa_stream_peek(s, &data, &length) < 0) {
|
|
fprintf(stderr, "pa_stream_peek() failed: %s\n", pa_strerror(pa_context_errno(context)));
|
|
quit(1);
|
|
return;
|
|
}
|
|
|
|
assert(data);
|
|
assert(length > 0);
|
|
|
|
int excess = buffer_index * 2 + length - ( CHUNK );
|
|
|
|
if ( excess < 0 ) excess = 0;
|
|
|
|
memcpy( buffer + buffer_index, data, length - excess );
|
|
buffer_index += ( length - excess ) / 2;
|
|
|
|
if ( excess ) {
|
|
memcpy( snapshot, buffer, buffer_index * 2 );
|
|
buffer_index = 0;
|
|
}
|
|
|
|
pa_stream_drop(s);
|
|
}
|
|
|
|
static void stream_state_callback( pa_stream *s, void* userdata );
|
|
|
|
static void init_source_stream_for_recording() {
|
|
|
|
if (!(stream = pa_stream_new( context, stream_name, &sample_spec, channel_map_set ? &channel_map : NULL))) {
|
|
fprintf(stderr, "pa_stream_new() failed: %s\n", pa_strerror(pa_context_errno(context)));
|
|
quit(1);
|
|
}
|
|
|
|
pa_stream_set_read_callback(stream, stream_read_callback, NULL);
|
|
pa_stream_set_state_callback( stream, stream_state_callback, NULL );
|
|
pa_operation_unref( pa_context_set_source_mute_by_index( context, source_index, 0, unmute_source_success_cb, NULL ) );
|
|
pa_operation_unref( pa_context_get_source_info_by_index( context, source_index, get_source_info_callback, NULL ) );
|
|
}
|
|
|
|
static void stream_state_callback( pa_stream *s, void* userdata ) {
|
|
if ( pa_stream_get_state( s ) == PA_STREAM_TERMINATED ) {
|
|
pa_stream_unref( stream );
|
|
init_source_stream_for_recording();
|
|
}
|
|
}
|
|
|
|
static void context_state_callback( pa_context *c, void *userdata ) {
|
|
|
|
switch (pa_context_get_state(c)) {
|
|
case PA_CONTEXT_CONNECTING:
|
|
case PA_CONTEXT_AUTHORIZING:
|
|
case PA_CONTEXT_SETTING_NAME:
|
|
break;
|
|
case PA_CONTEXT_READY:
|
|
assert(c);
|
|
assert(!stream);
|
|
|
|
/*if (!(stream = pa_stream_new(c, stream_name, &sample_spec, channel_map_set ? &channel_map : NULL))) {
|
|
fprintf(stderr, "pa_stream_new() failed: %s\n", pa_strerror(pa_context_errno(c)));
|
|
quit(1);
|
|
}
|
|
|
|
pa_stream_set_read_callback(stream, stream_read_callback, NULL);*/
|
|
init_source_stream_for_recording();
|
|
|
|
break;
|
|
case PA_CONTEXT_TERMINATED:
|
|
quit(0);
|
|
break;
|
|
|
|
case PA_CONTEXT_FAILED:
|
|
default:
|
|
fprintf(stderr, "Connection failure: %s\n", pa_strerror(pa_context_errno(c)));
|
|
quit(1);
|
|
}
|
|
}
|
|
|
|
void im_stop (void) {
|
|
|
|
pa_threaded_mainloop_stop( mainloop );
|
|
|
|
//printf( "exit\n" );
|
|
}
|
|
|
|
void im_setSourceIndex( uint32_t index ) {
|
|
source_index = index;
|
|
if ( !stream ) return;
|
|
|
|
if ( pa_stream_get_state( stream ) != PA_STREAM_UNCONNECTED )
|
|
pa_stream_disconnect( stream );
|
|
else
|
|
init_source_stream_for_recording();
|
|
}
|
|
|
|
double *im_getSnapshot( int fft ) {
|
|
|
|
static double magnitude[ CHUNK / 4 ];
|
|
|
|
if ( ! fft ) {
|
|
int i;
|
|
for ( i = 0; i < CHUNK / 2; i += sample_spec.channels ) {
|
|
magnitude[ i / sample_spec.channels ] = 0;
|
|
int j;
|
|
for ( j = 0; j < sample_spec.channels; j++ )
|
|
magnitude[ i / sample_spec.channels ] += fabs( ( (double) snapshot[ i + j ] / ( pow( 2, 16 ) / 2 ) ) / sample_spec.channels );
|
|
}
|
|
} else {
|
|
|
|
double *in;
|
|
fftw_complex *out;
|
|
fftw_plan p;
|
|
|
|
in = (double*) malloc( sizeof( double ) * ( CHUNK / 2 ) );
|
|
out = (fftw_complex*) fftw_malloc( sizeof( fftw_complex ) * ( CHUNK / 2 ) );
|
|
|
|
if ( snapshot != NULL ) {
|
|
int i;
|
|
for ( i = 0; i < CHUNK / 2; i++ ) {
|
|
in[ i ] = (double) snapshot[ i ];
|
|
}
|
|
}
|
|
|
|
p = fftw_plan_dft_r2c_1d( CHUNK / 2, in, out, 0 );
|
|
|
|
fftw_execute( p );
|
|
|
|
fftw_destroy_plan( p );
|
|
|
|
if ( out != NULL ) {
|
|
int i;
|
|
for ( i = 0; i < CHUNK / 2 / sample_spec.channels; i++ ) {
|
|
magnitude[ i ] = (double) sqrt( pow( out[ i ][ 0 ], 2 ) + pow( out[ i ][ 1 ], 2 ) ) / (double) fft_max[ i ];
|
|
if ( magnitude[ i ] > 1.0 ) magnitude[ i ] = 1.0;
|
|
}
|
|
}
|
|
|
|
free( in );
|
|
fftw_free(out);
|
|
}
|
|
|
|
return magnitude; // PyString_FromStringAndSize( (char *) snapshot, CHUNK );
|
|
}
|
|
|
|
|
|
void im_start ( void ) {
|
|
|
|
// Pulseaudio
|
|
int r;
|
|
char *server = NULL;
|
|
|
|
client_name = pa_xstrdup( "impulse" );
|
|
stream_name = pa_xstrdup( "impulse" );
|
|
|
|
// Set up a new main loop
|
|
|
|
if ( ! ( mainloop = pa_threaded_mainloop_new( ) ) ) {
|
|
fprintf( stderr, "pa_mainloop_new() failed.\n" );
|
|
return;
|
|
}
|
|
|
|
mainloop_api = pa_threaded_mainloop_get_api( mainloop );
|
|
|
|
r = pa_signal_init( mainloop_api );
|
|
assert( r == 0 );
|
|
|
|
/*if (!(stdio_event = mainloop_api->io_new(mainloop_api,
|
|
STDOUT_FILENO,
|
|
PA_IO_EVENT_OUTPUT,
|
|
stdout_callback, NULL))) {
|
|
fprintf(stderr, "io_new() failed.\n");
|
|
goto quit;
|
|
}*/
|
|
|
|
// create a new connection context
|
|
if ( ! ( context = pa_context_new( mainloop_api, client_name ) ) ) {
|
|
fprintf( stderr, "pa_context_new() failed.\n" );
|
|
return;
|
|
}
|
|
|
|
pa_context_set_state_callback( context, context_state_callback, NULL );
|
|
|
|
/* Connect the context */
|
|
pa_context_connect( context, server, 0, NULL );
|
|
|
|
// pulseaudio thread
|
|
pa_threaded_mainloop_start( mainloop );
|
|
|
|
return;
|
|
}
|
|
|