HB9EIK	Courses	Speech	Projects	Photos	Code	My Profile
2013-03-28 Easter Egg 2011-06-12 OpenGL Radio Interface 2010-08-07 "Analog" encoder 2010-06-18 MyLinScope V4.0 code 2009-02-16 MyLinScope V2 screenshots 2009-02-15 MyLinScope V2 code 2008-05-24 MySqlManager code 2008-05-22 MyLinScope code 2008-05-19 MyLinScope Screenshots	MyLinScopeV4.0 by HB9EIK ====== README ====== Licenced as per GPLv3 by HB9EIK =============================== CAUTION ======= This is experimental you must be root to use it make this at your own risk To compile ========== make To run only oscilloscope ======================== make oscill To run all ========== make run To run all with debug ===================== make debug Config files ============ Simple -> oscill.conf Complex -> video.conf ======== Makefile ======== all: libMyIo.so libMyMath.so video my.html MyLinScopeV4.0.zip run: all xdefaults export LD_LIBRARY_PATH=.;./video debug: all xdefaults export LD_LIBRARY_PATH=.;./video -d1 oscill: all xdefaults export LD_LIBRARY_PATH=.;./video -f oscill.conf clean: rm *.o *.so my.html video *.zip .c.o: gcc -Wall -fPIC -c $*.c libMyFuncs.so: myfuncs.o scope.h gcc -shared -Wl,-soname,libMyFuncs.so -o libMyFuncs.so myfuncs.o libMyIo.so: dsp.o scope.h gcc -shared -Wl,-soname,libMyIo.so -o libMyIo.so dsp.o libMyMath.so: fft.o scope.h gcc -shared -Wl,-soname,libMyMath.so -o libMyMath.so fft.o video: video.c scope.h libMyFuncs.so cc -o video video.c -rdynamic -L. -lMyFuncs -lm -lXm -lXt -lX11 -L. -lpthread -lm install: cat Xdefaults >> ~/.Xdefaults xdefaults: xrdb -load ~/.Xdefaults MyLinScopeV4.0.zip: dsp.c fft.c scope.h video.c myfuncs.c Xdefaults Makefile zip myLinScopeV4.0.zip *.c *.h Makefile libMyFuncs.so libMyIo.so libMyMath.so video Presentazione.* my.html: dsp.c fft.c scope.h video.c myfuncs.c Xdefaults Makefile video.conf oscill.conf README echo "MyLinScopeV4.0 by HB9EIK" >my.html echo "======" >>my.html echo "README" >>my.html echo "======" >>my.html cat README >>my.html echo "========" >>my.html echo "Makefile" >>my.html echo "========" >>my.html cat Makefile >>my.html echo "=========" >>my.html echo "Xdefaults" >>my.html echo "=========" >>my.html cat Xdefaults >>my.html echo "=====" >>my.html echo "dsp.c" >>my.html echo "=====" >>my.html cat dsp.c >>my.html echo "=======" >>my.html echo "scope.h" >>my.html echo "=======" >>my.html cat scope.h >>my.html echo "=====" >>my.html echo "fft.c" >>my.html echo "=====" >>my.html cat fft.c >>my.html echo "=========" >>my.html echo "myfuncs.c" >>my.html echo "=========" >>my.html cat myfuncs.c >>my.html echo "=======" >>my.html echo "video.c" >>my.html echo "=======" >>my.html cat video.c >>my.html echo "==========" >>my.html echo "video.conf" >>my.html echo "==========" >>my.html cat video.conf >>my.html echo "===========" >>my.html echo "oscill.conf" >>my.html echo "===========" >>my.html cat oscill.conf >>my.html ========= Xdefaults ========= // .Xdefaults // HB9EIK.width: 680 HB9EIK.height: 550 HB9EIK*foreground: red HB9EIK*background: white ===== dsp.c ===== // Licenced as per GPLv3 by HB9EIK #include <unistd.h> #include <fcntl.h> #include <sys/types.h> #include <sys/ioctl.h> #include <stdlib.h> #include <stdio.h> #include <linux/soundcard.h> #include <sys/timeb.h> #include <signal.h> #include <pthread.h> #include <string.h> #include <semaphore.h> #include "scope.h" int inizializza_audio( parmp datas ); #define RATE (48000) /* the sampling rate */ #define SIZE 16 /* sample size: 8 or 16 bits */ #define CHANNELS 1 /* 1 = mono 2 = stereo */ void *thread_input( void * ); void *thread_output( void * ); int fd=(-1); /* sound device file descriptor */ static int sread, swrite; static int terminate=1; static int debug=0; static pthread_t thread_in; static struct sched_param prio_in; static pthread_t thread_out; static struct sched_param prio_out; int DspHalt( parmp parms ) { terminate = 0; return( 1 ); } int DspIn( parmp datas ) { int arg; /* argument for ioctl calls */ int status; /* return status of system calls */ int slice; terminate = 1; slice = *(datas->howManyLocation); sread = slice * SIZE * CHANNELS / 8; swrite = slice * CHANNELS; /* open sound device */ fd = open( datas->inFileName, O_RDWR|O_DSYNC ); if( fd < 0 ) { fprintf( stderr, "Unable to open %s\n", datas->inFileName ); perror( "open of dsp failed" ); exit(1); } /* set sampling parameters */ arg = SIZE; /* sample size */ status = ioctl( fd, SOUND_PCM_WRITE_BITS, &arg ); if( status == -1 ) { perror( "SOUND_PCM_WRITE_BITS ioctl failed" ); } if( arg != SIZE ) { fprintf( stderr, "unable to set sample size: wanted %d got %d\n", SIZE, arg ); perror( "unable to set sample size" ); } arg = CHANNELS; /* mono or stereo */ status = ioctl( fd, SOUND_PCM_WRITE_CHANNELS, &arg ); if( status == -1 ) { perror( "SOUND_PCM_WRITE_CHANNELS ioctl failed" ); } if( arg != CHANNELS ) { fprintf( stderr, "unable to set channels: wanted %d got %d\n", CHANNELS, arg ); perror( "unable to set number of channels" ); } arg = RATE; /* sampling rate */ status = ioctl( fd, SOUND_PCM_WRITE_RATE, &arg ); if( status == -1 ) { fprintf( stderr, "unable to set rate: wanted %d got %d\n", RATE, arg ); perror( "SOUND_PCM_WRITE_WRITE ioctl failed" ); } status = pthread_create( &thread_in, NULL, thread_input, (void *)datas ); if( status ) { perror( "Error creating dsp read thread\n" ); exit( 1 ); } prio_in.sched_priority = 4; pthread_setschedparam( thread_in, SCHED_RR, &prio_in ); return 0; } int DspOut( parmp datas ) { int status; status = pthread_create( &thread_out, NULL, thread_output, (void *)datas ); if( status ) { perror( "Error creating dsp write thread\n" ); exit( 1 ); } prio_out.sched_priority = 8; pthread_setschedparam( thread_out, SCHED_RR, &prio_out ); return( 0 ); } void *thread_input( void *arg ) { int status; /* return status of system calls */ char *buf; double *duf; int j; parmp parms; parms = (parmp) arg; buf = calloc( sread, sizeof(char) ); if( buf == NULL ) { perror( "error allocating device buffer" ); exit(1); } debug = parms->debug; duf = parms->outFileLocation; if( duf == NULL ) { perror( "error allocating fifo buffer" ); exit(1); } for( ;terminate ; ) { status = read( fd, buf, sread ); if( status != sread && debug == 1) { perror( "in read wrong number of bytes" ); } if( debug == 1) { fprintf( stderr, "in read %d bytes\n", status ); } switch( SIZE ) { case 8: for( j=0; j<swrite; j++ ) { duf[*( parms->outFilePosition )] = ( double ) 65536 * ( ( unsigned char ) buf[j] - 127 ); *( parms->outFilePosition ) = *( parms->outFilePosition )+1; *( parms->outFilePosition ) %= FIFO_LENGTH; } break; case 16: for( j=0; j<swrite; j++ ) { duf[*( parms->outFilePosition )] = ( double ) 256 * ( buf[j*2] + 256 * buf[j*2+1] ); *( parms->outFilePosition ) = *( parms->outFilePosition )+1; *( parms->outFilePosition ) %= FIFO_LENGTH; } break; case 24: for( j=0; j<swrite; j++ ) { duf[*( parms->outFilePosition )] = ( double ) ( buf[j*3] + 256 * buf[j*3+1] + 65536 * buf[j*3+2] ); *( parms->outFilePosition ) = *( parms->outFilePosition )+1; *( parms->outFilePosition ) %= FIFO_LENGTH; } break; } } free( buf ); pthread_exit( NULL ); } void *thread_output( void *arg ) { int status; /* return status of system calls */ char *buf; double *duf; int j; parmp parms; int position=0; int arrived; int k; int l; parms = (parmp) arg; buf = calloc( FIFO_LENGTH, sizeof(char) ); if( buf == NULL ) { perror( "error allocating device buffer" ); exit(1); } duf = parms->inFileLocation; for( k=0;terminate ; ) { arrived = *(parms->inFilePosition); switch( SIZE ) { case 8: for( j=0; arrived != position; j++ ) { buf[k+j]= 127 + ( unsigned char ) ( duf[position] / 65536 ); position++; position %= FIFO_LENGTH; l=j; } break; case 16: for( j=0; arrived != position; j++ ) { buf[k+j*2+1]=( unsigned char ) ( duf[position] / 65536 ); buf[k+j*2]=( unsigned char )( duf[position] - buf[k+j*2+1] * 65526 ); position++; position %= FIFO_LENGTH; l = j*2+2; } break; case 24: for( j=0; j<swrite; j++ ) { buf[k+j*3+2]=( unsigned char ) ( duf[position] / 65536 ); buf[k+j*3+1]=( unsigned char ) ( duf[position] - buf[j*2+1] * 65526 ) / 256; buf[k+j*3]=( unsigned char ) duf[position] - buf[j*2+2] * 65526 - buf[j*2+1] * 256; position++; position %= FIFO_LENGTH; l = j*3+3; } break; } if( l ) { status = write( fd, buf+k, l ); if( status != j && debug == 1) { perror( "out write wrong number of bytes on output device" ); } if( debug == 1) { fprintf( stderr, "out write %d bytes on output device\n", status ); } k=k+l; if( 2*k > FIFO_LENGTH ) { k=0; } } else { usleep( 200 ); } } free( buf ); pthread_exit( NULL ); } ======= scope.h ======= // Licenced as per GPLv3 by HB9EIK #include <X11/Intrinsic.h> #include <X11/StringDefs.h> #include <Xm/Xm.h> #include <Xm/DrawingA.h> #include <Xm/Form.h> #include <X11/Xutil.h> #include <Xm/Label.h> #include <Xm/Text.h> #include <Xm/RowColumn.h> #include <Xm/ToggleB.h> #include <Xm/PushB.h> #include <Xm/Protocols.h> #include <unistd.h> #include <fcntl.h> #include <sys/types.h> #include <sys/ioctl.h> #include <stdlib.h> #include <stdio.h> #include <math.h> #include <sys/time.h> #include <sys/timeb.h> #include <dlfcn.h> #include <pthread.h> //#define FIFO_LENGTH 4194304 #define FIFO_LENGTH 16777216 typedef struct _function { char *name; char *inFileName; char *howMany; char *outFileName; char *library; char *function; char *inEvent; char *outEvent; } function, *functionp; typedef struct _intFiles { char *fileName; double *location; int position; } intFile, *intFilep; typedef struct _intDataPreloads { char *dataName; char *dataPointer; } intDataPreload, *intDataPreloadp; typedef struct _intDatas { char *dataName; int *dataPointer; } intData, *intDatap; typedef struct _intHandles { char *libraryName; void *libHandle; } intHandle, *intHandlep; typedef struct { Dimension width, height; int background, foreground; double maxlevel; intDatap value; int number; int debug; int started; XtAppContext context; } image_data, *image_data_ptr; typedef struct _parm { char *inFileName; double *inFileLocation; int *inFilePosition; int *howManyLocation; char *outFileName; double *outFileLocation; int *outFilePosition; int *inEventLocation; int *outEventLocation; int debug; image_data_ptr data; } parm, *parmp; typedef struct _command { char *type; char *title; char *dataname; char *multiplier; char *value; char *operation; } command, *commandp; typedef struct _otherdata { Widget upperwidget; int *datapointer; int multiplier; int operation; } otherdata, *otherdatap; #define INT_FILES 1 #define INT_DATAS 2 #define INT_HANDLES 3 void myalloc( char *object, int *where, char **dati, size_t size, int *howMany, int what ); void myinitialize( int *height, int *how_many, char *nome, image_data_ptr data, int *commandN, commandp *commands ); int *valore( image_data_ptr data, char *nome ); int *setvalore( image_data_ptr data, char *nome, int *valore ); void readConf( int *height, int *how_many, char *file, int *intDatasPreloadN, intDataPreloadp *intDatasPreloadp, int *functionN, functionp *functions, int *commandN, commandp *commands ); ===== fft.c ===== // Licenced as per GPLv3 by HB9EIK #include <unistd.h> #include <fcntl.h> #include <stdlib.h> #include <stdio.h> #include <sys/timeb.h> #include <signal.h> #include <pthread.h> #include <math.h> #include "scope.h" int terminate = 1; static int fftbuffer; static int debug; static struct sched_param prio; static pthread_t thread_ff; void *thread_fft( void * ); int FFT( parmp parms ) { int status; status = pthread_create( &thread_ff, NULL, thread_fft, (void *) parms ); if( status ) { perror( "Error creating FFT thread" ); exit( 1 ); } prio.sched_priority = 16; pthread_setschedparam( thread_ff, SCHED_RR, &prio ); return 0; } void *thread_fft( void *arg ) { double *co = NULL; double *si = NULL; double *yr = NULL; double *yi = NULL; double *fftr = NULL; double *ffti = NULL; int N; double co1, si1; double pi=3.141592653589793238462643383279502884197169399375105820974944592; double fftdr, fftdi, ymax; int j, k; int m, p, md, ng, ig, i, ind, i1, i2, jd, kp; parmp parms; double *duf; int position; int filepos = 0; struct timeb tb; int tempo; int oldtempo; parms = (parmp) arg; for( ;; ) { fftbuffer = *(parms->howManyLocation); debug = parms->debug; N = 1 << fftbuffer; fftr = calloc( N, sizeof( double ) ); if( fftr == NULL ) { perror( "error allocating fftr buffer" ); exit(1); } ffti = calloc( N, sizeof( double ) ); if( ffti == NULL ) { perror( "error allocating ffti buffer" ); exit(1); } yr = calloc( N, sizeof( double ) ); if( yr == NULL ) { perror( "error allocating yr buffer" ); exit(1); } yi = calloc( N, sizeof( double ) ); if( yi == NULL ) { perror( "error allocating yi buffer" ); exit(1); } co = calloc( N/2, sizeof( double ) ); if( co == NULL ) { perror( "error allocating co buffer" ); exit(1); } si = calloc( N/2, sizeof( double ) ); if( si == NULL ) { perror( "error allocating si buffer" ); exit(1); } // inizializzazione tabella dei seni m = N/2; p = fftbuffer; co1 = cos( pi/m ); si1 = -sin( pi/m ); co[0] = 1; si[0] = 0; for( j=1; j<m; j++ ) { co[j] = co1 * co[j-1] - si1 * si[j-1]; si[j] = si1 * co[j-1] + co1 * si[j-1]; } duf = parms->inFileLocation; for( ;fftbuffer == *(parms->howManyLocation); ) { // aspetta il via libera for( ;!*(parms->inEventLocation); usleep( 200 ) ); *(parms->inEventLocation)=0; position = ( *( parms->inFilePosition ) - N + FIFO_LENGTH ) % FIFO_LENGTH; /* Read input data */ for( j=0; j<N; j++ ) { fftr[j]=duf[position]; position++; position %= FIFO_LENGTH; } m = N/2; p = fftbuffer; ftime( &tb ); tempo=tb.time*1000+tb.millitm; oldtempo = tempo; for( j=0; j<N; j++ ) { ffti[j] = 0; } for( j=0,ng=1,md=m; j<p; j++ ) { for( ind=0, ig=0; ig<ng; ig++ ) { for( i=0, k=0; i<md; i++ ) { i1=ind+i; i2=i1+md; fftdr = fftr[i1] - fftr[i2]; fftdi = ffti[i1] - ffti[i2]; fftr[i1] = fftr[i1] + fftr[i2]; ffti[i1] = ffti[i1] + ffti[i2]; fftr[i2] = fftdr * co[k] - fftdi * si[k]; ffti[i2] = fftdr * si[k] + fftdi * co[k]; k += ng; } ind += md*2; } md >>= 1; ng <<= 1; } for( j=0; j<N; j++ ) { jd=j; k=0; kp=m; for( i=1; i<=p; i++ ) { k = k + (jd-(jd/2)*2)*kp; jd >>= 1; kp >>= 1; } if( k>j ) { fftdr = fftr[j]; fftdi = ffti[j]; fftr[j] = fftr[k]; ffti[j] = ffti[k]; fftr[k] = fftdr; ffti[k] = fftdi; } } ftime( &tb ); tempo=tb.time*1000+tb.millitm; if( debug==10 ) { printf( "%d\n", tempo-oldtempo ); } fftr[0] = 0; ffti[0] = 0; for( j=0; j<N; j++ ) { fftr[j] = fftr[j]/m; ffti[j] = ffti[j]/m; fftr[j] = sqrt( fftr[j] * fftr[j] + ffti[j] * ffti[j] ); if( ymax < fftr[j] ) { ymax = fftr[j]; } } /* Write output data */ for( j=0; j<N; j++ ) { (parms->outFileLocation)[filepos+j]=fftr[j]; } filepos+=N; *(parms->outFilePosition)=filepos; if( filepos > FIFO_LENGTH/2 ) { filepos=0; } if( debug == 1) { fprintf( stderr, "fft write %d bytes on output device\n", j ); } *(parms->outEventLocation)=1; } free( co ); free( si); free( yr); free( yi); free( fftr ); free( ffti ); } pthread_exit( NULL ); } ========= myfuncs.c ========= // Licenced as per GPLv3 by HB9EIK #include "scope.h" void myinitialize( int *points, int *how_many, char *nome, image_data_ptr data, int *commandN, commandp *commands ) { int j, jj; int k1, k2; intFilep intFiles; int FileN = 0; intDatap intDatas; int DataN = 0; parm *parms; intHandlep intHandles; int HandleN=0; int (*fn)( parmp ); char *error; intDataPreloadp intDatasPreload; int intDatasPreloadN; functionp functions; int functionN; readConf( points, how_many, nome, &intDatasPreloadN, &intDatasPreload, &functionN, &functions, commandN, commands ); parms = calloc( functionN, sizeof( parm ) ); if( parms == NULL ) { perror( "error allocating function parms" ); exit( 1 ); } for( j=0; j<intDatasPreloadN; j++ ) { k1 = -1; myalloc( intDatasPreload[j].dataName, &(k1), (char **)&intDatas, sizeof( intData ), &DataN, INT_DATAS ); if( data->debug == 1 ) { fprintf( stderr, "Data length %d\n", k1 ); } k2 = atoi( intDatasPreload[j].dataPointer ); *(intDatas[k1].dataPointer) = k2; } // two runs: myalloc works reallocating, so beware of the assignments! they must be done only after all realloc() // jj == 0: first round, in wich we alloc/realloc. jj == 1: last round: we assign pointer values for( jj=0; jj<2; jj++ ) { for( j=0; j<functionN ; j++ ) { k1 = -1; if( strlen( functions[j].inFileName ) && strncmp( functions[j].inFileName, "/dev/", 5 ) ) { myalloc( functions[j].inFileName, &(k1), (char **)&intFiles, sizeof( intFile ), &FileN, INT_FILES ); if( jj == 1 ) { parms[j].inFileLocation = intFiles[k1].location; parms[j].inFilePosition = &intFiles[k1].position; } } else { parms[j].inFileName = functions[j].inFileName; parms[j].inFileLocation = NULL; parms[j].inFilePosition = NULL; } k2 = -1; if( strlen( functions[j].outFileName ) && strncmp( functions[j].outFileName, "/dev/", 5 ) ) { myalloc( functions[j].outFileName, &(k2), (char **)&intFiles, sizeof( intFile ), &FileN, INT_FILES ); if( jj == 1 ) { parms[j].outFileLocation = intFiles[k2].location; parms[j].outFilePosition = &intFiles[k2].position; } } else { parms[j].outFileName = functions[j].outFileName; parms[j].outFileLocation = NULL; parms[j].outFilePosition = NULL; } if( data->debug == 1 ) { fprintf( stderr, "%s %s : Input file %d, Output file %d\n", functions[j].inFileName, functions[j].outFileName, k1, k2 ); } k1 = -1; if( strlen( functions[j].inEvent ) ) { myalloc( functions[j].inEvent, &(k1), (char **)&intDatas, sizeof( intData ), &DataN, INT_DATAS ); if( jj == 1 ) { parms[j].inEventLocation=intDatas[k1].dataPointer; } } else { parms[j].inEventLocation=NULL; } k2 = -1; if( strlen( functions[j].outEvent ) ) { myalloc( functions[j].outEvent, &(k2), (char **)&intDatas, sizeof( intData ), &DataN, INT_DATAS ); if( jj == 1 ) { parms[j].outEventLocation=intDatas[k2].dataPointer; } } else { parms[j].outEventLocation=NULL; } if( data->debug == 1 ) { fprintf( stderr, "%s %s: Input event %d, Output event %d\n", functions[j].inEvent, functions[j].outEvent, k1, k2 ); } k1 = -1; if( strlen( functions[j].howMany ) ) { myalloc( functions[j].howMany, &(k1), (char **)&intDatas, sizeof( intData ), &DataN, INT_DATAS ); if( jj == 1 ) { parms[j].howManyLocation = intDatas[k1].dataPointer; } } else { parms[j].howManyLocation = NULL; } if( jj == 1 ) { if( data->debug == 1 ) { fprintf( stderr, "Data length %d\n", k1 ); fprintf( stderr, "Data length %s %d\n", functions[j].howMany, k1 ); } parms[j].debug = data->debug; parms[j].data = data; k1 = -1; if( strlen( functions[j].library ) ) { myalloc( functions[j].library, &(k1), (char **)&intHandles, sizeof( intHandle ), &HandleN, INT_HANDLES ); fn = dlsym( intHandles[k1].libHandle, functions[j].function ); if ((error = dlerror()) != NULL) { fprintf(stderr, "error retrieving function %s\n", error); exit(1); } (*fn)( parms+j ); } else { myalloc( functions[j].library, &(k1), (char **)&intHandles, sizeof( intHandle ), &HandleN, INT_HANDLES ); fn = dlsym( intHandles[k1].libHandle, functions[j].function ); if ((error = dlerror()) != NULL) { fprintf(stderr, "error retrieving function %s\n", error); exit(1); } (*fn)( parms+j ); } } } } data->value = intDatas; data->number = DataN; return points; } void myalloc( char *object, int *where, char **dati, size_t size, int *howMany, int what ) { int k; char *s; for( k=0; k<(*howMany); k++ ) { switch( what ) { case INT_FILES: s = (*(intFilep *)dati)[k].fileName; break; case INT_DATAS: s = (*(intDatap *)dati)[k].dataName; break; } if( !strcmp( object, s ) ) { *where = k; break; } } if( *where < 0 ) { if( (*howMany) == 0 ) { *dati = calloc( 1, size ); if( *dati == NULL ) { perror( "error calloc-ating inFile 1" ); exit( 1 ); } } else { *dati = realloc( *dati, size * ( (*howMany) + 1 ) ); if( *dati == NULL ) { perror( "error realloc-ating inFile 1" ); exit( 1 ); } } switch( what ) { case INT_FILES: (*(intFilep *)dati)[(*howMany)].fileName=object; (*(intFilep *)dati)[(*howMany)].position=0; (*(intFilep *)dati)[(*howMany)].location = calloc( FIFO_LENGTH, 2 * sizeof( double ) ); if( (*(intFilep *)dati)[(*howMany)].location == NULL ) { perror( "error calloc-ating infile location 10" ); exit( 1 ); } break; case INT_DATAS: (*(intDatap *)dati)[(*howMany)].dataName=object; (*(intDatap *)dati)[(*howMany)].dataPointer=calloc( 1, sizeof( int ) ); if( (*(intDatap *)dati)[(*howMany)].dataPointer == NULL ) { perror( "error calloc-ating datas 5" ); exit( 1 ); } break; case INT_HANDLES: (*(intHandlep *)dati)[(*howMany)].libraryName=object; (*(intHandlep *)dati)[(*howMany)].libHandle = dlopen( object, RTLD_LAZY); if (!(*(intHandlep *)dati)[(*howMany)].libHandle) { fprintf(stderr, "error opening library %s\n", dlerror()); exit(1); } break; } *where = (*howMany); (*howMany)++; } } int *valore( image_data_ptr data, char *nome ) { int j; for( j=0; j<data->number; j++ ) { if( !strcmp( nome, data->value[j].dataName ) ) { return( data->value[j].dataPointer ); } } fprintf(stderr, "Variable %s not found\n", nome); fflush( stderr ); exit(1); } int *setvalore( image_data_ptr data, char *nome, int *valore ) { int j; for( j=0; j<data->number; j++ ) { if( !strcmp( nome, data->value[j].dataName ) ) { data->value[j].dataPointer = valore; return( data->value[j].dataPointer ); } } fprintf(stderr, "Variable %s not found\n", nome); exit(1); } void readConf( int *points, int *how_many, char *file, int *intDatasPreloadN, intDataPreloadp *intDatasPreloadp, int *functionN, functionp *functions, int *commandN, commandp *commands ) { FILE *fp; char buffer[200]; char *pp; int k1, k2; *points = 0; *how_many = 0; fp = fopen( file, "r" ); if( fp == NULL ) { fprintf( stderr, "Configuration file %s not found\n", file ); exit( 1 ); } *intDatasPreloadp = (intDataPreloadp) calloc( 1, sizeof( intDataPreload ) ); if( *intDatasPreloadp == NULL ) { fprintf( stderr, "Calloc error on intDatasPreload\n" ); exit( 1 ); } *intDatasPreloadN = 0; *functions = (functionp) calloc( 1, sizeof( function ) ); if( *functions == NULL ) { fprintf( stderr, "Calloc error on functions\n" ); exit( 1 ); } *functionN = 0; *commands = (commandp) calloc( 1, sizeof( command ) ); if( *commands == NULL ) { fprintf( stderr, "Calloc error on commands\n" ); exit( 1 ); } *commandN = 0; for( ;; ) { memset( buffer, 0, sizeof( buffer ) ); pp = fgets( buffer, sizeof( buffer ), fp ); if( pp == NULL ) { break; } if( pp[0] == '#' ) { continue; } pp[strlen( pp )-1] = '\0'; if( pp[0] == '1' ) { (*intDatasPreloadN)++; *intDatasPreloadp = (intDataPreloadp) realloc( (void *) *intDatasPreloadp, *intDatasPreloadN * sizeof( intDataPreload ) ); if( *intDatasPreloadp == NULL ) { fprintf( stderr, "Realloc error on intDatasPreload\n" ); exit( 1 ); } for( k1=0; pp[k1] && pp[k1]!=','; k1++ ); pp[k1] = '\0'; for( k2=k1+1; pp[k2] && pp[k2]!=','; k2++ ); pp[k2] = '\0'; (*intDatasPreloadp)[*intDatasPreloadN-1].dataName = XtNewString( pp+k1+1 ); (*intDatasPreloadp)[*intDatasPreloadN-1].dataPointer = XtNewString( pp+k2+1 ); } else if( pp[0] == '2' ) { (*functionN)++; *functions = (functionp) realloc( (void *) *functions, *functionN * sizeof( function ) ); if( *functions == NULL ) { fprintf( stderr, "Realloc error on functions\n" ); exit( 1 ); } for( k1=0; pp[k1] && pp[k1]!=','; k1++ ); pp[k1] = '\0'; for( k2=k1+1; pp[k2] && pp[k2]!=','; k2++ ); pp[k2] = '\0'; (*functions)[*functionN-1].name = XtNewString( pp+k1+1 ); for( k1=k2,k2=k1+1; pp[k2] && pp[k2]!=','; k2++ ); pp[k2] = '\0'; (*functions)[*functionN-1].inFileName = XtNewString( pp+k1+1 ); for( k1=k2,k2=k1+1; pp[k2] && pp[k2]!=','; k2++ ); pp[k2] = '\0'; (*functions)[*functionN-1].howMany = XtNewString( pp+k1+1 ); for( k1=k2,k2=k1+1; pp[k2] && pp[k2]!=','; k2++ ); pp[k2] = '\0'; (*functions)[*functionN-1].outFileName = XtNewString( pp+k1+1 ); for( k1=k2,k2=k1+1; pp[k2] && pp[k2]!=','; k2++ ); pp[k2] = '\0'; (*functions)[*functionN-1].library = XtNewString( pp+k1+1 ); for( k1=k2,k2=k1+1; pp[k2] && pp[k2]!=','; k2++ ); pp[k2] = '\0'; (*functions)[*functionN-1].function = XtNewString( pp+k1+1 ); for( k1=k2,k2=k1+1; pp[k2] && pp[k2]!=','; k2++ ); pp[k2] = '\0'; (*functions)[*functionN-1].inEvent = XtNewString( pp+k1+1 ); for( k1=k2,k2=k1+1; pp[k2] && pp[k2]!=','; k2++ ); pp[k2] = '\0'; (*functions)[*functionN-1].outEvent = XtNewString( pp+k1+1 ); } else if( pp[0] == '3' ) { (*commandN)++; *commands = (commandp) realloc( (void *) *commands, *commandN * sizeof( command ) ); if( *commands == NULL ) { fprintf( stderr, "Realloc error on commands\n" ); exit( 1 ); } for( k1=0; pp[k1] && pp[k1]!=','; k1++ ); pp[k1] = '\0'; for( k2=k1+1; pp[k2] && pp[k2]!=','; k2++ ); pp[k2] = '\0'; (*commands)[*commandN-1].type = XtNewString( pp+k1+1 ); for( k1=k2,k2=k1+1; pp[k2] && pp[k2]!=','; k2++ ); pp[k2] = '\0'; (*commands)[*commandN-1].title = XtNewString( pp+k1+1 ); for( k1=k2,k2=k1+1; pp[k2] && pp[k2]!=','; k2++ ); pp[k2] = '\0'; (*commands)[*commandN-1].dataname = XtNewString( pp+k1+1 ); for( k1=k2,k2=k1+1; pp[k2] && pp[k2]!=','; k2++ ); pp[k2] = '\0'; (*commands)[*commandN-1].multiplier = XtNewString( pp+k1+1 ); for( k1=k2,k2=k1+1; pp[k2] && pp[k2]!=','; k2++ ); pp[k2] = '\0'; (*commands)[*commandN-1].value = XtNewString( pp+k1+1 ); for( k1=k2,k2=k1+1; pp[k2] && pp[k2]!=','; k2++ ); pp[k2] = '\0'; (*commands)[*commandN-1].operation = XtNewString( pp+k1+1 ); if( ((*commands)[*commandN-1].type)[0]=='1' ) { if( strlen( (*commands)[*commandN-1].operation ) < 3 ) { (*points)++; } else { (*points)+=2; } //fprintf( stderr, "aa %s %d\n", (*commands)[*commandN-1].operation, *points ); } else { (*how_many)++; //fprintf( stderr, "aa %s %d\n", (*commands)[*commandN-1].type, *how_many ); } } } } ======= video.c ======= // Licenced as per GPLv3 by HB9EIK #include "scope.h" void init_data( image_data *data ); void create_image( Widget w, image_data *data ); void resize( Widget w, image_data *data, caddr_t *call_data ); void cb( Widget scale_w, XtPointer client_data, XtPointer call_data ); void myclose( Widget scale_w, XtPointer client_data, XtPointer call_data ); void *timer( void * ); int main( int argc, char *argv[], char** envp ) { Widget toplevel, form; XtAppContext context; GC gc; image_data data; int j; void *type; char alignment; void *cbeventname; char buffer[20]; int top, bottom, left, right; int toph; char *title; Widget w, w1; otherdatap otherDatas; int commandN; commandp commands; int k, k1, k2, jj; pthread_t th; struct sched_param prio; intDatap intDatas; int DataN = 0; char *nome; int points; int how_many; data.debug = 0; nome = "video.conf"; for( j=1; j<argc; j++ ) { if( !strcmp( argv[j], "-d1" ) ) { data.debug = 1; } else if( !strcmp( argv[j], "-dd" ) ) { data.debug = 10; } else if( !strcmp( argv[j], "-f" ) ) { if( j+1 < argc ) { nome = argv[j+1]; } } } if( !XInitThreads( ) ) { printf( "Xlib not thread safe\n" ); exit( 1 ); } if( !XtToolkitThreadInitialize( ) ) { printf( "Xt not thread safe\n" ); exit( 1 ); } data.started = 0; myinitialize( &points, &how_many, nome, &data, &commandN, &commands ); toplevel = XtAppInitialize( &context, "HB9EIK", NULL, 0, &argc, argv, NULL, NULL, 0 ); data.context = context; intDatas = data.value; DataN = data.number; points *=5; points +=3; form = XtVaCreateWidget("form", xmFormWidgetClass, toplevel, XmNfractionBase, points, NULL); top = -4; bottom = 1; toph = 1; for( j=0; j<commandN; j++ ) { if( commands[j].type[0] == '1' ) { for( k=0; k<5; k++ ) { otherDatas = calloc( 1, sizeof( otherdata ) ); if( otherDatas == NULL ) { perror( "error calloc-ating otherDatas" ); exit( 1 ); } k1 = -1; myalloc( commands[j].dataname, &(k1), (char **)&intDatas, sizeof( intData ), &DataN, INT_DATAS ); otherDatas->datapointer = intDatas[k1].dataPointer; *(otherDatas->datapointer) = atoi( commands[j].value ); switch( k ) { case 0: // First widget is a label w1 = NULL; top += 5; bottom +=5; left = 0; if( strlen( commands[j].operation ) == 1 ) { right = 15; type = xmPushButtonWidgetClass; alignment = XmALIGNMENT_CENTER; cbeventname = XmNactivateCallback; otherDatas->operation = commands[j].operation[0]; otherDatas->multiplier = atoi( commands[j].multiplier ); title = calloc( strlen( commands[j].title ) +1, 1 ); strcpy( title, commands[j].title ); } else if( strlen( commands[j].operation ) == 2 ) { right = 7; type = xmPushButtonWidgetClass; alignment = XmALIGNMENT_CENTER; cbeventname = XmNactivateCallback; otherDatas->operation = commands[j].operation[0]; otherDatas->multiplier = atoi( commands[j].multiplier ); title = calloc( strlen( commands[j].title ) + 1, 1 ); for( jj=0; commands[j].title[jj] && commands[j].title[jj]!='/'; jj++ ); strcpy( title, commands[j].title+jj+1 ); } else { right = 7; type = xmLabelWidgetClass; alignment = XmALIGNMENT_BEGINNING; cbeventname = 0; title = calloc( strlen( commands[j].title ) +1, 1 ); strcpy( title, commands[j].title ); } break; case 1: // Second widget is a text if( strlen( commands[j].operation ) == 2 ) { left = 8; type = xmPushButtonWidgetClass; alignment = XmALIGNMENT_CENTER; cbeventname = XmNactivateCallback; otherDatas->operation = commands[j].operation[1]; otherDatas->multiplier = atoi( commands[j].multiplier ); title = calloc( strlen( commands[j].title ) +1, 1 ); strcpy( title, commands[j].title ); for( jj=0; title[jj] && title[jj]!='/'; jj++ ); title[jj]=0; } else { left = 7; type = xmTextWidgetClass; alignment = XmALIGNMENT_END; cbeventname = XmNvalueChangedCallback; title = ""; otherDatas->operation = ' '; } right = 15; otherDatas->multiplier = atoi( commands[j].multiplier ); break; case 2: // other widget are buttons top += 5; bottom +=5; left = 0; right = 5; type = xmPushButtonWidgetClass; alignment = XmALIGNMENT_CENTER; cbeventname = XmNactivateCallback; title = calloc( 2, 1 ); title[0] = commands[j].operation[0]; otherDatas->operation = commands[j].operation[0]; otherDatas->multiplier = atoi( commands[j].multiplier ); break; case 3: // other widget are buttons left += 5; right += 5; type = xmPushButtonWidgetClass; alignment = XmALIGNMENT_CENTER; cbeventname = XmNactivateCallback; title = calloc( 2, 1 ); title[0] = commands[j].operation[k-2]; otherDatas->operation = commands[j].operation[k-2]; otherDatas->multiplier = atoi( commands[j].value ); break; case 4: // other widget are buttons left += 5; right += 5; type = xmPushButtonWidgetClass; alignment = XmALIGNMENT_CENTER; cbeventname = XmNactivateCallback; title = calloc( 2, 1 ); title[0] = commands[j].operation[k-2]; otherDatas->operation = commands[j].operation[k-2]; otherDatas->multiplier = atoi( commands[j].multiplier ); break; } w = XtVaCreateManagedWidget ( title, type, form, XmNtopAttachment, XmATTACH_POSITION, XmNtopPosition, top, XmNbottomAttachment, XmATTACH_POSITION, XmNbottomPosition, bottom, XmNleftAttachment, XmATTACH_POSITION, XmNleftPosition, left, XmNrightAttachment, XmATTACH_POSITION, XmNrightPosition, right, XmNalignment, alignment, XmNcursorPositionVisible, False, XmNmarginHeight, 1, XmNmarginWidth, 2, NULL); if( k == 1 && strlen( commands[j].operation ) > 2 ) { // Second widget is a text w1 = w; sprintf( buffer, "%d", *(otherDatas->datapointer) ); XmTextSetString( w1, buffer ); } otherDatas->upperwidget = w1; if( cbeventname ) { XtAddCallback ( w, cbeventname, cb, otherDatas ); } if( k==0 && strlen( commands[j].operation ) == 1 ) { break; } if( k==1 && strlen( commands[j].operation ) == 2 ) { break; } } } else { w = XtVaCreateManagedWidget( commands[j].title, xmDrawingAreaWidgetClass, form, XmNheight, 25, XmNwidth, 25, XmNtopAttachment, XmATTACH_POSITION, XmNtopPosition, toph+1, XmNbottomAttachment, XmATTACH_POSITION, XmNbottomPosition, toph+(points-6)/how_many, XmNleftAttachment, XmATTACH_POSITION, XmNleftPosition, 16, XmNrightAttachment, XmATTACH_POSITION, XmNrightPosition, points-2, NULL ); XtAddCallback( w, XmNresizeCallback, (XtCallbackProc) resize, &data ); k1 = -1; myalloc( commands[j].dataname, &(k1), (char **)&intDatas, sizeof( intData ), &DataN, INT_DATAS ); intDatas[k1].dataPointer = (int *)w; toph += (points-6)/how_many+2; } } init_data( &data ); pthread_create( &th, NULL, timer, (void *)&data ); prio.sched_priority = 10; pthread_setschedparam( th, SCHED_RR, &prio ); XtManageChild(form); XtRealizeWidget( toplevel ); data.started = 1; XtAppMainLoop( context ); return( 0 ); } void init_data( image_data *data ) { int y; Arg wargs[2]; XGCValues val; int (*fn)(int); char *error; Widget schermo, spettro, cascata; schermo = (Widget)valore( data, "schermo" ); spettro = (Widget)valore( data, "spettro" ); cascata = (Widget)valore( data, "cascata" ); XtSetArg( wargs[0], XtNwidth, &data->width ); XtSetArg( wargs[1], XtNheight, &data->height ); XtGetValues( schermo, wargs, 2 ); val.line_width=1; setvalore( data, "gc", (int *)XCreateGC( XtDisplay( schermo ), DefaultRootWindow( XtDisplay( schermo ) ), (int) GCLineWidth, &val ) ); setvalore( data, "pix", (int *)NULL ); setvalore( data, "pix1", (int *)NULL ); setvalore( data, "pix2", (int *)NULL ); } void resize( Widget w, image_data *data, caddr_t *call_data ) { Arg wargs[10]; Widget schermo, spettro, cascata; Pixmap pix, pix1, pix2; GC gc; schermo = (Widget)valore( data, "schermo" ); spettro = (Widget)valore( data, "spettro" ); cascata = (Widget)valore( data, "cascata" ); pix = (Pixmap)valore( data, "pix" ); pix1 = (Pixmap)valore( data, "pix1" ); pix2 = (Pixmap)valore( data, "pix2" ); XtSetArg( wargs[0], XtNwidth, &data->width ); XtSetArg( wargs[1], XtNheight, &data->height ); XtGetValues( w, wargs, 2 ); if( XtIsRealized( w ) ) { XClearArea( XtDisplay( w ), XtWindow( w ), 0, 0, 0, 0, TRUE ); } if( schermo == w ) { if( pix ) { XFreePixmap( XtDisplay( w ), pix ); } pix = (Pixmap) setvalore( data, "pix", (int *)XCreatePixmap( XtDisplay( w ), DefaultRootWindow( XtDisplay( w ) ), data->width, data->height, DefaultDepthOfScreen( XtScreen( w ) ) ) ); } if( spettro == w ) { if( pix1 ) { XFreePixmap( XtDisplay( w ), pix1 ); } pix1 = (Pixmap) setvalore( data, "pix1", (int *)XCreatePixmap( XtDisplay( w ), DefaultRootWindow( XtDisplay( w ) ), data->width, data->height, DefaultDepthOfScreen( XtScreen( w ) ) ) ); } if( cascata == w ) { if( pix2 ) { XFreePixmap( XtDisplay( w ), pix2 ); } pix2 = (Pixmap) setvalore( data, "pix2", (int *)XCreatePixmap( XtDisplay( w ), DefaultRootWindow( XtDisplay( w ) ), data->width, data->height, DefaultDepthOfScreen( XtScreen( w ) ) ) ); gc = (GC) valore( data, "gc" ); XSetForeground( XtDisplay( w ), gc, data->background ); XFillRectangle( XtDisplay( w ), pix2, gc, 0, 0, data->width, data->height ); } } void cb( Widget w, XtPointer client_data, XtPointer call_data ) { static char value[100]; XmAnyCallbackStruct *cbs = (XmAnyCallbackStruct *) call_data; otherdatap cmd = (otherdatap) client_data; switch( cmd->operation ) { case 'R': *(cmd->datapointer) = 1 - cmd->multiplier; break; case ' ': *(cmd->datapointer) = atoi( XmTextGetString( w ) ); break; case '=': case 'S': *(cmd->datapointer) = cmd->multiplier; break; case '*': *(cmd->datapointer) *= cmd->multiplier; break; case '/': *(cmd->datapointer) /= cmd->multiplier; break; case '+': *(cmd->datapointer) += cmd->multiplier; break; case '-': *(cmd->datapointer) -= cmd->multiplier; break; } if( cmd->upperwidget != NULL && cmd->upperwidget != w ) { sprintf( value, "%d", *(cmd->datapointer) ); XmTextSetString( cmd->upperwidget, value ); } } void myclose( Widget w, XtPointer client_data, XtPointer call_data ) { image_data_ptr data = (image_data_ptr) client_data; exit( 0 ); } void * timer( void *arg ) { int status; int *wfallscan; int *dofft; image_data_ptr data; data=(image_data_ptr) arg; wfallscan = valore( data, "wfallscan" ); dofft = valore( data, "DoFFT" ); for( ;; ) { *dofft = 1; setvalore( data, "DoFFT", dofft ); if( *wfallscan < 1 ) { *wfallscan = 1; } usleep( 1000 ); dofft = (int *)valore( data, "DoFFT" ); if( *dofft==1 ) { *wfallscan /= 2; } usleep( 10000000/ *wfallscan ); } return( 0 ); } static pthread_t thread_Oscillosc; static struct sched_param prio_Oscillosc; void *thread_Oscill( void *parm ); int Oscillosc( parmp datas ) { int status; status = pthread_create( &thread_Oscillosc, NULL, thread_Oscill, (void *)datas ); if( status ) { perror( "Error creating oscilloscope read thread\n" ); exit( 1 ); } prio_Oscillosc.sched_priority = 4; pthread_setschedparam( thread_Oscillosc, SCHED_RR, &prio_Oscillosc ); return( 0 ); } void *thread_Oscill( void *parm ) { int foreground,background; Arg al[10]; int ac; int j, k; int h, w, m, n; int status; int *fftdone; static int yy = 0; image_data *data = ((parmp)parm)->data; int x, y, oldx, oldy; int min, max; static int N; static double *buf = NULL; int posit; int *fftbuffer; int *position; int *scale; int *period; int *time; Widget schermo; GC gc; Pixmap pix; for( ;; ) { for( ;; ) { if( !data->started ) { usleep( 1000 ); continue; } fftdone = (int *) valore( data, "FFTDone" ); if( *fftdone ) { break; } usleep( 1000 ); } XtAppLock( data->context ); schermo = (Widget)valore( data, "schermo" ); gc = (GC)valore( data, "gc" ); pix = (Pixmap)valore( data, "pix" ); // get the current fg and bg colors. ac = 0; XtSetArg( al[ac], XmNforeground, &foreground ); ac++; XtSetArg( al[ac], XmNbackground, &background ); ac++; XtGetValues( schermo, al, ac ); data->background = background; data->foreground = foreground; // clear the screen XSetForeground( XtDisplay( schermo ), gc, background ); XFillRectangle( XtDisplay( schermo ), pix, gc, 0, 0, data->width, data->height ); XSetForeground( XtDisplay( schermo ), gc, 50 ); h = data->height -1; w = data->width -1; m = h / 2 ; n = w / 2 ; for( j=0; j<=100; j++ ) { k = w * j / 100 ; if( j%10 ) { if( j%2 ) { XDrawLine( XtDisplay( schermo ), pix, gc, k, m-2, k, m+3 ); } else { XDrawLine( XtDisplay( schermo ), pix, gc, k, m-5, k, m+6 ); } } else { XDrawLine( XtDisplay( schermo ), pix, gc, k, 1, k, h ); } } for( j=0; j<=10; j++ ) { k = h * j / 10; XDrawLine( XtDisplay( schermo ), pix, gc, 0, k, w+1, k ); } for( j=0; j<=50; j++ ) { k = h * j / 50; if( j%2 ) { XDrawLine( XtDisplay( schermo ), pix, gc, n-2, k, n+3, k ); } else { XDrawLine( XtDisplay( schermo ), pix, gc, n-5, k, n+6, k ); } } fftbuffer = valore( data, "fftbuffer" ); position = valore( data, "position" ); scale = valore( data, "scale" ); period = valore( data, "period" ); time = valore( data, "time" ); N = 1 << *fftbuffer; k=0; oldx = 0; oldy = data->height * (128 - *position) / 256 ; posit=(*(((parmp)parm)->inFilePosition)-N+FIFO_LENGTH)% FIFO_LENGTH; if( buf == NULL ) { buf = calloc( FIFO_LENGTH, sizeof( double ) ); if( buf == NULL ) { fprintf( stderr, "Error allocating %d bytes fo oscilloscope buffer\n", FIFO_LENGTH ); exit( 1 ); } } for( k=0; k<N; k++ ) { buf[k]=((parmp)parm)->inFileLocation[posit]; posit++; posit %= FIFO_LENGTH; } min=buf[0]; max=buf[0]; for( k=0; k< N; k++ ) { if( min > buf[k] ) { min = buf[k]; } if( max < buf[k] ) { max = buf[k]; } } k = 0; for( k=0; k< N; k++ ) { if( buf[k]<0.0 && buf[k+1]>0.0 ) { break; } } if( k== N ) { k = 0; } XSetForeground( XtDisplay( schermo ), gc, data->foreground ); for( j=0; j< N/2 && j+k < N; j++ ) { y = -(data->height * buf[j+k] * *scale / 4096 / 256 / 256 ) + ( data->height / 2 ) - (data->height * *position / 128) ; x = ( data->width / 5 ) * j * *period / N - data->width * *time * *period / 100 ; if( x < data->width && x > 0 ) { XDrawLine( XtDisplay( schermo ), pix, gc, oldx, oldy, x, y ); } oldx=x; oldy=y; } XCopyArea( XtDisplay( schermo ), pix, XtWindow( schermo ), gc, 0, 0, data->width, data->height, 0, 0 ); XtAppUnlock( data->context ); usleep( 10000 ); *fftdone = 0; setvalore( data, "FFTDone", (int *)fftdone ); } return( NULL ); } static pthread_t thread_Spectre; static struct sched_param prio_Spectre; void *thread_Spectr( void *parm ); int Spectre( parmp datas ) { int status; status = pthread_create( &thread_Spectre, NULL, thread_Spectr, (void *)datas ); if( status ) { perror( "Error creating spectrum read thread\n" ); exit( 1 ); } prio_Spectre.sched_priority = 4; pthread_setschedparam( thread_Spectre, SCHED_RR, &prio_Spectre ); return( 0 ); } void *thread_Spectr( void *parm ) { int foreground,background; Arg al[10]; int ac; int j, k; int h, w, m, n; int *fftdone; static int yy = 0; image_data *data = ((parmp)parm)->data; int x, y, oldx, oldy; static int N; static double ymax; static double *fftr = NULL; int *fftbuffer; int *period; int *time; int *holdlevel; int *logscale; int *threshold; int *band; int *channel; Widget spettro; GC gc; Pixmap pix1; for( ;; ) { for( ;; ) { if( !data->started ) { usleep( 1000 ); continue; } fftdone = (int *)valore( data, "FFTDone" ); if( *fftdone ) { break; } usleep( 1000 ); } XtAppLock( data->context ); spettro = (Widget)valore( data, "spettro" ); gc = (GC)valore( data, "gc" ); pix1 = (Pixmap)valore( data, "pix1" ); // get the current fg and bg colors. ac = 0; XtSetArg( al[ac], XmNforeground, &foreground ); ac++; XtSetArg( al[ac], XmNbackground, &background ); ac++; XtGetValues( spettro, al, ac ); data->background = background; data->foreground = foreground; // clear the screen XSetForeground( XtDisplay( spettro ), gc, background ); XFillRectangle( XtDisplay( spettro ), pix1, gc, 0, 0, data->width, data->height ); XSetForeground( XtDisplay( spettro ), gc, 50 ); h = data->height -1; w = data->width -1; m = h / 2 ; n = w / 2 ; for( j=0; j<=100; j++ ) { k = w * j / 100 ; if( !(j%10) ) { XDrawLine( XtDisplay( spettro ), pix1, gc, k, 1, k, h ); } } for( j=0; j<=10; j++ ) { k = h * j / 10; XDrawLine( XtDisplay( spettro ), pix1, gc, 0, k, w+1, k ); } fftbuffer = valore( data, "fftbuffer" ); period = valore( data, "period" ); time = valore( data, "time" ); holdlevel = valore( data, "holdlevel" ); logscale = valore( data, "logscale" ); threshold = valore( data, "threshold" ); band = valore( data, "band" ); channel = valore( data, "channel" ); N = 1 << *fftbuffer; k=0; if( *holdlevel ) { *holdlevel = 0; data->maxlevel = ymax; } else { ymax = data->maxlevel; } XSetForeground( XtDisplay( spettro ), gc, foreground ); if( *logscale ) { XDrawLine( XtDisplay( spettro ), pix1, gc, 0, data->height*log( 100/ *threshold )/log(10)/10, data->width+1, data->height*log( 100/ *threshold )/log(10)/10 ); } else { XDrawLine( XtDisplay( spettro ), pix1, gc, 0, data->height * ( 100 - *threshold ) / 100 , data->width+1, data->height * ( 100 - *threshold ) / 100 ); } fftr=((parmp)parm)->inFileLocation+*(((parmp)parm)->inFilePosition)-N; for( j=1, ymax=fftr[0]; j<N; j++ ) { if( ymax < fftr[j] ) { ymax = fftr[j]; } } oldx=0; oldy=data->height - fftr[0] * data->height / ymax; for( j=0; j< N/2 ; j++ ) { if( *logscale ) { y = data->height * log( ymax / fftr[j] ) / 10 / log(10); if( y > data->height - 2 ) { y = data -> height - 2 ; } } else { y = data->height - 2 - fftr[j] * ( data->height -2 ) / ymax; } x = 1.0 * data->width * j * *band / N / 5 - 1.0 * data->width * *band * *channel / 1000 ;; if( x >= 0 && x <= data->width ) { XDrawLine( XtDisplay( spettro ), pix1, gc, oldx, oldy, x, y ); } oldx=x; oldy=y; } XCopyArea( XtDisplay( spettro ), pix1, XtWindow( spettro ), gc, 0, 0, data->width, data->height, 0, 0 ); XtAppUnlock( data->context ); usleep( 10000 ); } return( NULL ); } static pthread_t thread_Waterfall; static struct sched_param prio_Waterfall; void *thread_Waterf( void *parm ); int Waterfall( parmp datas ) { int status; status = pthread_create( &thread_Waterfall, NULL, thread_Waterf, (void *)datas ); if( status ) { perror( "Error creating waterfall read thread\n" ); exit( 1 ); } prio_Waterfall.sched_priority = 4; pthread_setschedparam( thread_Waterfall, SCHED_RR, &prio_Waterfall ); return( 0 ); } void *thread_Waterf( void *parm ) { int foreground,background; Arg al[10]; int ac; int j, k; int h, w, m, n; int status; int *fftdone; static int yy = 0; image_data *data = ((parmp)parm)->data; int x, y, oldx, oldy; static int N; static double ymax; static double *fftr = NULL; int color; int *fftbuffer; int *holdlevel; int *logscale; int *threshold; int *band; int *channel; Widget cascata; GC gc; Pixmap pix2; for( ;; ) { for( ;; ) { if( !data->started ) { usleep( 1000 ); continue; } fftdone = (int *)valore( data, "FFTDone" ); if( *fftdone ) { break; } usleep( 1000 ); } XtAppLock( data->context ); cascata = (Widget) valore( data, "cascata" ); gc = (GC) valore( data, "gc" ); pix2 = (Pixmap) valore( data, "pix2" ); // get the current fg and bg colors. ac = 0; XtSetArg( al[ac], XmNforeground, &foreground ); ac++; XtSetArg( al[ac], XmNbackground, &background ); ac++; XtGetValues( cascata, al, ac ); data->background = background; data->foreground = foreground; // clear the screen XSetForeground( XtDisplay( cascata ), gc, background ); XSetForeground( XtDisplay( cascata ), gc, 50 ); h = data->height -1; w = data->width -1; m = h / 2 ; n = w / 2 ; for( j=0; j<=100; j++ ) { k = w * j / 100 ; if( !(j%10) ) { XDrawLine( XtDisplay( cascata ), pix2, gc, k, 1, k, h ); } } XDrawLine( XtDisplay( cascata ), pix2, gc, 0, 0, w+1, 0 ); fftbuffer = valore( data, "fftbuffer" ); holdlevel = valore( data, "holdlevel" ); logscale = valore( data, "logscale" ); threshold = valore( data, "threshold" ); band = valore( data, "band" ); channel = valore( data, "channel" ); N = 1 << *fftbuffer; fftr=((parmp)parm)->inFileLocation+*(((parmp)parm)->inFilePosition)-N; for( j=1, ymax=fftr[0]; j<N; j++ ) { if( ymax < fftr[j] ) { ymax = fftr[j]; } } XCopyArea( XtDisplay( cascata ), pix2, pix2, gc, 0, 2, data->width, data->height-2, 0, 1 ); oldx=0; oldy=data->height - fftr[0] * data->height / ymax; for( j=0; j< N/2 ; j++ ) { if( fftr[j] * 100 / ymax < *threshold || *threshold > 100 ) { color = data->background; if( *logscale ) { color = 2047 + 600 * log( fftr[j] / ymax ) / log(10); } else { color = 2047 * fftr[j] / ymax; } if( color < 0 ) color = 0; if( color > 2047 ) color = 2047; } else { color = data->foreground; } y = data->height - 2 - fftr[j] * data->height / ymax; y = data->height - 2; XSetForeground( XtDisplay( cascata ), gc, color ); x = 1.0 * data->width * j * *band / N / 5 - 1.0 * data->width * *band * *channel / 1000 ;; if( x >= 0 && x <= data->width ) { XDrawLine( XtDisplay( cascata ), pix2, gc, oldx, oldy, x, y ); } oldx=x; oldy=y; } XCopyArea( XtDisplay( cascata ), pix2, XtWindow( cascata ), gc, 0, 0, data->width, data->height, 0, 0 ); XtAppUnlock( data->context ); usleep( 10000 ); *fftdone = 0; // setvalore( data, "FFTDone", (int *)fftdone ); } return( NULL ); } ========== video.conf ========== #1:dataPreload:name,value 1,scale,16 1,position,0 1,period,20 1,length,480 1,time,0 1,logscale,1 1,fftbuffer,12 1,band,10 1,channel,0 1,threshold,101 1,debug,0 1,wfallscan,100 1,holdlevel,1 1,DoFFT,0 1,FFTDone,0 1,spettro, 1,schermo, 1,cascata, 1,gc, 1,pix, 1,pix1, 1,pix2, #2:function:name,file_in,chunk,file_out,library,function,event_in,event_out 2,Input,/dev/dsp,length,DigiInput,libMyIo.so,DspIn,,IFRdy 2,FFT,DigiInput,fftbuffer,FFTOutput,libMyMath.so,FFT,DoFFT,FFTDone 2,Oscilloscope,DigiInput,,,,Oscillosc,FFTDone 2,Spectrum,FFTOutput,,,,Spectre,FFTDone 2,Waterfall,FFTOutput,,,,Waterfall,FFTDone 2,Output,DigiInput,length,/dev/dsp,libMyIo.so,DspOut,IFRdy #3:commands:type,name,data,increment,default,operations 3,1,V.Gain,scale,2,16,*=/ 3,1,V.Pos.,position,1,0,+=- 3,1,H.Time,period,2,20,*=/ 3,1,H.Pos.,time,1,0,+=- 3,1,Lin/Log,logscale,1,1,SR 3,1,FFT Pt,fftbuffer,1,12,+=- 3,1,F.Span,band,2,10,*=/ 3,1,Freq.,channel,1,0,+=- 3,1,Thresh,threshold,1,101,+=- 3,1,Scan,wfallscan,2,100,*=/ 3,1,Hold,holdlevel,1,1,= 3,2,Schermo,schermo,,, 3,2,Spettro,spettro,,, 3,2,Cascata,cascata,,, =========== oscill.conf =========== #1:dataPreload:name,value 1,scale,16 1,position,0 1,period,20 1,length,480 1,time,0 1,logscale,1 1,fftbuffer,12 1,band,10 1,channel,0 1,threshold,101 1,debug,0 1,wfallscan,100 1,holdlevel,1 1,DoFFT,0 1,FFTDone,0 1,spettro, 1,schermo, 1,cascata, 1,gc, 1,pix, 1,pix1, 1,pix2, #2:function:name,file_in,chunk,file_out,library,function,event_in,event_out 2,Input,/dev/dsp,length,DigiInput,libMyIo.so,DspIn,,IFRdy 2,FFT,DigiInput,fftbuffer,FFTOutput,libMyMath.so,FFT,DoFFT,FFTDone 2,Oscilloscope,DigiInput,,,,Oscillosc,FFTDone #2,Spectrum,FFTOutput,,,,Spectre,FFTDone #2,Waterfall,FFTOutput,,,,Waterfall,FFTDone 2,Output,DigiInput,length,/dev/dsp,libMyIo.so,DspOut,IFRdy #3:commands:type,name,data,increment,default,operations 3,1,V.Gain,scale,2,16,*=/ 3,1,V.Pos.,position,1,0,+=- 3,1,H.Time,period,2,20,*=/ 3,1,H.Pos.,time,1,0,+=- #3,1,Lin/Log,logscale,1,1,SR 3,1,Length,fftbuffer,1,12,+=- #3,1,F.Span,band,2,10,*=/ #3,1,Freq.,channel,1,0,+=- #3,1,Thresh,threshold,1,101,+=- #3,1,Scan,wfallscan,2,100,*=/ #3,1,Hold,holdlevel,1,1,= 3,2,Schermo,schermo,,, #3,2,Spettro,spettro,,, #3,2,Cascata,cascata,,,						2011-07-28 Perseus Demo in Ligornetto Tnx HB9OAR / HB9TUZ 2011-06-12 OpenGL Radio Interface Proof of concept, see Projects, Code 2010-06-18 Rewrite MyLinScope V 4.0 Configuration from file, threaded X 2008-05-22 First ,MyLinScope release First MyLinScope code release, see projects and photos sections